Skip to content

Commit d530291

Browse files
committed
Fix compile.
1 parent d62196a commit d530291

1 file changed

Lines changed: 3 additions & 1 deletion

File tree

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/testsource/AppendOnlyTableSourceFunction.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -107,7 +107,9 @@ public void open(Configuration parameters) throws Exception {
107107
}
108108

109109
@Override
110-
public void run(SourceContext<Event> context) {
110+
public void run(
111+
org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<Event>
112+
context) {
111113
// Emit all events in the first subtask
112114
if (getRuntimeContext().getTaskInfo().getIndexOfThisSubtask() == 0) {
113115
for (Event event : testEventList) {

0 commit comments

Comments
 (0)