https://github.com/apache/flink

sort by:
Revision Author Date Message Commit Date
f06faf1 Commit for release 1.13.0 23 April 2021, 13:39:21 UTC
62cef45 [FLINK-22000][io] Set a default character set in InputStreamReader 23 April 2021, 13:34:08 UTC
7952830 [FLINK-21903][docs-zh] Translate "Importing Flink into an IDE" page into Chinese 23 April 2021, 12:15:51 UTC
2bb26ad [FLINK-22384][docs] Fix typos in Chinese "fault-tolerance/state" page (#15694) 23 April 2021, 11:57:36 UTC
9b76a60 [FLINK-22398][runtime] Fix incorrect comments in InputOutputFormatVertex (#15705) 23 April 2021, 11:55:52 UTC
f66c4c4 [FLINK-22177][docs][table] Add documentation for time functions and time zone support This closes #15634 23 April 2021, 09:33:25 UTC
28eea07 [FLINK-22085][tests] Update TestUtils::tryExecute() to cancel the job after execution failure. This closes #15713 22 April 2021, 16:46:06 UTC
d18bba5 [FLINK-22385][runtime] Fixes type cast error This closes #15710. 22 April 2021, 15:44:05 UTC
1b9ad44 [FLINK-22341][hive] Fix describe table for hive dialect This closes #15660 22 April 2021, 12:54:31 UTC
72b3eb7 [FLINK-22168][table] Partition insert can not work with union all This closes #15666 22 April 2021, 10:02:10 UTC
3b202cf [hotfix][table-api] Properly deprecate StreamTableEnvironment.execute 22 April 2021, 09:30:39 UTC
9400f88 [FLINK-22345][coordination] Catch pre-mature state restore for Operator Coordinators 22 April 2021, 09:24:53 UTC
266a0b7 [FLINK-19980][table] Support fromChangelogStream/toChangelogStream This closes #15699. 22 April 2021, 08:34:09 UTC
4875d2a [FLINK-19980][table-common] Add a ChangelogMode.all() shortcut 22 April 2021, 08:29:34 UTC
5efca9e [FLINK-19980][table-common] Add a ChangelogMode.upsert() shortcut 22 April 2021, 08:29:34 UTC
cd74279 [FLINK-22396][hbase] Remove unnecessary entries from shaded plugin configuration 22 April 2021, 07:44:26 UTC
666fd24 [FLINK-22396][legal] Remove unnecessary entries from sql hbase connector NOTICE file This closes #15706 22 April 2021, 07:44:18 UTC
ca95953 [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 [hotfix] Regenerate html configuration after 4be9aff3eccb3808df1f10ef7c30480ec11a9cb0 22 April 2021, 06:09:10 UTC
860a716 [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 [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 [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 [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 [FLINK-22354][table] Fix TIME field display in sql-client This closes #15689 21 April 2021, 14:30:20 UTC
d919168 [FLINK-22354][table] Remove the strict precision check of time attribute field This closes #15689 21 April 2021, 14:30:15 UTC
74c6a06 [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 [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 [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 [FLINK-22092][hive] Ignore static conf file URLs in HiveConf This closes #15692 21 April 2021, 12:41:39 UTC
2959103 [hotfix][docs][python] Add missing pages for PyFlink documentation 21 April 2021, 12:10:08 UTC
fbc1f72 [hotfix][docs] Fix the invalid urls in iterations.md 21 April 2021, 11:48:00 UTC
a321f65 [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 [hotfix][docs][python] Fix the invalid url in state.md 21 April 2021, 11:27:15 UTC
5f666c3 [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 [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 [FLINK-22369][rocksdb] RocksDB state backend might occur ClassNotFoundException when deserializing on TM side 21 April 2021, 09:15:31 UTC
26d92d4 [FLINK-18206][table-api][sql-client] Fix the incorrect timestamp display This closes #15658 21 April 2021, 04:39:07 UTC
e8d1b57 [FLINK-22302][docs][table] Improvements content based on reviews This closes #15642 21 April 2021, 03:50:55 UTC
e34d3e3 [FLINK-22302][docs][table] Update "Queries" Chinese documentations This closes #15642 21 April 2021, 03:50:51 UTC
54c2500 [FLINK-22159][docs][table] Add documentation for the new window TVF based operations This closes #15642 21 April 2021, 03:50:44 UTC
67cf79e [FLINK-22302][docs][table] Restructure SQL "Queries" documentation into one page per operation This closes #15642 21 April 2021, 03:50:40 UTC
b39d4c0 [hotfix][docs] Add SQL CLI examples in Table API "Configuration" page 21 April 2021, 03:50:35 UTC
c6c1680 [FLINK-22171][docs][sql-client] Update the SQL Client documentation for FLIP-163 This closes #15595 21 April 2021, 03:28:27 UTC
a653949 [FLINK-22372][table-common] Fix typo of parameter name of LogicalTypeCasts#castTo method This closes #15686 21 April 2021, 03:20:59 UTC
d58db3b [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 [FLINK-22239][tests] Test JDBC XA Sink against PostgreSQL 20 April 2021, 20:15:25 UTC
9718347 [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 [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 [FLINK-21694][docs] Regenerate docs for adjusted RocksDB config 20 April 2021, 18:47:12 UTC
af20495 [FLINK-21694][pyflink] Adjust state backend test for number of RocksDB state transfer threads 20 April 2021, 18:40:34 UTC
cc6a608 [FLINK-21694][rocksdb] Increase default value for 'state.backend.rocksdb.checkpoint.transfer.thread.num' 20 April 2021, 16:13:07 UTC
2850456 [hotfix][rocksdb] Properly adjust RocksDB config options to new builder pattern 20 April 2021, 16:13:07 UTC
dbc74ef [FLINK-21796][FLINK-17510] Disable tests that use KafkaResource 20 April 2021, 15:01:36 UTC
fdcf730 [FLINK-22133][core] Add checkpointID to 'SplitEnumerator.snapshotState()' This closes #15677 20 April 2021, 14:56:08 UTC
3948227 [FLINK-22346][sql-client] Remove sql-client-defaults.yaml This closes #15670 20 April 2021, 13:57:33 UTC
0b1078c [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 [FLINK-22352][mesos] Deprecates Mesos support 20 April 2021, 08:39:14 UTC
0e1468a [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 [FLINK-22335][runtime][config] Increase default resource wait timeout for the adaptive scheduler. This closes #15657 20 April 2021, 07:28:10 UTC
adeb0db [FLINK-22359][python] Set the version to 1.13.dev0 for PyFlink This closes #15680. 20 April 2021, 06:16:57 UTC
5abd413 [FLINK-22297][python] Perform early validation for the result of Pandas UDF This closes #15681. 20 April 2021, 06:13:17 UTC
5d4b451 [FLINK-22338][table-planner] Clear watermark output when test finished for FromElementSourceFunctionWithWatermark This closes #15672 20 April 2021, 03:11:24 UTC
a5221c2 [hotfix][docs] Fix config.toml error 20 April 2021, 03:03:17 UTC
a771b21 [FLINK-21073][docs] Mention that RocksDB would ignore java's equals/hashCode during comparing objects 20 April 2021, 02:44:21 UTC
123c1c4 [FLINK-22351][coordination] Promote resource declaration log to INFO in FineGrainedSlotManager This closes # 15669 20 April 2021, 01:57:00 UTC
f4105f6 [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 [hotfix][test] Cleans up unused local variable 19 April 2021, 17:31:53 UTC
9252ee2 [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 [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 [FLINK-22208][build] Bump snappy-java to 1.1.8.3 19 April 2021, 12:25:22 UTC
021cf0b [FLINK-22340][runtime] Make ThresholdMeter thread safe. This closes #15662 19 April 2021, 11:36:15 UTC
b714421 [hotfix][runtime] Minor clean-up in ThreasholdMeter. 19 April 2021, 11:36:06 UTC
b2d242a [FLINK-22339][python] Fix some encoding exceptions were not thrown in cython coders This closes #15661. 19 April 2021, 09:20:31 UTC
766f717 [FLINK-22085][tests] Update NetworkFailureHandler to prevent closeOnFlush() from being called recursively 19 April 2021, 09:01:45 UTC
5787dc6 [hotfix][docs] Removed reference to "fold" function in "Windows" page (#15574) 19 April 2021, 07:12:25 UTC
e263af3 [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 [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 [FLINK-22104][sql-client] Fix unstable SqlClientTest.testExecuteSqlFile This closes #15534 19 April 2021, 03:06:16 UTC
b2c40e3 [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 Update for 1.13.0 18 April 2021, 12:17:49 UTC
d98d731 [FLINK-21627][table-planner-blink] The digest of Sink should consider table hints This closes #15559 18 April 2021, 05:39:44 UTC
c6147f2 [FLINK-21627][table-planner-blink] The digest of TableScan should consider table hints This closes #15559 18 April 2021, 05:39:44 UTC
d32ca07 [FLINK-22310][table-planner-blink] Fix the incorrect deserialization result of LogicalWindowJsonDeserializer This closes #15645 18 April 2021, 03:56:13 UTC
d293577 [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 [FLINK-22305][network] Improve log messages of sort-merge blocking shuffle This closes #15652. 18 April 2021, 02:56:37 UTC
577113f [FLINK-22117] Reduce the logs if not all tasks are RUNNING when checkpointing 17 April 2021, 08:58:10 UTC
fd8e34c [FLINK-20855][table-runtime-blink] Fix calculating numBuckets overflow (#14566) 17 April 2021, 01:45:20 UTC
e4a2738 [FLINK-22308][sql-client] Fix CliTableauResultView print results after cancel in STREAMING mode (#15644) 17 April 2021, 01:36:49 UTC
1562ed0 [FLINK-22016][table-planner-blink] RexNodeExtractor#visitLiteral should deal with NULL literals correctly (#15570) 17 April 2021, 01:36:12 UTC
9466e09 [hotfix][coordination] Add safety guard against uncaught exceptions for Future dependent lambdas 16 April 2021, 22:32:44 UTC
9045362 [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 [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 Revert "[FLINK-22249][FLINK-22248] Temporarily disable JobMasterStopWithSavepointITCase" This reverts commit eb631935dcce5b037e3ad5245f48e373b5b3c426. 16 April 2021, 16:48:23 UTC
22e9357 [FLINK-22248][tests] Improve JobMasterStopWithSavepoint#waitForJob to wait for all tasks running 16 April 2021, 16:48:23 UTC
68512cc [hotfix][tests] Cancel all running jobs after each test in AbstractTestBase 16 April 2021, 16:48:23 UTC
25fa42d [FLINK-22248][tests] Remove timeouts from JobMasterStopWithSavepointITCase 16 April 2021, 16:48:23 UTC
3ebf940 [FLINK-22249][tests] Add `FAILLING` to an assertion in JobMasterStopWithSavepointITCase 16 April 2021, 16:48:23 UTC
de069df [hotfix][docs] Fix config doc structure 16 April 2021, 16:37:52 UTC
7359d61 [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 [FLINK-22290][checkpointing] Use duration for alignment timeout. 16 April 2021, 16:37:52 UTC
back to top