[flink] branch release-1.15 updated: [FLINK-27999][hive] Fix Hive3 VirtualColumn NoSuchMethodError

[chesnay]

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

chesnay pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.15 by this push:
     new 90b8e82ee8a [FLINK-27999][hive] Fix Hive3 VirtualColumn 
NoSuchMethodError
90b8e82ee8a is described below

commit 90b8e82ee8a868864e65e63076fd723bdc9796d9
Author: luoyuxia <luoyu...@alumni.sjtu.edu.cn>
AuthorDate: Tue Jun 14 16:28:57 2022 +0800

    [FLINK-27999][hive] Fix Hive3 VirtualColumn NoSuchMethodError
    
    VirtualColumn.VIRTUAL_COLUMN_NAMES has a different type in hive2 vs hive3, 
causing NoSuchFieldErrors since our code is only compiled against hive2
---
 .../planner/delegation/hive/copy/HiveParserBaseSemanticAnalyzer.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/copy/HiveParserBaseSemanticAnalyzer.java
 
b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/copy/HiveParserBaseSemanticAnalyzer.java
index c277781fdde..b4e6d4d4672 100644
--- 
a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/copy/HiveParserBaseSemanticAnalyzer.java
+++ 
b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/copy/HiveParserBaseSemanticAnalyzer.java
@@ -387,7 +387,9 @@ public class HiveParserBaseSemanticAnalyzer {
     }
 
     private static void checkColumnName(String columnName) throws 
SemanticException {
-        if 
(VirtualColumn.VIRTUAL_COLUMN_NAMES.contains(columnName.toUpperCase())) {
+        ColumnInfo columnInfo = new ColumnInfo();
+        columnInfo.setAlias(columnName);
+        if (VirtualColumn.isVirtualColumnBasedOnAlias(columnInfo)) {
             throw new SemanticException("Invalid column name " + columnName);
         }
     }