flink git commit: [FLINK-5998] Un-fat Hadoop from Flink fat jar.

Repository: flink Updated Branches: refs/heads/master 981dea41e -> 43fa50713 [FLINK-5998] Un-fat Hadoop from Flink fat jar. This closes #3604 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/43fa5071 Tree: http://git-wip-u

[1/2] flink-web git commit: fix mis-spelling real-word to real-world.

Repository: flink-web Updated Branches: refs/heads/asf-site 6cc3ed960 -> 0ad8f45f2 fix mis-spelling real-word to real-world. Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/eda6843b Tree: http://git-wip-us.apache.o

[2/2] flink-web git commit: Rebuild page This closes #57

Rebuild page This closes #57 Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/0ad8f45f Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/0ad8f45f Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/0ad

[2/2] flink-web git commit: Rebuild site

Rebuild site This closes #56 Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/ef6fbe8f Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/ef6fbe8f Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/ef

[1/2] flink-web git commit: Update hadoop version

Repository: flink-web Updated Branches: refs/heads/asf-site 0ad8f45f2 -> ef6fbe8fd Update hadoop version Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/9ac902fd Tree: http://git-wip-us.apache.org/repos/asf/flink-w

[2/2] flink-web git commit: Update trademark disclaimer and year

Update trademark disclaimer and year Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/b563976f Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/b563976f Diff: http://git-wip-us.apache.org/repos/asf/flink-web/

[1/2] flink-web git commit: Update trademark disclaimer and year

Repository: flink-web Updated Branches: refs/heads/asf-site ef6fbe8fd -> b563976f8 http://git-wip-us.apache.org/repos/asf/flink-web/blob/b563976f/content/privacy-policy.html -- diff --git a/content/privacy-policy.html b/content

[2/2] flink git commit: [FLINK-5718] [core] TaskManagers exit the JVM on fatal exceptions.

[FLINK-5718] [core] TaskManagers exit the JVM on fatal exceptions. Manually applied and adapted commit dfc6fba5b9830e6a7804a6a0c9f69b36bf772730 for the `release-1.2` branch. This closes #3811. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/

[1/2] flink git commit: [FLINK-5718] [core] Remove unnecessary configuration parameters

Repository: flink Updated Branches: refs/heads/release-1.2 852a710b4 -> 52b6e2fda [FLINK-5718] [core] Remove unnecessary configuration parameters Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/52b6e2fd Tree: http://git-wi

[13/16] flink git commit: [FLINK-6217] Fix ContaineredTaskManagerParametersTest to properly test off heap settings

[FLINK-6217] Fix ContaineredTaskManagerParametersTest to properly test off heap settings Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b1f18642 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b1f18642 Diff: http://g

[14/16] flink git commit: [FLINK-6217] ContaineredTaskManagerParameters sets off-heap memory size incorrectly.

[FLINK-6217] ContaineredTaskManagerParameters sets off-heap memory size incorrectly. This closes #3648. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5cf22f41 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5cf22f4

[09/16] flink git commit: [FLINK-6078] Remove CuratorFramework#close calls from ZooKeeper based HA services

http://git-wip-us.apache.org/repos/asf/flink/blob/ddd6a99a/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala -- diff --git a/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManag

[02/16] flink git commit: [FLINK-6136] Separate EmbeddedHaServices and StandaloneHaServices

http://git-wip-us.apache.org/repos/asf/flink/blob/a0bb99c7/flink-runtime/src/main/java/org/apache/flink/runtime/util/LeaderRetrievalUtils.java -- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/util/LeaderRetriev

[16/16] flink git commit: [FLINK-5974] [mesos] Make mesos service name configurable for dns lookups

[FLINK-5974] [mesos] Make mesos service name configurable for dns lookups Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d7364fff Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d7364fff Diff: http://git-wip-us.apache

[12/16] flink git commit: [FLINK-6435] [async] React to exceptionally completed StreamElementQueueEntry

[FLINK-6435] [async] React to exceptionally completed StreamElementQueueEntry The AsyncWaitOperator should not only react to orderly completed StreamElementQueueEntries but also to those completed with a user exception or those which timed out. This PR fixes the problem by calling the onComplete

[05/16] flink git commit: [FLINK-6078] Remove CuratorFramework#close calls from ZooKeeper based HA services

http://git-wip-us.apache.org/repos/asf/flink/blob/ddd6a99a/flink-tests/src/test/java/org/apache/flink/test/recovery/ProcessFailureCancelingITCase.java -- diff --git a/flink-tests/src/test/java/org/apache/flink/test/recovery/Proces

