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 dfc0bd12021 Enable UseCorrectAssertInTests ErrorProne Check (#37766)
add 298f3090920 Fix InlineFormatString Error Prone checks (#37768)
add e28ed02b9b8 Add Apache Beam installation to Dockerfile
add 08af69c65f6 Install setuptools for playground cd examples
add f682a85fbbe Merge pull request #37619 from
apache/playground-interactive
add 828914840df [Dataflow Java Streaming] Ensure that OutOfMemoryError
triggers JVM shutdown instead of being retried. This matches MemoryMonitor
detection of gc thrashing and prevents workers from remaining in broken state
that may be fixed by restarting (#37749)
add b42c992c7d4 [ErrorProne] Fix BadInstanceof and enable check (#37753)
add 676c998dec7 Enable StringCharset Error Prone Check (#37767)
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 3 -
.../examples/complete/game/injector/Injector.java | 6 +-
.../org/apache/beam/it/common/TestProperties.java | 6 +-
playground/backend/containers/python/Dockerfile | 4 +-
.../cloudbuild/playground_cd_examples.sh | 9 +-
.../functions/ImpulseSourceFunctionTest.java | 3 +-
.../flink/FlinkStreamingTranslationContext.java | 2 +-
.../flink/PipelineTranslationModeOptimizer.java | 2 +-
.../translation/utils/LookupPipelineVisitor.java | 2 +-
.../functions/ImpulseSourceFunctionTest.java | 3 +-
.../work/processing/StreamingWorkScheduler.java | 21 ++--
.../processing/failures/WorkFailureProcessor.java | 118 ++++++++++++---------
.../failures/WorkFailureProcessorTest.java | 22 ++--
.../java/org/apache/beam/runners/jet/Utils.java | 2 +-
.../samza/metrics/SamzaTransformMetrics.java | 3 +-
.../translation/ParDoBoundMultiTranslator.java | 4 +-
.../translation/SplittableParDoTranslators.java | 2 +-
.../spark/translation/EvaluationContext.java | 2 +-
.../twister2/Twister2TranslationContext.java | 2 +-
.../util/construction/PTransformReplacements.java | 4 +-
.../sdk/util/construction/ParDoTranslation.java | 2 +-
.../beam/sdk/schemas/JsonSchemaConversionTest.java | 15 +--
.../sdk/expansion/service/TransformProvider.java | 2 +-
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 10 +-
.../sdk/io/gcp/spanner/ReadSpannerSchemaTest.java | 4 +-
.../sdk/io/gcp/spanner/SpannerIOWriteTest.java | 8 +-
.../org/apache/beam/sdk/io/kafka/KafkaDlqTest.java | 14 +--
.../beam/sdk/io/kafka/KafkaIOExternalTest.java | 12 ++-
.../KafkaWriteSchemaTransformProviderTest.java | 22 ++--
.../beam/sdk/io/splunk/HttpEventPublisher.java | 4 +-
.../beam/sdk/nexmark/queries/Query4Model.java | 2 +-
.../beam/sdk/nexmark/queries/Query6Model.java | 2 +-
32 files changed, 174 insertions(+), 143 deletions(-)
