[flink-web] 01/03: Rebuild website

[fhueske]

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 36c49b45c70261cdd53752f625641d1f540ca1f0
Author: Fabian Hueske 
AuthorDate: Fri Sep 13 09:48:30 2019 +0200

Rebuild website
---
 content/blog/feed.xml | 103 +++---
 content/downloads.html|   2 +-
 content/zh/downloads.html |   2 +-
 3 files changed, 99 insertions(+), 8 deletions(-)

diff --git a/content/blog/feed.xml b/content/blog/feed.xml
index a3f9991..2113d6f 100644
--- a/content/blog/feed.xml
+++ b/content/blog/feed.xml
@@ -7,6 +7,97 @@
 https://flink.apache.org/blog/feed.xml"; rel="self" 
type="application/rss+xml" />
 
 
+Apache Flink 1.8.2 Released
+
The Apache Flink community released the second bugfix 
version of the Apache Flink 1.8 series.
+
+
This release includes 23 fixes and minor improvements for Flink 
1.8.1. The list below includes a detailed list of all fixes and 
improvements.
+
+
We highly recommend all users to upgrade to Flink 1.8.2.
+
+
Updated Maven dependencies:
+
+
<dependency>
+  <groupId>org.apache.flink</groupId>
+  <artifactId>flink-java</artifactId>
+  <version>1.8.2</version>
+</dependency>
+<dependency>
+  <groupId>org.apache.flink</groupId>
+  <artifactId>flink-streaming-java_2.11</artifactId>
+  <version>1.8.2</version>
+</dependency>
+<dependency>
+  <groupId>org.apache.flink</groupId>
+  <artifactId>flink-clients_2.11</artifactId>
+  <version>1.8.2</version>
+</dependency>
+
+
You can find the binaries on the updated Downloads page.
+
+
List of resolved issues:
+
+
Bug
+
+

+
[FLINK-13941;]
 - Prevent data-loss by not cleaning up small part files from S3.
+
+
[FLINK-9526;]
 - BucketingSink end-to-end test failed on Travis
+
+
[FLINK-10368;]
 - 'Kerberized YARN on Docker test' unstable
+
+
[FLINK-12319;]
 - StackOverFlowError in cep.nfa.sharedbuffer.SharedBuffer
+
+
[FLINK-12736;]
 - ResourceManager may release TM with allocated slots
+
+
[FLINK-12889;]
 - Job keeps in FAILING state
+
+
[FLINK-13059;]
 - Cassandra Connector leaks Semaphore on Exception; hangs on close
+
+
[FLINK-13159;]
 - java.lang.ClassNotFoundException when restore job
+
+
[FLINK-13367;]
 - Make ClosureCleaner detect writeReplace serialization override
+
+
[FLINK-13369;]
 - Recursive closure cleaner ends up with stackOverflow in case of 
circular dependency
+
+
[FLINK-13394;]
 - Use fallback unsafe secure MapR in nightly.sh
+
+
[FLINK-13484;]
 - ConnectedComponents end-to-end test instable with 
NoResourceAvailableException
+
+
[FLINK-13499;]
 - Remove dependency on MapR artifact repository
+
+
[FLINK-13508;]
 - CommonTestUtils#waitUntilCondition() may attempt to sleep with 
negative time
+
+
[FLINK-13586;]
 - Method ClosureCleaner.clean broke backward compatibility between 
1.8.0 and 1.8.1
+<

[flink-web] 01/03: Rebuild website

[chesnay]

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

chesnay pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git

commit 80ae871143ff8ad817d564ad8dc2f5433771bd3d
Author: Dian Fu 
AuthorDate: Thu Dec 5 10:10:25 2019 +0800

Rebuild website
---
 content/blog/feed.xml | 419 ++
 1 file changed, 419 insertions(+)

diff --git a/content/blog/feed.xml b/content/blog/feed.xml
index 1410119..be37a00 100644
--- a/content/blog/feed.xml
+++ b/content/blog/feed.xml
@@ -7,6 +7,425 @@
 https://flink.apache.org/blog/feed.xml"; rel="self" 
type="application/rss+xml" />
 
 
+How to query Pulsar Streams using Apache Flink
+
In a previous story;
 on the  Flink blog, we explained the different ways that Apache Flink and Apache Pulsar can 
integrate to provide elastic data processing at large scale. This blog post 
discusses the new developments and integrations between the two fra [...]
+
+
A short intro to 
Apache Pulsar
+
+
Apache Pulsar is a flexible pub/sub messaging system, backed by 
durable log storage. Some of the framework’s highlights include multi-tenancy, 
a unified message model, structured event streams and a cloud-native 
architecture that make it a perfect fit for a wide set of use cases, ranging 
from billing, payments and trading services all the way to the unification of 
the different messaging architectures in an organization. If you are interested 
in finding out more about Pulsar, yo [...]
+
+
Existing 
Pulsar & Flink integration (Apache Flink 1.6+)
+
+
The existing integration between Pulsar and Flink exploits Pulsar as 
a message queue in a Flink application. Flink developers can utilize Pulsar as 
a streaming source and streaming sink for their Flink applications by selecting 
a specific Pulsar source and connecting to their desired Pulsar cluster and 
topic:
+
+
// create 
and configure Pulsar consumer
+PulsarSourceBuilder<String>builder = PulsarSourceBuilder  
+  .builder(new SimpleStringSchema()) 
+  .serviceUrl(serviceUrl)
+  .topic(inputTopic)
+  .subsciptionName(subscription);
+SourceFunction<String> src = builder.build// ingest DataStream with Pulsar 
consumer
+DataStream<String> words = env.addSource 
[...]
+
+
Pulsar streams can then get connected to the Flink processing 
logic…
+
+
// perform 
computation on DataStream (here a simple WordCount)
+DataStream<WordWithCount> wc = words
+  .flatmap((FlatMapFunction<String, WordWithCount>) collector.collect(new WordWithCount(word, 1})
+ 
+  .returns(WordWithCount