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 2023/12/04 18:59:21 UTC

(beam) branch dependabot/go_modules/sdks/golang.org/x/net-0.19.0 updated (edddafd8e95 -> 668737e8e10)

This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a change to branch dependabot/go_modules/sdks/golang.org/x/net-0.19.0
in repository https://gitbox.apache.org/repos/asf/beam.git


    omit edddafd8e95 Bump golang.org/x/net from 0.18.0 to 0.19.0 in /sdks
     add 93fb2045ea1 Add interfaces for direct path, and StreamingEngineClient (#28835)
     add 6c7606e975c Fix UnsupportedOperationException because of ImmutableCollection.add (#29570)
     add c6c70860400 Enable triggering postcommit via specific file (#29549)
     add 35a0b68c06b Fix small doc issues (#29578)
     add 7c99c330350 Bump github.com/aws/aws-sdk-go-v2/credentials in /sdks (#29575)
     add 5f6afcef55f Bump cryptography from 41.0.4 to 41.0.6 in /sdks/python/container/py38 (#29554)
     add 90b1a6b7200 Add new AnyOf environment.
     add e5a9ab6233e Add AnyOf environment handling to the various runners.
     add b136f1d3dd6 Add AnyOf environment handling to the artifact staging services.
     add 6550cec0e9c Add the ability to cache subprocess services for the duration of a pipeline.
     add e8cebdf4fe7 Add an option to start loopback workers in expansion services.
     add e88fb5df887 Use Java expansion services as workers by default in Python.
     add d85ce3f38c5 More complete documentation of environment proto definitions.
     add f337c74b828 Merge pull request #29283 Cross language pipelines without Docker.
     add 26135b07473 Support for upgrading BigQuery transforms without upgrading the pipeline (#29550)
     add ebc4a5585e0 Documents the transform upgrade feature (#29581)
     add 39e1615f945 fix typos (#29588)
     add 04fe4b53433 Consider underlying providers in both directions when doing affinity test.
     add 85d4fcf7f37 Merge pull request #29586 from Better affinity test.
     add 6593a0f15c1 Adding failure_mode parameter to Spanner Python transforms (#29529)
     add f7ae6b41c37 Bump Pyarrow version to include 14.0.0 (#29536)
     add a7b1f036445 Bump cloud.google.com/go/spanner from 1.51.0 to 1.53.0 in /sdks (#29448)
     add c86971158a5 Bump google.golang.org/api from 0.151.0 to 0.152.0 in /sdks (#29596)
     new 668737e8e10 Bump golang.org/x/net from 0.18.0 to 0.19.0 in /sdks

This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version.  This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:

 * -- * -- B -- O -- O -- O   (edddafd8e95)
            \
             N -- N -- N   refs/heads/dependabot/go_modules/sdks/golang.org/x/net-0.19.0 (668737e8e10)

You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.

Any revisions marked "omit" are not gone; other references still
refer to them.  Any revisions marked "discard" are gone forever.

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:
 .github/build.gradle                               |  35 +-
 .github/workflows/README.md                        | 357 +++++-----
 .github/workflows/beam_Java_JMH.yml                |   2 +-
 .github/workflows/beam_PostCommit_Go.yml           |   2 +-
 .../workflows/beam_PostCommit_Go_Dataflow_ARM.yml  |   2 +-
 .github/workflows/beam_PostCommit_Go_VR_Flink.yml  |   2 +-
 .github/workflows/beam_PostCommit_Go_VR_Samza.yml  |   2 +-
 .github/workflows/beam_PostCommit_Go_VR_Spark.yml  |   2 +-
 .github/workflows/beam_PostCommit_Java.yml         |   2 +-
 .../beam_PostCommit_Java_Avro_Versions.yml         |   2 +-
 .../beam_PostCommit_Java_BigQueryEarlyRollout.yml  |   2 +-
 .../workflows/beam_PostCommit_Java_DataflowV1.yml  |   2 +-
 .../workflows/beam_PostCommit_Java_DataflowV2.yml  |   2 +-
 .../beam_PostCommit_Java_Examples_Dataflow.yml     |   2 +-
 .../beam_PostCommit_Java_Examples_Dataflow_ARM.yml |   2 +-
 ...beam_PostCommit_Java_Examples_Dataflow_Java.yml |   2 +-
 .../beam_PostCommit_Java_Examples_Dataflow_V2.yml  |   2 +-
 ...m_PostCommit_Java_Examples_Dataflow_V2_Java.yml |   2 +-
 .../beam_PostCommit_Java_Examples_Direct.yml       |   2 +-
 .../beam_PostCommit_Java_Examples_Flink.yml        |   2 +-
 .../beam_PostCommit_Java_Examples_Spark.yml        |   2 +-
 .../beam_PostCommit_Java_Hadoop_Versions.yml       |   2 +-
 .../beam_PostCommit_Java_IO_Performance_Tests.yml  |   2 +-
 .../beam_PostCommit_Java_InfluxDbIO_IT.yml         |   2 +-
 .../beam_PostCommit_Java_Jpms_Dataflow_Java11.yml  |   2 +-
 .../beam_PostCommit_Java_Jpms_Dataflow_Java17.yml  |   2 +-
 .../beam_PostCommit_Java_Jpms_Direct_Java11.yml    |   2 +-
 .../beam_PostCommit_Java_Jpms_Direct_Java17.yml    |   2 +-
 .../beam_PostCommit_Java_Jpms_Direct_Java21.yml    |   2 +-
 .../beam_PostCommit_Java_Jpms_Flink_Java11.yml     |   2 +-
 .../beam_PostCommit_Java_Jpms_Spark_Java11.yml     |   2 +-
 .../beam_PostCommit_Java_Nexmark_Dataflow.yml      |   2 +-
 .../beam_PostCommit_Java_Nexmark_Dataflow_V2.yml   |   2 +-
 ...am_PostCommit_Java_Nexmark_Dataflow_V2_Java.yml |   2 +-
 .../beam_PostCommit_Java_Nexmark_Direct.yml        |   2 +-
 .../beam_PostCommit_Java_Nexmark_Flink.yml         |   2 +-
 .../beam_PostCommit_Java_Nexmark_Spark.yml         |   2 +-
 .../beam_PostCommit_Java_PVR_Flink_Streaming.yml   |   2 +-
 .../workflows/beam_PostCommit_Java_PVR_Samza.yml   |   2 +-
 .../beam_PostCommit_Java_PVR_Spark3_Streaming.yml  |   2 +-
 .../beam_PostCommit_Java_PVR_Spark_Batch.yml       |   2 +-
 .github/workflows/beam_PostCommit_Java_Sickbay.yml |   2 +-
 .../beam_PostCommit_Java_SingleStoreIO_IT.yml      |   2 +-
 .../beam_PostCommit_Java_Tpcds_Dataflow.yml        |   2 +-
 .../workflows/beam_PostCommit_Java_Tpcds_Flink.yml |   2 +-
 .../workflows/beam_PostCommit_Java_Tpcds_Spark.yml |   2 +-
 ...am_PostCommit_Java_ValidatesRunner_Dataflow.yml |   2 +-
 ..._Java_ValidatesRunner_Dataflow_JavaVersions.yml |   2 +-
 ...mit_Java_ValidatesRunner_Dataflow_Streaming.yml |   2 +-
 ...PostCommit_Java_ValidatesRunner_Dataflow_V2.yml |   2 +-
 ..._Java_ValidatesRunner_Dataflow_V2_Streaming.yml |   2 +-
 ...beam_PostCommit_Java_ValidatesRunner_Direct.yml |   2 +-
 ...it_Java_ValidatesRunner_Direct_JavaVersions.yml |   2 +-
 .../beam_PostCommit_Java_ValidatesRunner_Flink.yml |   2 +-
 ...ostCommit_Java_ValidatesRunner_Flink_Java11.yml |   2 +-
 .../beam_PostCommit_Java_ValidatesRunner_Samza.yml |   2 +-
 .../beam_PostCommit_Java_ValidatesRunner_Spark.yml |   2 +-
 ...va_ValidatesRunner_SparkStructuredStreaming.yml |   2 +-
 ...ostCommit_Java_ValidatesRunner_Spark_Java11.yml |   2 +-
 ...am_PostCommit_Java_ValidatesRunner_Twister2.yml |   2 +-
 .../beam_PostCommit_Java_ValidatesRunner_ULR.yml   |   2 +-
 .github/workflows/beam_PostCommit_Javadoc.yml      |   2 +-
 .../beam_PostCommit_PortableJar_Flink.yml          |   2 +-
 .../beam_PostCommit_PortableJar_Spark.yml          |   2 +-
 .github/workflows/beam_PostCommit_Python.yml       |   2 +-
 .github/workflows/beam_PostCommit_Python_Arm.yml   |   2 +-
 .../beam_PostCommit_Python_Examples_Dataflow.yml   |   2 +-
 .../beam_PostCommit_Python_Examples_Direct.yml     |   2 +-
 .../beam_PostCommit_Python_Examples_Flink.yml      |   2 +-
 .../beam_PostCommit_Python_Examples_Spark.yml      |   2 +-
 .../beam_PostCommit_Python_MongoDBIO_IT.yml        |   2 +-
 .../beam_PostCommit_Python_Nexmark_Direct.yml      |   2 +-
 ...stCommit_Python_ValidatesContainer_Dataflow.yml |   2 +-
 ..._Python_ValidatesContainer_Dataflow_With_RC.yml |   2 +-
 ..._PostCommit_Python_ValidatesRunner_Dataflow.yml |   2 +-
 ...eam_PostCommit_Python_ValidatesRunner_Flink.yml |   2 +-
 ...eam_PostCommit_Python_ValidatesRunner_Samza.yml |   2 +-
 ...eam_PostCommit_Python_ValidatesRunner_Spark.yml |   2 +-
 .../beam_PostCommit_Python_Xlang_Gcp_Dataflow.yml  |   2 +-
 .../beam_PostCommit_Python_Xlang_Gcp_Direct.yml    |   2 +-
 .../beam_PostCommit_Python_Xlang_IO_Dataflow.yml   |   2 +-
 .github/workflows/beam_PostCommit_SQL.yml          |   2 +-
 .../workflows/beam_PostCommit_Sickbay_Python.yml   |   2 +-
 .../beam_PostCommit_TransformService_Direct.yml    |   2 +-
 .github/workflows/beam_PostCommit_Website_Test.yml |   2 +-
 .github/workflows/beam_PostCommit_XVR_Direct.yml   |   2 +-
 .github/workflows/beam_PostCommit_XVR_Flink.yml    |   2 +-
 .../beam_PostCommit_XVR_GoUsingJava_Dataflow.yml   |   2 +-
 ...eam_PostCommit_XVR_JavaUsingPython_Dataflow.yml |   2 +-
 ..._PostCommit_XVR_PythonUsingJavaSQL_Dataflow.yml |   2 +-
 ...eam_PostCommit_XVR_PythonUsingJava_Dataflow.yml |   2 +-
 .github/workflows/beam_PostCommit_XVR_Samza.yml    |   2 +-
 .github/workflows/beam_PostCommit_XVR_Spark3.yml   |   2 +-
 .../workflows/beam_PreCommit_CommunityMetrics.yml  |   2 +-
 .github/workflows/beam_PreCommit_GHA.yml           |   2 +-
 .github/workflows/beam_PreCommit_Go.yml            |   2 +-
 .github/workflows/beam_PreCommit_GoPortable.yml    |   2 +-
 .github/workflows/beam_PreCommit_GoPrism.yml       |   2 +-
 .github/workflows/beam_PreCommit_ItFramework.yml   |   1 +
 .github/workflows/beam_PreCommit_Java.yml          |   1 +
 ...eCommit_Java_Amazon-Web-Services2_IO_Direct.yml |   1 +
 ...reCommit_Java_Amazon-Web-Services_IO_Direct.yml |   1 +
 .../beam_PreCommit_Java_Amqp_IO_Direct.yml         |   1 +
 .../beam_PreCommit_Java_Azure_IO_Direct.yml        |   1 +
 .../beam_PreCommit_Java_Cassandra_IO_Direct.yml    |   1 +
 .../beam_PreCommit_Java_Cdap_IO_Direct.yml         |   1 +
 .../beam_PreCommit_Java_Clickhouse_IO_Direct.yml   |   1 +
 .../beam_PreCommit_Java_Csv_IO_Direct.yml          |   1 +
 .../beam_PreCommit_Java_Debezium_IO_Direct.yml     |   1 +
 ...beam_PreCommit_Java_ElasticSearch_IO_Direct.yml |   1 +
 .../beam_PreCommit_Java_Examples_Dataflow.yml      |   1 +
 ...eam_PreCommit_Java_Examples_Dataflow_Java21.yml |   1 +
 ...Commit_Java_File-schema-transform_IO_Direct.yml |   1 +
 .../beam_PreCommit_Java_Flink_Versions.yml         |   1 +
 .../beam_PreCommit_Java_GCP_IO_Direct.yml          |   1 +
 .../beam_PreCommit_Java_Google-ads_IO_Direct.yml   |   1 +
 .../beam_PreCommit_Java_HBase_IO_Direct.yml        |   1 +
 .../beam_PreCommit_Java_HCatalog_IO_Direct.yml     |   1 +
 .../beam_PreCommit_Java_Hadoop_IO_Direct.yml       |   1 +
 .../workflows/beam_PreCommit_Java_IOs_Direct.yml   |   1 +
 .../beam_PreCommit_Java_InfluxDb_IO_Direct.yml     |   1 +
 .../beam_PreCommit_Java_JDBC_IO_Direct.yml         |   1 +
 .../beam_PreCommit_Java_Jms_IO_Direct.yml          |   1 +
 .../beam_PreCommit_Java_Kafka_IO_Direct.yml        |   1 +
 .../beam_PreCommit_Java_Kinesis_IO_Direct.yml      |   1 +
 .../beam_PreCommit_Java_Kudu_IO_Direct.yml         |   1 +
 .../beam_PreCommit_Java_MongoDb_IO_Direct.yml      |   1 +
 .../beam_PreCommit_Java_Mqtt_IO_Direct.yml         |   1 +
 .../beam_PreCommit_Java_Neo4j_IO_Direct.yml        |   1 +
 .../beam_PreCommit_Java_PVR_Flink_Batch.yml        |   1 +
 .../beam_PreCommit_Java_PVR_Flink_Docker.yml       |   1 +
 .../beam_PreCommit_Java_Parquet_IO_Direct.yml      |   1 +
 .../beam_PreCommit_Java_Pulsar_IO_Direct.yml       |   1 +
 .../beam_PreCommit_Java_RabbitMq_IO_Direct.yml     |   1 +
 .../beam_PreCommit_Java_Redis_IO_Direct.yml        |   1 +
 ...am_PreCommit_Java_RequestResponse_IO_Direct.yml |   1 +
 .../beam_PreCommit_Java_SingleStore_IO_Direct.yml  |   1 +
 .../beam_PreCommit_Java_Snowflake_IO_Direct.yml    |   1 +
 .../beam_PreCommit_Java_Solr_IO_Direct.yml         |   1 +
 .../beam_PreCommit_Java_Spark3_Versions.yml        |   1 +
 .../beam_PreCommit_Java_Splunk_IO_Direct.yml       |   1 +
 .../beam_PreCommit_Java_Thrift_IO_Direct.yml       |   1 +
 .../beam_PreCommit_Java_Tika_IO_Direct.yml         |   1 +
 .../workflows/beam_PreCommit_Kotlin_Examples.yml   |   1 +
 .../workflows/beam_PreCommit_Portable_Python.yml   |   1 +
 .github/workflows/beam_PreCommit_Python.yml        |   2 +-
 .github/workflows/beam_PreCommit_PythonDocker.yml  |   2 +-
 .github/workflows/beam_PreCommit_PythonDocs.yml    |   2 +-
 .../workflows/beam_PreCommit_PythonFormatter.yml   |   2 +-
 .github/workflows/beam_PreCommit_PythonLint.yml    |   2 +-
 .../workflows/beam_PreCommit_Python_Coverage.yml   |   2 +-
 .../workflows/beam_PreCommit_Python_Dataframes.yml |   2 +-
 .../workflows/beam_PreCommit_Python_Examples.yml   |   2 +-
 .../beam_PreCommit_Python_Integration.yml          |   2 +-
 .../workflows/beam_PreCommit_Python_PVR_Flink.yml  |   1 +
 .../workflows/beam_PreCommit_Python_Runners.yml    |   2 +-
 .../workflows/beam_PreCommit_Python_Transforms.yml |   2 +-
 .github/workflows/beam_PreCommit_SQL.yml           |   2 +-
 .github/workflows/beam_PreCommit_SQL_Java11.yml    |   2 +-
 .github/workflows/beam_PreCommit_SQL_Java17.yml    |   2 +-
 .github/workflows/beam_PreCommit_Spotless.yml      |   1 +
 .github/workflows/beam_PreCommit_Typescript.yml    |   2 +-
 .github/workflows/beam_PreCommit_Website.yml       |   2 +-
 .../workflows/beam_PreCommit_Website_Stage_GCS.yml |   2 +-
 .github/workflows/beam_PreCommit_Whitespace.yml    |   2 +-
 ...cs_Publish.yml => beam_Publish_BeamMetrics.yml} |   4 +-
 ...ebsite_Publish.yml => beam_Publish_Website.yml} |   6 +-
 CHANGES.md                                         |   5 +-
 .../beam/model/pipeline/v1/beam_runner_api.proto   |  34 +-
 .../runners/core/construction/Environments.java    |  47 ++
 .../core/construction/TransformUpgrader.java       |  52 +-
 .../core/construction/EnvironmentsTest.java        |  41 ++
 .../beam/runners/dataflow/DataflowRunner.java      |  22 +-
 .../worker/windmill/WindmillConnection.java        |  57 ++
 .../client/grpc/GetWorkTimingInfosTracker.java     |  10 +-
 .../windmill/client/grpc/GrpcCommitWorkStream.java |   4 +-
 .../client/grpc/GrpcDirectGetWorkStream.java       | 320 +++++++++
 .../windmill/client/grpc/GrpcGetDataStream.java    |   4 +-
 .../client/grpc/GrpcGetWorkerMetadataStream.java   |   3 +-
 .../client/grpc/GrpcWindmillStreamFactory.java     |  28 +-
 .../client/grpc/StreamingEngineClient.java         | 401 +++++++++++
 .../grpc/StreamingEngineConnectionState.java       |  64 ++
 .../windmill/client/grpc/WindmillStreamSender.java | 156 ++++
 .../windmill/work/ProcessWorkItemClient.java       |  52 ++
 .../worker/windmill/work/WorkItemProcessor.java    |  57 ++
 .../work/budget/EvenGetWorkBudgetDistributor.java  | 101 +++
 .../worker/windmill/work/budget/GetWorkBudget.java |  35 +-
 .../work/budget/GetWorkBudgetDistributor.java      |  33 +
 .../work/budget/GetWorkBudgetDistributors.java     |  29 +
 .../work/budget/GetWorkBudgetRefresher.java        | 133 ++++
 .../client/grpc/StreamingEngineClientTest.java     | 417 +++++++++++
 .../client/grpc/WindmillStreamSenderTest.java      | 239 +++++++
 .../budget/EvenGetWorkBudgetDistributorTest.java   | 265 +++++++
 .../work/budget/GetWorkBudgetRefresherTest.java    | 102 +++
 .../windmill/work/budget/GetWorkBudgetTest.java    |  26 +-
 .../control/DefaultJobBundleFactory.java           |   6 +
 .../runners/jobsubmission/InMemoryJobService.java  |  58 +-
 sdks/go.mod                                        |  44 +-
 sdks/go.sum                                        |  92 +--
 sdks/java/expansion-service/build.gradle           |   3 +
 .../sdk/expansion/service/ExpansionService.java    |  55 +-
 .../expansion/service/ExpansionServiceOptions.java |   5 +
 .../sdk/io/gcp/bigquery/BigQueryIOTranslation.java | 782 +++++++++++++++++++++
 .../io/gcp/spanner/SpannerTransformRegistrar.java  |  10 +
 .../io/gcp/bigquery/BigQueryIOTranslationTest.java | 303 ++++++++
 .../sdk/io/kafka/upgrade/KafkaIOTranslation.java   |  26 +-
 sdks/python/apache_beam/io/gcp/bigquery.py         |  18 +-
 sdks/python/apache_beam/io/gcp/spanner.py          |  21 +
 .../io/gcp/tests/xlang_spannerio_it_test.py        |   1 +
 sdks/python/apache_beam/io/parquetio_test.py       |   3 +
 sdks/python/apache_beam/pipeline.py                |  10 +-
 .../runners/dataflow/dataflow_runner.py            |   8 +-
 .../runners/portability/expansion_service.py       |  14 +-
 .../runners/portability/expansion_service_main.py  |  16 +-
 .../runners/portability/fn_api_runner/fn_runner.py |  29 +-
 .../portability/fn_api_runner/worker_handlers.py   |  12 +
 .../runners/portability/local_job_service.py       |  59 +-
 sdks/python/apache_beam/transforms/environments.py |  58 ++
 sdks/python/apache_beam/transforms/external.py     |  27 +-
 sdks/python/apache_beam/utils/subprocess_server.py | 192 +++--
 .../apache_beam/utils/subprocess_server_test.py    |  79 +++
 sdks/python/apache_beam/yaml/yaml_provider.py      |   6 +-
 .../container/py310/base_image_requirements.txt    |  80 +--
 .../container/py311/base_image_requirements.txt    |  76 +-
 .../container/py38/base_image_requirements.txt     |  80 +--
 .../container/py39/base_image_requirements.txt     |  80 +--
 sdks/python/setup.py                               |  14 +-
 website/www/site/content/en/blog/beam-2.52.0.md    |  69 +-
 .../content/en/documentation/programming-guide.md  |  64 +-
 .../partials/section-menu/en/documentation.html    |   1 +
 230 files changed, 5030 insertions(+), 787 deletions(-)
 rename .github/workflows/{beam_PostCommit_BeamMetrics_Publish.yml => beam_Publish_BeamMetrics.yml} (97%)
 rename .github/workflows/{beam_PostCommit_Website_Publish.yml => beam_Publish_Website.yml} (95%)
 create mode 100644 runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/WindmillConnection.java
 create mode 100644 runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcDirectGetWorkStream.java
 create mode 100644 runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/StreamingEngineClient.java
 create mode 100644 runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/StreamingEngineConnectionState.java
 create mode 100644 runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/WindmillStreamSender.java
 create mode 100644 runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/work/ProcessWorkItemClient.java
 create mode 100644 runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/work/WorkItemProcessor.java
 create mode 100644 runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/work/budget/EvenGetWorkBudgetDistributor.java
 create mode 100644 runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/work/budget/GetWorkBudgetDistributor.java
 create mode 100644 runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/work/budget/GetWorkBudgetDistributors.java
 create mode 100644 runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/work/budget/GetWorkBudgetRefresher.java
 create mode 100644 runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/StreamingEngineClientTest.java
 create mode 100644 runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/WindmillStreamSenderTest.java
 create mode 100644 runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/work/budget/EvenGetWorkBudgetDistributorTest.java
 create mode 100644 runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/work/budget/GetWorkBudgetRefresherTest.java
 create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTranslation.java
 create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTranslationTest.java


(beam) 01/01: Bump golang.org/x/net from 0.18.0 to 0.19.0 in /sdks

Posted by gi...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a commit to branch dependabot/go_modules/sdks/golang.org/x/net-0.19.0
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 668737e8e10156982219c849c5fd8f963bef07ef
Author: dependabot[bot] <49...@users.noreply.github.com>
AuthorDate: Mon Dec 4 18:59:15 2023 +0000

    Bump golang.org/x/net from 0.18.0 to 0.19.0 in /sdks
    
    Bumps [golang.org/x/net](https://github.com/golang/net) from 0.18.0 to 0.19.0.
    - [Commits](https://github.com/golang/net/compare/v0.18.0...v0.19.0)
    
    ---
    updated-dependencies:
    - dependency-name: golang.org/x/net
      dependency-type: direct:production
      update-type: version-update:semver-minor
    ...
    
    Signed-off-by: dependabot[bot] <su...@github.com>
---
 sdks/go.mod |  6 +++---
 sdks/go.sum | 12 ++++++------
 2 files changed, 9 insertions(+), 9 deletions(-)

diff --git a/sdks/go.mod b/sdks/go.mod
index 33c575deed5..6985e5de267 100644
--- a/sdks/go.mod
+++ b/sdks/go.mod
@@ -54,10 +54,10 @@ require (
 	github.com/xitongsys/parquet-go v1.6.2
 	github.com/xitongsys/parquet-go-source v0.0.0-20220315005136-aec0fe3e777c
 	go.mongodb.org/mongo-driver v1.12.1
-	golang.org/x/net v0.18.0
+	golang.org/x/net v0.19.0
 	golang.org/x/oauth2 v0.14.0
 	golang.org/x/sync v0.5.0
-	golang.org/x/sys v0.14.0
+	golang.org/x/sys v0.15.0
 	golang.org/x/text v0.14.0
 	google.golang.org/api v0.152.0
 	google.golang.org/genproto v0.0.0-20231106174013-bbf56f31fb17
@@ -173,7 +173,7 @@ require (
 	github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d // indirect
 	github.com/zeebo/xxh3 v1.0.2 // indirect
 	go.opencensus.io v0.24.0 // indirect
-	golang.org/x/crypto v0.15.0 // indirect
+	golang.org/x/crypto v0.16.0 // indirect
 	golang.org/x/mod v0.11.0 // indirect
 	golang.org/x/tools v0.10.0 // indirect
 	golang.org/x/xerrors v0.0.0-20220907171357-04be3eba64a2 // indirect
diff --git a/sdks/go.sum b/sdks/go.sum
index 94ced030dec..0092cffa4f2 100644
--- a/sdks/go.sum
+++ b/sdks/go.sum
@@ -495,8 +495,8 @@ golang.org/x/crypto v0.0.0-20201002170205-7f63de1d35b0/go.mod h1:LzIPMQfyMNhhGPh
 golang.org/x/crypto v0.0.0-20210513164829-c07d793c2f9a/go.mod h1:P+XmwS30IXTQdn5tA2iutPOUgjI07+tq3H3K9MVA1s8=
 golang.org/x/crypto v0.0.0-20210921155107-089bfa567519/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc=
 golang.org/x/crypto v0.0.0-20220622213112-05595931fe9d/go.mod h1:IxCIyHEi3zRg3s0A5j5BB6A9Jmi73HwBIUl50j+osU4=
-golang.org/x/crypto v0.15.0 h1:frVn1TEaCEaZcn3Tmd7Y2b5KKPaZ+I32Q2OA3kYp5TA=
-golang.org/x/crypto v0.15.0/go.mod h1:4ChreQoLWfG3xLDer1WdlH5NdlQ3+mwnQq1YTKY+72g=
+golang.org/x/crypto v0.16.0 h1:mMMrFzRSCF0GvB7Ne27XVtVAaXLrPmgPC7/v0tkwHaY=
+golang.org/x/crypto v0.16.0/go.mod h1:gCAAfMLgwOJRpTjQ2zCCt2OcSfYMTeZVSRtQlPC7Nq4=
 golang.org/x/exp v0.0.0-20190121172915-509febef88a4/go.mod h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA=
 golang.org/x/exp v0.0.0-20190306152737-a1d7652674e8/go.mod h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA=
 golang.org/x/exp v0.0.0-20190510132918-efd6b22b2522/go.mod h1:ZjyILWgesfNpC6sMxTJOJm9Kp84zZh5NQWvqDGG3Qr8=
@@ -555,8 +555,8 @@ golang.org/x/net v0.0.0-20201224014010-6772e930b67b/go.mod h1:m0MpNAwzfU5UDzcl9v
 golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg=
 golang.org/x/net v0.0.0-20211112202133-69e39bad7dc2/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=
 golang.org/x/net v0.0.0-20220722155237-a158d28d115b/go.mod h1:XRhObCWvk6IyKnWLug+ECip1KBveYUHfp+8e9klMJ9c=
-golang.org/x/net v0.18.0 h1:mIYleuAkSbHh0tCv7RvjL3F6ZVbLjq4+R7zbOn3Kokg=
-golang.org/x/net v0.18.0/go.mod h1:/czyP5RqHAH4odGYxBJ1qz0+CE5WZ+2j1YgoEo8F2jQ=
+golang.org/x/net v0.19.0 h1:zTwKpTd2XuCqf8huc7Fo2iSy+4RHPd10s4KzeTnVr1c=
+golang.org/x/net v0.19.0/go.mod h1:CfAk/cbD4CthTvqiEl8NpboMuiuOYsAr/7NOjZJtv1U=
 golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
 golang.org/x/oauth2 v0.0.0-20190226205417-e64efc72b421/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
 golang.org/x/oauth2 v0.0.0-20190604053449-0f29369cfe45/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
@@ -616,8 +616,8 @@ golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.8.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.11.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.12.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.14.0 h1:Vz7Qs629MkJkGyHxUlRHizWJRG2j8fbQKjELVSNhy7Q=
-golang.org/x/sys v0.14.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
+golang.org/x/sys v0.15.0 h1:h48lPFYpsTvQJZF4EKyI4aLHaev3CxivZmv7yZig9pc=
+golang.org/x/sys v0.15.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
 golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
 golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8=
 golang.org/x/text v0.0.0-20170915032832-14c0d48ead0c/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=