https://github.com/apache/flink

sort by:
Revision Author Date Message Commit Date
4c580cb [hotfix][table] Fix typo in maven shade configuration (#24621) Co-authored-by: anupamaggarwal <aaggarwal@confluent.io> 04 April 2024, 19:11:02 UTC
9150f93 [FLINK-35000][build] Updates link to test code convention in pull request template 03 April 2024, 14:48:22 UTC
1711ba8 [FLINK-34955] Upgrade commons-compress to 1.26.0. Addresses 2 CVE as described at https://mvnrepository.com/artifact/org.apache.commons/commons-compress. --------- Co-authored-by: slfan1989 <55643692+slfan1989@users.noreply.github.com> 03 April 2024, 13:06:53 UTC
20c506d [FLINK-34922] Adds ITCase for GlobalFailureOnRestart Add an ITCase where a global failure is triggered while the scheduler is restarting, and asserts that this failure is handled such that can be retrieved via the REST API. 28 March 2024, 16:46:03 UTC
fcb581f [FLINK-34922][rest] Support concurrent global failure 28 March 2024, 16:46:03 UTC
94d1363 [FLINK-34933][test] Fixes JobMasterServiceLeadershipRunnerTest#testResultFutureCompletionOfOutdatedLeaderIsIgnored 28 March 2024, 13:00:22 UTC
a6aa569 [FLINK-34897][test] Enables JobMasterServiceLeadershipRunnerTest#testJobMasterServiceLeadershipRunnerCloseWhenElectionServiceGrantLeaderShip again. 27 March 2024, 14:37:13 UTC
febdaee [FLINK-26515][tests] Tolerate TimeoutException in RetryingExecutorTest.testDiscardOnTimeout 27 March 2024, 11:51:40 UTC
f3625bc [FLINK-26615][tests] Assert only the minimum delay in RetryingExecutorTest.testTimeout 27 March 2024, 11:51:40 UTC
f2a6ff5 [FLINK-34409][ci] Enable any still disabled e2e tests for the AdaptiveScheduler 25 March 2024, 16:07:02 UTC
836b332 [FLINK-21535][test] Adds proper comment to test methods that are disabled for the AdaptiveScheduler 25 March 2024, 16:07:02 UTC
f5c2430 [FLINK-21450][test] Enables tests that were disabled for the AdaptiveScheduler For a few tests, a proper explanation is added why the tests are still disabled 25 March 2024, 16:07:02 UTC
8f6890f [FLINK-21400][ci] Enables FileSink and Stateful stream job e2e test for the AdaptiveScheduler 25 March 2024, 16:07:02 UTC
940b3bb [FLINK-32513][core] Add predecessor caching This closes #24475. 22 March 2024, 13:40:00 UTC
906f860 [hotfix][tests] Migrate TransformationTest to Junit5 22 March 2024, 13:18:41 UTC
0e54a36 [hotfix] Fix maven property typo in root pom.xml 20 March 2024, 08:27:26 UTC
c2a85ac [FLINK-29114][connector][filesystem] Fix issue of file overwriting caused by multiple writes to the same sink table and shared staging directory This closes #24511 * Fix unstable TableSourceITCase#testTableHintWithLogicalTableScanReuse * Move the staging dir configuration into builder for easier testing --------- Co-authored-by: Matthias Pohl <matthias.pohl@aiven.io> (cherry picked from commit 7d0111dfab640f2f590dd710d76de927c86cf83e) 19 March 2024, 07:51:28 UTC
5a1fb80 [FLINK-33798][statebackend/rocksdb] automatically clean up rocksdb logs when the task exited. (#23922) 14 March 2024, 10:11:22 UTC
ff256ef [FLINK-34622][docs] fix typo in execution_mode.md 08 March 2024, 09:21:16 UTC
31f1361 [FLINK-34616][python] Fix python dist dir doesn't clean when open method construct resource has exception. This closes #24462. 08 March 2024, 01:39:56 UTC
620c5a7 [BP-1.18][FLINK-34517][table]fix environment configs ignored when calling procedure operation (#24419) 04 March 2024, 08:16:43 UTC
e770cef [FLINK-34499] Configuration#toString hides sensitive values 29 February 2024, 06:59:49 UTC
9802d24 [BP-1.18][FLINK-34274][runtime] Implicitly disable resource wait timeout for AdaptiveSchedulerTest (#24399) 28 February 2024, 14:23:37 UTC
320d612 [hotfix][runtime] Refactors suspend and cancel logic suspend and cancel reset the ExecutionGraph in a similar way. I move the common logic into its own method to make this more prominent in the code. 27 February 2024, 09:05:49 UTC
384f6b2 [FLINK-34518][runtime] Fixes AdaptiveScheduler#suspend bug when the job is suspended during Restarting phase 27 February 2024, 09:05:49 UTC
39ed3cf [FLINK-34496] Break circular dependency in static initialization 23 February 2024, 09:30:02 UTC
0293639 Revert "[FLINK-34331][ci] Adds reusable workflow that is used to load the runner configuration based on the projects owner" This reverts commit b1aa03a28c0f14a8ca158a02a9c0d036aad7675c. 21 February 2024, 13:40:25 UTC
b1aa03a [FLINK-34331][ci] Adds reusable workflow that is used to load the runner configuration based on the projects owner The goal is to enable Apache-hosted runners for the main repo but allow forks to use the GitHub-hosted runners. 21 February 2024, 13:22:53 UTC
5c16321 [FLINK-34202][python] Optimize Python nightly CI time (#24321) (cherry picked from commit 95163e89c84edbbad8477715739d3e5f2d80615e) 21 February 2024, 06:46:25 UTC
d952439 [hotfix][docs] Update the versions of mongodb supported by mongodb-connector (#24343) 20 February 2024, 08:56:05 UTC
21cfe99 [FLINK-34434][slotmanager] Complete the returnedFuture when slot removed before allocation success 20 February 2024, 02:42:30 UTC
e95cb6e [hotfix][test] Assert the slot allocation eventually succeed in dedicated tests of DefaultSlotStatusSyncerTest Also deduplicate the code of these tests. 20 February 2024, 02:42:30 UTC
a9ce499 [FLINK-22765][test] Hardens ExceptionUtilsITCase#testIsMetaspaceOutOfMemoryError This test started to fail quite regularly in JDK21 (but rarely also appeared with other JDKs). The problem was that the low heap size could have caused an OutOfMemoryError to appear when compiling the dummy classes. An OOM in the compilation phase results in a different error message being printed to stdout that wasn't captured by the test. The solution is to pre-compile the classes upfront (with the normal heap size). The test main method will only load the classes. No compilation is necessary. 19 February 2024, 15:43:32 UTC
943eee6 [hotfix][test] Removes duplicate Apache header 19 February 2024, 15:43:32 UTC
349e870 [hotfix] Integrate mongodb v1.1 docs (#24332) 19 February 2024, 12:32:01 UTC
10c8943 [FLINK-34418][ci] Mounts /mnt folder to /root 19 February 2024, 11:41:39 UTC
39a2043 [hotfix][ci] Removes obsolete line 19 February 2024, 11:41:39 UTC
35c5603 [FLINK-34333][k8s] Upgrade k8s client to v6.9.2 to cover client issue #5464 (cherry-picked from FLINK-34007) https://github.com/fabric8io/kubernetes-client/issues/5463 The change in KubernetesClientTestBase was necessary because of the change [#5369](https://github.com/fabric8io/kubernetes-client/pull/5369) that ended up in v6.9.0 as well. 13 February 2024, 16:19:19 UTC
87560b7 [FLINK-34333][k8s] fabric8io LeaderElector is created with every new #run() call (cherry-picked from FLINK-34007) v5.12.4 allowed us to reuse the LeaderElector. With v6.6.2 (fabric8io/kubernetes-client#4125) this behavior changed. One LeaderElector can only be used until the leadership is lost. An ITCase is added to cover the scenario where the leadership is lost. 13 February 2024, 16:19:19 UTC
0afa89d [hotfix][core] Makes ExecutorUtils#gracefulShutdown return any outstanding tasks 13 February 2024, 16:19:19 UTC
38690d0 [hotfix][test] Refactors TestingLeaderCallbackHandler to allow async calls This way, we can use FlinkAssertions#assertThatFuture and use assertion messages instead of comments. 13 February 2024, 16:19:19 UTC
6441f58 [hotfix][test] Makes ManuallyTriggeredScheduledExecutorService#execute rely on a BlockingQueue This allows us to wait for tasks to "arrive". 13 February 2024, 16:19:19 UTC
e5d488c [hotfix][test] Moves ConfigMap lifecycle management into @BeforeEach/@AfterEach methods 13 February 2024, 16:19:19 UTC
d693936 [FLINK-34422][test] BatchTestBase uses MiniClusterExtension 12 February 2024, 11:01:09 UTC
33fb37a [FLINK-34344] Pass JobID to CheckpointStatsTracker 12 February 2024, 08:05:05 UTC
8d162fc [FLINK-34420] Correct hadoop.tar.gz download url 11 February 2024, 12:32:07 UTC
6cd7150 [FLINK-33960][Scheduler] Fix the bug that Adaptive Scheduler doesn't respect the lowerBound when one flink job has more than 1 tasks 08 February 2024, 10:57:01 UTC
ae8f8b1 [FLINK-33960][JUnit5 migration] Migrate SlotSharingSlotAllocatorTest to Junit5 and Assertj 08 February 2024, 10:57:01 UTC
d185531 [hotfix][build] Fixes error message when printing the 15 biggest directories 07 February 2024, 14:17:22 UTC
9f76892 [FLINK-34360][ci] Adds cleanup to job_init action 07 February 2024, 14:17:22 UTC
bee4157 [release] Integrate Kafka v3.1 connector documentation 07 February 2024, 08:10:44 UTC
a4dd585 Revert "[FLINK-34324][test] Makes all s3 related operations being declared and called in a single location" This reverts commit a15515ebc0e4c59ea0642e745e942591c28b3a3c. 06 February 2024, 16:32:22 UTC
a15515e [FLINK-34324][test] Makes all s3 related operations being declared and called in a single location 06 February 2024, 07:44:41 UTC
ee9945c [FLINK-34343][rpc] Use actor path when rejecting early messages 05 February 2024, 11:45:14 UTC
fc54ffd [FLINK-33981][runtime] Fix not closing DirectoryStream after listing local state files 04 February 2024, 07:11:09 UTC
32ee966 [hotfix] Integrate opensearch v1.1 docs 01 February 2024, 10:35:05 UTC
a27e036 [FLINK-33915][ci] Adds workflow release-1.18 nightly CI workflow 31 January 2024, 11:51:44 UTC
a64e1c9 [FLINK-33914][ci] Introduces a basic GitHub Actions workflow - Adds basic CI workflow - Adds composite workflow for starting Flink's CI stages - Updates CI helper scripts to support GitHub Actions - Adds composite workflow for doing pre-compile checks - Adds custom action to enable maven-utils.sh in workflows - Adds custom action for initializing a job 31 January 2024, 11:42:47 UTC
fff63f4 [FLINK-27082][ci] Updates github-actions profile. A dedicated github-actions profile doesn't work if other profiles which configure excludeGroups for the surefire plugin are enabled. 31 January 2024, 11:42:47 UTC
4da0f1b [hotfix][ci] Adds proper log message at the end of a successful CI run 31 January 2024, 11:42:47 UTC
bfa590d [hotfix][ci] Replaces spaces with tabs The space indentation was accidentally added in FLINK-33906 31 January 2024, 11:42:47 UTC
ffdce2c [hotfix][build] Adds Maven and Java version to Maven command 31 January 2024, 11:42:47 UTC
227f50b [hotfix][ci] Fixes condition for filtering NOTICE files 31 January 2024, 11:42:47 UTC
2c6493b [hotfix][ci] Fixes find commands where touch might cause a failure if no files were found 31 January 2024, 11:42:47 UTC
d903990 [FLINK-34115][table-planner] Fix TableAggregateITCase unstable test This closes #24222 30 January 2024, 07:56:02 UTC
f287fb8 [FLINK-34117][filesystem] Fix CompactCoordinator data loss upon termination This closes #24195. 26 January 2024, 09:38:49 UTC
78064d9 [FLINK-34166][table] Fix KeyedLookupJoinWrapper incorrectly process delete message for inner join when previous lookup result is empty This closes #24166 25 January 2024, 01:58:07 UTC
0a1d671 [FLINK-34115][table-planner] Fix unstable TableAggregateITCase.testFlagAggregateWithOrWithoutIncrementalUpdate This closes #24178 (cherry picked from commit ecd7efc2522b7640ec8d561ee8607c971cd714e7) 24 January 2024, 14:25:03 UTC
369fae7 [FLINK-33233][hive] Fix NPE when non-native udf is used in join condition with Hive dialect (#24149) 24 January 2024, 04:02:31 UTC
20fb88b [FLINK-33850][doc] Update minor version for 1.18.1 release 19 January 2024, 16:57:05 UTC
8e3326f [FLINK-33844][doc] Update japicmp configuration for 1.18.1 19 January 2024, 16:33:24 UTC
e395598 [FLINK-34063][runtime] Fix OperatorState repartitioning when compression is enabled. We should only write compression headers once, at the end of the "value" part of the serialized stream, to make sure we can always seek to a split point. 19 January 2024, 14:28:49 UTC
5136c25 [FLINK-34063][runtime] Operator states need to be restored in an order they've been written for the compression to work properly on empty states. 19 January 2024, 14:28:49 UTC
c334cbf [FLINK-34063][runtime] Fix CompressibleFSDataInputStream#seek in case of partial reads. 19 January 2024, 14:28:49 UTC
5e40a55 [FLINK-34063][test-utils] Add ExecutionOptions.SNAPSHOT_COMPRESSION to randomized checkpointing options. 19 January 2024, 14:28:49 UTC
1cd68f9 [FLINK-34063][runtime] Always flush compression buffers, when retrieving stream position during OperatorState snapshot. 19 January 2024, 14:28:49 UTC
6e96772 [FLINK-34150][ci] Enables local file sink e2e tests in general CI setups 19 January 2024, 11:15:07 UTC
e68180a [FLINK-33907][ci] Moves jar generation in flink-clients into pre-integration-tests - Renames DefaultPackagedProgramRetrieverTest and FromClasspathEntryClassInformationProviderTest into ITCases because they are using jars 19 January 2024, 11:11:15 UTC
846ab49 [FLINK-33694][gs-fs-hadoop] Support overriding GCS root URL 18 January 2024, 17:22:00 UTC
2b6c656 [FLINK-27756] Refactor Async Sink send gauge test 16 January 2024, 09:05:59 UTC
d40ddc3 [FLINK-33906][ci] Makes debug_files_utils.sh agnostic to the CI backend 15 January 2024, 13:33:34 UTC
d7e9abe [FLINK-31788][table] TableAggregateFunction supports emitUpdateWithRetract This closes #24074 (cherry picked from commit 01569644aedb56f792c7f7e04f84612d405b0bdf) 14 January 2024, 05:10:21 UTC
3090e77 [BP-1.18][FLINK-34047][ci] Makes uploading_watchdog.sh support Azure Pipelines and GitHub Actions (#24063) - Makes prepare_debug_files not rely on "magic" environment variables anymore - Makes uploading_watchdog.sh support Azure Pipelines and GitHub Actions 12 January 2024, 07:47:31 UTC
ce9f5a2 [FLINK-33907][ci] Makes copying test jars being done in the package phase This fixes the following error when compiling the test artifacts of flink-clients: Error: 2.054 [ERROR] Failed to execute goal org.apache.maven.plugins:maven-dependency-plugin:3.2.0:copy-dependencies (copy-dependencies) on project flink-clients: Artifact has not been packaged yet. When used on reactor artifact, copy should be executed after packaging: see MDEP-187. -> [Help 1] 11 January 2024, 13:40:22 UTC
12463fb [FLINK-33938][runtime-web] Correct implicit coercions in relational operators to adopt typescript 5.0 This closes #23999 09 January 2024, 06:55:52 UTC
8342ac7 [FLINK-33939][runtime-web] Remove the husky dependency to make sure the global hooks work as expected This closes #23992 04 January 2024, 03:40:33 UTC
f9383e6 [FLINK-33863] Fix restoring compressed operator state 02 January 2024, 10:24:57 UTC
9bb6fd3 [FLINK-33947][configuration] Fix bugs about prefix attribute in the DelegatingConfiguration class. 29 December 2023, 09:04:15 UTC
32146f9 [FLINK-33942][configuration][refactor] Using ConfigOption instead of string key in DelegatingConfiguration 29 December 2023, 02:11:38 UTC
0978d88 [FLINK-33942][configuration] Fix the bug that DelegatingConfiguration misses the prefix in some get methods 29 December 2023, 02:11:38 UTC
257260c [FLINK-33942][configuration][junit5-migration] Migrate DelegatingConfigurationTest to Junit5 and Assertj 29 December 2023, 02:11:38 UTC
7dc01e2 [docs][hotfix] Set available Flink Pulsar connector for 1.18 to v4.1 28 December 2023, 10:11:41 UTC
3813eaf [FLINK-27082][ci] Adds a github-actions profile that disables certain tests that do not run in GHA The Docker setup for GitHub Actions is run with root permissions. Any limitations on files are ignored because root is allowed to do anything. We haven't discovered, yet, why this works in Azure CI. 22 December 2023, 08:59:51 UTC
2ee3bee [FLINK-33902][ci] Adds -legacy to openssl command 21 December 2023, 13:55:21 UTC
6aa64eb [FLINK-33534][runtime] Support configuring PARALLELISM_OVERRIDES during job submission 20 December 2023, 03:54:00 UTC
54fd94a [FLINK-33872] Retrieve checkpoint history for jobs in completed state 19 December 2023, 13:49:30 UTC
c53493e Fix NullArgumentException of getQuantile method in DescriptiveStatisticsHistogramStatistics (cherry picked from commit 5e1deeea19c2e73f3bc6f1f9881a778d13abf6a4) 19 December 2023, 13:37:16 UTC
ff1ef78 [FLINK-31650][metrics][rest] Remove transient metrics for subtasks in terminal state This closes #23447 19 December 2023, 12:42:04 UTC
0d6ab1d [FLINK-33531][python] Remove cython upper bounds Co-authored-by: HuangXingBo <hxb@apache.org> 18 December 2023, 22:14:17 UTC
8951f90 [FLINK-33704][Filesytems] Update GCS filesystems to latest available versions. This closes #23935 * [FLINK-33704][Filesystem] Update GCS filesystem dependencies - Update GS SDK from 2.15.0 to 2.29.1 - Update GS Hadoop Connector from 2.2.15 to 2.2.18 - Update GS GRPC to highest shared version * [FLINK-33704] Make NOTICE inclusion of com.google.re2j for GCS consistent RE2J is listed for the other filesystems as Go license, we should remain consistent throughout the project (cherry picked from commit 492a886248208904276fcd2bda138a79c86bc71c) 18 December 2023, 08:05:00 UTC
back to top