Search code examples
scalaapache-flinkflink-streamingflink-cepflink-sql

Create SQL Table from a DataStream in a Java/Scala program and query it from SQL Client CLI - Apache Flink

Is it possible interact with a table using Flink SQL client CLI where which table was created within a Scala/Java program running in the cluster?

Solution

  • No this is not possible.

    You could sink the DataStream of the Scala/Java program into a topic in a message queue or event log like Apache Kafka or Apache Pulsar and register the topic as a table in the CLI client.

    Once the table is register, it can be queried with SQL in the client.