Kafka Consumer Group Properties#34334

Closed

talatuyarer wants to merge 48 commits intoapache:masterfrom

talatuyarer:beamsql-kafka-table-properties

Commits on Mar 18, 2025

Commits on Mar 20, 2025

Expose add-modules JVM option in SDKHarnessOptions (#34289)

authored and
talatuyarer
committed
[AnomalyDetection] Refactor and improve Specifiable (#34310)

shunping
authored and
talatuyarer
committed
Bump golang.org/x/oauth2 from 0.26.0 to 0.28.0 in /sdks (#34190)

dependabot[bot]
authored and
talatuyarer
committed
Support directory separator for Python local filesystem (#34318)

liferoad
authored and
talatuyarer
committed
Bump github.com/nats-io/nats.go from 1.39.0 to 1.39.1 in /sdks (#34029)

dependabot[bot]
authored and
talatuyarer
committed
Make yaml provider an abstract class.

robertwb
authored and
talatuyarer
committed
Add support for python package dependencies on UDFs.

robertwb
authored and
talatuyarer
committed
Add dependency support for delegating providers.

robertwb
authored and
talatuyarer
committed
Allow dependency declarations for java.

robertwb
authored and
talatuyarer
committed
Make yapf, lint, and mypy happy, fix test.

robertwb
authored and
talatuyarer
committed
[AnomalyDetection] Support offline detectors (#34311)

shunping
authored and
talatuyarer
committed
add option to disable metrics (#34303)

authored and
talatuyarer
committed
initial schema transform provider implementation for SQS read functionality.

prodriguezdefino
authored and
talatuyarer
committed
fixing checkstyle errors.

prodriguezdefino
authored and
talatuyarer
committed
removing region configuration since its not needed

prodriguezdefino
authored and
talatuyarer
committed
adding package info for the new providers

prodriguezdefino
authored and
talatuyarer
committed
added tests to the provider

prodriguezdefino
authored and
talatuyarer
committed
[Dataflow Streaming] WindmillTimerInternals: Use a single map to store timer data + liveness (#34292)

arunpandianp
authored and
talatuyarer
committed
add equals hashCode to BoundedToUnboundedSourceAdapter (#34057)

scwhittle
authored and
talatuyarer
committed
Remove cancelled tasks from ReadOperation queue when shutting down (#34335)

damccorm
authored and
talatuyarer
committed
[Prism] Refactor stageState to a behavior interface to reduce branch combinatorics (#34132)

lostluck
authored and
talatuyarer
committed
More precise binary operation inference. (#34305)

robertwb
authored and
talatuyarer
committed
Fix precommit flink container (#34250)

akashorabek
authored and
talatuyarer
committed
Aggregation option in Kinesis Writer Python sdk (#34323)

Nakachi-S
authored and
talatuyarer
committed
Add an experiment named enableLineageRollup which when passed to Java SDK will make it report Lineage as BoundedTrie

rohitsinha54
authored and
talatuyarer
committed
Allow boundedtrie emission outside of lineage usecase

rohitsinha54
authored and
talatuyarer
committed
Update Lineage query result to support BoundedTrie and StringSet both

rohitsinha54
authored and
talatuyarer
committed
update CHANGES with Read bugs/improvements (#34344)

scwhittle
authored and
talatuyarer
committed
Revert Skip BoundedTrie on Dataflow till service is have BoundedTrie #33921

rohitsinha54
authored and
talatuyarer
committed
Do not runner UsesBoundedTrie test on Dataflow runner as the test verify metric result

rohitsinha54
authored and
talatuyarer
committed
[#31438] Add changes.md message for Trigger support in Prism. (#34346)

lostluck
authored and
talatuyarer
committed
Bump cloud.google.com/go/storage from 1.50.0 to 1.51.0 in /sdks (#34340)

dependabot[bot]
authored and
talatuyarer
committed
Bump serialize-javascript and mocha in /sdks/typescript (#34012)

dependabot[bot]
authored and
talatuyarer
committed
Bump github.com/fsouza/fake-gcs-server from 1.52.1 to 1.52.2 in /sdks (#34094)

dependabot[bot]
authored and
talatuyarer
committed
Bump golang.org/x/net from 0.23.0 to 0.36.0 in /learning/katas/go (#34267)

dependabot[bot]
authored and
talatuyarer
committed
Fix pandas doctests sensitive to NumpyExtensionArray formatting. (#34336)

robertwb
authored and
talatuyarer
committed
Bump google.golang.org/api from 0.221.0 to 0.226.0 in /sdks (#34293)

dependabot[bot]
authored and
talatuyarer
committed
Fix relative path yaml provider error when no base provided.

robertwb
authored and
talatuyarer
committed
Fixed infinitive loop
talatuyarer
committed
Avoid holding data elements alive via stack frame gc roots. (#33086)

scwhittle
authored and
talatuyarer
committed
Remove finalizers from sdb-cluster before deleting singlestoreio namespaces (#34359)

akashorabek
authored and
talatuyarer
committed
Bump google.golang.org/api from 0.226.0 to 0.227.0 in /sdks (#34356)

dependabot[bot]
authored and
talatuyarer
committed
Bump github.com/nats-io/nats-server/v2 from 2.10.25 to 2.11.0 in /sdks (#34358)

dependabot[bot]
authored and
talatuyarer
committed
[IcebergIO] Filter out data files that have already been committed (#34264)

ahmedabu98
authored and
talatuyarer
committed
[Python] File staging to user worker support (#34208)

stankiewicz
authored and
talatuyarer
committed
Fix dockerfile version (#34352)

damccorm
authored and
talatuyarer
committed