You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2022/06/29 14:04:06 UTC
[flink] 01/02: [hotfix] Fix the generic of RecordWriter
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 <19...@gmail.com>
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();
}
}