Ask about convert KafkaTableSource to table

[Rad Rad]

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/

[Shuyi Chen]

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 <[hidden email]> 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/

--