| 69ecda0 | Qingsheng Ren | 17 March 2023, 09:30:06 UTC | Commit for release 1.17.0 | 17 March 2023, 09:30:06 UTC |
| 09fb503 | Ran Tao | 03 March 2023, 17:51:26 UTC | [FLINK-31319][connectors/kafka] Fix kafka new source partitionDiscoveryIntervalMs error condition check cause bounded source can not quit | 17 March 2023, 09:26:27 UTC |
| 0bd6388 | Martijn Visser | 16 March 2023, 10:31:07 UTC | [hotfix] Sort NOTICE dependencies in alphabetical order | 17 March 2023, 07:54:55 UTC |
| 64f17ee | Martijn Visser | 16 March 2023, 10:29:50 UTC | [FLINK-31485][Confluent Avro] Change packaging of Schema Registry so that by default everything is included. This resolves the accidental exclusion of Guava, causing Avro Confluent Schema Registry to fail. | 17 March 2023, 07:54:55 UTC |
| 17ab9fd | felixzh | 07 March 2023, 02:12:50 UTC | [FLINK-31321][Deployment/YARN] Yarn-session mode, securityConfiguration supports dynamic configuration This closes #22119 | 17 March 2023, 01:55:16 UTC |
| 7e9cf7a | Hang Ruan | 15 March 2023, 15:35:13 UTC | [FLINK-30959][table][docs] Improve the documentation of UNIX_TIMESTAMP function for different argument formats This closes #22187. | 15 March 2023, 15:35:13 UTC |
| 0dfb5ab | wangfeifan | 13 March 2023, 08:11:21 UTC | [FLINK-31414][checkpointing] make BarrierAlignmentUtil.DelayableTimer not hidden exception | 15 March 2023, 10:17:39 UTC |
| 3327862 | zhengyunhong.zyh | 01 March 2023, 07:28:50 UTC | [FLINK-31273][table-planner] Fix left join with IS_NULL filter be wrongly pushed down and get wrong join results This closes #22049 (cherry picked from commit 8990822bd77d70f3249e1220a853e16dadd8ef54) | 15 March 2023, 09:50:20 UTC |
| 6eb213d | Weijie Guo | 13 March 2023, 15:09:08 UTC | [FLINK-31420][test] Fix unstable test ThreadInfoRequestCoordinatorTest#testShutDown. testShutDown using two gateways contains a timeout gateway but expected all request futures not done before shutdown. If the timeout reached, this future will be failed, result in request future to be done. | 15 March 2023, 09:46:26 UTC |
| 43fafd4 | Junrui Lee | 15 March 2023, 09:18:11 UTC | [FLINK-31437][hbase][docs] Fix wrong key 'lookup.cache.caching-missing-key' in 'hbase.md' | 15 March 2023, 09:40:24 UTC |
| 4e52803 | Yuxin Tan | 14 March 2023, 09:55:20 UTC | [FLINK-31418][network][tests] Fix unstable test case SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout This closes #22172. | 14 March 2023, 09:55:20 UTC |
| a8d7ec9 | K.I. (Dennis) Jung | 13 March 2023, 08:03:16 UTC | [FLINK-31227][docs] Remove Scala suffix for ORC and Parquet format download links on the the FileSystem documentation. This closes #22039 Remove Scala suffix for ORC and Parquet format download links on the the FileSystem documentation (cherry picked from commit a8848f8d6aa700e0325e79a8f7b44f611d287cb3) | 13 March 2023, 08:09:49 UTC |
| 9080c7d | Shengkai | 13 March 2023, 07:26:46 UTC | [FLINK-30025][table][tests] Fix unstable tests by removing "-" and " " from table header of operator IDs This closes #22164. Co-authored-by: jingge <gejing@gmail.com> | 13 March 2023, 07:26:46 UTC |
| 02814d6 | Weijie Guo | 10 March 2023, 07:56:08 UTC | [FLINK-31393] Fix the bug that HsFileDataManager use an incorrect default timeout. | 11 March 2023, 13:43:58 UTC |
| b90bf7a | kevin.cyj | 09 March 2023, 03:52:21 UTC | [FLINK-31386][network] Fix the potential deadlock issue of blocking shuffle Currently, the SortMergeResultPartition may allocate more network buffers than the guaranteed size of the LocalBufferPool. As a result, some result partitions may need to wait other result partitions to release the over-allocated network buffers to continue. However, the result partitions which have allocated more than guaranteed buffers relies on the processing of input data to trigger data spilling and buffer recycling. The input data further relies on batch reading buffers used by the SortMergeResultPartitionReadScheduler which may already taken by those blocked result partitions that are waiting for buffers. Then deadlock occurs. This patch fixes the deadlock issue by reserving the guaranteed buffers on initializing. This closes #22148. | 10 March 2023, 14:32:06 UTC |
| 5b90c07 | JunRuiLee | 08 March 2023, 02:57:30 UTC | [FLINK-31144][coordination] Ignore the input locations of a ConsumePartitionGroup if it has too many consumers This closes #22098. | 10 March 2023, 09:08:32 UTC |
| 704076a | Wencong Liu | 06 March 2023, 14:08:34 UTC | [FLINK-31298] fix ConnectionUtilsTest.testFindConnectingAddressWhenGetLocalHostThrows swallows IllegalArgumentException | 09 March 2023, 06:00:16 UTC |
| 32b3701 | Shengkai | 08 March 2023, 04:12:05 UTC | [FLINK-31351][sql-gateway] Don't stop the stuck thread by force This closes #22127 | 08 March 2023, 11:48:28 UTC |
| 54c67e5 | Weijie Guo | 06 March 2023, 14:40:53 UTC | [FLINK-31346][runtime] IO scheduler does not throw TimeoutException if numRequestedBuffers is greater than 0. This will cause deadlock as read buffer was occupied by a reader with low consumption priority. This closes #22122 (cherry picked from commit 5ad2ae2c24ade2655981f609298978d26329466f) | 08 March 2023, 02:33:45 UTC |
| e8c7c10 | Weijie Guo | 06 March 2023, 14:29:43 UTC | [hotfix][runtime] IO Scheduler should handle un-expected exceptions. (cherry picked from commit faf663a6298c602d93c351f9971eed8aa8dabb93) | 08 March 2023, 02:33:20 UTC |
| e71e695 | Weijie Guo | 06 March 2023, 16:26:58 UTC | [hotfix][test] Remove meaningless reader in SortMergeResultPartitionReadSchedulerTest#testRequestTimeoutIsRefreshedAndSuccess. (cherry picked from commit a3068310ba90ad851f660d4efb43ddf364218cdb) | 08 March 2023, 02:33:20 UTC |
| bef6f51 | David Moravek | 07 March 2023, 12:39:51 UTC | [FLINK-31348][Docs] Fix unclosed shortcodes (/tabs) in the docs, that causes issues with Hugo version 0.111.0 and higher. This closes #22113 (cherry picked from commit 3ea83baad0c8413f8e1f4a027866335d13789538) | 07 March 2023, 12:42:23 UTC |
| c02099b | David Moravek | 06 March 2023, 18:38:02 UTC | [FLINK-31347] Prevent AdaptiveSchedulerClusterITCase.testAutomaticScaleUp timing out. We're starting TMs with two slots, and in case both slots don't arrive simultaneously, we might have an additional restart of the job. Unfortunately calling OnceBlockingNoOpInvokable#cancel would effectively unblock all future #invoke calls by setting the running flag to true. We address the issue by tracking this flag for each execution attempt separately. | 07 March 2023, 12:22:25 UTC |
| 865a056 | Shuiqiang Chen | 07 March 2023, 01:26:03 UTC | [FLINK-30922][table-planner] Fix errors when reference metadata columns in column list of a partial-insert statement This closes #22109 | 07 March 2023, 01:26:03 UTC |
| c43b3d2 | Juntao Hu | 06 March 2023, 12:48:56 UTC | [FLINK-31337][python] Fix python keyed broadcast batch operator input not sorted This closes #22107. | 06 March 2023, 15:35:37 UTC |
| c71d880 | Weihua Hu | 02 March 2023, 15:27:28 UTC | [FLINK-31297][Runtime] Use processResourceRequirements to allocate task manager in FineGrainedSlotManagerTest. We use TaskManagerTracker.addPendingTaskManager to allocate task manager in FineGrainedSlotManagerTest. This make the resource requirements different between FineGrainedSlotManager and TaskManagerTracker. And the FineGrainedSlotManager may trigger resource recycling after the requirementCheckDelay. So we use processResourceRequirements to allocate task manager. And set the requirementCheckDelay to 0 to stabilize this test. (cherry picked from commit bec6a4589703bb7619cfc04bf69822995b49893f) | 06 March 2023, 13:27:58 UTC |
| 5c1ec19 | Timo Walther | 27 February 2023, 13:37:30 UTC | [FLINK-31182][table] Fix CompiledPlan containing UNNEST This closes #22040. | 06 March 2023, 12:59:06 UTC |
| 5dddc0d | Shengkai | 06 March 2023, 10:15:35 UTC | [FLINK-30978][sql-client] Fix ExecutorImpl#testInterruptException hangs (#22099) | 06 March 2023, 10:15:35 UTC |
| 8acec2c | Yun Tang | 04 March 2023, 16:04:33 UTC | [FLINK-31324][connector] Reintroduce previous SingleThreadFetcherManager constructor and mark it as deprecated This closes #22094. | 06 March 2023, 10:12:47 UTC |
| 8ff09cb | Yuxin Tan | 15 February 2023, 04:37:48 UTC | [FLINK-30983][runtime] Support configured ssl algorithms for external REST SSL | 06 March 2023, 05:40:19 UTC |
| d2ef11f | Yuxin Tan | 15 February 2023, 06:00:19 UTC | [FLINK-30983][runtime] Migrate SSLUtilsTest to junit5 | 06 March 2023, 05:40:19 UTC |
| a708d65 | Dong Lin | 04 March 2023, 05:02:49 UTC | Update Flink build instruction to deprecate Java 8 instead of requiring Java 11 This closes #22092. | 04 March 2023, 05:02:49 UTC |
| 6e77037 | Roman Khachatryan | 25 February 2023, 21:24:46 UTC | [FLINK-31133][tests] Prevent timeouts in PartiallyFinishedSourcesITCase - Only obtain execution exception if the job is in globally terminal state - [hotfix] Unsubscribe finished TestEventSources from test commands. Otherwise, any command with SINGLE_SUBTASK scope might be dispatched to a finished source. This will result in TestJobExecutor.waitForFailover timing out while waiting for the command to be executed and ACKed. - [hotfix] Mark TestEventSource.scheduledCommands volatile - [hotfix] Make sure to process all commands in TestEventSource | 03 March 2023, 19:57:21 UTC |
| ac2eb5b | fengli | 27 February 2023, 09:44:46 UTC | [FLINK-31239][hive] Add some notes in document about table.exec.hive.native-agg-function.enabled option can't turned on per job when using it via SqlClient This closes #22031 (cherry picked from commit 62a3b99d23229b39c798a0b657cb11218a5bc940) | 03 March 2023, 12:33:36 UTC |
| 3bdb505 | fengli | 27 February 2023, 09:15:47 UTC | [FLINK-31239][hive] Fix native sum function can't get the corrected value when the argument type is string This closes #22031 (cherry picked from commit 263555c9adcca0abe194e9a6c1d85ec591c304e4) | 03 March 2023, 12:33:35 UTC |
| 0bdb51e | Ron | 20 February 2023, 12:52:47 UTC | [FLINK-30824][hive] Add document for option 'table.exec.hive.native-agg-function.enabled' This closes #21789 (cherry picked from commit afdc079465c393d98bf2b3607a75b1fc9d58d281) | 03 March 2023, 12:33:07 UTC |
| 7040af5 | Juntao Hu | 23 February 2023, 07:47:42 UTC | [FLINK-31185][python] Support side-output in broadcast processing This closes #22003. | 03 March 2023, 12:07:17 UTC |
| 86e12eb | Shengkai | 02 March 2023, 12:05:51 UTC | [FLINK-31092][table-common] Fix ServiceLoaderUtil keeps loading even though the classloader has been closed This closes #22072 Co-authored-by: Matthias Pohl <matthias.pohl@aiven.io> | 03 March 2023, 07:37:38 UTC |
| 5940106 | Shengkai | 02 March 2023, 09:57:55 UTC | [FLINK-31092][sql-gateway] Fix OperationManager can not kill the running task by force | 03 March 2023, 07:37:37 UTC |
| 7dd61c3 | Weijie Guo | 02 March 2023, 10:08:37 UTC | [FLINK-31288][doc] Update doc ralated to overdraft buffer. | 02 March 2023, 16:34:57 UTC |
| 9749699 | Weijie Guo | 02 March 2023, 07:29:25 UTC | [FLINK-31288][runtime] Disable overdraft buffer for non pipelined result partition. | 02 March 2023, 16:34:57 UTC |
| 30344f1 | Weihua Hu | 02 March 2023, 06:29:49 UTC | [FLINK-29852][Runtime] Fix AdaptiveScheduler add operator repeatedly in json plan. | 02 March 2023, 16:08:12 UTC |
| 3330881 | fengli | 26 February 2023, 07:59:33 UTC | [FLINK-30989][table] Fix some options don't take effect in batch mode This closes #22024 (cherry picked from commit b4d43b47c993b7b4d5e4f7a78610c54124fcbcb4) | 02 March 2023, 13:28:55 UTC |
| 30e32ea | Weihua Hu | 28 December 2022, 10:43:18 UTC | [FLINK-30517][log]Decrease log output interval while waiting for YARN JobManager be allocated. (cherry picked from commit 1993ad0c968efa60ad5071e8472f630b247251f0) | 02 March 2023, 07:52:24 UTC |
| ecec13a | Dian Fu | 02 March 2023, 03:48:03 UTC | [FLINK-31286][python] Make sure Python processes are cleaned up when TaskManager crashes This closes #22065. | 02 March 2023, 06:35:56 UTC |
| 3e02b30 | Jark Wu | 02 March 2023, 02:01:34 UTC | [FLINK-29729][parquet] Fix credential info configured in flink-conf.yaml is lost during creating ParquetReader (#22056) | 02 March 2023, 02:01:34 UTC |
| c19c6e5 | Dian Fu | 01 March 2023, 10:36:56 UTC | [FLINK-31272][python] Handle properly for SinkTransformation to avoid duplicate operators introduced by chaining optimization This closes #22053. | 01 March 2023, 13:19:28 UTC |
| 3de6b33 | JunRuiLee | 27 February 2023, 08:42:45 UTC | [FLINK-29859][e2e] Running TPC-DS with adaptive batch scheduler supports custom errors check. This closes #22029. | 28 February 2023, 11:53:01 UTC |
| 74743d0 | yunhong | 17 February 2023, 07:10:45 UTC | [FLINK-30971][table-planner] Modify the default value of parameter 'table.exec.local-hash-agg.adaptive.sampling-threshold' This closes #21900 (cherry picked from commit 55b927b0e6eb2d5d71487b9bb2c4dab80017a7e5) | 28 February 2023, 08:23:55 UTC |
| 65e4551 | Roc Marshal | 26 February 2023, 04:18:00 UTC | [FLINK-29816][streaming] Fix the bug that StreamTask doesn't handle exception during restoring (cherry picked from commit a98bb9a6c978d5458cf4cc11dc7b68034f4def4b) | 27 February 2023, 14:47:08 UTC |
| 95f93cc | Roc Marshal | 24 February 2023, 05:19:37 UTC | [hotfix] Migrate StreamTaskTest to Junit5 and Assertj (cherry picked from commit eb4106a166f367091d2f25a9aa0c522c461372c0) | 27 February 2023, 14:47:08 UTC |
| 29f4181 | Venkata krishnan Sowrirajan | 26 February 2023, 20:07:22 UTC | [FLINK-31109][Yarn] Support Hadoop proxy user when delegation token fetch is disabled. This closes #22009 * [FLINK-31109][yarn] Support Hadoop proxy user when delegation token fetch is disabled (cherry picked from commit 78136133fbec4ca145dec66d4bc0c324c8e16d82) | 27 February 2023, 13:53:52 UTC |
| dca8195 | JunRuiLee | 16 February 2023, 05:47:29 UTC | [FLINK-31077][runtime] Mark pending checkpoint onCompletionPromise complete only after the completed checkpoint is added to the checkpoint store. This closes #21943. | 27 February 2023, 06:54:50 UTC |
| 57175e8 | JunRuiLee | 15 February 2023, 10:30:44 UTC | [hotfix] Migrate PendingCheckpointTest to Junit5 and AssertJ. | 27 February 2023, 06:54:42 UTC |
| 6f30f5b | JunRuiLee | 15 February 2023, 10:30:03 UTC | [hotfix] Migrate DefaultSchedulerTest to Junit5 and AssertJ. | 27 February 2023, 06:54:36 UTC |
| 5ee98b5 | Mulavar | 21 December 2022, 13:25:24 UTC | [FLINK-30396][table-planner] Fix incorrect hint propagation into sub-query of lookup join hint This closes #21545 | 27 February 2023, 06:45:29 UTC |
| 05f207c | Sergey Nuyanzin | 26 February 2023, 13:58:09 UTC | [FLINK-31142][Table SQL/Client] Catch TokenMgrError in SqlCommandParserImpl#scan | 26 February 2023, 13:58:09 UTC |
| c66ef25 | Lijie Wang | 22 February 2023, 03:44:06 UTC | [FLINK-31114][runtime] Set parallelism of job vertices in forward group at compilation phase This closes #21963 | 24 February 2023, 11:35:54 UTC |
| 2a8e2f7 | Lijie Wang | 21 February 2023, 16:45:30 UTC | [FLINK-31114][runtime] Refactor the package path of ForwardGroup | 24 February 2023, 11:35:49 UTC |
| 6170615 | Weihua Hu | 23 February 2023, 06:18:27 UTC | [FLINK-27115][blob] Enrich the error log with remote address for blob server. | 24 February 2023, 07:43:30 UTC |
| e077380 | frankeshi | 15 February 2023, 12:23:03 UTC | [FLINK-31123][connector/files] Add IT case for FileSink speculative execution This closes #21968. | 23 February 2023, 10:14:24 UTC |
| 50021a2 | Weihua Hu | 20 February 2023, 07:39:06 UTC | [FLINK-31041][runtime] Fix multiple restoreState when GlobalFailure occurs in a short period. | 23 February 2023, 08:42:44 UTC |
| 1290842 | zhengyunhong.zyh | 16 February 2023, 11:14:24 UTC | [FLINK-31082][table-planner] Setting maven property 'flink.resueForks' to false in table planner module | 23 February 2023, 08:41:49 UTC |
| c94a079 | shuiqiangchen | 18 February 2023, 13:24:58 UTC | [FLINK-31124][Connectors/Hive] Add IT case for HiveTableSink speculative execution This closes #21962. | 23 February 2023, 05:49:58 UTC |
| 7201d0a | Shuiqiang Chen | 23 February 2023, 02:32:45 UTC | [FLINK-31120] Add concurrent access control for collectorIterators in StreamExecutionEnvironment This closes #21961. (cherry picked from commit fa6a2aed6136ae59ed14cd01819e8f94867840b7) | 23 February 2023, 02:34:14 UTC |
| 8535c26 | Sergey Nuyanzin | 22 February 2023, 14:44:42 UTC | [FLINK-31091][sql-gateway] Add Ser/de for Interval types (#21991) | 22 February 2023, 14:44:42 UTC |
| 2f86dcb | Weijie Guo | 20 February 2023, 12:55:01 UTC | [FLINK-31132][hive] Let hive compact operator without setting parallelism subject to sink operator's configured parallelism. | 22 February 2023, 14:43:26 UTC |
| 6ea94b0 | Weijie Guo | 20 February 2023, 17:30:28 UTC | [hotfix][test] Migrate HiveTableCompactSinkTICase, HiveTableFactoryTest, HiveTableSinkITCase to Junit5 and AssertJ. | 22 February 2023, 14:43:26 UTC |
| 17fd037 | Weijie Guo | 20 February 2023, 13:12:10 UTC | [hotfix] Fix typo in HiveTableSink and HiveTableCompactSinkITCase. | 22 February 2023, 14:43:26 UTC |
| bfadd9c | Xintong Song | 22 February 2023, 02:13:26 UTC | [FLINK-31169][k8s] Fix that pod termination may be mis-treated as fatal error. This closes #21986 | 22 February 2023, 09:55:24 UTC |
| fb901d1 | Shengkai | 22 February 2023, 09:20:14 UTC | [FLINK-31175][doc] Fix link doesn't work in hive_read_write doc (#21988) | 22 February 2023, 09:22:11 UTC |
| db15e1e | Shengkai | 22 February 2023, 02:46:28 UTC | [FLINK-31136][sql-client] Forbid sql client to read executor config in the gateway mode This closes #21974 | 22 February 2023, 02:46:28 UTC |
| 5026156 | Dian Fu | 21 February 2023, 11:54:17 UTC | [hotfix][docs] Update outdated documentation of windowing support in Python DataStream API | 21 February 2023, 11:56:07 UTC |
| d588293 | Hong Liang Teoh | 19 February 2023, 10:34:28 UTC | [FLINK-30948][Formats/AWS] Remove GlueSchemaRegistry Avro and JSON formats from main repository | 21 February 2023, 08:54:04 UTC |
| 3ae7b1f | Shengkai | 21 February 2023, 06:25:35 UTC | [FLINK-31137][hive] Fix wrong ResultKind in DescribeTable and ShowCreateTable results (#21976) | 21 February 2023, 06:25:35 UTC |
| ae53a8d | 1996fanrui | 17 February 2023, 13:10:52 UTC | [FLINK-31036][test][checkpoint] FileSystemCheckpointStorage as the default for test | 20 February 2023, 14:32:57 UTC |
| 2046d43 | Chesnay Schepler | 20 February 2023, 11:19:29 UTC | [FLINK-31119][tests] Use even # of slots | 20 February 2023, 14:08:32 UTC |
| 0b90d3c | luoyuxia | 20 February 2023, 07:15:59 UTC | [FLINK-31130][doc] Improve version info shown in the doc of SQL Gateway (cherry picked from commit 804072aef4f512f61f26d1c0c9950250da333f79) | 20 February 2023, 09:30:52 UTC |
| 6b47f45 | Xintong Song | 10 February 2023, 05:21:49 UTC | [FLINK-30908][Yarn] Fix YarnResourceManagerDrivers handling error callbacks after being terminated. This closes #21868 | 20 February 2023, 02:11:20 UTC |
| aecefe7 | Xintong Song | 10 February 2023, 04:02:21 UTC | [FLINK-30908][k8s][yarn] Fix potential uncaught exception in k8s/yarn resource allocation. | 20 February 2023, 02:11:20 UTC |
| 6b6dceb | Xintong Song | 10 February 2023, 06:28:42 UTC | [hotfix] Minor clean-ups in ResourceManagerDriverTestBase and YarnResourceManagerDriverTest. | 20 February 2023, 02:11:19 UTC |
| 257be14 | Juntao Hu | 13 February 2023, 13:29:25 UTC | [FLINK-31017][FLINK-31042][cep] Fix no after-match processing when pattern timeout This closes #21920. | 17 February 2023, 08:13:00 UTC |
| 629bc9a | Lijie Wang | 16 February 2023, 04:12:17 UTC | [FLINK-31055][runtime] Fix the bug that dynamic flag of stream graph does not take effect when translating the transformations This closes #21932 | 16 February 2023, 15:14:42 UTC |
| fceeec7 | Lijie Wang | 16 February 2023, 04:01:02 UTC | [hotfix] Refactor code to configure stream graph at the same location | 16 February 2023, 15:14:16 UTC |
| 3587680 | Lijie Wang | 14 February 2023, 13:32:51 UTC | [hotfix] Fix the missing parameter error in ForwardForConsecutiveHashPartitionerTest | 16 February 2023, 15:14:11 UTC |
| 9e1cf08 | Chesnay Schepler | 16 February 2023, 13:51:03 UTC | [FLINK-30895][coordination] Dynamically adjust slot distribution | 16 February 2023, 13:52:14 UTC |
| c7c035a | huangxingbo | 16 February 2023, 07:23:55 UTC | [FLINK-31099][python] Fix chained WindowOperator throws NPE in PyFlink Thread Mode This closes #21948. | 16 February 2023, 09:29:19 UTC |
| b64739a | Licho | 16 February 2023, 07:49:48 UTC | [FLINK-27800][streaming] Fix the error check in StreamNode#addInEdge This closes #19824 | 16 February 2023, 07:50:59 UTC |
| 873f887 | Dian Fu | 15 February 2023, 11:35:06 UTC | [FLINK-31083][python] Make sure OutputTag._j_output_tag is initialized during unpickle | 15 February 2023, 11:37:00 UTC |
| 712c9ee | Juntao Hu | 15 February 2023, 10:07:13 UTC | [FLINK-31083][python] Allow OutputTag to be reused This closes #21941. | 15 February 2023, 11:25:07 UTC |
| 21158c0 | Weijie Guo | 13 February 2023, 09:47:08 UTC | [FLINK-30629][test] Set CLIENT_ALIVENESS_CHECK_DURATION to clientHeartbeatInterval for testJobCancelledIfClientHeartbeatTimeout. This closes #21929 | 15 February 2023, 03:29:48 UTC |
| e68bac9 | Paul Lin | 11 February 2023, 09:17:08 UTC | [FLINK-28658][docs] Add docs for job statements This closes #21912 | 15 February 2023, 02:49:22 UTC |
| 556a3fa | huangxingbo | 14 February 2023, 08:14:35 UTC | [FLINK-28786][following][python] Fix PyFlink execution failure on Mac Os with M1 chip This closes #21926. | 14 February 2023, 11:28:56 UTC |
| c7c6027 | Weijie Guo | 14 February 2023, 09:50:50 UTC | [hotfix][docs] Fix typo in explain.md This closes #21913. | 14 February 2023, 09:54:39 UTC |
| cf448f0 | Juntao Hu | 06 February 2023, 12:14:54 UTC | [FLINK-30864][FLINK-30885][CEP] Fix wrong NFA related to optional decoration at the beginning of group pattern This closes #21866. | 14 February 2023, 09:09:07 UTC |
| 58ca4d4 | Weijie Guo | 08 February 2023, 07:25:40 UTC | [FLINK-30860][doc] Add document for hybrid shuffle with adaptive batch scheduler. This closes #21890 | 14 February 2023, 03:24:20 UTC |
| c8f4c8f | Weijie Guo | 08 February 2023, 07:27:52 UTC | [hotfix] Fix incorrect url link in batch_shuffle.md. | 14 February 2023, 03:24:10 UTC |
| e1c6352 | Lijie Wang | 06 February 2023, 08:46:35 UTC | [FLINK-30917][runtime] Let adaptive batch scheduler also respect the user-configured max parallelism when deciding parallelism This closes #21861 | 14 February 2023, 03:17:16 UTC |
| c20ebde | Lijie Wang | 10 February 2023, 13:42:38 UTC | [hotfix] Adjust the parameters of AdaptiveBatchSchedulerITCase to make tests more reasonable | 14 February 2023, 03:17:11 UTC |
| 44e6cfb | Juntao Hu | 08 February 2023, 10:05:30 UTC | [FLINK-30962][python] Improve the error message during launching py4j gateway server This closes #21894. | 14 February 2023, 02:44:44 UTC |
