flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "thinktothings (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-11933) 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.
Date Fri, 15 Mar 2019 11:29:00 GMT
thinktothings created FLINK-11933:
-------------------------------------

             Summary: 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


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)

Mime
View raw message