[2/2] flink git commit: [FLINK-7978][kafka] Ensure that transactional ids will never clash

2017-11-08 Thread aljoscha
[FLINK-7978][kafka] Ensure that transactional ids will never clash Previously transactional ids to use and to abort could clash between subtasks. This could lead to a race condition between initialization and writting the data, where one subtask is still initializing/aborting some transactional

flink git commit: [FLINK-8001] [kafka] Prevent PeriodicWatermarkEmitter from violating IDLE status

2017-11-08 Thread tzulitai
Repository: flink Updated Branches: refs/heads/master 81e1ac352 -> 6bce2b833 [FLINK-8001] [kafka] Prevent PeriodicWatermarkEmitter from violating IDLE status Prior to this commit, a bug exists such that if a Kafka consumer subtask initially marks itself as idle because it didn't have any

[1/2] flink git commit: [hotfix][kafka] Extract TransactionalIdsGenerator class from FlinkKafkaProducer011

2017-11-08 Thread aljoscha
Repository: flink Updated Branches: refs/heads/master 6bce2b833 -> fdae3ae1f [hotfix][kafka] Extract TransactionalIdsGenerator class from FlinkKafkaProducer011 This is pure refactor without any functional changes. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-8009][build][runtime] Remove transitive dependency promotion

2017-11-08 Thread chesnay
Repository: flink Updated Branches: refs/heads/release-1.4 17aae5af4 -> f5a0b4bdf [FLINK-8009][build][runtime] Remove transitive dependency promotion This closes #4972. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-8001] [kafka] Mark consumer subtask as IDLE if it doesn't have partitions

2017-11-08 Thread tzulitai
Repository: flink Updated Branches: refs/heads/release-1.3 6bf24b968 -> b307081a3 [FLINK-8001] [kafka] Mark consumer subtask as IDLE if it doesn't have partitions Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b307081a

flink git commit: [FLINK-8009][build][runtime] Remove transitive dependency promotion

2017-11-08 Thread chesnay
Repository: flink Updated Branches: refs/heads/master 747288f11 -> 1602bc3ca [FLINK-8009][build][runtime] Remove transitive dependency promotion This closes #4972. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1602bc3c

flink git commit: [FLINK-7773] [tests] Move all mocking before testing code in UtilsTest to avoid unfinished stubbing

2017-11-08 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 1602bc3ca -> 7d293692f [FLINK-7773] [tests] Move all mocking before testing code in UtilsTest to avoid unfinished stubbing Move all mocking code before the actual testing code in

[1/2] flink git commit: [FLINK-7076] [yarn] Implement stopWorker logic for YarnResourceManager

2017-11-08 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 7d293692f -> cd5325161 [FLINK-7076] [yarn] Implement stopWorker logic for YarnResourceManager This closes #4729. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/2] flink git commit: [FLINK-7076] [tests] Harden YarnResourcemanagerTest#testStopWorker to properly wait for concurrent operations

2017-11-08 Thread trohrmann
[FLINK-7076] [tests] Harden YarnResourcemanagerTest#testStopWorker to properly wait for concurrent operations Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cd532516 Tree:

[2/5] flink git commit: [FLINK-7996] [table] Add support for (left.time = right.time) predicates to window join.

2017-11-08 Thread fhueske
[FLINK-7996] [table] Add support for (left.time = right.time) predicates to window join. This closes #4977. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1ad18309 Tree:

[3/5] flink git commit: [FLINK-7971] [table] Fix potential NPE in non-windowed aggregation.

2017-11-08 Thread fhueske
[FLINK-7971] [table] Fix potential NPE in non-windowed aggregation. This closes #4941. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9d20e898 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9d20e898 Diff:

[5/5] flink git commit: [FLINK-7922] [table] Fix FlinkTypeFactory.leastRestrictive for composite types.

2017-11-08 Thread fhueske
[FLINK-7922] [table] Fix FlinkTypeFactory.leastRestrictive for composite types. This closes #4929. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/949ae79d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/949ae79d

