[zeppelin] branch master updated: [ZEPPELIN-5506] Replace flink table config doc url

[zj...@apache.org]

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

zjffdu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/zeppelin.git


The following commit(s) were added to refs/heads/master by this push:
     new 7ac3a02  [ZEPPELIN-5506] Replace flink table config doc url
7ac3a02 is described below

commit 7ac3a0284dd718e155211af89501ec24700fe916
Author: Ada Wong <wu...@dtstack.com>
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 <wu...@dtstack.com>
    
    Closes #4213 from deadwind4/z-5506 and squashes the following commits:
    
    b45f80af24 [Ada Wong] [ZEPPELIN-5506] Replace flink table config doc url
---
 .../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);