Hey all (but mostly the streaming folks), while refactoring the writers for the runtime changes (FLINK-986) I discovered a possible race condition in StreamRecordWriter [1].
The problem is that the record writer is not thread-safe, but both the streaming task vertex and the OutputFlusher thread use it concurrently. Am I overlooking something and is it safe to use it this way? If not: should I ensure that record writer is thread-safe with my upcoming changes? – Ufuk [1] https://github.com/apache/incubator-flink/blob/b904b0041cf97b2c6181b1985afc457ed01cf626/flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/io/StreamRecordWriter.java
