flink sql写入clickhouse报错需要本地表

[kaiwangleo]

Exception in thread "main" org.apache.flink.table.api.ValidationException: Unable to create a sink for writing table 'default_catalog.default_database.sink_app_basic_ed_hardware_status_new'.

Table options are:

'connector'='clickhouse' 'format'='json' 'password'='nMtk1aYu' 'table-name'='basic_ed_hardware_status_16_new' 'url'='jdbc:clickhouse://10.204.209.171:8123,10.204.209.172:8123,10.204.209.173:8123,10.204.209.174:8123,10.204.209.175:8123/default' 'username'='chadmin' at org.apache.flink.table.factories.FactoryUtil.createTableSink(FactoryUtil.java:164) at org.apache.flink.table.planner.delegation.PlannerBase.getTableSink(PlannerBase.scala:344) at org.apache.flink.table.planner.delegation.PlannerBase.translateToRel(PlannerBase.scala:204) at org.apache.flink.table.planner.delegation.PlannerBase$$anonfun$1.apply(PlannerBase.scala:163) at org.apache.flink.table.planner.delegation.PlannerBase$$anonfun$1.apply(PlannerBase.scala:163) 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.Iterator$class.foreach(Iterator.scala:891) at scala.collection.AbstractIterator.foreach(Iterator.scala:1334) at scala.collection.IterableLike$class.foreach(IterableLike.scala:72) at scala.collection.AbstractIterable.foreach(Iterable.scala:54) at scala.collection.TraversableLike$class.map(TraversableLike.scala:234) at scala.collection.AbstractTraversable.map(Traversable.scala:104) at org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:163) at org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1264) at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:700) at org.apache.flink.table.api.internal.StatementSetImpl.execute(StatementSetImpl.java:97) at com.fcbox.streaming.sql.submit.StreamingJob.run(StreamingJob.java:161) at com.fcbox.streaming.sql.submit.StreamingJob.main(StreamingJob.java:86) Caused by: org.apache.flink.table.api.ValidationException: One or more required options are missing.

Missing required options are:

local-table-name at org.apache.flink.table.factories.FactoryUtil.validateFactoryOptions(FactoryUtil.java:285) at org.apache.flink.table.factories.FactoryUtil$TableFactoryHelper.validate(FactoryUtil.java:482) at com.fcbox.streaming.connector.clickhouse.table.ClickHouseDynamicTableFactory.createDynamicTableSink(ClickHouseDynamicTableFactory.java:88) at org.apache.flink.table.factories.FactoryUtil.createTableSink(FactoryUtil.java:161) ... 18 more

你好，请问需要参数local-table-name，是什么原因呢