This is an automated email from the ASF dual-hosted git repository.
danny0405 pushed a commit to branch branch-0.x
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/branch-0.x by this push:
new 8e35db80ef1 [HUDI-7828][branch-0.x] Support Flink 1.18.1 (#11393)
8e35db80ef1 is described below
commit 8e35db80ef15b17bf130ba6d8b22c76789601e7c
Author: Shawn Chang <[email protected]>
AuthorDate: Wed Jun 5 01:55:19 2024 -0700
[HUDI-7828][branch-0.x] Support Flink 1.18.1 (#11393)
Co-authored-by: Shawn Chang <[email protected]>
---
.../hudi/table/format/cow/vector/reader/AbstractColumnReader.java | 2 +-
pom.xml | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/AbstractColumnReader.java
b/hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/AbstractColumnReader.java
index a8b733de636..556375351cf 100644
---
a/hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/AbstractColumnReader.java
+++
b/hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/AbstractColumnReader.java
@@ -192,7 +192,7 @@ public abstract class AbstractColumnReader<V extends
WritableColumnVector>
// Column vector supports lazy decoding of dictionary values so just
set the dictionary.
// We can't do this if rowId != 0 AND the column doesn't have a
dictionary (i.e. some
// non-dictionary encoded values have already been added).
- vector.setDictionary(new ParquetDictionary(dictionary));
+ vector.setDictionary(new ParquetDictionary(dictionary, descriptor));
} else {
readBatchFromDictionaryIds(rowId, num, vector, dictionaryIds);
}
diff --git a/pom.xml b/pom.xml
index 5fcf4c8fcb1..935af737faf 100644
--- a/pom.xml
+++ b/pom.xml
@@ -140,7 +140,7 @@
<spark2.version>2.4.4</spark2.version>
<spark3.version>3.5.1</spark3.version>
<sparkbundle.version></sparkbundle.version>
- <flink1.18.version>1.18.0</flink1.18.version>
+ <flink1.18.version>1.18.1</flink1.18.version>
<flink1.17.version>1.17.1</flink1.17.version>
<flink1.16.version>1.16.2</flink1.16.version>
<flink1.15.version>1.15.1</flink1.15.version>