[07/16] flink git commit: [FLINK-6078] Remove CuratorFramework#close calls from ZooKeeper based HA services

http://git-wip-us.apache.org/repos/asf/flink/blob/ddd6a99a/flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskManagerRegistrationTest.java -- diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/task

[10/16] flink git commit: [FLINK-6078] Remove CuratorFramework#close calls from ZooKeeper based HA services

http://git-wip-us.apache.org/repos/asf/flink/blob/ddd6a99a/flink-libraries/flink-python/src/test/resources/log4j-test.properties -- diff --git a/flink-libraries/flink-python/src/test/resources/log4j-test.properties b/flink-librar

[06/16] flink git commit: [FLINK-6078] Remove CuratorFramework#close calls from ZooKeeper based HA services

http://git-wip-us.apache.org/repos/asf/flink/blob/ddd6a99a/flink-tests/src/test/java/org/apache/flink/test/accumulators/AccumulatorErrorITCase.java -- diff --git a/flink-tests/src/test/java/org/apache/flink/test/accumulators/Accum

[08/16] flink git commit: [FLINK-6078] Remove CuratorFramework#close calls from ZooKeeper based HA services

http://git-wip-us.apache.org/repos/asf/flink/blob/ddd6a99a/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobManagerTest.java -- diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobMana

[11/16] flink git commit: [FLINK-6078] Remove CuratorFramework#close calls from ZooKeeper based HA services

[FLINK-6078] Remove CuratorFramework#close calls from ZooKeeper based HA services Remove client less factory methods from ZooKeeperUtils Introduce default job id This closes #3781. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/

[01/16] flink git commit: [FLINK-6136] Separate EmbeddedHaServices and StandaloneHaServices

Repository: flink Updated Branches: refs/heads/master 43fa50713 -> d7364fffb http://git-wip-us.apache.org/repos/asf/flink/blob/a0bb99c7/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNHighAvailabilityITCase.java -- dif

[04/16] flink git commit: [FLINK-6136] Separate EmbeddedHaServices and StandaloneHaServices

[FLINK-6136] Separate EmbeddedHaServices and StandaloneHaServices This PR introduces a standalone high availability services implementation which can be used in a distributed setting with no HA guarantees. Additionally, it introduces a common base class which is also used by the EmbeddedHaServic

[15/16] flink git commit: [FLINK-5974] [mesos] Added configurations to support mesos-dns hostname resolution

[FLINK-5974] [mesos] Added configurations to support mesos-dns hostname resolution This closes #3692. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1e53b75e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1e53b75e

[03/16] flink git commit: [FLINK-6136] Separate EmbeddedHaServices and StandaloneHaServices

http://git-wip-us.apache.org/repos/asf/flink/blob/a0bb99c7/flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/nonha/NonHaRegistry.java -- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/highava

[1/2] flink git commit: [FLINK-3320] Add NOT pattern support to CEP's pattern API

Repository: flink Updated Branches: refs/heads/master d7364fffb -> 5795ebe18 http://git-wip-us.apache.org/repos/asf/flink/blob/5795ebe1/flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/pattern/PatternTest.java -- di

[2/2] flink git commit: [FLINK-3320] Add NOT pattern support to CEP's pattern API

[FLINK-3320] Add NOT pattern support to CEP's pattern API NOT patterns are not yet supported when an OPTIONAL pattern directly preceeds a NOT. In these cases, an exception is thrown that proposes an alternative (but not the most efficient) way to support these patterns. Project: http://git-wip-u

[2/2] flink-web git commit: Rebuild website

Rebuild website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/4fc16962 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/4fc16962 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/4fc16962 Branch

[1/2] flink-web git commit: Reword ambiguous "Hadoop 2 version" from downloads page

Repository: flink-web Updated Branches: refs/heads/asf-site b563976f8 -> 4fc169624 Reword ambiguous "Hadoop 2 version" from downloads page Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/1452aaca Tree: http://git-w

[1/2] flink git commit: [FLINK-6364] [checkpoint] Additional minor review changes

Repository: flink Updated Branches: refs/heads/master 5795ebe18 -> 8ba5c7a37 [FLINK-6364] [checkpoint] Additional minor review changes Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8ba5c7a3 Tree: http://git-wip-us.apache

[2/2] flink git commit: [FLINK-6364] [checkpoint] Incremental checkpointing in RocksDBKeyedStateBackend

