This is an automated email from the ASF dual-hosted git repository. kenn pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git.
from 1019ef3 Prepare a website update for 2.23.0 (#12212) add a443fdd Refactor Beam SQL QueryPlanner instantiation to be more type safe and robust add 8084d1b Move individual spotbug suppressions out of spotbugs-filter.xml and remove some global suppressions add 12631cb [BEAM-10575] Fix rawtypes in FileSystemRegistrar and implementations add 45d1a5c [BEAM-10556] Eliminate remaining trivial rawtypes in sdks/java/io/hadoop-file-system add eb20f3a [BEAM-10577] Eliminate remaining trivial rawtypes in sdks/java/io/azure add ab29122 [BEAM-10575] Eliminate rawtypes from GCP IOs and enable -Wrawtypes new c2eb01d Merge pull request #12376: [BEAM-10575] Eliminate legacy rawtypes from GCP IOs and some others; enable -Wrawtypes -Werror The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../apache/beam/examples/snippets/Snippets.java | 2 +- .../beam/examples/complete/AutoCompleteTest.java | 2 +- .../complete/game/StatefulTeamScoreTest.java | 1 - .../org/apache/beam/runners/core/DoFnRunner.java | 8 +- .../apache/beam/runners/core/PaneInfoTracker.java | 3 + .../org/apache/beam/runners/core/StateMerging.java | 2 + .../apache/beam/runners/core/SystemReduceFn.java | 2 + .../apache/beam/runners/core/WatermarkHold.java | 6 + .../direct/ExecutorServiceParallelExecutor.java | 13 + .../runners/direct/ParDoMultiOverrideFactory.java | 4 + .../beam/runners/flink/metrics/FileReporter.java | 3 + .../beam/runners/dataflow/TestDataflowRunner.java | 2 + .../runners/dataflow/util/OutputReference.java | 2 + .../beam/runners/dataflow/worker/graph/Nodes.java | 4 +- .../JulHandlerPrintStreamAdapterFactory.java | 15 +- .../jobsubmission/PortablePipelineJarCreator.java | 4 +- .../beam/runners/spark/metrics/sink/CsvSink.java | 3 + .../runners/spark/metrics/sink/GraphiteSink.java | 3 + .../src/main/resources/beam/spotbugs-filter.xml | 426 ++------------------- .../java/org/apache/beam/sdk/coders/AvroCoder.java | 5 + .../apache/beam/sdk/coders/SerializableCoder.java | 3 + .../sdk/expansion/ExternalTransformRegistrar.java | 2 +- .../apache/beam/sdk/io/ClassLoaderFileSystem.java | 2 +- .../apache/beam/sdk/io/FileSystemRegistrar.java | 2 +- .../org/apache/beam/sdk/io/GenerateSequence.java | 2 +- .../beam/sdk/io/LocalFileSystemRegistrar.java | 2 +- .../beam/sdk/options/ProxyInvocationHandler.java | 10 + .../java/org/apache/beam/sdk/testing/PAssert.java | 2 + .../beam/sdk/testing/SerializableMatchers.java | 2 + .../apache/beam/sdk/testing/WindowSupplier.java | 3 + .../java/org/apache/beam/sdk/transforms/Mean.java | 4 + .../org/apache/beam/sdk/util/CombineFnUtil.java | 4 + .../sdk/util/ExposedByteArrayOutputStream.java | 2 + .../beam/sdk/io/LocalFileSystemRegistrarTest.java | 3 +- .../sdk/expansion/service/ExpansionService.java | 14 +- .../google-cloud-platform-core/build.gradle | 1 - .../gcp/storage/GcsFileSystemRegistrar.java | 2 +- .../beam/sdk/extensions/gcp/util/GcsUtil.java | 3 + .../gcp/storage/GcsFileSystemRegistrarTest.java | 3 +- .../expansion/ExternalSqlTransformRegistrar.java | 2 +- .../beam/sdk/extensions/sql/jdbc/BeamSqlLine.java | 5 +- .../provider/bigquery/BigQueryIOPushDownIT.java | 3 +- .../beam/sdk/extensions/sql/impl/BeamSqlEnv.java | 31 +- .../extensions/sql/impl/CalciteQueryPlanner.java | 17 +- .../beam/sdk/extensions/sql/impl/QueryPlanner.java | 6 + .../extensions/sql/impl/planner/BeamRuleSets.java | 19 +- .../sql/impl/rule/IOPushDownRuleTest.java | 3 +- .../sql/impl/rule/JoinReorderingTest.java | 4 +- ...tTableProviderWithFilterAndProjectPushDown.java | 3 +- .../test/TestTableProviderWithFilterPushDown.java | 3 +- .../test/TestTableProviderWithProjectPushDown.java | 3 +- .../sql/zetasql/ZetaSQLQueryPlanner.java | 31 +- .../sql/zetasql/ZetaSQLPushDownTest.java | 3 +- .../extensions/sql/zetasql/ZetaSqlTestBase.java | 3 +- .../beam/sdk/io/aws/s3/S3FileSystemRegistrar.java | 2 +- sdks/java/io/azure/build.gradle | 3 +- .../AzureBlobStoreFileSystemRegistrar.java | 2 +- .../sdk/io/azure/blobstore/AzfsResourceIdTest.java | 2 +- sdks/java/io/google-cloud-platform/build.gradle | 1 - .../sdk/io/gcp/bigquery/BigQueryServicesImpl.java | 6 +- .../gcp/bigquery/BigQueryStorageStreamSource.java | 2 +- .../beam/sdk/io/gcp/bigquery/BigQueryUtils.java | 11 +- .../sdk/io/gcp/bigquery/TableRowInfoCoder.java | 4 +- .../beam/sdk/io/gcp/bigquery/TagWithUniqueIds.java | 5 +- .../beam/sdk/io/gcp/bigquery/WriteTables.java | 4 +- .../io/gcp/healthcare/HealthcareIOErrorCoder.java | 2 +- .../beam/sdk/io/gcp/pubsub/ExternalRead.java | 2 +- .../beam/sdk/io/gcp/pubsub/ExternalWrite.java | 2 +- .../beam/sdk/io/gcp/spanner/SpannerAccessor.java | 4 +- .../apache/beam/sdk/io/gcp/spanner/SpannerIO.java | 6 +- .../sdk/io/gcp/testing/FakeBigQueryServices.java | 2 +- .../sdk/io/gcp/bigquery/BigQueryIOReadTest.java | 6 +- .../gcp/bigquery/BigQueryIOStorageQueryTest.java | 2 +- .../io/gcp/bigquery/BigQueryIOStorageReadTest.java | 2 +- .../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 4 +- .../sdk/io/gcp/pubsub/PubsubIOExternalTest.java | 2 +- .../sdk/io/gcp/spanner/SpannerIOWriteTest.java | 31 +- sdks/java/io/hadoop-file-system/build.gradle | 1 - .../sdk/io/hdfs/HadoopFileSystemRegistrar.java | 4 +- .../sdk/io/hdfs/HadoopFileSystemModuleTest.java | 6 +- .../sdk/io/hdfs/HadoopFileSystemOptionsTest.java | 4 +- .../sdk/io/hdfs/HadoopFileSystemRegistrarTest.java | 2 +- .../java/org/apache/beam/sdk/io/jdbc/JdbcIO.java | 5 + .../beam/sdk/io/jdbc/JdbcReadRowsRegistrar.java | 2 +- .../beam/sdk/io/jdbc/JdbcWriteRegistrar.java | 2 +- .../java/org/apache/beam/sdk/io/jms/JmsRecord.java | 10 + .../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 20 +- .../testing/expansion/TestExpansionService.java | 4 +- 88 files changed, 346 insertions(+), 533 deletions(-)