date:20190906

Build failed in Jenkins: flink-snapshot-deployment-1.7 #302

2019-09-06 Thread Apache Jenkins Server

See 


--
[...truncated 424.24 KB...]
[INFO] Excluding org.objenesis:objenesis:jar:2.1 from the shaded jar.
[INFO] No artifact matching filter io.netty:netty
[INFO] Replacing original artifact with shaded artifact.
[INFO] Replacing 

 with 

[INFO] Replacing original test artifact with shaded test artifact.
[INFO] Replacing 

 with 

[INFO] Dependency-reduced POM written at: 

[INFO] 
[INFO] >>> maven-source-plugin:2.2.1:jar (attach-sources) > generate-sources @ 
flink-scala_2.11 >>>
[INFO] 
[INFO] --- maven-checkstyle-plugin:2.17:check (validate) @ flink-scala_2.11 ---
[INFO] 
[INFO] --- maven-enforcer-plugin:3.0.0-M1:enforce (enforce-maven-version) @ 
flink-scala_2.11 ---
[INFO] 
[INFO] --- maven-enforcer-plugin:3.0.0-M1:enforce (enforce-maven) @ 
flink-scala_2.11 ---
[INFO] 
[INFO] --- maven-enforcer-plugin:3.0.0-M1:enforce (enforce-versions) @ 
flink-scala_2.11 ---
[INFO] 
[INFO] --- directory-maven-plugin:0.1:highest-basedir (directories) @ 
flink-scala_2.11 ---
[INFO] Highest basedir set to: 

[INFO] 
[INFO] --- build-helper-maven-plugin:1.7:add-source (add-source) @ 
flink-scala_2.11 ---
[INFO] Source directory: 

 added.
[INFO] 
[INFO] <<< maven-source-plugin:2.2.1:jar (attach-sources) < generate-sources @ 
flink-scala_2.11 <<<
[INFO] 
[INFO] --- maven-source-plugin:2.2.1:jar (attach-sources) @ flink-scala_2.11 ---
[INFO] Building jar: 

[INFO] 
[INFO] --- maven-javadoc-plugin:2.9.1:jar (attach-javadocs) @ flink-scala_2.11 
---
[INFO] Building jar: 

[INFO] 
[INFO] --- maven-surefire-plugin:2.18.1:test (integration-tests) @ 
flink-scala_2.11 ---
[INFO] Tests are skipped.
[INFO] 
[INFO] --- scalastyle-maven-plugin:1.0.0:check (default) @ flink-scala_2.11 ---
Saving to 
outputFile=
Processed 103 file(s)
Found 0 errors
Found 0 warnings
Found 0 infos
Finished in 1864 ms
[INFO] 
[INFO] --- japicmp-maven-plugin:0.11.0:cmp (default) @ flink-scala_2.11 ---
[INFO] Written file 
'
[INFO] Written file 
'
[INFO] Written file 
'
[INFO] 
[INFO] --- maven-install-plugin:2.5.2:install (default-install) @ 
flink-scala_2.11 ---
[INFO] Installing 

 to 
/home/jenkins/.m2/repository/org/apache/flink/flink-scala_2.11/1.7-SNAPSHOT/flink-scala_2.11-1.7-SNAPSHOT.jar
[INFO] Installing 

 to 
/home/jenkins/.m2/repository/org/apache/flink/flink-scala_2.11/1.7-SNAPSHOT/flink-scala_2.11-1.7-SNAPSHOT.pom
[INFO] Installing 

 to 
/home/jenkins/.m2/repository/org/apache/flink/flink-scala_2.11/1.7-SNAPSHOT/flink-scala_2.11-1.7-SNAPSHOT-tests.jar
[INFO] Installing 

 to 
/home/jenkins/.m2/repository/org/apache/flink/flink-scala_2.11/1.7-SNAPSHOT/flink-scala_2.11-1.7-SNAPSHOT-tests.jar
[INFO] Installing 

 to 
/home/jenkins/.m2/repository/org/apache/flink/flink-scala_2.11/1.7-SNAPSHOT/flink-scala_2.11-1.7-SNAPSHOT-sources.jar
[INFO] Installing

[flink] branch master updated: [hotfix] Fix NOTICE-binary.

2019-09-06 Thread fhueske

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

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


The following commit(s) were added to refs/heads/master by this push:
 new 2880c98  [hotfix] Fix NOTICE-binary.
2880c98 is described below

commit 2880c9829fcc9a9c17b932c7e8daff9d255c025a
Author: Fabian Hueske 
AuthorDate: Fri Sep 6 16:28:07 2019 +0200

[hotfix] Fix NOTICE-binary.
---
 NOTICE-binary | 277 +++---
 1 file changed, 130 insertions(+), 147 deletions(-)

diff --git a/NOTICE-binary b/NOTICE-binary
index 24a61db..f37ba47 100644
--- a/NOTICE-binary
+++ b/NOTICE-binary
@@ -108,18 +108,6 @@ This project bundles the following dependencies under the 
Apache Software Licens
 - org.eclipse.jetty:jetty-util:9.3.19.v20170502
 - org.eclipse.jetty:jetty-util-ajax:9.3.19.v20170502
 