[1/5] flink git commit: [FLINK-8002] [table] Fix join window boundary for LESS_THAN and GREATER_THAN predicates.

2017-11-08 Thread fhueske
Repository: flink Updated Branches: refs/heads/master cd5325161 -> 989c77970 [FLINK-8002] [table] Fix join window boundary for LESS_THAN and GREATER_THAN predicates. This closes #4962. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[3/5] flink git commit: [FLINK-7996] [table] Add support for (left.time = right.time) predicates to window join.

2017-11-08 Thread fhueske
[FLINK-7996] [table] Add support for (left.time = right.time) predicates to window join. This closes #4977. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1b20f70d Tree:

[4/5] flink git commit: [FLINK-8012] [table] Fix TableSink config for tables with time attributes.

2017-11-08 Thread fhueske
[FLINK-8012] [table] Fix TableSink config for tables with time attributes. This closes #4974. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/51657fc6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/51657fc6 Diff:

[5/5] flink git commit: [FLINK-8002] [table] Fix join window boundary for LESS_THAN and GREATER_THAN predicates.

2017-11-08 Thread fhueske
[FLINK-8002] [table] Fix join window boundary for LESS_THAN and GREATER_THAN predicates. This closes #4962. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c7943291 Tree:

[1/5] flink git commit: [FLINK-7971] [table] Fix potential NPE in non-windowed aggregation.

2017-11-08 Thread fhueske
Repository: flink Updated Branches: refs/heads/release-1.4 f5a0b4bdf -> c79432915 [FLINK-7971] [table] Fix potential NPE in non-windowed aggregation. This closes #4941. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[3/3] flink git commit: [FLINK-8012] [table] Fix TableSink config for tables with time attributes.

2017-11-08 Thread fhueske
[FLINK-8012] [table] Fix TableSink config for tables with time attributes. This closes #4974. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7893aba4 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7893aba4 Diff:

[1/3] flink git commit: [FLINK-7971] [table] Fix potential NPE in non-windowed aggregation.

2017-11-08 Thread fhueske
Repository: flink Updated Branches: refs/heads/release-1.3 b307081a3 -> 7893aba41 [FLINK-7971] [table] Fix potential NPE in non-windowed aggregation. This closes #4941. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/3] flink git commit: [FLINK-7922] [table] Fix FlinkTypeFactory.leastRestrictive for composite types.

2017-11-08 Thread fhueske
[FLINK-7922] [table] Fix FlinkTypeFactory.leastRestrictive for composite types. This closes #4929. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/eb299576 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/eb299576

flink git commit: [FLINK-8004][metrics][docs] Fix usage examples

2017-11-08 Thread chesnay
Repository: flink Updated Branches: refs/heads/master fdae3ae1f -> 0c504306b [FLINK-8004][metrics][docs] Fix usage examples This closes #4965. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0c504306 Tree:

flink git commit: [FLINK-8004][metrics][docs] Fix usage examples

2017-11-08 Thread chesnay
Repository: flink Updated Branches: refs/heads/release-1.4 dc1ca78a4 -> 5af710080 [FLINK-8004][metrics][docs] Fix usage examples Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5af71008 Tree:

flink git commit: [FLINK-8010][build] Bump remaining flink-shaded versions

2017-11-08 Thread chesnay
Repository: flink Updated Branches: refs/heads/release-1.4 5af710080 -> 49dc38069 [FLINK-8010][build] Bump remaining flink-shaded versions Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/49dc3806 Tree:

flink git commit: [FLINK-8001] [kafka] Prevent PeriodicWatermarkEmitter from violating IDLE status

2017-11-08 Thread aljoscha
Repository: flink Updated Branches: refs/heads/release-1.4 49dc38069 -> 17aae5af4 [FLINK-8001] [kafka] Prevent PeriodicWatermarkEmitter from violating IDLE status Prior to this commit, a bug exists such that if a Kafka consumer subtask initially marks itself as idle because it didn't have any