Hi Leonard,
Thank you so much! It worked, I did get a new error but it is unrelated to
this question.
Den man. 18. maj 2020 kl. 15.21 skrev Leonard Xu :
> More precisely: Should the sink table `sql-sink` missed required version
> option.
>
>
> 在 2020年5月18日，21:13，Leonard Xu 写道：
>
> Hi,
>
> Lo
More precisely: Should the sink table `sql-sink` missed required version
option.
> 在 2020年5月18日，21:13，Leonard Xu 写道：
>
> Hi,
>
> Look likes you missed two required parameters: version and topic[1], you need
> to add them for both source table and sink table.
>
> .connect(
> new Kafka()
Hi,
Look likes you missed two required parameters: version and topic[1], you need
to add them for both source table and sink table.
.connect(
new Kafka()
.version("0.11")// required: valid connector versions are
// "0.8", "0.9", "0.10", "0.11", and "universal
Hi Jark Wu,
Thanks for your answer,
Here is what I have so far
import java.util.Properties
import org.apache.flink.table.descriptors.Json
import org.apache.flink.table.descriptors.{Kafka, Schema}
import org.apache.flink.streaming.connectors.kafka.{FlinkKafkaConsumer,
FlinkKafkaConsumerBase, Flin
Hi,
Could you share the SQL DDL and the full exception message? It might be you
are using the wrong `connector.version` or other options.
Best,
Jark
On Fri, 15 May 2020 at 20:14, Martin Frank Hansen
wrote:
> Hi,
>
> I am trying to connect to kafka through flink, but having some difficulty
>
Hi,
I am trying to connect to kafka through flink, but having some difficulty
getting the right table-factory-source.
I currently get the error: NoMatchingTableFactoryException: Could not find
a suitable table factory for
'org.apache.flink.table.factories.TableSourceFactory' in the classpath. m
