ZmmBigdata commented on PR #24841:
URL: https://github.com/apache/flink/pull/24841#issuecomment-2133532442
Two more files have been committed
docs:flink-docs-release-1.19/docs/dev/table/sql/queries/overview/
[docs]Flink sql queries-overview Missing required options are:path
Exception in thread "main" org.apache.flink.table.api.ValidationException:
Unable to create a sink for writing table
'default_catalog.default_database.RubberOrders'.
Table options are:
'connector'='filesystem'
'csv.field-delimiter'=','
'format'='csv'
at
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:270)
at
org.apache.flink.table.planner.delegation.PlannerBase.getTableSink(PlannerBase.scala:459)
at
org.apache.flink.table.planner.delegation.PlannerBase.translateToRel(PlannerBase.scala:236)
at
org.apache.flink.table.planner.delegation.PlannerBase.$anonfun$translate$1(PlannerBase.scala:194)
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:194)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1803)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:881)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:989)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql(TableEnvironmentImpl.java:765)
at com.yushu.table.TableAPIDemo1.main(TableAPIDemo1.java:65)
Caused by: org.apache.flink.table.api.ValidationException: One or more
required options are missing.
Missing required options are:
path
at
org.apache.flink.table.factories.FactoryUtil.validateFactoryOptions(FactoryUtil.java:612)
at
org.apache.flink.table.factories.FactoryUtil.validateFactoryOptions(FactoryUtil.java:582)
at
org.apache.flink.table.factories.FactoryUtil$FactoryHelper.validate(FactoryUtil.java:930)
at
org.apache.flink.table.factories.FactoryUtil$FactoryHelper.validateExcept(FactoryUtil.java:955)
at
org.apache.flink.connector.file.table.FileSystemTableFactory.validate(FileSystemTableFactory.java:152)
at
org.apache.flink.connector.file.table.FileSystemTableFactory.createDynamicTableSink(FileSystemTableFactory.java:84)
at
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:267)
... 19 more
![068ff8b05220e937e3f5db4c7053f0d](https://github.com/apache/flink/assets/102840730/3edd99a0-cc41-4b55-a3a0-f6e509fe8a9d)
![54ce1c2c1ad112e9fd4be700f9e7fda](https://github.com/apache/flink/assets/102840730/037e5247-758b-4148-a67c-2e18b4401ab0)
![4e2d63556fcdd3930fdb4cd5211d369](https://github.com/apache/flink/assets/102840730/afa258ec-570a-437f-bf84-f9a626af5e12)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org