You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Radhya Sahal <ra...@gmail.com> on 2018/05/31 13:22:33 UTC
Ask about convert KafkaTableSource to table
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/
Re: Ask about convert KafkaTableSource to table
Posted by Shuyi Chen <su...@gmail.com>.
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 <ra...@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."