[5/6] flink git commit: [FLINK-6996] [kafka] Fix at-least-once semantic for FlinkKafkaProducer010

[FLINK-6996] [kafka] Fix at-least-once semantic for FlinkKafkaProducer010 This closes #4206. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6630dfdd Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6630dfdd Diff: http

[4/6] flink git commit: [FLINK-7041] Deserialize StateBackend from JobCheckpointingSettings with user classloader

[FLINK-7041] Deserialize StateBackend from JobCheckpointingSettings with user classloader This closes #4232. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/78bbb844 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/78

[6/6] flink git commit: [FLINK-6422] [core] Unreachable code in FileInputFormat#createInputSplits

[FLINK-6422] [core] Unreachable code in FileInputFormat#createInputSplits This closes #4202. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/530a4d1f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/530a4d1f Diff: http

[2/6] flink git commit: [FLINK-7038] [docs] Correct misused term (KeyedDataStream -> KeyedStream)

[FLINK-7038] [docs] Correct misused term (KeyedDataStream -> KeyedStream) Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7ca13f2f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7ca13f2f Diff: http://git-wip-us.apache

[3/6] flink git commit: [FLINK-7038] Correct misused terms (WindowedDataStream, JoinedDataStream)

[FLINK-7038] Correct misused terms (WindowedDataStream, JoinedDataStream) This closes #4229. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0c9a0b96 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0c9a0b96 Diff: http

[1/6] flink git commit: [hotfix] [docs] Added missing "more" word to programming-model docs.

Repository: flink Updated Branches: refs/heads/release-1.3 5f4296ee8 -> 530a4d1f6 [hotfix] [docs] Added missing "more" word to programming-model docs. This closes #4244. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b7f

[5/7] flink git commit: [FLINK-7038] Correct misused terms (WindowedDataStream, JoinedDataStream)

[FLINK-7038] Correct misused terms (WindowedDataStream, JoinedDataStream) This closes #4229. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5c6d7970 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5c6d7970 Diff: http

[4/7] flink git commit: [hotfix] [docs] Added missing "more" word to programming-model docs.

[hotfix] [docs] Added missing "more" word to programming-model docs. This closes #4244. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/07186aad Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/07186aad Diff: http://gi

[6/7] flink git commit: [FLINK-6996] [kafka] Fix at-least-once semantic for FlinkKafkaProducer010

[FLINK-6996] [kafka] Fix at-least-once semantic for FlinkKafkaProducer010 This closes #4206. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/21ec86f0 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/21ec86f0 Diff: http

[1/7] flink git commit: [FLINK-6422] [core] Unreachable code in FileInputFormat#createInputSplits

Repository: flink Updated Branches: refs/heads/master 546e9a77e -> 6eae45ea8 [FLINK-6422] [core] Unreachable code in FileInputFormat#createInputSplits This closes #4202. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6ea

[2/7] flink git commit: [FLINK-6499] [config] Migrate state configuration options

[FLINK-6499] [config] Migrate state configuration options This closes #4173. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/10f50698 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/10f50698 Diff: http://git-wip-us.ap

[7/7] flink git commit: [FLINK-7041] Deserialize StateBackend from JobCheckpointingSettings with user classloader

[FLINK-7041] Deserialize StateBackend from JobCheckpointingSettings with user classloader This closes #4232. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/78303d4e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/78

[3/7] flink git commit: [FLINK-7038] [docs] Correct misused term (KeyedDataStream -> KeyedStream)

[FLINK-7038] [docs] Correct misused term (KeyedDataStream -> KeyedStream) Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/02039f64 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/02039f64 Diff: http://git-wip-us.apache

[5/6] flink git commit: [FLINK-7006] [gelly] Base class using POJOs for Gelly algorithms

http://git-wip-us.apache.org/repos/asf/flink/blob/98a15004/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/clustering/undirected/TriangleListing.java -- diff --git a/flink-libraries/flink-gelly/src/main/ja

[2/6] flink git commit: [FLINK-6879] [runtime] Activate checkstyle for runtime/memory

[FLINK-6879] [runtime] Activate checkstyle for runtime/memory This closes #4097 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7c150a6f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7c150a6f Diff: http://git-wip-us

