Skip to content

Commit 7907aae

Browse files
committed
Remove reflective invocation of emitPeriodicWatermark in MixedFormatSourceReader
1 parent 0f4a8b5 commit 7907aae

1 file changed

Lines changed: 0 additions & 13 deletions

File tree

amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/read/hybrid/reader/MixedFormatSourceReader.java

Lines changed: 0 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -195,19 +195,6 @@ private void emitPeriodicWatermark(SourceOutput<T> splitOutput) {
195195
return;
196196
}
197197

198-
try {
199-
java.lang.reflect.Method method =
200-
splitOutput.getClass().getDeclaredMethod("emitPeriodicWatermark");
201-
method.setAccessible(true);
202-
method.invoke(splitOutput);
203-
return;
204-
} catch (ReflectiveOperationException e) {
205-
LOGGER.debug(
206-
"Failed to invoke emitPeriodicWatermark on split output {}, fallback to reader output",
207-
splitOutput.getClass(),
208-
e);
209-
}
210-
211198
watermarkOutput.emitPeriodicWatermark();
212199
}
213200
}

0 commit comments

Comments
 (0)