(flink) 03/03: fixup: aggregate keyGroupSize in subtask (not across subtasks)

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 999b7a2f2e3a892ce16eaeaf38e99542b5a5c618 Author: Roman Khachatryan AuthorDate: Thu Mar 2 00:39:38 2023 + fixup

(flink) branch master updated (9aab300c9f2 -> 999b7a2f2e3)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 9aab300c9f2 [FLINK-34543][docs] Add document of full partition processing on non-keyed datastream new caf9b23b320

(flink) 01/03: [hotfix][runtime] Remove unnecessary throws clause

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit caf9b23b3208c8b30cdb6c56ff6f334e2342ce5c Author: Roman Khachatryan AuthorDate: Thu Mar 2 15:15:37 2023 + [hotfix

(flink) 02/03: [FLINK-31261][runtime] Make AdaptiveScheduler aware of local state size

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 203acadb44dc5a8bba80c277124042f656353bca Author: Roman Khachatryan AuthorDate: Thu Mar 2 15:15:50 2023 + [FLINK

(flink) branch release-1.19 updated: [FLINK-35786] Fix NPE BlobServer / shutdownHook

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.19 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.19 by this push: new 3693d07db27 [FLINK-35786] Fix NPE

(flink) branch master updated: [FLINK-35786] Fix NPE BlobServer / shutdownHook

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 050767cda9d [FLINK-35786] Fix NPE BlobServer

(flink) branch master updated (482969aa24d -> 0b0158b4df9)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 482969aa24d [FLINK-35552][runtime] Rework how CheckpointStatsTracker is constructed. new 320d1a5fc5b [FLINK-35742

(flink) 01/02: [FLINK-35742] Don't create RocksDB Column Families if task cancellation is in progress

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 320d1a5fc5b2e2f5b8f55110f4bb0a3b44f1d80d Author: Roman Khachatryan AuthorDate: Tue Mar 26 21:43:14 2024 +0100 [FLINK

(flink) 02/02: [hotfix] Propagate cancellation to RocksDBWriteBatchWrapper during recovery

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 0b0158b4df97a0a0ae44d43f6c7b6947e8ed433f Author: Roman Khachatryan AuthorDate: Thu Apr 4 19:24:50 2024 +0200 [hotfix

(flink) 01/02: [FLINK-35501] Replace inheritance with encapsulation for RocksDBStateDataTransfer*

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 5855f5354985cabea6f01b6b2effaaa8cfcbee55 Author: Roman Khachatryan AuthorDate: Wed May 29 21:46:11 2024 +0200 [FLINK

(flink) branch master updated (ceb4db4d88a -> 9708f9fd657)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from ceb4db4d88a [FLINK-35532][Runtime/Web Frontend] Prevent Cross-Site Authentication (XSA) attacks on Flink dashboard

(flink) 02/02: [FLINK-35501] Use common IO thread pool for RocksDB data transfer

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 9708f9fd65751296b3b0377c964207b630958259 Author: Roman Khachatryan AuthorDate: Wed May 29 22:30:50 2024 +0200 [FLINK

(flink) branch master updated: [FLINK-26050] Manually compact small SST files

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new cd722033fb3 [FLINK-26050] Manually compact small

(flink) branch master updated (d301839dfe2 -> f86c0804121)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from d301839dfe2 [FLINK-35000][build] Updates link to test code convention in pull request template new 875683082a5

(flink) 02/02: [hotfix] Log JobID in checkpoint abort message if available

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit f86c08041211bbeddf36c9ff0fbe6ae4abaa3b9d Author: Roman Khachatryan AuthorDate: Wed Apr 3 10:23:14 2024 +0200 [hotfix

(flink) 01/02: [FLINK-34994][tests] Ignore unknown task checkpoint confirmation log in JobIDLoggingITCase

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 875683082a58636b377bbb0a82bac4d273455e6e Author: Roman Khachatryan AuthorDate: Wed Apr 3 10:19:34 2024 +0200 [FLINK

(flink) 02/02: [FLINK-26515][tests] Tolerate TimeoutException in RetryingExecutorTest.testDiscardOnTimeout

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.18 in repository https://gitbox.apache.org/repos/asf/flink.git commit febdaeeda5117f54dcb7fa8f8e9802eb9fd2898e Author: Roman Khachatryan AuthorDate: Tue Mar 26 18:53:00 2024 +0100

(flink) 02/02: [FLINK-26515][tests] Tolerate TimeoutException in RetryingExecutorTest.testDiscardOnTimeout

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.19 in repository https://gitbox.apache.org/repos/asf/flink.git commit b4767aeeebcb482584ddd70dfcd329a2a2c4ff03 Author: Roman Khachatryan AuthorDate: Tue Mar 26 18:53:00 2024 +0100

(flink) 01/02: [FLINK-26615][tests] Assert only the minimum delay in RetryingExecutorTest.testTimeout

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.19 in repository https://gitbox.apache.org/repos/asf/flink.git commit 4069d87c3b5e7281923d8d7fddeb83703c9b Author: Roman Khachatryan AuthorDate: Tue Mar 26 18:00:03 2024 +0100

(flink) branch release-1.19 updated (f82ff7c656d -> b4767aeeebc)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch release-1.19 in repository https://gitbox.apache.org/repos/asf/flink.git from f82ff7c656d [FLINK-34409][ci] Enable any still disabled e2e tests for the AdaptiveScheduler new 4069d87c333

(flink) 01/02: [FLINK-26615][tests] Assert only the minimum delay in RetryingExecutorTest.testTimeout

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.18 in repository https://gitbox.apache.org/repos/asf/flink.git commit f3625bc87faa8ff9020e95d8083b22f197391feb Author: Roman Khachatryan AuthorDate: Tue Mar 26 18:00:03 2024 +0100

(flink) branch release-1.18 updated (f2a6ff5a97b -> febdaeeda51)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch release-1.18 in repository https://gitbox.apache.org/repos/asf/flink.git from f2a6ff5a97b [FLINK-34409][ci] Enable any still disabled e2e tests for the AdaptiveScheduler new f3625bc87fa

(flink) branch master updated: [FLINK-34643] Use AdaptiveScheduler in JobIDLoggingITCase

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new d4c1a0a1ba4 [FLINK-34643] Use AdaptiveScheduler

(flink) branch master updated (7ea5bcce6a5 -> 7d6cdc5e5b9)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 7ea5bcce6a5 [FLINK-34938] Fix incorrect behaviour for comparison functions (#24566) new fc60d176e3a [FLINK-26615

(flink) 01/02: [FLINK-26615][tests] Assert only the minimum delay in RetryingExecutorTest.testTimeout

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit fc60d176e3ad7f06a93ebb37da491737f196fbe6 Author: Roman Khachatryan AuthorDate: Tue Mar 26 18:00:03 2024 +0100 [FLINK

(flink) 02/02: [FLINK-26515][tests] Tolerate TimeoutException in RetryingExecutorTest.testDiscardOnTimeout

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 7d6cdc5e5b97db6ac9daf8636fe1873765479246 Author: Roman Khachatryan AuthorDate: Tue Mar 26 18:53:00 2024 +0100 [FLINK

(flink) 01/02: [FLINK-34643] Fix concurrency issue in LoggerAuditingExtension

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit ed4d6f091f27ffc778cbb6de6a3fa19251277bdc Author: Roman Khachatryan AuthorDate: Thu Mar 21 14:26:44 2024 +0100 [FLINK

(flink) 02/02: [FLINK-34643][tests] Ignore 'lost leadership' log messages

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 4edafcc8b0b96920036a1afaaa37ae87b77668ed Author: Roman Khachatryan AuthorDate: Fri Mar 22 16:10:07 2024 +0100 [FLINK

(flink) branch master updated (8dcb0ae9063 -> 4edafcc8b0b)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 8dcb0ae9063 [FLINK-32513][core] Add predecessor caching new ed4d6f091f2 [FLINK-34643] Fix concurrency issue

(flink) branch master updated: [FLINK-34643][tests] Fix JobIDLoggingITCase

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 6b5ae445724 [FLINK-34643][tests] Fix

(flink) branch master updated: [FLINK-34417] Log Job ID via MDC

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new d6a4eb966fb [FLINK-34417] Log Job ID via MDC

(flink) branch release-1.19 updated: [FLINK-34344] Pass JobID to CheckpointStatsTracker

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.19 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.19 by this push: new 37756561d99 [FLINK-34344] Pass JobID

(flink) branch release-1.18 updated: [FLINK-34344] Pass JobID to CheckpointStatsTracker

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.18 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.18 by this push: new 33fb37aac5f [FLINK-34344] Pass JobID

(flink) branch master updated: [FLINK-34344] Pass JobID to CheckpointStatsTracker

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new c84f42c1a7e [FLINK-34344] Pass JobID

(flink) branch release-1.17 updated: [FLINK-33442] Copy local state collection preventively

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.17 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.17 by this push: new 9f067c4a825 [FLINK-33442] Copy local

[flink] branch master updated: [FLINK-33077][runtime] Minimize the risk of hard back-pressure with buffer debloating enabled

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new c7f6470bb8c [FLINK-33077][runtime] Minimize

[flink] branch master updated (3ef71327177 -> 5f9de3eda3e)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 3ef71327177 [FLINK-32835][runtime] Migrate unit tests in "accumulators" and "blob" package

[flink] branch release-1.17 updated: [FLINK-31139][state/changelog] not upload empty state changelog file

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.17 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.17 by this push: new 8798fde04e4 [FLINK-31139][state

[flink] branch release-1.16 updated: [FLINK-31139][state/changelog] not upload empty state changelog file

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.16 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.16 by this push: new 5157ac5921d [FLINK-31139][state

[flink] branch release-1.17 updated: [hotfix][checkpointing] Fix outdated java doc in SharedStateRegistry after FLINK-29913

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.17 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.17 by this push: new e213267ebf6 [hotfix][checkpointing

[flink] branch release-1.16 updated: [hotfix][checkpointing] Fix outdated java doc in SharedStateRegistry after FLINK-29913

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.16 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.16 by this push: new f2d3ca0bf4d [hotfix][checkpointing

[flink] branch master updated: [hotfix][checkpointing] Fix outdated java doc in SharedStateRegistry after FLINK-29913

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new c7d3e360530 [hotfix][checkpointing] Fix outdated

[flink] 02/04: [refactor][test] Introduce DiscardRecordedStateObject to avoid using mocks for state handles

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.17 in repository https://gitbox.apache.org/repos/asf/flink.git commit 46fa6a03062b90c460141aa275fa06347bc876da Author: wangfeifan AuthorDate: Mon Jul 24 14:44:02 2023 +0800

[flink] 01/04: [FLINK-29913][checkpointing] Use PhysicalStateHandleID as a key for shared state of IncrementalRemoteKeyedStateHandle

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.17 in repository https://gitbox.apache.org/repos/asf/flink.git commit f3d212956660a77d58ab99f4de6611760e5f0b9a Author: wangfeifan AuthorDate: Mon Jul 24 15:39:51 2023 +0800 [FLINK

[flink] branch release-1.17 updated (96a6d96451a -> 65e7004dd32)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch release-1.17 in repository https://gitbox.apache.org/repos/asf/flink.git from 96a6d96451a [hotfix][doc] Fix typo in JobManagerOptions (#22992) new f3d21295666 [FLINK-29913][checkpointing

[flink] 03/04: [FLINK-29913][checkpointing] Remove de-duplication from SharedStateRegistry#registerReference()

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.17 in repository https://gitbox.apache.org/repos/asf/flink.git commit 9217bd9f4dc937f1aff55fe5696e33954445970f Author: wangfeifan AuthorDate: Mon Jul 24 15:12:38 2023 +0800 [FLINK

[flink] 04/04: [hotfix][state-changelog] Don't trigger new materialization unless the previous one is confirmed/failed/cancelled

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.17 in repository https://gitbox.apache.org/repos/asf/flink.git commit 65e7004dd32633f9dfc87b0808ffcb587daf525c Author: wangfeifan AuthorDate: Fri Jun 16 11:48:58 2023 +0800 [hotfix

[flink] 02/04: [refactor][test] Introduce DiscardRecordedStateObject to avoid using mocks for state handles

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.16 in repository https://gitbox.apache.org/repos/asf/flink.git commit d00e2eb73aa5f2d2506370b5fbe9c8867cbec987 Author: wangfeifan AuthorDate: Mon Jul 24 14:44:02 2023 +0800

[flink] 04/04: [hotfix][state-changelog] Don't trigger new materialization unless the previous one is confirmed/failed/cancelled

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.16 in repository https://gitbox.apache.org/repos/asf/flink.git commit aad658910fd6967199bce69f33872d245315bca1 Author: wangfeifan AuthorDate: Fri Jun 16 11:48:58 2023 +0800 [hotfix

[flink] 03/04: [FLINK-29913][checkpointing] Remove de-duplication from SharedStateRegistry#registerReference()

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.16 in repository https://gitbox.apache.org/repos/asf/flink.git commit bf8456df6954def6f2134511840522b8e959b92b Author: wangfeifan AuthorDate: Mon Jul 24 15:12:38 2023 +0800 [FLINK

[flink] 01/04: [FLINK-29913][checkpointing] Use PhysicalStateHandleID as a key for shared state of IncrementalRemoteKeyedStateHandle

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.16 in repository https://gitbox.apache.org/repos/asf/flink.git commit c6c54412bf70af4432071dfdf131b62ff8236fe7 Author: wangfeifan AuthorDate: Mon Jul 24 15:39:51 2023 +0800 [FLINK

[flink] branch release-1.16 updated (d4c52b372a8 -> aad658910fd)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch release-1.16 in repository https://gitbox.apache.org/repos/asf/flink.git from d4c52b372a8 [hotfix][doc] Fix typo in JobManagerOptions (#22992) new c6c54412bf7 [FLINK-29913][checkpointing

[flink] 02/04: [refactor][test] Introduce DiscardRecordedStateObject to avoid using mocks for state handles

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 4467ad05bb9823d90be770d5e1c36989f3905d1b Author: wangfeifan AuthorDate: Mon Jul 24 14:44:02 2023 +0800 [refactor

[flink] 01/04: [FLINK-29913][checkpointing] Use PhysicalStateHandleID as a key for shared state of IncrementalRemoteKeyedStateHandle

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 6dcb10abf319b9e5494a82bee71f1ae1a4e4b211 Author: wangfeifan AuthorDate: Mon Jul 24 15:39:51 2023 +0800 [FLINK-29913

[flink] 04/04: [hotfix][state-changelog] Don't trigger new materialization unless the previous one is confirmed/failed/cancelled

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 85f32d6bcb31708c9c2c845ea03ef117726b7c1a Author: wangfeifan AuthorDate: Fri Jun 16 11:48:58 2023 +0800 [hotfix

[flink] 03/04: [FLINK-29913][checkpointing] Remove de-duplication from SharedStateRegistry#registerReference()

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit bde09516be2c3693c8f8fef3678999b6e47333c6 Author: wangfeifan AuthorDate: Mon Jul 24 15:12:38 2023 +0800 [FLINK-29913

[flink] branch master updated (255d83087c6 -> 85f32d6bcb3)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 255d83087c6 [FLINK-32560][Scala] Deprecate all Scala API new 6dcb10abf31 [FLINK-29913][checkpointing] Use

[flink] branch master updated (fd96076b1b4 -> 86207724d5b)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from fd96076b1b4 [FLINK-32404][table] Add catalog modification listener interface and create listener for catalog manager

[flink] branch master updated: [FLINK-31035] add warn info to user when NoNodeException happend

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new f89be70c2b0 [FLINK-31035] add warn info to user

[flink] branch release-1.16 updated (e891bfc156d -> 80ee512f00a)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch release-1.16 in repository https://gitbox.apache.org/repos/asf/flink.git from e891bfc156d [python][examples] Add Python streaming word count examples add 80ee512f00a [FLINK-31527][tests

[flink] branch master updated: [FLINK-31527][tests] Stabilize ChangelogRescalingITCase

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 9ba3b1a5863 [FLINK-31527][tests] Stabilize

[flink] branch master updated: [FLINK-30023][changelog] increase timeout in ChangelogStorageMetricsTest#testTotalAttemptsPerUpload for improving stability

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new ef5b3173c15 [FLINK-30023][changelog] increase

[flink] branch master updated: [FLINK-31139][state/changelog] not upload empty state changelog file

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new fb37e6a87d9 [FLINK-31139][state/changelog

[flink] branch release-1.15 updated: [FLINK-27169][tests] Increase changelog upload timeout in PartiallyFinishedSourcesITCase

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.15 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.15 by this push: new ddec8d8e144 [FLINK-27169][tests

[flink] branch release-1.15 updated: [FLINK-31133][tests] Prevent timeouts in PartiallyFinishedSourcesITCase

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.15 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.15 by this push: new 51660f840cf [FLINK-31133][tests

[flink] branch release-1.17 updated: [FLINK-31133][tests] Prevent timeouts in PartiallyFinishedSourcesITCase

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.17 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.17 by this push: new 6e7703738cd [FLINK-31133][tests

[flink] branch release-1.16 updated (01c8eb59c1b -> cf04b2c08fa)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch release-1.16 in repository https://gitbox.apache.org/repos/asf/flink.git from 01c8eb59c1b [FLINK-31288][doc] Update doc ralated to overdraft buffer. add cf04b2c08fa [FLINK-31133][tests

[flink] branch master updated: [FLINK-31133][tests] Prevent timeouts in PartiallyFinishedSourcesITCase

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 4aacff572a9 [FLINK-31133][tests] Prevent timeouts

[flink] 04/04: [FLINK-21450][runtime] Support LocalRecovery by AdaptiveScheduler

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit e38a6709b57000e38bf044d0e55da3dd3ec3bde8 Author: David Moravek AuthorDate: Fri Jan 21 10:09:53 2022 +0100 [FLINK

[flink] 03/04: [FLINK-21450][runtime] Restructure types passed between AdaptiveScheduler and SlotAssigner

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 416cb7aaa02c176e01485ff11ab4269f76b5e9e2 Author: Roman Khachatryan AuthorDate: Tue Feb 28 14:22:28 2023 + [FLINK

[flink] branch master updated (18c73f1488b -> e38a6709b57)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 18c73f1488b [docs][hotfix] correct label in config configuration new d718342ad03 [hotfix][tests] Make

[flink] 02/04: [FLINK-21450][runtime] Add previous ExecutionGraph to WaitingForResources AdaptiveScheduler state

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 676e8e5528f99eb8ba5747f7489b0f02ee025dd6 Author: Roman Khachatryan AuthorDate: Mon Feb 20 23:08:47 2023 + [FLINK

[flink] 01/04: [hotfix][tests] Make LocalRecoveryITCase fail when allocations don't match

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit d718342ad0311ea7481d1a1bd87c395aeff25928 Author: Roman Khachatryan AuthorDate: Mon Feb 20 20:30:19 2023 +

[flink] branch release-1.16 updated (f0e0069a741 -> 700f8839126)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch release-1.16 in repository https://gitbox.apache.org/repos/asf/flink.git from f0e0069a741 [FLINK-31031][python] Disable the output buffer of Python process add 700f8839126 [FLINK-28440

[flink] branch release-1.17 updated: [FLINK-28440][state/changelog] record reference count of StreamStateHandle in TaskChangelogRegistry

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.17 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.17 by this push: new c612575ed33 [FLINK-28440][state

[flink] branch master updated: [FLINK-28440][state/changelog] record reference count of StreamStateHandle in TaskChangelogRegistry

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new c0aa73df4df [FLINK-28440][state/changelog] record

[flink] branch release-1.17 updated: [FLINK-30561][state/changelog] fix changelog local cache file not found

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.17 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.17 by this push: new 0d14c618825 [FLINK-30561][state

[flink] branch master updated: [FLINK-30561][state/changelog] fix changelog local cache file not found

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new ba2b55df207 [FLINK-30561][state/changelog] fix

[flink] branch release-1.17 updated: [FLINK-30785][tests] Ignore completeExceptionally in e2e test logs

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.17 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.17 by this push: new 05e687cdea8 [FLINK-30785][tests

[flink] branch master updated (d9102ddd755 -> d7bbb763ded)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from d9102ddd755 [FLINK-29237][table] Remove RexSimplify from Flink code, SearchOperator code generation

[flink] branch master updated (b1e70aebd3e -> 7b656441617)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from b1e70aebd3e [FLINK-30846][runtime] Fix getSchedulerType for testing with flink.tests.enable-adaptive-scheduler

[flink] 01/02: [refactor][state / rocksdb] Introduce RocksDBMemory factory interface to facilitate testing

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit c5d13f8c7c20ec4b69a824c2b1a19ce578b80add Author: Roman Khachatryan AuthorDate: Sun Jan 29 14:19:57 2023 +

[flink] 02/02: [FLINK-30328][tests] Use RocksDBMemory factory interface in TaskManagerWideRocksDbMemorySharingITCase

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 7b65644161767e90f0834db76ba116d4d92449d5 Author: Roman Khachatryan AuthorDate: Sun Jan 29 14:20:51 2023 + [FLINK

[flink] branch master updated (c9e87fe410c -> abb060aa775)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from c9e87fe410c [FLINK-30692][sql-client] Introduce SingleSessionManager to support REMOVE JAR syntax (#21771) add

[flink] branch master updated (f8105bb584f -> b4fe4a42887)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from f8105bb584f [FLINK-30328][tests] Fix unstable TaskManagerWideRocksDbMemorySharingITCase add b4fe4a42887 [FLINK

[flink] branch master updated (f38c2370e85 -> f8105bb584f)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from f38c2370e85 [FLINK-30278][streaming] Unset parallelism in the SinkTransformationTranslator if it wasn't set before

[flink] branch master updated (6b68bc6ccc1 -> c7a8205a221)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 6b68bc6ccc1 [FLINK-30275][tests] Fix off-by-one error in TaskExecutorTest.testSharedResourcesLifecycle add

[flink] branch master updated (fb27e689350 -> 6b68bc6ccc1)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from fb27e689350 [FLINK-30240][table]Fix doc error reference to TableKind#MANAGED add 6b68bc6ccc1 [FLINK-30275][tests

[flink] branch master updated: [FLINK-29928][runtime, state] Share RocksDB memory across TM slots

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 3b6d08e57f6 [FLINK-29928][runtime, state] Share

[flink] 01/03: [hotfix][tests] Use negative changelog materialization interval in tests

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.15 in repository https://gitbox.apache.org/repos/asf/flink.git commit 258c3e35265bb3a966bd317340f2a5fe7cfd7364 Author: Roman Khachatryan AuthorDate: Wed Aug 24 18:20:02 2022 +0200

[flink] 03/03: [FLINK-28976][state] Don't add extra delay to the 1st materialization

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.15 in repository https://gitbox.apache.org/repos/asf/flink.git commit 493a1aa8556038283e256efc5368bd319bd06d17 Author: Roman Khachatryan AuthorDate: Mon Aug 15 19:30:36 2022 +0200

[flink] 02/03: [hotfix][state] Fix logging in Materializer and make FLINK-28976 more explicit

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.15 in repository https://gitbox.apache.org/repos/asf/flink.git commit 605a7118a018a716b7715834f5b3f63f3e7064af Author: Roman Khachatryan AuthorDate: Mon Aug 15 19:29:58 2022 +0200

[flink] branch release-1.15 updated (62d7cc0ee4b -> 493a1aa8556)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch release-1.15 in repository https://gitbox.apache.org/repos/asf/flink.git from 62d7cc0ee4b Update japicmp configuration for 1.15.2 new 258c3e35265 [hotfix][tests] Use negative changelog

[flink] branch master updated (3149c621671 -> 91e1291e942)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 3149c621671 [FLINK-29096][table] Update documentation for JSON_VALUE special characters add a38b852bbbd [hotfix

[flink-benchmarks] branch master updated: [FLINK-28931] Fix BlockingPartitionBenchmark compile error

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-benchmarks.git The following commit(s) were added to refs/heads/master by this push: new 4726194 [FLINK-28931] Fix

[flink] branch release-1.15 updated: [FLINK-27570][runtime] Count checkpoint finalization failures in CheckpointFailureManager

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.15 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.15 by this push: new b24c5161162 [FLINK-27570][runtime

[flink] branch master updated: [FLINK-27570][runtime] Count checkpoint finalization failures in CheckpointFailureManager

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 88b309b7dca [FLINK-27570][runtime] Count

[flink] branch master updated (465db25502e -> 3268ec6a7ce)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 465db25502e [FLINK-28904][python][docs] Add missing connector/format documentation add 3268ec6a7ce [FLINK-28898

[flink] branch master updated (10a6f41fa12 -> c5a8b0f3c29)

This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 10a6f41fa12 [FLINK-28532][table] Support full caching in lookup join runner using InputFormats as scan runtime

[flink] branch master updated: [FLINK-28178][runtime-web] Show the delegated StateBackend and whether changelog is enabled in the UI

This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 9ed70a1e8b5 [FLINK-28178][runtime-web] Show

  1   2   3   4   5   >