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 7d08467 (commit)
to a17f735 (commit)
from 7d08467 Merge pull request #14548: [BEAM-11648] Update to new
StreamWriterV2 API
add dc168c6 use toMinutes
add 86df18c update test
add a89879f [BEAM-8611] Move TextSourceTest into TextIOReadTest (#14560)
add dc665d5 Merge remote-tracking branch 'upstream/master' into minutes
add ffcc5e0 Merge pull request #14546 : [BEAM-12173] use toMinutes
add e0136ff Change kafka table provider properties structure. (#14507)
add b9de6b6 [BEAM-11839] Improve DeferredFrameTest._run_test (#14552)
add ff144a2 [BEAM-12118] Fix racy precondition exception in
QueueingBeamFnDataClient
add faaf646 Merge pull request #14572: [BEAM-12118] Fix racy precondition
exception in QueueingBeamFnDataClient
add a17f735 [BEAM-12191] Fix a bug that upload_graph doesn't reduce
template file size (#14582)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 2 +
.../org/apache/beam/sdk/io/TextIOReadTest.java | 122 +++++++
.../org/apache/beam/sdk/io/TextSourceTest.java | 158 ----------
.../meta/provider/kafka/KafkaTableProvider.java | 63 +++-
.../provider/kafka/BeamKafkaTableAvroTest.java | 4 +-
.../provider/kafka/BeamKafkaTableJsonTest.java | 4 +-
.../provider/kafka/BeamKafkaTableProtoTest.java | 3 +-
.../provider/kafka/BeamKafkaTableThriftTest.java | 3 +-
.../meta/provider/kafka/KafkaTableProviderIT.java | 34 +-
.../provider/kafka/KafkaTableProviderTest.java | 112 +++++--
.../fn/harness/data/QueueingBeamFnDataClient.java | 2 +-
.../sdk/io/gcp/bigquery/BigQueryServicesImpl.java | 2 +-
.../io/gcp/bigquery/BigQueryServicesImplTest.java | 2 +-
sdks/python/apache_beam/dataframe/frames_test.py | 351 +++++++++++----------
.../runners/dataflow/internal/apiclient.py | 16 +-
.../dsls/sql/extensions/create-external-table.md | 195 +++++++++---
16 files changed, 633 insertions(+), 440 deletions(-)
delete mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/io/TextSourceTest.java
