This is an automated email from the ASF dual-hosted git repository.
zjffdu pushed a commit to branch branch-0.9
in repository https://gitbox.apache.org/repos/asf/zeppelin.git
The following commit(s) were added to refs/heads/branch-0.9 by this push:
new 8758ce2 [ZEPPELIN-5229] - bump flink 1.10 minor version
8758ce2 is described below
commit 8758ce2bf1a80439f9ec14127dc7422da258d058
Author: OmriK <[email protected]>
AuthorDate: Thu Feb 11 09:50:08 2021 +0200
[ZEPPELIN-5229] - bump flink 1.10 minor version
### What is this PR for?
Bumping flink minor version, fixing minor flink doc typos
### What type of PR is it?
Improvement
### Todos
* [ ] - Task
### What is the Jira issue?
https://issues.apache.org/jira/browse/ZEPPELIN-5229
### How should this be tested?
Automation and builds
### 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: OmriK <[email protected]>
Closes #4052 from omrisk/ZEPPELIN-5229-upgrade-flink-version and squashes
the following commits:
7e883818d [OmriK] bump flink 1.10 minor version in integration tests
d86c374cb [OmriK] Minor readme fixes for flink docs
8bc7d7a18 [OmriK] bump flink 1.10 minor version
(cherry picked from commit 4a25272d822c6d2de09fbcb405e073f35dabf5be)
Signed-off-by: Jeff Zhang <[email protected]>
---
docs/interpreter/flink.md | 14 +++++++-------
flink/pom.xml | 2 +-
.../zeppelin/integration/FlinkIntegrationTest110.java | 2 +-
3 files changed, 9 insertions(+), 9 deletions(-)
diff --git a/docs/interpreter/flink.md b/docs/interpreter/flink.md
index 0d68f6e..dcfc625 100644
--- a/docs/interpreter/flink.md
+++ b/docs/interpreter/flink.md
@@ -26,8 +26,8 @@ limitations under the License.
## Overview
[Apache Flink](https://flink.apache.org) is an open source platform for
distributed stream and batch data processing. Flink’s core is a streaming
dataflow engine that provides data distribution, communication, and fault
tolerance for distributed computations over data streams. Flink also builds
batch processing on top of the streaming engine, overlaying native iteration
support, managed memory, and program optimization.
-In Zeppelin 0.9, we refactor the Flink interpreter in Zeppelin to support the
latest version of Flink. **Only Flink 1.10+ is supported, old version of flink
won't work.**
-Apache Flink is supported in Zeppelin with Flink interpreter group which
consists of below five interpreters.
+In Zeppelin 0.9, we refactor the Flink interpreter in Zeppelin to support the
latest version of Flink. **Only Flink 1.10+ is supported, old versions of flink
won't work.**
+Apache Flink is supported in Zeppelin with the Flink interpreter group which
consists of the five interpreters listed below.
<table class="table-configuration">
<tr>
@@ -251,7 +251,7 @@ And will create 6 variables as pyflink (`%flink.pyflink` or
`%flink.ipyflink`) e
## Blink/Flink Planner
-There're 2 planners supported by Flink's table api: `flink` & `blink`.
+There are 2 planners supported by Flink's table api: `flink` & `blink`.
* If you want to use DataSet api, and convert it to flink table then please
use flink planner (`btenv_2` and `stenv_2`).
* In other cases, we would always recommend you to use `blink` planner. This
is also what flink batch/streaming sql interpreter use (`%flink.bsql` &
`%flink.ssql`)
@@ -275,7 +275,7 @@ because by default it is only 4 TM with 1 Slots which may
not be enough for some
### Run Flink in Remote Mode
-Running Flink in remote mode will connect to a existing flink cluster which
could be standalone cluster or yarn session cluster. Besides specifying
`flink.execution.mode` to be `remote`. You also need to specify
+Running Flink in remote mode will connect to an existing flink cluster which
could be standalone cluster or yarn session cluster. Besides specifying
`flink.execution.mode` to be `remote`. You also need to specify
`flink.execution.remote.host` and `flink.execution.remote.port` to point to
flink job manager.
### Run Flink in Yarn Mode
@@ -377,8 +377,8 @@ bt_env.register_function("python_upper", udf(PythonUpper(),
DataTypes.STRING(),
```
-Zeppelin only supports scala and python for flink interpreter, if you want to
write java udf or the udf is pretty complicated which make it not suitable to
write in Zeppelin,
-then you can write the udf in IDE and build a udf jar.
+Zeppelin only supports scala and python for flink interpreter, if you want to
write a java udf or the udf is pretty complicated which make it not suitable to
write in Zeppelin,
+then you can write the udf in IDE and build an udf jar.
In Zeppelin you just need to specify `flink.udf.jars` to this jar, and flink
interpreter will detect all the udfs in this jar and register all the udfs to
TableEnvironment, the udf name is the class name.
@@ -485,7 +485,7 @@ In this section, we will list and explain all the supported
local properties in
## Tutorial Notes
-Zeppelin is shipped with several Flink tutorial notes which may be helpful for
you. You check more features in the tutorial notes.
+Zeppelin is shipped with several Flink tutorial notes which may be helpful for
you. You can check for more features in the tutorial notes.
diff --git a/flink/pom.xml b/flink/pom.xml
index 8dcf666..32460fc 100644
--- a/flink/pom.xml
+++ b/flink/pom.xml
@@ -43,7 +43,7 @@
</modules>
<properties>
- <flink1.10.version>1.10.2</flink1.10.version>
+ <flink1.10.version>1.10.3</flink1.10.version>
<flink1.11.version>1.11.3</flink1.11.version>
<flink1.12.version>1.12.0</flink1.12.version>
</properties>
diff --git
a/zeppelin-interpreter-integration/src/test/java/org/apache/zeppelin/integration/FlinkIntegrationTest110.java
b/zeppelin-interpreter-integration/src/test/java/org/apache/zeppelin/integration/FlinkIntegrationTest110.java
index 7779d2f..ab68068 100644
---
a/zeppelin-interpreter-integration/src/test/java/org/apache/zeppelin/integration/FlinkIntegrationTest110.java
+++
b/zeppelin-interpreter-integration/src/test/java/org/apache/zeppelin/integration/FlinkIntegrationTest110.java
@@ -29,7 +29,7 @@ public class FlinkIntegrationTest110 extends
FlinkIntegrationTest {
@Parameterized.Parameters
public static List<Object[]> data() {
return Arrays.asList(new Object[][]{
- {"1.10.2"}
+ {"1.10.3"}
});
}
