(flink) branch release-1.18 updated: [FLINK-35217] Add missing fsync to #closeForCommit in some subclasses of RecoverableFsDataOutputStream. (#24722) (#24752)

This is an automated email from the ASF dual-hosted git repository. srichter 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 e6726d3b962 [FLINK-35217] Add

(flink) branch release-1.19 updated: [FLINK-35217] Add missing fsync to #closeForCommit in some subclasses of RecoverableFsDataOutputStream. (#24722) (#24751)

This is an automated email from the ASF dual-hosted git repository. srichter 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 ac4aa35c6e2 [FLINK-35217] Add

(flink) branch master updated: [FLINK-35217] Add missing fsync to #closeForCommit in some subclasses of RecoverableFsDataOutputStream. (#24722)

This is an automated email from the ASF dual-hosted git repository. srichter 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 80af4d50231 [FLINK-35217] Add missing fsync

(flink) branch master updated: [FLINK-34546] Emit span with failure labels on failure in AdaptiveScheduler. (#24498)

This is an automated email from the ASF dual-hosted git repository. srichter 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 10bff3dbad1 [FLINK-34546] Emit span

(flink) branch master updated: [FLINK-34546] Emit span with failure labels on failure.

This is an automated email from the ASF dual-hosted git repository. srichter 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 7c8e3f5a0c3 [FLINK-34546] Emit span

(flink) 01/02: [hotfix] Fix configuration through TernaryBoolean in EmbeddedRocksDBStateBackend.

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 5be8b3e1dfdb5a009677b2e194def2ad3b1122ec Author: Stefan Richter AuthorDate: Tue Feb 27 10:48:40 2024 +0100

(flink) 02/02: [hotfix] Reduce code duplication and add logging in RocksDBIncrementalCheckpointUtils#deleteRangeData.

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit e2b6588ef39cbeb1825cacf553a80272ae7b9418 Author: Stefan Richter AuthorDate: Tue Feb 27 11:54:28 2024 +0100

(flink) branch master updated (b9069227098 -> e2b6588ef39)

This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from b9069227098 [FLINK-34454][doc/annotation] Use claim mode instead of restore mode everywhere new 5be8b3e1dfd

(flink) 01/02: [FLINK-34050][state] Clean up useless files in deleted ranges during restore for RocksdbStateBackend

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 534ea31e7ef8c7aa906ed4226f4f55ec0abc3fb2 Author: Jinzhong Li AuthorDate: Mon Jan 15 18:00:34 2024 +0800 [FLINK

(flink) 02/02: [FLINK-34050][state] Introduce parameter protection for DeleteFilesInRange

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit b048a9cd37d0f202117bfbb74f2991879223c160 Author: Jinzhong Li AuthorDate: Mon Feb 26 20:08:56 2024 +0800 [FLINK

(flink) branch master updated (db3e21f84c2 -> b048a9cd37d)

This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from db3e21f84c2 [hotfix][runtime] Refactors suspend and cancel logic new 534ea31e7ef [FLINK-34050][state] Clean up

(flink) branch master updated: [hotfix] Remove redundant call to remove().

This is an automated email from the ASF dual-hosted git repository. srichter 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 049de6628de [hotfix] Remove redundant call

(flink) 04/05: [FLINK-34199] Add tracing for durations of rescaling/restoring (from local and downloaded remote state).

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 16eae412a1219fec1aaf43381fb03709e52407bd Author: Stefan Richter AuthorDate: Mon Jan 22 15:46:32 2024 +0100 [FLINK

(flink) 01/05: [FLINK-31238] Use IngestDB to speed up Rocksdb rescaling recovery (part 1)

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 4ddedeb0357eb89bef445ccb2d084c940f2c1c52 Author: 马越 AuthorDate: Tue Aug 8 14:56:17 2023 +0200 [FLINK-31238] Use

(flink) 02/05: [FLINK-31238] Use IngestDB to speed up Rocksdb rescaling recovery (part 2)

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 5495a96a38663dc04753cb6db0c100aa2bc7d297 Author: Stefan Richter AuthorDate: Fri Jan 5 15:32:32 2024 +0100 [FLINK

(flink) 03/05: [FLINK-31238] Deactivate parts of the code until new FRocksDB release is available.

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 268a30802edf0c7d1be61e29d47ba5343dfa8a49 Author: Stefan Richter AuthorDate: Mon Feb 12 13:35:40 2024 +0100 [FLINK

(flink) 05/05: [FLINK-34199] Add documentation.

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 6bf97674b660dbe1cd96b5b0273c3954f2c16fba Author: Stefan Richter AuthorDate: Mon Jan 22 15:50:09 2024 +0100 [FLINK

(flink) branch master updated (5844092408d -> 6bf97674b66)

This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 5844092408d [FLINK-34000] Remove IncrementalGroupAgg Json Plan & IT tests new 4ddedeb0357 [FLINK-31238]

(flink) branch master updated (201571b486f -> bdf31327775)

This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 201571b486f [FLINK-27992] Set ALWAYS chaining strategy for CepOperator in ExecMatch new f1e355437eb [FLINK

(flink) 05/06: [FLINK-34134] Collect and report size/location statistics during task restore.

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 9dc0f6f658be4e8d1845857bb16ac5155ccb0873 Author: Stefan Richter AuthorDate: Tue Jan 16 17:22:02 2024 +0100 [FLINK

(flink) 01/06: [FLINK-34134] Minor cleanup of unused parameters in RocksDB backend.

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit f1e355437eb8ae5a0cdad0caccac26faa5c022c6 Author: Stefan Richter AuthorDate: Mon Jan 15 13:22:41 2024 +0100 [FLINK

(flink) 04/06: [FLINK-34134] Implement handle-specific size/location reporting methods.

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 8e0e2ca97c9225d4ce3faa6781a0e3a524645cd4 Author: Stefan Richter AuthorDate: Tue Jan 16 16:09:44 2024 +0100 [FLINK

(flink) 02/06: [FLINK-34134] Introduce size/location statistics reporting to StateObject interface.

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 22241080a8013296a95c2b18cc17d5148befad4f Author: Stefan Richter AuthorDate: Tue Jan 16 15:22:19 2024 +0100 [FLINK

(flink) 06/06: [FLINK-34134] Add documentation.

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit bdf313277754ebcab4d6ccb6aba9d49860933322 Author: Stefan Richter AuthorDate: Wed Jan 17 14:55:20 2024 +0100 [FLINK

(flink) 03/06: [FLINK-34134] Add methods to determine local directory sizes to FileUtils.

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 210ab633350c77b026f883f72d3884eda20a03ae Author: Stefan Richter AuthorDate: Tue Jan 16 15:36:09 2024 +0100 [FLINK

(flink) 04/05: [FLINK-33341][state] Add support for rescaling from local keyed state to RockDBIncrementalRestoreOperation.

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 05cdb299e26db931a328bdc4e536dfb7effdb905 Author: Stefan Richter AuthorDate: Wed Oct 25 11:50:55 2023 +0200 [FLINK

(flink) 03/05: [FLINK-33341][state] Refactoring: consolidate equals/hashCode/toString for incremental state handle classes.

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 0be231972d5d687924db22ae81d6a10049f7c43e Author: Stefan Richter AuthorDate: Fri Oct 27 11:01:49 2023 +0200 [FLINK

(flink) 02/05: [FLINK-33341][state] Refactoring: introduce common superclass for all IncrementalKeyedStateHandle.

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 2d74ee3966525be5ab3770a653c96a7d04d5f05a Author: Stefan Richter AuthorDate: Thu Oct 19 14:31:10 2023 +0200 [FLINK

(flink) branch master updated (e914eb7fc3f -> a4ad86fb083)

This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from e914eb7fc3f [FLINK-33371] Make TestValues sinks return results as Rows new 98e4610f09f [FLINK-33246][tests] Add

(flink) 01/05: [FLINK-33246][tests] Add AutoRescalingITCase.

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 98e4610f09f35a942e55472b5d358ebe113b0dba Author: Stefan Richter AuthorDate: Mon Oct 9 14:23:47 2023 +0200 [FLINK

(flink) 05/05: [FLINK-33341][state] Add support for rescaling from local keyed state to PrioritizedOperatorSubtaskState.

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit a4ad86fb083f90503938a9c3d816cdda9dc22427 Author: Stefan Richter AuthorDate: Fri Oct 13 16:27:39 2023 +0200 [FLINK

[flink] branch master updated (9e6f8e8e127 -> d11cc32948b)

This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 9e6f8e8e127 [FLINK-32680][streaming] Fix the messed up JobVertex name when the source nodes chained

[flink] branch master updated (9d7b1663296 -> 1ef99736979)

This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 9d7b1663296 [FLINK-32495][connectors/common] Limit the CoordinatorExecutorThreadFactory to be a one-off add

[flink] branch master updated: [FLINK-32441] Fix DefaultSchedulerTest#testTriggerCheckpointAndCompletedAfterStore (#22879)

This is an automated email from the ASF dual-hosted git repository. srichter 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 0c787f522ed [FLINK-32441] Fix

[flink] branch master updated: [FLINK-32347][checkpoint] Exceptions from the CompletedCheckpointStore are not registered by the CheckpointFailureManager. (#22793)

This is an automated email from the ASF dual-hosted git repository. srichter 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 602261648db [FLINK-32347][checkpoint

[flink] branch master updated: [FLINK-32345][state] Improve parallel download of RocksDB incremental state. (#22788)

This is an automated email from the ASF dual-hosted git repository. srichter 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 2ed858318f3 [FLINK-32345][state] Improve

[flink] branch master updated: [FLINK-32326][state] Disable WAL in RocksDBWriteBatchWrapper by default. (#22771)

This is an automated email from the ASF dual-hosted git repository. srichter 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 45ba7ee87ca [FLINK-32326][state] Disable WAL

[flink] branch release-1.17 updated: [FLINK-31963][state] Fix rescaling bug in recovery from unaligned checkpoints. (#22584) (#22594)

This is an automated email from the ASF dual-hosted git repository. srichter 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 8d8a486aaa8 [FLINK-31963][state

[flink] branch release-1.16 updated (ffa58e1de3d -> 2203bc3bdc9)

This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch release-1.16 in repository https://gitbox.apache.org/repos/asf/flink.git from ffa58e1de3d [FLINK-31418][network][tests] Fix unstable test case

[flink] branch master updated: [FLINK-31963][state] Fix rescaling bug in recovery from unaligned checkpoints. (#22584)

This is an automated email from the ASF dual-hosted git repository. srichter 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 354c0f455b9 [FLINK-31963][state] Fix rescaling

[flink] branch master updated (de7440e -> 3d51e6c3d)

This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from de7440e [FLINK-15658][table-planner-blink] Fix duplicate field names exception when join on the same key multiple

[flink] branch master updated (61d2525 -> c75af84)

This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 61d2525 [FLINK-13323][table-runtime-blink] Add tests for complex data formats add 23f726c [FLINK-13326] Add

[flink] branch release-1.9 updated: [FLINK-13249][runtime] Fix handling of partition producer responses by running them with the task's executor

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

[flink] branch master updated: [FLINK-13249][runtime] Fix handling of partition producer responses b… (#9138)

This is an automated email from the ASF dual-hosted git repository. srichter 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 23bd23b [FLINK-13249][runtime] Fix handling

[flink] branch release-1.9 updated: [FLINK-13256] Ensure periodical checkpointing continues when regional failover aborts pending checkpoints

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

[flink] branch master updated: [FLINK-13256] Ensure periodical checkpointing continues when regional failover aborts pending checkpoints

This is an automated email from the ASF dual-hosted git repository. srichter 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 1ec3424 [FLINK-13256] Ensure periodical

[flink] 03/03: [FLINK-12804] Change mailbox implementation from bounded to unbounded

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 6cf98b671d889f1003172bc656ded69d1aab9235 Author: Stefan Richter AuthorDate: Wed Jul 3 13:32:46 2019 +0200 [FLINK

[flink] 02/03: [FLINK-12804] Introduce mailbox-based ExecutorService

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 5b24aa0302074a5eaf6c1b47c2764e9883b674ab Author: Stefan Richter AuthorDate: Fri Jun 21 18:07:03 2019 +0200 [FLINK

[flink] branch master updated (3059a2f -> 6cf98b6)

This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 3059a2f [FLINK-13133] [pubsub] Fix small error in PubSub documentation relating to PubSubSink serializer

[flink] 01/03: [hotfix] Remove dangerous waiting methods from mailbox

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit acfbc83cf17f94a27c1aa71c331ee95382f55596 Author: Stefan Richter AuthorDate: Wed Jun 26 12:21:33 2019 +0200

[flink] branch master updated: [FLINK-13063] Temporary fix for AsyncWaitOperator consistency problems

This is an automated email from the ASF dual-hosted git repository. srichter 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 c773ce5 [FLINK-13063] Temporary fix

[flink] branch master updated: [FLINK-12730][runtime] Unify BitSet implementations in flink-runtime

This is an automated email from the ASF dual-hosted git repository. srichter 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 14c4b23 [FLINK-12730][runtime] Unify BitSet

[flink] branch master updated: [FLINK-12364] Introduce CheckpointFailureManager for centralized checkpoint failure handling

This is an automated email from the ASF dual-hosted git repository. srichter 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 8c57e5a [FLINK-12364] Introduce

[flink] 01/02: [FLINK-12478, FLINK-12480][runtime] Introduce mailbox to StreamTask main-loop.

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 022f6cceef65859bc6f172151d09140038297f69 Author: Stefan Richter AuthorDate: Fri May 10 11:20:02 2019 +0200 [FLINK

[flink] 02/02: [FLINK-12483][runtime] Support (legacy) SourceFunction as special case in the mailbox model for stream tasks.

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit ead9139680ea82c4fdfd1e9d19baf4d4a08ec845 Author: Stefan Richter AuthorDate: Tue May 14 15:33:48 2019 +0200 [FLINK

[flink] branch master updated (3813bb9 -> ead9139)

This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 3813bb9 [FLINK-12241][hive] Support Flink functions in catalog function APIs of HiveCatalog new 022f6cc

[flink] branch release-1.6 updated: [FLINK-12296][StateBackend] Fix local state directory collision with state loss for chained keyed operators

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

[flink] branch release-1.7 updated: [FLINK-12296][StateBackend] Fix local state directory collision with state loss for chained keyed operators (#8323)

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

[flink] branch release-1.8 updated: [hotfix] Fix compile error from rebase of FLINK-12296]

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

[flink] branch release-1.8 updated: [FLINK-12296][StateBackend] Fix local state directory collision with state loss for chained keyed operators

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

[flink] branch master updated: [FLINK-12296][StateBackend] Fix local state directory collision with state loss for chained keyed operators

This is an automated email from the ASF dual-hosted git repository. srichter 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 ee60846 [FLINK-12296][StateBackend] Fix local

[flink] branch release-1.8 updated: [FLINK-12350] [State Backends] RocksDBStateBackendTest doesn't cover the incremental checkpoint code path

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

[flink] branch master updated: [FLINK-12350] [State Backends] RocksDBStateBackendTest doesn't cover the incremental checkpoint code path

This is an automated email from the ASF dual-hosted git repository. srichter 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 9aeb4e5 [FLINK-12350] [State Backends

[flink] branch master updated: [FLINK-11167] Optimize RocksDBListState#put by removing the clear before every put operation

This is an automated email from the ASF dual-hosted git repository. srichter 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 03faeb9 [FLINK-11167] Optimize

[flink] branch master updated: [FLINK-10724] Refactor failure handling in check point coordinator

This is an automated email from the ASF dual-hosted git repository. srichter 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 c4b0e8f [FLINK-10724] Refactor failure

[flink] branch master updated: [FLINK-12212][docs] Clarify that operator state is checkpointed asynchronously

This is an automated email from the ASF dual-hosted git repository. srichter 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 046d752 [FLINK-12212][docs] Clarify

[flink] branch master updated: [FLINK-10712] Support state restore for RestartPipelinedRegionStrategy

This is an automated email from the ASF dual-hosted git repository. srichter 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 c3a9293 [FLINK-10712] Support state restore

[flink] branch master updated: [hotfix] Delete empty TaskManager.scala file

This is an automated email from the ASF dual-hosted git repository. srichter 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 851ac7d [hotfix] Delete empty

[flink] branch master updated: [hotfix] Remove unused method ExecutionGraph#restoreLatestCheckpointedState

This is an automated email from the ASF dual-hosted git repository. srichter 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 32f0ad7 [hotfix] Remove unused method

[flink] 03/06: [FLINK-11952][2/4] Introduce basic plugin mechanism for Flink

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 0c4953c4c5ff583d88f1686cd96fd7e7be9d8f11 Author: Stefan Richter AuthorDate: Tue Apr 9 10:37:03 2019 +0200 [FLINK

[flink] 01/06: [hotfix] Remove unused exception from FileSystem#initialize

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 5aee179cb6677aad1e1b6f1808873167c4a05789 Author: Stefan Richter AuthorDate: Fri Mar 15 15:02:51 2019 +0100

[flink] 04/06: [FLINK-11952][3/4] Integrate plugin mechanism with FileSystem

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit c7b141b4b8767c9b7c8c72ef21055fd65908e848 Author: Stefan Richter AuthorDate: Fri Mar 22 14:57:09 2019 +0100 [FLINK

[flink] branch master updated (2c503c2 -> 703dc8d)

This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 2c503c2 [FLINK-11884][table] Ported sort & limit validation on top of Expressions new 5aee179 [ho

[flink] 06/06: [hotfix] Use TemporaryClassLoaderContext in other appropriate places in the codebase

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 703dc8dab1ee35b2532b472eec40fdc7dd124cc3 Author: Stefan Richter AuthorDate: Mon Apr 8 17:38:26 2019 +0200 [hotfix

[flink] branch master updated: [FLINK-10205] Introduce fault tolerance for InputSplits in batch execution

This is an automated email from the ASF dual-hosted git repository. srichter 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 4f689b1 [FLINK-10205] Introduce fault

[flink] 03/03: [hotfix] Remove unused method in AbstractKeyedStateBackend

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.8 in repository https://gitbox.apache.org/repos/asf/flink.git commit 2ab4ae7e862f98cffe9be187292cea7c6ed2e05c Author: Stefan Richter AuthorDate: Wed Mar 20 12:35:04 2019 +0100

[flink] branch release-1.8 updated (f421f32 -> 2ab4ae7)

This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch release-1.8 in repository https://gitbox.apache.org/repos/asf/flink.git. from f421f32 Update NOTICE-binary with latest changes new 0ced11c [hotfix] Fix inactive branch

[flink] 02/03: [FLINK-11980] Improve efficiency of iterating KeySelectionListener on notification

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.8 in repository https://gitbox.apache.org/repos/asf/flink.git commit ae91fd3bb5d1d132885399e7cc259a59459b8c6e Author: Stefan Richter AuthorDate: Tue Mar 19 15:01:06 2019 +0100

[flink] 01/03: [hotfix] Fix inactive branch in TtlStateTestBase

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.8 in repository https://gitbox.apache.org/repos/asf/flink.git commit 0ced11c8be7ccaf5112f3e050406cf75d5e55637 Author: Stefan Richter AuthorDate: Tue Mar 19 15:00:50 2019 +0100

[flink] 02/03: [FLINK-11980] Improve efficiency of iterating KeySelectionListener on notification

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 284e4486e57270c63b4f08d56599b1b4f97006c7 Author: Stefan Richter AuthorDate: Tue Mar 19 15:01:06 2019 +0100 [FLINK

[flink] 01/03: [hotfix] Fix inactive branch in TtlStateTestBase

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit aee1f182e8fbd311713d1661ab61755b069b1a6c Author: Stefan Richter AuthorDate: Tue Mar 19 15:00:50 2019 +0100

[flink] branch master updated (21cff1d -> b5c5499)

This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 21cff1d [hotfix][runtime] Delete unused interface ExecutionStatusListener new aee1f18 [hotfix] Fix inactive

[flink] 03/03: [hotfix] Remove unused method in AbstractKeyedStateBackend

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit b5c5499789f4e2ab21c4a05bf3da8ce7408b9663 Author: Stefan Richter AuthorDate: Wed Mar 20 12:35:04 2019 +0100

[flink] branch master updated: [FLINK-11903][tests] Improve FileStateBackendTest by using JUnit's parameterized

This is an automated email from the ASF dual-hosted git repository. srichter 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 76b9f8b [FLINK-11903][tests] Improve

[flink] branch master updated: [FLINK-11904][tests]Improve MemoryStateBackendTest by using JUnit's Parameterized

This is an automated email from the ASF dual-hosted git repository. srichter 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 6c7ddf3 [FLINK-11904][tests]Improve

[flink] branch master updated: [FLINK-11874][checkpoint] Split CheckpointStorage interface to distinguish JM and TM side

This is an automated email from the ASF dual-hosted git repository. srichter 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 b6b4baf [FLINK-11874][checkpoint] Split

[flink] branch master updated: [FLINK-11861][tests] Fix JobMasterTriggerSavepointIT not executed

This is an automated email from the ASF dual-hosted git repository. srichter 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 a709ed2 [FLINK-11861][tests] Fix

[flink] branch release-1.8 updated: [hotfix][statebackend] Reduce and simplify code for column creation in RocksDB backend

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

[flink] branch master updated: [hotfix][statebackend] Reduce and simplify code for column creation in RocksDB backend

This is an automated email from the ASF dual-hosted git repository. srichter 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 953a5ff [hotfix][statebackend] Reduce

[flink] branch master updated: [FLINK-11829][checkpoint] Avoid FsCheckpointStateOutputStream to store state in files when size below fileStateThreshold

This is an automated email from the ASF dual-hosted git repository. srichter 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 753bc10 [FLINK-11829][checkpoint] Avoid

[flink] branch master updated: [hotfix][flink-core] fix errors in MemorySegment description

This is an automated email from the ASF dual-hosted git repository. srichter 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 4399181 [hotfix][flink-core] fix errors

[flink] branch release-1.8 updated: [FLINK-11833] [State Backends] Cleanup unnecessary createKeyedStateBackend methods in StateBackend

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

[flink] branch master updated: [FLINK-11833] [State Backends] Cleanup unnecessary createKeyedStateBackend methods in StateBackend

This is an automated email from the ASF dual-hosted git repository. srichter 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 f10a7d8 [FLINK-11833] [State Backends

[flink] 01/02: [FLINK-11731] [State Backends] Make DefaultOperatorStateBackend follow the builder pattern

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.8 in repository https://gitbox.apache.org/repos/asf/flink.git commit 2f62b890624116cbe205cdcc9762e41f6a80c84f Author: Yu Li AuthorDate: Sat Mar 2 11:19:21 2019 +0100 [FLINK

[flink] branch release-1.8 updated (b027fa7 -> ce2d65d)

This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch release-1.8 in repository https://gitbox.apache.org/repos/asf/flink.git. from b027fa7 Fix version change expressions in releasing scripts new 2f62b89 [FLINK-11731] [State Backends

[flink] 02/02: [FLINK-11796] [State Backends] Remove Snapshotable interface

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.8 in repository https://gitbox.apache.org/repos/asf/flink.git commit ce2d65d88d28bcd5cf182395d511a239dacfb89d Author: Yu Li AuthorDate: Sat Mar 2 20:00:43 2019 +0100 [FLINK

[flink] branch master updated (fb256d4 -> e8daa49)

This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from fb256d4 [FLINK-11803][table-planner-blink] Improve FlinkTypeFactory for Blink (#7898) new 94f84a5 [FLINK

[flink] 02/02: [FLINK-11796] [State Backends] Remove Snapshotable interface

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit e8daa49a593edc401cd44761b25b1324b11be4a6 Author: Yu Li AuthorDate: Sun Mar 3 03:00:43 2019 +0800 [FLINK-11796

[flink] 02/02: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.8 in repository https://gitbox.apache.org/repos/asf/flink.git commit d5364dff200728d8611e9cdf0e8f798de145adcf Author: Yu Li AuthorDate: Thu Feb 28 20:02:35 2019 +0100 [FLINK

[flink] branch release-1.8 updated (8a5c972 -> d5364df)

This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch release-1.8 in repository https://gitbox.apache.org/repos/asf/flink.git. from 8a5c972 [hotfix][tests] Added matcher that performs deep comparison with taking Tuples into account new

  1   2   3   4   5   6   7   >