[flink-table-store] 08/08: [FLINK-25619] Disable merge button
This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-table-store.git commit 9d5c08c86cbda10119a0f4da679529974617d637 Author: JingsongLi AuthorDate: Wed Jan 12 14:13:14 2022 +0800 [FLINK-25619] Disable merge button This closes #1 --- .asf.yaml | 6 ++ 1 file changed, 6 insertions(+) diff --git a/.asf.yaml b/.asf.yaml index 82eef0b..de63c92 100644 --- a/.asf.yaml +++ b/.asf.yaml @@ -3,3 +3,9 @@ notifications: issues: iss...@flink.apache.org pullrequests: iss...@flink.apache.org jira_options: link label + +github: + enabled_merge_buttons: +squash: true +merge: false +rebase: true
[flink-table-store] 04/08: [FLINK-25619] Add tools/maven/
This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-table-store.git commit 7d01fc003c39046f52a7c1652d93e251d614869b Author: JingsongLi AuthorDate: Wed Jan 12 14:08:06 2022 +0800 [FLINK-25619] Add tools/maven/ --- tools/maven/checkstyle.xml| 562 ++ tools/maven/scalastyle-config.xml | 146 ++ tools/maven/suppressions.xml | 85 ++ 3 files changed, 793 insertions(+) diff --git a/tools/maven/checkstyle.xml b/tools/maven/checkstyle.xml new file mode 100644 index 000..2048fd1 --- /dev/null +++ b/tools/maven/checkstyle.xml @@ -0,0 +1,562 @@ + + +http://www.puppycrawl.com/dtds/configuration_1_3.dtd";> + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +
[flink-table-store] 02/08: [FLINK-25619] Add NOTICE LICENSE CODE_OF_CONDUCT
This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-table-store.git commit 96de3c96feecc1337af8f7d99aed73e8f948eb73 Author: JingsongLi AuthorDate: Wed Jan 12 14:07:37 2022 +0800 [FLINK-25619] Add NOTICE LICENSE CODE_OF_CONDUCT --- CODE_OF_CONDUCT.md | 3 + LICENSE| 201 + NOTICE | 5 ++ 3 files changed, 209 insertions(+) diff --git a/CODE_OF_CONDUCT.md b/CODE_OF_CONDUCT.md new file mode 100644 index 000..8821b1e --- /dev/null +++ b/CODE_OF_CONDUCT.md @@ -0,0 +1,3 @@ +# Code of Conduct + +Apache Flink and all its associated repositories follow the [Code of Conduct of the Apache Software Foundation](https://www.apache.org/foundation/policies/conduct). diff --git a/LICENSE b/LICENSE new file mode 100644 index 000..261eeb9 --- /dev/null +++ b/LICENSE @@ -0,0 +1,201 @@ + Apache License + Version 2.0, January 2004 +http://www.apache.org/licenses/ + + TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION + + 1. Definitions. + + "License" shall mean the terms and conditions for use, reproduction, + and distribution as defined by Sections 1 through 9 of this document. + + "Licensor" shall mean the copyright owner or entity authorized by + the copyright owner that is granting the License. + + "Legal Entity" shall mean the union of the acting entity and all + other entities that control, are controlled by, or are under common + control with that entity. For the purposes of this definition, + "control" means (i) the power, direct or indirect, to cause the + direction or management of such entity, whether by contract or + otherwise, or (ii) ownership of fifty percent (50%) or more of the + outstanding shares, or (iii) beneficial ownership of such entity. + + "You" (or "Your") shall mean an individual or Legal Entity + exercising permissions granted by this License. + + "Source" form shall mean the preferred form for making modifications, + including but not limited to software source code, documentation + source, and configuration files. + + "Object" form shall mean any form resulting from mechanical + transformation or translation of a Source form, including but + not limited to compiled object code, generated documentation, + and conversions to other media types. + + "Work" shall mean the work of authorship, whether in Source or + Object form, made available under the License, as indicated by a + copyright notice that is included in or attached to the work + (an example is provided in the Appendix below). + + "Derivative Works" shall mean any work, whether in Source or Object + form, that is based on (or derived from) the Work and for which the + editorial revisions, annotations, elaborations, or other modifications + represent, as a whole, an original work of authorship. For the purposes + of this License, Derivative Works shall not include works that remain + separable from, or merely link (or bind by name) to the interfaces of, + the Work and Derivative Works thereof. + + "Contribution" shall mean any work of authorship, including + the original version of the Work and any modifications or additions + to that Work or Derivative Works thereof, that is intentionally + submitted to Licensor for inclusion in the Work by the copyright owner + or by an individual or Legal Entity authorized to submit on behalf of + the copyright owner. For the purposes of this definition, "submitted" + means any form of electronic, verbal, or written communication sent + to the Licensor or its representatives, including but not limited to + communication on electronic mailing lists, source code control systems, + and issue tracking systems that are managed by, or on behalf of, the + Licensor for the purpose of discussing and improving the Work, but + excluding communication that is conspicuously marked or otherwise + designated in writing by the copyright owner as "Not a Contribution." + + "Contributor" shall mean Licensor and any individual or Legal Entity + on behalf of whom a Contribution has been received by Licensor and + subsequently incorporated within the Work. + + 2. Grant of Copyright License. Subject to the terms and conditions of + this License, each Contributor hereby grants to You a perpetual, + worldwide, non-exclusive, no-charge, royalty-free, irrevocable + copyright license to reproduce, prepare Derivative Works of, + publicly display, publicly perform, sublicense, and distribute the + Work and such Derivative Works in Source or Object form. + + 3. Grant of
[flink-table-store] 05/08: [FLINK-25619] Add tools/releasing/
This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-table-store.git
commit 0a6c41aa844c30627ebcd3b0bc8c662956d9ac28
Author: JingsongLi
AuthorDate: Wed Jan 12 14:08:16 2022 +0800
[FLINK-25619] Add tools/releasing/
---
tools/releasing/create_release_branch.sh | 62 ++
tools/releasing/create_source_release.sh | 89
tools/releasing/deploy_staging_jars.sh | 47 +
tools/releasing/update_branch_version.sh | 69 +
4 files changed, 267 insertions(+)
diff --git a/tools/releasing/create_release_branch.sh
b/tools/releasing/create_release_branch.sh
new file mode 100755
index 000..b490db6
--- /dev/null
+++ b/tools/releasing/create_release_branch.sh
@@ -0,0 +1,62 @@
+#!/usr/bin/env bash
+
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+#http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+##
+## Variables with defaults (if not overwritten by environment)
+##
+RELEASE_CANDIDATE=${RELEASE_CANDIDATE:-none}
+
+##
+## Required variables
+##
+RELEASE_VERSION=${RELEASE_VERSION}
+
+if [ -z "${RELEASE_VERSION}" ]; then
+ echo "RELEASE_VERSION was not set"
+ exit 1
+fi
+
+# fail immediately
+set -o errexit
+set -o nounset
+
+CURR_DIR=`pwd`
+BASE_DIR="$( cd "$( dirname "${BASH_SOURCE[0]}" )" >/dev/null && pwd )"
+PROJECT_ROOT="${BASE_DIR}/../../"
+
+# Sanity check to ensure that resolved paths are valid; a LICENSE file should
aways exist in project root
+if [ ! -f ${PROJECT_ROOT}/LICENSE ]; then
+echo "Project root path ${PROJECT_ROOT} is not valid; script may be in the
wrong directory."
+exit 1
+fi
+
+###
+
+TARGET_BRANCH=release-${RELEASE_VERSION}
+if [ "${RELEASE_CANDIDATE}" != "none" ]; then
+ TARGET_BRANCH=${TARGET_BRANCH}-rc${RELEASE_CANDIDATE}
+fi
+
+cd ${PROJECT_ROOT}
+git checkout -b ${TARGET_BRANCH}
+
+RELEASE_COMMIT_HASH=`git rev-parse HEAD`
+echo "Done. Created a new release branch with commit hash
${RELEASE_COMMIT_HASH}."
+
+cd ${CURR_DIR}
diff --git a/tools/releasing/create_source_release.sh
b/tools/releasing/create_source_release.sh
new file mode 100755
index 000..1731851
--- /dev/null
+++ b/tools/releasing/create_source_release.sh
@@ -0,0 +1,89 @@
+#!/usr/bin/env bash
+
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+#http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+##
+## Variables with defaults (if not overwritten by environment)
+##
+MVN=${MVN:-mvn}
+
+##
+## Required variables
+##
+RELEASE_VERSION=${RELEASE_VERSION}
+
+if [ -z "${RELEASE_VERSION}" ]; then
+ echo "RELEASE_VERSION is unset"
+ exit 1
+fi
+
+# fail immediately
+set -o errexit
+set -o nounset
+
+CURR_DIR=`pwd`
+BASE_DIR="$( cd "$( dirname "${BASH_SOURCE[0]}" )" >/dev/null && pwd )"
+PROJECT_ROOT="$( cd "$( dirname "${BASE_DIR}/../../../" )" >/dev/null && pwd )"
+
+# Sanity check to ensure that resolved paths are valid; a LICENSE file should
aways exist in project root
+if [ ! -f ${PROJECT_ROOT}/LICENSE ]; then
+echo "Project root path ${PROJECT_ROOT} is not valid; script may be in the
wrong directory."
+exit 1
+fi
+
+if [ "$(uname)" == "Darwin" ]; then
+SHASUM="shasum -a 512"
+else
+SHASUM="sha512sum"
+fi
+
+###
+
+RELEASE_DIR=${PROJECT_ROOT}/release
+CLONE_DIR=${RELEASE_DIR}/flink-table-store-tmp-clone
+
+rm -rf ${RELEASE_DIR}
+mkdir ${RELEASE_DIR}
+
+# delete the temporary release directory on error
+trap 'rm -rf ${RELEASE_DIR}' ERR
+
+echo
[flink-table-store] 07/08: [FLINK-25619] Add pom.xml
This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-table-store.git
commit 2bd3dd55c39dfded93d55b2dac42fa19cb8582e8
Author: JingsongLi
AuthorDate: Wed Jan 12 14:12:49 2022 +0800
[FLINK-25619] Add pom.xml
---
pom.xml | 700
1 file changed, 700 insertions(+)
diff --git a/pom.xml b/pom.xml
new file mode 100644
index 000..f37d66b
--- /dev/null
+++ b/pom.xml
@@ -0,0 +1,700 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
+4.0.0
+
+
+org.apache
+apache
+23
+
+
+flink-table-store-parent
+org.apache.flink
+Flink Table Store
+0.1-SNAPSHOT
+pom
+
+http://flink.apache.org
+2019
+
+
+
+The Apache Software License, Version 2.0
+https://www.apache.org/licenses/LICENSE-2.0.txt
+repo
+
+
+
+
+https://github.com/apache/flink-table-store
+g...@github.com:apache/flink-table-store.git
+
scm:git:https://gitbox.apache.org/repos/asf/flink-table-store.git
+
+
+
+
+
+
+1.15-SNAPSHOT
+2.12
+1.7.15
+2.17.1
+5.8.1
+2.4.2
+1.8
+3.21.0
+1.3.2
+1C
+true
+
+
+
+**/*Test.*
+
+
+
+
+
+
+org.slf4j
+slf4j-api
+
+
+
+
+com.google.code.findbugs
+jsr305
+
+
+
+
+
+org.junit.jupiter
+junit-jupiter
+${junit5.version}
+test
+
+
+
+org.junit
+junit-bom
+${junit5.version}
+pom
+import
+
+
+
+org.assertj
+assertj-core
+${assertj.version}
+test
+
+
+
+
+
+org.apache.logging.log4j
+log4j-slf4j-impl
+test
+
+
+
+org.apache.logging.log4j
+log4j-api
+test
+
+
+
+org.apache.logging.log4j
+log4j-core
+test
+
+
+
+
+org.apache.logging.log4j
+log4j-1.2-api
+test
+
+
+
+
+
+
+javax.annotation
+javax.annotation-api
+${javax.annotation-api.version}
+
+
+
+
+com.google.code.findbugs
+jsr305
+1.3.9
+
+
+
+org.apache.flink
+flink-shaded-jackson
+${jackson.version}-${flink.shaded.version}
+
+
+
+junit
+junit
+${junit.version}
+
+
+
+org.slf4j
+slf4j-api
+${slf4j.version}
+
+
+
+org.apache.logging.log4j
+log4j-slf4j-impl
+${log4j.version}
+
+
+
+org.apache.logging.log4j
+log4j-api
+${log4j.version}
+
+
+
+org.apache.logging.log4j
+log4j-core
+${log4j.version}
+
+
+
+
+org.apache.logging.log4j
+log4j-1.2-api
+${log4j.version}
+
+
+
+org.apache.flink
+flink-test-utils-junit
+${flink.version}
+test
+
+
+
+
+
+
+
+apache-release
+
+
+
+org.apache.maven.plugins
+maven-assembly-plugin
+
+
+org.apache.apache.resources
+
apache-source-release-assembly-descriptor
+1.0.6
+
+
+
+
+source-release-assembly
+
+none
+
+
+
+
+
+
+
+
+
+
+
+org.apache.maven.plugins
+maven-jar-plugin
+
[flink-table-store] 06/08: [FLINK-25619] Add .github/workflows/java8-build.yml
This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-table-store.git commit f6f294fb763989cd49f89f0da90e16aadd0d2cfd Author: JingsongLi AuthorDate: Wed Jan 12 14:08:42 2022 +0800 [FLINK-25619] Add .github/workflows/java8-build.yml --- .github/workflows/java8-build.yml | 18 ++ 1 file changed, 18 insertions(+) diff --git a/.github/workflows/java8-build.yml b/.github/workflows/java8-build.yml new file mode 100644 index 000..d68d465 --- /dev/null +++ b/.github/workflows/java8-build.yml @@ -0,0 +1,18 @@ +name: Java 8 Build + +on: [push, pull_request] + +jobs: + build: +runs-on: ubuntu-latest + +steps: + - name: Checkout code +uses: actions/checkout@v2 + - name: Set up JDK 1.8 +uses: actions/setup-java@v1 +with: + java-version: 1.8 + - name: Build +run: mvn clean install +
[flink-table-store] branch master updated (a249eba -> 9d5c08c)
This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink-table-store.git. from a249eba Initial Commit. Add .asf.yaml new d0e4138 [FLINK-25619] Add README.md new 96de3c9 [FLINK-25619] Add NOTICE LICENSE CODE_OF_CONDUCT new 8098f0a [FLINK-25619] Add .gitignore new 7d01fc0 [FLINK-25619] Add tools/maven/ new 0a6c41a [FLINK-25619] Add tools/releasing/ new f6f294f [FLINK-25619] Add .github/workflows/java8-build.yml new 2bd3dd5 [FLINK-25619] Add pom.xml new 9d5c08c [FLINK-25619] Disable merge button The 8 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: .asf.yaml| 6 + .github/workflows/java8-build.yml| 18 + .gitignore | 18 + CODE_OF_CONDUCT.md | 3 + LICENSE | 201 + NOTICE | 5 + README.md| 19 + pom.xml | 700 +++ tools/maven/checkstyle.xml | 562 + tools/maven/scalastyle-config.xml| 146 +++ tools/maven/suppressions.xml | 85 tools/releasing/create_release_branch.sh | 62 +++ tools/releasing/create_source_release.sh | 89 tools/releasing/deploy_staging_jars.sh | 47 +++ tools/releasing/update_branch_version.sh | 69 +++ 15 files changed, 2030 insertions(+) create mode 100644 .github/workflows/java8-build.yml create mode 100644 .gitignore create mode 100644 CODE_OF_CONDUCT.md create mode 100644 LICENSE create mode 100644 NOTICE create mode 100644 README.md create mode 100644 pom.xml create mode 100644 tools/maven/checkstyle.xml create mode 100644 tools/maven/scalastyle-config.xml create mode 100644 tools/maven/suppressions.xml create mode 100755 tools/releasing/create_release_branch.sh create mode 100755 tools/releasing/create_source_release.sh create mode 100755 tools/releasing/deploy_staging_jars.sh create mode 100755 tools/releasing/update_branch_version.sh
[flink-table-store] 03/08: [FLINK-25619] Add .gitignore
This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-table-store.git commit 8098f0a604503795de347bfc27478b53d6bef285 Author: JingsongLi AuthorDate: Wed Jan 12 14:07:50 2022 +0800 [FLINK-25619] Add .gitignore --- .gitignore | 18 ++ 1 file changed, 18 insertions(+) diff --git a/.gitignore b/.gitignore new file mode 100644 index 000..afd1e95 --- /dev/null +++ b/.gitignore @@ -0,0 +1,18 @@ +.cache +.classpath +.idea +.metadata +.settings +.project +target +.version.properties +*.class +*.iml +*.swp +*.jar +*.zip +*.log +*.pyc +.DS_Store +*.ipr +*.iws
[flink-table-store] 01/08: [FLINK-25619] Add README.md
This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-table-store.git commit d0e4138a24ca35b944c0243f97d19c48b2501c59 Author: JingsongLi AuthorDate: Wed Jan 12 14:07:09 2022 +0800 [FLINK-25619] Add README.md --- README.md | 19 +++ 1 file changed, 19 insertions(+) diff --git a/README.md b/README.md new file mode 100644 index 000..1ef906b --- /dev/null +++ b/README.md @@ -0,0 +1,19 @@ +# FLink Table Store + +Flink Table Store is a unified streaming and batch store for building dynamic tables on Apache Flink. + +Flink Table Store is developed under the umbrella of [Apache Flink](https://flink.apache.org/). + +## Building the Project + +Run the `mvn clean package` command. + +Then you will find a JAR file that contains your application, plus any libraries that you may have added as dependencies to the application: `target/-.jar`. + +## Contributing + +You can learn more about how to contribute on the [Apache Flink website](https://flink.apache.org/contributing/how-to-contribute.html). For code contributions, please read carefully the [Contributing Code](https://flink.apache.org/contributing/contribute-code.html) section for an overview of ongoing community work. + +## License + +The code in this repository is licensed under the [Apache Software License 2](LICENSE).
[flink] branch master updated (41e96d2 -> 2d98608)
This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 41e96d2 [FLINK-25601][state][config] Update the 'state.backend' option add 2d98608 [FLINK-25209][tests] Wait until the consuming topic is ready before polling records in KafkaContainerClient#readMessages No new revisions were added by this update. Summary of changes: .../tests/util/kafka/KafkaContainerClient.java | 25 +++--- .../util/kafka/SQLClientSchemaRegistryITCase.java | 2 -- 2 files changed, 22 insertions(+), 5 deletions(-)
[flink-table-store] 01/01: Initial Commit. Add .asf.yaml
This is an automated email from the ASF dual-hosted git repository. jqin pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-table-store.git commit a249ebac66d00f664d257551029da9b1beddaf1f Author: Jiangjie (Becket) Qin AuthorDate: Wed Jan 12 11:33:21 2022 +0800 Initial Commit. Add .asf.yaml --- .asf.yaml | 5 + 1 file changed, 5 insertions(+) diff --git a/.asf.yaml b/.asf.yaml new file mode 100644 index 000..82eef0b --- /dev/null +++ b/.asf.yaml @@ -0,0 +1,5 @@ +notifications: + commits: commits@flink.apache.org + issues: iss...@flink.apache.org + pullrequests: iss...@flink.apache.org + jira_options: link label
[flink-table-store] branch master created (now a249eba)
This is an automated email from the ASF dual-hosted git repository. jqin pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink-table-store.git. at a249eba Initial Commit. Add .asf.yaml This branch includes the following new commits: new a249eba Initial Commit. Add .asf.yaml 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.
[flink] branch master updated (785ca59 -> 41e96d2)
This is an automated email from the ASF dual-hosted git repository. tangyun pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 785ca59 [FLINK-25107][formats/gsr] Migrate tests to use Assert4J add 41e96d2 [FLINK-25601][state][config] Update the 'state.backend' option No new revisions were added by this update. Summary of changes: flink-dist/src/main/resources/flink-conf.yaml | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-)
[flink] branch master updated (785ca59 -> 41e96d2)
This is an automated email from the ASF dual-hosted git repository. tangyun pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 785ca59 [FLINK-25107][formats/gsr] Migrate tests to use Assert4J add 41e96d2 [FLINK-25601][state][config] Update the 'state.backend' option No new revisions were added by this update. Summary of changes: flink-dist/src/main/resources/flink-conf.yaml | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-)
[flink] branch master updated (d7cf2c1 -> 785ca59)
This is an automated email from the ASF dual-hosted git repository. dannycranmer pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from d7cf2c1 [FLINK-22602][Formats][Parquet] Upgrade Parquet dependency to 1.12.2 add 46e1e60 [FLINK-25107][formats/gsr] Adding support to define AWS Credential Provider from property map, fixing e2e tests add 785ca59 [FLINK-25107][formats/gsr] Migrate tests to use Assert4J No new revisions were added by this update. Summary of changes: .../flink/connector/aws/util/AWSGeneralUtil.java | 15 +++ .../connector/aws/util/AWSGeneralUtilTest.java | 11 ++ .../registry/test/GSRKinesisPubsubClient.java | 50 - .../test/GlueSchemaRegistryAvroKinesisITCase.java | 35 --- .../flink-glue-schema-registry-json-test/pom.xml | 2 +- .../registry/test/json/GSRKinesisPubsubClient.java | 50 - .../json/GlueSchemaRegistryJsonKinesisITCase.java | 32 +++--- .../flink-avro-glue-schema-registry/pom.xml| 6 ++ .../GlueSchemaRegistryInputStreamDeserializer.java | 7 +- .../GlueSchemaRegistryOutputStreamSerializer.java | 8 +- ...chemaRegistryAvroDeserializationSchemaTest.java | 24 ++--- .../GlueSchemaRegistryAvroSchemaCoderTest.java | 32 ++ ...eSchemaRegistryAvroSerializationSchemaTest.java | 52 +- ...eSchemaRegistryInputStreamDeserializerTest.java | 113 + ...ueSchemaRegistryOutputStreamSerializerTest.java | 22 ++-- .../flink-json-glue-schema-registry/pom.xml| 6 ++ .../GlueSchemaRegistryJsonSchemaCoder.java | 10 +- ...chemaRegistryJsonDeserializationSchemaTest.java | 62 ++- .../GlueSchemaRegistryJsonSchemaCoderTest.java | 80 +++ ...eSchemaRegistryJsonSerializationSchemaTest.java | 58 +-- 20 files changed, 400 insertions(+), 275 deletions(-) create mode 100644 flink-formats/flink-json-glue-schema-registry/src/test/java/org/apache/flink/formats/json/glue/schema/registry/GlueSchemaRegistryJsonSchemaCoderTest.java
[flink] branch master updated: [FLINK-22602][Formats][Parquet] Upgrade Parquet dependency to 1.12.2
This is an automated email from the ASF dual-hosted git repository. fpaul 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 d7cf2c1 [FLINK-22602][Formats][Parquet] Upgrade Parquet dependency to 1.12.2 d7cf2c1 is described below commit d7cf2c10f8d4fba81173854cbd8be27c657c7c7f Author: Bo Cui AuthorDate: Sat May 8 11:47:19 2021 +0800 [FLINK-22602][Formats][Parquet] Upgrade Parquet dependency to 1.12.2 --- .../flink-connector-hive/src/main/resources/META-INF/NOTICE | 12 ++-- .../flink-sql-parquet/src/main/resources/META-INF/NOTICE | 12 ++-- flink-formats/pom.xml| 2 +- 3 files changed, 13 insertions(+), 13 deletions(-) diff --git a/flink-connectors/flink-connector-hive/src/main/resources/META-INF/NOTICE b/flink-connectors/flink-connector-hive/src/main/resources/META-INF/NOTICE index 829fb7b..3c07c1e 100644 --- a/flink-connectors/flink-connector-hive/src/main/resources/META-INF/NOTICE +++ b/flink-connectors/flink-connector-hive/src/main/resources/META-INF/NOTICE @@ -6,9 +6,9 @@ The Apache Software Foundation (http://www.apache.org/). This project bundles the following dependencies under the Apache Software License 2.0. (http://www.apache.org/licenses/LICENSE-2.0.txt) -- org.apache.parquet:parquet-hadoop:1.11.1 -- org.apache.parquet:parquet-column:1.11.1 -- org.apache.parquet:parquet-common:1.11.1 -- org.apache.parquet:parquet-encoding:1.11.1 -- org.apache.parquet:parquet-format-structures:1.11.1 -- org.apache.parquet:parquet-jackson:1.11.1 +- org.apache.parquet:parquet-hadoop:1.12.2 +- org.apache.parquet:parquet-column:1.12.2 +- org.apache.parquet:parquet-common:1.12.2 +- org.apache.parquet:parquet-encoding:1.12.2 +- org.apache.parquet:parquet-format-structures:1.12.2 +- org.apache.parquet:parquet-jackson:1.12.2 diff --git a/flink-formats/flink-sql-parquet/src/main/resources/META-INF/NOTICE b/flink-formats/flink-sql-parquet/src/main/resources/META-INF/NOTICE index 97c0d9e..bc6ac30 100644 --- a/flink-formats/flink-sql-parquet/src/main/resources/META-INF/NOTICE +++ b/flink-formats/flink-sql-parquet/src/main/resources/META-INF/NOTICE @@ -6,10 +6,10 @@ The Apache Software Foundation (http://www.apache.org/). This project bundles the following dependencies under the Apache Software License 2.0. (http://www.apache.org/licenses/LICENSE-2.0.txt) -- org.apache.parquet:parquet-hadoop:1.11.1 -- org.apache.parquet:parquet-column:1.11.1 -- org.apache.parquet:parquet-common:1.11.1 -- org.apache.parquet:parquet-encoding:1.11.1 -- org.apache.parquet:parquet-format-structures:1.11.1 -- org.apache.parquet:parquet-jackson:1.11.1 +- org.apache.parquet:parquet-hadoop:1.12.2 +- org.apache.parquet:parquet-column:1.12.2 +- org.apache.parquet:parquet-common:1.12.2 +- org.apache.parquet:parquet-encoding:1.12.2 +- org.apache.parquet:parquet-format-structures:1.12.2 +- org.apache.parquet:parquet-jackson:1.12.2 - commons-pool:commons-pool:1.6 diff --git a/flink-formats/pom.xml b/flink-formats/pom.xml index cbb32d9..4427256 100644 --- a/flink-formats/pom.xml +++ b/flink-formats/pom.xml @@ -31,7 +31,7 @@ under the License. - 1.11.1 + 1.12.2 flink-formats
[flink] branch master updated (651e851 -> d1cc458)
This is an automated email from the ASF dual-hosted git repository. pnowojski pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 651e851 [hotfix][python][docs] Fix typo in a description of submitting option add d1cc458 [FLINK-24694][docs-zh] Translate "Checkpointing under backpressure" page into Chinese No new revisions were added by this update. Summary of changes: .../ops/state/checkpointing_under_backpressure.md | 178 + 1 file changed, 76 insertions(+), 102 deletions(-)
[flink] branch master updated (c661cf9 -> 651e851)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from c661cf9 [FLINK-24884][runtime-web] use correct type add 651e851 [hotfix][python][docs] Fix typo in a description of submitting option No new revisions were added by this update. Summary of changes: docs/content.zh/docs/deployment/cli.md | 2 +- docs/content/docs/deployment/cli.md| 2 +- 2 files changed, 2 insertions(+), 2 deletions(-)
[flink] branch master updated (f56771d -> c661cf9)
This is an automated email from the ASF dual-hosted git repository. airblader pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from f56771d [FLINK-25553][filesystem] Remove MapR filesystem add c661cf9 [FLINK-24884][runtime-web] use correct type No new revisions were added by this update. Summary of changes: flink-runtime-web/web-dashboard/src/@types/d3-flame-graph/index.d.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
[flink] branch master updated (7601bd3 -> f56771d)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 7601bd3 [FLINK-25488][table] Clarify delimiters usage in STR_TO_MAP function add f56771d [FLINK-25553][filesystem] Remove MapR filesystem No new revisions were added by this update. Summary of changes: .../docs/deployment/filesystems/overview.md| 6 +- .../docs/deployment/filesystems/plugins.md | 2 +- docs/content.zh/docs/internals/filesystems.md | 1 - .../docs/deployment/filesystems/overview.md| 7 +- .../content/docs/deployment/filesystems/plugins.md | 2 +- docs/content/docs/internals/filesystems.md | 1 - .../java/org/apache/flink/core/fs/FileSystem.java | 1 - flink-dist/pom.xml | 10 +- flink-filesystems/flink-mapr-fs/pom.xml| 70 -- .../flink/runtime/fs/maprfs/MapRFsFactory.java | 242 - .../org.apache.flink.core.fs.FileSystemFactory | 16 -- .../src/test/java/com/mapr/fs/MapRFileSystem.java | 97 - .../flink/runtime/fs/maprfs/MapRFsFactoryTest.java | 65 -- .../runtime/fs/maprfs/MapRNotInClassPathTest.java | 124 --- .../src/test/resources/log4j2-test.properties | 28 --- flink-filesystems/pom.xml | 1 - .../datastream/stream_execution_environment.py | 2 +- tools/ci/shade.sh | 8 - tools/ci/stage.sh | 1 - 19 files changed, 9 insertions(+), 675 deletions(-) delete mode 100644 flink-filesystems/flink-mapr-fs/pom.xml delete mode 100644 flink-filesystems/flink-mapr-fs/src/main/java/org/apache/flink/runtime/fs/maprfs/MapRFsFactory.java delete mode 100644 flink-filesystems/flink-mapr-fs/src/main/resources/META-INF/services/org.apache.flink.core.fs.FileSystemFactory delete mode 100644 flink-filesystems/flink-mapr-fs/src/test/java/com/mapr/fs/MapRFileSystem.java delete mode 100644 flink-filesystems/flink-mapr-fs/src/test/java/org/apache/flink/runtime/fs/maprfs/MapRFsFactoryTest.java delete mode 100644 flink-filesystems/flink-mapr-fs/src/test/java/org/apache/flink/runtime/fs/maprfs/MapRNotInClassPathTest.java delete mode 100644 flink-filesystems/flink-mapr-fs/src/test/resources/log4j2-test.properties
[flink] branch master updated (602db48 -> 7601bd3)
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 602db48 [FLINK-25190][coordination][metrics] Add "numPendingTaskManagers" metrics add 7601bd3 [FLINK-25488][table] Clarify delimiters usage in STR_TO_MAP function No new revisions were added by this update. Summary of changes: docs/data/sql_functions.yml | 6 -- docs/data/sql_functions_zh.yml | 3 ++- .../flink/table/planner/expressions/ScalarFunctionsTest.scala | 3 +++ .../org/apache/flink/table/runtime/functions/SqlFunctionUtils.java | 4 +++- 4 files changed, 12 insertions(+), 4 deletions(-)
[flink] branch master updated (423b710 -> 602db48)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 423b710 [FLINK-25390][connector-kafka][json] Show usage of helper to forward and merge options add 602db48 [FLINK-25190][coordination][metrics] Add "numPendingTaskManagers" metrics No new revisions were added by this update. Summary of changes: docs/content.zh/docs/ops/metrics.md | 5 + docs/content/docs/ops/metrics.md | 5 + .../src/main/java/org/apache/flink/runtime/metrics/MetricNames.java | 1 + .../flink/runtime/resourcemanager/active/ActiveResourceManager.java | 2 ++ 4 files changed, 13 insertions(+)
[flink] branch master updated (23c477f -> 423b710)
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 23c477f [FLINK-25280][connector/kafka] Disable log deletion in KafkaTestEnvironmentImpl to prevent records from being deleted during test run add ca3a3cf [FLINK-25390][table-common] Introduce forwardOptions for table and format factories add 423b710 [FLINK-25390][connector-kafka][json] Show usage of helper to forward and merge options No new revisions were added by this update. Summary of changes: .../connector/elasticsearch/table/TestContext.java | 1 + .../kafka/table/KafkaConnectorOptionsUtil.java | 1 + .../kafka/table/KafkaDynamicTableFactory.java | 20 ++- .../flink/formats/json/JsonFormatFactory.java | 11 ++ .../flink/formats/json/JsonFormatFactoryTest.java | 137 --- .../flink/table/catalog/ManagedTableListener.java | 3 +- .../table/factories/DecodingFormatFactory.java | 2 +- .../flink/table/factories/DynamicTableFactory.java | 67 +++- .../table/factories/EncodingFormatFactory.java | 2 +- .../apache/flink/table/factories/FactoryUtil.java | 189 +++-- .../flink/table/factories/FormatFactory.java | 52 ++ .../flink/table/factories/FactoryUtilTest.java | 165 ++ .../table/factories/TestDynamicTableFactory.java | 8 + .../flink/table/factories/TestFormatFactory.java | 7 + .../flink/table/factories/utils/FactoryMocks.java | 9 + 15 files changed, 595 insertions(+), 79 deletions(-) create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/FormatFactory.java
[flink] branch master updated (29dd24f -> 23c477f)
This is an automated email from the ASF dual-hosted git repository. fpaul pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 29dd24f [FLINK-25461][python] Update net.sf.py4j:py4j dependency to 0.10.8.1 add 23c477f [FLINK-25280][connector/kafka] Disable log deletion in KafkaTestEnvironmentImpl to prevent records from being deleted during test run No new revisions were added by this update. Summary of changes: .../flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java | 2 ++ 1 file changed, 2 insertions(+)
[flink] branch master updated (7bbf368 -> 29dd24f)
This is an automated email from the ASF dual-hosted git repository. hxb pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 7bbf368 [FLINK-25362][docs] fix maven instructions for "Confluent Avro Format" add 29dd24f [FLINK-25461][python] Update net.sf.py4j:py4j dependency to 0.10.8.1 No new revisions were added by this update. Summary of changes: NOTICE | 2 +- flink-python/README.md | 2 +- flink-python/dev/dev-requirements.txt | 2 +- flink-python/lib/py4j-0.10.8.1-src.zip | Bin 82546 -> 0 bytes flink-python/lib/py4j-0.10.9.3-src.zip | Bin 0 -> 83148 bytes flink-python/setup.py | 2 +- flink-python/src/main/resources/META-INF/NOTICE | 2 +- pom.xml | 2 +- 8 files changed, 6 insertions(+), 6 deletions(-) delete mode 100644 flink-python/lib/py4j-0.10.8.1-src.zip create mode 100644 flink-python/lib/py4j-0.10.9.3-src.zip
[flink] branch release-1.14 updated: [FLINK-25576][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206
This is an automated email from the ASF dual-hosted git repository. fpaul pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.14 by this push: new 2f16c53 [FLINK-25576][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206 2f16c53 is described below commit 2f16c5323c59eeaa6ca286655baf1a880de4c42c Author: martijnvisser AuthorDate: Fri Jan 7 14:49:02 2022 +0100 [FLINK-25576][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206 --- flink-connectors/flink-connector-jdbc/pom.xml | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/flink-connectors/flink-connector-jdbc/pom.xml b/flink-connectors/flink-connector-jdbc/pom.xml index e555ce7..16b4be6 100644 --- a/flink-connectors/flink-connector-jdbc/pom.xml +++ b/flink-connectors/flink-connector-jdbc/pom.xml @@ -158,8 +158,8 @@ under the License. com.h2database h2 - 1.4.200 - + 2.0.206 + org.testcontainers
[flink] branch release-1.13 updated (e3d06b8 -> 74a4351)
This is an automated email from the ASF dual-hosted git repository. fpaul pushed a change to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git. from e3d06b8 [FLINK-25362][docs] fix maven instructions for "Confluent Avro Format" add 74a4351 [FLINK-25576][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206 No new revisions were added by this update. Summary of changes: flink-connectors/flink-connector-jdbc/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
[flink] branch master updated (0bc2234 -> 7bbf368)
This is an automated email from the ASF dual-hosted git repository. nkruber pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 0bc2234 [FLINK-25266][e2e] Convert StreamingKafkaITCase to SmokeKafkaITCase covering application packaging new e9dba5e [FLINK-25362][docs] allow SQL maven artifact list new dccbb87 [FLINK-25362][docs] fix the Avro Format maven dependency new 7bbf368 [FLINK-25362][docs] fix maven instructions for "Confluent Avro Format" The 3 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: .../docs/connectors/table/formats/avro-confluent.md | 2 ++ docs/content/docs/connectors/table/formats/avro-confluent.md | 2 ++ docs/data/sql_connectors.yml | 6 -- docs/layouts/shortcodes/sql_download_table.html | 11 --- 4 files changed, 16 insertions(+), 5 deletions(-)
[flink] 03/03: [FLINK-25362][docs] fix maven instructions for "Confluent Avro Format"
This is an automated email from the ASF dual-hosted git repository.
nkruber pushed a commit to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git
commit e3d06b8807fd736a9ae3706c7c5bc4ef4336cd51
Author: Nico Kruber
AuthorDate: Fri Dec 17 11:50:06 2021 +0100
[FLINK-25362][docs] fix maven instructions for "Confluent Avro Format"
---
docs/content.zh/docs/connectors/table/formats/avro-confluent.md | 2 ++
docs/content/docs/connectors/table/formats/avro-confluent.md| 2 ++
docs/data/sql_connectors.yml| 4 +++-
3 files changed, 7 insertions(+), 1 deletion(-)
diff --git a/docs/content.zh/docs/connectors/table/formats/avro-confluent.md
b/docs/content.zh/docs/connectors/table/formats/avro-confluent.md
index 9ff6aba..b8ca74a 100644
--- a/docs/content.zh/docs/connectors/table/formats/avro-confluent.md
+++ b/docs/content.zh/docs/connectors/table/formats/avro-confluent.md
@@ -44,6 +44,8 @@ Avro Schema Registry 格式只能与 [Apache Kafka SQL 连接器]({{< ref
"docs/
{{< sql_download_table "avro-confluent" >}}
+For Maven, SBT, Gradle, or other build automation tools, please also ensure
that Confluent's maven repository at `https://packages.confluent.io/maven/` is
configured in your project's build files.
+
如何创建使用 Avro-Confluent 格式的表
diff --git a/docs/content/docs/connectors/table/formats/avro-confluent.md
b/docs/content/docs/connectors/table/formats/avro-confluent.md
index d8d9224..518baff 100644
--- a/docs/content/docs/connectors/table/formats/avro-confluent.md
+++ b/docs/content/docs/connectors/table/formats/avro-confluent.md
@@ -42,6 +42,8 @@ Dependencies
{{< sql_download_table "avro-confluent" >}}
+For Maven, SBT, Gradle, or other build automation tools, please also ensure
that Confluent's maven repository at `https://packages.confluent.io/maven/` is
configured in your project's build files.
+
How to create tables with Avro-Confluent format
--
diff --git a/docs/data/sql_connectors.yml b/docs/data/sql_connectors.yml
index 44d92ff..63f52421 100644
--- a/docs/data/sql_connectors.yml
+++ b/docs/data/sql_connectors.yml
@@ -44,7 +44,9 @@ avro:
avro-confluent:
name: Avro Schema Registry
-maven: flink-avro-confluent-registry
+maven:
+ - flink-avro-confluent-registry
+ - flink-avro
category: format
sql_url:
https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-avro-confluent-registry/$version/flink-sql-avro-confluent-registry-$version.jar
[flink] 02/03: [FLINK-25362][docs] fix the Avro Format maven dependency
This is an automated email from the ASF dual-hosted git repository. nkruber pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git commit 06ab1ecbae141abfc4f97edf13fc9eba377efe9f Author: Nico Kruber AuthorDate: Fri Dec 17 11:38:15 2021 +0100 [FLINK-25362][docs] fix the Avro Format maven dependency It was falsely pointing to the shaded sql artifact. --- docs/data/sql_connectors.yml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/data/sql_connectors.yml b/docs/data/sql_connectors.yml index 989b5f2..44d92ff 100644 --- a/docs/data/sql_connectors.yml +++ b/docs/data/sql_connectors.yml @@ -38,7 +38,7 @@ avro: name: Avro -maven: flink-sql-avro +maven: flink-avro category: format sql_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-avro/$version/flink-sql-avro-$version.jar
[flink] 01/03: [FLINK-25362][docs] allow SQL maven artifact list
This is an automated email from the ASF dual-hosted git repository.
nkruber pushed a commit to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 327113d26e80cfe3d9adf759473ce78374df47fd
Author: Nico Kruber
AuthorDate: Fri Dec 17 11:36:07 2021 +0100
[FLINK-25362][docs] allow SQL maven artifact list
If a connector needs more than one maven dependency, these can instead be
defined as a list/array now. The old syntax with a single string is also
still
possible.
---
docs/layouts/shortcodes/sql_download_table.html | 11 ---
1 file changed, 8 insertions(+), 3 deletions(-)
diff --git a/docs/layouts/shortcodes/sql_download_table.html
b/docs/layouts/shortcodes/sql_download_table.html
index 3c348c7e..0952e06 100644
--- a/docs/layouts/shortcodes/sql_download_table.html
+++ b/docs/layouts/shortcodes/sql_download_table.html
@@ -89,11 +89,16 @@ and SQL Client with SQL JAR bundles.
rendered documentation.
*/}}
{{ define "maven-artifact" }}{{/* (dict "ArtifactId" .ArtifactId */}}
-
+
+{{- $artifacts := cond (eq (printf "%T" .ArtifactId) "string") (slice
.ArtifactId) .ArtifactId -}}
+{{- range $artifact := $artifacts -}}
+
org.apache.flink
- {{- partial "docs/interpolate"
.ArtifactId -}}
+ {{- partial "docs/interpolate"
$artifact -}}
{{- site.Params.Version -}}
-
+
+{{- end -}}
+
Copied to clipboard!
[flink] branch release-1.13 updated (86a6e2b -> e3d06b8)
This is an automated email from the ASF dual-hosted git repository. nkruber pushed a change to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git. from 86a6e2b [FLINK-25307][test] Print the curl logs is querying dispatcher startup failed new 327113d [FLINK-25362][docs] allow SQL maven artifact list new 06ab1ec [FLINK-25362][docs] fix the Avro Format maven dependency new e3d06b8 [FLINK-25362][docs] fix maven instructions for "Confluent Avro Format" The 3 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: .../docs/connectors/table/formats/avro-confluent.md | 2 ++ docs/content/docs/connectors/table/formats/avro-confluent.md | 2 ++ docs/data/sql_connectors.yml | 6 -- docs/layouts/shortcodes/sql_download_table.html | 11 --- 4 files changed, 16 insertions(+), 5 deletions(-)
[flink] 02/03: [FLINK-25362][docs] fix the Avro Format maven dependency
This is an automated email from the ASF dual-hosted git repository. nkruber pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git commit eca3aabc1691f3abb604994f06153ddf84a132d7 Author: Nico Kruber AuthorDate: Fri Dec 17 11:38:15 2021 +0100 [FLINK-25362][docs] fix the Avro Format maven dependency It was falsely pointing to the shaded sql artifact. --- docs/data/sql_connectors.yml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/data/sql_connectors.yml b/docs/data/sql_connectors.yml index 989b5f2..44d92ff 100644 --- a/docs/data/sql_connectors.yml +++ b/docs/data/sql_connectors.yml @@ -38,7 +38,7 @@ avro: name: Avro -maven: flink-sql-avro +maven: flink-avro category: format sql_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-avro/$version/flink-sql-avro-$version.jar
[flink] branch release-1.14 updated (ae8a4b7 -> 7b24c90)
This is an automated email from the ASF dual-hosted git repository. nkruber pushed a change to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git. from ae8a4b7 [FLINK-25307][test] Print the curl logs is querying dispatcher startup failed new d8b6f89 [FLINK-25362][docs] allow SQL maven artifact list new eca3aab [FLINK-25362][docs] fix the Avro Format maven dependency new 7b24c90 [FLINK-25362][docs] fix maven instructions for "Confluent Avro Format" The 3 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: .../docs/connectors/table/formats/avro-confluent.md | 2 ++ docs/content/docs/connectors/table/formats/avro-confluent.md | 2 ++ docs/data/sql_connectors.yml | 6 -- docs/layouts/shortcodes/sql_download_table.html | 11 --- 4 files changed, 16 insertions(+), 5 deletions(-)
[flink] 03/03: [FLINK-25362][docs] fix maven instructions for "Confluent Avro Format"
This is an automated email from the ASF dual-hosted git repository.
nkruber pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 7b24c90c125d4eaf8e97e6be8073cf8ee83d2290
Author: Nico Kruber
AuthorDate: Fri Dec 17 11:50:06 2021 +0100
[FLINK-25362][docs] fix maven instructions for "Confluent Avro Format"
---
docs/content.zh/docs/connectors/table/formats/avro-confluent.md | 2 ++
docs/content/docs/connectors/table/formats/avro-confluent.md| 2 ++
docs/data/sql_connectors.yml| 4 +++-
3 files changed, 7 insertions(+), 1 deletion(-)
diff --git a/docs/content.zh/docs/connectors/table/formats/avro-confluent.md
b/docs/content.zh/docs/connectors/table/formats/avro-confluent.md
index 61248d1..ddb3c08 100644
--- a/docs/content.zh/docs/connectors/table/formats/avro-confluent.md
+++ b/docs/content.zh/docs/connectors/table/formats/avro-confluent.md
@@ -44,6 +44,8 @@ Avro Schema Registry 格式只能与 [Apache Kafka SQL 连接器]({{< ref
"docs/
{{< sql_download_table "avro-confluent" >}}
+For Maven, SBT, Gradle, or other build automation tools, please also ensure
that Confluent's maven repository at `https://packages.confluent.io/maven/` is
configured in your project's build files.
+
如何创建使用 Avro-Confluent 格式的表
diff --git a/docs/content/docs/connectors/table/formats/avro-confluent.md
b/docs/content/docs/connectors/table/formats/avro-confluent.md
index 7ab4c98..cf2fe70 100644
--- a/docs/content/docs/connectors/table/formats/avro-confluent.md
+++ b/docs/content/docs/connectors/table/formats/avro-confluent.md
@@ -42,6 +42,8 @@ Dependencies
{{< sql_download_table "avro-confluent" >}}
+For Maven, SBT, Gradle, or other build automation tools, please also ensure
that Confluent's maven repository at `https://packages.confluent.io/maven/` is
configured in your project's build files.
+
How to create tables with Avro-Confluent format
--
diff --git a/docs/data/sql_connectors.yml b/docs/data/sql_connectors.yml
index 44d92ff..63f52421 100644
--- a/docs/data/sql_connectors.yml
+++ b/docs/data/sql_connectors.yml
@@ -44,7 +44,9 @@ avro:
avro-confluent:
name: Avro Schema Registry
-maven: flink-avro-confluent-registry
+maven:
+ - flink-avro-confluent-registry
+ - flink-avro
category: format
sql_url:
https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-avro-confluent-registry/$version/flink-sql-avro-confluent-registry-$version.jar
[flink] 01/03: [FLINK-25362][docs] allow SQL maven artifact list
This is an automated email from the ASF dual-hosted git repository.
nkruber pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git
commit d8b6f896c424e92bf020abc18f532cf02e99bdc7
Author: Nico Kruber
AuthorDate: Fri Dec 17 11:36:07 2021 +0100
[FLINK-25362][docs] allow SQL maven artifact list
If a connector needs more than one maven dependency, these can instead be
defined as a list/array now. The old syntax with a single string is also
still
possible.
---
docs/layouts/shortcodes/sql_download_table.html | 11 ---
1 file changed, 8 insertions(+), 3 deletions(-)
diff --git a/docs/layouts/shortcodes/sql_download_table.html
b/docs/layouts/shortcodes/sql_download_table.html
index 3c348c7e..0952e06 100644
--- a/docs/layouts/shortcodes/sql_download_table.html
+++ b/docs/layouts/shortcodes/sql_download_table.html
@@ -89,11 +89,16 @@ and SQL Client with SQL JAR bundles.
rendered documentation.
*/}}
{{ define "maven-artifact" }}{{/* (dict "ArtifactId" .ArtifactId */}}
-
+
+{{- $artifacts := cond (eq (printf "%T" .ArtifactId) "string") (slice
.ArtifactId) .ArtifactId -}}
+{{- range $artifact := $artifacts -}}
+
org.apache.flink
- {{- partial "docs/interpolate"
.ArtifactId -}}
+ {{- partial "docs/interpolate"
$artifact -}}
{{- site.Params.Version -}}
-
+
+{{- end -}}
+
Copied to clipboard!
[flink] 02/03: [FLINK-25362][docs] fix the Avro Format maven dependency
This is an automated email from the ASF dual-hosted git repository. nkruber pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit dccbb87462b9188472d2b93e301774ca4716ce4d Author: Nico Kruber AuthorDate: Fri Dec 17 11:38:15 2021 +0100 [FLINK-25362][docs] fix the Avro Format maven dependency It was falsely pointing to the shaded sql artifact. --- docs/data/sql_connectors.yml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/data/sql_connectors.yml b/docs/data/sql_connectors.yml index b3e6d53..31e68ee 100644 --- a/docs/data/sql_connectors.yml +++ b/docs/data/sql_connectors.yml @@ -38,7 +38,7 @@ avro: name: Avro -maven: flink-sql-avro +maven: flink-avro category: format sql_url: https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-avro/$version/flink-sql-avro-$version.jar
[flink] 03/03: [FLINK-25362][docs] fix maven instructions for "Confluent Avro Format"
This is an automated email from the ASF dual-hosted git repository.
nkruber pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 7bbf368bdfbf518245a659cc64ee8a8661ba4e8c
Author: Nico Kruber
AuthorDate: Fri Dec 17 11:50:06 2021 +0100
[FLINK-25362][docs] fix maven instructions for "Confluent Avro Format"
---
docs/content.zh/docs/connectors/table/formats/avro-confluent.md | 2 ++
docs/content/docs/connectors/table/formats/avro-confluent.md| 2 ++
docs/data/sql_connectors.yml| 4 +++-
3 files changed, 7 insertions(+), 1 deletion(-)
diff --git a/docs/content.zh/docs/connectors/table/formats/avro-confluent.md
b/docs/content.zh/docs/connectors/table/formats/avro-confluent.md
index 61248d1..ddb3c08 100644
--- a/docs/content.zh/docs/connectors/table/formats/avro-confluent.md
+++ b/docs/content.zh/docs/connectors/table/formats/avro-confluent.md
@@ -44,6 +44,8 @@ Avro Schema Registry 格式只能与 [Apache Kafka SQL 连接器]({{< ref
"docs/
{{< sql_download_table "avro-confluent" >}}
+For Maven, SBT, Gradle, or other build automation tools, please also ensure
that Confluent's maven repository at `https://packages.confluent.io/maven/` is
configured in your project's build files.
+
如何创建使用 Avro-Confluent 格式的表
diff --git a/docs/content/docs/connectors/table/formats/avro-confluent.md
b/docs/content/docs/connectors/table/formats/avro-confluent.md
index 7ab4c98..cf2fe70 100644
--- a/docs/content/docs/connectors/table/formats/avro-confluent.md
+++ b/docs/content/docs/connectors/table/formats/avro-confluent.md
@@ -42,6 +42,8 @@ Dependencies
{{< sql_download_table "avro-confluent" >}}
+For Maven, SBT, Gradle, or other build automation tools, please also ensure
that Confluent's maven repository at `https://packages.confluent.io/maven/` is
configured in your project's build files.
+
How to create tables with Avro-Confluent format
--
diff --git a/docs/data/sql_connectors.yml b/docs/data/sql_connectors.yml
index 31e68ee..003828f 100644
--- a/docs/data/sql_connectors.yml
+++ b/docs/data/sql_connectors.yml
@@ -44,7 +44,9 @@ avro:
avro-confluent:
name: Avro Schema Registry
-maven: flink-avro-confluent-registry
+maven:
+ - flink-avro-confluent-registry
+ - flink-avro
category: format
sql_url:
https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-avro-confluent-registry/$version/flink-sql-avro-confluent-registry-$version.jar
[flink] 01/03: [FLINK-25362][docs] allow SQL maven artifact list
This is an automated email from the ASF dual-hosted git repository.
nkruber pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit e9dba5e81f353fc6795b03add39a6d299e4c7aa5
Author: Nico Kruber
AuthorDate: Fri Dec 17 11:36:07 2021 +0100
[FLINK-25362][docs] allow SQL maven artifact list
If a connector needs more than one maven dependency, these can instead be
defined as a list/array now. The old syntax with a single string is also
still
possible.
---
docs/layouts/shortcodes/sql_download_table.html | 11 ---
1 file changed, 8 insertions(+), 3 deletions(-)
diff --git a/docs/layouts/shortcodes/sql_download_table.html
b/docs/layouts/shortcodes/sql_download_table.html
index 3c348c7e..0952e06 100644
--- a/docs/layouts/shortcodes/sql_download_table.html
+++ b/docs/layouts/shortcodes/sql_download_table.html
@@ -89,11 +89,16 @@ and SQL Client with SQL JAR bundles.
rendered documentation.
*/}}
{{ define "maven-artifact" }}{{/* (dict "ArtifactId" .ArtifactId */}}
-
+
+{{- $artifacts := cond (eq (printf "%T" .ArtifactId) "string") (slice
.ArtifactId) .ArtifactId -}}
+{{- range $artifact := $artifacts -}}
+
org.apache.flink
- {{- partial "docs/interpolate"
.ArtifactId -}}
+ {{- partial "docs/interpolate"
$artifact -}}
{{- site.Params.Version -}}
-
+
+{{- end -}}
+
Copied to clipboard!
