[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
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
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:
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:
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
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
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
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:
[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:
[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:
[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:
[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
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:
[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:
[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:
[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:
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:
[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:
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:
[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
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:
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:
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:
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
24 matches
Mail list logo