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 c9ab4b6ae8d Add default_pickle_library_override delegation to
InteractiveRunner (#37752)
add e5db1b3c63e [Dataflow Java Streaming] Reset state using finally blocks
instead of catching Exception, in cases where it may otherwise corrupt
datastructures if an OutOfMemoryError is thrown. (#37746)
add e1e0637d989 [ErrorProne] Fix FormatStringShouldUsePlaceholders string
concat when Preconditions is used (#37745)
add eb5f9950c4a [Direct Runner] Fix test failure and logging configuration
by ensuring overridden Loggers are not garbaged collected (#37763)
add 7ba0efd4d24 [ErrorProne] Enable `MutablePublicArray` Error Prone Check
(#37761)
add 38b416cfb63 update java container version (#37756)
add d42111cd019 Merge pull request #37748: Where a Throwable is being
caught, take care to rethrow OutOfMemoryError
add 505ac1a9b22 Fix MissingSummary errorprone Warnings Across Codebase
add e7a97c26893 Fix MissingSummary errorprone Warnings Across Codebase
(#37759)
add 96306945ad6 refactor: Remove redundant protected access modifiers and
enable the `ProtectedMembersInFinalClass` ErrorProne check. (#37757)
add dfc0bd12021 Enable UseCorrectAssertInTests ErrorProne Check (#37766)
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 4 --
.../gcp/datastream/DatastreamResourceManager.java | 18 +++++---
.../beam/it/truthmatchers/ListAccumulator.java | 2 +-
.../org/apache/beam/runners/core/DoFnRunner.java | 3 +-
.../runners/core/PushbackSideInputDoFnRunner.java | 3 +-
.../apache/beam/runners/core/SimpleDoFnRunner.java | 18 ++++----
.../beam/runners/core/metrics/BoundedTrieData.java | 2 +-
.../core/metrics/MonitoringInfoMetricName.java | 2 +-
.../runners/core/metrics/SimpleStateRegistry.java | 2 +-
.../core/triggers/AfterWatermarkStateMachine.java | 2 +-
.../apache/beam/runners/direct/DirectRunner.java | 12 +++--
.../flink/adapter/BeamFlinkDataStreamAdapter.java | 3 +-
.../functions/FlinkSideInputReader.java | 2 +-
runners/google-cloud-dataflow-java/build.gradle | 4 +-
.../beam/runners/dataflow/util/PackageUtil.java | 10 ++--
.../dataflow/worker/BatchDataflowWorker.java | 4 +-
.../dataflow/worker/BatchModeExecutionContext.java | 6 ++-
.../dataflow/worker/GroupAlsoByWindowFnRunner.java | 6 +--
.../dataflow/worker/GroupAlsoByWindowsParDoFn.java | 2 +
.../MetricsToPerStepNamespaceMetricsConverter.java | 7 +--
.../worker/StreamingStepMetricsContainer.java | 5 +-
.../beam/runners/dataflow/worker/WindmillSink.java | 54 +++++++++++++---------
.../dataflow/worker/WorkerCustomSources.java | 6 +++
.../logging/DataflowWorkerLoggingHandler.java | 2 +-
.../runners/dataflow/worker/util/JfrInterop.java | 2 +
.../dataflow/worker/util/MemoryMonitor.java | 2 +-
.../util/ThreadLocalByteStringOutputStream.java | 2 +-
.../common/worker/BatchingShuffleEntryReader.java | 2 +-
.../common/worker/CachingShuffleBatchReader.java | 4 +-
.../util/common/worker/WorkProgressUpdater.java | 10 +++-
.../windmill/client/AbstractWindmillStream.java | 41 +++++++++-------
.../windmill/client/grpc/GrpcGetDataStream.java | 14 +++---
.../dataflow/worker/windmill/state/RangeCoder.java | 4 +-
.../windmill/state/WindmillTagEncodingV1.java | 2 +-
.../windmill/state/WindmillTagEncodingV2.java | 2 +-
.../work/processing/StreamingCommitFinalizer.java | 2 +
.../artifact/ArtifactStagingService.java | 2 +
.../control/ProcessBundleDescriptors.java | 2 +-
...renceCountingExecutableStageContextFactory.java | 4 +-
.../environment/EmbeddedEnvironmentFactory.java | 2 +
.../beam/runners/jobsubmission/JobInvocation.java | 2 +-
.../apache/beam/runners/prism/PrismLocator.java | 2 +-
.../samza/runtime/ClassicBundleManager.java | 11 +++--
.../runners/samza/translation/ConfigBuilder.java | 2 +-
.../spark/translation/SparkInputDataProcessor.java | 4 +-
.../java/org/apache/beam/sdk/PipelineResult.java | 4 +-
.../apache/beam/sdk/coders/BigDecimalCoder.java | 4 +-
.../sdk/coders/CannotProvideCoderException.java | 2 +-
.../org/apache/beam/sdk/coders/DelegateCoder.java | 2 +-
.../beam/sdk/coders/StringDelegateCoder.java | 2 +-
.../sdk/fn/data/BeamFnDataOutboundAggregator.java | 2 +
.../org/apache/beam/sdk/io/CompressedSource.java | 20 ++++----
.../java/org/apache/beam/sdk/io/FileBasedSink.java | 24 +++++-----
.../java/org/apache/beam/sdk/io/TFRecordIO.java | 10 ++--
.../main/java/org/apache/beam/sdk/io/TextIO.java | 16 +++----
.../java/org/apache/beam/sdk/io/TextSource.java | 6 +--
.../apache/beam/sdk/metrics/BoundedTrieResult.java | 2 +-
.../apache/beam/sdk/metrics/StringSetResult.java | 2 +-
.../org/apache/beam/sdk/options/ValueProvider.java | 2 +
.../apache/beam/sdk/runners/AppliedPTransform.java | 2 +-
.../apache/beam/sdk/schemas/AutoValueSchema.java | 10 ++--
.../apache/beam/sdk/schemas/JavaBeanSchema.java | 10 ++--
.../apache/beam/sdk/schemas/JavaFieldSchema.java | 10 ++--
.../beam/sdk/transforms/ApproximateUnique.java | 2 +
.../beam/sdk/transforms/DoFnOutputReceivers.java | 3 +-
.../beam/sdk/transforms/GroupIntoBatches.java | 6 +--
.../apache/beam/sdk/transforms/Redistribute.java | 6 ++-
.../beam/sdk/transforms/display/DisplayData.java | 2 +
.../reflect/ByteBuddyDoFnInvokerFactory.java | 4 +-
.../sdk/transforms/reflect/DoFnSignatures.java | 4 +-
.../sdk/transforms/windowing/AfterWatermark.java | 4 +-
.../org/apache/beam/sdk/util/InstanceBuilder.java | 24 ++++------
.../java/org/apache/beam/sdk/util/MoreFutures.java | 4 ++
.../org/apache/beam/sdk/util/MutationDetector.java | 2 +-
.../util/construction/PTransformReplacements.java | 2 +-
.../org/apache/beam/sdk/values/WindowedValues.java | 2 +-
.../test/java/org/apache/beam/sdk/TestUtils.java | 10 ++--
.../beam/sdk/coders/BigDecimalCoderTest.java | 1 -
.../org/apache/beam/sdk/io/TextIOReadTest.java | 8 ++--
.../org/apache/beam/sdk/io/TextIOWriteTest.java | 33 ++++++-------
.../org/apache/beam/sdk/transforms/CreateTest.java | 7 ++-
.../apache/beam/sdk/transforms/FlattenTest.java | 12 ++---
.../euphoria/core/annotation/operator/Basic.java | 4 +-
.../euphoria/core/annotation/operator/Derived.java | 4 +-
.../core/annotation/operator/Recommended.java | 8 ++--
.../extensions/euphoria/core/client/lib/Split.java | 4 +-
.../core/client/operator/AssignEventTime.java | 9 ++--
.../euphoria/core/client/operator/ReduceByKey.java | 4 +-
.../sdk/extensions/gcp/util/CustomHttpErrors.java | 2 +-
.../sdk/extensions/gcp/util/GceMetadataUtil.java | 2 +-
.../extensions/gcp/util/HttpCallCustomError.java | 2 +-
.../sdk/extensions/gcp/util/HttpCallMatcher.java | 2 +-
.../gcp/util/RetryHttpRequestInitializer.java | 12 ++++-
.../kafka/factories/FileAwareFactoryFn.java | 8 ++--
.../beam/sdk/extensions/ml/DLPDeidentifyText.java | 49 +++++++++++++++-----
.../beam/sdk/extensions/ml/DLPInspectText.java | 36 +++++++++++----
.../beam/sdk/extensions/ml/DLPReidentifyText.java | 48 ++++++++++++++-----
.../ml/RecommendationAICreateCatalogItem.java | 18 ++++++--
.../ml/RecommendationAIImportCatalogItems.java | 27 ++++++++---
.../ml/RecommendationAIImportUserEvents.java | 35 ++++++++++----
.../sdk/extensions/ml/RecommendationAIPredict.java | 32 +++++++++----
.../ml/RecommendationAIWriteUserEvent.java | 24 +++++++---
.../ordered/ContiguousSequenceRange.java | 6 +--
.../ordered/OrderedEventProcessorResult.java | 14 +++---
.../ordered/OrderedProcessingHandler.java | 2 +-
.../ordered/OrderedProcessingStatus.java | 28 +++++------
.../beam/sdk/extensions/ordered/ProcessorDoFn.java | 2 +-
.../extensions/sketching/ApproximateDistinct.java | 5 +-
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 41 ++++++++--------
.../SplittablePairWithRestrictionDoFnRunner.java | 2 +
...littableSplitAndSizeRestrictionsDoFnRunner.java | 2 +
...ittableTruncateSizedRestrictionsDoFnRunner.java | 2 +
.../fn/harness/control/ProcessBundleHandler.java | 2 +
.../harness/data/PTransformFunctionRegistry.java | 4 +-
.../fn/harness/logging/BeamFnLoggingClient.java | 2 +
.../apache/beam/fn/harness/logging/QuotaEvent.java | 16 ++++++-
.../fn/harness/state/FnApiTimerBundleTracker.java | 2 +
.../beam/sdk/io/aws2/kinesis/KinesisRecord.java | 8 ++--
.../apache/beam/sdk/io/cassandra/CassandraIO.java | 23 ++++-----
.../apache/beam/sdk/io/cassandra/RingRange.java | 4 +-
.../beam/sdk/io/common/NetworkTestHelper.java | 2 +-
.../io/contextualtextio/ContextualTextIOTest.java | 12 ++---
.../io/gcp/bigquery/BeamRowToStorageApiProto.java | 10 ++--
.../sdk/io/gcp/bigquery/BigQuerySinkMetrics.java | 13 ++++--
.../beam/sdk/io/gcp/bigquery/BigQueryUtils.java | 23 +++++----
.../changestreams/dao/MetadataTableAdminDao.java | 2 +-
.../changestreams/dao/MetadataTableDao.java | 8 ++--
.../beam/sdk/io/gcp/firestore/FirestoreDoFn.java | 8 ++--
.../apache/beam/sdk/io/gcp/firestore/RpcQos.java | 10 ++--
.../apache/beam/sdk/io/gcp/healthcare/FhirIO.java | 2 +-
.../beam/sdk/io/gcp/spanner/OrderedCode.java | 2 +-
...artitionQueryResponseToRunQueryRequestTest.java | 2 +-
.../java/org/apache/beam/sdk/io/jdbc/JdbcUtil.java | 4 +-
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 6 +--
.../KafkaIOReadImplementationCompatibility.java | 8 ++--
.../beam/sdk/io/kafka/KafkaUnboundedSource.java | 8 ++--
.../sdk/io/kafka/WatchForKafkaTopicPartitions.java | 6 +--
.../beam/sdk/io/sparkreceiver/HasOffset.java | 8 +++-
.../beam/sdk/io/sparkreceiver/ReceiverBuilder.java | 4 +-
.../java/org/apache/beam/sdk/io/xml/XmlIO.java | 14 +++---
.../apache/beam/sdk/nexmark/NexmarkQueryName.java | 4 +-
141 files changed, 722 insertions(+), 492 deletions(-)
