[ https://issues.apache.org/jira/browse/BEAM-12516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Luke Cwik updated BEAM-12516: ----------------------------- Fix Version/s: 2.32.0 Resolution: Fixed Status: Resolved (was: Open) > StreamingDataflowWorker.ShardedKey.toString throws exception if key is less > than 100 bytes > ------------------------------------------------------------------------------------------ > > Key: BEAM-12516 > URL: https://issues.apache.org/jira/browse/BEAM-12516 > Project: Beam > Issue Type: Bug > Components: runner-dataflow > Affects Versions: 2.28.0 > Reporter: Sam Whittle > Assignee: Sam Whittle > Priority: P2 > Fix For: 2.32.0 > > Time Spent: 1h 50m > Remaining Estimate: 0h > > ByteString.substring does not support an end index beyond the string length. > example exception: > SLF4J: Failed toString() invocation on an object of type > [org.apache.beam.runners.dataflow.worker.AutoValue_StreamingDataflowWorker_ShardedKey] > java.lang.IndexOutOfBoundsException: End index: 100 >= 3 > org.apache.beam.vendor.grpc.v1p26p0.com.google.protobuf.ByteString.checkRange(ByteString.java:1272) > org.apache.beam.vendor.grpc.v1p26p0.com.google.protobuf.ByteString$LiteralByteString.substring(ByteString.java:1343) > org.apache.beam.runners.dataflow.worker.StreamingDataflowWorker$ShardedKey.toString(StreamingDataflowWorker.java:1144) > at > org.slf4j.helpers.MessageFormatter.safeObjectAppend(MessageFormatter.java:277) > at > org.slf4j.helpers.MessageFormatter.deeplyAppendParameter(MessageFormatter.java:249) > at org.slf4j.helpers.MessageFormatter.arrayFormat(MessageFormatter.java:211) > at org.slf4j.helpers.MessageFormatter.arrayFormat(MessageFormatter.java:161) > at org.slf4j.helpers.MessageFormatter.format(MessageFormatter.java:151) > at org.slf4j.impl.JDK14LoggerAdapter.error(JDK14LoggerAdapter.java:522) > at > org.apache.beam.runners.dataflow.worker.StreamingDataflowWorker$ComputationState.invalidateStuckCommits(StreamingDataflowWorker.java:2326) -- This message was sent by Atlassian Jira (v8.3.4#803005)