[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) >

[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=17340705#comment-17340705 ] Robert Metzger commented on FLINK-22559: [~fsk119] can you take a look at the test? >

[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=17340704#comment-17340704 ] Robert Metzger commented on FLINK-22559:

[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=17340703#comment-17340703 ] Robert Metzger commented on FLINK-22566: Thanks for your investigations. Which logs are

[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=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=17340608#comment-17340608 ] Robert Metzger commented on FLINK-22406:

[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=17340590#comment-17340590 ] Robert Metzger commented on FLINK-10407: Hi Xie Fan, The link called FLIP-159 is actually the

[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

[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=17340168#comment-17340168 ] Robert Metzger commented on FLINK-22413: Thanks a lot for working on the ticket. I assigned you

[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=17340111#comment-17340111 ] Robert Metzger commented on FLINK-22266: Thanks a lot for looking into the problem [~trohrmann].

[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=17339813#comment-17339813 ] Robert Metzger commented on FLINK-21439: What's the status of this effort? > Adaptive

[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

[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

[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

[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=17338771#comment-17338771 ] Robert Metzger commented on FLINK-22555: I will look into extending the license checker for

[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=17338198#comment-17338198 ] Robert Metzger commented on FLINK-19481: Hi Ben, thanks a lot for getting back on this ticket.

[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=17337377#comment-17337377 ] Robert Metzger commented on FLINK-19916: I've reset the priority to Major since multiple tickets

[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=17337376#comment-17337376 ] Robert Metzger commented on FLINK-21914: I would like to close this ticket and track the

[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=17337375#comment-17337375 ] Robert Metzger commented on FLINK-21914: Just deploying on YARN doesn't cause the exceptions on

[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

[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=17337371#comment-17337371 ] Robert Metzger commented on FLINK-21914: This is a known issue, reported here FLINK-22509 and

[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

[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=17337368#comment-17337368 ] Robert Metzger commented on FLINK-22509: Closing as a duplicate of FLINK-19916. > ./bin/flink

[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

[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=17337367#comment-17337367 ] Robert Metzger commented on FLINK-19916: Where did you see this exception? I found the same

[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

[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=17335750#comment-17335750 ] Robert Metzger edited comment on FLINK-22509 at 4/29/21, 6:37 PM: -- This

[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

[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=17335750#comment-17335750 ] Robert Metzger commented on FLINK-22509: This ticket basically came to the same conclusion:

[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=17335340#comment-17335340 ] Robert Metzger commented on FLINK-22495: Merged to master in

[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=17335336#comment-17335336 ] Robert Metzger commented on FLINK-22493: I believe the problem is the following here: Once all

[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=17335306#comment-17335306 ] Robert Metzger commented on FLINK-22493: I upgraded the priority because we usually mark test

[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:

[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) >

[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=17334913#comment-17334913 ] Robert Metzger commented on FLINK-22513: Let's hope this is just some glitch in the

[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

[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

[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

[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=17334676#comment-17334676 ] Robert Metzger commented on FLINK-22509: Instead of fixing this issue, we could consider

[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

[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=17334657#comment-17334657 ] Robert Metzger commented on FLINK-22493: Yes, I'll take a look. >

[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 >

[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=17334642#comment-17334642 ] Robert Metzger commented on FLINK-16504: Sorry, this bot is new, we are still adjusting to it ;)

[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

[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=17333456#comment-17333456 ] Robert Metzger commented on FLINK-22495: Sure. I'll take care of this tomorrow. > Document how

[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

[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

[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

[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=17328035#comment-17328035 ] Robert Metzger commented on FLINK-17274: This is a helpful observation: Maybe higher load on the

[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=17327953#comment-17327953 ] Robert Metzger commented on FLINK-22386: +1 We can at least introduce a cache for the builds

[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=17327934#comment-17327934 ] Robert Metzger commented on FLINK-20114: Thanks a lot for your detailed follow up! I won't have

[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=17324967#comment-17324967 ] Robert Metzger commented on FLINK-21073: [~flink-jira-bot] I made a pass over the PR and removed

[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

[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=17322454#comment-17322454 ] Robert Metzger commented on FLINK-22158: Thanks a lot for your quick response. You are right,

[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=17320132#comment-17320132 ] Robert Metzger edited comment on FLINK-22158 at 4/13/21, 12:24 PM: --- I

[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=17320132#comment-17320132 ] Robert Metzger edited comment on FLINK-22158 at 4/13/21, 12:23 PM: --- I

[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=17320132#comment-17320132 ] Robert Metzger commented on FLINK-22158: I tested the following: - checked the docs - used the

[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=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

[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=17319971#comment-17319971 ] Robert Metzger commented on FLINK-21708: I'm closing this ticket as a duplicate > CloserCleaner

[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 > - > >

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

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

[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

[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 >

[jira] [Updated] (FLINK-22117) Not print stack trace for checkpoint trigger failure if not all tasks are started.

[ https://issues.apache.org/jira/browse/FLINK-22117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22117: --- Component/s: Runtime / Checkpointing > Not print stack trace for checkpoint trigger failure

[jira] [Commented] (FLINK-22126) when i set ssl ,the jobmanager got certificate_unknown exception

[ https://issues.apache.org/jira/browse/FLINK-22126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319964#comment-17319964 ] Robert Metzger commented on FLINK-22126: Mh, could this be the same issue?

[jira] [Commented] (FLINK-22175) some mistakes in common.md

[ https://issues.apache.org/jira/browse/FLINK-22175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319961#comment-17319961 ] Robert Metzger commented on FLINK-22175: Thanks a lot, I assigned you! For these small issues,

[jira] [Updated] (FLINK-22126) when i set ssl ,the jobmanager got certificate_unknown exception

[ https://issues.apache.org/jira/browse/FLINK-22126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22126: --- Component/s: Runtime / Coordination > when i set ssl ,the jobmanager got

[jira] [Assigned] (FLINK-22175) some mistakes in common.md

[ https://issues.apache.org/jira/browse/FLINK-22175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-22175: -- Assignee: wym_maozi > some mistakes in common.md > --- > >

[jira] [Commented] (FLINK-22115) JobManager dies with IllegalStateException SharedSlot (physical request SlotRequestId{%}) has been released

[ https://issues.apache.org/jira/browse/FLINK-22115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319960#comment-17319960 ] Robert Metzger commented on FLINK-22115: Thanks a lot for your bug report and the included logs!

[jira] [Updated] (FLINK-21907) Support watermark syntax for Hive DDL dialect

[ https://issues.apache.org/jira/browse/FLINK-21907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21907: --- Component/s: Table SQL / Ecosystem > Support watermark syntax for Hive DDL dialect >

[jira] [Updated] (FLINK-22013) Add Github Actions to flink-ml for every push and pull request

[ https://issues.apache.org/jira/browse/FLINK-22013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22013: --- Component/s: Build System / CI > Add Github Actions to flink-ml for every push and pull

[jira] [Updated] (FLINK-22115) JobManager dies with IllegalStateException SharedSlot (physical request SlotRequestId{%}) has been released

[ https://issues.apache.org/jira/browse/FLINK-22115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22115: --- Component/s: Runtime / Coordination > JobManager dies with IllegalStateException SharedSlot

[jira] [Updated] (FLINK-21448) Test Changelog State backend (Wrapper)

[ https://issues.apache.org/jira/browse/FLINK-21448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21448: --- Component/s: Runtime / State Backends > Test Changelog State backend (Wrapper) >

[jira] [Updated] (FLINK-22012) Add nightly-build pipeline to test flink-ml repo with the latest flink repo snapshot

[ https://issues.apache.org/jira/browse/FLINK-22012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22012: --- Component/s: Build System > Add nightly-build pipeline to test flink-ml repo with the

[jira] [Updated] (FLINK-21921) Unreasonable ADDED event ignoring in callback handler in KubernetesLeaderRetrievalDriver

[ https://issues.apache.org/jira/browse/FLINK-21921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21921: --- Component/s: Deployment / Kubernetes > Unreasonable ADDED event ignoring in callback

[jira] [Updated] (FLINK-21520) ParquetInputFormat#setfilterPredicate() does not work

[ https://issues.apache.org/jira/browse/FLINK-21520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21520: --- Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) >

[jira] [Updated] (FLINK-21468) ParquetTableSource: where clause on integer does not work

[ https://issues.apache.org/jira/browse/FLINK-21468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21468: --- Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) > ParquetTableSource: where

[jira] [Updated] (FLINK-21968) Calcite parser doesn't support to parse "-- test"

[ https://issues.apache.org/jira/browse/FLINK-21968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21968: --- Component/s: Table SQL / Planner > Calcite parser doesn't support to parse "-- test" >

[jira] [Updated] (FLINK-21863) SortPartition should allow chaining of KeySelectors to support different sorting orders for the fields

[ https://issues.apache.org/jira/browse/FLINK-21863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21863: --- Component/s: API / DataSet > SortPartition should allow chaining of KeySelectors to support

[jira] [Updated] (FLINK-21607) Twitter table source connector

[ https://issues.apache.org/jira/browse/FLINK-21607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21607: --- Component/s: Table SQL / Ecosystem > Twitter table source connector >

[jira] [Created] (FLINK-22252) Backquotes are not rendered correctly in config option descriptions

Robert Metzger created FLINK-22252: -- Summary: Backquotes are not rendered correctly in config option descriptions Key: FLINK-22252 URL: https://issues.apache.org/jira/browse/FLINK-22252 Project:

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