From 7d2ae9982a6c8cfa2e19e85f6f5bdf4b916326f1 Mon Sep 17 00:00:00 2001
From: gepa <gepa@itu.dk>
Date: Wed, 20 May 2026 19:44:15 +0200
Subject: [PATCH] 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.
---
 .../java/org/apache/wayang/jdbc/execution/JdbcExecutor.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/execution/JdbcExecutor.java b/wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/execution/JdbcExecutor.java
index 11076b77f..c193704a3 100644
--- a/wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/execution/JdbcExecutor.java
+++ b/wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/execution/JdbcExecutor.java
@@ -129,9 +129,9 @@ private static void executeSinkStage(final ExecutionStage stage,
         // Extract operators from the stage
         final JdbcTableSource tableOp = (JdbcTableSource) startTask.getOperator();
         final JdbcTableSinkOperator sinkOp = (JdbcTableSinkOperator) termTask.getOperator();
-        final Collection<JdbcFilterOperator> filterTasks = new ArrayList<>(4);
+        final Collection<JdbcExecutionOperator> filterTasks = new ArrayList<>(4);
         JdbcProjectionOperator projectionTask = null;
-        final Collection<JdbcJoinOperator<?>> joinTasks = new ArrayList<>();
+        final Collection<JdbcExecutionOperator> joinTasks = new ArrayList<>();
 
         // Walk through intermediate operators, stopping at the sink
         ExecutionTask nextTask = JdbcExecutor.findJdbcExecutionOperatorTaskInStage(startTask, stage);