夏帅 created FLINK-17964:
--------------------------
Summary: Hivemodule does not support map type
Key: FLINK-17964
URL: https://issues.apache.org/jira/browse/FLINK-17964
Project: Flink
Issue Type: Bug
Components: Connectors / Hive
Affects Versions: 1.10.1
Reporter: 夏帅
Fix For: 1.12.0, 1.11.1
{code:java}
//代码占位符
Exception in thread "main" scala.MatchError: MAP (of class
org.apache.flink.table.types.logical.LogicalTypeRoot)Exception in thread "main"
scala.MatchError: MAP (of class
org.apache.flink.table.types.logical.LogicalTypeRoot) at
org.apache.flink.table.planner.codegen.CodeGenUtils$.hashCodeForType(CodeGenUtils.scala:212)
at
org.apache.flink.table.planner.codegen.HashCodeGenerator$$anonfun$2.apply(HashCodeGenerator.scala:97)
at
org.apache.flink.table.planner.codegen.HashCodeGenerator$$anonfun$2.apply(HashCodeGenerator.scala:91)
at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
at
scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
at scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:35) at
scala.collection.TraversableLike$class.map(TraversableLike.scala:234) at
scala.collection.AbstractTraversable.map(Traversable.scala:104) at
org.apache.flink.table.planner.codegen.HashCodeGenerator$.generateCodeBody(HashCodeGenerator.scala:91)
at
org.apache.flink.table.planner.codegen.HashCodeGenerator$.generateRowHash(HashCodeGenerator.scala:61)
at
org.apache.flink.table.planner.plan.nodes.physical.batch.BatchExecExchange.translateToPlanInternal(BatchExecExchange.scala:182)
at
org.apache.flink.table.planner.plan.nodes.physical.batch.BatchExecExchange.translateToPlanInternal(BatchExecExchange.scala:52)
at
org.apache.flink.table.planner.plan.nodes.exec.ExecNode$class.translateToPlan(ExecNode.scala:58)
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
