flink.git
16 hours ago[FLINK-29349][table-runtime] Use state ttl instead of timer to clean up state in... master
lincoln lee [Mon, 26 Sep 2022 09:46:19 +0000 (17:46 +0800)] 
[FLINK-29349][table-runtime] Use state ttl instead of timer to clean up state in proctime unbounded over aggregate

This closes #20898

16 hours ago[hotfix][docs] Fix typo in try-flink/datastream.md
saikikun [Sun, 25 Sep 2022 17:21:07 +0000 (01:21 +0800)] 
[hotfix][docs] Fix typo in try-flink/datastream.md

16 hours ago[FLINK-29274][hive] Fix ObjectStore leak when different users has different config...
Shengkai [Mon, 26 Sep 2022 08:57:57 +0000 (16:57 +0800)] 
[FLINK-29274][hive] Fix ObjectStore leak when different users has different config (#20891)

17 hours ago[FLINK-24476][docs] Rename Elasticsearch case in docs. This closes #17451
Ryan Skraba [Fri, 8 Oct 2021 07:21:04 +0000 (09:21 +0200)] 
[FLINK-24476][docs] Rename Elasticsearch case in docs. This closes #17451

18 hours ago[FLINK-29386][hive] Fix failed to compile flink-connector-hive in hive3 profile ...
yuxia Luo [Mon, 26 Sep 2022 07:07:26 +0000 (15:07 +0800)] 
[FLINK-29386][hive] Fix failed to compile flink-connector-hive in hive3 profile (#20882)

20 hours ago[FLINK-29020][docs] Add document for CREATE TABLE AS SELECT
zhangmang [Mon, 26 Sep 2022 05:34:07 +0000 (13:34 +0800)] 
[FLINK-29020][docs] Add document for CREATE TABLE AS SELECT

This closes #20653

21 hours ago[hotfix] fix the problem that BatchShuffleItCase not subject to configuration.
Weijie Guo [Thu, 15 Sep 2022 16:19:01 +0000 (00:19 +0800)] 
[hotfix] fix the problem that BatchShuffleItCase not subject to configuration.

This closes #20857

3 days ago[hotfix][docs] Fix typo in Kinesis Connector docs.
Alexander Fedulov [Wed, 21 Sep 2022 21:59:35 +0000 (21:59 +0000)] 
[hotfix][docs] Fix typo in Kinesis Connector docs.

3 days ago[FLINK-29389][docs] Update documentation of JDBC and HBase lookup table for new cachi...
Qingsheng Ren [Fri, 23 Sep 2022 14:41:51 +0000 (22:41 +0800)] 
[FLINK-29389][docs] Update documentation of JDBC and HBase lookup table for new caching options (#20884)

3 days ago[FLINK-29093][table] Fix InternalCompilerException in LookupJoinITCase + reset resour...
Smirnov Alexander [Mon, 5 Sep 2022 09:07:57 +0000 (16:07 +0700)] 
[FLINK-29093][table] Fix InternalCompilerException in LookupJoinITCase + reset resource counter before each test

3 days ago[FLINK-29309][streaming-java] Relax allow-client-job-configurations for Table API...
Timo Walther [Thu, 15 Sep 2022 11:49:33 +0000 (13:49 +0200)] 
[FLINK-29309][streaming-java] Relax allow-client-job-configurations for Table API and parameters

This closes #20840.

3 days ago[FLINK-29375][rpc] Move getSelfGateway() into RpcService
Chesnay Schepler [Fri, 23 Sep 2022 09:45:10 +0000 (11:45 +0200)] 
[FLINK-29375][rpc] Move getSelfGateway() into RpcService

3 days ago[FLINK-28890][table] Fix semantic of latestLoadTime in caching lookup function
Qingsheng Ren [Tue, 9 Aug 2022 10:29:01 +0000 (18:29 +0800)] 
[FLINK-28890][table] Fix semantic of latestLoadTime in caching lookup function

4 days ago[FLINK-29340][coordination][tests] Avoid selfGateway implementation details
Chesnay Schepler [Mon, 19 Sep 2022 19:26:00 +0000 (21:26 +0200)] 
[FLINK-29340][coordination][tests] Avoid selfGateway implementation details

4 days ago[FLINK-29397][runtime] Check if changelog provider is null
Chesnay Schepler [Wed, 21 Sep 2022 16:10:08 +0000 (18:10 +0200)] 
[FLINK-29397][runtime] Check if changelog provider is null

4 days ago[FLINK-29378][coordination] Improve logging of failed execution state transitions
Chesnay Schepler [Wed, 21 Sep 2022 08:50:04 +0000 (10:50 +0200)] 
[FLINK-29378][coordination] Improve logging of failed execution state transitions

4 days ago[FLINK-29374][rpc][tests] Use proper RPC url
Chesnay Schepler [Tue, 20 Sep 2022 09:47:35 +0000 (11:47 +0200)] 
[FLINK-29374][rpc][tests] Use proper RPC url

4 days ago[FLINK-29229][hive] Fix HiveServer2 endpoint doesn't support execute statements in...
Shengkai [Thu, 8 Sep 2022 11:52:23 +0000 (19:52 +0800)] 
[FLINK-29229][hive] Fix HiveServer2 endpoint doesn't support execute statements in sync mode

4 days ago[FLINK-29228][hive] Align the schema of the HiveServer2 getMetadata with JDBC
Shengkai [Thu, 8 Sep 2022 07:08:21 +0000 (15:08 +0800)] 
[FLINK-29228][hive] Align the schema of the HiveServer2 getMetadata with JDBC

4 days ago[FLINK-29377][rpc] Reusable timeout extraction 18358/head
Chesnay Schepler [Wed, 21 Sep 2022 08:41:56 +0000 (10:41 +0200)] 
[FLINK-29377][rpc] Reusable timeout extraction

5 days ago[FLINK-29152][hive] Fix inconsistent behavior with Hive for `desc table` in Hive...
yuxia Luo [Wed, 21 Sep 2022 15:10:04 +0000 (23:10 +0800)] 
[FLINK-29152][hive] Fix inconsistent behavior with Hive for `desc table` in Hive dialect

This closes #20789

5 days ago[FLINK-29152][hive] Fix "SHOW CREATE TABLE" doesn't work for Hive dialect
yuxia Luo [Wed, 21 Sep 2022 07:11:32 +0000 (15:11 +0800)] 
[FLINK-29152][hive] Fix "SHOW CREATE TABLE" doesn't work for Hive dialect

This closes #20795

5 days ago[hotfix] Make ParquetProtoWriters.ParquetProtoWriterBuilder public to support customi...
Jin [Wed, 31 Aug 2022 01:34:30 +0000 (18:34 -0700)] 
[hotfix] Make ParquetProtoWriters.ParquetProtoWriterBuilder public to support customized scenarios

This closes #20786.

5 days ago[FLINK-29325][docs] Fix documentation bug on how to enable batch mode for streaming...
Jun He [Sat, 17 Sep 2022 02:56:07 +0000 (10:56 +0800)] 
[FLINK-29325][docs] Fix documentation bug on how to enable batch mode for streaming examples

This closes #20849.

6 days ago[FLINK-29191][hive] Fix Hive dialect can't get value for the variables set by set...
yuxia Luo [Wed, 21 Sep 2022 01:46:50 +0000 (09:46 +0800)] 
[FLINK-29191][hive] Fix Hive dialect can't get value for the variables set by set command

This closes #20774

6 days ago[FLINK-29324][Connectors/Kinesis] Fix NPE for Kinesis connector when closing (#20853)
harker2015 [Tue, 20 Sep 2022 15:31:44 +0000 (17:31 +0200)] 
[FLINK-29324][Connectors/Kinesis] Fix NPE for Kinesis connector when closing (#20853)

* [FLINK-29324] Fix NPE for Kinesis connector when closing

* [FLINK-29324] Add unit test case

6 days ago[FLINK-29222][hive] Fix wrong behavior for Hive's load data inpath
yuxia Luo [Tue, 20 Sep 2022 14:30:08 +0000 (22:30 +0800)] 
[FLINK-29222][hive] Fix wrong behavior for Hive's load data inpath

This closes #20778

6 days ago[FLINK-29045][hive] Optimize error message in Flink SQL Client and Gateway when try...
yuxia Luo [Tue, 20 Sep 2022 14:28:35 +0000 (22:28 +0800)] 
[FLINK-29045][hive] Optimize error message in Flink SQL Client and Gateway when try to use Hive Dialect

This closes #20695

6 days ago[FLINK-29185][hive] Fix ClassNotFoundException for CREATE TEMPORARY FUNCTION USING...
luoyuxia [Wed, 7 Sep 2022 06:38:04 +0000 (14:38 +0800)] 
[FLINK-29185][hive] Fix ClassNotFoundException for CREATE TEMPORARY FUNCTION USING JAR with Hive dialect

This closes #20776

6 days ago[hotfix] Add 1.15 release note in Chinese doc
huangxingbo [Tue, 20 Sep 2022 04:31:33 +0000 (12:31 +0800)] 
[hotfix] Add 1.15 release note in Chinese doc

7 days ago[FLINK-29025][docs][hive] Remove "alias" front matter of new added Hive compatibility...
Jark Wu [Mon, 19 Sep 2022 14:46:50 +0000 (22:46 +0800)] 
[FLINK-29025][docs][hive] Remove "alias" front matter of new added Hive compatibility pages

Alias front matter is used to setup redirect from removed page to this one. The Hive compatibility pages are new pages, so there is no need to add "alias" front matter.

7 days ago[FLINK-29025][docs][hive] Fix links of Hive compatibility pages
Jark Wu [Mon, 19 Sep 2022 14:39:51 +0000 (22:39 +0800)] 
[FLINK-29025][docs][hive] Fix links of Hive compatibility pages

7 days ago[FLINK-29025][docs][hive] Use dash-case instead of camelCase in URL of Hive compatibi...
Jark Wu [Mon, 19 Sep 2022 14:35:45 +0000 (22:35 +0800)] 
[FLINK-29025][docs][hive] Use dash-case instead of camelCase in URL of Hive compatibility pages

7 days ago[FLINK-29025][docs] Update page weight of Hive compatibility pages
Jark Wu [Mon, 19 Sep 2022 14:29:54 +0000 (22:29 +0800)] 
[FLINK-29025][docs] Update page weight of Hive compatibility pages

7 days ago[FLINK-29025][docs] Improve documentation of Hive compatibility pages
luoyuxia [Wed, 7 Sep 2022 11:38:01 +0000 (19:38 +0800)] 
[FLINK-29025][docs] Improve documentation of Hive compatibility pages

7 days ago[FLINK-29025][docs] add show page for Hive dialect
luoyuxia [Mon, 29 Aug 2022 07:43:32 +0000 (15:43 +0800)] 
[FLINK-29025][docs] add show page for Hive dialect

7 days ago[FLINK-29025][docs] add set page for Hive dialect
luoyuxia [Mon, 29 Aug 2022 07:42:36 +0000 (15:42 +0800)] 
[FLINK-29025][docs] add set page for Hive dialect

7 days ago[FLINK-29025][docs] add load data page for Hive dialect
luoyuxia [Mon, 29 Aug 2022 07:41:20 +0000 (15:41 +0800)] 
[FLINK-29025][docs] add load data page for Hive dialect

7 days ago[FLINK-29025][docs] add insert page for Hive dialect
luoyuxia [Mon, 29 Aug 2022 07:40:25 +0000 (15:40 +0800)] 
[FLINK-29025][docs] add insert page for Hive dialect

7 days ago[FLINK-29025][docs] add drop page for Hive dialect
luoyuxia [Mon, 29 Aug 2022 07:39:05 +0000 (15:39 +0800)] 
[FLINK-29025][docs] add drop page for Hive dialect

7 days ago[FLINK-29025][docs] add create page for Hive dialect
luoyuxia [Mon, 29 Aug 2022 07:36:32 +0000 (15:36 +0800)] 
[FLINK-29025][docs] add create page for Hive dialect

7 days ago[FLINK-29025][docs] add alter page for Hive dialect
luoyuxia [Mon, 29 Aug 2022 07:35:36 +0000 (15:35 +0800)] 
[FLINK-29025][docs] add alter page for Hive dialect

7 days ago[FLINK-29025][docs] add `add jar` page for Hive dialect
luoyuxia [Mon, 29 Aug 2022 07:34:17 +0000 (15:34 +0800)] 
[FLINK-29025][docs] add `add jar` page for Hive dialect

7 days ago[FLINK-29025][docs] add table sample page for Hive dialect
luoyuxia [Mon, 29 Aug 2022 07:22:09 +0000 (15:22 +0800)] 
[FLINK-29025][docs] add table sample page for Hive dialect

7 days ago[FLINK-29025][docs] add transform page for Hive dialect
luoyuxia [Mon, 29 Aug 2022 07:21:01 +0000 (15:21 +0800)] 
[FLINK-29025][docs] add transform page for Hive dialect

7 days ago[FLINK-29025][docs] add cte page for Hive dialect
luoyuxia [Mon, 29 Aug 2022 07:18:52 +0000 (15:18 +0800)] 
[FLINK-29025][docs] add cte page for Hive dialect

7 days ago[FLINK-29025][docs] add sub query page for Hive dialect
luoyuxia [Mon, 29 Aug 2022 07:16:54 +0000 (15:16 +0800)] 
[FLINK-29025][docs] add sub query page for Hive dialect

7 days ago[FLINK-29025][docs] add window functions page for Hive dialect
luoyuxia [Mon, 29 Aug 2022 07:15:46 +0000 (15:15 +0800)] 
[FLINK-29025][docs] add window functions page for Hive dialect

7 days ago[FLINK-29025][docs] add lateral view page for Hive dialect
luoyuxia [Mon, 29 Aug 2022 07:14:20 +0000 (15:14 +0800)] 
[FLINK-29025][docs] add lateral view page for Hive dialect

7 days ago[FLINK-29025][docs] add set operation page for Hive dialect
luoyuxia [Mon, 29 Aug 2022 07:12:58 +0000 (15:12 +0800)] 
[FLINK-29025][docs] add set operation page for Hive dialect

7 days ago[FLINK-29025][docs] add join page for Hive dialect
luoyuxia [Mon, 29 Aug 2022 07:11:34 +0000 (15:11 +0800)] 
[FLINK-29025][docs] add join page for Hive dialect

7 days ago[FLINK-29025][docs] add group by page for Hive dialect
luoyuxia [Mon, 29 Aug 2022 07:10:14 +0000 (15:10 +0800)] 
[FLINK-29025][docs] add group by page for Hive dialect

7 days ago[FLINK-29025][docs] add sort/cluster/distribute by page for Hive dialect
luoyuxia [Mon, 29 Aug 2022 07:04:49 +0000 (15:04 +0800)] 
[FLINK-29025][docs] add sort/cluster/distribute by page for Hive dialect

7 days ago[FLINK-29025][docs] add overview page of queries for Hive dialect
luoyuxia [Mon, 29 Aug 2022 07:01:37 +0000 (15:01 +0800)] 
[FLINK-29025][docs] add overview page of queries for Hive dialect

7 days ago[FLINK-29025][docs] add overview page for Hive dialect
luoyuxia [Mon, 29 Aug 2022 06:51:11 +0000 (14:51 +0800)] 
[FLINK-29025][docs] add overview page for Hive dialect

7 days ago[FLINK-29023][docs][table] Improve docs of limitation of ADD JAR
Jark Wu [Mon, 19 Sep 2022 09:40:27 +0000 (17:40 +0800)] 
[FLINK-29023][docs][table] Improve docs of limitation of ADD JAR

7 days ago[FLINK-29023][docs][table] Update documentation of JAR statement page
fengli [Fri, 19 Aug 2022 10:20:23 +0000 (18:20 +0800)] 
[FLINK-29023][docs][table] Update documentation of JAR statement page

This closes #20630

7 days ago[FLINK-29148][docs][hive] Improve the docs of HiveServer2 page
Jark Wu [Mon, 19 Sep 2022 04:21:55 +0000 (12:21 +0800)] 
[FLINK-29148][docs][hive] Improve the docs of HiveServer2 page

7 days ago[FLINK-29148][docs][sql-gateway][hive] Add SQL Gateway docs
Shengkai [Wed, 31 Aug 2022 03:52:11 +0000 (11:52 +0800)] 
[FLINK-29148][docs][sql-gateway][hive] Add SQL Gateway docs

This closes #20719

7 days ago[hotfix] Bind to broadcast address when host is not specified
Shengkai [Mon, 5 Sep 2022 06:46:10 +0000 (14:46 +0800)] 
[hotfix] Bind to broadcast address when host is not specified

7 days ago[FLINK-29188][sql-gateway][hive] Make option "sql-gateway.endpint.hiveserver2.catalog...
Shengkai [Mon, 5 Sep 2022 04:06:42 +0000 (12:06 +0800)] 
[FLINK-29188][sql-gateway][hive] Make option "sql-gateway.endpint.hiveserver2.catalog.hive-conf-dir" required

7 days ago[FLINK-24907] Support side out late data for interval join
chenyuzhi459 [Mon, 19 Sep 2022 06:38:11 +0000 (14:38 +0800)] 
[FLINK-24907] Support side out late data for interval join

7 days ago[FLINK-29280][table-planner] Fix join hints could not be propagated in subquery
xuyang [Tue, 13 Sep 2022 10:59:43 +0000 (18:59 +0800)] 
[FLINK-29280][table-planner] Fix join hints could not be propagated in subquery

This closes #20823

7 days ago[FLINK-28738][table-planner] Adds a user doc about the determinism in streaming
lincoln lee [Mon, 22 Aug 2022 09:01:03 +0000 (17:01 +0800)] 
[FLINK-28738][table-planner] Adds a user doc about the determinism in streaming

This closes #20679

10 days ago[FLINK-29250][rpc] Drop RcService#getTerminationFuture
Chesnay Schepler [Fri, 16 Sep 2022 15:33:14 +0000 (17:33 +0200)] 
[FLINK-29250][rpc] Drop RcService#getTerminationFuture

10 days ago[FLINK-28902][tests] rename FileSystemJobResultStoreTestInternal to FileSystemJobResu...
tonyzhu918 [Fri, 16 Sep 2022 02:57:14 +0000 (10:57 +0800)] 
[FLINK-28902][tests] rename FileSystemJobResultStoreTestInternal to FileSystemJobResultStoreFileOperationsTest

10 days ago[FLINK-29263] Remove Elasticsearch connector
Chesnay Schepler [Tue, 13 Sep 2022 11:49:58 +0000 (13:49 +0200)] 
[FLINK-29263] Remove Elasticsearch connector

11 days ago[FLINK-27142][test] Rework SQL client E2E test 20839/head
Alexander Preuß [Thu, 15 Sep 2022 16:12:03 +0000 (18:12 +0200)] 
[FLINK-27142][test] Rework SQL client E2E test

Rework the test to Java and remove dependencies on the ES connector.

11 days ago[FLINK-29287][tests] Rewrite sql-client packaging tests
Chesnay Schepler [Wed, 14 Sep 2022 08:21:06 +0000 (10:21 +0200)] 
[FLINK-29287][tests] Rewrite sql-client packaging tests

11 days ago[FLINK-29287][tests] Add PackagingTestUtils
Chesnay Schepler [Tue, 13 Sep 2022 16:26:15 +0000 (18:26 +0200)] 
[FLINK-29287][tests] Add PackagingTestUtils

11 days ago[FLINK-28569][table-planner] Fix SinkUpsertMaterializer that should be aware of the...
lincoln.lil [Thu, 8 Sep 2022 13:50:10 +0000 (21:50 +0800)] 
[FLINK-28569][table-planner] Fix SinkUpsertMaterializer that should be aware of the input upsertKey if it is not empty to prevent wrong results

This closes #20791

11 days ago[FLINK-28569][table-planner] Move non-deterministic test functions to userDefinedScal...
lincoln.lil [Thu, 8 Sep 2022 10:11:15 +0000 (18:11 +0800)] 
[FLINK-28569][table-planner] Move non-deterministic test functions to userDefinedScalarFunctions

This closes #20791

11 days ago[FLINK-28569][table-planner] Add projectRowType to RowTypeUtils and deprecate AggCode...
lincoln.lil [Thu, 8 Sep 2022 10:08:58 +0000 (18:08 +0800)] 
[FLINK-28569][table-planner] Add projectRowType to RowTypeUtils and deprecate AggCodeGenHelper#projectRowType

This closes #20791

11 days ago[hotfix][tests] Update job name
Chesnay Schepler [Thu, 15 Sep 2022 08:35:44 +0000 (10:35 +0200)] 
[hotfix][tests] Update job name

11 days ago[FLINK-29305][tests] UpsertTestSinkWriter creates parent directories
Chesnay Schepler [Wed, 14 Sep 2022 15:59:47 +0000 (17:59 +0200)] 
[FLINK-29305][tests] UpsertTestSinkWriter creates parent directories

11 days ago[FLINK-29299][network] Fix the network memory size calculation issue in fine-grained...
kevin.cyj [Wed, 14 Sep 2022 07:31:26 +0000 (15:31 +0800)] 
[FLINK-29299][network] Fix the network memory size calculation issue in fine-grained resource mode

This closes #20834.

12 days ago[FLINK-29301] Publish flink-ci-tools
Chesnay Schepler [Wed, 14 Sep 2022 12:17:57 +0000 (14:17 +0200)] 
[FLINK-29301] Publish flink-ci-tools

12 days ago[FLINK-29301] Rename java-ci-tools to flink-ci-tools
Chesnay Schepler [Wed, 14 Sep 2022 12:17:24 +0000 (14:17 +0200)] 
[FLINK-29301] Rename java-ci-tools to flink-ci-tools

12 days ago[FLINK-29301] Automatically determine modules skipping deployment
Chesnay Schepler [Wed, 14 Sep 2022 11:35:45 +0000 (13:35 +0200)] 
[FLINK-29301] Automatically determine modules skipping deployment

In order to work with external modules we can't rely on a static list for modules that skip deployment (== where the NOTICE contents are irrelevant). We can determine that easily from the build output.

12 days ago[FLINK-29301] loadFromResources works as jar
Chesnay Schepler [Wed, 14 Sep 2022 11:32:38 +0000 (13:32 +0200)] 
[FLINK-29301] loadFromResources works as jar

loadFromResource implicitly relied on being called in the context of the java-ci-tools module, directly accessing the resources directly from the source.

When packaged as a jar this approach doesn't work, because then you'd load files from a jar filesystem that you have to create explicitly.

Instead we now load the resource as an InputStream which works in all cases.

12 days ago[hotfix][ci] Improve output when NOTICE is missing
Chesnay Schepler [Wed, 14 Sep 2022 11:15:11 +0000 (13:15 +0200)] 
[hotfix][ci] Improve output when NOTICE is missing

12 days ago[FLINK-29282][tests] Decouple Quickstart E2E test from Elasticsearch
Chesnay Schepler [Wed, 14 Sep 2022 15:13:07 +0000 (17:13 +0200)] 
[FLINK-29282][tests] Decouple Quickstart E2E test from Elasticsearch

12 days ago[FLINK-29285][tests] Move TestUtils#getResource
Chesnay Schepler [Wed, 14 Sep 2022 15:12:10 +0000 (17:12 +0200)] 
[FLINK-29285][tests] Move TestUtils#getResource

12 days ago[FLINK-29101] ignore non canBePipelined consumedPartitionGroup in getAllSchedulableRe...
Weijie Guo [Mon, 5 Sep 2022 09:49:04 +0000 (17:49 +0800)] 
[FLINK-29101] ignore non canBePipelined consumedPartitionGroup in getAllSchedulableRegions.

This closes #20739

12 days ago[FLINK-29101] Use loop instead of recursive algorithm for maybeScheduleRegions to...
Weijie Guo [Mon, 5 Sep 2022 03:13:58 +0000 (11:13 +0800)] 
[FLINK-29101] Use loop instead of recursive algorithm for maybeScheduleRegions to avoid stackOverFlow.

12 days ago[FLINK-29101] Filter the the execution vertex finished event for non-finished Consume...
Weijie Guo [Fri, 2 Sep 2022 09:56:02 +0000 (17:56 +0800)] 
[FLINK-29101] Filter the the execution vertex finished event for non-finished ConsumedPartitionGroup

12 days ago[hotfix] Let scheduledRegions using the set backed up by IdentityHashMap
Weijie Guo [Fri, 2 Sep 2022 09:59:49 +0000 (17:59 +0800)] 
[hotfix] Let scheduledRegions using the set backed up by IdentityHashMap

12 days ago[hotfix] make schedulingDownStreamTasksInBatchJobBenchmark more in line with the...
Weijie Guo [Wed, 14 Sep 2022 07:15:30 +0000 (15:15 +0800)] 
[hotfix] make schedulingDownStreamTasksInBatchJobBenchmark more in line with the real scene.

12 days ago[FLINK-28853] Address PR comments / Add Kafka and Pulsar split pausing tests
Maximilian Michels [Thu, 1 Sep 2022 14:15:33 +0000 (16:15 +0200)] 
[FLINK-28853] Address PR comments / Add Kafka and Pulsar split pausing tests

12 days ago[FLINK-28853][connector-base] Add source reader split alignment test
Sebastian Mattheis [Tue, 26 Jul 2022 05:33:35 +0000 (07:33 +0200)] 
[FLINK-28853][connector-base] Add source reader split alignment test

12 days ago[FLINK-28853][connector-base] Add allow-unaligned-source-splits config option
Sebastian Mattheis [Sun, 24 Jul 2022 10:09:48 +0000 (12:09 +0200)] 
[FLINK-28853][connector-base] Add allow-unaligned-source-splits config option

12 days ago[FLINK-28853][pulsar] Implement pausing Pulsar splits in case of watermark drift
Dawid Wysakowicz [Fri, 25 Mar 2022 08:33:33 +0000 (09:33 +0100)] 
[FLINK-28853][pulsar] Implement pausing Pulsar splits in case of watermark drift

12 days ago[FLINK-28853][kafka] Implement pausing Kafka partitions in case of watermark drift
Dawid Wysakowicz [Fri, 25 Mar 2022 08:25:57 +0000 (09:25 +0100)] 
[FLINK-28853][kafka] Implement pausing Kafka partitions in case of watermark drift

12 days ago[FLINK-28853][source][connector-base] Add support for aligning individual splits
Dawid Wysakowicz [Mon, 25 Apr 2022 07:55:03 +0000 (09:55 +0200)] 
[FLINK-28853][source][connector-base] Add support for aligning individual splits

This provides support for pausing and resuming individual splits in SourceReaderBase. This is used to align individual splits based on emitted watermarks in SourceOperator.

12 days ago[FLINK-28853][connector-base] Add support for paused SplitFetcher.
Arvid Heise [Wed, 24 Nov 2021 16:10:12 +0000 (17:10 +0100)] 
[FLINK-28853][connector-base] Add support for paused SplitFetcher.

When there is only one SplitFetcher per split, the split advanced too much, and aligned event time is enabled, then the complete SplitFetcher can be paused by SplitFetcherManager#alignSplits, such that temporarily no more records are read from the respective split.

12 days ago[FLINK-28853][connector-base] Revise threading model of SplitFetcher.
Arvid Heise [Wed, 24 Nov 2021 13:36:09 +0000 (14:36 +0100)] 
[FLINK-28853][connector-base] Revise threading model of SplitFetcher.

Instead of mixing 4 different concepts of synchronization, this commit aims to have one lock for everything and go through with it.

12 days ago[FLINK-28928][tests] Add E2E test for hybrid shuffle mode.
Weijie Guo [Tue, 13 Sep 2022 14:16:00 +0000 (22:16 +0800)] 
[FLINK-28928][tests] Add E2E test for hybrid shuffle mode.

This closes #20750

12 days ago[FLINK-28928][tests] Add IT test for hybrid shuffle mode.
Weijie Guo [Mon, 5 Sep 2022 08:02:59 +0000 (16:02 +0800)] 
[FLINK-28928][tests] Add IT test for hybrid shuffle mode.

12 days ago[FLINK-29102] Fix unstable ChangelogLocalRecoveryITCase
fredia [Tue, 13 Sep 2022 06:56:24 +0000 (14:56 +0800)] 
[FLINK-29102] Fix unstable ChangelogLocalRecoveryITCase

This closes #20820.

12 days ago[FLINK-29113][table-planner] Throw exception when finding at least one invalid table...
xuyang [Mon, 29 Aug 2022 10:21:39 +0000 (18:21 +0800)] 
[FLINK-29113][table-planner] Throw exception when finding at least one invalid table name in join hints

This closes #20705