This is an automated email from the ASF dual-hosted git repository.
bhulette pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 918f345 [BEAM-13244] Support STS Assume role credentials provider for
AWS SDK v2 (#16116)
add b52762b [BEAM-11936] Fix errorprone UnusedVariable in
core,examples,harness.. (#16037)
No new revisions were added by this update.
Summary of changes:
.../examples/complete/game/StatefulTeamScore.java | 3 +-
.../beam/examples/cookbook/JoinExamples.java | 3 +-
.../apache/beam/examples/snippets/Snippets.java | 3 +-
.../examples/subprocess/ExampleEchoPipeline.java | 1 -
.../subprocess/kernel/SubProcessKernel.java | 2 -
.../examples/subprocess/utils/ExecutableFile.java | 4 --
.../examples/complete/TrafficMaxLaneFlowIT.java | 4 +-
.../beam/examples/complete/TrafficRoutesIT.java | 3 -
.../datatokenization/DataTokenizationTest.java | 2 -
.../subprocess/ExampleEchoPipelineTest.java | 2 -
sdks/java/build-tools/build.gradle | 2 +-
.../apache/beam/codestyle/CodeStyleTestClass.java | 2 -
sdks/java/core/build.gradle | 1 -
.../apache/beam/sdk/coders/RowCoderGenerator.java | 4 --
.../beam/sdk/io/ReadAllViaFileBasedSource.java | 3 -
.../beam/sdk/metrics/MetricQueryResults.java | 1 -
.../beam/sdk/options/PipelineOptionsFactory.java | 5 +-
.../java/org/apache/beam/sdk/schemas/Schema.java | 4 --
.../apache/beam/sdk/schemas/transforms/Filter.java | 3 +-
.../sdk/schemas/transforms/SchemaAggregateFn.java | 2 -
.../apache/beam/sdk/schemas/transforms/Select.java | 6 --
.../beam/sdk/schemas/utils/AutoValueUtils.java | 2 -
.../org/apache/beam/sdk/state/StateKeySpec.java | 14 +---
.../apache/beam/sdk/transforms/Deduplicate.java | 2 +
.../beam/sdk/transforms/DoFnSchemaInformation.java | 17 +----
.../beam/sdk/transforms/GroupIntoBatches.java | 10 ++-
.../java/org/apache/beam/sdk/transforms/ParDo.java | 4 +-
.../java/org/apache/beam/sdk/transforms/Watch.java | 4 --
.../reflect/ByteBuddyDoFnInvokerFactory.java | 3 -
.../reflect/ByteBuddyOnTimerInvokerFactory.java | 6 --
.../beam/sdk/transforms/reflect/DoFnInvokers.java | 6 +-
.../sdk/transforms/reflect/DoFnSignatures.java | 15 ----
.../main/java/org/apache/beam/sdk/values/Row.java | 1 -
.../sdk/coders/PCollectionCustomCoderTest.java | 3 -
.../org/apache/beam/sdk/io/TextIOWriteTest.java | 17 +++--
.../beam/sdk/io/TextRowCountEstimatorTest.java | 5 +-
.../apache/beam/sdk/io/range/ByteKeyRangeTest.java | 4 +-
.../apache/beam/sdk/schemas/AvroSchemaTest.java | 3 -
.../sdk/schemas/FieldAccessDescriptorTest.java | 4 +-
.../beam/sdk/schemas/JavaBeanSchemaTest.java | 2 +-
.../apache/beam/sdk/schemas/SchemaOptionsTest.java | 2 +-
.../beam/sdk/schemas/transforms/CoGroupTest.java | 48 ++++++-------
.../beam/sdk/schemas/transforms/GroupTest.java | 10 ++-
.../beam/sdk/schemas/transforms/SelectTest.java | 13 ++--
.../beam/sdk/schemas/utils/SelectHelpersTest.java | 6 +-
.../apache/beam/sdk/testing/TestStreamTest.java | 3 +
.../apache/beam/sdk/transforms/GroupByKeyTest.java | 3 +-
.../org/apache/beam/sdk/transforms/LatestTest.java | 3 -
.../beam/sdk/transforms/ParDoLifecycleTest.java | 1 +
.../beam/sdk/transforms/ParDoSchemaTest.java | 4 ++
.../org/apache/beam/sdk/transforms/ParDoTest.java | 47 ++++++------
.../beam/sdk/transforms/PerKeyOrderingTest.java | 9 +--
.../beam/sdk/transforms/WithFailuresTest.java | 3 -
.../sdk/transforms/display/DisplayDataTest.java | 6 +-
.../sdk/transforms/reflect/DoFnInvokersTest.java | 5 +-
.../reflect/DoFnSignaturesSplittableDoFnTest.java | 16 ++---
.../sdk/transforms/reflect/DoFnSignaturesTest.java | 83 +++++++++++++++-------
.../transforms/reflect/OnTimerInvokersTest.java | 2 +
.../reflect/testhelper/DoFnInvokersTestHelper.java | 7 ++
.../GrowableOffsetRangeTrackerTest.java | 2 +-
.../splittabledofn/OffsetRangeTrackerTest.java | 2 +-
.../beam/sdk/util/MutationDetectorsTest.java | 2 +-
.../java/org/apache/beam/sdk/values/RowTest.java | 4 +-
sdks/java/expansion-service/build.gradle | 1 -
.../JavaClassLookupTransformProviderTest.java | 2 -
sdks/java/fn-execution/build.gradle | 1 -
sdks/java/harness/build.gradle | 1 -
.../beam/fn/harness/BeamFnDataWriteRunner.java | 4 --
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 10 +--
.../fn/harness/control/FinalizeBundleHandler.java | 17 +++--
.../fn/harness/control/ProcessBundleHandler.java | 2 -
.../harness/data/PCollectionConsumerRegistry.java | 2 -
.../beam/fn/harness/status/MemoryMonitor.java | 1 +
.../beam/fn/harness/FnApiDoFnRunnerTest.java | 9 +--
.../harness/control/ProcessBundleHandlerTest.java | 1 +
.../state/BeamFnStateGrpcClientCacheTest.java | 8 ---
.../state/CachingBeamFnStateClientTest.java | 8 +--
.../fn/harness/status/BeamFnStatusClientTest.java | 11 ++-
sdks/java/javadoc/build.gradle | 2 +-
sdks/java/maven-archetypes/examples/build.gradle | 2 +-
.../maven-archetypes/gcp-bom-examples/build.gradle | 2 +-
sdks/java/maven-archetypes/starter/build.gradle | 2 +-
sdks/java/testing/expansion-service/build.gradle | 1 -
sdks/java/testing/jpms-tests/build.gradle | 1 -
sdks/java/testing/kafka-service/build.gradle | 2 +-
sdks/java/testing/load-tests/build.gradle | 1 -
.../beam/sdk/loadtests/SideInputLoadTest.java | 3 +
sdks/java/testing/nexmark/build.gradle | 1 -
.../java/org/apache/beam/sdk/nexmark/Main.java | 7 +-
.../apache/beam/sdk/nexmark/NexmarkLauncher.java | 3 -
.../org/apache/beam/sdk/nexmark/NexmarkUtils.java | 3 +-
.../beam/sdk/nexmark/model/sql/SelectEvent.java | 1 -
.../beam/sdk/nexmark/queries/NexmarkQuery.java | 7 --
.../apache/beam/sdk/nexmark/queries/Query10.java | 1 +
.../apache/beam/sdk/nexmark/queries/Query3.java | 7 +-
.../queries/sql/SqlBoundedSideInputJoin.java | 3 -
.../beam/sdk/nexmark/queries/sql/SqlQuery0.java | 6 +-
.../beam/sdk/nexmark/queries/sql/SqlQuery2.java | 2 +-
sdks/java/testing/test-utils/build.gradle | 1 -
sdks/java/testing/tpcds/build.gradle | 1 -
sdks/java/testing/watermarks/build.gradle | 1 -
101 files changed, 236 insertions(+), 365 deletions(-)
