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 02a1cd2 (commit)
to 6649ccc (commit)
from 02a1cd2 Merge pull request #13291: [BEAM-11074] Adjust release
candidate email template to encourage reviewers.
add 28409f9 [BEAM-11192] Replace Java FnApi test tasks with Runner V2.
add 0690ec2 Merge pull request #13260: [BEAM-11192] Replace Java FnApi
test tasks with Runner V2.
add 538179b Account for overheads for small/empty PCollections.
add 1bd3133 Actually flush batches in rebatch.
add b09543e Merge pull request #13314 from robertwb/dataframe-rebatch
add 1abea32 [BEAM-11249] Read larger chunks for dataframe sources.
add 1f3577d Merge pull request #13312 [BEAM-11249] Read larger chunks for
dataframe sources.
add 06fc5b03 [BEAM-10114] Pub/Sub Lite getSplitBacklog implementation
(#12867)
add d48b0e3 Add 2.27.0 section
add 816017e Merge pull request #13320 from apache/lostluck-patch-1 - Add
2.27.0 section to CHANGES.md
add 92b7025 [BEAM-11255] Adding upper bound on urllib3 dependency.
add a041611 Merge pull request #13321 from [BEAM-11255] Adding upper
bound on urllib3 dependency
add a55b9f9 Get writer method from df
add b2f550c [BEAM-11256] Get writer method from dataframe at execution
time (#13322)
add 382cf37 Add display data to BoundedSourceDoFn (#13310)
add e2310e5 Require Pandas 1.x for dataframes. (#13323)
add a5b58fc BEAM-11193: Fix KeyedTimerData
add fc274f6 Fix style
add 21fbd91 [BEAM-11193]: Fix KeyedTimerData in Samza Runner
add 76c82a7 [BEAM-7372] Drop python 2 support in
base_image_requirements.txt (#13324)
add df2084f [BEAM-11142] Enable CrossLanguageValidateRunner test for
dataflow runner v2
add d990874 enable sql testing
add b4c988f disable failed tests
add 6649ccc Merge pull request #13283 from ihji/BEAM-11142
No new revisions were added by this update.
Summary of changes:
...t_CrossLanguageValidatesRunner_Dataflow.groovy} | 28 +++-
...ob_PostCommit_Java_Examples_Dataflow_V2.groovy} | 8 +-
CHANGES.md | 33 +++-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 69 ++++----
runners/flink/job-server/flink_job_server.gradle | 14 +-
runners/google-cloud-dataflow-java/build.gradle | 144 ++++++++--------
.../beam/runners/samza/runtime/KeyedTimerData.java | 6 +-
runners/spark/job-server/build.gradle | 15 +-
.../gcp/pubsublite/PubsubLiteUnboundedReader.java | 63 ++++++-
.../gcp/pubsublite/PubsubLiteUnboundedSource.java | 5 +-
.../sdk/io/gcp/pubsublite/SubscriberOptions.java | 85 ++++++----
.../sdk/io/gcp/pubsublite/TopicBacklogReader.java | 49 ++++++
.../io/gcp/pubsublite/TopicBacklogReaderImpl.java | 89 ++++++++++
.../gcp/pubsublite/TopicBacklogReaderSettings.java | 89 ++++++++++
.../pubsublite/PubsubLiteUnboundedReaderTest.java | 101 +++++++++++-
.../gcp/pubsublite/TopicBacklogReaderImplTest.java | 183 +++++++++++++++++++++
sdks/python/apache_beam/dataframe/io.py | 17 +-
sdks/python/apache_beam/dataframe/transforms.py | 7 +-
.../apache_beam/dataframe/transforms_test.py | 32 ++++
.../io/external/xlang_parquetio_test.py | 2 +-
sdks/python/apache_beam/io/iobase.py | 16 +-
sdks/python/apache_beam/transforms/sql_test.py | 2 +
.../transforms/validate_runner_xlang_test.py | 2 +
sdks/python/container/base_image_requirements.txt | 21 +--
sdks/python/setup.py | 4 +-
sdks/python/test-suites/direct/xlang/build.gradle | 15 +-
26 files changed, 911 insertions(+), 188 deletions(-)
copy
.test-infra/jenkins/{job_PostCommit_CrossLanguageValidatesRunner_Direct.groovy
=> job_PostCommit_CrossLanguageValidatesRunner_Dataflow.groovy} (56%)
copy .test-infra/jenkins/{job_PostCommit_Java_Dataflow_Examples_Java11.groovy
=> job_PostCommit_Java_Examples_Dataflow_V2.groovy} (85%)
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/TopicBacklogReader.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/TopicBacklogReaderImpl.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/TopicBacklogReaderSettings.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsublite/TopicBacklogReaderImplTest.java
