Please take a look at the table api/SQL doc [1] below on how to register a table/tablesource. Thanks.
[1] https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/table/common.html#register-a-table On Thu, May 31, 2018 at 6:22 AM, Radhya Sahal <radhya.sa...@gmail.com> wrote: > Hi, > > Could you help me which is the integrated versions of Java/Kafka/ Flink > which can work without errors. > > > I have a problem when I read streamed data from KafkaTableSource to table. > I use this command > > tableEnv.registerDataStream("sensors", myKafkaTableSource) > > But, there it doesn't run (i.e., compilation error). Since, these are the > dependencies in pom.xml > > </dependency> > <dependency> > <groupId>org.apache.flink</groupId> > <artifactId>flink-streaming-java_2.11</artifactId> > <version>1.4.0</version> > </dependency> > <dependency> > <groupId>org.apache.flink</groupId> > <artifactId>flink-clients_2.11</artifactId> > <version>1.4.0</version> > </dependency> > <dependency> > <groupId>org.apache.flink</groupId> > <artifactId>flink-connector-kafka-0.11_2.11</artifactId> > <version>1.4.0</version> > </dependency> > <dependency> > <groupId>org.apache.flink</groupId> > <artifactId>flink-table_2.11</artifactId> > <version>1.4.0</version> > </dependency> > <dependency> > <groupId>org.apache.flink</groupId> > <artifactId>flink-core</artifactId> > <version>1.4.0</version> > </dependency> > <dependency> > <groupId>org.apache.flink</groupId> > <artifactId>flink-streaming-scala_2.11</artifactId> > <version>1.4.0</version> > </dependency> > </dependencies> > > > > > > Regards. > > Radhya Sahal > > > > > -- > Sent from: http://apache-flink-user-mailing-list-archive.2336050. > n4.nabble.com/ > -- "So you have to trust that the dots will somehow connect in your future."
