f06faf1 | Dawid Wysakowicz | 23 April 2021, 13:39:21 UTC | Commit for release 1.13.0 | 23 April 2021, 13:39:21 UTC |
62cef45 | dbgp2021 | 22 April 2021, 13:23:56 UTC | [FLINK-22000][io] Set a default character set in InputStreamReader | 23 April 2021, 13:34:08 UTC |
7952830 | zhaoxing | 22 April 2021, 09:48:01 UTC | [FLINK-21903][docs-zh] Translate "Importing Flink into an IDE" page into Chinese | 23 April 2021, 12:15:51 UTC |
2bb26ad | simenliuxing | 23 April 2021, 11:57:02 UTC | [FLINK-22384][docs] Fix typos in Chinese "fault-tolerance/state" page (#15694) | 23 April 2021, 11:57:36 UTC |
9b76a60 | kanata163 | 23 April 2021, 11:54:54 UTC | [FLINK-22398][runtime] Fix incorrect comments in InputOutputFormatVertex (#15705) | 23 April 2021, 11:55:52 UTC |
f66c4c4 | Leonard Xu | 19 April 2021, 15:23:38 UTC | [FLINK-22177][docs][table] Add documentation for time functions and time zone support This closes #15634 | 23 April 2021, 09:33:25 UTC |
28eea07 | Dong Lin | 21 April 2021, 10:46:46 UTC | [FLINK-22085][tests] Update TestUtils::tryExecute() to cancel the job after execution failure. This closes #15713 | 22 April 2021, 16:46:06 UTC |
d18bba5 | sharkdtu | 21 April 2021, 03:55:38 UTC | [FLINK-22385][runtime] Fixes type cast error This closes #15710. | 22 April 2021, 15:44:05 UTC |
1b9ad44 | Rui Li | 22 April 2021, 12:49:03 UTC | [FLINK-22341][hive] Fix describe table for hive dialect This closes #15660 | 22 April 2021, 12:54:31 UTC |
72b3eb7 | Jingsong Lee | 22 April 2021, 10:02:10 UTC | [FLINK-22168][table] Partition insert can not work with union all This closes #15666 | 22 April 2021, 10:02:10 UTC |
3b202cf | Timo Walther | 22 April 2021, 09:28:34 UTC | [hotfix][table-api] Properly deprecate StreamTableEnvironment.execute | 22 April 2021, 09:30:39 UTC |
9400f88 | Stephan Ewen | 22 April 2021, 00:06:20 UTC | [FLINK-22345][coordination] Catch pre-mature state restore for Operator Coordinators | 22 April 2021, 09:24:53 UTC |
266a0b7 | Timo Walther | 13 April 2021, 11:49:07 UTC | [FLINK-19980][table] Support fromChangelogStream/toChangelogStream This closes #15699. | 22 April 2021, 08:34:09 UTC |
4875d2a | Timo Walther | 20 April 2021, 09:07:00 UTC | [FLINK-19980][table-common] Add a ChangelogMode.all() shortcut | 22 April 2021, 08:29:34 UTC |
5efca9e | Timo Walther | 19 April 2021, 06:30:39 UTC | [FLINK-19980][table-common] Add a ChangelogMode.upsert() shortcut | 22 April 2021, 08:29:34 UTC |
cd74279 | Dawid Wysakowicz | 21 April 2021, 15:14:45 UTC | [FLINK-22396][hbase] Remove unnecessary entries from shaded plugin configuration | 22 April 2021, 07:44:26 UTC |
666fd24 | Dawid Wysakowicz | 21 April 2021, 13:30:40 UTC | [FLINK-22396][legal] Remove unnecessary entries from sql hbase connector NOTICE file This closes #15706 | 22 April 2021, 07:44:18 UTC |
ca95953 | Till Rohrmann | 15 April 2021, 08:15:10 UTC | [FLINK-22001] Fix forwarding of JobMaster exceptions to user [FLINK-XXXX] Draft separation of leader election and creation of JobMasterService [FLINK-XXXX] Continued work on JobMasterServiceLeadershipRunner [FLINK-XXXX] Integrate RunningJobsRegistry, Cancelling state and termination future watching [FLINK-XXXX] Delete old JobManagerRunnerImpl classes [FLINK-22001] Add tests for DefaultJobMasterServiceProcess [FLINK-22001][hotfix] Clean up ITCase a bit [FLINK-22001] Add missing check for empty job graph [FLINK-22001] Rename JobMasterServiceFactoryNg to JobMasterServiceFactory This closes #15717. | 22 April 2021, 06:53:42 UTC |
cad930c | Robert Metzger | 22 April 2021, 06:00:24 UTC | [hotfix] Regenerate html configuration after 4be9aff3eccb3808df1f10ef7c30480ec11a9cb0 | 22 April 2021, 06:09:10 UTC |
860a716 | Piotr Nowojski | 21 April 2021, 12:53:13 UTC | [FLINK-20654] Fix double recycling of Buffers in case of an exception on persisting Exception can be thrown for example if task is being cancelled. This was leading to same buffer being recycled twice. Most of the times that was just leading to an IllegalReferenceCount being thrown, which was ignored, as this task was being cancelled. However on rare occasions this buffer could have been picked up by another task after being recycled for the first time, recycled second time and being picked up by another (third task). In that case we had two users of the same buffer, which could lead to all sort of data corruptions. | 22 April 2021, 05:36:54 UTC |
0cad0aa | godfreyhe | 21 April 2021, 08:26:35 UTC | [hotfix][table-planner-blink] Fix the incorrect ExecNode's id in testIncrementalAggregate.out After FLINK-22298 is finished, the ExecNode's id should always start from 1 in the json plan tests, while the testIncrementalAggregate.out was overrided by FLINK-20613 This closes #15698 (cherry picked from commit 84ce237bbc04db47495abf5f50f8ac3cc6a793bd) | 22 April 2021, 02:05:46 UTC |
41f013d | Stephan Ewen | 21 April 2021, 21:21:33 UTC | [FLINK-22345][coordination] Remove incorrect assertion in scheduler When this incorrect assertion is violated, the scheduler can trip into an unrecoverable failover loop. | 21 April 2021, 21:25:30 UTC |
16ec833 | Till Rohrmann | 21 April 2021, 19:15:32 UTC | [hotfix] Set default value of resource-stabilization-timeout to 10s Additionally, set speed up the AdaptiveScheduler ITCases by configuring a very low jobmanager.adaptive-scheduler.resource-stabilization-timeout. | 21 April 2021, 19:16:52 UTC |
cdf65b6 | Leonard Xu | 21 April 2021, 07:14:15 UTC | [FLINK-22354][table] Fix TIME field display in sql-client This closes #15689 | 21 April 2021, 14:30:20 UTC |
d919168 | Leonard Xu | 21 April 2021, 04:41:26 UTC | [FLINK-22354][table] Remove the strict precision check of time attribute field This closes #15689 | 21 April 2021, 14:30:15 UTC |
74c6a06 | Leonard Xu | 21 April 2021, 04:22:19 UTC | [FLINK-22354][table-planner] Fix the timestamp function return value precision isn't matching with declared DataType This closes #15689 | 21 April 2021, 14:30:08 UTC |
50dcd81 | huangxingbo | 21 April 2021, 09:55:27 UTC | [FLINK-22350][python][docs] Add documentation for user-defined window in Python DataStream API This closes #15702. | 21 April 2021, 13:04:56 UTC |
9f40251 | huangxingbo | 19 April 2021, 08:10:23 UTC | [FLINK-22348][python] Fix DataStream.execute_and_collect which doesn't declare managed memory for Python operators This closes #15665. | 21 April 2021, 12:48:56 UTC |
7dee2c2 | Rui Li | 21 April 2021, 12:41:39 UTC | [FLINK-22092][hive] Ignore static conf file URLs in HiveConf This closes #15692 | 21 April 2021, 12:41:39 UTC |
2959103 | Dian Fu | 21 April 2021, 12:09:05 UTC | [hotfix][docs][python] Add missing pages for PyFlink documentation | 21 April 2021, 12:10:08 UTC |
fbc1f72 | Dian Fu | 21 April 2021, 11:46:53 UTC | [hotfix][docs] Fix the invalid urls in iterations.md | 21 April 2021, 11:48:00 UTC |
a321f65 | Jing Zhang | 21 April 2021, 04:31:20 UTC | [hotfix][table-planner-blink] Fix bug for window join: plan is wrong if join condition contains 'IS NOT DISTINCT FROM' Fix Flink-22098 caused by a mistake when rebasing This closes #15695 (cherry picked from commit a0124007d6ed33988a4def18809c18baced0f45b) | 21 April 2021, 11:33:01 UTC |
c90274b | Dian Fu | 21 April 2021, 11:25:03 UTC | [hotfix][docs][python] Fix the invalid url in state.md | 21 April 2021, 11:27:15 UTC |
5f666c3 | Leonard Xu | 21 April 2021, 09:55:39 UTC | [FLINK-22349][table-api] Throw Exception for unsupported Zone ID instead of using wrong value This closes #15678 | 21 April 2021, 09:56:28 UTC |
ed4cdbf | Jing Zhang | 21 April 2021, 03:26:57 UTC | [FLINK-21302][table-planner-blink] Fix NPE when use row_number() in overAgg This closes #14880 (cherry picked from commit 293739deeba7da1f66611471de9b1835bf8fc317) | 21 April 2021, 09:40:21 UTC |
61007c9 | Seth Wiesman | 20 April 2021, 13:48:32 UTC | [FLINK-22369][rocksdb] RocksDB state backend might occur ClassNotFoundException when deserializing on TM side | 21 April 2021, 09:15:31 UTC |
26d92d4 | Leonard Xu | 19 April 2021, 03:53:22 UTC | [FLINK-18206][table-api][sql-client] Fix the incorrect timestamp display This closes #15658 | 21 April 2021, 04:39:07 UTC |
e8d1b57 | Jark Wu | 16 April 2021, 08:38:09 UTC | [FLINK-22302][docs][table] Improvements content based on reviews This closes #15642 | 21 April 2021, 03:50:55 UTC |
e34d3e3 | Jark Wu | 16 April 2021, 08:34:05 UTC | [FLINK-22302][docs][table] Update "Queries" Chinese documentations This closes #15642 | 21 April 2021, 03:50:51 UTC |
54c2500 | Jark Wu | 15 April 2021, 15:20:44 UTC | [FLINK-22159][docs][table] Add documentation for the new window TVF based operations This closes #15642 | 21 April 2021, 03:50:44 UTC |
67cf79e | Jark Wu | 15 April 2021, 04:03:33 UTC | [FLINK-22302][docs][table] Restructure SQL "Queries" documentation into one page per operation This closes #15642 | 21 April 2021, 03:50:40 UTC |
b39d4c0 | Jark Wu | 15 April 2021, 05:45:15 UTC | [hotfix][docs] Add SQL CLI examples in Table API "Configuration" page | 21 April 2021, 03:50:35 UTC |
c6c1680 | Shengkai | 13 April 2021, 11:43:04 UTC | [FLINK-22171][docs][sql-client] Update the SQL Client documentation for FLIP-163 This closes #15595 | 21 April 2021, 03:28:27 UTC |
a653949 | Mulan | 21 April 2021, 03:19:47 UTC | [FLINK-22372][table-common] Fix typo of parameter name of LogicalTypeCasts#castTo method This closes #15686 | 21 April 2021, 03:20:59 UTC |
d58db3b | Rui Li | 24 December 2020, 03:39:35 UTC | [FLINK-20722][hive] HiveTableSink should copy the record when converting RowData to Row This closes #14484 (cherry picked from commit 65827041830e1332aeb373eb64ae31505a49f268) | 21 April 2021, 03:10:08 UTC |
3482390 | Roman Khachatryan | 15 April 2021, 17:23:25 UTC | [FLINK-22239][tests] Test JDBC XA Sink against PostgreSQL | 20 April 2021, 20:15:25 UTC |
9718347 | Roman Khachatryan | 18 April 2021, 15:20:41 UTC | [FLINK-22239][jdbc] Rollback XA transactions on recovery Leaving transactions not rolled back may lead to new transactions being blocked by the old ones. | 20 April 2021, 20:15:25 UTC |
571cce8 | Roman Khachatryan | 15 April 2021, 20:21:18 UTC | [FLINK-22239][jdbc] Pool connections in JDBC XA sink Some databases like PostgreSQL and MySql allow at most one XA transaction per connection. Using new connection for each transaction (and pooling) allows to overcome this limitation. | 20 April 2021, 20:15:25 UTC |
749faf6 | Stephan Ewen | 20 April 2021, 18:47:12 UTC | [FLINK-21694][docs] Regenerate docs for adjusted RocksDB config | 20 April 2021, 18:47:12 UTC |
af20495 | Stephan Ewen | 20 April 2021, 18:40:34 UTC | [FLINK-21694][pyflink] Adjust state backend test for number of RocksDB state transfer threads | 20 April 2021, 18:40:34 UTC |
cc6a608 | Stephan Ewen | 20 April 2021, 15:38:04 UTC | [FLINK-21694][rocksdb] Increase default value for 'state.backend.rocksdb.checkpoint.transfer.thread.num' | 20 April 2021, 16:13:07 UTC |
2850456 | Stephan Ewen | 20 April 2021, 15:36:06 UTC | [hotfix][rocksdb] Properly adjust RocksDB config options to new builder pattern | 20 April 2021, 16:13:07 UTC |
dbc74ef | Dawid Wysakowicz | 20 April 2021, 15:00:38 UTC | [FLINK-21796][FLINK-17510] Disable tests that use KafkaResource | 20 April 2021, 15:01:36 UTC |
fdcf730 | Stephan Ewen | 19 April 2021, 15:32:00 UTC | [FLINK-22133][core] Add checkpointID to 'SplitEnumerator.snapshotState()' This closes #15677 | 20 April 2021, 14:56:08 UTC |
3948227 | Shengkai | 20 April 2021, 13:54:29 UTC | [FLINK-22346][sql-client] Remove sql-client-defaults.yaml This closes #15670 | 20 April 2021, 13:57:33 UTC |
0b1078c | fuyli | 14 April 2021, 02:00:56 UTC | [FLINK-22264][docs] Fix misleading statement about Flink Job Cluster Kubernetes Support in Flink Architecture page [FLINK-22264][docs] Add Chinese documentation This closes #15602. | 20 April 2021, 08:47:41 UTC |
040df88 | Matthias Pohl | 19 April 2021, 10:13:49 UTC | [FLINK-22352][mesos] Deprecates Mesos support | 20 April 2021, 08:39:14 UTC |
0e1468a | wangfeifan | 15 April 2021, 06:18:53 UTC | [FLINK-21986][State Backends] fix native memory used by RocksDB not be released timely after job restart [FLINK-21986][State Backends] fix spotless-check error This closes #15619. | 20 April 2021, 08:17:21 UTC |
5e336cf | Xintong Song | 19 April 2021, 03:24:25 UTC | [FLINK-22335][runtime][config] Increase default resource wait timeout for the adaptive scheduler. This closes #15657 | 20 April 2021, 07:28:10 UTC |
adeb0db | huangxingbo | 20 April 2021, 01:47:42 UTC | [FLINK-22359][python] Set the version to 1.13.dev0 for PyFlink This closes #15680. | 20 April 2021, 06:16:57 UTC |
5abd413 | Dian Fu | 19 April 2021, 01:53:53 UTC | [FLINK-22297][python] Perform early validation for the result of Pandas UDF This closes #15681. | 20 April 2021, 06:13:17 UTC |
5d4b451 | Shengkai | 20 April 2021, 03:11:24 UTC | [FLINK-22338][table-planner] Clear watermark output when test finished for FromElementSourceFunctionWithWatermark This closes #15672 | 20 April 2021, 03:11:24 UTC |
a5221c2 | huangxingbo | 20 April 2021, 03:03:17 UTC | [hotfix][docs] Fix config.toml error | 20 April 2021, 03:03:17 UTC |
a771b21 | Yun Tang | 08 April 2021, 14:27:14 UTC | [FLINK-21073][docs] Mention that RocksDB would ignore java's equals/hashCode during comparing objects | 20 April 2021, 02:44:21 UTC |
123c1c4 | Yangze Guo | 19 April 2021, 09:39:23 UTC | [FLINK-22351][coordination] Promote resource declaration log to INFO in FineGrainedSlotManager This closes # 15669 | 20 April 2021, 01:57:00 UTC |
f4105f6 | Matthias Pohl | 15 April 2021, 08:12:25 UTC | [FLINK-22276][runtime] Fixes the concurrency issue This commit fixes an issue where multiple failures can occur close to each other. In that case, the DefaultScheduler's restart logic competes for each of these failures. If multiple failures refer to the same Execution, it might be that the restart due to one failure handling cleans up the failure already. This leads to an IllegalArgumentException when archiving the next failure refering to the same Execution. The issue was that the code relied on ExecutionVertices instead of Executions. The new implementation relies on the Executions that were present when the failure was handled. Therefore, FailureHandlingResultSnapshot is introduced. It extracts the Execution information from the ExecutionGraph. Additionally, instead of accessing on ExecutionVertex.getTaskNameWithSubtaskIndex() to collect the task name, the new implementation relies on Execution.getVertexWithAttempt(). This enables us to solely rely on the Execution without an extra dependency on the ExecutionVertex. The new implementation also removes the add method from RootExceptionHistoryEntry. This makes the instantiation cleaner. ExceptionHistoryEntryExtractor was replaced by the factory methods RootExceptionHistoryEntry.fromFailureHandlingResultSnapshot and RootExceptionHistoryEntry.fromFailureHandlingResultSnapshot as part of this effort. This closes #15640. | 19 April 2021, 17:31:53 UTC |
139e80c | Matthias Pohl | 16 April 2021, 02:52:39 UTC | [hotfix][test] Cleans up unused local variable | 19 April 2021, 17:31:53 UTC |
9252ee2 | Matthias Pohl | 19 April 2021, 07:27:28 UTC | [hotfix][runtime] Wrong annotation was used The Throwable can be null in that case due to FLINK-21376. We're not enforcing that behavior for now. FLINK-22060 covers the resolution on the ExecutionGraph side. FLINK-21376 covers the issue on the Task side. | 19 April 2021, 17:31:53 UTC |
bf254ee | Jing Zhang | 02 April 2021, 03:42:27 UTC | [FLINK-22098][table-planner-blink] Fix bug for window join: plan is wrong if join condition contains 'IS NOT DISTINCT FROM' This closes #15476 (cherry picked from commit 6604c5c65e74224970be1a4c89e2ca20b1c92a0e) | 19 April 2021, 13:29:55 UTC |
cf7faab | Chesnay Schepler | 12 April 2021, 08:12:07 UTC | [FLINK-22208][build] Bump snappy-java to 1.1.8.3 | 19 April 2021, 12:25:22 UTC |
021cf0b | Xintong Song | 19 April 2021, 06:28:11 UTC | [FLINK-22340][runtime] Make ThresholdMeter thread safe. This closes #15662 | 19 April 2021, 11:36:15 UTC |
b714421 | Xintong Song | 19 April 2021, 05:54:45 UTC | [hotfix][runtime] Minor clean-up in ThreasholdMeter. | 19 April 2021, 11:36:06 UTC |
b2d242a | huangxingbo | 19 April 2021, 06:26:33 UTC | [FLINK-22339][python] Fix some encoding exceptions were not thrown in cython coders This closes #15661. | 19 April 2021, 09:20:31 UTC |
766f717 | Dong Lin | 15 April 2021, 14:14:27 UTC | [FLINK-22085][tests] Update NetworkFailureHandler to prevent closeOnFlush() from being called recursively | 19 April 2021, 09:01:45 UTC |
5787dc6 | mans2singh | 19 April 2021, 07:11:39 UTC | [hotfix][docs] Removed reference to "fold" function in "Windows" page (#15574) | 19 April 2021, 07:12:25 UTC |
e263af3 | Jing Zhang | 02 April 2021, 05:01:48 UTC | [FLINK-22099][table-planner-blink] Fix bug about throwing ArrayIndexOutOfBoundsException when window join deals with semi/anti queries This closes #15477 (cherry picked from commit f51168041512b0473decabb2088c1ff4fa4f34bc) | 19 April 2021, 06:46:06 UTC |
a428ed4 | Dian Fu | 16 April 2021, 21:38:27 UTC | [FLINK-22327][python] Makes sure that bundleStarted is set to false when it throws exception in finishBundle This closes #15650. | 19 April 2021, 05:41:01 UTC |
a329d81 | Shengkai | 14 April 2021, 09:39:26 UTC | [FLINK-22104][sql-client] Fix unstable SqlClientTest.testExecuteSqlFile This closes #15534 | 19 April 2021, 03:06:16 UTC |
b2c40e3 | lincoln-lil | 16 April 2021, 07:29:23 UTC | [FLINK-22303][table-planner-blink] FlinkRelMdFilteredColumnInterval should remapping the columnIndex of the inputRel otherwise may cause IllegalArgumentException or get incorrectly metadata This closes #15641 | 18 April 2021, 20:44:23 UTC |
7b81e52 | GuoWei Ma | 18 April 2021, 12:17:49 UTC | Update for 1.13.0 | 18 April 2021, 12:17:49 UTC |
d98d731 | godfreyhe | 12 April 2021, 04:25:52 UTC | [FLINK-21627][table-planner-blink] The digest of Sink should consider table hints This closes #15559 | 18 April 2021, 05:39:44 UTC |
c6147f2 | godfreyhe | 12 April 2021, 03:10:23 UTC | [FLINK-21627][table-planner-blink] The digest of TableScan should consider table hints This closes #15559 | 18 April 2021, 05:39:44 UTC |
d32ca07 | godfreyhe | 16 April 2021, 10:28:23 UTC | [FLINK-22310][table-planner-blink] Fix the incorrect deserialization result of LogicalWindowJsonDeserializer This closes #15645 | 18 April 2021, 03:56:13 UTC |
d293577 | kevin.cyj | 15 April 2021, 15:36:07 UTC | [FLINK-22307][network] Increase the default value of data writing cache size (not configurable) for sort-merge blocking shuffle Currently, the data writing cache of sort-merge blocking shuffle is 8M, which can be not enough if data compression is enabled. This patch increases the cache size to 16M which can improve the performance for high compression ratio scenarios. This closes #15651. | 18 April 2021, 03:07:00 UTC |
77e0478 | kevin.cyj | 17 April 2021, 07:02:44 UTC | [FLINK-22305][network] Improve log messages of sort-merge blocking shuffle This closes #15652. | 18 April 2021, 02:56:37 UTC |
577113f | Yun Gao | 16 April 2021, 12:37:21 UTC | [FLINK-22117] Reduce the logs if not all tasks are RUNNING when checkpointing | 17 April 2021, 08:58:10 UTC |
fd8e34c | JieFang.He | 17 April 2021, 01:45:20 UTC | [FLINK-20855][table-runtime-blink] Fix calculating numBuckets overflow (#14566) | 17 April 2021, 01:45:20 UTC |
e4a2738 | Shengkai | 17 April 2021, 01:36:49 UTC | [FLINK-22308][sql-client] Fix CliTableauResultView print results after cancel in STREAMING mode (#15644) | 17 April 2021, 01:36:49 UTC |
1562ed0 | TsReaper | 17 April 2021, 01:36:12 UTC | [FLINK-22016][table-planner-blink] RexNodeExtractor#visitLiteral should deal with NULL literals correctly (#15570) | 17 April 2021, 01:36:12 UTC |
9466e09 | Stephan Ewen | 16 April 2021, 16:10:25 UTC | [hotfix][coordination] Add safety guard against uncaught exceptions for Future dependent lambdas | 16 April 2021, 22:32:44 UTC |
9045362 | Stephan Ewen | 14 April 2021, 03:02:55 UTC | [FLINK-21996][coordination] Ensure exactly-once guarantees for OperatorEvent RPCs This consists of two changes that work together: - Delay checkpoints until we have clarity about all in-flight OperatorEvents - Fail target subtask if the result future for an OperatorEvent send fails | 16 April 2021, 22:32:44 UTC |
fe41a87 | Matthias Pohl | 16 April 2021, 16:41:54 UTC | [FLINK-22276][runtime] Adds workaround for FLINK-22276 This is just a temporary workaround. The actual fix should be provided by FLINK-22276 before releasing 1.13. This closes #15648. | 16 April 2021, 21:10:00 UTC |
79eb5c7 | Dawid Wysakowicz | 16 April 2021, 09:20:39 UTC | Revert "[FLINK-22249][FLINK-22248] Temporarily disable JobMasterStopWithSavepointITCase" This reverts commit eb631935dcce5b037e3ad5245f48e373b5b3c426. | 16 April 2021, 16:48:23 UTC |
22e9357 | Dawid Wysakowicz | 15 April 2021, 09:56:23 UTC | [FLINK-22248][tests] Improve JobMasterStopWithSavepoint#waitForJob to wait for all tasks running | 16 April 2021, 16:48:23 UTC |
68512cc | Dawid Wysakowicz | 15 April 2021, 09:45:20 UTC | [hotfix][tests] Cancel all running jobs after each test in AbstractTestBase | 16 April 2021, 16:48:23 UTC |
25fa42d | Dawid Wysakowicz | 13 April 2021, 07:47:34 UTC | [FLINK-22248][tests] Remove timeouts from JobMasterStopWithSavepointITCase | 16 April 2021, 16:48:23 UTC |
3ebf940 | Dawid Wysakowicz | 13 April 2021, 07:35:01 UTC | [FLINK-22249][tests] Add `FAILLING` to an assertion in JobMasterStopWithSavepointITCase | 16 April 2021, 16:48:23 UTC |
de069df | Arvid Heise | 15 April 2021, 14:04:43 UTC | [hotfix][docs] Fix config doc structure | 16 April 2021, 16:37:52 UTC |
7359d61 | Arvid Heise | 15 April 2021, 14:01:31 UTC | [FLINK-22290][checkpointing] Adding alignment timeout and force unaligned checkpoint options to PyFlink and polished Java API. | 16 April 2021, 16:37:52 UTC |
52b400f | Arvid Heise | 15 April 2021, 13:05:58 UTC | [FLINK-22290][checkpointing] Use duration for alignment timeout. | 16 April 2021, 16:37:52 UTC |