-Apache Commons Lang
-Copyright 2001-2014 The Apache Software Foundation
-
-This product includes software from the Spring Framework,
-under the Apache License 2.0 (see: StringUtils.containsWhitespace())
-
-Apache Commons Collections
-Copyright 2001-2015 The Apache Software Foundation
-
-This product includes software developed by
-The Apache Software Foundation (http://www.apache.org/).
-
 
 flink-hadoop-fs
 Copyright 2014-2019 The Apache Software Foundation
@@ -3113,6 +3101,12 @@ which has the following notices:
 Apache Commons IO
 Copyright 2002-2012 The Apache Software Foundation
 
+This product includes software developed by
+The Apache Software Foundation (http://www.apache.org/).
+
+Apache Commons Collections
+Copyright 2001-2015 The Apache Software Foundation
+
 Apache Commons Logging
 Copyright 2003-2013 The Apache Software Foundation
 
@@ -3125,6 +3119,12 @@ Copyright 2000-2016 The Apache Software Foundation
 Apache Commons Configuration
 Copyright 2001-2017 The Apache Software Foundation
 
+Apache Commons Lang
+Copyright 2001-2014 The Apache Software Foundation
+
+This product includes software from the Spring Framework,
+under the Apache License 2.0 (see: StringUtils.containsWhitespace())
+
 htrace-core4
 Copyright 2016 The Apache Software Foundation
 
@@ -3449,113 +3449,6 @@ FasterXML.com (http://fasterxml.com).
 Apache Commons CLI
 Copyright 2001-2015 The Apache Software Foundation
 
-The Netty Project
-=
-
-Please visit the Netty web site for more information:
-
-  * http://netty.io/
-
-Copyright 2011 The Netty Project
-
-The Netty Project licenses this file to you under the Apache License,
-version 2.0 (the "License"); you may not use this file except in compliance
-with the License. You may obtain a copy of the License at:
-
-http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing, software
-distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
-WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
-License for the specific language governing permissions and limitations
-under the License.
-
-Also, please refer to each LICENSE..txt file, which is located in
-the 'license' directory of the distribution file, for the license terms of the
-components that this product depends on.
-

-This product contains the extensions to Java Collections Framework which has
-been derived from the works by JSR-166 EG, Doug Lea, and Jason T. Greene:
-
-  * LICENSE:
-* license/LICENSE.jsr166y.txt (Public Domain)
-  * HOMEPAGE:
-* http://gee.cs.oswego.edu/cgi-bin/viewcvs.cgi/jsr166/
-* 
http://viewvc.jboss.org/cgi-bin/viewvc.cgi/jbosscache/experimental/jsr166/
-
-  * LICENSE:
-* license/LICENSE.base64.txt (Public Domain)
-  * HOMEPAGE:
-* http://iharder.sourceforge.net/current/java/base64/
-
-  * LICENSE:
-* license/LICENSE.jzlib.txt (BSD Style License)
-  * HOMEPAGE:
-* http://www.jcraft.com/jzlib/
-
-  * LICENSE:
-* license/LICENSE.webbit.txt (BSD License)
-  * HOMEPAGE:
-* https://github.com/joewalnes/webbit
-
-This product optionally depends on 'Protocol Buffers', Google's data
-interchange format, which can be obtained at:
-
-  * LICENSE:
-* license/LICENSE.protobuf.txt (New BSD License)
-  * HOMEPAGE:
-* http://code.google.com/p/protobuf/
-
-This product optionally depends on 'Bouncy Castle Crypto APIs' to generate
-a temporary self-signed X.509 certificate when the JVM does not provide the
-equivalent functionality.  It can be obtained at:
-
-  * LICENSE:
-* license/LICENSE.bouncycastle.txt (MIT License)
-  * HOMEPAGE:
-* http://www.bouncycastle.org/
-
-This product optionally depends on 'SLF4J', a simple logging facade for Java,
-which can be obtained at:
-
-  * LICENSE:
-* license/LICENSE.slf4j.txt (MIT License)
-  * HOMEPAGE:
-* http://www.slf4j.org/
-
-This product optionally depends on 'Apache Commons

[flink] branch master updated (fe84fc5 -> 7c0f4a3)

2019-09-06 Thread chesnay

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

chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


from fe84fc5  [FLINK-13625][Tests] Update 
StatefulJobSavepointMigrationITCase to restore from 1.9 savepoint
 add 7c0f4a3  [FLINK-13934][rest] Use hamcrest for checking String contents

No new revisions were added by this update.

Summary of changes:
 .../history/HistoryServerStaticFileServerHandlerTest.java   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

[flink] branch master updated (2bae85e -> fe84fc5)

2019-09-06 Thread trohrmann

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

trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


from 2bae85e  [FLINK-13624][Tests] Update 
StatefulJobWBroadcastStateMigrationITCase to restore from 1.9 savepoint
 add fe84fc5  [FLINK-13625][Tests] Update 
StatefulJobSavepointMigrationITCase to restore from 1.9 savepoint

No new revisions were added by this update.

Summary of changes:
 .../StatefulJobWBroadcastStateMigrationITCase.java  |   4 +++-
 .../_metadata   | Bin 9470 -> 9470 bytes
 .../_metadata   | Bin 14070 -> 14070 bytes
 3 files changed, 3 insertions(+), 1 deletion(-)
 copy 
flink-tests/src/test/resources/{new-stateful-broadcast-udf-migration-itcase-flink1.8-rocksdb-savepoint
 => 
new-stateful-broadcast-udf-migration-itcase-flink1.9-rocksdb-savepoint}/_metadata
 (71%)
 copy 
flink-tests/src/test/resources/{new-stateful-broadcast-udf-migration-itcase-flink1.8-savepoint
 => new-stateful-broadcast-udf-migration-itcase-flink1.9-savepoint}/_metadata 
(83%)

[flink] branch master updated: [FLINK-13624][Tests] Update StatefulJobWBroadcastStateMigrationITCase to restore from 1.9 savepoint

2019-09-06 Thread trohrmann

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

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


The following commit(s) were added to refs/heads/master by this push:
 new 2bae85e  [FLINK-13624][Tests] Update 
StatefulJobWBroadcastStateMigrationITCase to restore from 1.9 savepoint
2bae85e is described below

commit 2bae85ed34a04c15a235a700de4649024dcf61d9
Author: yanghua 
AuthorDate: Thu Sep 5 16:02:20 2019 +0800

[FLINK-13624][Tests] Update StatefulJobWBroadcastStateMigrationITCase to 
restore from 1.9 savepoint

This closes #9626.
---
 .../_metadata   | Bin 0 -> 51942 bytes
 .../_metadata   | Bin 0 -> 51942 bytes
 .../StatefulJobWBroadcastStateMigrationITCase.scala |   6 --
 3 files changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.9-jobmanager-savepoint/_metadata
 
b/flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.9-jobmanager-savepoint/_metadata
new file mode 100644
index 000..8ffcb37
Binary files /dev/null and 
b/flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.9-jobmanager-savepoint/_metadata
 differ
diff --git 
a/flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.9-rocksdb-savepoint/_metadata
 
b/flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.9-rocksdb-savepoint/_metadata
new file mode 100644
index 000..5f20171
Binary files /dev/null and 
b/flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.9-rocksdb-savepoint/_metadata
 differ
diff --git 
a/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobWBroadcastStateMigrationITCase.scala
 
b/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobWBroadcastStateMigrationITCase.scala
index 822ff9a..4acfa78 100644
--- 
a/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobWBroadcastStateMigrationITCase.scala
+++ 
b/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobWBroadcastStateMigrationITCase.scala
@@ -60,14 +60,16 @@ object StatefulJobWBroadcastStateMigrationITCase {
   (MigrationVersion.v1_7, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
   (MigrationVersion.v1_7, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
   (MigrationVersion.v1_8, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
-  (MigrationVersion.v1_8, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME))
+  (MigrationVersion.v1_8, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
+  (MigrationVersion.v1_9, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
+  (MigrationVersion.v1_9, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME))
   }
 
   // TODO to generate savepoints for a specific Flink version / backend type,
   // TODO change these values accordingly, e.g. to generate for 1.3 with 
RocksDB,
   // TODO set as (MigrationVersion.v1_3, 
StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME)
   // TODO Note: You should generate the savepoint based on the release branch 
instead of the master.
-  val GENERATE_SAVEPOINT_VER: MigrationVersion = MigrationVersion.v1_8
+  val GENERATE_SAVEPOINT_VER: MigrationVersion = MigrationVersion.v1_9
   val GENERATE_SAVEPOINT_BACKEND_TYPE: String = 
StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME
 
   val NUM_ELEMENTS = 4

[flink] branch master updated (bee0967 -> b28f445)

2019-09-06 Thread trohrmann

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

trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


from bee0967  [FLINK-13621][Tests] Update 
ContinuousFileProcessingMigrationTest to restore from 1.9 savepoint
 add b28f445  [FLINK-13623][Tests] Update 
StatefulJobSavepointMigrationITCase to restore from 1.9 savepoint

No new revisions were added by this update.

Summary of changes:
 .../_metadata   | Bin 0 -> 40081 bytes
 .../_metadata   | Bin 0 -> 40081 bytes
 .../migration/StatefulJobSavepointMigrationITCase.scala |   8 +---
 3 files changed, 5 insertions(+), 3 deletions(-)
 create mode 100644 
flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.9-jobmanager-savepoint/_metadata
 create mode 100644 
flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.9-rocksdb-savepoint/_metadata

[flink] branch master updated (dc9e449 -> bee0967)

2019-09-06 Thread trohrmann

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

trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


from dc9e449  [hotfix] Undo removal of ClusterClient#shutdown() for 
backwards compatibility.
 add bee0967  [FLINK-13621][Tests] Update 
ContinuousFileProcessingMigrationTest to restore from 1.9 savepoint

No new revisions were added by this update.

Summary of changes:
 .../ContinuousFileProcessingMigrationTest.java|   3 ++-
 ...ion-migration-test-1567499868000-flink1.9-snapshot | Bin 0 -> 316 bytes
 ...apshot => reader-migration-test-flink1.9-snapshot} | Bin 2614 -> 2614 bytes
 3 files changed, 2 insertions(+), 1 deletion(-)
 create mode 100644 
flink-fs-tests/src/test/resources/monitoring-function-migration-test-1567499868000-flink1.9-snapshot
 copy 
flink-fs-tests/src/test/resources/{reader-migration-test-flink1.8-snapshot => 
reader-migration-test-flink1.9-snapshot} (96%)

[flink] branch master updated (2c38a9b -> dc9e449)

2019-09-06 Thread kkloudas

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

kkloudas pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


from 2c38a9b  [FLINK-13946] Remove taskManagerNumSlots and 
defaultOverwriteFiles from LocalExecutor
 add dc9e449  [hotfix] Undo removal of ClusterClient#shutdown() for 
backwards compatibility.

No new revisions were added by this update.

Summary of changes:
 .../main/java/org/apache/flink/client/program/ClusterClient.java  | 8 
 1 file changed, 8 insertions(+)

[flink] branch master updated (6e80a83 -> 2c38a9b)

2019-09-06 Thread kkloudas

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

kkloudas pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


from 6e80a83  [FLINK-13990][coordination] Remove legacy exceptions
 add 790fe27  [FLINK-13946] Remove session-related code from execution env
 add 9753614  [FLINK-13946] Remove session-related code from the 
PlanExecutors
 add c746cbb  [FLINK-13946] Refactor executor code to ban resource sharing 
between plan executions.
 add 80fa99d  [FLINK-13946] Remove unused constructors from RemoteExecutor
 add e8650cd  [FLINK-13946] Make the ClusterClient autocloseable
 add 2c38a9b  [FLINK-13946] Remove taskManagerNumSlots and 
defaultOverwriteFiles from LocalExecutor

No new revisions were added by this update.

Summary of changes:
 .../org/apache/flink/client/LocalExecutor.java | 176 +
 .../org/apache/flink/client/RemoteExecutor.java| 105 +---
 .../org/apache/flink/client/cli/CliFrontend.java   |   6 +-
 .../apache/flink/client/program/ClusterClient.java |  12 +-
 .../flink/client/program/ContextEnvironment.java   |   9 +-
 .../client/program/OptimizerPlanEnvironment.java   |   5 -
 .../client/program/PreviewPlanEnvironment.java |   4 -
 .../client/program/rest/RestClusterClient.java |   8 +-
 .../flink/client/cli/CliFrontendSavepointTest.java |  12 +-
 .../client/program/rest/RestClusterClientTest.java |  18 +--
 .../org/apache/flink/api/common/PlanExecutor.java  |  32 +---
 .../flink/api/java/CollectionEnvironment.java  |   4 -
 .../flink/api/java/ExecutionEnvironment.java   |  72 +
 .../apache/flink/api/java/LocalEnvironment.java| 151 ++
 .../apache/flink/api/java/RemoteEnvironment.java   |  97 +---
 .../api/java/ScalaShellRemoteEnvironment.java  |  30 ++--
 .../org/apache/flink/api/scala/FlinkShell.scala|   2 +-
 .../org/apache/flink/api/java/FlinkILoopTest.java  |  15 --
 .../flink/api/scala/ExecutionEnvironment.scala |  50 +-
 .../api/environment/RemoteStreamEnvironment.java   |   2 +-
 .../table/client/gateway/local/LocalExecutor.java  |   2 +-
 .../client/gateway/local/ProgramDeployer.java  |   4 +-
 .../test/util/MiniClusterWithClientResource.java   |   2 +-
 .../apache/flink/test/util/TestEnvironment.java|   4 -
 .../test/example/client/JobRetrievalITCase.java|   2 +-
 .../test/example/client/LocalExecutorITCase.java   |  12 +-
 .../jsonplan/JsonJobGraphGenerationTest.java   |   4 -
 .../recovery/ProcessFailureCancelingITCase.java|   2 +-
 .../runtime/BigUserProgramJobSubmitITCase.java |   2 +-
 .../flink/yarn/YARNHighAvailabilityITCase.java |   4 +-
 .../java/org/apache/flink/yarn/YARNITCase.java |   2 +-
 .../apache/flink/yarn/YarnConfigurationITCase.java |   2 +-
 .../apache/flink/yarn/cli/FlinkYarnSessionCli.java |   4 +-
 33 files changed, 134 insertions(+), 722 deletions(-)

[flink] branch master updated (c6bd03c -> 6e80a83)

2019-09-06 Thread chesnay

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

chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


from c6bd03c  [FLINK-13988][coordination] Remove legacy JobManagerCliOptions
 add 6e80a83  [FLINK-13990][coordination] Remove legacy exceptions

No new revisions were added by this update.

Summary of changes:
 .../jobmaster/exceptions/JobMasterException.java   | 41 --
 .../exceptions/JobModificationException.java   | 39 
 2 files changed, 80 deletions(-)
 delete mode 100644 
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/exceptions/JobMasterException.java
 delete mode 100644 
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/exceptions/JobModificationException.java

[flink] branch master updated (20b6674 -> c6bd03c)

2019-09-06 Thread chesnay

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

chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


from 20b6674  [FLINK-13989][coordination] Remove legacy ClassloadingProps
 add c6bd03c  [FLINK-13988][coordination] Remove legacy JobManagerCliOptions

No new revisions were added by this update.

Summary of changes:
 .../runtime/jobmanager/JobManagerCliOptions.java   | 78 --
 .../flink/runtime/jobmanager/JobManagerMode.java   | 37 --
 2 files changed, 115 deletions(-)
 delete mode 100644 
flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/JobManagerCliOptions.java
 delete mode 100644 
flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/JobManagerMode.java

[flink] branch release-1.9 updated: [FLINK-13942][docs] Add "Getting Started" overview page.

2019-09-06 Thread fhueske

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

fhueske pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.9 by this push:
 new fcdad72  [FLINK-13942][docs] Add "Getting Started" overview page.
fcdad72 is described below

commit fcdad7265866b5f5b44bb09f7b036e1540f7e27f
Author: Fabian Hueske 
AuthorDate: Tue Sep 3 09:54:30 2019 +0200

[FLINK-13942][docs] Add "Getting Started" overview page.

[ci skip]
---
 docs/getting-started/index.md| 30 ++
 docs/getting-started/index.zh.md | 30 ++
 2 files changed, 60 insertions(+)

diff --git a/docs/getting-started/index.md b/docs/getting-started/index.md
index bd80898..901e48c 100644
--- a/docs/getting-started/index.md
+++ b/docs/getting-started/index.md
@@ -4,6 +4,7 @@ nav-id: getting-started
 nav-title: ' 
Getting Started'
 nav-parent_id: root
 section-break: true
+nav-show_overview: true
 nav-pos: 1
 ---
 
+
+There are many ways to get started with Apache Flink. Which one is the best 
for you depends on your goal and prior experience.
+
+### Taking a first look at Flink
+
+The **Docker Playgrounds** provide sandboxed Flink environments that are set 
up in just a few minutes and which allow you to explore and play with Flink.
+
+* The [**Operations 
Playground**](./docker-playgrounds/flink-operations-playground.html) shows you 
how to operate streaming applications with Flink. You can experience how Flink 
recovers application from failures, upgrade and scale streaming applications up 
and down, and query application metrics.
+
+
+
+### First steps with one of Flink's APIs
+
+The **API Tutorials** are the best way to get started and introduce you step 
by step to an API.
+A tutorial provides instructions to bootstrap a small Flink project with a 
code skeleton and shows how to extend it to a simple application.
+
+* The [**DataStream API**](./tutorials/datastream_api.html) tutorial shows how 
to implement a basic DataStream application. The DataStream API is Flink's main 
abstraction to implement stateful streaming applications with sophisticated 
time semantics in Java or Scala.
+
+
diff --git a/docs/getting-started/index.zh.md b/docs/getting-started/index.zh.md
index bd80898..901e48c 100644
--- a/docs/getting-started/index.zh.md
+++ b/docs/getting-started/index.zh.md
@@ -4,6 +4,7 @@ nav-id: getting-started
 nav-title: ' 
Getting Started'
 nav-parent_id: root
 section-break: true
+nav-show_overview: true
 nav-pos: 1
 ---
 
+
+There are many ways to get started with Apache Flink. Which one is the best 
for you depends on your goal and prior experience.
+
+### Taking a first look at Flink
+
+The **Docker Playgrounds** provide sandboxed Flink environments that are set 
up in just a few minutes and which allow you to explore and play with Flink.
+
+* The [**Operations 
Playground**](./docker-playgrounds/flink-operations-playground.html) shows you 
how to operate streaming applications with Flink. You can experience how Flink 
recovers application from failures, upgrade and scale streaming applications up 
and down, and query application metrics.
+
+
+
+### First steps with one of Flink's APIs
+
+The **API Tutorials** are the best way to get started and introduce you step 
by step to an API.
+A tutorial provides instructions to bootstrap a small Flink project with a 
code skeleton and shows how to extend it to a simple application.
+
+* The [**DataStream API**](./tutorials/datastream_api.html) tutorial shows how 
to implement a basic DataStream application. The DataStream API is Flink's main 
abstraction to implement stateful streaming applications with sophisticated 
time semantics in Java or Scala.
+
+

[flink] branch release-1.8 updated: [hotfix][travis] Add detailed instructions for update binary licensing

2019-09-06 Thread chesnay

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

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


The following commit(s) were added to refs/heads/release-1.8 by this push:
 new 7de0568  [hotfix][travis] Add detailed instructions for update binary 
licensing
7de0568 is described below

commit 7de05686ac33f5b40dd9bb7018f527caf66a1127
Author: Chesnay Schepler 
AuthorDate: Fri Sep 6 14:56:03 2019 +0200

[hotfix][travis] Add detailed instructions for update binary licensing
---
 tools/travis_controller.sh | 11 +--
 1 file changed, 9 insertions(+), 2 deletions(-)

diff --git a/tools/travis_controller.sh b/tools/travis_controller.sh
index f27e408..6996484 100755
--- a/tools/travis_controller.sh
+++ b/tools/travis_controller.sh
@@ -105,8 +105,15 @@ if [ $STAGE == "$STAGE_COMPILE" ]; then
 if [ $EXIT_CODE != 0 ]; then
   echo 
"=="
   echo "ERROR: binary licensing is out-of-date."
-  echo "Please update NOTICE-binary and licenses-binary using"
-  echo "'tools/releasing/collect_license_files.sh'."
+  echo "Please update NOTICE-binary and licenses-binary:"
+  echo "Step 1: Rebuild flink"
+  echo "Step 2: Run 'tools/releasing/collect_license_files.sh 
build-target'"
+  echo "  This extracts all the licensing files from the distribution, 
and puts them in 'licenses-output'."
+  echo "  If the build-target symlink does not exist after building 
flink, point the tool to 
'flink-dist/target/flink--bin/flink-' instead."
+  echo "Step 3: Replace existing licensing"
+  echo "  Delete NOTICE-binary and the entire licenses-binary 
directory."
+  echo "  Copy the contents in 'licenses-output' into the root 
directory of the Flink project."
+  echo "Step 4: Remember to commit the changes!"
   echo 
"=="
 fi
 else

[flink] branch release-1.9 updated (5b519dd -> 7729dd0)

2019-09-06 Thread chesnay

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

chesnay pushed a change to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git.


from 5b519dd  [FLINK-13388][web][docs] Updated screenshots to ones taken 
from the new UI
 add 7729dd0  [hotfix][travis] Add detailed instructions for update binary 
licensing

No new revisions were added by this update.

Summary of changes:
 tools/travis_controller.sh | 11 +--
 1 file changed, 9 insertions(+), 2 deletions(-)

[flink] branch master updated (3e79030 -> b61290f)

2019-09-06 Thread dwysakowicz

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

dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


from 3e79030  [hotfix] Update NOTICE-binary file.
 add b61290f  [FLINK-13388][web][docs] Updated screenshots to ones taken 
from the new UI

No new revisions were added by this update.

Summary of changes:
 docs/fig/back_pressure_sampling_high.png   | Bin 77546 -> 55567 bytes
 docs/fig/back_pressure_sampling_in_progress.png| Bin 79112 -> 54160 bytes
 docs/fig/back_pressure_sampling_ok.png | Bin 79668 -> 59379 bytes
 docs/fig/checkpoint_monitoring-details.png | Bin 94761 -> 112126 bytes
 .../fig/checkpoint_monitoring-details_subtasks.png | Bin 47710 -> 57970 bytes
 docs/fig/checkpoint_monitoring-details_summary.png | Bin 50860 -> 37267 bytes
 docs/fig/checkpoint_monitoring-history.png | Bin 83569 -> 83561 bytes
 docs/fig/checkpoint_monitoring-summary.png | Bin 51257 -> 43713 bytes
 .../page/img/quickstart-example/jobmanager-job.png | Bin 520093 -> 288116 bytes
 .../img/quickstart-example/jobmanager-overview.png | Bin 355967 -> 250493 bytes
 docs/page/img/quickstart-setup/jobmanager-1.png| Bin 66956 -> 152801 bytes
 docs/page/img/quickstart-setup/jobmanager-2.png| Bin 77840 -> 162583 bytes
 docs/page/img/quickstart-setup/jobmanager-3.png| Bin 97567 -> 179605 bytes
 13 files changed, 0 insertions(+), 0 deletions(-)

[flink] branch release-1.9 updated (36204ab -> 5b519dd)

2019-09-06 Thread dwysakowicz

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

dwysakowicz pushed a change to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git.


from 36204ab  [FLINK-13968][travis] Check correctness of binary licensing
 add 5b519dd  [FLINK-13388][web][docs] Updated screenshots to ones taken 
from the new UI

No new revisions were added by this update.

Summary of changes:
 docs/fig/back_pressure_sampling_high.png   | Bin 77546 -> 55567 bytes
 docs/fig/back_pressure_sampling_in_progress.png| Bin 79112 -> 54160 bytes
 docs/fig/back_pressure_sampling_ok.png | Bin 79668 -> 59379 bytes
 docs/fig/checkpoint_monitoring-details.png | Bin 94761 -> 112126 bytes
 .../fig/checkpoint_monitoring-details_subtasks.png | Bin 47710 -> 57970 bytes
 docs/fig/checkpoint_monitoring-details_summary.png | Bin 50860 -> 37267 bytes
 docs/fig/checkpoint_monitoring-history.png | Bin 83569 -> 83561 bytes
 docs/fig/checkpoint_monitoring-summary.png | Bin 51257 -> 43713 bytes
 .../page/img/quickstart-example/jobmanager-job.png | Bin 520093 -> 288116 bytes
 .../img/quickstart-example/jobmanager-overview.png | Bin 355967 -> 250493 bytes
 docs/page/img/quickstart-setup/jobmanager-1.png| Bin 66956 -> 152801 bytes
 docs/page/img/quickstart-setup/jobmanager-2.png| Bin 77840 -> 162583 bytes
 docs/page/img/quickstart-setup/jobmanager-3.png| Bin 97567 -> 179605 bytes
 13 files changed, 0 insertions(+), 0 deletions(-)

[flink] branch master updated: [hotfix] Update NOTICE-binary file.

2019-09-06 Thread fhueske

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

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


The following commit(s) were added to refs/heads/master by this push:
 new 3e79030  [hotfix] Update NOTICE-binary file.
3e79030 is described below

commit 3e79030f8ad2195920adfa3792d807536d256b96
Author: Fabian Hueske 
AuthorDate: Fri Sep 6 14:43:59 2019 +0200

[hotfix] Update NOTICE-binary file.
---
 NOTICE-binary | 307 +-
 1 file changed, 151 insertions(+), 156 deletions(-)

diff --git a/NOTICE-binary b/NOTICE-binary
index cf10657..24a61db 100644
--- a/NOTICE-binary
+++ b/NOTICE-binary
@@ -26,40 +26,18 @@ Copyright 2006-2019 The Apache Software Foundation
 This product includes software developed at
 The Apache Software Foundation (http://www.apache.org/).
 
-flink-examples-streaming-click-event-count
+flink-examples-streaming-state-machine
 Copyright 2014-2019 The Apache Software Foundation
 
 This project bundles the following dependencies under the Apache Software 
License 2.0. (http://www.apache.org/licenses/LICENSE-2.0.txt)
 
-- org.apache.kafka:kafka-clients:2.2.0
-
-
-flink-connector-kafka
-Copyright 2014-2019 The Apache Software Foundation
-
-flink-connector-kafka-base
-Copyright 2014-2019 The Apache Software Foundation
-
-// --
-// NOTICE file corresponding to the section 4d of The Apache License,
-// Version 2.0, in this case for Apache Flink
-// --
+- org.apache.kafka:kafka-clients:0.10.2.1
 
-Apache Flink
-Copyright 2006-2019 The Apache Software Foundation
-
-This product includes software developed at
-The Apache Software Foundation (http://www.apache.org/).
 
-flink-examples-streaming-state-machine
+flink-connector-kafka-0.10
 Copyright 2014-2019 The Apache Software Foundation
 
-This project bundles the following dependencies under the Apache Software 
License 2.0. (http://www.apache.org/licenses/LICENSE-2.0.txt)
-
-- org.apache.kafka:kafka-clients:2.2.0
-
-
-flink-connector-kafka
+flink-connector-kafka-0.9
 Copyright 2014-2019 The Apache Software Foundation
 
 flink-connector-kafka-base
@@ -130,6 +108,18 @@ This project bundles the following dependencies under the 
Apache Software Licens
 - org.eclipse.jetty:jetty-util:9.3.19.v20170502
 - org.eclipse.jetty:jetty-util-ajax:9.3.19.v20170502
 
+Apache Commons Lang
+Copyright 2001-2014 The Apache Software Foundation
+
+This product includes software from the Spring Framework,
+under the Apache License 2.0 (see: StringUtils.containsWhitespace())
+
+Apache Commons Collections
+Copyright 2001-2015 The Apache Software Foundation
+
+This product includes software developed by
+The Apache Software Foundation (http://www.apache.org/).
+
 
 flink-hadoop-fs
 Copyright 2014-2019 The Apache Software Foundation
@@ -3123,12 +3113,6 @@ which has the following notices:
 Apache Commons IO
 Copyright 2002-2012 The Apache Software Foundation
 
-This product includes software developed by
-The Apache Software Foundation (http://www.apache.org/).
-
-Apache Commons Collections
-Copyright 2001-2015 The Apache Software Foundation
-
 Apache Commons Logging
 Copyright 2003-2013 The Apache Software Foundation
 
@@ -3141,12 +3125,6 @@ Copyright 2000-2016 The Apache Software Foundation
 Apache Commons Configuration
 Copyright 2001-2017 The Apache Software Foundation
 
-Apache Commons Lang
-Copyright 2001-2014 The Apache Software Foundation
-
-This product includes software from the Spring Framework,
-under the Apache License 2.0 (see: StringUtils.containsWhitespace())
-
 htrace-core4
 Copyright 2016 The Apache Software Foundation
 
@@ -3471,6 +3449,113 @@ FasterXML.com (http://fasterxml.com).
 Apache Commons CLI
 Copyright 2001-2015 The Apache Software Foundation
 
+The Netty Project
+=
+
+Please visit the Netty web site for more information:
+
+  * http://netty.io/
+
+Copyright 2011 The Netty Project
+
+The Netty Project licenses this file to you under the Apache License,
+version 2.0 (the "License"); you may not use this file except in compliance
+with the License. You may obtain a copy of the License at:
+
+http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+License for the specific language governing permissions and limitations
+under the License.
+
+Also, please refer to each LICENSE..txt file, which is located in
+the 'license' directory of the distribution file, for the license terms of the
+components that this product depends on.
+
+---
+This product

[flink] annotated tag release-1.8.2-rc1 updated (6322618 -> 0da8b33)

2019-09-06 Thread jark

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

jark pushed a change to annotated tag release-1.8.2-rc1
in repository https://gitbox.apache.org/repos/asf/flink.git.


*** WARNING: tag release-1.8.2-rc1 was modified! ***

from 6322618  (commit)
  to 0da8b33  (tag)
 tagging 6322618bb0f1b7942d86cb1b2b7bc55290d9e330 (commit)
 replaces pre-apache-rename
  by Jark Wu
  on Wed Sep 4 22:08:17 2019 +0800

- Log -
release-1.8.2-rc1
-BEGIN PGP SIGNATURE-

iQIzBAABCAAdFiEE4sRUF77VwQQVTzQQhbrLWu+uMgIFAl1vxVEACgkQhbrLWu+u
MgLICQ//VyrqE/gxMSAcuN+0VIpLRr2BVSdHGmUJTp0V840/AA2E4KGwsNZcoVpU
Kyb98De98RqpwWfDf8kDzt8JGSu6ZSleOACwvU6li7Togyum8OLuoEZwSkJ7iz3u
XyC9ceZu5wQ+YMpvodPfwgkupWHB0ZDxGiu9UJIYxt0eoyex7kLYs2SweQXjMhti
lLHUZvNDI3pKJVCBlGRkouuapUAtnNsZuHbUOXANk80a5P3T5GI+mJaIPTbltAGz
joVa8b202zZ+NFlwAvjmWQLZkqrQhP09BLuNfOxeBISxxz/LoksB2dPyCqYNxpmx
HMwP8NWOBHU/JKeLToXyOsqhg8xuXbiNwnq7lMklJqJYd65SseZ4uGrOMiVErigI
W7dSacStb8mgMgU8lBPFTd7RfPrOD9Valp5QTkAIKvnsp7INbESNZ8YcNc8+Eip3
jIyPoHkI7LrFS0Wo4XGm0ZaldVJ1i19oJd84rq1IKrOKNAeLN+D6mfblDkZTESlk
xEz+3yFYljCpX2oQRx/e10CvBD0DEHuUmGBhb5EFoq2p/WE7DgD73xc1X+c6d8r/
4J9E/tcqqwPhk4k6lJUhjuq5B8+hsUZCU8XB4lQDnKpINqCpI2fY4yXma+cFVYx6
t2rfS9npT05topOLkQfRhuy+uGgkOXhJLkbBmIjApMIxQVjZ+ak=
=WFpY
-END PGP SIGNATURE-
---


No new revisions were added by this update.

Summary of changes:

svn commit: r35637 - /dev/flink/flink-1.8.2-rc1/

2019-09-06 Thread jark

Author: jark
Date: Fri Sep  6 12:27:24 2019
New Revision: 35637

Log:
Add flink-1.8.2-rc1

Added:
dev/flink/flink-1.8.2-rc1/
dev/flink/flink-1.8.2-rc1/flink-1.8.2-bin-scala_2.11.tgz   (with props)
dev/flink/flink-1.8.2-rc1/flink-1.8.2-bin-scala_2.11.tgz.asc
dev/flink/flink-1.8.2-rc1/flink-1.8.2-bin-scala_2.11.tgz.sha512
dev/flink/flink-1.8.2-rc1/flink-1.8.2-bin-scala_2.12.tgz   (with props)
dev/flink/flink-1.8.2-rc1/flink-1.8.2-bin-scala_2.12.tgz.asc
dev/flink/flink-1.8.2-rc1/flink-1.8.2-bin-scala_2.12.tgz.sha512
dev/flink/flink-1.8.2-rc1/flink-1.8.2-src.tgz   (with props)
dev/flink/flink-1.8.2-rc1/flink-1.8.2-src.tgz.asc
dev/flink/flink-1.8.2-rc1/flink-1.8.2-src.tgz.sha512

Added: dev/flink/flink-1.8.2-rc1/flink-1.8.2-bin-scala_2.11.tgz
==
Binary file - no diff available.

Propchange: dev/flink/flink-1.8.2-rc1/flink-1.8.2-bin-scala_2.11.tgz
--
svn:mime-type = application/octet-stream

Added: dev/flink/flink-1.8.2-rc1/flink-1.8.2-bin-scala_2.11.tgz.asc
==
--- dev/flink/flink-1.8.2-rc1/flink-1.8.2-bin-scala_2.11.tgz.asc (added)
+++ dev/flink/flink-1.8.2-rc1/flink-1.8.2-bin-scala_2.11.tgz.asc Fri Sep  6 
12:27:24 2019
@@ -0,0 +1,16 @@
+-BEGIN PGP SIGNATURE-
+
+iQIzBAABCAAdFiEE4sRUF77VwQQVTzQQhbrLWu+uMgIFAl1yTu8ACgkQhbrLWu+u
+MgJAmw/9FGgn1flWRLLHzCc48SKSd8w5X/1R19tY/NtkN7pDc6pErMwv0tXzvSwM
+1p1ck5zWz1A/Lmn93aysdmjwCiA7qwPcZkne9j6+3P+E3cxtIslT2tFO2VYI/cSg
+9NuxSbRjGstnjf7aeGpLxFRz+SFManvmwtbpDsYzHS9J9QUmjuO1Tl3YRsGMkalc
+5zZyf/6I/arLQzjVveFKkyH4gMN5tr8HaYj3/J2NfycjQTCT7FlAyi7TiJKtjntz
+2mr7eyz1UvaMbhmgVXaoegwbrMS4MPdR7GYFVW/AuSRsc3v6MjnlMaR8mu5E9g/X
+w9AIUhJH9pfDr+wbo4rColgDYjmtcGf6/J5fbBds4zTxdLxkvYGaCEHK1wbIFg48
+iGfN66Z7ABO4uBNYYeNNYh2X78sYXrnXFoBET/RXsvqkJsV974YrjHMIlO1fEou6
+zjWIu+4h3aIG9hbEaT3LO2QdWCfS6Q/quRgoaJy+9flqH0ivutu3hH6/131NXn71
+ngSE8MM74sRMwbaxtLFH6v8FM9d0syQ7mvvjOPBqSOdESovDNgoau5C0UtPJC86/
+FNFwpb2iPlFHaGvwMJPyy1D8Boxz5wj+E/2xY8JjhO18KJoHklk+ett8T1qPcr9y
+7wvPl6JSeCZFfFHMbf/G5z8T2CWs9oyXAiFgN1BdXffp+ts8Kdg=
+=UPxN
+-END PGP SIGNATURE-

Added: dev/flink/flink-1.8.2-rc1/flink-1.8.2-bin-scala_2.11.tgz.sha512
==
--- dev/flink/flink-1.8.2-rc1/flink-1.8.2-bin-scala_2.11.tgz.sha512 (added)
+++ dev/flink/flink-1.8.2-rc1/flink-1.8.2-bin-scala_2.11.tgz.sha512 Fri Sep  6 
12:27:24 2019
@@ -0,0 +1 @@
+75b51d1420f458a5bb87152118aa02e9bc1e7b2ea9a029a7af437ab3192c85720b6e64a8815bedf2d59c14804a01dcb8280d1ba7e53022cd3dfd922c9ce63d03
  flink-1.8.2-bin-scala_2.11.tgz

Added: dev/flink/flink-1.8.2-rc1/flink-1.8.2-bin-scala_2.12.tgz
==
Binary file - no diff available.

Propchange: dev/flink/flink-1.8.2-rc1/flink-1.8.2-bin-scala_2.12.tgz
--
svn:mime-type = application/octet-stream

Added: dev/flink/flink-1.8.2-rc1/flink-1.8.2-bin-scala_2.12.tgz.asc
==
--- dev/flink/flink-1.8.2-rc1/flink-1.8.2-bin-scala_2.12.tgz.asc (added)
+++ dev/flink/flink-1.8.2-rc1/flink-1.8.2-bin-scala_2.12.tgz.asc Fri Sep  6 
12:27:24 2019
@@ -0,0 +1,16 @@
+-BEGIN PGP SIGNATURE-
+
+iQIzBAABCAAdFiEE4sRUF77VwQQVTzQQhbrLWu+uMgIFAl1yTHoACgkQhbrLWu+u
+MgKfMBAAiG6wlPO3ot9+9LaxCjD3/hUfX7DZdht/QNnvqqN/zHNfV1ILmZ8YqVHn
+Nip38LoWaYZ9LKYweVK8vfypOV29BTtPzDP/jVLCn2ziCWj8K+jsrHzI1rO63LK4
+mUSbDnOY77zNmRXJEhM4vkDqaFfXVubb8J2Vms6BeU6lOacBVFDH+A3sE3CYj85D
+tRL78UJE8maVAbS2nLC81pZvCKkq7w3wKe0fiezgJVB0Y+D6XqwR+VxoESsiXAWE
+3tWsq+IY7in2OyU5Bg29htEtGE9y9kfixJfkd2XXiM5Mw0k3ba6prZVPXGRydFSe
+c0Pf3gWozuMhck30aqiCib96XWkWWemhKQDOPcytway4K0CNs57VCLnCUWM3Jek7
+4OI11Ba4pZeSA1jtPKSfmDEjOVX8/1CIx2thNaUTllBxdtyzjsOMCBFKhkXyB8YR
++QS3i+fbrizjDCBEugd5U0fipQzV+pxP/2tcCTWgjprwwXGZswa81ttqnEinS/us
+nKTojdgkpk8JaOV/5FrYtCRrjH/PPW+HaKGNXqslEVgqX3CSF5MsCRVvhBChn3a+
+M63+1Q4c3VlX4FfTErtpTRG8reoJvsoiIKQ2dTcMvE5jBGrWSQOQ6s9IdrmQXY33
+zfAV1foBvom+b4qQZZo6ajnYVLjXAaDISRdo8CwH7GO7LE6hpvw=
+=GkkB
+-END PGP SIGNATURE-

Added: dev/flink/flink-1.8.2-rc1/flink-1.8.2-bin-scala_2.12.tgz.sha512
==
--- dev/flink/flink-1.8.2-rc1/flink-1.8.2-bin-scala_2.12.tgz.sha512 (added)
+++ dev/flink/flink-1.8.2-rc1/flink-1.8.2-bin-scala_2.12.tgz.sha512 Fri Sep  6 
12:27:24 2019
@@ -0,0 +1 @@
+b1818e701665e29e12fc25036f67b721cd6808e175fbd6f15db26e213637262a6c7989b7ad12937798f436ba36a718e009027f36c6678aa6141ab4dc196ec667
  flink-1.8.2-bin-scala_2.12.tgz

Added: dev/flink/flink-1.8.2-rc1/flink-1.8.2-src.tgz
==
Binary file - no diff available.

Propchange:

[flink] 02/03: [FLINK-12749][docs] Add operations playground.

2019-09-06 Thread fhueske

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

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

commit a17623ba51f7cae83bc789cd4f8ffc7f105a8715
Author: Fabian Hueske 
AuthorDate: Mon Aug 26 17:00:24 2019 +0200

[FLINK-12749][docs] Add operations playground.

This closes #9543.

[ci skip]
---
 docs/fig/click-event-count-example.svg |  21 +
 docs/fig/flink-docker-playground.svg   |  21 +
 docs/fig/playground-webui-failure.png  | Bin 0 -> 37334 bytes
 docs/fig/playground-webui.png  | Bin 0 -> 18135 bytes
 .../flink-operations-playground.md | 817 +
 .../flink-operations-playground.zh.md  | 817 +
 docs/getting-started/docker-playgrounds/index.md   |  25 +
 .../getting-started/docker-playgrounds/index.zh.md |  25 +
 8 files changed, 1726 insertions(+)

diff --git a/docs/fig/click-event-count-example.svg 
b/docs/fig/click-event-count-example.svg
new file mode 100644
index 000..4d9c06f
--- /dev/null
+++ b/docs/fig/click-event-count-example.svg
@@ -0,0 +1,21 @@
+
+
+http://www.w3.org/Graphics/SVG/1.1/DTD/svg11.dtd;>
+http://www.w3.org/2000/svg; 
xmlns:xlink="http://www.w3.org/1999/xlink; version="1.1" width="713px" 
height="359px" viewBox="-0.5 -0.5 713 359" content="mxfile 
modified=2019-07-30T06:33:46.579Z host=www.draw.io 
agent=Mozilla/5.0 (X11; Linux x86_64; rv:66.0) Gecko/20100101 
Firefox/66.0 etag=Gyms1__7o2-6Tou9Fwcv 
version=11.0.7 type=devicediagram 
id=axHalsAsTUV6G1jOH0Rx name=Page- [...]
\ No newline at end of file
diff --git a/docs/fig/flink-docker-playground.svg 
b/docs/fig/flink-docker-playground.svg
new file mode 100644
index 000..24a53e2
--- /dev/null
+++ b/docs/fig/flink-docker-playground.svg
@@ -0,0 +1,21 @@
+
+
+http://www.w3.org/Graphics/SVG/1.1/DTD/svg11.dtd;>
+http://www.w3.org/2000/svg; 
xmlns:xlink="http://www.w3.org/1999/xlink; version="1.1" width="681px" 
height="221px" viewBox="-0.5 -0.5 681 221" content="mxfile 
modified=2019-07-30T05:46:19.236Z host=www.draw.io 
agent=Mozilla/5.0 (X11; Linux x86_64; rv:66.0) Gecko/20100101 
Firefox/66.0 etag=6b7qPJhosj6WVEuTns2y 
version=11.0.7 type=devicediagram 
id=zIUxMKcIWk6lTGESeTwo name=Page- [...]
\ No newline at end of file
diff --git a/docs/fig/playground-webui-failure.png 
b/docs/fig/playground-webui-failure.png
new file mode 100644
index 000..31968dc
Binary files /dev/null and b/docs/fig/playground-webui-failure.png differ
diff --git a/docs/fig/playground-webui.png b/docs/fig/playground-webui.png
new file mode 100644
index 000..3833d6d
Binary files /dev/null and b/docs/fig/playground-webui.png differ
diff --git 
a/docs/getting-started/docker-playgrounds/flink-operations-playground.md 
b/docs/getting-started/docker-playgrounds/flink-operations-playground.md
new file mode 100644
index 000..38a0848
--- /dev/null
+++ b/docs/getting-started/docker-playgrounds/flink-operations-playground.md
@@ -0,0 +1,817 @@
+---
+title: "Flink Operations Playground"
+nav-title: 'Flink Operations Playground'
+nav-parent_id: docker-playgrounds
+nav-pos: 1
+---
+
+
+There are many ways to deploy and operate Apache Flink in various 
environments. Regardless of this
+variety, the fundamental building blocks of a Flink Cluster remain the same, 
and similar
+operational principles apply.
+
+In this playground, you will learn how to manage and run Flink Jobs. You will 
see how to deploy and 
+monitor an application, experience how Flink recovers from Job failure, and 
perform everyday 
+operational tasks like upgrades and rescaling.
+
+{% if site.version contains "SNAPSHOT" %}
+
+  
+  NOTE: The Apache Flink Docker images used for this playground are only 
available for
+  released versions of Apache Flink.
+  
+  Since you are currently looking at the latest SNAPSHOT
+  version of the documentation, all version references below will not work.
+  Please switch the documentation to the latest released version via the 
release picker which you
+  find on the left side below the menu.
+
+{% endif %}
+
+* This will be replaced by the TOC
+{:toc}
+
+## Anatomy of this Playground
+
+This playground consists of a long living
+[Flink Session Cluster]({{ site.baseurl 
}}/concepts/glossary.html#flink-session-cluster) and a Kafka
+Cluster.
+
+A Flink Cluster always consists of a 
+[Flink Master]({{ site.baseurl }}/concepts/glossary.html#flink-master) and one 
or more 
+[Flink TaskManagers]({{ site.baseurl 
}}/concepts/glossary.html#flink-taskmanager). The Flink Master 
+is responsible for handling [Job]({{ site.baseurl 
}}/concepts/glossary.html#flink-job) submissions, 
+the supervision of Jobs as well as resource management. The Flink TaskManagers 
are the worker 
+processes and are responsible for the execution of the actual 
+[Tasks]({{ site.baseurl }}/concepts/glossary.html#task) which make up a Flink 
Job. In this 
+playground you will

[flink] 03/03: [FLINK-13942][docs] Add "Getting Started" overview page.

2019-09-06 Thread fhueske

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

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

commit 275fe9641a8be0815fee152388bf105941b23418
Author: Fabian Hueske 
AuthorDate: Tue Sep 3 09:54:30 2019 +0200

[FLINK-13942][docs] Add "Getting Started" overview page.

This closes #9603.

[ci skip]
---
 docs/getting-started/index.md| 35 +++
 docs/getting-started/index.zh.md | 35 +++
 2 files changed, 70 insertions(+)

diff --git a/docs/getting-started/index.md b/docs/getting-started/index.md
index bd80898..861be99 100644
--- a/docs/getting-started/index.md
+++ b/docs/getting-started/index.md
@@ -4,6 +4,7 @@ nav-id: getting-started
 nav-title: ' 
Getting Started'
 nav-parent_id: root
 section-break: true
+nav-show_overview: true
 nav-pos: 1
 ---
 
+
+There are many ways to get started with Apache Flink. Which one is the best 
for you depends on your goal and prior experience.
+
+### Taking a first look at Flink
+
+The **Docker Playgrounds** provide sandboxed Flink environments that are set 
up in just a few minutes and which allow you to explore and play with Flink.
+
+* The [**Operations 
Playground**](./docker-playgrounds/flink-operations-playground.html) shows you 
how to operate streaming applications with Flink. You can experience how Flink 
recovers application from failures, upgrade and scale streaming applications up 
and down, and query application metrics.
+
+
+
+### First steps with one of Flink's APIs
+
+The **Code Walkthroughs** are the best way to get started and introduce you 
step by step to an API.
+A walkthrough provides instructions to bootstrap a small Flink project with a 
code skeleton and shows how to extend it to a simple application.
+
+
+* The [**DataStream API**](./tutorials/datastream_api.html) tutorial shows how 
to implement a basic DataStream application. The DataStream API is Flink's main 
abstraction to implement stateful streaming applications with sophisticated 
time semantics in Java or Scala.
+
+* The [**Table API**](./walkthroughs/table_api.html) code walkthrough shows 
how to implement a simple Table API query on a batch source and how to evolve 
it into a continuous query on a streaming source. The Table API Flink's 
language-embedded, relational API to write SQL-like queries in Java or Scala 
which are automatically optimized similar to SQL queries. Table API queries can 
be executed on batch or streaming data with identical syntax and semantics.
+
+
diff --git a/docs/getting-started/index.zh.md b/docs/getting-started/index.zh.md
index bd80898..861be99 100644
--- a/docs/getting-started/index.zh.md
+++ b/docs/getting-started/index.zh.md
@@ -4,6 +4,7 @@ nav-id: getting-started
 nav-title: ' 
Getting Started'
 nav-parent_id: root
 section-break: true
+nav-show_overview: true
 nav-pos: 1
 ---
 
+
+There are many ways to get started with Apache Flink. Which one is the best 
for you depends on your goal and prior experience.
+
+### Taking a first look at Flink
+
+The **Docker Playgrounds** provide sandboxed Flink environments that are set 
up in just a few minutes and which allow you to explore and play with Flink.
+
+* The [**Operations 
Playground**](./docker-playgrounds/flink-operations-playground.html) shows you 
how to operate streaming applications with Flink. You can experience how Flink 
recovers application from failures, upgrade and scale streaming applications up 
and down, and query application metrics.
+
+
+
+### First steps with one of Flink's APIs
+
+The **Code Walkthroughs** are the best way to get started and introduce you 
step by step to an API.
+A walkthrough provides instructions to bootstrap a small Flink project with a 
code skeleton and shows how to extend it to a simple application.
+
+
+* The [**DataStream API**](./tutorials/datastream_api.html) tutorial shows how 
to implement a basic DataStream application. The DataStream API is Flink's main 
abstraction to implement stateful streaming applications with sophisticated 
time semantics in Java or Scala.
+
+* The [**Table API**](./walkthroughs/table_api.html) code walkthrough shows 
how to implement a simple Table API query on a batch source and how to evolve 
it into a continuous query on a streaming source. The Table API Flink's 
language-embedded, relational API to write SQL-like queries in Java or Scala 
which are automatically optimized similar to SQL queries. Table API queries can 
be executed on batch or streaming data with identical syntax and semantics.
+
+

[flink] 01/03: [FLINK-12749][docs] Revert commit f695a76b10b0cb5f074bbb874fe374cd11e6eff3

2019-09-06 Thread fhueske

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

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

commit 8998b2fe286d4ac788011f03fc6953f8b040b119
Author: Fabian Hueske 
AuthorDate: Tue Aug 27 13:51:44 2019 +0200

[FLINK-12749][docs] Revert commit f695a76b10b0cb5f074bbb874fe374cd11e6eff3
---
 docs/fig/click-event-count-example.svg |  21 -
 docs/fig/flink-docker-playground.svg   |  21 -
 docs/fig/playground-webui-failure.png  | Bin 37334 -> 0 bytes
 docs/fig/playground-webui.png  | Bin 18135 -> 0 bytes
 .../docker-playgrounds/flink_cluster_playground.md | 812 -
 .../flink_cluster_playground.zh.md | 774 
 docs/getting-started/docker-playgrounds/index.md   |  25 -
 .../getting-started/docker-playgrounds/index.zh.md |  25 -
 flink-dist/pom.xml |   7 -
 flink-dist/src/main/assemblies/bin.xml |  11 -
 .../pom.xml| 106 ---
 .../src/main/resources/META-INF/NOTICE |   9 -
 .../src/main/resources/META-INF/NOTICE |   2 +-
 flink-examples/flink-examples-build-helper/pom.xml |   1 -
 flink-examples/flink-examples-streaming/pom.xml|   3 +-
 .../statemachine/KafkaEventsGeneratorJob.java  |   4 +-
 .../examples/statemachine/StateMachineExample.java |   4 +-
 .../windowing/clickeventcount/ClickEventCount.java | 117 ---
 .../clickeventcount/ClickEventGenerator.java   | 122 
 .../functions/ClickEventStatisticsCollector.java   |  47 --
 .../functions/CountingAggregator.java  |  47 --
 .../clickeventcount/records/ClickEvent.java|  85 ---
 .../records/ClickEventDeserializationSchema.java   |  51 --
 .../records/ClickEventSerializationSchema.java |  55 --
 .../records/ClickEventStatistics.java  | 116 ---
 .../ClickEventStatisticsSerializationSchema.java   |  55 --
 26 files changed, 7 insertions(+), 2513 deletions(-)

diff --git a/docs/fig/click-event-count-example.svg 
b/docs/fig/click-event-count-example.svg
deleted file mode 100644
index 4d9c06f..000
--- a/docs/fig/click-event-count-example.svg
+++ /dev/null
@@ -1,21 +0,0 @@
-
-
-http://www.w3.org/Graphics/SVG/1.1/DTD/svg11.dtd;>
-http://www.w3.org/2000/svg; 
xmlns:xlink="http://www.w3.org/1999/xlink; version="1.1" width="713px" 
height="359px" viewBox="-0.5 -0.5 713 359" content="mxfile 
modified=2019-07-30T06:33:46.579Z host=www.draw.io 
agent=Mozilla/5.0 (X11; Linux x86_64; rv:66.0) Gecko/20100101 
Firefox/66.0 etag=Gyms1__7o2-6Tou9Fwcv 
version=11.0.7 type=devicediagram 
id=axHalsAsTUV6G1jOH0Rx name=Page- [...]
\ No newline at end of file
diff --git a/docs/fig/flink-docker-playground.svg 
b/docs/fig/flink-docker-playground.svg
deleted file mode 100644
index 24a53e2..000
--- a/docs/fig/flink-docker-playground.svg
+++ /dev/null
@@ -1,21 +0,0 @@
-
-
-http://www.w3.org/Graphics/SVG/1.1/DTD/svg11.dtd;>
-http://www.w3.org/2000/svg; 
xmlns:xlink="http://www.w3.org/1999/xlink; version="1.1" width="681px" 
height="221px" viewBox="-0.5 -0.5 681 221" content="mxfile 
modified=2019-07-30T05:46:19.236Z host=www.draw.io 
agent=Mozilla/5.0 (X11; Linux x86_64; rv:66.0) Gecko/20100101 
Firefox/66.0 etag=6b7qPJhosj6WVEuTns2y 
version=11.0.7 type=devicediagram 
id=zIUxMKcIWk6lTGESeTwo name=Page- [...]
\ No newline at end of file
diff --git a/docs/fig/playground-webui-failure.png 
b/docs/fig/playground-webui-failure.png
deleted file mode 100644
index 31968dc..000
Binary files a/docs/fig/playground-webui-failure.png and /dev/null differ
diff --git a/docs/fig/playground-webui.png b/docs/fig/playground-webui.png
deleted file mode 100644
index 3833d6d..000
Binary files a/docs/fig/playground-webui.png and /dev/null differ
diff --git 
a/docs/getting-started/docker-playgrounds/flink_cluster_playground.md 
b/docs/getting-started/docker-playgrounds/flink_cluster_playground.md
deleted file mode 100644
index 7f6ef23..000
--- a/docs/getting-started/docker-playgrounds/flink_cluster_playground.md
+++ /dev/null
@@ -1,812 +0,0 @@

-title: "Flink Cluster Playground"
-nav-title: 'Flink Cluster Playground'
-nav-parent_id: docker-playgrounds
-nav-pos: 1

-
-
-There are many ways to deploy and operate Apache Flink in various 
environments. Regardless of this
-variety, the fundamental building blocks of a Flink Cluster remain the same, 
and similar
-operational principles apply.
-
-In this playground, you will learn how to manage and run Flink Jobs. You will 
see how to deploy and 
-monitor an application, experience how Flink recovers from Job failure, and 
perform everyday 
-operational tasks like upgrades and rescaling.
-
-* This will be replaced by the TOC
-{:toc}
-
-## Anatomy of this Playground
-
-This playground consists of a long living
-[Flink Session Cluster]({{ site.baseurl 
}}/concepts/glossary.html#flink-session-cluster) and a

[flink] branch master updated (d49e174 -> 275fe96)

2019-09-06 Thread fhueske

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

fhueske pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


from d49e174  [FLINK-13968][travis] Check correctness of binary licensing
 new 8998b2f  [FLINK-12749][docs] Revert commit 
f695a76b10b0cb5f074bbb874fe374cd11e6eff3
 new a17623b  [FLINK-12749][docs] Add operations playground.
 new 275fe96  [FLINK-13942][docs] Add "Getting Started" overview page.

The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 ...layground.md => flink-operations-playground.md} |  61 +++---
 ...und.zh.md => flink-operations-playground.zh.md} | 213 +
 docs/getting-started/index.md  |  35 
 docs/getting-started/index.zh.md   |  35 
 flink-dist/pom.xml |   7 -
 flink-dist/src/main/assemblies/bin.xml |  11 --
 .../pom.xml| 106 --
 .../src/main/resources/META-INF/NOTICE |   9 -
 .../src/main/resources/META-INF/NOTICE |   2 +-
 flink-examples/flink-examples-build-helper/pom.xml |   1 -
 flink-examples/flink-examples-streaming/pom.xml|   3 +-
 .../statemachine/KafkaEventsGeneratorJob.java  |   4 +-
 .../examples/statemachine/StateMachineExample.java |   4 +-
 .../windowing/clickeventcount/ClickEventCount.java | 117 ---
 .../clickeventcount/ClickEventGenerator.java   | 122 
 .../functions/ClickEventStatisticsCollector.java   |  47 -
 .../functions/CountingAggregator.java  |  47 -
 .../clickeventcount/records/ClickEvent.java|  85 
 .../records/ClickEventDeserializationSchema.java   |  51 -
 .../records/ClickEventSerializationSchema.java |  55 --
 .../records/ClickEventStatistics.java  | 116 ---
 .../ClickEventStatisticsSerializationSchema.java   |  55 --
 22 files changed, 238 insertions(+), 948 deletions(-)
 rename docs/getting-started/docker-playgrounds/{flink_cluster_playground.md => 
flink-operations-playground.md} (92%)
 rename docs/getting-started/docker-playgrounds/{flink_cluster_playground.zh.md 
=> flink-operations-playground.zh.md} (76%)
 delete mode 100644 
flink-examples/flink-examples-build-helper/flink-examples-streaming-click-event-count/pom.xml
 delete mode 100644 
flink-examples/flink-examples-build-helper/flink-examples-streaming-click-event-count/src/main/resources/META-INF/NOTICE
 delete mode 100644 
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/clickeventcount/ClickEventCount.java
 delete mode 100644 
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/clickeventcount/ClickEventGenerator.java
 delete mode 100644 
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/clickeventcount/functions/ClickEventStatisticsCollector.java
 delete mode 100644 
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/clickeventcount/functions/CountingAggregator.java
 delete mode 100644 
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/clickeventcount/records/ClickEvent.java
 delete mode 100644 
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/clickeventcount/records/ClickEventDeserializationSchema.java
 delete mode 100644 
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/clickeventcount/records/ClickEventSerializationSchema.java
 delete mode 100644 
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/clickeventcount/records/ClickEventStatistics.java
 delete mode 100644 
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/clickeventcount/records/ClickEventStatisticsSerializationSchema.java

[flink] branch java11_test deleted (was bcf64ba)

2019-09-06 Thread chesnay

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

chesnay pushed a change to branch java11_test
in repository https://gitbox.apache.org/repos/asf/flink.git.


 was bcf64ba  presto

This change permanently discards the following revisions:

 discard bcf64ba  presto
 discard cf173fa  disable some profiles
 discard 28280d4  move jaxb to actual fs module
 discard 49402b5  typo
 discard 7cb3032  relocate jaxb-api
 discard 9a581f5  remove test scope
 discard 343e7a6  [s3] add jaxb test dependency
 discard ae4791d  hide download stuff
 discard 423772b  asm
 discard 84392ad  disable modern kafka e2e
 discard 38a6abf  +fs
 discard 93e3433  include hadoop
 discard 4512716f add misc/heavvy e2e test runs
 discard 4730872  [FLINK-X][tests] Disable failing tests on Java 11
 discard cde5e98  harden StreamTaskTest
 discard 6342088  [TMP] setup custom flink-shaded install
 discard b5fedec  [TMP][FLINK-13467][build] Bump ASM to 7.1
 discard 6e27f98  [TMP] run jdk 9 tests by default
 discard 4e16897  [FLINK-13457][travis] Setup JDK 11 builds

[flink] branch release-1.9 updated (94aa4db -> 36204ab)

2019-09-06 Thread chesnay

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

chesnay pushed a change to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git.


from 94aa4db  [FLINK-13892][hs] Harden HistoryServerTest
 add 36204ab  [FLINK-13968][travis] Check correctness of binary licensing

No new revisions were added by this update.

Summary of changes:
 tools/travis_controller.sh | 20 
 1 file changed, 20 insertions(+)

[flink] branch master updated (f43138e -> d49e174)

2019-09-06 Thread chesnay

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

chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


from f43138e  [FLINK-12501] Use SpecificRecord.getSchema in AvroFactory
 add d49e174  [FLINK-13968][travis] Check correctness of binary licensing

No new revisions were added by this update.

Summary of changes:
 tools/travis_controller.sh | 20 
 1 file changed, 20 insertions(+)

[flink] branch release-1.8 updated: [FLINK-13968][travis] Check correctness of binary licensing

2019-09-06 Thread chesnay

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

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


The following commit(s) were added to refs/heads/release-1.8 by this push:
 new 68885b8  [FLINK-13968][travis] Check correctness of binary licensing
68885b8 is described below

commit 68885b888afce0b45664cb8c4cf2d4d52a1bfb3d
Author: Chesnay Schepler 
AuthorDate: Wed Sep 4 15:37:20 2019 +0200

[FLINK-13968][travis] Check correctness of binary licensing
---
 tools/travis_controller.sh | 20 
 1 file changed, 20 insertions(+)

diff --git a/tools/travis_controller.sh b/tools/travis_controller.sh
index c0f70a5..f27e408 100755
--- a/tools/travis_controller.sh
+++ b/tools/travis_controller.sh
@@ -96,6 +96,26 @@ if [ $STAGE == "$STAGE_COMPILE" ]; then
 fi
 
 if [ $EXIT_CODE == 0 ]; then
+./tools/releasing/collect_license_files.sh ./build-target
+diff "NOTICE-binary" "licenses-output/NOTICE-binary"
+EXIT_CODE=$(($EXIT_CODE+$?))
+diff -r "licenses-binary" "licenses-output/licenses-binary"
+EXIT_CODE=$(($EXIT_CODE+$?))
+
+if [ $EXIT_CODE != 0 ]; then
+  echo 
"=="
+  echo "ERROR: binary licensing is out-of-date."
+  echo "Please update NOTICE-binary and licenses-binary using"
+  echo "'tools/releasing/collect_license_files.sh'."
+  echo 
"=="
+fi
+else
+echo 
"=="
+echo "Previous build failure detected, skipping licensing check."
+echo 
"=="
+fi
+
+if [ $EXIT_CODE == 0 ]; then
 echo "Creating cache build directory $CACHE_FLINK_DIR"
 mkdir -p "$CACHE_FLINK_DIR"

[flink] branch master updated: [FLINK-12501] Use SpecificRecord.getSchema in AvroFactory

2019-09-06 Thread aljoscha

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

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


The following commit(s) were added to refs/heads/master by this push:
 new f43138e  [FLINK-12501] Use SpecificRecord.getSchema in AvroFactory
f43138e is described below

commit f43138e0fe52a66f23225cbf5f72eae110bd3841
Author: Aljoscha Krettek 
AuthorDate: Fri Aug 30 10:42:58 2019 +0200

[FLINK-12501] Use SpecificRecord.getSchema in AvroFactory

Before, we were using SpecificData.getSchema(type) which was not working
for types that were generated using Avrohugger (for Scala) because
the SCHEMA was generated in the companion object. Now we use a method
that must be available on all SpecificRecord(s).

We still use the old method as a fallback if we cannot instantiate or
call getSchema() on the instance.
---
 .../flink/formats/avro/typeutils/AvroFactory.java  | 36 +-
 .../avro/typeutils/AvroSerializerSnapshot.java |  2 +-
 2 files changed, 36 insertions(+), 2 deletions(-)

diff --git 
a/flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroFactory.java
 
b/flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroFactory.java
index 9a8bdcb..4916a90 100644
--- 
a/flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroFactory.java
+++ 
b/flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroFactory.java
@@ -37,6 +37,8 @@ import org.apache.avro.specific.SpecificData;
 import org.apache.avro.specific.SpecificDatumReader;
 import org.apache.avro.specific.SpecificDatumWriter;
 import org.apache.avro.specific.SpecificRecord;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.util.Optional;
 
@@ -50,6 +52,8 @@ import static 
org.apache.flink.util.Preconditions.checkNotNull;
 @Internal
 final class AvroFactory {
 
+   private static final Logger LOG = 
LoggerFactory.getLogger(AvroFactory.class);
+
private final DataOutputEncoder encoder = new DataOutputEncoder();
private final DataInputDecoder decoder = new DataInputDecoder();
 
@@ -94,7 +98,7 @@ final class AvroFactory {
@SuppressWarnings("OptionalUsedAsFieldOrParameterType")
private static  AvroFactory fromSpecific(Class type, 
ClassLoader cl, Optional previousSchema) {
SpecificData specificData = new SpecificData(cl);
-   Schema newSchema = specificData.getSchema(type);
+   Schema newSchema = extractAvroSpecificSchema(type, 
specificData);
 
return new AvroFactory<>(
specificData,
@@ -130,6 +134,36 @@ final class AvroFactory {
);
}
 
+   /**
+* Extracts an Avro {@link Schema} from a {@link SpecificRecord}. We do 
this either via {@link
+* SpecificData} or by instantiating a record and extracting the schema 
from the instance.
+*/
+   static  Schema extractAvroSpecificSchema(
+   Class type,
+   SpecificData specificData) {
+   Optional newSchemaOptional = 
tryExtractAvroSchemaViaInstance(type);
+   return newSchemaOptional.orElseGet(() -> 
specificData.getSchema(type));
+   }
+
+   /**
+* Extracts an Avro {@link Schema} from a {@link SpecificRecord}. We do 
this by creating an
+* instance of the class using the zero-argument constructor and 
calling {@link
+* SpecificRecord#getSchema()} on it.
+*/
+   @SuppressWarnings("unchecked")
+   private static Optional 
tryExtractAvroSchemaViaInstance(Class type) {
+   try {
+   SpecificRecord instance = (SpecificRecord) 
type.newInstance();
+   return Optional.ofNullable(instance.getSchema());
+   } catch (InstantiationException | IllegalAccessException e) {
+   LOG.warn(
+   "Could not extract schema from 
Avro-generated SpecificRecord class {}: {}.",
+   type,
+   e);
+   return Optional.empty();
+   }
+   }
+
private AvroFactory(
GenericData avroData,
Schema schema,
diff --git 
a/flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializerSnapshot.java
 
b/flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializerSnapshot.java
index a5f47d1..316a162 100644
--- 
a/flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializerSnapshot.java
+++ 
b/flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializerSnapshot.java
@@ -186,7 +186,7 @@ public class AvroSerializerSnapshot implements

[flink] branch release-1.9 updated (6acbe66 -> 94aa4db)

2019-09-06 Thread chesnay

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

chesnay pushed a change to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git.


from 6acbe66  [FLINK-13967][licensing] Fully generate binary licensing
 add 94aa4db  [FLINK-13892][hs] Harden HistoryServerTest

No new revisions were added by this update.

Summary of changes:
 .../runtime/webmonitor/history/HistoryServerArchiveFetcher.java | 6 +-
 1 file changed, 5 insertions(+), 1 deletion(-)

[flink] branch release-1.8 updated: [FLINK-13892][hs] Harden HistoryServerTest

2019-09-06 Thread chesnay

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

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


The following commit(s) were added to refs/heads/release-1.8 by this push:
 new 750648d  [FLINK-13892][hs] Harden HistoryServerTest
750648d is described below

commit 750648d4fb0dd83edf7e0a8462cc52118a98e484
Author: Chesnay Schepler 
AuthorDate: Thu Sep 5 13:40:06 2019 +0200

[FLINK-13892][hs] Harden HistoryServerTest
---
 .../runtime/webmonitor/history/HistoryServerArchiveFetcher.java | 6 +-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java
 
b/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java
index 47888cd..fed220f 100644
--- 
a/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java
+++ 
b/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java
@@ -153,6 +153,7 @@ class HistoryServerArchiveFetcher {
continue;
}
boolean updateOverview = false;
+   int numFetchedArchives = 0;
for (FileStatus jobArchive : 
jobArchives) {
Path jobArchivePath = 
jobArchive.getPath();
String jobID = 
jobArchivePath.getName();
@@ -200,7 +201,7 @@ class HistoryServerArchiveFetcher {
}
}
updateOverview 
= true;
-   
numArchivedJobs.countDown();
+   
numFetchedArchives++;
} catch (IOException e) 
{

LOG.error("Failure while fetching/processing job archive for job {}.", jobID, 
e);
// Make sure we 
attempt to fetch the archive again
@@ -224,6 +225,9 @@ class HistoryServerArchiveFetcher {
}
if (updateOverview) {

updateJobOverview(webOverviewDir, webDir);
+   for (int x = 0; x < 
numFetchedArchives; x++) {
+   
numArchivedJobs.countDown();
+   }
}
}
} catch (Exception e) {

[flink] branch master updated: [FLINK-13892][hs] Harden HistoryServerTest

2019-09-06 Thread chesnay

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

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


The following commit(s) were added to refs/heads/master by this push:
 new 878b6b1  [FLINK-13892][hs] Harden HistoryServerTest
878b6b1 is described below

commit 878b6b19e8e23d69299aa00fb48fa19c3a9116c9
Author: Chesnay Schepler 
AuthorDate: Thu Sep 5 13:40:06 2019 +0200

[FLINK-13892][hs] Harden HistoryServerTest
---
 .../runtime/webmonitor/history/HistoryServerArchiveFetcher.java | 6 +-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java
 
b/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java
index 47888cd..fed220f 100644
--- 
a/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java
+++ 
b/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java
@@ -153,6 +153,7 @@ class HistoryServerArchiveFetcher {
continue;
}
boolean updateOverview = false;
+   int numFetchedArchives = 0;
for (FileStatus jobArchive : 
jobArchives) {
Path jobArchivePath = 
jobArchive.getPath();
String jobID = 
jobArchivePath.getName();
@@ -200,7 +201,7 @@ class HistoryServerArchiveFetcher {
}
}
updateOverview 
= true;
-   
numArchivedJobs.countDown();
+   
numFetchedArchives++;
} catch (IOException e) 
{

LOG.error("Failure while fetching/processing job archive for job {}.", jobID, 
e);
// Make sure we 
attempt to fetch the archive again
@@ -224,6 +225,9 @@ class HistoryServerArchiveFetcher {
}
if (updateOverview) {

updateJobOverview(webOverviewDir, webDir);
+   for (int x = 0; x < 
numFetchedArchives; x++) {
+   
numArchivedJobs.countDown();
+   }
}
}
} catch (Exception e) {

[flink] branch release-1.8 updated: [FLINK-13936][licensing] Update NOTICE-binary

2019-09-06 Thread chesnay

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

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


The following commit(s) were added to refs/heads/release-1.8 by this push:
 new 1ebc30c  [FLINK-13936][licensing] Update NOTICE-binary
1ebc30c is described below

commit 1ebc30c5e5d9f49f4af715cedd9cf99478418f1c
Author: Chesnay Schepler 
AuthorDate: Fri Sep 6 12:08:45 2019 +0200

[FLINK-13936][licensing] Update NOTICE-binary
---
 NOTICE-binary | 1 -
 1 file changed, 1 deletion(-)

diff --git a/NOTICE-binary b/NOTICE-binary
index bde3487..321d55b 100644
--- a/NOTICE-binary
+++ b/NOTICE-binary
@@ -669,7 +669,6 @@ Copyright 2006-2019 The Apache Software Foundation
 This product includes software developed at
 The Apache Software Foundation (http://www.apache.org/).
 
-
 flink-oss-fs-hadoop
 Copyright 2014-2019 The Apache Software Foundation

[flink] branch release-1.8 updated: [FLINK-13967][licensing] Fully generate binary licensing

2019-09-06 Thread chesnay

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

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


The following commit(s) were added to refs/heads/release-1.8 by this push:
 new 863b92b  [FLINK-13967][licensing] Fully generate binary licensing
863b92b is described below

commit 863b92ba29b9f10737e0479349ba22b70a024dbd
Author: Chesnay Schepler 
AuthorDate: Wed Sep 4 15:37:07 2019 +0200

[FLINK-13967][licensing] Fully generate binary licensing
---
 tools/releasing/LICENSE.slf4j  | 21 +
 tools/releasing/NOTICE-binary_PREAMBLE.txt | 17 +
 tools/releasing/collect_license_files.sh   | 12 +---
 3 files changed, 47 insertions(+), 3 deletions(-)

diff --git a/tools/releasing/LICENSE.slf4j b/tools/releasing/LICENSE.slf4j
new file mode 100644
index 000..93119e7
--- /dev/null
+++ b/tools/releasing/LICENSE.slf4j
@@ -0,0 +1,21 @@
+Copyright (c) 2004-2017 QOS.ch
+ All rights reserved.
+
+ Permission is hereby granted, free  of charge, to any person obtaining
+ a  copy  of this  software  and  associated  documentation files  (the
+ "Software"), to  deal in  the Software without  restriction, including
+ without limitation  the rights to  use, copy, modify,  merge, publish,
+ distribute,  sublicense, and/or sell  copies of  the Software,  and to
+ permit persons to whom the Software  is furnished to do so, subject to
+ the following conditions:
+
+ The  above  copyright  notice  and  this permission  notice  shall  be
+ included in all copies or substantial portions of the Software.
+
+ THE  SOFTWARE IS  PROVIDED  "AS  IS", WITHOUT  WARRANTY  OF ANY  KIND,
+ EXPRESS OR  IMPLIED, INCLUDING  BUT NOT LIMITED  TO THE  WARRANTIES OF
+ MERCHANTABILITY,FITNESSFORA   PARTICULARPURPOSEAND
+ NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
+ LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
+ OF CONTRACT, TORT OR OTHERWISE,  ARISING FROM, OUT OF OR IN CONNECTION
+ WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
diff --git a/tools/releasing/NOTICE-binary_PREAMBLE.txt 
b/tools/releasing/NOTICE-binary_PREAMBLE.txt
new file mode 100644
index 000..d749616
--- /dev/null
+++ b/tools/releasing/NOTICE-binary_PREAMBLE.txt
@@ -0,0 +1,17 @@
+// --
+// NOTICE file corresponding to the section 4d of The Apache License,
+// Version 2.0, in this case for Apache Flink
+// --
+
+Apache Flink
+Copyright 2014-2019 The Apache Software Foundation
+
+This project bundles the following dependencies under the Apache Software 
License 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt)
+
+- log4j:log4j:1.2.17
+
+This project bundles the following dependencies under the MIT/X11 license.
+See bundled license files for details.
+
+- org.slf4j:slf4j-log4j12:1.7.15
+
diff --git a/tools/releasing/collect_license_files.sh 
b/tools/releasing/collect_license_files.sh
index 6da1733..5aa7585 100755
--- a/tools/releasing/collect_license_files.sh
+++ b/tools/releasing/collect_license_files.sh
@@ -30,6 +30,9 @@ SRC=${1:-.}
 DST=${2:-licenses-output}
 PWD=$(pwd)
 TMP="${DST}/tmp"
+DIR=$(dirname "$0")
+NOTICE_BINARY_PREAMBLE="${DIR}/NOTICE-binary_PREAMBLE.txt"
+SLF4J_LICENSE="${DIR}/LICENSE.slf4j"
 
 USAGE="collect_license_files  
"
 
@@ -46,12 +49,15 @@ do
(cd "${DIR}" && jar xf ${JAR} META-INF/NOTICE META-INF/licenses)
 done
 
-NOTICE="${DST}/NOTICE"
+NOTICE="${DST}/NOTICE-binary"
 [ -f "${NOTICE}" ] && rm "${NOTICE}"
+cp "${NOTICE_BINARY_PREAMBLE}" "${NOTICE}"
 (export LC_ALL=C; find "${TMP}" -name "NOTICE" | sort | xargs cat >> 
"${NOTICE}")
 
-LICENSES="${DST}/licenses"
-[ -f "${LICENSES}" ] && rm -r ""
+LICENSES="${DST}/licenses-binary"
+[ -f "${LICENSES}" ] && rm -r "${LICENSES}"
 find "${TMP}" -name "licenses" -type d -exec cp -r -- "{}" "${DST}" \;
+mv "${DST}/licenses" "${LICENSES}"
+cp "${SLF4J_LICENSE}" "${LICENSES}"
 
 rm -r "${TMP}"

[flink-web] branch asf-site updated (8b4af0c -> f6b28f7)

2019-09-06 Thread fhueske

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

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


from 8b4af0c  Rebuild website
 new 8c02afc  [hotfix] Fix links to ASF license and events page.
 new f6b28f7  Rebuild website

The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 _includes/navbar.html   | 15 ++-
 content/2019/05/03/pulsar-flink.html| 15 ++-
 content/2019/05/14/temporal-tables.html | 15 ++-
 content/2019/05/19/state-ttl.html   | 15 ++-
 content/2019/06/05/flink-network-stack.html | 15 ++-
 content/2019/06/26/broadcast-state.html | 15 ++-
 content/2019/07/23/flink-network-stack-2.html   | 15 ++-
 content/blog/index.html | 15 ++-
 content/blog/page2/index.html   | 15 ++-
 content/blog/page3/index.html   | 15 ++-
 content/blog/page4/index.html   | 15 ++-
 content/blog/page5/index.html   | 15 ++-
 content/blog/page6/index.html   | 15 ++-
 content/blog/page7/index.html   | 15 ++-
 content/blog/page8/index.html   | 15 ++-
 content/blog/page9/index.html   | 15 ++-
 content/blog/release_1.0.0-changelog_known_issues.html  | 15 ++-
 content/blog/release_1.1.0-changelog.html   | 15 ++-
 content/blog/release_1.2.0-changelog.html   | 15 ++-
 content/blog/release_1.3.0-changelog.html   | 15 ++-
 content/community.html  | 15 ++-
 content/contributing/code-style-and-quality-common.html | 15 ++-
 .../contributing/code-style-and-quality-components.html | 15 ++-
 .../contributing/code-style-and-quality-formatting.html | 15 ++-
 content/contributing/code-style-and-quality-java.html   | 15 ++-
 .../contributing/code-style-and-quality-preamble.html   | 15 ++-
 .../code-style-and-quality-pull-requests.html   | 15 ++-
 content/contributing/code-style-and-quality-scala.html  | 15 ++-
 content/contributing/contribute-code.html   | 15 ++-
 content/contributing/contribute-documentation.html  | 15 ++-
 content/contributing/how-to-contribute.html | 15 ++-
 content/contributing/improve-website.html   | 15 ++-
 content/contributing/reviewing-prs.html | 15 ++-
 content/documentation.html  | 15 ++-
 content/downloads.html  | 15 ++-
 content/ecosystem.html  | 15 ++-
 content/faq.html| 15 ++-
 content/features/2017/07/04/flink-rescalable-state.html | 15 ++-
 .../features/2018/01/30/incremental-checkpointing.html  | 15 ++-
 .../03/01/end-to-end-exactly-once-apache-flink.html | 15 ++-
 content/features/2019/03/11/prometheus-monitoring.html  | 15 ++-
 content/flink-applications.html | 15 ++-
 content/flink-architecture.html | 15 ++-
 content/flink-operations.html   | 15 ++-
 content/gettinghelp.html| 15 ++-
 content/index.html  | 17 +++--
 content/material.html   | 15 ++-
 content/news/2014/08/26/release-0.6.html| 15 ++-
 content/news/2014/09/26/release-0.6.1.html  | 15 ++-
 content/news/2014/10/03/upcoming_events.html| 15 ++-
 content/news/2014/11/04/release-0.7.0.html  | 15 ++-
 content/news/2014/11/18/hadoop-compatibility.html   | 15 ++-
 content/news/2015/01/06/december-in-flink.html  | 15 ++-
 content/news/2015/01/21/release-0.8.html| 15 ++-
 content/news/2015/02/04/january-in-flink.html   | 15 ++-
 content/news/2015/02/09/streaming-example.html  | 15 ++-
 content/news/2015/03/02/february-2015-in-flink.html |

[flink-web] 01/02: [hotfix] Fix links to ASF license and events page.

2019-09-06 Thread 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 8c02afc727e2770db11e0698f2de45db46f57fd0
Author: Fabian Hueske 
AuthorDate: Fri Sep 6 10:56:23 2019 +0200

[hotfix] Fix links to ASF license and events page.
---
 _includes/navbar.html | 15 ++-
 index.md  |  2 +-
 index.zh.md   |  2 +-
 3 files changed, 8 insertions(+), 11 deletions(-)

diff --git a/_includes/navbar.html b/_includes/navbar.html
index 6516e2d..148332a 100755
--- a/_includes/navbar.html
+++ b/_includes/navbar.html
@@ -153,21 +153,18 @@
 
 
   
-.smalllinks {
-  display: inline !important;
-}
-.smalllinks:hover {
-  background: none !important;
+.smalllinks:link {
+  display: inline-block !important; background: none; 
padding-top: 0px; padding-bottom: 0px; padding-right: 0px; min-width: 75px;
 }
   
 
-  https://www.apache.org/licenses/; 
target="_blank">Licenses 
+  https://www.apache.org/licenses/; 
target="_blank">License 
 
-  https://www.apache.org/security/; 
target="_blank">Security 
+  https://www.apache.org/security/; 
target="_blank">Security 
 
-  https://www.apache.org/foundation/sponsorship.html; 
target="_blank">Donate 
+  https://www.apache.org/foundation/sponsorship.html; 
target="_blank">Donate 
 
-  https://www.apache.org/foundation/thanks.html; target="_blank">Thanks 

+  https://www.apache.org/foundation/thanks.html; target="_blank">Thanks 

 
 
   
diff --git a/index.md b/index.md
index 876d494..73a37ab 100644
--- a/index.md
+++ b/index.md
@@ -328,7 +328,7 @@ layout: base
 
   
   
-  https://events.apache.org/x/current-event.html; target="_blank">
+  https://www.apache.org/events/current-event; target="_blank">
 https://www.apache.org/events/current-event-234x60.png; 
alt="ApacheCon"/>
   
 
diff --git a/index.zh.md b/index.zh.md
index 8a96b47..3b9ad46 100644
--- a/index.zh.md
+++ b/index.zh.md
@@ -322,7 +322,7 @@ layout: base
 
   
   
-  https://events.apache.org/x/current-event.html; target="_blank">
+  https://www.apache.org/events/current-event; target="_blank">
 https://www.apache.org/events/current-event-234x60.png; 
alt="ApacheCon"/>

[flink] branch master updated (0d390c1 -> 5ec02e2)

2019-09-06 Thread azagrebin

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

azagrebin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


from 0d390c1  [FLINK-13967][licensing] Fully generate binary licensing
 add 5ec02e2  [FLINK-13963][docs] Consolidate Hadoop file systems usage and 
Hadoop integration docs

No new revisions were added by this update.

Summary of changes:
 docs/dev/batch/connectors.md  | 34 -
 docs/dev/batch/connectors.zh.md   | 34 -
 docs/dev/batch/hadoop_compatibility.md|  9 +
 docs/dev/batch/hadoop_compatibility.zh.md |  9 +
 docs/ops/config.md|  2 +
 docs/ops/config.zh.md |  2 +
 docs/ops/deployment/hadoop.md | 22 ++-
 docs/ops/deployment/hadoop.zh.md  | 22 ++-
 docs/ops/filesystems/index.md | 61 +-
 docs/ops/filesystems/index.zh.md  | 63 +--
 10 files changed, 119 insertions(+), 139 deletions(-)

[flink] branch release-1.9 updated (1e88d42 -> 6acbe66)

2019-09-06 Thread chesnay

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

chesnay pushed a change to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git.


from 1e88d42  [FLINK-13937][docs] Fix the error of the hive connector 
dependency version
 add 6acbe66  [FLINK-13967][licensing] Fully generate binary licensing

No new revisions were added by this update.

Summary of changes:
 {licenses-binary => tools/releasing}/LICENSE.slf4j |  0
 tools/releasing/NOTICE-binary_PREAMBLE.txt | 17 +
 tools/releasing/collect_license_files.sh   | 12 +---
 3 files changed, 26 insertions(+), 3 deletions(-)
 copy {licenses-binary => tools/releasing}/LICENSE.slf4j (100%)
 create mode 100644 tools/releasing/NOTICE-binary_PREAMBLE.txt

[flink] branch master updated (906b630 -> 0d390c1)

2019-09-06 Thread chesnay

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

chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


from 906b630  [FLINK-13970][coordinate] Remove LifoSetQueue and SetQueue
 add 0d390c1  [FLINK-13967][licensing] Fully generate binary licensing

No new revisions were added by this update.

Summary of changes:
 {licenses-binary => tools/releasing}/LICENSE.slf4j |  0
 tools/releasing/NOTICE-binary_PREAMBLE.txt | 17 +
 tools/releasing/collect_license_files.sh   | 12 +---
 3 files changed, 26 insertions(+), 3 deletions(-)
 copy {licenses-binary => tools/releasing}/LICENSE.slf4j (100%)
 create mode 100644 tools/releasing/NOTICE-binary_PREAMBLE.txt

[flink] branch master updated (1d53e8d -> 906b630)

2019-09-06 Thread trohrmann

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

trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


from 1d53e8d  [FLINK-13868][rest] Job vertex add taskmanager id in rest api
 add 906b630  [FLINK-13970][coordinate] Remove LifoSetQueue and SetQueue

No new revisions were added by this update.

Summary of changes:
 .../runtime/jobmanager/scheduler/LifoSetQueue.java | 113 -
 .../runtime/jobmanager/scheduler/SetQueue.java | 134 -
 .../jobmanager/scheduler/LifoSetQueueTest.java | 128 
 .../runtime/jobmanager/scheduler/SetQueueTest.java | 110 -
 4 files changed, 485 deletions(-)
 delete mode 100644 
flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler/LifoSetQueue.java
 delete mode 100644 
flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler/SetQueue.java
 delete mode 100644 
flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/scheduler/LifoSetQueueTest.java
 delete mode 100644 
flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/scheduler/SetQueueTest.java

[flink] branch master updated (a453bf6 -> 1d53e8d)

2019-09-06 Thread trohrmann

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

trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


from a453bf6  [FLINK-13977] Let HighAvailabilityServices implementations 
implement getClusterRestEndpointLeaderElectionService
 add 1d53e8d  [FLINK-13868][rest] Job vertex add taskmanager id in rest api

No new revisions were added by this update.

Summary of changes:
 docs/_includes/generated/rest_v1_dispatcher.html   |  9 +
 .../src/test/resources/rest_api_v1.snapshot|  9 +
 .../rest/handler/job/JobVertexDetailsHandler.java  |  4 +++-
 .../rest/messages/JobVertexDetailsInfo.java| 13 ++---
 .../job/SubtaskExecutionAttemptDetailsInfo.java| 22 ++
 .../SubtaskCurrentAttemptDetailsHandlerTest.java   |  3 ++-
 .../SubtaskExecutionAttemptDetailsHandlerTest.java |  3 ++-
 .../rest/messages/JobVertexDetailsInfoTest.java|  9 ++---
 .../SubtaskExecutionAttemptDetailsInfoTest.java|  3 ++-
 9 files changed, 61 insertions(+), 14 deletions(-)

[flink] branch master updated (a72b238 -> a453bf6)

2019-09-06 Thread trohrmann

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

trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


from a72b238  [FLINK-13964] Replace #getWebMonitorLeaderRetriever 
implementations with #getClusterRestEndpointLeaderRetriever
 add d047c47  [FLINK-13977] Replace 
HighAvailabilityServices#getWebMonitorLeaderElectionService with 
#getClusterRestEndpointLeaderElectionService
 add a453bf6  [FLINK-13977] Let HighAvailabilityServices implementations 
implement getClusterRestEndpointLeaderElectionService

No new revisions were added by this update.

Summary of changes:
 ...tDispatcherResourceManagerComponentFactory.java |  2 +-
 .../highavailability/HighAvailabilityServices.java | 27 +-
 .../nonha/embedded/EmbeddedHaServices.java | 12 +-
 .../nonha/standalone/StandaloneHaServices.java |  2 +-
 .../zookeeper/ZooKeeperHaServices.java |  2 +-
 .../TestingHighAvailabilityServices.java   | 10 
 .../TestingHighAvailabilityServicesBuilder.java|  2 +-
 .../TestingManualHighAvailabilityServices.java | 10 
 .../YarnIntraNonHaMasterServices.java  |  2 +-
 .../YarnPreConfiguredMasterNonHaServices.java  |  2 +-
 10 files changed, 48 insertions(+), 23 deletions(-)

[flink] branch master updated (d2957bd -> a72b238)

2019-09-06 Thread trohrmann

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

trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


from d2957bd  [FLINK-13960] Add throwing 
HighAvailabilityServices#getWebMonitorLeaderRetriever default impl
 add 06fc5ce  [FLINK-13964] Let HighAvailabilityServices create cluster and 
client side HA services
 add 51d939b  [hotfix] Remove code duplication in 
HighAvailabilityServicesUtils
 add a72b238  [FLINK-13964] Replace #getWebMonitorLeaderRetriever 
implementations with #getClusterRestEndpointLeaderRetriever

No new revisions were added by this update.

Summary of changes:
 .../concurrent/UnsupportedOperationExecutor.java}  | 17 ---
 .../highavailability/HighAvailabilityServices.java | 20 +++--
 .../HighAvailabilityServicesFactory.java   | 18 ++--
 .../HighAvailabilityServicesUtils.java | 25 +++---
 .../nonha/embedded/EmbeddedHaServices.java |  2 +-
 .../nonha/standalone/StandaloneHaServices.java | 12 +--
 .../zookeeper/ZooKeeperHaServices.java |  2 +-
 .../flink/runtime/minicluster/MiniCluster.java | 12 +--
 .../TestingHighAvailabilityServices.java   | 10 -
 .../TestingHighAvailabilityServicesBuilder.java|  2 +-
 .../TestingManualHighAvailabilityServices.java |  2 +-
 .../YarnIntraNonHaMasterServices.java  |  2 +-
 .../YarnPreConfiguredMasterNonHaServices.java  |  2 +-
 13 files changed, 60 insertions(+), 66 deletions(-)
 copy 
flink-runtime/src/{test/java/org/apache/flink/runtime/checkpoint/NoOpFailJobCall.java
 => 
main/java/org/apache/flink/runtime/concurrent/UnsupportedOperationExecutor.java}
 (64%)

[flink] branch master updated (60cf41a -> d2957bd)

2019-09-06 Thread trohrmann

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

trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


from 60cf41a  [FLINK-13591][web] fix job list display when job name is very 
long
 add e3a848c  [hotfix] Fix checkstyle violations in HighAvailabilityServices
 add d2957bd  [FLINK-13960] Add throwing 
HighAvailabilityServices#getWebMonitorLeaderRetriever default impl

No new revisions were added by this update.

Summary of changes:
 .../highavailability/HighAvailabilityServices.java   | 16 +++-
 1 file changed, 11 insertions(+), 5 deletions(-)

43 matches

Mail list logo