Skip to content

Flaky-test: PulsarSinksTest.testKinesis / KinesisSinkTester.addMoreRecordsAndGetMillisBehindLatest #15364

Open
@lhotari

Description

KinesisSinkTester.addMoreRecordsAndGetMillisBehindLatest is flaky. It fails sporadically.

example failure

  Error:  testKinesis(org.apache.pulsar.tests.integration.io.sinks.PulsarSinksTest)  Time elapsed: 62.576 s  <<< FAILURE!
  java.io.UncheckedIOException: Cannot encode string.
  	at software.amazon.awssdk.utils.StringUtils.fromBytes(StringUtils.java:578)
  	at software.amazon.awssdk.core.BytesWrapper.asString(BytesWrapper.java:82)
  	at org.apache.pulsar.tests.integration.io.sinks.KinesisSinkTester.addMoreRecordsAndGetMillisBehindLatest(KinesisSinkTester.java:210)
  	at org.apache.pulsar.tests.integration.io.sinks.KinesisSinkTester.lambda$internalValidateSinkResult$2(KinesisSinkTester.java:195)
  	at org.awaitility.core.CallableCondition$ConditionEvaluationWrapper.eval(CallableCondition.java:99)
  	at org.awaitility.core.ConditionAwaiter$ConditionPoller.call(ConditionAwaiter.java:248)
  	at org.awaitility.core.ConditionAwaiter$ConditionPoller.call(ConditionAwaiter.java:235)
  	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
  	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
  	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
  	at java.base/java.lang.Thread.run(Thread.java:833)
  Caused by: java.nio.charset.MalformedInputException: Input length = 3
  	at java.base/java.nio.charset.CoderResult.throwException(CoderResult.java:274)
  	at java.base/java.nio.charset.CharsetDecoder.decode(CharsetDecoder.java:820)
  	at software.amazon.awssdk.utils.StringUtils.fromBytes(StringUtils.java:576)
  	... 10 more

Metadata

Assignees

No one assigned

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions