[GitHub] [pulsar] jerrypeng commented on a change in pull request #3909: Using Auto Consume consumer on a topic that doesn't have a schema doesn't work

[GitBox <gi...@apache.org>]

jerrypeng commented on a change in pull request #3909: Using Auto Consume consumer on a topic that doesn't have a schema doesn't work
URL: https://github.com/apache/pulsar/pull/3909#discussion_r269407480
 
 

 ##########
 File path: tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarFunctionsTest.java
 ##########
 @@ -1121,8 +1123,9 @@ public void testAutoSchemaFunction() throws Exception {
         // publish and consume result
         publishAndConsumeAvroMessages(inputTopicName, outputTopicName, numMessages);
 
-        // get function status
-        getFunctionStatus(functionName, numMessages);
+        // get function status. Note that this function might restart a few times until
+        // the producer above writes the messages.
+        getFunctionStatus(functionName, numMessages, false);
 
 Review comment:
   why will this restart a couple of times? That doesn't sound like the correct behavior

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services