You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Luke Cwik (Jira)" <ji...@apache.org> on 2021/07/09 21:19:00 UTC
[jira] [Updated] (BEAM-12516)
StreamingDataflowWorker.ShardedKey.toString throws exception if key is less
than 100 bytes
[ 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)