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 e384c3a275a Merge pull request #17824: [BEAM-10496] Eliminate some
null errors from core SDK coders
add 8847486ffd2 [BEAM-3177][BEAM-5468] Add pipeline options to set default
logging level
add 79c067cc625 [BEAM-3177][BEAM-5468] Add pipeline options to set default
logging level #21724
add 4a5de3a7fd1 test fixes
add 5f3754c2cb3 no need for this line
add 82384a462a0 Fix NonType error when importing google.api_core fails
add 2e3d5e596da Expand pr bot to python (#21791)
add 0dac9b4455d Update run inference documentation (#21921)
add b5ea07d77c0 Consider skipped checks successful (#21924)
add 992d4c08ade Suppress unneeded spotbugs unused store warnings
add 152bcde49e4 Eliminate nullness errors in KafkaIO
add 3a6100d7af5 Merge pull request #21783: Eliminate nullness errors in
KafkaIO
add 58f31a8d02b Add guidance on self-assigning/closing to issue templates
(#21931)
add 7ad92ae41af Unsickbay copy_rewrite_token tests
add ed27a6bde34 Merge pull request #21900: Unsickbay copy_rewrite_token
tests
add 07506e091f6 [Website] add publishdate attribute to frontmatter
add 06f204b0910 Merge pull request #21908 from [Website] add publishdate
attribute to case studies frontmatter
add 914e1afee9e Fix beam_PostCommit_Java_Sickbay build
add f10f96d2e25 Merge pull request #21922 from Fix
beam_PostCommit_Java_Sickbay build
add ed900737d0a [Website] add new case-study, fix styles, add related
images (#21891)
add c627e472bd7 Merge pull request #21928 from [Fixes #21927] Compress
(Un)BoundedSourceAsSdfWrapper element and restriction coders
add 838b66e13ad BigQueryIO: Adding the BASIC view setting to getTable
request (#21879)
add 25121b6357e Update names.py
add 525a169e6f8 Merge pull request #21933 from Update container tags used
by Dataflow runner with unreleased SDKs
No new revisions were added by this update.
Summary of changes:
.github/ISSUE_TEMPLATE/bug.yml | 2 +-
.github/ISSUE_TEMPLATE/feature.yml | 2 +-
.github/ISSUE_TEMPLATE/task.yml | 2 +-
.github/REVIEWERS.yml | 10 ++
CHANGES.md | 1 +
build.gradle.kts | 8 +-
scripts/ci/pr-bot/processNewPrs.ts | 19 ++-
scripts/ci/pr-bot/processPrUpdate.ts | 10 +-
scripts/ci/pr-bot/shared/checks.ts | 5 +-
.../src/main/resources/beam/spotbugs-filter.xml | 7 +
.../src/main/java/org/apache/beam/sdk/io/Read.java | 21 ++-
.../beam/sdk/io/gcp/bigquery/BigQueryHelpers.java | 5 +-
.../beam/sdk/io/gcp/bigquery/BigQueryServices.java | 14 ++
.../sdk/io/gcp/bigquery/BigQueryServicesImpl.java | 18 ++-
.../sdk/io/gcp/bigquery/CreateTableHelpers.java | 4 +-
.../beam/sdk/io/gcp/bigquery/TableSchemaCache.java | 15 +-
.../sdk/io/gcp/testing/FakeDatasetService.java | 17 +++
.../io/gcp/bigquery/BigQueryServicesImplTest.java | 6 +-
.../beam/sdk/io/gcp/bigquery/BigQueryUtilTest.java | 2 +
...onfluentSchemaRegistryDeserializerProvider.java | 22 +--
.../beam/sdk/io/kafka/KafkaCheckpointMark.java | 5 +-
.../beam/sdk/io/kafka/KafkaCommitOffset.java | 1 -
.../beam/sdk/io/kafka/KafkaExactlyOnceSink.java | 67 +++++----
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 149 +++++++++++++------
.../org/apache/beam/sdk/io/kafka/KafkaIOUtils.java | 3 +-
.../org/apache/beam/sdk/io/kafka/KafkaRecord.java | 5 +-
.../apache/beam/sdk/io/kafka/KafkaRecordCoder.java | 10 +-
.../beam/sdk/io/kafka/KafkaSourceDescriptor.java | 47 +++---
.../beam/sdk/io/kafka/KafkaUnboundedReader.java | 63 +++++---
.../beam/sdk/io/kafka/KafkaUnboundedSource.java | 17 ++-
.../org/apache/beam/sdk/io/kafka/KafkaWriter.java | 67 +++++----
.../sdk/io/kafka/LocalDeserializerProvider.java | 11 +-
.../beam/sdk/io/kafka/ProducerRecordCoder.java | 22 +--
.../org/apache/beam/sdk/io/kafka/ProducerSpEL.java | 130 +++++++++--------
.../beam/sdk/io/kafka/ReadFromKafkaDoFn.java | 56 +++++---
.../beam/sdk/io/kafka/TopicPartitionCoder.java | 1 -
.../sdk/io/kafka/WatchKafkaTopicPartitionDoFn.java | 16 +--
.../io/kafka/LocalDeserializerProviderTest.java | 14 +-
.../beam/sdk/io/kafka/ReadFromKafkaDoFnTest.java | 2 +
.../beam/sdk/io/kafka/TopicPartitionCoderTest.java | 1 -
.../io/kafka/WatchKafkaTopicPartitionDoFnTest.java | 1 -
sdks/python/apache_beam/io/gcp/bigquery_test.py | 39 +++--
.../apache_beam/io/gcp/gcsio_integration_test.py | 12 +-
sdks/python/apache_beam/ml/inference/base.py | 5 +
.../apache_beam/ml/inference/pytorch_inference.py | 10 +-
.../apache_beam/ml/inference/sklearn_inference.py | 12 +-
.../python/apache_beam/options/pipeline_options.py | 8 ++
.../apache_beam/runners/dataflow/internal/names.py | 4 +-
sdks/python/apache_beam/runners/worker/logger.py | 8 +-
.../apache_beam/runners/worker/sdk_worker_main.py | 27 +++-
.../runners/worker/sdk_worker_main_test.py | 18 +++
website/www/site/assets/scss/_case_study.scss | 11 +-
website/www/site/content/en/case-studies/hop.md | 1 +
website/www/site/content/en/case-studies/lyft.md | 158 +++++++++++++++++++++
.../www/site/content/en/case-studies/paloalto.md | 1 +
.../www/site/content/en/case-studies/ricardo.md | 1 +
website/www/site/content/en/case-studies/seznam.md | 1 +
.../lyft/apache_beam_ml_features_generation.svg | 102 +++++++++++++
.../images/case-study/lyft/ravi_kiran_magham.png | Bin 0 -> 155159 bytes
.../site/static/images/logos/powered-by/lyft.png | Bin 0 -> 50028 bytes
60 files changed, 949 insertions(+), 347 deletions(-)
create mode 100644 website/www/site/content/en/case-studies/lyft.md
create mode 100644
website/www/site/static/images/case-study/lyft/apache_beam_ml_features_generation.svg
create mode 100644
website/www/site/static/images/case-study/lyft/ravi_kiran_magham.png
create mode 100644 website/www/site/static/images/logos/powered-by/lyft.png
