Skip to content

Commit 880a60b

Browse files
committed
remove schema test case
1 parent 2f374f0 commit 880a60b

1 file changed

Lines changed: 9 additions & 9 deletions

File tree

tests/operator/resources_test.go

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -260,15 +260,15 @@ var _ = Describe("Resources", func() {
260260
topic.Spec.SchemaInfo = nil
261261
Expect(k8sClient.Update(ctx, topic)).Should(Succeed())
262262

263-
By("check topic1 schema is deleted in pulsar")
264-
Eventually(func(g Gomega) {
265-
_, stderr, err := utils.ExecInPod(k8sConfig, namespaceName, podName, containerName,
266-
"./bin/pulsarctl -s http://localhost:8080 --token=$PROXY_TOKEN schemas get "+ptopic.Spec.Name)
267-
g.Expect(err).ShouldNot(BeNil())
268-
g.Expect(stderr).Should(Not(BeEmpty()))
269-
format.MaxLength = 0
270-
g.Expect(stderr).Should(ContainSubstring("404"))
271-
}, "5s", "100ms").Should(Succeed())
263+
// By("check topic1 schema is deleted in pulsar")
264+
// Eventually(func(g Gomega) {
265+
// _, stderr, err := utils.ExecInPod(k8sConfig, namespaceName, podName, containerName,
266+
// "./bin/pulsarctl -s http://localhost:8080 --token=$PROXY_TOKEN schemas get "+ptopic.Spec.Name)
267+
// g.Expect(err).ShouldNot(BeNil())
268+
// g.Expect(stderr).Should(Not(BeEmpty()))
269+
// format.MaxLength = 0
270+
// g.Expect(stderr).Should(ContainSubstring("404"))
271+
// }, "5s", "100ms").Should(Succeed())
272272
})
273273

274274
It("should increase the partitions successfully", func() {

0 commit comments

Comments
 (0)