Hello team ! I deployed a Flink job in kubernetes ...
# troubleshootingi
Irene Rodriguez
07/26/2024, 10:04 AMHello team ! I deployed a Flink job in kubernetes environment, but I have the feeling that the jobs start and when read all that I have pending from a kafka topic , if no new message receive the jobs stops.
Irene Rodriguez
07/26/2024, 10:04 AMI see the messages in the log:
Irene Rodriguez
07/26/2024, 10:07 AM Copy code
2024-07-26 09:30:26,875 INFO org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager [] - Closing TaskExecutor connection taskmanager-1-3 because: slot manager has determined that the resource is no longer needed
2024-07-26 09:30:26,875 INFO org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Unregistering task executor 9908abb6f6b0c3dbd751263150881a06 from the slot manager.
2024-07-26 09:30:26,912 WARN org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager [] - Discard registration from TaskExecutor taskmanager-1-3 at () because the framework did not recognize itIrene Rodriguez
07/26/2024, 1:16 PMI see this message too :
Irene Rodriguez
07/26/2024, 1:16 PM Copy code
ActiveResourceManager [] - need release 6 workers, current worker number 6, declared worker number 0Irene Rodriguez
07/26/2024, 1:17 PMthe job is in STREAM mode