This is an automated email from the ASF dual-hosted git repository. martijnvisser pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push: new f6d09c5c018 [FLINK-32511][FileSystems] Upgrade GCS connector to 2.2.15. This closes #22930 f6d09c5c018 is described below commit f6d09c5c0182767243d6628fb257ddd0a93482e4 Author: Jayadeep Jayaraman <53975210+jayadeep-jayara...@users.noreply.github.com> AuthorDate: Tue Jul 4 13:40:11 2023 +0530 [FLINK-32511][FileSystems] Upgrade GCS connector to 2.2.15. This closes #22930 * [FLINK-32511] Upgrade GCS connector to 2.2.15 * Update NOTICE file --- .idea/vcs.xml | 30 +++++++++++++++++- docs/content.zh/docs/deployment/filesystems/gcs.md | 4 +-- docs/content/docs/deployment/filesystems/gcs.md | 4 +-- flink-filesystems/flink-gs-fs-hadoop/pom.xml | 4 +-- .../src/main/resources/META-INF/NOTICE | 36 +++++++++++----------- 5 files changed, 53 insertions(+), 25 deletions(-) diff --git a/.idea/vcs.xml b/.idea/vcs.xml index 165d593076e..8c1dfffdcbb 100644 --- a/.idea/vcs.xml +++ b/.idea/vcs.xml @@ -15,6 +15,34 @@ <option name="issueRegexp" value="#(\d+)" /> <option name="linkRegexp" value="https://github.com/apache/flink/pull/$1" /> </IssueNavigationLink> + <IssueNavigationLink> + <option name="issueRegexp" value="\bb/(\d+)(#\w+)?\b" /> + <option name="linkRegexp" value="https://buganizer.corp.google.com/issues/$1$2" /> + </IssueNavigationLink> + <IssueNavigationLink> + <option name="issueRegexp" value="\b(?:BUG=|FIXED=)(\d+)\b" /> + <option name="linkRegexp" value="https://buganizer.corp.google.com/issues/$1" /> + </IssueNavigationLink> + <IssueNavigationLink> + <option name="issueRegexp" value="\b(?:cl/|cr/|OCL=|DIFFBASE=|ROLLBACK_OF=)(\d+)\b" /> + <option name="linkRegexp" value="https://critique.corp.google.com/$1" /> + </IssueNavigationLink> + <IssueNavigationLink> + <option name="issueRegexp" value="\bomg/(\d+)\b" /> + <option name="linkRegexp" value="https://omg.corp.google.com/$1" /> + </IssueNavigationLink> + <IssueNavigationLink> + <option name="issueRegexp" value="\b(?:go/|goto/)([^,.<>()"\s]+(?:[.,][^,.<>()"\s]+)*)" /> + <option name="linkRegexp" value="https://goto.google.com/$1" /> + </IssueNavigationLink> + <IssueNavigationLink> + <option name="issueRegexp" value="\bcs/([^\s]+[\w$])" /> + <option name="linkRegexp" value="https://cs.corp.google.com/search/?q=$1" /> + </IssueNavigationLink> + <IssueNavigationLink> + <option name="issueRegexp" value="(LINT\.IfChange)|(LINT\.ThenChange)" /> + <option name="linkRegexp" value="https://goto.google.com/ifthisthenthatlint" /> + </IssueNavigationLink> </list> </option> </component> @@ -22,4 +50,4 @@ <mapping directory="$PROJECT_DIR$" vcs="Git" /> <mapping directory="$PROJECT_DIR$/docs/themes/book" vcs="Git" /> </component> -</project> +</project> \ No newline at end of file diff --git a/docs/content.zh/docs/deployment/filesystems/gcs.md b/docs/content.zh/docs/deployment/filesystems/gcs.md index 2a92caf9771..363cd2fec90 100644 --- a/docs/content.zh/docs/deployment/filesystems/gcs.md +++ b/docs/content.zh/docs/deployment/filesystems/gcs.md @@ -55,7 +55,7 @@ Note that these examples are *not* exhaustive and you can use GCS in other place Flink provides the `flink-gs-fs-hadoop` file system to write to GCS. This implementation is self-contained with no dependency footprint, so there is no need to add Hadoop to the classpath to use it. -`flink-gs-fs-hadoop` registers a `FileSystem` wrapper for URIs with the *gs://* scheme. It uses Google's [gcs-connector](https://mvnrepository.com/artifact/com.google.cloud.bigdataoss/gcs-connector/hadoop3-2.2.11) Hadoop library to access GCS. It also uses Google's [google-cloud-storage](https://mvnrepository.com/artifact/com.google.cloud/google-cloud-storage/2.15.0) library to provide `RecoverableWriter` support. +`flink-gs-fs-hadoop` registers a `FileSystem` wrapper for URIs with the *gs://* scheme. It uses Google's [gcs-connector](https://mvnrepository.com/artifact/com.google.cloud.bigdataoss/gcs-connector/hadoop3-2.2.15) Hadoop library to access GCS. It also uses Google's [google-cloud-storage](https://mvnrepository.com/artifact/com.google.cloud/google-cloud-storage/2.15.0) library to provide `RecoverableWriter` support. This file system can be used with the [FileSystem connector]({{< ref "docs/connectors/datastream/filesystem.md" >}}). @@ -68,7 +68,7 @@ cp ./opt/flink-gs-fs-hadoop-{{< version >}}.jar ./plugins/gs-fs-hadoop/ ### Configuration -The underlying Hadoop file system can be configured using the [Hadoop configuration keys](https://github.com/GoogleCloudDataproc/hadoop-connectors/blob/v2.2.11/gcs/CONFIGURATION.md) for `gcs-connector` by adding the configurations to your `flink-conf.yaml`. +The underlying Hadoop file system can be configured using the [Hadoop configuration keys](https://github.com/GoogleCloudDataproc/hadoop-connectors/blob/v2.2.15/gcs/CONFIGURATION.md) for `gcs-connector` by adding the configurations to your `flink-conf.yaml`. For example, `gcs-connector` has a `fs.gs.http.connect-timeout` configuration key. If you want to change it, you need to set `gs.http.connect-timeout: xyz` in `flink-conf.yaml`. Flink will internally translate this back to `fs.gs.http.connect-timeout`. diff --git a/docs/content/docs/deployment/filesystems/gcs.md b/docs/content/docs/deployment/filesystems/gcs.md index a7d891f4012..97e008eca33 100644 --- a/docs/content/docs/deployment/filesystems/gcs.md +++ b/docs/content/docs/deployment/filesystems/gcs.md @@ -55,7 +55,7 @@ Note that these examples are *not* exhaustive and you can use GCS in other place Flink provides the `flink-gs-fs-hadoop` file system to write to GCS. This implementation is self-contained with no dependency footprint, so there is no need to add Hadoop to the classpath to use it. -`flink-gs-fs-hadoop` registers a `FileSystem` wrapper for URIs with the *gs://* scheme. It uses Google's [gcs-connector](https://mvnrepository.com/artifact/com.google.cloud.bigdataoss/gcs-connector/hadoop3-2.2.11) Hadoop library to access GCS. It also uses Google's [google-cloud-storage](https://mvnrepository.com/artifact/com.google.cloud/google-cloud-storage/2.15.0) library to provide `RecoverableWriter` support. +`flink-gs-fs-hadoop` registers a `FileSystem` wrapper for URIs with the *gs://* scheme. It uses Google's [gcs-connector](https://mvnrepository.com/artifact/com.google.cloud.bigdataoss/gcs-connector/hadoop3-2.2.15) Hadoop library to access GCS. It also uses Google's [google-cloud-storage](https://mvnrepository.com/artifact/com.google.cloud/google-cloud-storage/2.15.0) library to provide `RecoverableWriter` support. This file system can be used with the [FileSystem connector]({{< ref "docs/connectors/datastream/filesystem.md" >}}). @@ -68,7 +68,7 @@ cp ./opt/flink-gs-fs-hadoop-{{< version >}}.jar ./plugins/gs-fs-hadoop/ ### Configuration -The underlying Hadoop file system can be configured using the [Hadoop configuration keys](https://github.com/GoogleCloudDataproc/hadoop-connectors/blob/v2.2.11/gcs/CONFIGURATION.md) for `gcs-connector` by adding the configurations to your `flink-conf.yaml`. +The underlying Hadoop file system can be configured using the [Hadoop configuration keys](https://github.com/GoogleCloudDataproc/hadoop-connectors/blob/v2.2.15/gcs/CONFIGURATION.md) for `gcs-connector` by adding the configurations to your `flink-conf.yaml`. For example, `gcs-connector` has a `fs.gs.http.connect-timeout` configuration key. If you want to change it, you need to set `gs.http.connect-timeout: xyz` in `flink-conf.yaml`. Flink will internally translate this back to `fs.gs.http.connect-timeout`. diff --git a/flink-filesystems/flink-gs-fs-hadoop/pom.xml b/flink-filesystems/flink-gs-fs-hadoop/pom.xml index 2563dfd3415..623f7068d56 100644 --- a/flink-filesystems/flink-gs-fs-hadoop/pom.xml +++ b/flink-filesystems/flink-gs-fs-hadoop/pom.xml @@ -35,9 +35,9 @@ under the License. <!-- If updating these dependency versions, please also update the corresponding links --> <!-- in the GCS file system documentation. --> <fs.gs.sdk.version>2.15.0</fs.gs.sdk.version> - <fs.gs.connector.version>hadoop3-2.2.11</fs.gs.connector.version> + <fs.gs.connector.version>hadoop3-2.2.15</fs.gs.connector.version> <!-- Set this to the highest version of grpc artifacts from gcs-connector and google-cloud-storage --> - <fs.gs.grpc.version>1.50.2</fs.gs.grpc.version> + <fs.gs.grpc.version>1.50.3</fs.gs.grpc.version> </properties> <dependencies> diff --git a/flink-filesystems/flink-gs-fs-hadoop/src/main/resources/META-INF/NOTICE b/flink-filesystems/flink-gs-fs-hadoop/src/main/resources/META-INF/NOTICE index 814fd382dc3..7a34d1b4ef6 100644 --- a/flink-filesystems/flink-gs-fs-hadoop/src/main/resources/META-INF/NOTICE +++ b/flink-filesystems/flink-gs-fs-hadoop/src/main/resources/META-INF/NOTICE @@ -20,10 +20,10 @@ This project bundles the following dependencies under the Apache Software Licens - com.google.apis:google-api-services-iamcredentials:v1-rev20211203-2.0.0 - com.google.apis:google-api-services-storage:v1-rev20220705-2.0.0 - com.google.auto.value:auto-value-annotations:1.10 -- com.google.cloud.bigdataoss:gcs-connector:hadoop3-2.2.11 -- com.google.cloud.bigdataoss:gcsio:2.2.11 -- com.google.cloud.bigdataoss:util-hadoop:hadoop3-2.2.11 -- com.google.cloud.bigdataoss:util:2.2.11 +- com.google.cloud.bigdataoss:gcs-connector:hadoop3-2.2.15 +- com.google.cloud.bigdataoss:gcsio:2.2.15 +- com.google.cloud.bigdataoss:util-hadoop:hadoop3-2.2.15 +- com.google.cloud.bigdataoss:util:2.2.15 - com.google.cloud:google-cloud-core-grpc:2.8.27 - com.google.cloud:google-cloud-core-http:2.8.27 - com.google.cloud:google-cloud-core:2.8.27 @@ -42,20 +42,20 @@ This project bundles the following dependencies under the Apache Software Licens - com.google.oauth-client:google-oauth-client:1.34.1 - com.lmax:disruptor:3.4.2 - commons-codec:commons-codec:1.15 -- io.grpc:grpc-alts:1.50.2 -- io.grpc:grpc-api:1.50.2 -- io.grpc:grpc-auth:1.50.2 -- io.grpc:grpc-census:1.50.2 -- io.grpc:grpc-context:1.50.2 -- io.grpc:grpc-core:1.50.2 -- io.grpc:grpc-googleapis:1.50.2 -- io.grpc:grpc-grpclb:1.50.2 -- io.grpc:grpc-netty-shaded:1.50.2 -- io.grpc:grpc-protobuf-lite:1.50.2 -- io.grpc:grpc-protobuf:1.50.2 -- io.grpc:grpc-services:1.50.2 -- io.grpc:grpc-stub:1.50.2 -- io.grpc:grpc-xds:1.50.2 +- io.grpc:grpc-alts:1.50.3 +- io.grpc:grpc-api:1.50.3 +- io.grpc:grpc-auth:1.50.3 +- io.grpc:grpc-census:1.50.3 +- io.grpc:grpc-context:1.50.3 +- io.grpc:grpc-core:1.50.3 +- io.grpc:grpc-googleapis:1.50.3 +- io.grpc:grpc-grpclb:1.50.3 +- io.grpc:grpc-netty-shaded:1.50.3 +- io.grpc:grpc-protobuf-lite:1.50.3 +- io.grpc:grpc-protobuf:1.50.3 +- io.grpc:grpc-services:1.50.3 +- io.grpc:grpc-stub:1.50.3 +- io.grpc:grpc-xds:1.50.3 - io.opencensus:opencensus-api:0.31.1 - io.opencensus:opencensus-contrib-exemplar-util:0.31.0 - io.opencensus:opencensus-contrib-grpc-metrics:0.31.0