[6/6] flink git commit: [FLINK-7006] [gelly] Base class using POJOs for Gelly algorithms

[FLINK-7006] [gelly] Base class using POJOs for Gelly algorithms Gelly algorithms commonly have a Result class extending a Tuple type and implementing one of the Unary/Binary/TertiaryResult interfaces. Add a Unary/Binary/TertiaryResultBase class implementing each interface and convert the Result

[1/6] flink git commit: [FLINK-7045] [tests] Reduce element count of UdfStreamOperatorCheckpointingITCase

Repository: flink Updated Branches: refs/heads/master 57c675ea5 -> 546e9a77e [FLINK-7045] [tests] Reduce element count of UdfStreamOperatorCheckpointingITCase This closes #4230 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/co

[3/6] flink git commit: [FLINK-7023] [gelly] Remaining types for Gelly ValueArrays

http://git-wip-us.apache.org/repos/asf/flink/blob/546e9a77/flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/ShortValueArray.java -- diff --git a/flink-libraries/flink-gelly/src/main/java/org/apache

[4/6] flink git commit: [FLINK-7023] [gelly] Remaining types for Gelly ValueArrays

[FLINK-7023] [gelly] Remaining types for Gelly ValueArrays Add implementations of Byte/Char/Double/Float/ShortValueArray. Along with the existing implementations of Int/Long/Null/StringValueArray this covers all 10 CopyableValue types. This closes #4203 Project: http://git-wip-us.apache.org/rep

flink git commit: [FLINK-6925] [table] Add CONCAT/CONCAT_WS supported in SQL

Repository: flink Updated Branches: refs/heads/master 9c4676414 -> 57c675ea5 [FLINK-6925] [table] Add CONCAT/CONCAT_WS supported in SQL This closes #4138 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/57c675ea Tree: http

flink git commit: [FLINK-7097] [scripts] Enable Flip-6 TaskExecutor to be started with taskmanager.sh

Repository: flink Updated Branches: refs/heads/master 40dce2909 -> 9c4676414 [FLINK-7097] [scripts] Enable Flip-6 TaskExecutor to be started with taskmanager.sh The taskmanager.sh script now supports to start a TaskExecutor by providing flip6 as a second argument to the script. This closes

flink git commit: [FLINK-7074] [tm] Add entry point for the TaskManagerRunner

Repository: flink Updated Branches: refs/heads/master 1ba1260a8 -> 40dce2909 [FLINK-7074] [tm] Add entry point for the TaskManagerRunner The entry point can be used by the standalone mode to run a TaskManager. Moreover, the YarnTaskExecutorRunner now reuses some of the start up logic of the

flink git commit: [FLINK-7093] [tm] Send SlotReport as part of the heartbeat payload to the ResourceManager

Repository: flink Updated Branches: refs/heads/master 3fc96cd1f -> 1ba1260a8 [FLINK-7093] [tm] Send SlotReport as part of the heartbeat payload to the ResourceManager The TaskManager sends the SlotReport as part of the heartbeat payload to the ResourceManager. That way, the ResourceManager c

[3/3] flink git commit: [FLINK-7061] [cep] Fix quantifier range starting from 0

[FLINK-7061] [cep] Fix quantifier range starting from 0 This closes #4242 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3fc96cd1 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3fc96cd1 Diff: http://git-wip-us.apach

[1/3] flink git commit: [FLINK-6927] [cep] Support pattern group in CEP

Repository: flink Updated Branches: refs/heads/master 4d18afed8 -> 3fc96cd1f http://git-wip-us.apache.org/repos/asf/flink/blob/3096bd03/flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/GroupITCase.java -- diff -

[2/3] flink git commit: [FLINK-6927] [cep] Support pattern group in CEP

[FLINK-6927] [cep] Support pattern group in CEP This closes #4153 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3096bd03 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3096bd03 Diff: http://git-wip-us.apache.org/re

svn commit: r20303 - /release/flink/KEYS

Author: aljoscha Date: Wed Jul 5 07:19:48 2017 New Revision: 20303 Log: Add aljoscha to dist/release/flink/KEYS Modified: release/flink/KEYS Modified: release/flink/KEYS == --- release/flink/KEYS (original) +++ rele