-
Notifications
You must be signed in to change notification settings - Fork 4.2k
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.
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
Author
Label
Projects
Milestones
Assignee
Sort
Issues list
Determine partition backlog using endOffsets instead of seek2End and position
io
java
kafka
#32889
opened Oct 21, 2024 by
sjvanrossum
Loading…
3 tasks
Revert "Merge pull request #32757: Schema inference parameterized types"
extensions
io
java
protobuf
thrift
#32887
opened Oct 21, 2024 by
reuvenlax
Loading…
Added support for reading from multiple topics in MqttIO
io
java
mqtt
Next Action: Reviewers
#32881
opened Oct 20, 2024 by
twosom
Loading…
3 tasks
[Managed Iceberg] Allow updating partition specs at runtime
build
io
java
#32879
opened Oct 18, 2024 by
ahmedabu98
Loading…
[WIP] Enable configuration of mutation info callable for CDC Writes into BigQuery
gcp
io
python
#32878
opened Oct 18, 2024 by
prodriguezdefino
•
Draft
[Bug]: IcebergIO cannot write data into an hourly partitioned table
bug
dataflow
IcebergIO
IcebergIO: can only be used through ManagedIO
io
java
P2
#32865
opened Oct 18, 2024 by
DanielMorales9
3 of 17 tasks
[Managed Iceberg] Cleanup SerializedDataFile; use ByteBuffer instead
build
io
java
Next Action: Reviewers
#32821
opened Oct 16, 2024 by
ahmedabu98
Loading…
[Feature Request]: Provide the Python equivalent to Java's BigQueryIO
writeProtos
awaiting triage
dataflow
io
new feature
P2
python
#32781
opened Oct 15, 2024 by
lazarillo
3 of 17 tasks
[Managed Iceberg] Use table file size property if exists
io
java
#32760
opened Oct 11, 2024 by
ahmedabu98
Loading…
[Bug]: IcebergIO - Write performance issues
bug
dataflow
IcebergIO
IcebergIO: can only be used through ManagedIO
io
java
P2
#32746
opened Oct 10, 2024 by
DanielMorales9
3 of 17 tasks
fix: workaround BigtableIO.read() recreating the client for every split
bigtable
gcp
io
java
#32724
opened Oct 9, 2024 by
igorbernstein2
•
Draft
3 tasks
[Task]: Utilize Managed Service for Apache Kafka resources for testing purposes.
awaiting triage
io
java
P2
task
#32721
opened Oct 9, 2024 by
fozzie15
2 of 17 tasks
[Feature Request]: SolaceIO - publishing to dynamic topics (like TopicNameMapper in JmsIO)
awaiting triage
io
new feature
P2
#32718
opened Oct 9, 2024 by
ppawel
1 of 17 tasks
bump confluent version to fix CVE-2024-26308 CVE-2024-25710
io
java
kafka
#32674
opened Oct 7, 2024 by
stankiewicz
Loading…
3 tasks
[Feature Request]: BigQuery as Unbounded Source via Storage Read API
awaiting triage
io
java
new feature
P2
python
#32606
opened Oct 1, 2024 by
sapphire008
3 of 17 tasks
[Bug]: SolaceIO does not acknowledge messages
awaiting triage
bug
dataflow
io
java
P2
#32596
opened Sep 30, 2024 by
ppawel
3 of 17 tasks
Support Map in BQ for StorageWrites API for Beam Rows
gcp
io
java
Next Action: Reviewers
#32512
opened Sep 20, 2024 by
prodriguezdefino
Loading…
3 tasks
Previous Next
ProTip!
What’s not been updated in a month: updated:<2024-09-21.