Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4775#discussion_r143162433
--- Diff:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java
---
@@ -121,10 +122,13 @@ public static void shutDownServices() throws
Exception {
protected static Configuration getFlinkConfiguration() {
Configuration flinkConfig = new Configuration();
+ flinkConfig.setString(AkkaOptions.WATCH_HEARTBEAT_PAUSE, "5 s");
+ flinkConfig.setString(AkkaOptions.WATCH_HEARTBEAT_INTERVAL, "1
s");
+ flinkConfig.setBoolean(AkkaOptions.LOG_LIFECYCLE_EVENTS, true);
--- End diff --
Yes sure, I forgot to drop it, it was only for debug purposes
---
