We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
when using partitionByKey if the pipeline encounters a key that is not in the input set. Right now you get:
partitionByKey
org.apache.beam.sdk.util.UserCodeException: java.lang.IndexOutOfBoundsException: Partition function returned out of bounds index: -1 not in [0..2)
It would be great if the key that was not in the input set was printed, maybe even alongside the input set like keyset: [], missing key: []
keyset: [], missing key: []
The text was updated successfully, but these errors were encountered:
For specifically partitionByKey we are providing the partition function so should be able to capture the key not found when index is returned as -1
-1
Sorry, something went wrong.
Successfully merging a pull request may close this issue.
when using
partitionByKey
if the pipeline encounters a key that is not in the input set. Right now you get:It would be great if the key that was not in the input set was printed, maybe even alongside the input set like
keyset: [], missing key: []
The text was updated successfully, but these errors were encountered: