[
https://issues.apache.org/jira/browse/FLINK-11933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16793700#comment-16793700
]
Ken Krugler commented on FLINK-11933:
-------------------------------------
Hi thinktothings - please post problems like this to the Flink user email list
first, before opening up a Jira issue. If input from the Flink community then
indicates it's a bug or a worthwhile enhancement, you can and should create a
Jira issue. Thanks!
> Exception in thread "main" java.lang.RuntimeException: No data sinks have
> been created yet. A program needs at least one sink that consumes data.
> Examples are writing the data set or printing it.
> ---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-11933
> URL: https://issues.apache.org/jira/browse/FLINK-11933
> Project: Flink
> Issue Type: Bug
> Components: API / Table SQL
> Affects Versions: 1.7.2
> Environment: package
> com.opensourceteams.module.bigdata.flink.example.tableapi.convert.dataset
> import org.apache.flink.api.scala.ExecutionEnvironment
> import org.apache.flink.api.scala._
> import org.apache.flink.core.fs.FileSystem.WriteMode
> import org.apache.flink.table.api.\{TableEnvironment, Types}
> import org.apache.flink.table.sinks.CsvTableSink
> import org.apache.flink.api.common.typeinfo.TypeInformation
> object Run {
> def main(args: Array[String]): Unit = {
> val env = ExecutionEnvironment.getExecutionEnvironment
> val tableEnv = TableEnvironment.getTableEnvironment(env)
> val dataSet = env.fromElements( (1,"a",10),(2,"b",20), (3,"c",30) )
> val table = tableEnv.fromDataSet(dataSet)
> tableEnv.registerTable("user1",table)
> val csvTableSink = new
> CsvTableSink("sink-data/csv/a.csv",",",1,WriteMode.OVERWRITE)
> val fieldNames = Array("id", "name", "value")
> val fieldTypes: Array[TypeInformation[_]] = Array(Types.INT, Types.STRING,
> Types.LONG)
> tableEnv.registerTableSink("csvTableSink",fieldNames,fieldTypes,csvTableSink)
> tableEnv.scan("user1")
> env.execute()
> }
> }
> Reporter: thinktothings
> Priority: Major
>
> Exception in thread "main" java.lang.RuntimeException: No data sinks have
> been created yet. A program needs at least one sink that consumes data.
> Examples are writing the data set or printing it.
> at
> org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan(ExecutionEnvironment.java:945)
> at
> org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan(ExecutionEnvironment.java:923)
> at
> org.apache.flink.api.java.LocalEnvironment.execute(LocalEnvironment.java:85)
> at
> org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:817)
> at
> org.apache.flink.api.scala.ExecutionEnvironment.execute(ExecutionEnvironment.scala:525)
> at
> com.opensourceteams.module.bigdata.flink.example.tableapi.convert.dataset.Run$.main(Run.scala:36)
> at
> com.opensourceteams.module.bigdata.flink.example.tableapi.convert.dataset.Run.main(Run.scala)
> Process finished with exit code 1
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