[FLINK-6364] [checkpoint] Incremental checkpointing in RocksDBKeyedStateBackend Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6e94cf19 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6e94cf19 Diff: http://git-wip-us.

flink git commit: [FLINK-6463] [cep] Throw exception when NOT-NEXT is after OPTIONAL.

Repository: flink Updated Branches: refs/heads/master 8ba5c7a37 -> 28ab73750 [FLINK-6463] [cep] Throw exception when NOT-NEXT is after OPTIONAL. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/28ab7375 Tree: http://git-wip

[13/15] flink git commit: [FLINK-6093] [table] Implement and turn on retraction for table sinks.

[FLINK-6093] [table] Implement and turn on retraction for table sinks. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bfed279f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/bfed279f Diff: http://git-wip-us.apache.or

[03/15] flink git commit: [FLINK-5884] [table] Integrate time indicators for Table API & SQL

http://git-wip-us.apache.org/repos/asf/flink/blob/495f104b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala -- diff --git a/flink-libraries/flink-table/src/main/

[08/15] flink git commit: [FLINK-6216] [table] Add non-windowed GroupBy aggregation for streams.

http://git-wip-us.apache.org/repos/asf/flink/blob/8f78824b/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/GroupWindowAggregationsITCase.scala -- diff --git a/flink-libraries/flink-table/sr

[10/15] flink git commit: [FLINK-6091] [table] Implement and turn on retraction for non-windowed aggregates.

http://git-wip-us.apache.org/repos/asf/flink/blob/27bf4cab/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/TableEnvironmentTest.scala -- diff --git a/flink-libraries/flink-table/src/test/scala/org/apache/flink/ta

[14/15] flink git commit: [FLINK-6093] [table] Add stream TableSinks and DataStream conversion with support for retraction.

http://git-wip-us.apache.org/repos/asf/flink/blob/f37988c1/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sinks/CsvTableSink.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/tabl

[05/15] flink git commit: [FLINK-5884] [table] Integrate time indicators for Table API & SQL

[FLINK-5884] [table] Integrate time indicators for Table API & SQL This closes #3808. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/495f104b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/495f104b Diff: http://git-

[01/15] flink git commit: [FLINK-5884] [table] Integrate time indicators for Table API & SQL

Repository: flink Updated Branches: refs/heads/master 28ab73750 -> f37988c19 http://git-wip-us.apache.org/repos/asf/flink/blob/495f104b/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/GroupWindowTest.scala

[02/15] flink git commit: [FLINK-5884] [table] Integrate time indicators for Table API & SQL

http://git-wip-us.apache.org/repos/asf/flink/blob/495f104b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/validate/FunctionCatalog.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flin

[12/15] flink git commit: [FLINK-6091] [table] Implement and turn on retraction for non-windowed aggregates.

[FLINK-6091] [table] Implement and turn on retraction for non-windowed aggregates. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/27bf4cab Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/27bf4cab Diff: http://git-wip

[15/15] flink git commit: [FLINK-6093] [table] Add stream TableSinks and DataStream conversion with support for retraction.

[FLINK-6093] [table] Add stream TableSinks and DataStream conversion with support for retraction. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f37988c1 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f37988c1 Diff:

[06/15] flink git commit: [FLINK-6090] [table] Add RetractionRules for annotating AccMode to DataStreamRel nodes.

[FLINK-6090] [table] Add RetractionRules for annotating AccMode to DataStreamRel nodes. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dc54abc6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/dc54abc6 Diff: http://gi

[11/15] flink git commit: [FLINK-6091] [table] Implement and turn on retraction for non-windowed aggregates.

http://git-wip-us.apache.org/repos/asf/flink/blob/27bf4cab/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/CRowInputMapRunner.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/fl

[04/15] flink git commit: [FLINK-5884] [table] Integrate time indicators for Table API & SQL

http://git-wip-us.apache.org/repos/asf/flink/blob/495f104b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/fieldExpression.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/f

[09/15] flink git commit: [FLINK-6216] [table] Add non-windowed GroupBy aggregation for streams.

[FLINK-6216] [table] Add non-windowed GroupBy aggregation for streams. This closes #3646. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8f78824b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8f78824b Diff: http://

[07/15] flink git commit: [FLINK-5884] [table] Integrate time indicators for Table API & SQL. Continued

[FLINK-5884] [table] Integrate time indicators for Table API & SQL. Continued Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/24bf61ce Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/24bf61ce Diff: http://git-wip-us.ap

[flink] Git Push Summary

Repository: flink Updated Branches: refs/heads/table-retraction [deleted] e265620d4