[09/17] flink git commit: [FLINK-4748] [streaming api] Make timers in Ingestion Time source context properly cancelable.

2016-10-05 Thread sewen
[FLINK-4748] [streaming api] Make timers in Ingestion Time source context properly cancelable. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dd3416fd Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/dd3416fd Diff: ht

[17/17] flink git commit: [hotfix] [tests] Remove leftover sysout logging code

2016-10-05 Thread sewen
[hotfix] [tests] Remove leftover sysout logging code Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/417c5a4b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/417c5a4b Diff: http://git-wip-us.apache.org/repos/asf/flink/

[14/17] flink git commit: [hotfix] [streaming api] Remove obsolete and unused InputTypeSerializer from WindowOperator

2016-10-05 Thread sewen
[hotfix] [streaming api] Remove obsolete and unused InputTypeSerializer from WindowOperator Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1cd8d4f4 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1cd8d4f4 Diff: http:

[12/17] flink git commit: [FLINK-4718] [docs] Fix figure about parallel watermarks.

2016-10-05 Thread sewen
[FLINK-4718] [docs] Fix figure about parallel watermarks. This closes #2578 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8000b64a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8000b64a Diff: http://git-wip-us.apa

[13/17] flink git commit: [FLINK-4750] [runtime] Cleanly await end of all currently executing processing time timers when finite streams finish.

2016-10-05 Thread sewen
[FLINK-4750] [runtime] Cleanly await end of all currently executing processing time timers when finite streams finish. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8aea8c8f Tree: http://git-wip-us.apache.org/repos/asf/flin

[02/17] flink git commit: [hotfix] Various code cleanups around time service and asynchronous exceptions

2016-10-05 Thread sewen
[hotfix] Various code cleanups around time service and asynchronous exceptions - DefaultTimeServiceProvider now owns scheduled executor - Enforce that an asynchronous exception handler is always set Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.o

[04/17] flink git commit: [FLINK-4709] [core] Fix resource leak in InputStreamFSInputWrapper

2016-10-05 Thread sewen
[FLINK-4709] [core] Fix resource leak in InputStreamFSInputWrapper This closes #2581 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/28b37ef9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/28b37ef9 Diff: http://git-w

[10/17] flink git commit: [hotfix] [streaming api] Cleanup watermark initialization in window operator

2016-10-05 Thread sewen
[hotfix] [streaming api] Cleanup watermark initialization in window operator Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9d24d51f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9d24d51f Diff: http://git-wip-us.apa

[07/17] flink git commit: [FLINK-4737] [core] Add support for bz2 and xy compression in flink-core.

2016-10-05 Thread sewen
[FLINK-4737] [core] Add support for bz2 and xy compression in flink-core. Adds a dependency on 'commons-compression'. This closes #2002 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/81aec410 Tree: http://git-wip-us.apache.

[03/17] flink git commit: [hotfix] [core] Minor code cleanup and correction of javadocs for filesystem input stream classes.

2016-10-05 Thread sewen
[hotfix] [core] Minor code cleanup and correction of javadocs for filesystem input stream classes. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c62776f0 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c62776f0 Diff

[15/17] flink git commit: [FLINK-4749] [streaming api] Remove redundant processing time timer sets from window operator

2016-10-05 Thread sewen
[FLINK-4749] [streaming api] Remove redundant processing time timer sets from window operator Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/47e49774 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/47e49774 Diff: htt

[05/17] flink git commit: [FLINK-4329] [streaming api] Fix Streaming File Source Timestamps/Watermarks Handling

2016-10-05 Thread sewen
http://git-wip-us.apache.org/repos/asf/flink/blob/8ff451be/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/KeyedOneInputStreamOperatorTestHarness.java -- diff --git a/flink-streaming-java/src/test/java/org/apach

[16/17] flink git commit: [FLINK-4700] [tests] Expand and harden TimeServiceProvider test

2016-10-05 Thread sewen
[FLINK-4700] [tests] Expand and harden TimeServiceProvider test Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4fc54e3e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4fc54e3e Diff: http://git-wip-us.apache.org/repos

[11/17] flink git commit: [FLINK-4739] [elasticsearch connector] Adding packaging details for the Elasticsearch connector

2016-10-05 Thread sewen
[FLINK-4739] [elasticsearch connector] Adding packaging details for the Elasticsearch connector When an uber-jar containing an Elasticsearch sink is executed, an IllegalArgumentException may occur, which is caused by conflicting files of Elasticsearch and it's dependencies in META-INF/services.

[06/17] flink git commit: [FLINK-4329] [streaming api] Fix Streaming File Source Timestamps/Watermarks Handling

2016-10-05 Thread sewen
[FLINK-4329] [streaming api] Fix Streaming File Source Timestamps/Watermarks Handling This closes #2546 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8ff451be Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8ff451b

[01/17] flink git commit: [FLINK-4737] [core] Ensure that Flink and its Hadoop dependency pull the same version of 'commons-compress'

