flink.git
3 hours ago[FLINK-26771][hive] Fix incomparable exception between boolean type and numeric type... master
yuxia Luo [Fri, 12 Aug 2022 14:49:54 +0000 (22:49 +0800)] 
[FLINK-26771][hive] Fix incomparable exception between boolean type and numeric type in Hive dialect

This closes #19182

5 hours ago[FLINK-28932][Table/SQL] Remove use of deprecated method
Sergey Nuyanzin [Fri, 12 Aug 2022 13:09:02 +0000 (15:09 +0200)] 
[FLINK-28932][Table/SQL] Remove use of deprecated method

5 hours ago[FLINK-27399][Connector/Pulsar] Change initial consuming position setting logic for...
Yufan Sheng [Fri, 12 Aug 2022 12:48:34 +0000 (20:48 +0800)] 
[FLINK-27399][Connector/Pulsar] Change initial consuming position setting logic for better handle the checkpoint. (#19972)

* Change the initial start cursor and stop cursor to better handle the consuming behaviors.
* Create the initial subscription instead seek every time. This should fix the wrong position setting.
* Fix the wrong stop cursor, make sure it stops at the correct space
* Drop Consumer.seek() for https://github.com/apache/pulsar/pull/16171

8 hours ago[FLINK-28942][network] Fix the deadlock bug when recycling readers for SortMergeResul...
Yuxin Tan [Fri, 12 Aug 2022 09:44:38 +0000 (17:44 +0800)] 
[FLINK-28942][network] Fix the deadlock bug when recycling readers for SortMergeResultPartition

This closes #20560.

10 hours ago[FLINK-28626][tests] Fix unstable RescaleCheckpointManuallyITCase when unaligned...
fredia [Tue, 2 Aug 2022 10:10:27 +0000 (18:10 +0800)] 
[FLINK-28626][tests] Fix unstable RescaleCheckpointManuallyITCase when unaligned checkpoint is enabled

11 hours ago[FLINK-27570][runtime] Count checkpoint finalization failures in CheckpointFailureManager
鲍健昕 [Wed, 20 Jul 2022 02:35:40 +0000 (10:35 +0800)] 
[FLINK-27570][runtime] Count checkpoint finalization failures in CheckpointFailureManager

11 hours ago[FLINK-28921][python][docs] Optimize the Python DataStream Window Documentation
huangxingbo [Fri, 12 Aug 2022 03:33:27 +0000 (11:33 +0800)] 
[FLINK-28921][python][docs] Optimize the Python DataStream Window Documentation

This closes #20557.

14 hours ago[hotfix][python][dcos] Fix the typos in the Metrics Doc
huangxingbo [Fri, 12 Aug 2022 04:06:02 +0000 (12:06 +0800)] 
[hotfix][python][dcos] Fix the typos in the Metrics Doc

15 hours ago[FLINK-27856][k8s] Fix the NPE when no spec is configured in pod template
PengYuan [Fri, 12 Aug 2022 03:04:29 +0000 (11:04 +0800)] 
[FLINK-27856][k8s] Fix the NPE when no spec is configured in pod template

This closes #20516.

15 hours ago[FLINK-28767][sql-gateway] Fix unstable SqlGatewayServiceITCase.testCancelOperation
Shengkai [Wed, 10 Aug 2022 07:53:15 +0000 (15:53 +0800)] 
[FLINK-28767][sql-gateway] Fix unstable SqlGatewayServiceITCase.testCancelOperation

30 hours ago[FLINK-28887][python] Fix the bug of custom metrics in Thread Mode
huangxingbo [Thu, 11 Aug 2022 02:35:37 +0000 (10:35 +0800)] 
[FLINK-28887][python] Fix the bug of custom metrics in Thread Mode

This closes #20540.

31 hours ago[FLINK-27588][python][docs] Update broadcast state related documentation (#20550)
Juntao Hu [Thu, 11 Aug 2022 11:23:45 +0000 (19:23 +0800)] 
[FLINK-27588][python][docs] Update broadcast state related documentation (#20550)

32 hours ago[FLINK-28888] The statistics of HsResultPartition are not updated correctly
Weijie Guo [Tue, 9 Aug 2022 11:19:54 +0000 (19:19 +0800)] 
[FLINK-28888] The statistics of HsResultPartition are not updated correctly

This closes #20528

32 hours ago[FLINK-28884] Reset needNotify to true when get a zero backlog.
Weijie Guo [Wed, 10 Aug 2022 06:49:00 +0000 (14:49 +0800)] 
[FLINK-28884] Reset needNotify to true when get a zero backlog.

HsSubpartitionView should be notifiable when downstream get a zero backlog. Generally speaking, if the backlog is zero, when data become available, even if there is no credit, the backlog information will be notified also. However, in the hybrid shuffle, the notification will be ignored. This behavior is incorrect.

This closes #20529

32 hours ago[FLINK-28884] HsSubpartitionView should be initialized to a notifiable state.
Weijie Guo [Fri, 5 Aug 2022 02:33:23 +0000 (10:33 +0800)] 
[FLINK-28884] HsSubpartitionView should be initialized to a notifiable state.

HsSubpartitionView should be initialized to a notifiable state, there may be a problem of never consuming otherwise. Imagine the following situation: Downstream task has no initial credit(i.e. exclusive buffers is configured to zero), if there is no data output in the upstream, it will feedback a zero backlog to downstream input channel. All subsequent data available notifications will be intercepted as needNotify is false.

34 hours ago[FLINK-28783] [flink-core] Fix typo in ConfigOptions's example code
gongzhongqiang [Thu, 11 Aug 2022 08:19:33 +0000 (16:19 +0800)] 
[FLINK-28783] [flink-core] Fix typo in ConfigOptions's example code

This closes #20427.

2 days ago[FLINK-28900] Fix RecreateOnResetOperatorCoordinatorTest compilation failure
yunfengzhou-hub [Wed, 10 Aug 2022 16:28:37 +0000 (00:28 +0800)] 
[FLINK-28900] Fix RecreateOnResetOperatorCoordinatorTest compilation failure

This closes #20532.

2 days ago[FLINK-28898][state/changelog] Fix unstable ChangelogRecoverySwitchStateBackendITCase...
Hangxiang Yu [Wed, 10 Aug 2022 10:24:24 +0000 (18:24 +0800)] 
[FLINK-28898][state/changelog] Fix unstable ChangelogRecoverySwitchStateBackendITCase#testSwitchFromEnablingToDisablingWithRescalingOut

2 days ago[FLINK-28904][python][docs] Add missing connector/format documentation
Juntao Hu [Wed, 10 Aug 2022 08:43:01 +0000 (16:43 +0800)] 
[FLINK-28904][python][docs] Add missing connector/format documentation

This closes #20535.

2 days ago[FLINK-28895][python] Perform RowRowConverter automically when writing RowData into...
Juntao Hu [Wed, 10 Aug 2022 02:21:38 +0000 (10:21 +0800)] 
[FLINK-28895][python] Perform RowRowConverter automically when writing RowData into sink

This closes #20525.

2 days ago[hotfix][python] Move json/avro/csv SerializationSchema implementations into the...
Dian Fu [Wed, 10 Aug 2022 03:29:52 +0000 (11:29 +0800)] 
[hotfix][python] Move json/avro/csv SerializationSchema implementations into the corresponding files

2 days ago[FLINK-28060][kafka] Bump Kafka to 3.2.1
Chesnay Schepler [Wed, 10 Aug 2022 10:13:55 +0000 (12:13 +0200)] 
[FLINK-28060][kafka] Bump Kafka to 3.2.1

2 days ago[FLINK-28849][table-planner] Fix errors when enable retry on async lookup and add...
lincoln lee [Tue, 9 Aug 2022 10:14:08 +0000 (18:14 +0800)] 
[FLINK-28849][table-planner] Fix errors when enable retry on async lookup and add more tests

Disable retry on async because of two problems need to be resolved first

This closes #20482

2 days ago[hotfix][runtime] Do last attempt without successfully canceling the retry timer...
lincoln lee [Tue, 9 Aug 2022 09:53:04 +0000 (17:53 +0800)] 
[hotfix][runtime] Do last attempt without successfully canceling the retry timer to prevent unexpected incomplete element during finish phase in AsyncWaitOperator

It is hard to reproduce this in runtime tests, but occasionally happens in AsyncLookupJoinITCase#testAsyncJoinTemporalTableWithLookupThresholdWithSufficientRetry of FLINK-28849. It's better to add a separate test in runtime.

This closes #20482

2 days ago[hotfix][table-planner] Use scala isInstanceOf to check lookup function type instead...
lincoln lee [Tue, 9 Aug 2022 08:59:00 +0000 (16:59 +0800)] 
[hotfix][table-planner] Use scala isInstanceOf to check lookup function type instead of one-level parent class compartion in LookupJoinCodeGenerator

This bug can be reproduced by AsyncLookupJoinITCase#testAsyncJoinTemporalTableWithLookupThresholdWithInsufficientRetry when caching is disabled in FLINK-28849

This closes #20482

2 days ago[FLINK-28848][table-planner] Introduces LOOKUP join hint to support delayed retry...
lincoln lee [Sat, 6 Aug 2022 15:42:26 +0000 (23:42 +0800)] 
[FLINK-28848][table-planner] Introduces LOOKUP join hint to support delayed retry for lookup join (table alias unsupported in hint)

This is the main part of FLINK-28779 to implement FLIP-234: Support Retryable Lookup Join To Solve Delayed Updates Issue In External Systems

This closes #20482

2 days ago[FLINK-28632][sql-gateway][hive] Allow to GetColumns/GetPrimaryKeys/GetTableTypes...
yuzelin [Tue, 9 Aug 2022 02:46:52 +0000 (10:46 +0800)] 
[FLINK-28632][sql-gateway][hive] Allow to GetColumns/GetPrimaryKeys/GetTableTypes in the HiveServer2 Endpoint

This closes #20493

2 days ago[FLINK-28774][hive] Allow user to configure whether to enable sort not when it's...
yuxia Luo [Wed, 10 Aug 2022 05:26:23 +0000 (13:26 +0800)] 
[FLINK-28774][hive] Allow user to configure whether to enable sort not when it's for dynamic partition writing for HiveSource

This closes #20419

2 days ago[FLINK-28481][k8s] Bump the fabric8 kubernetes client to 5.12.3
bzhao [Wed, 10 Aug 2022 02:58:34 +0000 (10:58 +0800)] 
[FLINK-28481][k8s] Bump the fabric8 kubernetes client to 5.12.3

This closes #20390.

2 days ago[FLINK-28821][table-planner] Adjust join cost for dpp query pattern which could help...
zhengyunhong.zyh [Fri, 5 Aug 2022 07:34:39 +0000 (15:34 +0800)] 
[FLINK-28821][table-planner] Adjust join cost for dpp query pattern which could help more plans use dpp

This closes #20462

2 days ago[FLINK-26929][table-runtime] Introduce adaptive hash join strategy for batch hash...
Ron [Wed, 10 Aug 2022 02:23:05 +0000 (10:23 +0800)] 
[FLINK-26929][table-runtime] Introduce adaptive hash join strategy for batch hash join (#20365)

2 days ago[FLINK-27338][hive] Improve splitting file for Hive source
luoyuxia [Wed, 27 Jul 2022 09:11:45 +0000 (17:11 +0800)] 
[FLINK-27338][hive] Improve splitting file for Hive source

This closes #20377

2 days ago[FLINK-28701] Remove WIP prefix of ALL_EXCHANGE_HYBRID_FULL and ALL_EXCHANGE_HYBRID_S...
Weijie Guo [Mon, 8 Aug 2022 08:02:08 +0000 (16:02 +0800)] 
[FLINK-28701] Remove WIP prefix of ALL_EXCHANGE_HYBRID_FULL and ALL_EXCHANGE_HYBRID_SELECTIVE in BatchShuffleMode and expose them to documents.

This closes #20429

2 days ago[FLINK-28701] RestartPipelinedRegionFailoverStrategy takes reConsumable into account...
Weijie Guo [Wed, 27 Jul 2022 08:46:42 +0000 (16:46 +0800)] 
[FLINK-28701] RestartPipelinedRegionFailoverStrategy takes reConsumable into account when decide partition available.

2 days ago[FLINK-28701] Split HYBRID result partition type to HYBRID_FULL and HYBRID_SELECTIVE.
Weijie Guo [Mon, 8 Aug 2022 07:41:16 +0000 (15:41 +0800)] 
[FLINK-28701] Split HYBRID result partition type to HYBRID_FULL and HYBRID_SELECTIVE.

2 days ago[hotfix] Migrate RestartPipelinedRegionFailoverStrategyTest to Junit5 and AssertJ.
Weijie Guo [Fri, 29 Jul 2022 03:24:04 +0000 (11:24 +0800)] 
[hotfix] Migrate RestartPipelinedRegionFailoverStrategyTest to Junit5 and AssertJ.

2 days ago[FLINK-28876][python][format/orc] Support Orc format
Juntao Hu [Mon, 8 Aug 2022 15:23:44 +0000 (23:23 +0800)] 
[FLINK-28876][python][format/orc] Support Orc format

This closes #20505.

2 days ago[FLINK-28868][connector/hbase] Migrate HBase table connector to the new LookupFunctio...
Qingsheng Ren [Mon, 8 Aug 2022 09:51:13 +0000 (17:51 +0800)] 
[FLINK-28868][connector/hbase] Migrate HBase table connector to the new LookupFunction interface

This closes #20495

2 days ago[refactor][state/changelog] Rename ChangelogPeriodicMaterialization* to ChangelogReco...
fredia [Thu, 4 Aug 2022 09:30:19 +0000 (17:30 +0800)] 
[refactor][state/changelog] Rename ChangelogPeriodicMaterialization* to ChangelogRecovery*

2 days ago[FLINK-28529][state/changelog] Fix unstable ChangelogPeriodicMaterializationSwitchSta...
fredia [Mon, 1 Aug 2022 08:13:05 +0000 (16:13 +0800)] 
[FLINK-28529][state/changelog] Fix unstable ChangelogPeriodicMaterializationSwitchStateBackendITCase#testSwitchFromDisablingToEnablingInClaimMode

2 days ago[FLINK-28532][table] Support full caching in lookup join runner using InputFormats...
SmirAlex [Tue, 9 Aug 2022 21:12:29 +0000 (04:12 +0700)] 
[FLINK-28532][table] Support full caching in lookup join runner using InputFormats as scan runtime provider (#20447)

2 days ago[FLINK-28731][conf] Log dynamic properties
Chesnay Schepler [Thu, 28 Jul 2022 13:40:18 +0000 (15:40 +0200)] 
[FLINK-28731][conf] Log dynamic properties

3 days ago[FLINK-28797][hive] Simplify useModules for the parquet complex type tests
Jark Wu [Tue, 9 Aug 2022 07:27:45 +0000 (15:27 +0800)] 
[FLINK-28797][hive] Simplify useModules for the parquet complex type tests

3 days ago[FLINK-28797][hive] HiveSource enables vector reading for complex data type with...
luoyuxia [Sun, 7 Aug 2022 09:11:44 +0000 (17:11 +0800)] 
[FLINK-28797][hive] HiveSource enables vector reading for complex data type with parquet format

3 days ago[FLINK-28778][SQL/API] Bulk fetch of table and column statistics for given partitions
yuxia Luo [Tue, 9 Aug 2022 15:41:19 +0000 (23:41 +0800)] 
[FLINK-28778][SQL/API] Bulk fetch of table and column statistics for given partitions

This closes #20501

Co-authored-by: Jing Ge <gejing@gmail.com>
3 days ago[FLINK-28886][python] Support HybridSource in Python DataStream API
Dian Fu [Tue, 9 Aug 2022 09:39:06 +0000 (17:39 +0800)] 
[FLINK-28886][python] Support HybridSource in Python DataStream API

This closes #20515.

3 days ago[FLINK-28862][python][format/parquet] Support ParquetBulkWriter
Juntao Hu [Mon, 8 Aug 2022 08:23:45 +0000 (16:23 +0800)] 
[FLINK-28862][python][format/parquet] Support ParquetBulkWriter

This closes #20499.

3 days ago[FLINK-28623][network] Optimize the use of off-heap memory by blocking and hybrid...
Weijie Guo [Tue, 2 Aug 2022 17:51:23 +0000 (01:51 +0800)] 
[FLINK-28623][network] Optimize the use of off-heap memory by blocking and hybrid shuffle reader

Currently, each FileReader (PartitionFileReader or HsSubpartitionFileReaderImpl) will internally allocate a headerBuffer with the size of 8B. Besides, PartitionFileReader also has a 12B indexEntryBuf. Because FileReader is of subpartition granularity, if the parallelism becomes very big, and there are many slots on each TM, the memory occupation will even reach the MB level. In fact, all FileReaders of the same ResultPartition read data in a single thread, so we only need to allocate one headerBuffer for each ResultPartition to optimize it.

This closes #20333.

3 days ago[hotfix] Migrate PartitionFileWriteReadTest, SortMergeResultPartitionReadSchedulerTes...
Weijie Guo [Tue, 2 Aug 2022 17:38:35 +0000 (01:38 +0800)] 
[hotfix] Migrate PartitionFileWriteReadTest, SortMergeResultPartitionReadSchedulerTest, SortMergeSubpartitionReaderTest to Junit5 and AssertJ

This closes #20333.

3 days ago[FLINK-28857][docs] Add Document for DataStream Cache API
sxnan [Mon, 8 Aug 2022 07:21:14 +0000 (15:21 +0800)] 
[FLINK-28857][docs] Add Document for DataStream Cache API

This closes #20491.

3 days ago[FLINK-28871][table-planner] Force the output edges of dynamic filtering data collect...
Yun Gao [Mon, 8 Aug 2022 10:33:56 +0000 (18:33 +0800)] 
[FLINK-28871][table-planner] Force the output edges of dynamic filtering data collector to be BLOCKING

This closes #20497.

3 days ago[hotfix][python] Refactor thread mode Python runtime to make it more readable
Dian Fu [Tue, 9 Aug 2022 08:13:22 +0000 (16:13 +0800)] 
[hotfix][python] Refactor thread mode Python runtime to make it more readable

3 days ago[FLINK-28487][connectors] Introduce configurable RateLimitingStrategy for AsyncSinkWriter
Hong Teoh [Mon, 11 Jul 2022 16:34:03 +0000 (17:34 +0100)] 
[FLINK-28487][connectors] Introduce configurable RateLimitingStrategy for AsyncSinkWriter

3 days ago[FLINK-28854][connector/jdbc] Migrate JDBC lookup table to the new LookupFunction...
Qingsheng Ren [Mon, 25 Jul 2022 10:17:27 +0000 (18:17 +0800)] 
[FLINK-28854][connector/jdbc] Migrate JDBC lookup table to the new LookupFunction and caching interface

3 days ago[FLINK-28873][configuration] Make jobmanager.scheduler visible in documentation
Lijie Wang [Mon, 8 Aug 2022 13:41:54 +0000 (21:41 +0800)] 
[FLINK-28873][configuration] Make jobmanager.scheduler visible in documentation

3 days ago[FLINK-28606][Runtime/Checkpointing] Refractor coordination tests with JUnit5 Assertions
yunfengzhou-hub [Mon, 8 Aug 2022 11:32:54 +0000 (19:32 +0800)] 
[FLINK-28606][Runtime/Checkpointing] Refractor coordination tests with JUnit5 Assertions

3 days ago[FLINK-28606][Runtime/Checkpointing] Preserve consistency of OperatorEvent from Opera...
yunfengzhou-hub [Mon, 8 Aug 2022 11:23:42 +0000 (19:23 +0800)] 
[FLINK-28606][Runtime/Checkpointing] Preserve consistency of OperatorEvent from OperatorCoordinator to subtasks

3 days ago[FLINK-28178][runtime-web] Show the delegated StateBackend and whether changelog...
wangfeifan [Wed, 29 Jun 2022 07:58:46 +0000 (15:58 +0800)] 
[FLINK-28178][runtime-web] Show the delegated StateBackend and whether changelog is enabled in the UI

3 days ago[FLINK-27693][docs] Remove local recovery from the Limitations of changelog
fredia [Mon, 8 Aug 2022 15:45:45 +0000 (23:45 +0800)] 
[FLINK-27693][docs] Remove local recovery from the Limitations of changelog

3 days ago[FLINK-27693][changelog] Support local recovery for non-materialized part
fredia [Tue, 31 May 2022 07:22:59 +0000 (15:22 +0800)] 
[FLINK-27693][changelog] Support local recovery for non-materialized part

3 days ago[FLINK-28711][hive] Hive source supports dynamic filtering
Gen Luo [Tue, 2 Aug 2022 12:16:58 +0000 (20:16 +0800)] 
[FLINK-28711][hive] Hive source supports dynamic filtering

This closes #20415

3 days ago[FLINK-28860][tests] Disable CacheITCase temporarily
sxnan [Tue, 9 Aug 2022 08:41:50 +0000 (16:41 +0800)] 
[FLINK-28860][tests] Disable CacheITCase temporarily

This closes #20512.

3 days ago[FLINK-25244][hbase] Enable Java 11 tests for HBase 2.2
Chesnay Schepler [Thu, 4 Aug 2022 10:07:38 +0000 (12:07 +0200)] 
[FLINK-25244][hbase] Enable Java 11 tests for HBase 2.2

3 days ago[hotfix][build][hbase] Remove unused property
Chesnay Schepler [Thu, 4 Aug 2022 10:07:25 +0000 (12:07 +0200)] 
[hotfix][build][hbase] Remove unused property

3 days ago[FLINK-28785][network] Hybrid shuffle consumer thread and upstream thread may have...
Weijie Guo [Wed, 3 Aug 2022 06:24:21 +0000 (14:24 +0800)] 
[FLINK-28785][network] Hybrid shuffle consumer thread and upstream thread may have deadlock.

In hybrid shuffle mode, subpartition view lock will be acquired by consumer thread, and further wait the read lock of MemoryDataManager. But MemoryDataManager may acquire write lock to make a global spilling decision, and then wait subpartition view lock to get consuming offset. In this case, deadlock will occurs.

consumer thread : acqurie subpartition lock -> wait read lock.

upstream thread  : acquire write lock -> wait subpartition lock.

This closes #20456

3 days ago[FLINK-25485][connector/jdbc] Add default jdbc option 'rewriteBatchedStatements'...
Luning (Lucas) Wang [Tue, 9 Aug 2022 08:18:59 +0000 (16:18 +0800)] 
[FLINK-25485][connector/jdbc] Add default jdbc option 'rewriteBatchedStatements' for MySQL dialect

This closes #18469.

3 days ago[FLINK-28373][network] Read a full buffer of data per file IO read request for sort...
Yuxin Tan [Tue, 9 Aug 2022 06:48:39 +0000 (14:48 +0800)] 
[FLINK-28373][network] Read a full buffer of data per file IO read request for sort-shuffle

This closes #20457.

3 days ago[FLINK-26413][hive] Supports "LOAD DATA INPATH" in Hive dialect
yuxia Luo [Tue, 9 Aug 2022 06:46:37 +0000 (14:46 +0800)] 
[FLINK-26413][hive] Supports "LOAD DATA INPATH" in Hive dialect

This closes #19556

3 days ago[FLINK-28094][kinesis][glue] Updating AWS SDK versions for Kinesis connectors and...
Danny Cranmer [Sat, 6 Aug 2022 01:15:06 +0000 (02:15 +0100)] 
[FLINK-28094][kinesis][glue] Updating AWS SDK versions for Kinesis connectors and Glue Schema Registry formats

3 days ago[FLINK-27155][changelog] Reduce multiple reads to the same Changelog file in the...
wangfeifan [Sun, 17 Apr 2022 07:34:07 +0000 (15:34 +0800)] 
[FLINK-27155][changelog] Reduce multiple reads to the same Changelog file in the same taskmanager during restore

3 days ago[FLINK-28880][docs][cep] Fix wrong result of strict contiguity of looping patterns
Juntao Hu [Tue, 9 Aug 2022 03:15:11 +0000 (11:15 +0800)] 
[FLINK-28880][docs][cep] Fix wrong result of strict contiguity of looping patterns

This closes #20508.

3 days ago[FLINK-28699][state] Make non-incremental rocksdb checkpoint as native format
Lihe Ma [Thu, 30 Jun 2022 02:42:28 +0000 (10:42 +0800)] 
[FLINK-28699][state] Make non-incremental rocksdb checkpoint as native format

This closes #20399.

3 days ago[FLINK-28568][table-runtime] Implements a new lookup join operator (sync mode only...
lincoln.lil [Fri, 29 Jul 2022 13:11:28 +0000 (21:11 +0800)] 
[FLINK-28568][table-runtime] Implements a new lookup join operator (sync mode only) with state to eliminate non-deterministic result

This closes #20324

3 days ago[FLINK-28843][StateBackend] Fix restore from incremental checkpoint with changelog...
Lihe Ma [Sat, 6 Aug 2022 12:02:33 +0000 (20:02 +0800)] 
[FLINK-28843][StateBackend] Fix restore from incremental checkpoint with changelog checkpoint in claim mode

3 days ago[FLINK-28753][table-planner] Improve FilterIntoJoinRule which could push some predica...
godfreyhe [Wed, 3 Aug 2022 07:26:32 +0000 (15:26 +0800)] 
[FLINK-28753][table-planner] Improve FilterIntoJoinRule which could push some predicates to another side

For the above filter of inner/left/right join or the join condition of inner join, the predicate which field references are all from one side join condition can be pushed into another join side

This closes #20432

3 days ago[FLINK-28183][python] Model python test dependencies in Maven
Chesnay Schepler [Wed, 3 Aug 2022 08:04:37 +0000 (10:04 +0200)] 
[FLINK-28183][python] Model python test dependencies in Maven

This closes #20470.

3 days ago[FLINK-28799] PipelinedRegionSchedulingStrategy supports all resultPartitionType.
Weijie Guo [Fri, 5 Aug 2022 06:55:38 +0000 (14:55 +0800)] 
[FLINK-28799] PipelinedRegionSchedulingStrategy supports all resultPartitionType.

This closes #20487

3 days ago[FLINK-28799] PipelinedRegionSchedulingStrategy maintain scheduled regions
Weijie Guo [Fri, 5 Aug 2022 06:55:08 +0000 (14:55 +0800)] 
[FLINK-28799] PipelinedRegionSchedulingStrategy maintain scheduled regions

3 days ago[hotfix] Migrate PipelinedRegionSchedulingStrategyTest and StrategyTestUtil to Junit5...
Weijie Guo [Fri, 5 Aug 2022 06:34:23 +0000 (14:34 +0800)] 
[hotfix] Migrate PipelinedRegionSchedulingStrategyTest and StrategyTestUtil to Junit5 and AssertJ.

3 days ago[FLINK-28163][sql-gateway]Introduce the statement related API for REST endpoint
Wencong Liu [Sat, 23 Jul 2022 11:37:26 +0000 (19:37 +0800)] 
[FLINK-28163][sql-gateway]Introduce the statement related API for REST endpoint

This closes #20451

3 days ago[FLINK-28164][sql-gateway]Introduce utilities API for REST endpoint
Wencong Liu [Fri, 22 Jul 2022 09:57:34 +0000 (17:57 +0800)] 
[FLINK-28164][sql-gateway]Introduce utilities API for REST endpoint

3 days ago[FLINK-28162][sql-gateway]Introduce the operation related API for REST endpoint
Wencong Liu [Tue, 26 Jul 2022 09:21:45 +0000 (17:21 +0800)] 
[FLINK-28162][sql-gateway]Introduce the operation related API for REST endpoint

3 days ago[hotfix][sql-gateway] Use camelCase for REST request/response body fields in session...
Wencong Liu [Sat, 6 Aug 2022 07:35:24 +0000 (15:35 +0800)] 
[hotfix][sql-gateway] Use camelCase for REST request/response body fields in session related APIs.

3 days ago[FLINK-28631][sql-gateway][hive] Support to GetFunctions in the HiveServer2Endpoint
Shengkai [Sat, 6 Aug 2022 14:44:01 +0000 (22:44 +0800)] 
[FLINK-28631][sql-gateway][hive] Support to GetFunctions in the HiveServer2Endpoint

This closes #20479

3 days ago[FLINK-24614][parquet] Support complex types (arrya, map, row) for parquet reader
Ron [Tue, 9 Aug 2022 01:57:00 +0000 (09:57 +0800)] 
[FLINK-24614][parquet] Support complex types (arrya, map, row) for parquet reader

This closes #20442

3 days ago[FLINK-28380][runtime] Produce one intermediate dataset for multiple consumer job...
kevin.cyj [Mon, 25 Jul 2022 08:22:50 +0000 (16:22 +0800)] 
[FLINK-28380][runtime] Produce one intermediate dataset for multiple consumer job vertices consuming the same data

This closes #20351.

3 days ago[FLINK-28865] Add new PrintSink
Chesnay Schepler [Mon, 8 Aug 2022 23:04:25 +0000 (01:04 +0200)] 
[FLINK-28865] Add new PrintSink

3 days ago[FLINK-23252][state/changelog] [docs] Update the docs about disabling changelog
Hangxiang Yu [Thu, 7 Jul 2022 17:12:47 +0000 (01:12 +0800)] 
[FLINK-23252][state/changelog] [docs] Update the docs about disabling changelog

3 days ago[FLINK-28094][kinesis] Removing references to Regions enum and instead using RegionUt...
Hong Teoh [Mon, 8 Aug 2022 09:52:32 +0000 (10:52 +0100)] 
[FLINK-28094][kinesis] Removing references to Regions enum and instead using RegionUtils so that we include future AWS Regions as well

4 days ago[FLINK-28621] Enable Date/Time&Optional support for all mappers
Chesnay Schepler [Fri, 5 Aug 2022 11:45:18 +0000 (13:45 +0200)] 
[FLINK-28621] Enable Date/Time&Optional support for all mappers

4 days ago[FLINK-28621][core] Add central Jackson mapper factory methods
Chesnay Schepler [Thu, 28 Jul 2022 14:02:26 +0000 (16:02 +0200)] 
[FLINK-28621][core] Add central Jackson mapper factory methods

4 days ago[FLINK-28621][formats] Initialize mappers in open()
Chesnay Schepler [Thu, 28 Jul 2022 14:09:43 +0000 (16:09 +0200)] 
[FLINK-28621][formats] Initialize mappers in open()

4 days ago[hotfix][csv][tests] Open schemas
Chesnay Schepler [Sun, 7 Aug 2022 15:22:42 +0000 (17:22 +0200)] 
[hotfix][csv][tests] Open schemas

4 days ago[FLINK-28663][runtime] Allow multiple downstream consumer job vertices sharing the...
kevin.cyj [Mon, 25 Jul 2022 08:03:28 +0000 (16:03 +0800)] 
[FLINK-28663][runtime] Allow multiple downstream consumer job vertices sharing the same intermediate dataset at scheduler side

This closes #20350.

4 days ago[hotfix][tests] Migrate tests relevant to FLINK-28663 to Junit5/AssertJ
kevin.cyj [Wed, 27 Jul 2022 11:57:01 +0000 (19:57 +0800)] 
[hotfix][tests] Migrate tests relevant to FLINK-28663 to Junit5/AssertJ

Migrated tests include DefaultExecutionGraphConstructionTest, EdgeManagerBuildUtilTest, EdgeManagerTest, ExecutionJobVertexTest, IntermediateResultPartitionTest, RemoveCachedShuffleDescriptorTest, JobTaskVertexTest, DefaultExecutionTopologyTest, DefaultExecutionVertexTest, DefaultResultPartitionTest, AdaptiveBatchSchedulerTest and ForwardGroupComputeUtilTest.

This closes #20350.

4 days ago[hotfix][python] Make the format imports more explicit by adding format type
Dian Fu [Mon, 8 Aug 2022 10:20:56 +0000 (18:20 +0800)] 
[hotfix][python] Make the format imports more explicit by adding format type

4 days ago[refactor][state] Rename createInternalState to createOrUpdateInternalState
Hangxiang Yu [Thu, 4 Aug 2022 15:28:45 +0000 (23:28 +0800)] 
[refactor][state] Rename createInternalState to createOrUpdateInternalState

4 days ago[FLINK-23143][state/changelog] Support state migration for ChangelogStateBackend
Hangxiang Yu [Mon, 23 May 2022 15:13:16 +0000 (23:13 +0800)] 
[FLINK-23143][state/changelog] Support state migration for ChangelogStateBackend

4 days ago[FLINK-28788][python] Support SideOutput in Thread Mode
huangxingbo [Mon, 8 Aug 2022 04:58:33 +0000 (12:58 +0800)] 
[FLINK-28788][python] Support SideOutput in Thread Mode

This closes #20488.

4 days ago[FLINK-28793][sql-gateway][hive] Allow to GetInfo in the HiveServer2 Endpoint
zhaoweinan [Wed, 3 Aug 2022 09:34:51 +0000 (17:34 +0800)] 
[FLINK-28793][sql-gateway][hive] Allow to GetInfo in the HiveServer2 Endpoint

This closes #20444