commit ffc740573e59cd1ba8549f8e7db40e7509882e38
author slinkydeveloper <francescoguard@gmail.com> Wed Nov 03 11:40:40 2021 +0100
committer Sergey Nuyanzin <snuyanzin@gmail.com> Fri Dec 08 15:58:26 2023 +0100
tree e315cc0827844827c05a8adc37b7943aa712407c
parent 56abba4ab307b92a75b8363adf838f5bf609e98b

[FLINK-24747][table] Let SupportsProjectionPushDown#applyProjection provide the projected data type

Signed-off-by: slinkydeveloper <francescoguard@gmail.com>

This closes #17662.

flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSource.java

diff --git a/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSource.java b/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSource.java
index 67c5373..370ccdc 100644
--- a/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSource.java
+++ b/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSource.java
@@ -226,7 +226,7 @@
     }
 
     @Override
-    public void applyProjection(int[][] projectedFields) {
+    public void applyProjection(int[][] projectedFields, DataType producedDataType) {
         this.projectedFields = Arrays.stream(projectedFields).mapToInt(value -> value[0]).toArray();
     }