2016-10-05 Thread sewen
Repository: flink Updated Branches: refs/heads/master 10a42f951 -> 417c5a4b4 [FLINK-4737] [core] Ensure that Flink and its Hadoop dependency pull the same version of 'commons-compress' Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/f

[08/17] flink git commit: [FLINK-4728] [core, optimizer] Replace reference equality with object equality

2016-10-05 Thread sewen
[FLINK-4728] [core,optimizer] Replace reference equality with object equality Some cases of testing Integer equality using == rather than Integer.equals(Integer), and some additional cleanup. This closes #2582 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.

[1/2] flink git commit: [FLINK-4744] [streaming api] Introduce usercode class loader to deserialize partitionable operator state

2016-10-05 Thread sewen
Repository: flink Updated Branches: refs/heads/master 7c9bc1e51 -> 10a42f951 [FLINK-4744] [streaming api] Introduce usercode class loader to deserialize partitionable operator state This closes #2598 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache

[2/2] flink git commit: [FLINK-4744] [streaming api] Followup: Unify names for operator state access methods and comments.

2016-10-05 Thread sewen
[FLINK-4744] [streaming api] Followup: Unify names for operator state access methods and comments. Also make JavaSerializer package private, as it is not intended for user as a proper TypeSerializer Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org

[3/4] flink git commit: [FLINK-4734] [gelly] Remove use of Tuple setField for fixed position

2016-10-05 Thread greg
[FLINK-4734] [gelly] Remove use of Tuple setField for fixed position This closes #2590 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1577e898 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1577e898 Diff: http://git

[1/4] flink git commit: [FLINK-4729] [gelly] Use optional VertexCentric CombineFunction

2016-10-05 Thread greg
Repository: flink Updated Branches: refs/heads/master 8c7c42f0e -> 7c9bc1e51 http://git-wip-us.apache.org/repos/asf/flink/blob/bb34133e/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/operations/GraphOperationsITCase.java ---

[2/4] flink git commit: [FLINK-4729] [gelly] Use optional VertexCentric CombineFunction

2016-10-05 Thread greg
[FLINK-4729] [gelly] Use optional VertexCentric CombineFunction Passes through the CombineFunction to VertexCentricIteration, and other code cleanup discovered via IntelliJ's code analyzer. This closes #2587 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.ap

[4/4] flink git commit: [FLINK-4740] [tests] Upgrade testing libraries

2016-10-05 Thread greg
[FLINK-4740] [tests] Upgrade testing libraries Upgrades JUnit from 4.11 to 4.12 Mockito from 1.9.5 to 1.10.19 PowerMock from 1.5.5 to 1.6.5 This closes #2597 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7c9bc1e5 Tre

flink git commit: [FLINK-4329] Fix Streaming File Source Timestamps/Watermarks Handling

2016-10-05 Thread mxm
Repository: flink Updated Branches: refs/heads/release-1.1 fddd89bcd -> bab59dfa7 [FLINK-4329] Fix Streaming File Source Timestamps/Watermarks Handling This closes #2593. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ba

flink git commit: [FLINK-4677] fail if user jar contains no executions

2016-10-05 Thread mxm
Repository: flink Updated Branches: refs/heads/release-1.1 a83dbaeb0 -> fddd89bcd [FLINK-4677] fail if user jar contains no executions This closes #2548. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fddd89bc Tree: http

flink git commit: [FLINK-4677] fail if user jar contains no executions

2016-10-05 Thread mxm
Repository: flink Updated Branches: refs/heads/master 825ef3be3 -> 8c7c42f0e [FLINK-4677] fail if user jar contains no executions This closes #2548. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8c7c42f0 Tree: http://gi

flink git commit: [FLINK-3874] Rewrite Kafka JSON Table sink tests

2016-10-05 Thread twalthr
Repository: flink Updated Branches: refs/heads/master efb40cfc5 -> 825ef3be3 [FLINK-3874] Rewrite Kafka JSON Table sink tests This closes #2430. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/825ef3be Tree: http://git-wi

flink git commit: [hotfix] [kafka] Committed offset value set in KafkaTopicPartitionState should also be incremented by 1.

2016-10-05 Thread tzulitai
Repository: flink Updated Branches: refs/heads/release-1.1 a31a22ec7 -> a83dbaeb0 [hotfix] [kafka] Committed offset value set in KafkaTopicPartitionState should also be incremented by 1. The broken behaviour was introduced in the last hotfix commit eece0dd0. Project: http://git-wip-us.apach

flink git commit: [hotfix] [kafka] Committed offset value set in KafkaTopicPartitionState should also be incremented by 1.

2016-10-05 Thread tzulitai
Repository: flink Updated Branches: refs/heads/master 5a573c6bc -> efb40cfc5 [hotfix] [kafka] Committed offset value set in KafkaTopicPartitionState should also be incremented by 1. The broken behaviour was introduced in the last hotfix commit eece0dd0. Project: http://git-wip-us.apache.org