[jira] [Closed] (FLINK-20468) Enable leadership control in MiniCluster to test JM failover

[ https://issues.apache.org/jira/browse/FLINK-20468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-20468. --- Resolution: Done merged into master by b361027644a968ac3c32b818308bf8e52bdc9bf1 merged into

[jira] [Updated] (FLINK-20468) Enable leadership control in MiniCluster to test JM failover

[ https://issues.apache.org/jira/browse/FLINK-20468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-20468: Fix Version/s: 1.12.1 > Enable leadership control in MiniCluster to test JM failover > ---

[jira] [Closed] (FLINK-20469) Enable TaskManager start and terminate in MiniCluster

[ https://issues.apache.org/jira/browse/FLINK-20469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-20469. --- Resolution: Fixed merged into master by 736dc7475144b4217b6e229c34d72dc9e0a1a31a merged into

[jira] [Closed] (FLINK-20078) Factor out an ExecutionGraph factory method for DefaultExecutionTopology

[ https://issues.apache.org/jira/browse/FLINK-20078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-20078. --- Resolution: Fixed merged into master by cbdebd17017187900d13ed3a6769e08e59e56ca5 merged into

[jira] [Updated] (FLINK-20078) Factor out an ExecutionGraph factory method for DefaultExecutionTopology

[ https://issues.apache.org/jira/browse/FLINK-20078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-20078: Fix Version/s: 1.12.0 > Factor out an ExecutionGraph factory method for DefaultExecutionTo

[jira] [Updated] (FLINK-20468) Enable leadership control in MiniCluster to test JM failover

[ https://issues.apache.org/jira/browse/FLINK-20468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-20468: Description: [Original discussion|https://github.com/apache/flink/pull/14199#issuecomment

[jira] [Updated] (FLINK-20469) Enable TaskManager start and terminate in MiniCluster

[ https://issues.apache.org/jira/browse/FLINK-20469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-20469: Description: [Original discussion|https://github.com/apache/flink/pull/14199#issuecomment

[jira] [Created] (FLINK-20469) Enable TaskManager start and terminate in MiniCluster

Andrey Zagrebin created FLINK-20469: --- Summary: Enable TaskManager start and terminate in MiniCluster Key: FLINK-20469 URL: https://issues.apache.org/jira/browse/FLINK-20469 Project: Flink I

[jira] [Created] (FLINK-20468) Enable leadership control in MiniCluster to test JM failover

Andrey Zagrebin created FLINK-20468: --- Summary: Enable leadership control in MiniCluster to test JM failover Key: FLINK-20468 URL: https://issues.apache.org/jira/browse/FLINK-20468 Project: Flink

[jira] [Commented] (FLINK-17886) Update Chinese documentation for new WatermarkGenerator/WatermarkStrategies

[ https://issues.apache.org/jira/browse/FLINK-17886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239282#comment-17239282 ] Andrey Zagrebin commented on FLINK-17886: - should this also go into 1.11 as the

[jira] [Comment Edited] (FLINK-19247) Update Chinese documentation after removal of Kafka 0.10 and 0.11

[ https://issues.apache.org/jira/browse/FLINK-19247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239271#comment-17239271 ] Andrey Zagrebin edited comment on FLINK-19247 at 11/26/20, 1:29 PM: --

[jira] [Commented] (FLINK-19247) Update Chinese documentation after removal of Kafka 0.10 and 0.11

[ https://issues.apache.org/jira/browse/FLINK-19247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239271#comment-17239271 ] Andrey Zagrebin commented on FLINK-19247: - is this doc update supposed to also t

[jira] [Commented] (FLINK-20118) Test New File Source API - Continuous Streaming Execution

[ https://issues.apache.org/jira/browse/FLINK-20118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238050#comment-17238050 ] Andrey Zagrebin commented on FLINK-20118: -  I opened a PR to extend ITCases for

[jira] [Comment Edited] (FLINK-20290) Duplicated output in FileSource continuous ITCase with TM failover

[ https://issues.apache.org/jira/browse/FLINK-20290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237418#comment-17237418 ] Andrey Zagrebin edited comment on FLINK-20290 at 11/23/20, 2:59 PM: --

[jira] [Commented] (FLINK-20290) Duplicated output in FileSource continuous ITCase with TM failover

[ https://issues.apache.org/jira/browse/FLINK-20290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237418#comment-17237418 ] Andrey Zagrebin commented on FLINK-20290: - I think that the attached log file co

[jira] [Commented] (FLINK-20290) Duplicated output in FileSource continuous ITCase with TM failover

[ https://issues.apache.org/jira/browse/FLINK-20290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237416#comment-17237416 ] Andrey Zagrebin commented on FLINK-20290: - Sorry for confusion, I think I miscon

[jira] [Comment Edited] (FLINK-20290) Duplicated output in FileSource continuous ITCase with TM failover

[ https://issues.apache.org/jira/browse/FLINK-20290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237345#comment-17237345 ] Andrey Zagrebin edited comment on FLINK-20290 at 11/23/20, 1:01 PM: --

[jira] [Commented] (FLINK-20290) Duplicated output in FileSource continuous ITCase with TM failover

[ https://issues.apache.org/jira/browse/FLINK-20290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237345#comment-17237345 ] Andrey Zagrebin commented on FLINK-20290: - [~sewen] The TM and JM failures alway

[jira] [Updated] (FLINK-20290) Duplicated output in FileSource continuous ITCase with TM failover

[ https://issues.apache.org/jira/browse/FLINK-20290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-20290: Attachment: log > Duplicated output in FileSource continuous ITCase with TM failover > ---

[jira] [Comment Edited] (FLINK-20290) Duplicated output in FileSource continuous ITCase with TM failover

[ https://issues.apache.org/jira/browse/FLINK-20290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237248#comment-17237248 ] Andrey Zagrebin edited comment on FLINK-20290 at 11/23/20, 11:39 AM: -

[jira] [Comment Edited] (FLINK-20290) Duplicated output in FileSource continuous ITCase with TM failover

[ https://issues.apache.org/jira/browse/FLINK-20290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237248#comment-17237248 ] Andrey Zagrebin edited comment on FLINK-20290 at 11/23/20, 11:29 AM: -

[jira] [Updated] (FLINK-20225) Break link in the document

[ https://issues.apache.org/jira/browse/FLINK-20225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-20225: Component/s: Deployment / Kubernetes > Break link in the document > --

[jira] [Updated] (FLINK-20225) Break link in the document

[ https://issues.apache.org/jira/browse/FLINK-20225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-20225: Affects Version/s: (was: 1.12.0) 1.11.0 > Break link in the doc

[jira] [Commented] (FLINK-20225) Break link in the document

[ https://issues.apache.org/jira/browse/FLINK-20225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237268#comment-17237268 ] Andrey Zagrebin commented on FLINK-20225: - I think the idea was to refer to [the

[jira] [Commented] (FLINK-20290) Duplicated output in FileSource continuous ITCase with TM failover

[ https://issues.apache.org/jira/browse/FLINK-20290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237248#comment-17237248 ] Andrey Zagrebin commented on FLINK-20290: - FYI, I am not sure about the semantic

[jira] [Updated] (FLINK-20290) Duplicated output in FileSource continuous ITCase with TM failover

[ https://issues.apache.org/jira/browse/FLINK-20290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-20290: Description: If FileSourceTextLinesITCase::testContinuousTextFileSource includes TM restar

[jira] [Created] (FLINK-20290) Duplicated output in FileSource continuous ITCase with TM failover

Andrey Zagrebin created FLINK-20290: --- Summary: Duplicated output in FileSource continuous ITCase with TM failover Key: FLINK-20290 URL: https://issues.apache.org/jira/browse/FLINK-20290 Project: Fli

[jira] [Updated] (FLINK-20261) Uncaught exception in ExecutorNotifier due to split assignment broken by failed task

[ https://issues.apache.org/jira/browse/FLINK-20261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-20261: Description: While trying to extend {{FileSourceTextLinesITCase::testContinuousTextFileSo

[jira] [Commented] (FLINK-20118) Test New File Source API - Continuous Streaming Execution

[ https://issues.apache.org/jira/browse/FLINK-20118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17236154#comment-17236154 ] Andrey Zagrebin commented on FLINK-20118: - I found why TestingMiniCluster::termi

[jira] [Updated] (FLINK-20261) Uncaught exception in ExecutorNotifier due to split assignment broken by failed task

[ https://issues.apache.org/jira/browse/FLINK-20261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-20261: Description: While trying to extend FileSourceTextLinesITCase::testContinuousTextFileSourc

[jira] [Updated] (FLINK-20261) Uncaught exception in ExecutorNotifier due to split assignment broken by failed task

[ https://issues.apache.org/jira/browse/FLINK-20261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-20261: Description: While trying to extend FileSourceTextLinesITCase::testContinuousTextFileSourc

[jira] [Updated] (FLINK-20261) Uncaught exception in ExecutorNotifier due to split assignment broken by failed task

[ https://issues.apache.org/jira/browse/FLINK-20261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-20261: Description: While trying to extend FileSourceTextLinesITCase::testContinuousTextFileSourc

[jira] [Updated] (FLINK-20261) Uncaught exception in ExecutorNotifier due to split assignment broken by failed task

[ https://issues.apache.org/jira/browse/FLINK-20261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-20261: Description: While trying to extend FileSourceTextLinesITCase::testContinuousTextFileSourc

[jira] [Created] (FLINK-20261) Uncaught exception in ExecutorNotifier due to split assignment broken by failed task

Andrey Zagrebin created FLINK-20261: --- Summary: Uncaught exception in ExecutorNotifier due to split assignment broken by failed task Key: FLINK-20261 URL: https://issues.apache.org/jira/browse/FLINK-20261

[jira] [Comment Edited] (FLINK-20118) Test New File Source API - Continuous Streaming Execution

[ https://issues.apache.org/jira/browse/FLINK-20118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235406#comment-17235406 ] Andrey Zagrebin edited comment on FLINK-20118 at 11/20/20, 9:06 AM: --

[jira] [Comment Edited] (FLINK-20118) Test New File Source API - Continuous Streaming Execution

[ https://issues.apache.org/jira/browse/FLINK-20118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235406#comment-17235406 ] Andrey Zagrebin edited comment on FLINK-20118 at 11/20/20, 8:34 AM: --

[jira] [Comment Edited] (FLINK-20118) Test New File Source API - Continuous Streaming Execution

[ https://issues.apache.org/jira/browse/FLINK-20118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235406#comment-17235406 ] Andrey Zagrebin edited comment on FLINK-20118 at 11/20/20, 7:20 AM: --

[jira] [Comment Edited] (FLINK-20118) Test New File Source API - Continuous Streaming Execution

[ https://issues.apache.org/jira/browse/FLINK-20118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235406#comment-17235406 ] Andrey Zagrebin edited comment on FLINK-20118 at 11/20/20, 7:15 AM: --

[jira] [Comment Edited] (FLINK-20118) Test New File Source API - Continuous Streaming Execution

[ https://issues.apache.org/jira/browse/FLINK-20118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235406#comment-17235406 ] Andrey Zagrebin edited comment on FLINK-20118 at 11/19/20, 12:24 PM: -

[jira] [Commented] (FLINK-20118) Test New File Source API - Continuous Streaming Execution

[ https://issues.apache.org/jira/browse/FLINK-20118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235406#comment-17235406 ] Andrey Zagrebin commented on FLINK-20118: - True, I looked into how TM failures c

[jira] [Commented] (FLINK-20196) flink-connector-files needs explicit flink-connector-base dependency to run

[ https://issues.apache.org/jira/browse/FLINK-20196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234497#comment-17234497 ] Andrey Zagrebin commented on FLINK-20196: - I also encountered this issue while w

[jira] [Closed] (FLINK-20171) Improve error message for Flink process memory configuration

[ https://issues.apache.org/jira/browse/FLINK-20171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-20171. --- Resolution: Done merged into master by 2ad92169a4a4ffc92d32783f8777a132e1dac7c4 merged into

[jira] [Issue Comment Deleted] (FLINK-19161) Port File Sources to FLIP-27 API

[ https://issues.apache.org/jira/browse/FLINK-19161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-19161: Comment: was deleted (was: Is there a plan to also add some dedicated chapter(s) to the us

[jira] [Updated] (FLINK-20188) Add Documentation for new File Source

[ https://issues.apache.org/jira/browse/FLINK-20188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-20188: Component/s: Connectors / FileSystem > Add Documentation for new File Source > ---

[jira] [Comment Edited] (FLINK-19461) yarn-sesson.sh -jm -tm arguments have no effect

[ https://issues.apache.org/jira/browse/FLINK-19461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232790#comment-17232790 ] Andrey Zagrebin edited comment on FLINK-19461 at 11/16/20, 2:25 PM: --

[jira] [Commented] (FLINK-19461) yarn-sesson.sh -jm -tm arguments have no effect

[ https://issues.apache.org/jira/browse/FLINK-19461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232793#comment-17232793 ] Andrey Zagrebin commented on FLINK-19461: - [~kkl0u] let's see whether [~rmetzger

[jira] [Commented] (FLINK-19461) yarn-sesson.sh -jm -tm arguments have no effect

[ https://issues.apache.org/jira/browse/FLINK-19461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232790#comment-17232790 ] Andrey Zagrebin commented on FLINK-19461: - [~trohrmann] > [~azagrebin] can we i

[jira] [Updated] (FLINK-20171) Improve error message for Flink process memory configuration

[ https://issues.apache.org/jira/browse/FLINK-20171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-20171: Description: Originates from discussion in FLINK-19461. Currently, all configuration fail

[jira] [Created] (FLINK-20171) Improve error message for Flink process memory configuration

Andrey Zagrebin created FLINK-20171: --- Summary: Improve error message for Flink process memory configuration Key: FLINK-20171 URL: https://issues.apache.org/jira/browse/FLINK-20171 Project: Flink

[jira] [Commented] (FLINK-20118) Test New File Source API - Continuous Streaming Execution

[ https://issues.apache.org/jira/browse/FLINK-20118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232648#comment-17232648 ] Andrey Zagrebin commented on FLINK-20118: - I suggest to write an e2e test which

[jira] [Commented] (FLINK-19161) Port File Sources to FLIP-27 API

[ https://issues.apache.org/jira/browse/FLINK-19161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232640#comment-17232640 ] Andrey Zagrebin commented on FLINK-19161: - Is there a plan to also add some dedi

[jira] [Assigned] (FLINK-20118) Test New File Source API - Continuous Streaming Execution

[ https://issues.apache.org/jira/browse/FLINK-20118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-20118: --- Assignee: Andrey Zagrebin > Test New File Source API - Continuous Streaming Executi

[jira] [Comment Edited] (FLINK-19852) Managed memory released check can block IterativeTask

[ https://issues.apache.org/jira/browse/FLINK-19852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231231#comment-17231231 ] Andrey Zagrebin edited comment on FLINK-19852 at 11/13/20, 8:01 AM: --

[jira] [Commented] (FLINK-19852) Managed memory released check can block IterativeTask

[ https://issues.apache.org/jira/browse/FLINK-19852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231231#comment-17231231 ] Andrey Zagrebin commented on FLINK-19852: - UnsafeMemory usage has indeed become

[jira] [Closed] (FLINK-19207) TtlListState#IteratorWithCleanup support remove method

[ https://issues.apache.org/jira/browse/FLINK-19207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-19207. --- Resolution: Won't Fix Yes, I am closing it > TtlListState#IteratorWithCleanup support remov

[jira] [Assigned] (FLINK-20078) Factor out an ExecutionGraph factory method for DefaultExecutionTopology

[ https://issues.apache.org/jira/browse/FLINK-20078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-20078: --- Assignee: Andrey Zagrebin > Factor out an ExecutionGraph factory method for Default

[jira] [Created] (FLINK-20078) Factor out an ExecutionGraph factory method for DefaultExecutionTopology

Andrey Zagrebin created FLINK-20078: --- Summary: Factor out an ExecutionGraph factory method for DefaultExecutionTopology Key: FLINK-20078 URL: https://issues.apache.org/jira/browse/FLINK-20078 Projec

[jira] [Comment Edited] (FLINK-11900) Flink on Kubernetes sensitive about arguments placement

[ https://issues.apache.org/jira/browse/FLINK-11900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227427#comment-17227427 ] Andrey Zagrebin edited comment on FLINK-11900 at 11/6/20, 2:19 PM: ---

[jira] [Comment Edited] (FLINK-11900) Flink on Kubernetes sensitive about arguments placement

[ https://issues.apache.org/jira/browse/FLINK-11900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227427#comment-17227427 ] Andrey Zagrebin edited comment on FLINK-11900 at 11/6/20, 2:19 PM: ---

[jira] [Comment Edited] (FLINK-11900) Flink on Kubernetes sensitive about arguments placement

[ https://issues.apache.org/jira/browse/FLINK-11900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227427#comment-17227427 ] Andrey Zagrebin edited comment on FLINK-11900 at 11/6/20, 2:19 PM: ---

[jira] [Closed] (FLINK-11900) Flink on Kubernetes sensitive about arguments placement

[ https://issues.apache.org/jira/browse/FLINK-11900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-11900. --- Resolution: Abandoned This does not look like a problem in the current Flink version. If I c

[jira] [Closed] (FLINK-6911) StatsD Metrics name should escape spaces

[ https://issues.apache.org/jira/browse/FLINK-6911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-6911. -- Resolution: Duplicate This issue looks to be abandoned and subsumed by FLINK-7009. Please, reo

[jira] [Comment Edited] (FLINK-10240) Pluggable scheduling strategy for batch jobs

[ https://issues.apache.org/jira/browse/FLINK-10240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227397#comment-17227397 ] Andrey Zagrebin edited comment on FLINK-10240 at 11/6/20, 1:17 PM: ---

[jira] [Comment Edited] (FLINK-10240) Pluggable scheduling strategy for batch jobs

[ https://issues.apache.org/jira/browse/FLINK-10240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227397#comment-17227397 ] Andrey Zagrebin edited comment on FLINK-10240 at 11/6/20, 1:16 PM: ---

[jira] [Assigned] (FLINK-7981) Bump commons-lang3 version to 3.6

[ https://issues.apache.org/jira/browse/FLINK-7981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-7981: -- Assignee: (was: Hai Zhou) > Bump commons-lang3 version to 3.6 > --

[jira] [Commented] (FLINK-10240) Pluggable scheduling strategy for batch jobs

[ https://issues.apache.org/jira/browse/FLINK-10240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227397#comment-17227397 ] Andrey Zagrebin commented on FLINK-10240: - [~zhuzh] do we still want to keep thi

[jira] [Closed] (FLINK-7981) Bump commons-lang3 version to 3.6

[ https://issues.apache.org/jira/browse/FLINK-7981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-7981. -- Resolution: Abandoned I am closing this issue as abandoned at the moment. Please, reopen it if

[jira] [Closed] (FLINK-9030) JobManager fails to archive job to FS when TM is lost

[ https://issues.apache.org/jira/browse/FLINK-9030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-9030. -- Resolution: Abandoned This does not look problematic in the latest Flink 1.11 release. I am cl

[jira] [Closed] (FLINK-9960) JobManager can't failover to hdfs with multiple namenodes

[ https://issues.apache.org/jira/browse/FLINK-9960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-9960. -- Resolution: Duplicate duplicates FLINK-10130 > JobManager can't failover to hdfs with multiple

[jira] [Closed] (FLINK-9840) Remove Scala dependency from Flink's Mesos integration

[ https://issues.apache.org/jira/browse/FLINK-9840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-9840. -- Resolution: Abandoned This does not seem to happen any time soon. Closing related tickets as a

[jira] [Closed] (FLINK-7091) Rework ReconciliationCoordinator to not depend on Akka

[ https://issues.apache.org/jira/browse/FLINK-7091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-7091. -- Resolution: Abandoned This does not seem to happen any time soon. Closing related tickets as a

[jira] [Closed] (FLINK-7090) Rework ConnectionMonitor to not depend on Akka

[ https://issues.apache.org/jira/browse/FLINK-7090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-7090. -- Resolution: Abandoned This does not seem to happen any time soon. Closing related tickets as a

[jira] [Assigned] (FLINK-8541) Mesos RM should recover from failover timeout

[ https://issues.apache.org/jira/browse/FLINK-8541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-8541: -- Assignee: (was: Eron Wright) > Mesos RM should recover from failover timeout > ---

[jira] [Closed] (FLINK-12150) Flink on mesos failed to created TaskManager while cache directory is gone

[ https://issues.apache.org/jira/browse/FLINK-12150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-12150. --- Resolution: Abandoned It seems there is not enough data provided to analyse the issue and th

[jira] [Commented] (FLINK-8641) Move BootstrapTools#getTaskManagerShellCommand to flink-yarn

[ https://issues.apache.org/jira/browse/FLINK-8641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227334#comment-17227334 ] Andrey Zagrebin commented on FLINK-8641: [~chesnay] do you plan to work on this?

[jira] [Commented] (FLINK-9611) Allow for user-defined artifacts to be specified as part of a mesos overlay

[ https://issues.apache.org/jira/browse/FLINK-9611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227305#comment-17227305 ] Andrey Zagrebin commented on FLINK-9611: I am closing the issue for inactivity. [

[jira] [Closed] (FLINK-9611) Allow for user-defined artifacts to be specified as part of a mesos overlay

[ https://issues.apache.org/jira/browse/FLINK-9611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-9611. -- Resolution: Abandoned > Allow for user-defined artifacts to be specified as part of a mesos ove

[jira] [Assigned] (FLINK-8991) End-to-end test: Ganglia metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-8991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-8991: -- Assignee: (was: Tuo Wang) > End-to-end test: Ganglia metrics reporter > --

[jira] [Commented] (FLINK-8991) End-to-end test: Ganglia metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-8991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227294#comment-17227294 ] Andrey Zagrebin commented on FLINK-8991: [~Tuo Wang] are you working on this? I w

[jira] [Comment Edited] (FLINK-19994) All vertices in an DataSet iteration job will be eagerly scheduled

[ https://issues.apache.org/jira/browse/FLINK-19994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17226698#comment-17226698 ] Andrey Zagrebin edited comment on FLINK-19994 at 11/5/20, 2:07 PM: ---

[jira] [Comment Edited] (FLINK-19994) All vertices in an DataSet iteration job will be eagerly scheduled

[ https://issues.apache.org/jira/browse/FLINK-19994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17226698#comment-17226698 ] Andrey Zagrebin edited comment on FLINK-19994 at 11/5/20, 12:49 PM: --

[jira] [Commented] (FLINK-19994) All vertices in an DataSet iteration job will be eagerly scheduled

[ https://issues.apache.org/jira/browse/FLINK-19994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17226698#comment-17226698 ] Andrey Zagrebin commented on FLINK-19994: - This makes sense to me. We already ha

[jira] [Updated] (FLINK-16614) FLIP-116 Unified Memory Configuration for Job Manager

[ https://issues.apache.org/jira/browse/FLINK-16614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-16614: Release Note: see comment: https://issues.apache.org/jira/browse/FLINK-16614?focusedCommen

[jira] [Updated] (FLINK-16614) FLIP-116 Unified Memory Configuration for Job Manager

[ https://issues.apache.org/jira/browse/FLINK-16614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-16614: Release Note: see comment: https://ci.apache.org/projects/flink/flink-docs-stable/release-

[jira] [Closed] (FLINK-16614) FLIP-116 Unified Memory Configuration for Job Manager

[ https://issues.apache.org/jira/browse/FLINK-16614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-16614. --- Release Note: see comment Resolution: Fixed > FLIP-116 Unified Memory Configuration fo

[jira] [Updated] (FLINK-16614) FLIP-116 Unified Memory Configuration for Job Manager

[ https://issues.apache.org/jira/browse/FLINK-16614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-16614: Fix Version/s: (was: 1.12.0) 1.11.0 > FLIP-116 Unified Memory Confi

[jira] [Closed] (FLINK-19885) Extend the JobManager's web UI in accordance to FLIP-104

[ https://issues.apache.org/jira/browse/FLINK-19885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-19885. --- Fix Version/s: 1.12.0 Resolution: Done merged into master by 869f0bc28d9ab3b29f93fb97

[jira] [Closed] (FLINK-19897) Improve UI related to FLIP-102

[ https://issues.apache.org/jira/browse/FLINK-19897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-19897. --- Resolution: Done merged into master by 086247845334725e9411feb317aab1e94ab824a4 > Improve U

[jira] [Closed] (FLINK-19927) ExecutionStateUpdateListener is only updated when legacy scheduling is enabled

[ https://issues.apache.org/jira/browse/FLINK-19927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-19927. --- Resolution: Fixed merged into master by 375c96c0c1e3ef3555b756c90d58c17c6a2e47e5 > Executio

[jira] [Commented] (FLINK-19927) ExecutionStateUpdateListener is only updated when legacy scheduling is enabled

[ https://issues.apache.org/jira/browse/FLINK-19927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225375#comment-17225375 ] Andrey Zagrebin commented on FLINK-19927: - After offline discussion with [~chesn

[jira] [Created] (FLINK-19954) Move execution deployment tracking logic from legacy EG code to SchedulerNG

Andrey Zagrebin created FLINK-19954: --- Summary: Move execution deployment tracking logic from legacy EG code to SchedulerNG Key: FLINK-19954 URL: https://issues.apache.org/jira/browse/FLINK-19954 Pro

[jira] [Closed] (FLINK-19853) BulkSlotProviderImplTest.testFailedBulkSlotAllocationReleasesAllocatedSlot failed in azure

[ https://issues.apache.org/jira/browse/FLINK-19853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-19853. --- Resolution: Resolved The test has been removed with the dead code it was testing in -FLINK-1

[jira] [Closed] (FLINK-19923) Remove unused BulkSlotProvider, its implementation and tests

[ https://issues.apache.org/jira/browse/FLINK-19923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-19923. --- Resolution: Done merged into master by 86b3c710b0b404255003434211aa679bfb078375 > Remove un

[jira] [Commented] (FLINK-19927) ExecutionStateUpdateListener is only updated when legacy scheduling is enabled

[ https://issues.apache.org/jira/browse/FLINK-19927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225290#comment-17225290 ] Andrey Zagrebin commented on FLINK-19927: - True, the recent state handling logic

[jira] [Comment Edited] (FLINK-19927) ExecutionStateUpdateListener is only updated when legacy scheduling is enabled

[ https://issues.apache.org/jira/browse/FLINK-19927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224687#comment-17224687 ] Andrey Zagrebin edited comment on FLINK-19927 at 11/2/20, 2:34 PM: ---

[jira] [Commented] (FLINK-19927) ExecutionStateUpdateListener is only updated when legacy scheduling is enabled

[ https://issues.apache.org/jira/browse/FLINK-19927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224687#comment-17224687 ] Andrey Zagrebin commented on FLINK-19927: - It seems we need unit tests for how E

[jira] [Comment Edited] (FLINK-19853) BulkSlotProviderImplTest.testFailedBulkSlotAllocationReleasesAllocatedSlot failed in azure

[ https://issues.apache.org/jira/browse/FLINK-19853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224544#comment-17224544 ] Andrey Zagrebin edited comment on FLINK-19853 at 11/2/20, 10:03 AM: --

[jira] [Comment Edited] (FLINK-19853) BulkSlotProviderImplTest.testFailedBulkSlotAllocationReleasesAllocatedSlot failed in azure

[ https://issues.apache.org/jira/browse/FLINK-19853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224544#comment-17224544 ] Andrey Zagrebin edited comment on FLINK-19853 at 11/2/20, 10:04 AM: --

[jira] [Updated] (FLINK-19923) Remove unused BulkSlotProvider, its implementation and tests

[ https://issues.apache.org/jira/browse/FLINK-19923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-19923: Description: BulkSlotProvider is not used any more because it was introduced for the remov

[jira] [Updated] (FLINK-19923) Remove unused BulkSlotProvider, its implementation and tests

[ https://issues.apache.org/jira/browse/FLINK-19923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-19923: Summary: Remove unused BulkSlotProvider, its implementation and tests (was: Remove BulkSl

  1   2   3   4   5   6   7   8   9   10   >