gaborgsomogyi commented on PR #21247: URL: https://github.com/apache/flink/pull/21247#issuecomment-1305458387
All in all we have multiple issues stacked up: * Creating the same topic exception was ignored via bad Kafka API usage (missing future wait) * Topics are not deleted in tests (which makes sense in case of exception) * Somehow the producer is not super happy and throwing timeout exception (this may be a Kafka which requires huge amount of time to debug) I think the actual code should resolve the first 2 issues, the third may or may not disappear :/ Hope it will pass, such case we can just remove timeouts and ship 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
