This is an automated email from the ASF dual-hosted git repository.

twalthr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 745cfec705b4a884a7ccd4240ea817704aaf7267
Author: Timo Walther <twal...@apache.org>
AuthorDate: Tue Jan 18 13:51:39 2022 +0100

    [hotfix][table-common] Fix InternalDataUtils for MapData tests
---
 .../src/test/java/org/apache/flink/table/test/InternalDataUtils.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-table/flink-table-common/src/test/java/org/apache/flink/table/test/InternalDataUtils.java
 
b/flink-table/flink-table-common/src/test/java/org/apache/flink/table/test/InternalDataUtils.java
index 8abd316..5250d57 100644
--- 
a/flink-table/flink-table-common/src/test/java/org/apache/flink/table/test/InternalDataUtils.java
+++ 
b/flink-table/flink-table-common/src/test/java/org/apache/flink/table/test/InternalDataUtils.java
@@ -103,7 +103,7 @@ class InternalDataUtils {
                         : ((MapType) logicalType).getValueType();
 
         final ArrayData.ElementGetter keyGetter = 
ArrayData.createElementGetter(keyType);
-        final ArrayData.ElementGetter valueGetter = 
ArrayData.createElementGetter(keyType);
+        final ArrayData.ElementGetter valueGetter = 
ArrayData.createElementGetter(valueType);
 
         final ArrayData keys = mapData.keyArray();
         final ArrayData values = mapData.valueArray();

Reply via email to