[1/2] flink git commit: [FLINK-5625] [kinesis] Configurable date format for timestamp-based start position in FlinkKinesisConsumer

Repository: flink Updated Branches: refs/heads/master ee033c903 -> 193224017 [FLINK-5625] [kinesis] Configurable date format for timestamp-based start position in FlinkKinesisConsumer This closes #3651. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[02/50] [abbrv] flink git commit: [FLINK-5067][hotfix] Fix snapshot deployment

[FLINK-5067][hotfix] Fix snapshot deployment Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/64c7b119 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/64c7b119 Diff:

[11/50] [abbrv] flink git commit: [hotfix] Fix various small issues in WindowOperatorContractTest

[hotfix] Fix various small issues in WindowOperatorContractTest Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/25d52e4d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/25d52e4d Diff:

[26/50] [abbrv] flink git commit: [FLINK-5698] [table] Add NestedFieldsProjectableTableSource interface.

[FLINK-5698] [table] Add NestedFieldsProjectableTableSource interface. This closes #3269. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5c37e55c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5c37e55c Diff:

[35/50] [abbrv] flink git commit: comments

comments Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ad21a441 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ad21a441 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ad21a441 Branch:

[37/50] [abbrv] flink git commit: [FLINK-6034] [checkpoints] Introduce KeyedStateHandle abstraction for the snapshots in keyed streams

http://git-wip-us.apache.org/repos/asf/flink/blob/cd552741/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/OperatorSnapshotResult.java -- diff --git

[09/50] [abbrv] flink git commit: [hotfix][scripts] Fix zookeeper quorum regex

[hotfix][scripts] Fix zookeeper quorum regex Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3e860b40 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3e860b40 Diff:

[50/50] [abbrv] flink git commit: [FLINK-5653] [table] Add processing-time OVER ROWS BETWEEN x PRECEDING aggregation to SQL.

[FLINK-5653] [table] Add processing-time OVER ROWS BETWEEN x PRECEDING aggregation to SQL. This closes #3653. This closes #3574. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ee033c90 Tree:

[29/50] [abbrv] flink git commit: [hotfix] Make GC test more strict in WindowOperatorContractTest

[hotfix] Make GC test more strict in WindowOperatorContractTest Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/662ed33d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/662ed33d Diff:

[17/50] [abbrv] flink git commit: [FLINK-6182] Fix possible NPE in SourceStreamTask

[FLINK-6182] Fix possible NPE in SourceStreamTask This closes #3606. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4b19e272 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4b19e272 Diff:

[49/50] [abbrv] flink git commit: [FLINK-6200] [table] Add support for unbounded event-time OVER RANGE window.

[FLINK-6200] [table] Add support for unbounded event-time OVER RANGE window. This closes #3649. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/44f9c76a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/44f9c76a Diff:

[23/50] [abbrv] flink git commit: [FLINK-5570] [table] Register ExternalCatalogs in TableEnvironment.

[FLINK-5570] [table] Register ExternalCatalogs in TableEnvironment. This closes #3409. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/135a57c4 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/135a57c4 Diff:

[16/50] [abbrv] flink git commit: [hotfix] Remove validateRunsInMainThread from TaskExecutor to fix TaskExecutorTest

[hotfix] Remove validateRunsInMainThread from TaskExecutor to fix TaskExecutorTest Currently, the TestingSerialRpcService does not play well together with the MainThreadValidatorUtil which assumes that rpc calls are dispatched to a mailbox from where they are picked up. In order to support the

[44/50] [abbrv] flink git commit: [hotfix] [dist. coordination] Move metrics out of the Execution Graph

[hotfix] [dist. coordination] Move metrics out of the Execution Graph ExecutionGraph-based metrics should be in their own package 'org.apache.flink.runtime.executiongraph.metrics'. They are instantiated by whoever builds the execution graph, but not by the execution graph itself. This separates

[18/50] [abbrv] flink git commit: [FLINK-5890] [gelly] GatherSumApply broken when object reuse enabled

[FLINK-5890] [gelly] GatherSumApply broken when object reuse enabled The initial fix for this ticket is not working on larger data sets. Reduce supports returning the left input, right input, a new object, or a locally reused object. The trouble with the initial fix was that the returned local

[41/50] [abbrv] flink git commit: [hotfix] [dist. coordination] Small code cleanups in ExecutionGraph and related classes

[hotfix] [dist. coordination] Small code cleanups in ExecutionGraph and related classes Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/874d9565 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/874d9565 Diff:

[20/50] [abbrv] flink git commit: [FLINK-5658] [table] Add event-time OVER ROWS/RANGE UNBOUNDED PRECEDING aggregation to SQL.

[FLINK-5658] [table] Add event-time OVER ROWS/RANGE UNBOUNDED PRECEDING aggregation to SQL. This closes #3386. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fe2c61a2 Tree:

