hi????????hive??????????????sql??????like????????????????????????
??????
org.apache.flink.table.planner.codegen.CodeGenException: Unsupported call:
like(VARCHAR(255), STRING NOT NULL)
org.apache.flink.table.planner.codegen.CodeGenException: Unsupported call:
like(STRING, STRING NOT NULL)
If you think this function should be supported, you can create an issue and
start a discussion for it.
at
org.apache.flink.table.planner.codegen.ExprCodeGenerator$$anonfun$generateCallExpression$5$$anonfun$apply$2.apply(ExprCodeGenerator.scala:845)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.codegen.ExprCodeGenerator$$anonfun$generateCallExpression$5$$anonfun$apply$2.apply(ExprCodeGenerator.scala:845)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at scala.Option.getOrElse(Option.scala:121)
~[flink-dist_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.codegen.ExprCodeGenerator$$anonfun$generateCallExpression$5.apply(ExprCodeGenerator.scala:844)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.codegen.ExprCodeGenerator$$anonfun$generateCallExpression$5.apply(ExprCodeGenerator.scala:849)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at scala.Option.getOrElse(Option.scala:121)
~[flink-dist_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.codegen.ExprCodeGenerator.generateCallExpression(ExprCodeGenerator.scala:837)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.codegen.ExprCodeGenerator.visitCall(ExprCodeGenerator.scala:529)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.codegen.ExprCodeGenerator.visitCall(ExprCodeGenerator.scala:56)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at org.apache.calcite.rex.RexCall.accept(RexCall.java:174)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.codegen.ExprCodeGenerator.generateExpression(ExprCodeGenerator.scala:155)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.codegen.CalcCodeGenerator$.generateProcessCode(CalcCodeGenerator.scala:173)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.codegen.CalcCodeGenerator$.generateCalcOperator(CalcCodeGenerator.scala:50)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.codegen.CalcCodeGenerator.generateCalcOperator(CalcCodeGenerator.scala)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecCalc.translateToPlanInternal(CommonExecCalc.java:94)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:134)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:247)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecSink.translateToPlanInternal(BatchExecSink.java:58)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:134)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.delegation.BatchPlanner$$anonfun$translateToPlan$1.apply(BatchPlanner.scala:80)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.delegation.BatchPlanner$$anonfun$translateToPlan$1.apply(BatchPlanner.scala:79)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
~[flink-dist_2.11-1.13.1.jar:1.13.1]
at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
~[flink-dist_2.11-1.13.1.jar:1.13.1]
at scala.collection.Iterator$class.foreach(Iterator.scala:891)
~[flink-dist_2.11-1.13.1.jar:1.13.1]
at scala.collection.AbstractIterator.foreach(Iterator.scala:1334)
~[flink-dist_2.11-1.13.1.jar:1.13.1]
at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
~[flink-dist_2.11-1.13.1.jar:1.13.1]
at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
~[flink-dist_2.11-1.13.1.jar:1.13.1]
at
scala.collection.TraversableLike$class.map(TraversableLike.scala:234)
~[flink-dist_2.11-1.13.1.jar:1.13.1]
at scala.collection.AbstractTraversable.map(Traversable.scala:104)
~[flink-dist_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.delegation.BatchPlanner.translateToPlan(BatchPlanner.scala:79)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:165)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1518)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:740)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
at
org.apache.flink.table.api.internal.StatementSetImpl.execute(StatementSetImpl.java:99)
~[flink-table-blink_2.11-1.13.1.jar:1.13.1]
sql:
CREATE CATALOG `tempo_df_hive_default_catalog` WITH(
'type' = 'hive',
'default-database' = 'default'
);
USE CATALOG tempo_df_hive_default_catalog;
CREATE TABLE IF NOT EXISTS `default`.`tempo_blackhole_table` (
f0 INT
);use tempo_dw;
insert into table1 select * from table2 where cast(code as string) like 'qw%';
INSERT INTO `default`.`tempo_blackhole_table` SELECT 1
