This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.
*** WARNING: tag nightly-master was modified! ***
from ac57388 (commit)
to 2fd9875 (commit)
from ac57388 Merge pull request #15246 from [BEAM-12685] Allow managed
thread count in AvroIO
add 1d4a9cc Merge pull request #15298 from [BEAM-12729] Suppress Avro
Runtime Exceptions for Streaming
add 7e8c030 Refactor _RemoveDuplicates to use counter state (#15242)
add a647b23 [BEAM-12716] Update XLang Kafka taxi example to use BigQuery
sink
add 6b774be add comment
add 2fd9875 Merge pull request #15269 from ihji/BEAM-12716
No new revisions were added by this update.
Summary of changes:
.../main/java/org/apache/beam/sdk/io/AvroIO.java | 46 +++++++--
.../beam/sdk/io/ReadAllViaFileBasedSource.java | 41 +++++++-
.../apache_beam/examples/kafkataxi/kafka_taxi.py | 109 +++++++++++++++------
sdks/python/apache_beam/io/fileio.py | 20 ++--
4 files changed, 165 insertions(+), 51 deletions(-)
