This is an automated email from the ASF dual-hosted git repository.
zjffdu pushed a commit to branch branch-0.10
in repository https://gitbox.apache.org/repos/asf/zeppelin.git
The following commit(s) were added to refs/heads/branch-0.10 by this push:
new 9333fb7 [ZEPPELIN-5506] Replace flink table config doc url
9333fb7 is described below
commit 9333fb7c77713c4aae2b3d514dae27122ac9545d
Author: Ada Wong <[email protected]>
AuthorDate: Thu Sep 2 21:03:11 2021 +0800
[ZEPPELIN-5506] Replace flink table config doc url
### What is this PR for?
Update Flink doc url in Exception message.
### What type of PR is it?
[Improvement]
### Todos
none
### What is the Jira issue?
https://issues.apache.org/jira/browse/ZEPPELIN-5506
[ZEPPELIN-5506]
### How should this be tested?
none
### Screenshots (if appropriate)
### Questions:
* Does the licenses files need update? no
* Is there breaking changes for older versions? no
* Does this needs documentation? no
Author: Ada Wong <[email protected]>
Closes #4213 from deadwind4/z-5506 and squashes the following commits:
b45f80af24 [Ada Wong] [ZEPPELIN-5506] Replace flink table config doc url
(cherry picked from commit 7ac3a0284dd718e155211af89501ec24700fe916)
Signed-off-by: Jeff Zhang <[email protected]>
---
.../src/main/java/org/apache/zeppelin/flink/FlinkSqlInterpreter.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/flink/flink-scala-parent/src/main/java/org/apache/zeppelin/flink/FlinkSqlInterpreter.java
b/flink/flink-scala-parent/src/main/java/org/apache/zeppelin/flink/FlinkSqlInterpreter.java
index 3fa27f7..7cb2241 100644
---
a/flink/flink-scala-parent/src/main/java/org/apache/zeppelin/flink/FlinkSqlInterpreter.java
+++
b/flink/flink-scala-parent/src/main/java/org/apache/zeppelin/flink/FlinkSqlInterpreter.java
@@ -61,7 +61,7 @@ public abstract class FlinkSqlInterpreter extends
AbstractInterpreter {
private int defaultSqlParallelism;
private ReentrantReadWriteLock.WriteLock lock = new
ReentrantReadWriteLock().writeLock();
// all the available sql config options. see
- //
https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/config.html
+ //
https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/table/config/
private Map<String, ConfigOption> tableConfigOptions;
public FlinkSqlInterpreter(Properties properties) {
@@ -523,7 +523,7 @@ public abstract class FlinkSqlInterpreter extends
AbstractInterpreter {
if (!tableConfigOptions.containsKey(key)) {
throw new IOException(key + " is not a valid table/sql config, please
check link: " +
-
"https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/config.html");
+
"https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/table/config/");
}
LOGGER.info("Set table config: {}={}", key, value);