in Flink 1.15 or rewrite some code of Firehose connector to
migrate it to sink1.
Best regards,
Yuxia
发件人: "Zain Haider Nemati"
收件人: "Martijn Visser"
抄送: "yu'an huang" , "User"
发送时间: 星期四, 2022年 5 月 12日 下午 3:36:46
主题: Re: Incompatible data types wh
Hi,
As far as I know, there is no Firehose sink in Flink 1.13, only a Kinesis
one [1]
Best regards,
Martijn Visser
https://twitter.com/MartijnVisser82
https://github.com/MartijnVisser
[1]
https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/connectors/datastream/overview/
On Thu,
Hi, Appreciate your response.
My flink version is 1.13.
Is there any other way to sink data to kinesis without having to update to
1.15
On Thu, May 12, 2022 at 12:25 PM Martijn Visser
wrote:
> I'm guessing this must be Flink 1.15 since Firehose was added in that
> version :)
>
> On Thu, 12 May
I'm guessing this must be Flink 1.15 since Firehose was added in that
version :)
On Thu, 12 May 2022 at 08:41, yu'an huang wrote:
> Hi,
>
> Your code is working fine in my computer. What is the Flink version you
> are using.
>
>
>
>
> On 12 May 2022, at 3:39 AM, Zain Haider Nemati
> wrote:
>
>
Hi,
Your code is working fine in my computer. What is the Flink version you are
using.
> On 12 May 2022, at 3:39 AM, Zain Haider Nemati wrote:
>
> Hi Folks,
> Getting this error when sinking data to a firehosesink, would really
> appreciate some help !
>
> DataStream inputStream =
Hi Folks,
Getting this error when sinking data to a firehosesink, would really
appreciate some help !
DataStream inputStream = env.addSource(new
FlinkKafkaConsumer<>("xxx", new SimpleStringSchema(), properties));
Properties sinkProperties = new Properties();
Hi Folks,
Getting this error when sinking data to a firehosesink, would really
appreciate some help !
DataStream inputStream = env.addSource(new
FlinkKafkaConsumer<>("xxx", new SimpleStringSchema(), properties));
Properties sinkProperties = new Properties();
