kind a similar to my problem.
http://mail-archives.apache.org/mod_mbox/flink-user/201710.mbox/%3cfdd0a701-d6fe-433f-b343-19fd24cb3...@data-artisans.com%3e
How could I over come this condition?
Thanks & Regards,
Sushant Sawant
On Fri, 30 Aug 2019, 12:48 Yun Tang, wrote:
> Hi Sushant
&
Hi team,
Anyone for help/suggestion, now we have stopped all input in kafka, there
is no processing, no sink but checkpointing is failing.
Is it like once checkpoint fails it keeps failing forever until job restart.
Help appreciated.
Thanks & Regards,
Sushant Sawant
On 23 Aug 2019 12:56
anyone point me towards direction what would have went wrong/ trouble
shooting??
Thanks & Regards,
Sushant Sawant
Hi,
Could you share error stack trace?
Thanks & Regards,
Sushant Sawant
On Fri, 24 May 2019, 19:18 Timothy Victor, wrote:
> If a flink job crashes during startup (throws exception) the entire
> cluster goes down. This is even on a simple bare metal host.
>
>
> I have
could you please elaborate on version miss match of kafka broker and
consumer?
I never installed two kafka versions everything is from one package which
was downloaded from apache kafka tar file.
Thanks,
Sushant Sawant
On Tue, 2 Apr 2019, 19:46 Dominik Wosiński, wrote:
> Hey,
> As fa
maybe you
> could send a email to kafka user maillist.
>
> Best, Congxian
> On Apr 1, 2019, 05:26 +0800, Sushant Sawant ,
> wrote:
>
> Hi team,
> I am facing this exception,
>
> org.apache.kafka.common.KafkaException: Received exception when fetching
> the next rec
Hi team,
I am facing this exception,
org.apache.kafka.common.KafkaException: Received exception when fetching
the next record from topic_log-3. If needed, please seek past the record to
continue consumption.
at
org.apache.kafka.clients.consumer.internals.Fetcher$PartitionRecords.fetchReco
