This is an automated email from the ASF dual-hosted git repository. pnowojski pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 4c8e9a4c61930436b607c1541779a7294aa4e0f7 Author: fanrui <[email protected]> AuthorDate: Wed Jun 29 11:35:08 2022 +0800 [hotfix] Fix the generic of RecordWriter --- .../flink/runtime/io/network/api/writer/MultipleRecordWriters.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/MultipleRecordWriters.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/MultipleRecordWriters.java index 60da2de1775..cfcf702eb3c 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/MultipleRecordWriters.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/MultipleRecordWriters.java @@ -49,7 +49,7 @@ public class MultipleRecordWriters<T extends IOReadableWritable> @Override public void broadcastEvent(AbstractEvent event) throws IOException { IOException exception = null; - for (RecordWriter recordWriter : recordWriters) { + for (RecordWriter<T> recordWriter : recordWriters) { try { recordWriter.broadcastEvent(event); } catch (IOException e) { @@ -80,7 +80,7 @@ public class MultipleRecordWriters<T extends IOReadableWritable> @Override public boolean isAvailable() { - for (RecordWriter recordWriter : recordWriters) { + for (RecordWriter<T> recordWriter : recordWriters) { if (!recordWriter.isAvailable()) { return false; } @@ -90,7 +90,7 @@ public class MultipleRecordWriters<T extends IOReadableWritable> @Override public void close() { - for (RecordWriter recordWriter : recordWriters) { + for (RecordWriter<T> recordWriter : recordWriters) { recordWriter.close(); } }
