Skip to content

Issues: apache/beam

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

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

Clear current search query, filters, and sorts
113 Open 73 Closed
113 Open 73 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Assignee
Filter by who’s assigned
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Issues list

[Bug]: Pipeline fusion should break at @RequiresStableInput/determinism boundary portability runners
#24655 opened Dec 14, 2022 by je-ik
1 of 15 tasks
10
[Bug]: No parallelization for ReadFromParquet (or any Python Read transforms) in Spark RDD Runner bug P2 portability python runners spark
#24422 opened Nov 29, 2022 by cozos
[Bug]: Beam Pipeline does not halt execution while running on non local Spark Cluster bug harness P3 portability python spark
#23932 opened Nov 1, 2022 by nitinlkoin1984
10
[Bug]: Spark "uber jar" job server fails on cluster with NoSuchFileException bug portability spark
#23439 opened Sep 30, 2022 by mosche
2
[Task]: Improve documentation of PortableRunner for usage with Spark cross-language documentation portability runners spark task website
#23438 opened Sep 30, 2022 by mosche
ReadFromPubSub fails on Flink Runner bug flink P3 portability runners
#21325 opened Jun 4, 2022 by damccorm
Better error messages for misconfigured Beam worker flink improvement P3 portability runners spark
#21175 opened Jun 4, 2022 by damccorm
Enable org.apache.beam.sdk.transforms.ViewTest.testMapSideInputWithNullValuesCatchesDuplicates P3 portability runners samza tests
#21153 opened Jun 4, 2022 by damccorm
Enable org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests.testParDoReadingFromUnknownSideInput P3 portability runners samza tests
#21152 opened Jun 4, 2022 by damccorm
Enable org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests.testParDoWritingToUndeclaredTag P3 portability runners samza tests
#21151 opened Jun 4, 2022 by damccorm
Enable org.apache.beam.sdk.io.WriteFilesTest.testWithRunnerDeterminedShardingUnbounded P3 portability runners samza tests
#21150 opened Jun 4, 2022 by damccorm
Enable org.apache.beam.sdk.io.TextIOReadTest$CompressedReadTest.testCompressedReadWithoutExtension P3 portability runners samza tests
#21149 opened Jun 4, 2022 by damccorm
Enable org.apache.beam.sdk.io.TFRecordIOTest.testReadInvalidLengthMask P3 portability runners samza tests
#21148 opened Jun 4, 2022 by damccorm
Enable org.apache.beam.sdk.io.TFRecordIOTest.testReadInvalidDataMask P3 portability runners samza tests
#21147 opened Jun 4, 2022 by damccorm
Enable org.apache.beam.sdk.io.TFRecordIOTest.testReadInvalidRecord P3 portability runners samza tests
#21146 opened Jun 4, 2022 by damccorm
Enable org.apache.beam.sdk.transforms.DeduplicateTest.testEventTime P3 portability runners samza tests
#21145 opened Jun 4, 2022 by damccorm
Enable org.apache.beam.sdk.transforms.ParDoTest$TimestampTests.testParDoShiftTimestampInvalidZeroAllowed P3 portability runners samza tests
#21144 opened Jun 4, 2022 by damccorm
Enable org.apache.beam.sdk.transforms.ParDoTest$TimestampTests.testParDoShiftTimestampInvalid P3 portability runners samza tests
#21143 opened Jun 4, 2022 by damccorm
Enable org.apache.beam.sdk.transforms.GroupByKeyTest$WindowTests.testWindowFnPostMerging P3 portability runners samza tests
#21142 opened Jun 4, 2022 by damccorm
Clear ready timers before shutdown improvement P3 portability runners samza
#21059 opened Jun 4, 2022 by damccorm
Samza Portable Runner: Support Merging Custom Window Fns bug P3 portability runners samza
#21049 opened Jun 4, 2022 by damccorm
Samza portable Runner: Support SDF new feature P3 portability runners samza
#21045 opened Jun 4, 2022 by damccorm
Samza Portable Runner: Support Bundle Finalization new feature P3 portability runners samza
#21044 opened Jun 4, 2022 by damccorm
Portable Samza runner does not support flatten with different input/output coders in different languages (FlattenTest.testFlattenWithDifferentInputAndOutputCoders2) P2 portability runners samza
#21042 opened Jun 4, 2022 by damccorm
Enable TestStreamTest.testMultiStage P3 portability runners samza tests
#21023 opened Jun 4, 2022 by damccorm
ProTip! Find all open issues with in progress development work with linked:pr.