aljoscha commented on a change in pull request #12674:
URL: https://github.com/apache/flink/pull/12674#discussion_r440774298
##########
File path:
flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/main/java/org/apache/flink/tests/util/kafka/LocalStandaloneKafkaResource.java
##########
@@ -214,7 +225,7 @@ private static void queryBrokerStatus(final Path kafkaDir,
final Consumer<String
ZOOKEEPER_ADDRESS,
"get",
"/brokers/ids/0")
- .setStderrProcessor(stderrProcessor)
+ .setStdoutProcessor(stderrProcessor)
Review comment:
No, the output is very different. Before we were using the debug output
that happened to be printed to stderr, even in case of no errors. Now we just
use the regular, expected output of the command. This works with all the older
versions as well, the code just didn't do it.
----------------------------------------------------------------
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:
[email protected]
