failed checkpoint with metadata timeout exception

[Yitzchak Lieberman]

Hi.

I have flink a application that produces to kafka with 3 brokers.

When I add 2 brokers that are not up yet it fails the checkpoint (a key in s3) due to timeout error.

Do you know what can cause that?

Thanks,

Yitzchak.

[miki haiat]

Can you share your logs 

On Thu, Jul 18, 2019 at 3:22 PM Yitzchak Lieberman <[hidden email]> wrote:

Hi.

I have flink a application that produces to kafka with 3 brokers.

When I add 2 brokers that are not up yet it fails the checkpoint (a key in s3) due to timeout error.

Do you know what can cause that?

Thanks,

Yitzchak.

[Yitzchak Lieberman]

org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.

On Thu, Jul 18, 2019 at 3:49 PM miki haiat <[hidden email]> wrote:

Can you share your logs 

On Thu, Jul 18, 2019 at 3:22 PM Yitzchak Lieberman <[hidden email]> wrote:

Hi.

I have flink a application that produces to kafka with 3 brokers.

When I add 2 brokers that are not up yet it fails the checkpoint (a key in s3) due to timeout error.

Do you know what can cause that?

Thanks,

Yitzchak.

[miki haiat]

Can you check in the kafka logs what happens when you adding new brokers ?

On Thu, Jul 18, 2019 at 4:36 PM Yitzchak Lieberman <[hidden email]> wrote:

org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.

On Thu, Jul 18, 2019 at 3:49 PM miki haiat <[hidden email]> wrote:

Can you share your logs 

On Thu, Jul 18, 2019 at 3:22 PM Yitzchak Lieberman <[hidden email]> wrote:

Hi.

I have flink a application that produces to kafka with 3 brokers.

When I add 2 brokers that are not up yet it fails the checkpoint (a key in s3) due to timeout error.

Do you know what can cause that?

Thanks,

Yitzchak.