[48/50] [abbrv] flink git commit: [FLINK-6165] [cep] Implement internal continuity for looping states.

[FLINK-6165] [cep] Implement internal continuity for looping states. Allows looping states (oneOrMore, zeroOrMore, times) to specify if they want their elements to be consecutive or allow non-matching elements in-between. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[05/50] [abbrv] flink git commit: [FLINK-3318] Add support for quantifiers to CEP's pattern API

http://git-wip-us.apache.org/repos/asf/flink/blob/9001c4ef/flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java -- diff --git

[36/50] [abbrv] flink git commit: [FLINK-6207] Duplicate TypeSerializers for async snapshots of CopyOnWriteStateTable

[FLINK-6207] Duplicate TypeSerializers for async snapshots of CopyOnWriteStateTable Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/89866a5a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/89866a5a Diff:

[22/50] [abbrv] flink git commit: [hotfix] [table] Improved code documentation for external catalog.

[hotfix] [table] Improved code documentation for external catalog. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f97deaa9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f97deaa9 Diff:

[10/50] [abbrv] flink git commit: [FLINK-6129] [metrics] Stop query actor of MetricRegistry

[FLINK-6129] [metrics] Stop query actor of MetricRegistry This PR properly shuts down the query actor of the MetricRegistry upon shut down. Add locking to the MetricRegistry This closes #3573. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[33/50] [abbrv] flink git commit: [FLINK-6197] [cep] Add support for iterative conditions.

http://git-wip-us.apache.org/repos/asf/flink/blob/7fbdc100/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/conditions/OrCondition.java -- diff --git

[38/50] [abbrv] flink git commit: [FLINK-6034] [checkpoints] Introduce KeyedStateHandle abstraction for the snapshots in keyed streams

[FLINK-6034] [checkpoints] Introduce KeyedStateHandle abstraction for the snapshots in keyed streams Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cd552741 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cd552741

[24/50] [abbrv] flink git commit: [FLINK-6089] [table] Add decoration phase for stream queries to rewrite plans after the cost-based optimization.

[FLINK-6089] [table] Add decoration phase for stream queries to rewrite plans after the cost-based optimization. This closes #3564. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6949c8c7 Tree:

[31/50] [abbrv] flink git commit: [FLINK-5911] [gelly] Command-line parameters

[FLINK-5911] [gelly] Command-line parameters Create interface for parsing command-line parameters using ParameterTool and generic implementations for boolean, long, double, string, choice. This closes #3433 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[34/50] [abbrv] flink git commit: [FLINK-6197] [cep] Add support for iterative conditions.

[FLINK-6197] [cep] Add support for iterative conditions. So far, the where clause only supported simple FilterFunction conditions. With this, we add support for conditions where an event is accepted not only based on its own properties, e.g. name, as it was before, but also based on some

[47/50] [abbrv] flink git commit: [FLINK-5655] [table] Add event-time OVER RANGE BETWEEN x PRECEDING aggregation to SQL.

[FLINK-5655] [table] Add event-time OVER RANGE BETWEEN x PRECEDING aggregation to SQL. This closes #3629. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d4665a00 Tree:

[32/50] [abbrv] flink git commit: [FLINK-6197] [cep] Add support for iterative conditions.

http://git-wip-us.apache.org/repos/asf/flink/blob/7fbdc100/flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/pattern/PatternTest.java -- diff --git

[40/50] [abbrv] flink git commit: [hotfix] [dist. coordination] Clean up exception signature of ExecutionGraph

[hotfix] [dist. coordination] Clean up exception signature of ExecutionGraph Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/231bec8d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/231bec8d Diff:

[46/50] [abbrv] flink git commit: [hotfix] [dist. coordination] Remove redundant method 'ExecutionVertex.getSimpleName()'

[hotfix] [dist. coordination] Remove redundant method 'ExecutionVertex.getSimpleName()' Replace the method via identical method 'getTaskNameWithSubtaskIndex'. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ca681101 Tree:

[42/50] [abbrv] flink git commit: [hotfix] [dist. coordination] Add safety check for execution graph state transitions

[hotfix] [dist. coordination] Add safety check for execution graph state transitions Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/60895a3c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/60895a3c Diff:

[45/50] [abbrv] flink git commit: [FLINK-5340] [metrics] Add an uptime and downtime metric to the Execution Graph.

[FLINK-5340] [metrics] Add an uptime and downtime metric to the Execution Graph. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/719d0cf1 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/719d0cf1 Diff:

[14/50] [abbrv] flink git commit: [FLINK-6018] Add tests for KryoSerializer restore with registered types

http://git-wip-us.apache.org/repos/asf/flink/blob/09164cf2/flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java -- diff --git

[01/50] [abbrv] flink git commit: [FLINK-6139] [build] Add "mapr" build profile

