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 <zjf...@gmail.com>
AuthorDate: Wed May 27 12:08:11 2020 +0800
Apply suggestions from code review
address comment
Co-authored-by: MarkSfik <47176197+marks...@users.noreply.github.com>
Co-authored-by: morsapaes <marta.paes.more...@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)
