[jira] [Updated] (FLINK-22613) FlinkKinesisITCase.testStopWithSavepoint fails

[ https://issues.apache.org/jira/browse/FLINK-22613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22613: --- Priority: Critical (was: Major) > FlinkKinesisITCase.testStopWithSavepoint fails >

[jira] [Updated] (FLINK-22464) OperatorEventSendingCheckpointITCase.testOperatorEventLostWithReaderFailure hangs with `AdaptiveScheduler`

[ https://issues.apache.org/jira/browse/FLINK-22464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22464: --- Priority: Critical (was: Major) > OperatorEventSendingCheckpointITCase.testOperatorEventLos

[jira] [Commented] (FLINK-22613) FlinkKinesisITCase.testStopWithSavepoint fails

[ https://issues.apache.org/jira/browse/FLINK-22613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17341918#comment-17341918 ] Robert Metzger commented on FLINK-22613: https://dev.azure.com/rmetzger/Flink/_b

[jira] [Comment Edited] (FLINK-22067) SavepointWindowReaderITCase.testApplyEvictorWindowStateReader

[ https://issues.apache.org/jira/browse/FLINK-22067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17341902#comment-17341902 ] Robert Metzger edited comment on FLINK-22067 at 5/10/21, 1:11 PM:

[jira] [Commented] (FLINK-22067) SavepointWindowReaderITCase.testApplyEvictorWindowStateReader

[ https://issues.apache.org/jira/browse/FLINK-22067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17341902#comment-17341902 ] Robert Metzger commented on FLINK-22067: Thanks for looking into the failure. I

[jira] [Commented] (FLINK-22614) Provide build artifacts for YARN e2e tests

[ https://issues.apache.org/jira/browse/FLINK-22614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17341848#comment-17341848 ] Robert Metzger commented on FLINK-22614: Yes, this change makes sense. There's n

[jira] [Commented] (FLINK-19916) Hadoop3 ShutdownHookManager visit closed ClassLoader

[ https://issues.apache.org/jira/browse/FLINK-19916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17341784#comment-17341784 ] Robert Metzger commented on FLINK-19916: Manually running the shutdown hooks sou

[jira] [Commented] (FLINK-22566) Running Kerberized YARN application on Docker test (default input) fails with no resources

[ https://issues.apache.org/jira/browse/FLINK-22566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17340852#comment-17340852 ] Robert Metzger commented on FLINK-22566: Okay, that's a good proposal! Looking f

[jira] [Created] (FLINK-22593) SavepointITCase.testShouldAddEntropyToSavepointPath unstable

Robert Metzger created FLINK-22593: -- Summary: SavepointITCase.testShouldAddEntropyToSavepointPath unstable Key: FLINK-22593 URL: https://issues.apache.org/jira/browse/FLINK-22593 Project: Flink

[jira] [Updated] (FLINK-20432) SQLClientSchemaRegistryITCase hangs

[ https://issues.apache.org/jira/browse/FLINK-20432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-20432: --- Priority: Critical (was: Major) > SQLClientSchemaRegistryITCase hangs > ---

[jira] [Commented] (FLINK-22067) SavepointWindowReaderITCase.testApplyEvictorWindowStateReader

[ https://issues.apache.org/jira/browse/FLINK-22067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17340735#comment-17340735 ] Robert Metzger commented on FLINK-22067: testReduceWindowStateReader https://de

[jira] [Updated] (FLINK-22067) SavepointWindowReaderITCase.testApplyEvictorWindowStateReader

[ https://issues.apache.org/jira/browse/FLINK-22067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22067: --- Affects Version/s: 1.14.0 > SavepointWindowReaderITCase.testApplyEvictorWindowStateReader >

[jira] [Updated] (FLINK-22067) SavepointWindowReaderITCase.testApplyEvictorWindowStateReader

[ https://issues.apache.org/jira/browse/FLINK-22067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22067: --- Priority: Blocker (was: Critical) > SavepointWindowReaderITCase.testApplyEvictorWindowState

[jira] [Commented] (FLINK-22067) SavepointWindowReaderITCase.testApplyEvictorWindowStateReader

[ https://issues.apache.org/jira/browse/FLINK-22067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17340734#comment-17340734 ] Robert Metzger commented on FLINK-22067: Same issue in {{SavepointWindowReaderIT

[jira] [Commented] (FLINK-22067) SavepointWindowReaderITCase.testApplyEvictorWindowStateReader

[ https://issues.apache.org/jira/browse/FLINK-22067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17340726#comment-17340726 ] Robert Metzger commented on FLINK-22067: [~akalashnikov] I saw that you've recen

[jira] [Commented] (FLINK-22067) SavepointWindowReaderITCase.testApplyEvictorWindowStateReader

[ https://issues.apache.org/jira/browse/FLINK-22067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17340724#comment-17340724 ] Robert Metzger commented on FLINK-22067: I attached "isolated_logs_builD_9072.lo

[jira] [Updated] (FLINK-22067) SavepointWindowReaderITCase.testApplyEvictorWindowStateReader

[ https://issues.apache.org/jira/browse/FLINK-22067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22067: --- Attachment: isolated_logs_builD_9072.log > SavepointWindowReaderITCase.testApplyEvictorWindo

[jira] [Commented] (FLINK-22067) SavepointWindowReaderITCase.testApplyEvictorWindowStateReader

[ https://issues.apache.org/jira/browse/FLINK-22067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17340718#comment-17340718 ] Robert Metzger commented on FLINK-22067: Fails on my personal CI (this is just m

[jira] [Updated] (FLINK-22067) SavepointWindowReaderITCase.testApplyEvictorWindowStateReader

[ https://issues.apache.org/jira/browse/FLINK-22067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22067: --- Priority: Critical (was: Major) > SavepointWindowReaderITCase.testApplyEvictorWindowStateRe

[jira] [Commented] (FLINK-22559) UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue fails with output mismatch

[ https://issues.apache.org/jira/browse/FLINK-22559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17340705#comment-17340705 ] Robert Metzger commented on FLINK-22559: [~fsk119] can you take a look at the te

[jira] [Commented] (FLINK-22559) UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue fails with output mismatch

[ https://issues.apache.org/jira/browse/FLINK-22559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17340704#comment-17340704 ] Robert Metzger commented on FLINK-22559: https://github.com/apache/flink/commit/

[jira] [Commented] (FLINK-22566) Running Kerberized YARN application on Docker test (default input) fails with no resources

[ https://issues.apache.org/jira/browse/FLINK-22566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17340703#comment-17340703 ] Robert Metzger commented on FLINK-22566: Thanks for your investigations. Which

[jira] [Commented] (FLINK-22559) UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue fails with output mismatch

[ https://issues.apache.org/jira/browse/FLINK-22559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17340668#comment-17340668 ] Robert Metzger commented on FLINK-22559: I'll disable this test now on master.

[jira] [Commented] (FLINK-22406) Unstable test ReactiveModeITCase.testScaleDownOnTaskManagerLoss()

[ https://issues.apache.org/jira/browse/FLINK-22406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17340608#comment-17340608 ] Robert Metzger commented on FLINK-22406: https://dev.azure.com/apache-flink/apac

[jira] [Commented] (FLINK-10407) FLIP-159: Reactive mode

[ https://issues.apache.org/jira/browse/FLINK-10407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17340590#comment-17340590 ] Robert Metzger commented on FLINK-10407: Hi Xie Fan, The link called FLIP-159 is

[jira] [Assigned] (FLINK-22266) Harden JobMasterStopWithSavepointITCase

[ https://issues.apache.org/jira/browse/FLINK-22266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-22266: -- Assignee: Robert Metzger (was: Dawid Wysakowicz) > Harden JobMasterStopWithSavepoint

[jira] [Assigned] (FLINK-22574) Adaptive Scheduler: Can not cancel restarting job

[ https://issues.apache.org/jira/browse/FLINK-22574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-22574: -- Assignee: Robert Metzger > Adaptive Scheduler: Can not cancel restarting job > --

[jira] [Commented] (FLINK-22413) Hide Checkpointing page in the UI for batch jobs

[ https://issues.apache.org/jira/browse/FLINK-22413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17340168#comment-17340168 ] Robert Metzger commented on FLINK-22413: Thanks a lot for working on the ticket.

[jira] [Assigned] (FLINK-22413) Hide Checkpointing page in the UI for batch jobs

[ https://issues.apache.org/jira/browse/FLINK-22413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-22413: -- Assignee: Nicholas Jiang > Hide Checkpointing page in the UI for batch jobs > ---

[jira] [Commented] (FLINK-22266) Harden JobMasterStopWithSavepointITCase

[ https://issues.apache.org/jira/browse/FLINK-22266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17340111#comment-17340111 ] Robert Metzger commented on FLINK-22266: Thanks a lot for looking into the probl

[jira] [Commented] (FLINK-21439) Adaptive Scheduler: Add support for exception history

[ https://issues.apache.org/jira/browse/FLINK-21439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17339813#comment-17339813 ] Robert Metzger commented on FLINK-21439: What's the status of this effort? > Ad

[jira] [Updated] (FLINK-22574) Adaptive Scheduler: Can not cancel restarting job

[ https://issues.apache.org/jira/browse/FLINK-22574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22574: --- Description: I have a job in state RESTARTING. When I now issue a cancel RPC call, I get the

[jira] [Updated] (FLINK-21439) Adaptive Scheduler: Add support for exception history

[ https://issues.apache.org/jira/browse/FLINK-21439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21439: --- Summary: Adaptive Scheduler: Add support for exception history (was: Add support for except

[jira] [Created] (FLINK-22574) Adaptive Scheduler: Can not cancel restarting job

Robert Metzger created FLINK-22574: -- Summary: Adaptive Scheduler: Can not cancel restarting job Key: FLINK-22574 URL: https://issues.apache.org/jira/browse/FLINK-22574 Project: Flink Issue T

[jira] [Commented] (FLINK-22555) LGPL-2.1 files in flink-python jars

[ https://issues.apache.org/jira/browse/FLINK-22555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17338771#comment-17338771 ] Robert Metzger commented on FLINK-22555: I will look into extending the license

[jira] [Created] (FLINK-22556) Extend license checker to scan for traces of (L)GPL licensed code

Robert Metzger created FLINK-22556: -- Summary: Extend license checker to scan for traces of (L)GPL licensed code Key: FLINK-22556 URL: https://issues.apache.org/jira/browse/FLINK-22556 Project: Flink

[jira] [Commented] (FLINK-19481) Add support for a flink native GCS FileSystem

[ https://issues.apache.org/jira/browse/FLINK-19481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17338198#comment-17338198 ] Robert Metzger commented on FLINK-19481: Hi Ben, thanks a lot for getting back o

[jira] [Commented] (FLINK-19916) Hadoop3 ShutdownHookManager visit closed ClassLoader

[ https://issues.apache.org/jira/browse/FLINK-19916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17337377#comment-17337377 ] Robert Metzger commented on FLINK-19916: I've reset the priority to Major since

[jira] [Updated] (FLINK-19916) Hadoop3 ShutdownHookManager visit closed ClassLoader

[ https://issues.apache.org/jira/browse/FLINK-19916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19916: --- Affects Version/s: 1.12.2 > Hadoop3 ShutdownHookManager visit closed ClassLoader > -

[jira] [Closed] (FLINK-21914) Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-21914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-21914. -- Resolution: Duplicate > Trying to access closed classloader >

[jira] [Updated] (FLINK-19916) Hadoop3 ShutdownHookManager visit closed ClassLoader

[ https://issues.apache.org/jira/browse/FLINK-19916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19916: --- Priority: Major (was: Minor) > Hadoop3 ShutdownHookManager visit closed ClassLoader > -

[jira] [Commented] (FLINK-21914) Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-21914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17337376#comment-17337376 ] Robert Metzger commented on FLINK-21914: I would like to close this ticket and t

[jira] [Commented] (FLINK-21914) Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-21914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17337375#comment-17337375 ] Robert Metzger commented on FLINK-21914: Just deploying on YARN doesn't cause th

[jira] [Updated] (FLINK-21914) Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-21914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21914: --- Component/s: Deployment / YARN > Trying to access closed classloader > -

[jira] [Updated] (FLINK-21914) Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-21914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21914: --- Component/s: (was: Deployment / YARN) Connectors / Hive > Trying to acc

[jira] [Commented] (FLINK-21914) Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-21914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17337371#comment-17337371 ] Robert Metzger commented on FLINK-21914: This is a known issue, reported here FL

[jira] [Updated] (FLINK-21914) Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-21914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21914: --- Component/s: (was: API / Core) Deployment / YARN > Trying to access clo

[jira] [Commented] (FLINK-22509) ./bin/flink run -m yarn-cluster -d submission leads to IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-22509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17337368#comment-17337368 ] Robert Metzger commented on FLINK-22509: Closing as a duplicate of FLINK-19916.

[jira] [Closed] (FLINK-22509) ./bin/flink run -m yarn-cluster -d submission leads to IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-22509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-22509. -- Resolution: Duplicate > ./bin/flink run -m yarn-cluster -d submission leads to IllegalStateExc

[jira] [Commented] (FLINK-19916) Hadoop3 ShutdownHookManager visit closed ClassLoader

[ https://issues.apache.org/jira/browse/FLINK-19916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17337367#comment-17337367 ] Robert Metzger commented on FLINK-19916: Where did you see this exception? I fo

[jira] [Assigned] (FLINK-22509) ./bin/flink run -m yarn-cluster -d submission leads to IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-22509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-22509: -- Assignee: Robert Metzger > ./bin/flink run -m yarn-cluster -d submission leads to Ill

[jira] [Comment Edited] (FLINK-22509) ./bin/flink run -m yarn-cluster -d submission leads to IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-22509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17335750#comment-17335750 ] Robert Metzger edited comment on FLINK-22509 at 4/29/21, 6:37 PM:

[jira] [Closed] (FLINK-22493) AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond found unexpected files

[ https://issues.apache.org/jira/browse/FLINK-22493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-22493. -- Fix Version/s: 1.13.1 1.14.0 Resolution: Fixed master https://githu

[jira] [Commented] (FLINK-22509) ./bin/flink run -m yarn-cluster -d submission leads to IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-22509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17335750#comment-17335750 ] Robert Metzger commented on FLINK-22509: This ticket basically came to the same

[jira] [Assigned] (FLINK-19379) Submitting job to running YARN session fails

[ https://issues.apache.org/jira/browse/FLINK-19379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-19379: -- Assignee: Robert Metzger > Submitting job to running YARN session fails > ---

[jira] [Closed] (FLINK-22495) Document how to use the reactive mode on K8s

[ https://issues.apache.org/jira/browse/FLINK-22495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-22495. -- Fix Version/s: 1.14.0 Resolution: Fixed > Document how to use the reactive mode on K8s

[jira] [Commented] (FLINK-22495) Document how to use the reactive mode on K8s

[ https://issues.apache.org/jira/browse/FLINK-22495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17335340#comment-17335340 ] Robert Metzger commented on FLINK-22495: Merged to master in https://github.com

[jira] [Commented] (FLINK-22493) AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond found unexpected files

[ https://issues.apache.org/jira/browse/FLINK-22493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17335336#comment-17335336 ] Robert Metzger commented on FLINK-22493: I believe the problem is the following

[jira] [Commented] (FLINK-22493) AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond found unexpected files

[ https://issues.apache.org/jira/browse/FLINK-22493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17335306#comment-17335306 ] Robert Metzger commented on FLINK-22493: I upgraded the priority because we usua

[jira] [Updated] (FLINK-22493) AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond found unexpected files

[ https://issues.apache.org/jira/browse/FLINK-22493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22493: --- Attachment: AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond

[jira] [Updated] (FLINK-22493) AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond found unexpected files

[ https://issues.apache.org/jira/browse/FLINK-22493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22493: --- Priority: Critical (was: Major) > AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstS

[jira] [Commented] (FLINK-22513) Failed to upload compile artifacts

[ https://issues.apache.org/jira/browse/FLINK-22513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17334913#comment-17334913 ] Robert Metzger commented on FLINK-22513: Let's hope this is just some glitch in

[jira] [Updated] (FLINK-22438) add numRecordsOut metric for Async IO

[ https://issues.apache.org/jira/browse/FLINK-22438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22438: --- Fix Version/s: (was: 1.12.3) 1.12.4 > add numRecordsOut metric for As

[jira] [Updated] (FLINK-22479) [Kinesis][Consumer] Potential lock-up under error condition

[ https://issues.apache.org/jira/browse/FLINK-22479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22479: --- Fix Version/s: (was: 1.12.3) 1.12.4 > [Kinesis][Consumer] Potential l

[jira] [Updated] (FLINK-22434) Dispatcher does not store suspended jobs in execution graph store

[ https://issues.apache.org/jira/browse/FLINK-22434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22434: --- Fix Version/s: (was: 1.12.3) 1.12.4 > Dispatcher does not store suspe

[jira] [Commented] (FLINK-22509) ./bin/flink run -m yarn-cluster -d submission leads to IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-22509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17334676#comment-17334676 ] Robert Metzger commented on FLINK-22509: Instead of fixing this issue, we could

[jira] [Created] (FLINK-22509) ./bin/flink run -m yarn-cluster -d submission leads to IllegalStateException

Robert Metzger created FLINK-22509: -- Summary: ./bin/flink run -m yarn-cluster -d submission leads to IllegalStateException Key: FLINK-22509 URL: https://issues.apache.org/jira/browse/FLINK-22509 Proj

[jira] [Commented] (FLINK-22493) AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond found unexpected files

[ https://issues.apache.org/jira/browse/FLINK-22493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17334657#comment-17334657 ] Robert Metzger commented on FLINK-22493: Yes, I'll take a look. > AdaptiveSched

[jira] [Assigned] (FLINK-22493) AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond found unexpected files

[ https://issues.apache.org/jira/browse/FLINK-22493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-22493: -- Assignee: Robert Metzger > AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSa

[jira] [Commented] (FLINK-16504) Add a AWS DynamoDB sink

[ https://issues.apache.org/jira/browse/FLINK-16504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17334642#comment-17334642 ] Robert Metzger commented on FLINK-16504: Sorry, this bot is new, we are still ad

[jira] [Assigned] (FLINK-16504) Add a AWS DynamoDB sink

[ https://issues.apache.org/jira/browse/FLINK-16504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-16504: -- Assignee: Yuri Gusev > Add a AWS DynamoDB sink > --- > >

[jira] [Assigned] (FLINK-22495) Document how to use the reactive mode on K8s

[ https://issues.apache.org/jira/browse/FLINK-22495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-22495: -- Assignee: Robert Metzger > Document how to use the reactive mode on K8s > ---

[jira] [Updated] (FLINK-20950) SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with "AssertionError"

[ https://issues.apache.org/jira/browse/FLINK-20950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-20950: --- Affects Version/s: 1.12.2 > SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test f

[jira] [Commented] (FLINK-22495) Document how to use the reactive mode on K8s

[ https://issues.apache.org/jira/browse/FLINK-22495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17333456#comment-17333456 ] Robert Metzger commented on FLINK-22495: Sure. I'll take care of this tomorrow.

[jira] [Updated] (FLINK-22483) Recover checkpoints when JobMaster gains leadership

[ https://issues.apache.org/jira/browse/FLINK-22483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22483: --- Description: Recovering checkpoints (from the CompletedCheckpointStore) is a potentially lo

[jira] [Created] (FLINK-22483) Recover checkpoints when JobMaster gains leadership

Robert Metzger created FLINK-22483: -- Summary: Recover checkpoints when JobMaster gains leadership Key: FLINK-22483 URL: https://issues.apache.org/jira/browse/FLINK-22483 Project: Flink Issue

[jira] [Created] (FLINK-22413) Hide Checkpointing page in the UI for batch jobs

Robert Metzger created FLINK-22413: -- Summary: Hide Checkpointing page in the UI for batch jobs Key: FLINK-22413 URL: https://issues.apache.org/jira/browse/FLINK-22413 Project: Flink Issue Ty

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328035#comment-17328035 ] Robert Metzger commented on FLINK-17274: This is a helpful observation: Maybe hi

[jira] [Commented] (FLINK-22386) Introduce cache for docker images

[ https://issues.apache.org/jira/browse/FLINK-22386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17327953#comment-17327953 ] Robert Metzger commented on FLINK-22386: +1 We can at least introduce a cache f

[jira] [Commented] (FLINK-20114) Test Kafka Source based on the new Source API 

[ https://issues.apache.org/jira/browse/FLINK-20114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17327934#comment-17327934 ] Robert Metzger commented on FLINK-20114: Thanks a lot for your detailed follow u

[jira] [Updated] (FLINK-21073) Mention that RocksDB ignores equals/hashCode because it works on binary data

[ https://issues.apache.org/jira/browse/FLINK-21073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21073: --- Labels: pull-request-available (was: pull-request-available stale-assigned) > Mention that

[jira] [Commented] (FLINK-21073) Mention that RocksDB ignores equals/hashCode because it works on binary data

[ https://issues.apache.org/jira/browse/FLINK-21073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17324967#comment-17324967 ] Robert Metzger commented on FLINK-21073: [~flink-jira-bot] I made a pass over th

[jira] [Created] (FLINK-22331) CLI Frontend (RestClient) doesn't work on Apple M1

Robert Metzger created FLINK-22331: -- Summary: CLI Frontend (RestClient) doesn't work on Apple M1 Key: FLINK-22331 URL: https://issues.apache.org/jira/browse/FLINK-22331 Project: Flink Issue

[jira] [Closed] (FLINK-22244) Clarify Reactive Mode documentation wrt to timeouts

[ https://issues.apache.org/jira/browse/FLINK-22244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-22244. -- Resolution: Fixed Fixed in https://github.com/apache/flink/commit/3e76dac4ac230f13f8e848d77fe

[jira] [Closed] (FLINK-22158) Test native Kubernetes pod template

[ https://issues.apache.org/jira/browse/FLINK-22158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-22158. -- Resolution: Fixed > Test native Kubernetes pod template > ---

[jira] [Commented] (FLINK-22158) Test native Kubernetes pod template

[ https://issues.apache.org/jira/browse/FLINK-22158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17322454#comment-17322454 ] Robert Metzger commented on FLINK-22158: Thanks a lot for your quick response. Y

[jira] [Comment Edited] (FLINK-22158) Test native Kubernetes pod template

[ https://issues.apache.org/jira/browse/FLINK-22158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320132#comment-17320132 ] Robert Metzger edited comment on FLINK-22158 at 4/13/21, 12:24 PM: ---

[jira] [Comment Edited] (FLINK-22158) Test native Kubernetes pod template

[ https://issues.apache.org/jira/browse/FLINK-22158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320132#comment-17320132 ] Robert Metzger edited comment on FLINK-22158 at 4/13/21, 12:23 PM: ---

[jira] [Commented] (FLINK-22158) Test native Kubernetes pod template

[ https://issues.apache.org/jira/browse/FLINK-22158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320132#comment-17320132 ] Robert Metzger commented on FLINK-22158: I tested the following: - checked the d

[jira] [Created] (FLINK-22258) Adaptive Scheduler: Show history of rescales in the Web UI

Robert Metzger created FLINK-22258: -- Summary: Adaptive Scheduler: Show history of rescales in the Web UI Key: FLINK-22258 URL: https://issues.apache.org/jira/browse/FLINK-22258 Project: Flink

[jira] [Commented] (FLINK-22134) Test the reactive mode

[ https://issues.apache.org/jira/browse/FLINK-22134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319981#comment-17319981 ] Robert Metzger commented on FLINK-22134: Cool, thanks! > Test the reactive mode

[jira] [Updated] (FLINK-17530) Fix illegal reflective access by ClosureCleaner

[ https://issues.apache.org/jira/browse/FLINK-17530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17530: --- Fix Version/s: (was: 1.13.0) > Fix illegal reflective access by ClosureCleaner > ---

[jira] [Assigned] (FLINK-17530) Fix illegal reflective access by ClosureCleaner

[ https://issues.apache.org/jira/browse/FLINK-17530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-17530: -- Assignee: (was: Robert Metzger) > Fix illegal reflective access by ClosureCleaner

[jira] [Assigned] (FLINK-17530) Fix illegal reflective access by ClosureCleaner

[ https://issues.apache.org/jira/browse/FLINK-17530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-17530: -- Assignee: Robert Metzger > Fix illegal reflective access by ClosureCleaner >

[jira] [Commented] (FLINK-21708) CloserCleaner warning

[ https://issues.apache.org/jira/browse/FLINK-21708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319971#comment-17319971 ] Robert Metzger commented on FLINK-21708: I'm closing this ticket as a duplicate

[jira] [Closed] (FLINK-21708) CloserCleaner warning

[ https://issues.apache.org/jira/browse/FLINK-21708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-21708. -- Resolution: Duplicate > CloserCleaner warning > - > > Key:

[jira] [Commented] (FLINK-21708) CloserCleaner warning

[ https://issues.apache.org/jira/browse/FLINK-21708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319970#comment-17319970 ] Robert Metzger commented on FLINK-21708: This is a known issue: FLINK-17524. If

[jira] [Assigned] (FLINK-17530) Fix illegal reflective access by ClosureCleaner

[ https://issues.apache.org/jira/browse/FLINK-17530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-17530: -- Assignee: (was: Robert Metzger) > Fix illegal reflective access by ClosureCleaner

[jira] [Updated] (FLINK-21708) CloserCleaner warning

[ https://issues.apache.org/jira/browse/FLINK-21708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21708: --- Component/s: API / DataStream > CloserCleaner warning > - > >

[jira] [Updated] (FLINK-21671) some condition expressions can be simplified in org.apache.flink.yarn.YarnClusterDescriptor

[ https://issues.apache.org/jira/browse/FLINK-21671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21671: --- Component/s: Deployment / YARN > some condition expressions can be simplified in > org.apac

<    1   2   3   4   5   6   7   8   9   10   >