玩table api的時(shí)候遇到下面的報(bào)錯(cuò):

Exception in thread "main" org.apache.flink.table.api.TableException: Sink `default_catalog`.`default_database`.`OutOrders` does not existsat org.apache.flink.table.planner.delegation.PlannerBase.translateToRel(PlannerBase.scala:243)at org.apache.flink.table.planner.delegation.PlannerBase.$anonfun$translate$1(PlannerBase.scala:163)at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)at scala.collection.Iterator.foreach(Iterator.scala:937)at scala.collection.Iterator.foreach$(Iterator.scala:937)at scala.collection.AbstractIterator.foreach(Iterator.scala:1425)at scala.collection.IterableLike.foreach(IterableLike.scala:70)at scala.collection.IterableLike.foreach$(IterableLike.scala:69)at scala.collection.AbstractIterable.foreach(Iterable.scala:54)at scala.collection.TraversableLike.map(TraversableLike.scala:233)at scala.collection.TraversableLike.map$(TraversableLike.scala:226)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.TableImpl.executeInsert(TableImpl.java:565)at org.apache.flink.table.api.internal.TableImpl.executeInsert(TableImpl.java:549)at InsertInto.main(InsertInto.java:53)

解決方案:

需要個(gè)sink

代碼中新增:

tEnv.executeSql("CREATE TABLE OutOrders (`user` BIGINT, product VARCHAR, amount BIGINT) WITH (" +"'connector.url' = 'jdbc:mysql://Desktop:3306/flink',\n" +"'connector.type' = 'jdbc',\n" +"'connector.table' = 'table_api',\n" +"'connector.username' = 'appleyuchi',\n"+"'connector.password' = 'appleyuchi',\n" +"'connector.write.flush.max-rows' = '5000')");

pom.xml中新增:

<dependency><groupId>org.apache.flink</groupId><artifactId>flink-jdbc_2.11</artifactId><version>1.10.0</version> </dependency>

?

總結(jié)

以上是生活随笔為你收集整理的sink xxx does not exist的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。