dawidwys commented on a change in pull request #17471:
URL: https://github.com/apache/flink/pull/17471#discussion_r728713197
##########
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java
##########
@@ -105,9 +105,7 @@
private static final Logger LOG =
LoggerFactory.getLogger(StreamingJobGraphGenerator.class);
- private static final long DEFAULT_NETWORK_BUFFER_TIMEOUT = 100L;
-
- public static final long UNDEFINED_NETWORK_BUFFER_TIMEOUT = -1L;
+ public static final long DISABLED_NETWORK_BUFFER_TIMEOUT = -1L;
Review comment:
I don't know if it is a good idea. There were concerns in the past that
`flink-streaming-java` should not depend on the `flink-runtime`. It should
rather be the opposite.
Therefore I am a bit skeptical about using a constant from `RecordWriter` in
`StreamingJobGraphGenerator`.
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
