You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2025/02/15 03:44:35 UTC
(beam) branch nightly-refs/heads/master updated (ca070b2f50f -> eea972f92d4)
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 ca070b2f50f Update code-change-guide.md (#33985)
add f63446f4d6a sdks/java: support non-ascii BigQuery table name (#33990)
add 64b0e76154a [Managed Iceberg] custom equals method for SerializedDataFile (#33554)
add 12e4132c347 Add await for remove label (#33992)
add 2317228da4d Add Lineage known issues for Beam 2.59.0; update blog post (#33993)
add eea972f92d4 Eliminate usage of deprecated org.mockito.Matcherss (#33908)
No new revisions were added by this update.
Summary of changes:
.../IO_Iceberg_Integration_Tests.json | 2 +-
.github/workflows/self-assign.yml | 4 +-
CHANGES.md | 9 +++
.../beam/runners/core/ReduceFnRunnerTest.java | 2 +-
...cycleManagerRemovingTransformEvaluatorTest.java | 2 +-
.../direct/StatefulParDoEvaluatorFactoryTest.java | 10 +--
.../direct/UnboundedReadEvaluatorFactoryTest.java | 2 +-
.../flink/metrics/FlinkMetricContainerTest.java | 6 +-
.../FlinkExecutableStageFunctionTest.java | 2 +-
.../functions/ImpulseSourceFunctionTest.java | 6 +-
.../streaming/ExecutableStageDoFnOperatorTest.java | 2 +-
.../dataflow/BatchStatefulParDoOverridesTest.java | 2 +-
.../runners/dataflow/DataflowPipelineJobTest.java | 4 +-
.../dataflow/DataflowPipelineTranslatorTest.java | 6 +-
.../runners/dataflow/TestDataflowRunnerTest.java | 2 +-
.../runners/dataflow/util/PackageUtilTest.java | 4 +-
.../worker/DataflowWorkProgressUpdaterTest.java | 4 +-
.../IntrinsicMapTaskExecutorFactoryTest.java | 6 +-
.../worker/IntrinsicMapTaskExecutorTest.java | 4 +-
.../LazilyInitializedSideInputReaderTest.java | 2 +-
.../worker/PartialGroupByKeyParDoFnsTest.java | 12 +--
.../worker/StreamingDataflowWorkerTest.java | 2 +-
...eamingKeyedWorkItemSideInputDoFnRunnerTest.java | 4 +-
.../worker/StreamingSideInputDoFnRunnerTest.java | 4 +-
.../worker/StreamingSideInputFetcherTest.java | 4 +-
.../dataflow/worker/UserParDoFnFactoryTest.java | 2 +-
.../dataflow/worker/WorkItemStatusClientTest.java | 4 +-
.../dataflow/worker/status/DebugCaptureTest.java | 4 +-
.../harness/StreamingWorkerStatusReporterTest.java | 4 +-
.../sideinput/SideInputStateFetcherTest.java | 2 +-
.../util/common/worker/MapTaskExecutorTest.java | 4 +-
.../util/common/worker/ParDoOperationTest.java | 4 +-
.../util/common/worker/ReadOperationTest.java | 8 +-
.../worker/util/common/worker/StubbedExecutor.java | 4 +-
.../common/worker/WorkProgressUpdaterTest.java | 2 +-
.../util/common/worker/WriteOperationTest.java | 4 +-
.../windmill/state/WindmillStateInternalsTest.java | 2 +-
.../control/DefaultJobBundleFactoryTest.java | 2 +-
.../control/FnApiControlClientPoolServiceTest.java | 2 +-
.../control/FnApiControlClientTest.java | 2 +-
...eCountingExecutableStageContextFactoryTest.java | 2 +-
.../fnexecution/control/SdkHarnessClientTest.java | 4 +-
...gleEnvironmentInstanceJobBundleFactoryTest.java | 2 +-
.../environment/ProcessEnvironmentFactoryTest.java | 6 +-
.../fnexecution/state/GrpcStateServiceTest.java | 2 +-
.../jobsubmission/InMemoryJobServiceTest.java | 2 +-
.../PortablePipelineJarCreatorTest.java | 2 +-
.../samza/runtime/ClassicBundleManagerTest.java | 2 +-
.../SparkExecutableStageFunctionTest.java | 2 +-
.../main/resources/beam/checkstyle/checkstyle.xml | 8 ++
.../sdk/transforms/reflect/DoFnInvokersTest.java | 22 ++---
.../org/apache/beam/sdk/util/CoderUtilsTest.java | 2 +-
.../util/FilePatternMatchingShardedFileTest.java | 2 +-
.../beam/sdk/util/NumberedShardedFileTest.java | 2 +-
.../construction/ForwardingPTransformTest.java | 2 +-
.../sdk/extensions/gcp/options/GcpOptionsTest.java | 2 +-
.../extensions/gcp/storage/GcsFileSystemTest.java | 4 +-
.../gcp/storage/GcsPathValidatorTest.java | 2 +-
.../beam/sdk/extensions/gcp/util/GcsUtilTest.java | 2 +-
...LatencyRecordingHttpRequestInitializerTest.java | 2 +-
.../gcp/util/RetryHttpRequestInitializerTest.java | 4 +-
.../sorter/BufferedExternalSorterTest.java | 2 +-
.../sdk/extensions/sql/error/BeamSqlErrorTest.java | 4 +-
.../beam/fn/harness/BeamFnDataReadRunnerTest.java | 2 +-
.../sdk/io/aws2/kinesis/ShardCheckpointTest.java | 4 +-
.../aws2/kinesis/SimplifiedKinesisClientTest.java | 2 +-
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 18 ++++-
.../sdk/io/gcp/bigquery/BigQueryHelpersTest.java | 1 +
.../gcp/bigquery/BigQueryIOStorageQueryTest.java | 2 +-
.../beam/sdk/io/gcp/bigquery/BigQueryUtilTest.java | 2 +-
.../io/gcp/bigtable/BigtableServiceImplTest.java | 2 +-
.../beam/sdk/io/gcp/datastore/DatastoreV1Test.java | 4 +-
.../sdk/io/gcp/spanner/FakeServiceFactory.java | 9 ++-
.../sdk/io/gcp/spanner/ReadSpannerSchemaTest.java | 2 +-
.../beam/sdk/io/gcp/spanner/SpannerIOReadTest.java | 4 +-
.../sdk/io/gcp/spanner/SpannerIOWriteTest.java | 2 +-
.../sdk/io/gcp/testing/BigqueryClientTest.java | 4 +-
.../beam/sdk/io/iceberg/SerializableDataFile.java | 93 +++++++++++++++++++++-
.../sdk/io/iceberg/SerializableDataFileTest.java | 76 ++++++++++++++++++
.../org/apache/beam/sdk/io/jdbc/JdbcIOTest.java | 2 +-
.../apache/beam/sdk/io/jdbc/SchemaUtilTest.java | 4 +-
.../org/apache/beam/sdk/io/kudu/KuduIOTest.java | 2 +-
website/www/site/content/en/blog/beam-2.59.0.md | 4 +
website/www/site/content/en/blog/beam-2.60.0.md | 5 ++
website/www/site/content/en/blog/beam-2.61.0.md | 3 +
website/www/site/content/en/blog/beam-2.62.0.md | 3 +
86 files changed, 353 insertions(+), 138 deletions(-)
create mode 100644 sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/SerializableDataFileTest.java