Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-14209

org.apache.beam.sdk.io.pulsar.PulsarIOTest.testReadFromSimpleTopic flaky

    XMLWordPrintableJSON

Details

    • Test
    • Status: Open
    • P2
    • Resolution: Unresolved
    • None
    • None
    • test-failures
    • None

    Description

      https://ci-beam.apache.org/job/beam_PreCommit_Java_Cron/5270/testReport/org.apache.beam.sdk.io.pulsar/PulsarIOTest/testReadFromSimpleTopic/

      Caused by: java.lang.IllegalArgumentException: Trying to claim offset 1648580086959 before start of the range [1648580087254, 1648580087266)
	at org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Preconditions.checkArgument(Preconditions.java:440)
	at org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:97)
	at org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker.tryClaim(OffsetRangeTracker.java:38)
	at org.apache.beam.repackaged.direct_java.sdk.fn.splittabledofn.RestrictionTrackers$RestrictionTrackerObserver.tryClaim(RestrictionTrackers.java:59)
	at org.apache.beam.sdk.io.pulsar.ReadFromPulsarDoFn.processElement(ReadFromPulsarDoFn.java:170)

      Attachments

        Activity

          People

            Unassigned Unassigned
            kileys Kiley Sok
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated: