zu-Li (Gordon) Tai"
Date: Sunday, April 23, 2017 at 3:32 PM
To: "user@flink.apache.org"
Subject: Re: put record to kinesis and then trying consume using flink connector
Hi Sathi,
Here, in the producer-side log, it says:
2017-04-22 19:46:53,608 INFO [main] DLKnesisPublisher:
by an outside service then obviously no issues..
From: Alex Reid
Date: Tuesday, April 25, 2017 at 4:31 PM
To: Sathi Chowdhury
Cc: "user@flink.apache.org"
Subject: Re: put record to kinesis and then trying consume using flink connector
Hi Sathi,
I believe the issue is because you
s the new slot automatically get aware
> of the broadcasted data?
>
> Thanks
>
> Sathi
>
>
>
> *From: *Sathi Chowdhury
> *Date: *Tuesday, April 25, 2017 at 3:56 PM
> *To: *"Tzu-Li (Gordon) Tai" , "user@flink.apache.org"
>
>
> *Subject:
From: Sathi Chowdhury
Date: Tuesday, April 25, 2017 at 3:56 PM
To: "Tzu-Li (Gordon) Tai" , "user@flink.apache.org"
Subject: Re: put record to kinesis and then trying consume using flink connector
Hi Gordon,
That was a typo, as I was trying to mask off the stream name.. I st
day, April 23, 2017 at 3:32 PM
To: "user@flink.apache.org"
Subject: Re: put record to kinesis and then trying consume using flink connector
Hi Sathi,
Here, in the producer-side log, it says:
2017-04-22 19:46:53,608 INFO [main] DLKnesisPublisher: Successfully published
record, of byt
Hi Sathi,
Here, in the producer-side log, it says:
2017-04-22 19:46:53,608 INFO [main] DLKnesisPublisher: Successfully published
record, of bytes :162810 partition key
:fb043b73-1d9d-447a-a593-b9c1bf3d4974-1492915604228 ShardId:
shardId-Sequence
number49572539577762637793132019619
Hi Flink Dev,
I thought something will work easily with flink and it is simple enough ,yer I
am struggling to make it work.
I am using flink kinesis connector ..using 1.3-SNAPSHOT version.
Basically I am trying to bootstrap a stream with one event pushed into it as a
warmup inside flink job’s ma
