Skip to content

Commit 7d2ae99

Browse files
author
gepa
committed
Fix compilation error in JdbcExecutor.executeSinkStage
The executeSinkStage method introduced in #750 declared filterTasks and joinTasks as Collection<JdbcFilterOperator> and Collection<JdbcJoinOperator<?>> respectively, but passed them to createSqlString() which expects Collection<JdbcExecutionOperator>. Java generics are invariant so this caused a compilation failure. Fixed by widening both local variable declarations to Collection<JdbcExecutionOperator>, matching the existing pattern in the adjacent executeQueryStage method.
1 parent 4d8d5b7 commit 7d2ae99

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

  • wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/execution

wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/execution/JdbcExecutor.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -129,9 +129,9 @@ private static void executeSinkStage(final ExecutionStage stage,
129129
// Extract operators from the stage
130130
final JdbcTableSource tableOp = (JdbcTableSource) startTask.getOperator();
131131
final JdbcTableSinkOperator sinkOp = (JdbcTableSinkOperator) termTask.getOperator();
132-
final Collection<JdbcFilterOperator> filterTasks = new ArrayList<>(4);
132+
final Collection<JdbcExecutionOperator> filterTasks = new ArrayList<>(4);
133133
JdbcProjectionOperator projectionTask = null;
134-
final Collection<JdbcJoinOperator<?>> joinTasks = new ArrayList<>();
134+
final Collection<JdbcExecutionOperator> joinTasks = new ArrayList<>();
135135

136136
// Walk through intermediate operators, stopping at the sink
137137
ExecutionTask nextTask = JdbcExecutor.findJdbcExecutionOperatorTaskInStage(startTask, stage);

0 commit comments

Comments
 (0)