You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fh...@apache.org on 2020/06/15 14:20:29 UTC
[flink-web] 02/04: Apply suggestions from code review
This is an automated email from the ASF dual-hosted git repository.
fhueske pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git
commit ff4ccf3054aa4bf07b906740222c67db150dda90
Author: Jeff Zhang <zj...@gmail.com>
AuthorDate: Wed May 27 12:08:11 2020 +0800
Apply suggestions from code review
address comment
Co-authored-by: MarkSfik <47...@users.noreply.github.com>
Co-authored-by: morsapaes <ma...@gmail.com>
---
_posts/2020-05-25-flink-on-zeppelin.md | 24 ++++++++++++++----------
1 file changed, 14 insertions(+), 10 deletions(-)
diff --git a/_posts/2020-05-25-flink-on-zeppelin.md b/_posts/2020-05-25-flink-on-zeppelin.md
index 080a74b..b965fe4 100644
--- a/_posts/2020-05-25-flink-on-zeppelin.md
+++ b/_posts/2020-05-25-flink-on-zeppelin.md
@@ -9,8 +9,8 @@ authors:
twitter: "zjffdu"
---
-The latest release of Apache Zeppelin comes with a redesigned interpreter for Apache Flink (version Flink 1.10+ is only supported moving forward)
-that allows developers and data engineers to use Flink directly on Zeppelin notebooks for interactive data analysis. In this post, we explain how the Flink interpreter in Zeppelin works,
+The latest release of [Apache Zeppelin](https://zeppelin.apache.org/) comes with a redesigned interpreter for Apache Flink (version Flink 1.10+ is only supported moving forward)
+that allows developers to use Flink directly on Zeppelin notebooks for interactive data analysis. In this post, we explain how the Flink interpreter in Zeppelin works,
and provide a tutorial for running Streaming ETL with Flink on Zeppelin.
# The Flink Interpreter in Zeppelin 0.9
@@ -23,16 +23,17 @@ Zeppelin 0.9 now comes with the Flink interpreter group, consisting of the below
* %flink - Provides a Scala environment
* %flink.pyflink - Provides a python environment
* %flink.ipyflink - Provides an ipython environment
-* %flink.bsql - Provides a stream sql environment
-* %flink.ssql - Provides a batch sql environment
+* %flink.ssql - Provides a stream sql environment
+* %flink.bsql - Provides a batch sql environment
Not only has the interpreter been extended to support writing Flink applications in three languages, but it has also extended the available execution modes for Flink that now include:
+
* Running Flink in Local Mode
* Running Flink in Remote Mode
* Running Flink in Yarn Mode
-You can find more information about how to get started with Zeppelin and all the execution modes for Flink applications in Zeppelin notebooks in this post.
+You can find more information about how to get started with Zeppelin and all the execution modes for Flink applications in [Zeppelin notebooks](https://github.com/apache/zeppelin/tree/master/notebook/Flink%20Tutorial) in this post.
# Flink on Zeppelin for Stream processing
@@ -42,7 +43,7 @@ such as streaming ETL and real time data analytics, with the use of Flink SQL an
Below we showcase how you can execute streaming ETL using Flink on Zeppelin:
You can use Flink SQL to perform streaming ETL by following the steps below
-(for the full tutorial, please refer to the Flink Tutorial/Streaming ETL tutorial of the Zeppelin distribution):
+(for the full tutorial, please refer to the [Flink Tutorial/Streaming ETL tutorial](https://github.com/apache/zeppelin/blob/master/notebook/Flink%20Tutorial/4.%20Streaming%20ETL_2EYD56B9B.zpln) of the Zeppelin distribution):
* Step 1. Create source table to represent the source data.
@@ -56,13 +57,13 @@ You can use Flink SQL to perform streaming ETL by following the steps below
<img src="{{ site.baseurl }}/img/blog/2020-05-25-flink-on-zeppelin/create_sink.png" width="80%" alt="Create Sink Table"/>
</center>
-* Step 3. After creating the source and sink table, we can use insert them to our statement to trigger the streaming processing job as the following:
+* Step 3. After creating the source and sink table, we can insert them to our statement to trigger the stream processing job as the following:
<center>
<img src="{{ site.baseurl }}/img/blog/2020-05-25-flink-on-zeppelin/etl.png" width="80%" alt="ETL"/>
</center>
-* Step 4. After initiating the streaming job, you can use another SQL statement to query the sink table to verify your streaming job. Here you can see the top 10 records which will be refreshed every 3 seconds.
+* Step 4. After initiating the streaming job, you can use another SQL statement to query the sink table to verify the results of your job. Here you can see the top 10 records which will be refreshed every 3 seconds.
<center>
<img src="{{ site.baseurl }}/img/blog/2020-05-25-flink-on-zeppelin/preview.png" width="80%" alt="Preview"/>
@@ -71,8 +72,10 @@ You can use Flink SQL to perform streaming ETL by following the steps below
# Summary
In this post, we explained how the redesigned Flink interpreter works in Zeppelin 0.9.0 and provided some examples for performing streaming ETL jobs with
-Flink and Zeppelin. You can find additional tutorial for batch processing with Flink on Zeppelin as well as using Flink on Zeppelin for
-more advance operations like resource isolation, job concurrency & parallelism, multiple Hadoop & Hive environments and more on our series of post on Medium.
+Flink and Zeppelin. You can find an additional [tutorial for batch processing with Flink on Zeppelin](https://medium.com/@zjffdu/flink-on-zeppelin-part-2-batch-711731df5ad9) as well as using Flink on Zeppelin for
+more advance operations like resource isolation, job concurrency & parallelism, multiple Hadoop & Hive environments and more on our series of posts on Medium.
+And here's a list of [Flink on Zeppelin tutorial videos](https://www.youtube.com/watch?v=YxPo0Fosjjg&list=PL4oy12nnS7FFtg3KV1iS5vDb0pTz12VcX) for your reference.
+
# References
@@ -81,3 +84,4 @@ more advance operations like resource isolation, job concurrency & parallelism,
* Flink on Zeppelin tutorials - [Part 2](https://medium.com/@zjffdu/flink-on-zeppelin-part-2-batch-711731df5ad9)
* Flink on Zeppelin tutorials - [Part 3](https://medium.com/@zjffdu/flink-on-zeppelin-part-3-streaming-5fca1e16754)
* Flink on Zeppelin tutorials - [Part 4](https://medium.com/@zjffdu/flink-on-zeppelin-part-4-advanced-usage-998b74908cd9)
+* [Flink on Zeppelin tutorial videos](https://www.youtube.com/watch?v=YxPo0Fosjjg&list=PL4oy12nnS7FFtg3KV1iS5vDb0pTz12VcX)