This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from b20ccbfe3ef [2/3] sdks/python: sink data with Milvus Search I/O
connector (#36729)
add 6d94d5c00ee Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in
/sdks (#36882)
add f9f13c331dd enhance python tests (#36852)
add 6a8244815b0 Move Kafka read with redistribute override to Kafka IO
package. (#36887)
add 94336fa0187 Make RestrictionTrackers.getProgress unblocking until
initial progress successfully returned (#36750)
add c84ccd385c2 callStateMap was accessed from multiple threads without
synchronization. changing callStateMap to concurrent hashmap (#36886)
add c8aa39898cf Fix GcsEndpoint serialization in GcsOptions (#36879)
No new revisions were added by this update.
Summary of changes:
runners/google-cloud-dataflow-java/build.gradle | 2 -
.../beam/runners/dataflow/DataflowRunner.java | 5 +-
sdks/go.mod | 8 +-
sdks/go.sum | 16 ++--
.../sdk/fn/splittabledofn/RestrictionTrackers.java | 94 ++++++++++++++++++----
.../fn/splittabledofn/RestrictionTrackersTest.java | 90 ++++++++++++++++++++-
.../beam/sdk/transforms/ParDoLifecycleTest.java | 11 ++-
.../sdk/extensions/gcp/options/GcsOptions.java | 1 -
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 7 ++
.../kafka}/KafkaReadWithRedistributeOverride.java | 8 +-
.../KafkaReadWithRedistributeOverrideTest.java | 4 +-
sdks/python/conftest.py | 34 ++++----
12 files changed, 213 insertions(+), 67 deletions(-)
rename
{runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow
=>
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka}/KafkaReadWithRedistributeOverride.java
(90%)
rename
{runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow
=>
sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka}/KafkaReadWithRedistributeOverrideTest.java
(98%)
