[jira] [Created] (BEAM-12053) FlinkRuner: Pipeline using KafkaIO seems not be able to terminate

[Jira]

Jan Lukavský created BEAM-12053:
-----------------------------------

             Summary: FlinkRuner: Pipeline using KafkaIO seems not be able to 
terminate
                 Key: BEAM-12053
                 URL: https://issues.apache.org/jira/browse/BEAM-12053
             Project: Beam
          Issue Type: Bug
          Components: io-java-kafka
    Affects Versions: 2.28.0
            Reporter: Jan Lukavský
            Assignee: Jan Lukavský


{{2021-03-25 14:21:27,210 WARN 
org.apache.beam.sdk.io.kafka.KafkaUnboundedReader [] - Reader-0: Unexpected 
java.lang.InterruptedException: null at 
java.util.concurrent.SynchronousQueue.poll(Unknown Source) ~[?:?] at 
org.apache.beam.sdk.io.kafka.KafkaUnboundedReader.nextBatch(KafkaUnboundedReader.java:584)
 
~[blob_p-e4f6919ea552b3197dcb3d58dab934634011ea1d-f375010a962934be4febeb9924152473:?]
 at 
org.apache.beam.sdk.io.kafka.KafkaUnboundedReader.advance(KafkaUnboundedReader.java:214)
 
~[blob_p-e4f6919ea552b3197dcb3d58dab934634011ea1d-f375010a962934be4febeb9924152473:?]
 at 
org.apache.beam.sdk.io.Read$UnboundedSourceAsSDFWrapperFn$UnboundedSourceAsSDFRestrictionTracker.tryClaim(Read.java:841)
 
~[blob_p-cfeb2021150481a2d2069a38f7abd261d89645c3-b56abda9593e69f19cd5f833293fbd4f:?]
 at 
org.apache.beam.sdk.io.Read$UnboundedSourceAsSDFWrapperFn$UnboundedSourceAsSDFRestrictionTracker.tryClaim(Read.java:781)
 
~[blob_p-cfeb2021150481a2d2069a38f7abd261d89645c3-b56abda9593e69f19cd5f833293fbd4f:?]
 at 
org.apache.beam.sdk.fn.splittabledofn.RestrictionTrackers$RestrictionTrackerObserver.tryClaim(RestrictionTrackers.java:59)
 
~[blob_p-bcbef6ab6822495d6ebec31ea6f945a2703e27a2-beed43efff1368b0a55e8950c1c78418:?]}}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)