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 f1a0855b9bb Fix PostCommit Python ValidatesContainer Dataflow With RC
job (#36016)
add 17d5039a02f Bump github.com/aws/aws-sdk-go-v2/config from 1.31.4 to
1.31.6 in /sdks (#36025)
add 2ab70ffabea Upgrade Errorprone to 2.31.0 (#35684)
No new revisions were added by this update.
Summary of changes:
buildSrc/build.gradle.kts | 2 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 139 +++++++++++++--------
.../examples/complete/StreamingWordExtract.java | 12 +-
.../datatokenization/utils/SchemasUtils.java | 2 +-
.../beam/it/common/utils/ResourceManagerUtils.java | 3 +-
.../org/apache/beam/it/gcp/IOLoadTestBase.java | 2 +-
.../gcp/artifacts/matchers/ArtifactsSubject.java | 1 +
.../beam/it/gcp/bigquery/BigQueryStreamingLT.java | 4 +-
.../apache/beam/runners/core/PaneInfoTracker.java | 2 +-
.../core/SplittableParDoViaKeyedWorkItems.java | 3 +-
.../org/apache/beam/runners/core/StateMerging.java | 8 +-
.../org/apache/beam/runners/core/StateTags.java | 3 +-
.../apache/beam/runners/core/TimerInternals.java | 7 +-
.../apache/beam/runners/core/WatermarkHold.java | 7 +-
.../runners/core/metrics/MetricsContainerImpl.java | 5 +-
.../runners/core/metrics/SimpleExecutionState.java | 2 +-
.../triggers/ExecutableTriggerStateMachine.java | 8 +-
.../core/metrics/MetricsContainerStepMapTest.java | 2 +-
.../runners/core/metrics/MetricsPusherTest.java | 2 +-
.../triggers/ReshuffleTriggerStateMachineTest.java | 3 +-
.../beam/runners/direct/DirectRunnerTest.java | 2 +
.../runners/flink/FlinkDetachedRunnerResult.java | 2 +-
.../beam/runners/dataflow/BatchViewOverrides.java | 6 +-
.../beam/runners/dataflow/DataflowPipelineJob.java | 3 +-
.../dataflow/worker/WindmillTimerInternals.java | 70 ++++++-----
.../dataflow/worker/WorkerCustomSources.java | 3 +-
.../worker/windmill/state/ToIterableFunction.java | 6 +-
.../dataflow/worker/GroupingShuffleReaderTest.java | 2 +-
.../dataflow/worker/IsmSideInputReaderTest.java | 6 +-
.../worker/StreamingSideInputDoFnRunnerTest.java | 6 +-
.../worker/StreamingSideInputFetcherTest.java | 2 +-
.../worker/util/GroupAlsoByWindowProperties.java | 9 +-
.../windmill/state/WindmillStateInternalsTest.java | 16 +--
.../fnexecution/environment/DockerCommand.java | 2 +-
.../PortablePipelineJarCreatorTest.java | 1 +
.../java/org/apache/beam/runners/jet/Utils.java | 6 +-
.../org/apache/beam/runners/jet/TestStreamP.java | 2 +-
.../beam/runners/samza/SamzaPipelineResult.java | 1 +
.../beam/runners/samza/runtime/OpMessage.java | 2 +-
.../samza/translation/TranslationContext.java | 4 +-
.../samza/adapter/BoundedSourceSystemTest.java | 3 +-
.../translation/EvaluationContext.java | 1 +
.../GroupNonMergingWindowsFunctions.java | 11 +-
.../spark/translation/TransformTranslator.java | 2 +-
.../streaming/StreamingTransformTranslator.java | 2 +-
.../runners/spark/util/SideInputBroadcast.java | 1 +
.../streaming/utils/EmbeddedKafkaCluster.java | 5 +-
sdks/go.mod | 20 +--
sdks/go.sum | 40 +++---
.../apache/beam/sdk/jmh/schemas/RowBundles.java | 1 +
.../sdk/fn/data/BeamFnDataGrpcMultiplexer.java | 1 +
.../sdk/fn/data/BeamFnDataInboundObserver.java | 1 +
.../server/GrpcContextHeaderAccessorProvider.java | 2 +-
.../src/main/java/org/apache/beam/sdk/io/Read.java | 1 +
.../java/org/apache/beam/sdk/io/WriteFiles.java | 2 +-
.../beam/sdk/options/PipelineOptionsFactory.java | 7 +-
.../apache/beam/sdk/schemas/transforms/Select.java | 1 +
.../org/apache/beam/sdk/testing/TestStream.java | 2 +-
.../beam/sdk/transforms/DoFnOutputReceivers.java | 4 +-
.../beam/sdk/transforms/DoFnSchemaInformation.java | 2 +-
.../apache/beam/sdk/transforms/MapElements.java | 1 +
.../java/org/apache/beam/sdk/transforms/Reify.java | 2 +-
.../java/org/apache/beam/sdk/transforms/Wait.java | 2 +-
.../beam/sdk/transforms/join/CoGbkResult.java | 2 +-
.../sdk/transforms/reflect/DoFnSignatures.java | 2 +-
.../org/apache/beam/sdk/util/CombineFnUtil.java | 2 +-
.../construction/GroupIntoBatchesTranslation.java | 2 +-
.../sdk/util/construction/ParDoTranslation.java | 2 +-
.../sdk/util/construction/SplittableParDo.java | 2 +-
.../sdk/util/construction/TransformUpgrader.java | 18 +--
.../sdk/util/construction/UnconsumedReads.java | 2 +-
.../main/java/org/apache/beam/sdk/values/Row.java | 3 +-
.../org/apache/beam/sdk/coders/ZstdCoderTest.java | 1 +
.../org/apache/beam/sdk/io/CountingSourceTest.java | 2 +-
.../org/apache/beam/sdk/io/FileSystemsTest.java | 1 +
.../sdk/options/PipelineOptionsFactoryTest.java | 2 +-
.../beam/sdk/schemas/AutoValueSchemaTest.java | 2 +-
.../beam/sdk/schemas/JavaBeanSchemaTest.java | 2 +-
.../beam/sdk/schemas/JavaFieldSchemaTest.java | 4 +-
.../beam/sdk/schemas/transforms/GroupTest.java | 4 +-
.../beam/sdk/schemas/utils/TestJavaBeans.java | 4 +-
.../beam/sdk/transforms/GroupIntoBatchesTest.java | 4 +-
.../util/construction/CombineTranslationTest.java | 4 +-
.../beam/sdk/values/EncodableThrowableTest.java | 5 +-
.../beam/sdk/values/TypeDescriptorsTest.java | 1 +
.../sdk/expansion/service/ExpansionService.java | 2 +-
.../extensions/protobuf/ProtoByteBuddyUtils.java | 4 +-
.../sketching/ApproximateDistinctTest.java | 2 +-
.../extensions/sketching/TDigestQuantilesTest.java | 2 +-
sdks/java/extensions/sql/build.gradle | 3 +-
.../sql/impl/transform/agg/CovarianceFn.java | 4 +-
.../sql/impl/transform/agg/VarianceFn.java | 4 +-
...ittableTruncateSizedRestrictionsDoFnRunner.java | 2 +-
.../fn/harness/control/ProcessBundleHandler.java | 4 +-
.../apache/beam/sdk/io/aws2/kinesis/KinesisIO.java | 2 +-
.../apache/beam/sdk/io/aws2/StaticSupplier.java | 1 +
.../io/cdap/context/FailureCollectorWrapper.java | 2 +-
.../cdap/context/FailureCollectorWrapperTest.java | 9 +-
.../beam/sdk/io/common/DatabaseTestHelper.java | 2 +-
.../org/apache/beam/sdk/io/common/IOITHelper.java | 2 +-
.../DebeziumReadSchemaTransformProvider.java | 3 +-
.../FileWriteSchemaTransformFormatProviders.java | 2 +-
.../sdk/io/fileschematransform/XmlRowAdapter.java | 1 +
.../beam/sdk/io/googleads/GoogleAdsIOTest.java | 1 +
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 3 +-
.../sdk/io/gcp/bigquery/BigQuerySourceBase.java | 3 +-
.../beam/sdk/io/gcp/datastore/DatastoreV1.java | 6 +-
.../apache/beam/sdk/io/gcp/healthcare/FhirIO.java | 1 -
.../beam/sdk/io/gcp/pubsub/PubsubTestClient.java | 4 +-
.../gcp/pubsublite/internal/CloserReference.java | 2 +-
.../gcp/pubsublite/internal/MemoryLimiterImpl.java | 1 +
.../beam/sdk/io/gcp/spanner/SpannerAccessor.java | 2 +-
.../apache/beam/sdk/io/gcp/spanner/SpannerIO.java | 5 +-
.../action/DetectNewPartitionsAction.java | 2 +-
.../action/QueryChangeStreamAction.java | 2 +-
.../sdk/io/gcp/testing/FakeDatasetService.java | 3 +-
.../BigtableReadSchemaTransformProviderIT.java | 2 +-
.../beam/sdk/io/gcp/datastore/V1TestUtil.java | 5 +-
.../beam/sdk/io/gcp/pubsub/PubsubIOTest.java | 38 ++----
.../beam/sdk/io/gcp/spanner/SpannerIOReadTest.java | 2 +-
.../changestreams/it/IntegrationTestEnv.java | 1 -
.../beam/sdk/io/hbase/HBaseRowMutationsCoder.java | 4 +-
.../java/org/apache/beam/sdk/io/jdbc/JdbcIO.java | 2 +
.../java/org/apache/beam/sdk/io/jms/JmsIO.java | 1 +
.../sdk/io/kafka/jmh/KafkaIOUtilsBenchmark.java | 1 +
.../beam/sdk/io/kafka/KafkaCommitOffset.java | 2 +
.../org/apache/beam/sdk/io/kafka/KafkaWriter.java | 2 +-
.../org/apache/beam/sdk/io/kafka/KafkaIOIT.java | 5 +-
.../org/apache/beam/sdk/io/kafka/KafkaIOTest.java | 23 ++--
.../apache/beam/sdk/io/pulsar/PulsarIOUtils.java | 1 -
.../beam/sdk/io/pulsar/ReadFromPulsarDoFn.java | 1 -
.../apache/beam/sdk/io/pulsar/PulsarIOTest.java | 2 +
.../sparkreceiver/RabbitMqReceiverWithOffset.java | 2 +-
.../sdk/io/sparkreceiver/SparkReceiverIOIT.java | 2 +-
.../beam/sdk/io/splunk/SplunkEventWriter.java | 6 +-
.../beam/sdk/io/synthetic/BundleSplitterTest.java | 4 +-
.../testutils/publishing/InfluxDBPublisher.java | 2 +-
137 files changed, 380 insertions(+), 367 deletions(-)
