[GitHub] [flink] rkhachatryan commented on a change in pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

2021-07-20 Thread GitBox
rkhachatryan commented on a change in pull request #15322: URL: https://github.com/apache/flink/pull/15322#discussion_r672604163 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogOptions.java ## @@ -57,4 +87,18 @@

[GitHub] [flink] rkhachatryan commented on a change in pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

2021-07-20 Thread GitBox
rkhachatryan commented on a change in pull request #15322: URL: https://github.com/apache/flink/pull/15322#discussion_r672604163 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogOptions.java ## @@ -57,4 +87,18 @@

[GitHub] [flink] rkhachatryan commented on a change in pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

2021-07-19 Thread GitBox
rkhachatryan commented on a change in pull request #15322: URL: https://github.com/apache/flink/pull/15322#discussion_r672604163 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogOptions.java ## @@ -57,4 +87,18 @@

[GitHub] [flink] rkhachatryan commented on a change in pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

2021-07-15 Thread GitBox
rkhachatryan commented on a change in pull request #15322: URL: https://github.com/apache/flink/pull/15322#discussion_r670493892 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/RetryingExecutor.java ## @@ -0,0 +1,145 @@ +/* + * Licensed to

[GitHub] [flink] rkhachatryan commented on a change in pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

2021-07-15 Thread GitBox
rkhachatryan commented on a change in pull request #15322: URL: https://github.com/apache/flink/pull/15322#discussion_r670349351 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/RetryingExecutor.java ## @@ -0,0 +1,145 @@ +/* + * Licensed to

[GitHub] [flink] rkhachatryan commented on a change in pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

2021-07-15 Thread GitBox
rkhachatryan commented on a change in pull request #15322: URL: https://github.com/apache/flink/pull/15322#discussion_r670317795 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/RetryingExecutor.java ## @@ -0,0 +1,145 @@ +/* + * Licensed to

[GitHub] [flink] rkhachatryan commented on a change in pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

2021-07-15 Thread GitBox
rkhachatryan commented on a change in pull request #15322: URL: https://github.com/apache/flink/pull/15322#discussion_r670301045 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/RetryingExecutor.java ## @@ -0,0 +1,145 @@ +/* + * Licensed to

[GitHub] [flink] rkhachatryan commented on a change in pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

2021-07-15 Thread GitBox
rkhachatryan commented on a change in pull request #15322: URL: https://github.com/apache/flink/pull/15322#discussion_r670294511 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/RetryingExecutor.java ## @@ -0,0 +1,145 @@ +/* + * Licensed to

[GitHub] [flink] rkhachatryan commented on a change in pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

2021-07-15 Thread GitBox
rkhachatryan commented on a change in pull request #15322: URL: https://github.com/apache/flink/pull/15322#discussion_r670292361 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogOptions.java ## @@ -57,4 +87,18 @@

[GitHub] [flink] rkhachatryan commented on a change in pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

2021-07-15 Thread GitBox
rkhachatryan commented on a change in pull request #15322: URL: https://github.com/apache/flink/pull/15322#discussion_r670256039 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/StateChangeUploader.java ## @@ -0,0 +1,112 @@ +/* + * Licensed

[GitHub] [flink] rkhachatryan commented on a change in pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

2021-07-15 Thread GitBox
rkhachatryan commented on a change in pull request #15322: URL: https://github.com/apache/flink/pull/15322#discussion_r670246616 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogWriter.java ## @@ -0,0 +1,380 @@ +/* + *

[GitHub] [flink] rkhachatryan commented on a change in pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

2021-07-13 Thread GitBox
rkhachatryan commented on a change in pull request #15322: URL: https://github.com/apache/flink/pull/15322#discussion_r669034463 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/StateChangeUploader.java ## @@ -0,0 +1,112 @@ +/* + * Licensed

[GitHub] [flink] rkhachatryan commented on a change in pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

2021-07-13 Thread GitBox
rkhachatryan commented on a change in pull request #15322: URL: https://github.com/apache/flink/pull/15322#discussion_r669032073 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogWriter.java ## @@ -0,0 +1,380 @@ +/* + *

[GitHub] [flink] rkhachatryan commented on a change in pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

2021-07-13 Thread GitBox
rkhachatryan commented on a change in pull request #15322: URL: https://github.com/apache/flink/pull/15322#discussion_r669028568 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogWriter.java ## @@ -0,0 +1,380 @@ +/* + *

[GitHub] [flink] rkhachatryan commented on a change in pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

2021-07-13 Thread GitBox
rkhachatryan commented on a change in pull request #15322: URL: https://github.com/apache/flink/pull/15322#discussion_r669024193 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogWriter.java ## @@ -0,0 +1,380 @@ +/* + *

[GitHub] [flink] rkhachatryan commented on a change in pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

2021-07-13 Thread GitBox
rkhachatryan commented on a change in pull request #15322: URL: https://github.com/apache/flink/pull/15322#discussion_r669012703 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogCleanerImpl.java ## @@ -0,0 +1,66 @@ +/* + *

[GitHub] [flink] rkhachatryan commented on a change in pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

2021-07-13 Thread GitBox
rkhachatryan commented on a change in pull request #15322: URL: https://github.com/apache/flink/pull/15322#discussion_r669009917 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogWriter.java ## @@ -0,0 +1,380 @@ +/* + *

[GitHub] [flink] rkhachatryan commented on a change in pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

2021-07-12 Thread GitBox
rkhachatryan commented on a change in pull request #15322: URL: https://github.com/apache/flink/pull/15322#discussion_r668269992 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogStorage.java ## @@ -0,0 +1,135 @@ +/* + *

[GitHub] [flink] rkhachatryan commented on a change in pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

2021-07-12 Thread GitBox
rkhachatryan commented on a change in pull request #15322: URL: https://github.com/apache/flink/pull/15322#discussion_r668269992 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogStorage.java ## @@ -0,0 +1,135 @@ +/* + *

[GitHub] [flink] rkhachatryan commented on a change in pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

2021-07-12 Thread GitBox
rkhachatryan commented on a change in pull request #15322: URL: https://github.com/apache/flink/pull/15322#discussion_r667932492 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/BatchingStateChangeUploader.java ## @@ -0,0 +1,175 @@ +/* + *

[GitHub] [flink] rkhachatryan commented on a change in pull request #15322: [FLINK-21353][state] Add DFS-based StateChangelog (TM-owned state)

2021-07-01 Thread GitBox
rkhachatryan commented on a change in pull request #15322: URL: https://github.com/apache/flink/pull/15322#discussion_r662574161 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogWriter.java ## @@ -0,0 +1,207 @@ +/* + *