Repository: flink Updated Branches: refs/heads/table-retraction d160b5e56 -> ee033c903 [FLINK-6139] [build] Add "mapr" build profile This build profile is for building Flink to be compatible with MapR. It additionally excludes dependency clashes between MapR's Hadoop / Zookeeper distributions

[43/50] [abbrv] flink git commit: [hotfix] [dist. coordination] Fix waiting for execution termination

[hotfix] [dist. coordination] Fix waiting for execution termination Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/85f75a59 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/85f75a59 Diff:

[03/50] [abbrv] flink git commit: [FLINK-6170] [metrics] Don't rely on stats snapshot for checkpoint metrics

[FLINK-6170] [metrics] Don't rely on stats snapshot for checkpoint metrics This closes #3597. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d0695c05 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d0695c05 Diff:

[28/50] [abbrv] flink git commit: [FLINK-5929] Allow Access to Per-Window State in ProcessWindowFunction

[FLINK-5929] Allow Access to Per-Window State in ProcessWindowFunction Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fad201bf Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fad201bf Diff:

[15/50] [abbrv] flink git commit: [FLINK-6018] Add tests for KryoSerializer restore with registered types

[FLINK-6018] Add tests for KryoSerializer restore with registered types This commit also renames isCompatibleWith() to canRestoreFrom() to make the method asymetric because in the case of KryoSerializer we can restore from state that was stored using no registed types/serializers while the other

[08/50] [abbrv] flink git commit: [FLINK-4354] [heartbeat] Implement heartbeat logic between TaskManager and ResourceManager

[FLINK-4354] [heartbeat] Implement heartbeat logic between TaskManager and ResourceManager This closes #3591. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fd90672f Tree:

[07/50] [abbrv] flink git commit: [FLINK-4354] [heartbeat] Add heartbeats between the ResourceManager and TaskExecutor

[FLINK-4354] [heartbeat] Add heartbeats between the ResourceManager and TaskExecutor Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/83b99f8a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/83b99f8a Diff:

[30/50] [abbrv] flink git commit: [hotfix] [docs] Fix broken links

[hotfix] [docs] Fix broken links This closes #3618. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/037b5cbd Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/037b5cbd Diff:

[25/50] [abbrv] flink git commit: [hotfix] [table] Disable event-time OVER RANGE UNBOUNDED PRECEDING window.

[hotfix] [table] Disable event-time OVER RANGE UNBOUNDED PRECEDING window. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cac9fa02 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cac9fa02 Diff:

[12/50] [abbrv] flink git commit: [hotfix] Add EvictingWindowOperatorContractTest

[hotfix] Add EvictingWindowOperatorContractTest The existing WindowOperatorContractTest is turned into a test base while RegularWindowOperatorContract test tests WindowOperator and EvictingWindowOperatorTest tests EvictingWindowOperator. For this to work, the base tests now always use List

[06/50] [abbrv] flink git commit: [FLINK-3318] Add support for quantifiers to CEP's pattern API

[FLINK-3318] Add support for quantifiers to CEP's pattern API Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9001c4ef Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9001c4ef Diff:

[13/50] [abbrv] flink git commit: [FLINK-5972] Don't allow shrinking merging windows

[FLINK-5972] Don't allow shrinking merging windows This closes #3587. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/68289b1a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/68289b1a Diff:

[19/50] [abbrv] flink git commit: [FLINK-6128] [tests] Optimize JVM options to improve test performance

[FLINK-6128] [tests] Optimize JVM options to improve test performance Decrease the time to run TravisCI builds and reduce OOM by - increasing the heap size - switching to Java's serial garbage collector - removing the UseGCOverheadLimit option This closes #3571 Project:

[1/2] flink git commit: [FLINK-5653] [table] Add processing-time OVER ROWS BETWEEN x PRECEDING aggregation to SQL.

Repository: flink Updated Branches: refs/heads/master aa3c395b9 -> ee033c903 [FLINK-5653] [table] Add processing-time OVER ROWS BETWEEN x PRECEDING aggregation to SQL. This closes #3653. This closes #3574. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/2] flink git commit: [FLINK-6200] [table] Add support for unbounded event-time OVER RANGE window.

[FLINK-6200] [table] Add support for unbounded event-time OVER RANGE window. This closes #3649. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/44f9c76a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/44f9c76a Diff:

flink git commit: [FLINK-6165] [cep] Implement internal continuity for looping states.

Repository: flink Updated Branches: refs/heads/master d4665a00a -> aa3c395b9 [FLINK-6165] [cep] Implement internal continuity for looping states. Allows looping states (oneOrMore, zeroOrMore, times) to specify if they want their elements to be consecutive or allow non-matching elements

flink git commit: [FLINK-5655] [table] Add event-time OVER RANGE BETWEEN x PRECEDING aggregation to SQL.

Repository: flink Updated Branches: refs/heads/master ca681101f -> d4665a00a [FLINK-5655] [table] Add event-time OVER RANGE BETWEEN x PRECEDING aggregation to SQL. This closes #3629. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: