[jira] [Assigned] (FLINK-21101) Set up cron job to run CI with declarative scheduler

[ https://issues.apache.org/jira/browse/FLINK-21101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-21101: -- Assignee: Robert Metzger > Set up cron job to run CI with declarative scheduler > ---

[jira] [Commented] (FLINK-21362) Remove State#onEnter

[ https://issues.apache.org/jira/browse/FLINK-21362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17286405#comment-17286405 ] Robert Metzger commented on FLINK-21362: Draft PR: https://github.com/apache/fli

[jira] [Assigned] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-16947: -- Assignee: Robert Metzger > ArtifactResolutionException: Could not transfer artifact.

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17285831#comment-17285831 ] Robert Metzger commented on FLINK-16947: Awesome, thanks a lot for your comment!

[jira] [Assigned] (FLINK-21389) ParquetInputFormat should not need parquet schema as user input

[ https://issues.apache.org/jira/browse/FLINK-21389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-21389: -- Assignee: Etienne Chauchot > ParquetInputFormat should not need parquet schema as use

[jira] [Assigned] (FLINK-21362) Remove State#onEnter

[ https://issues.apache.org/jira/browse/FLINK-21362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-21362: -- Assignee: Robert Metzger (was: Chesnay Schepler) > Remove State#onEnter > --

[jira] [Commented] (FLINK-21390) Rename DeclarativeScheduler to AdaptiveScheduler

[ https://issues.apache.org/jira/browse/FLINK-21390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17285789#comment-17285789 ] Robert Metzger commented on FLINK-21390: [~knaufk] Since we had an offline discu

[jira] [Created] (FLINK-21390) Rename DeclarativeScheduler to AdaptiveScheduler

Robert Metzger created FLINK-21390: -- Summary: Rename DeclarativeScheduler to AdaptiveScheduler Key: FLINK-21390 URL: https://issues.apache.org/jira/browse/FLINK-21390 Project: Flink Issue Ty

[jira] [Updated] (FLINK-21389) ParquetInputFormat should not need parquet schema as user input

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

[jira] [Commented] (FLINK-21388) Parquet DECIMAL logical type is not properly supported in ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-21388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17285774#comment-17285774 ] Robert Metzger commented on FLINK-21388: Assigned. Happy coding! > Parquet DECI

[jira] [Assigned] (FLINK-21388) Parquet DECIMAL logical type is not properly supported in ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-21388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-21388: -- Assignee: Etienne Chauchot > Parquet DECIMAL logical type is not properly supported i

[jira] [Updated] (FLINK-21388) Parquet DECIMAL logical type is not properly supported in ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-21388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21388: --- Component/s: Table SQL / Ecosystem > Parquet DECIMAL logical type is not properly supported

[jira] [Updated] (FLINK-21388) Parquet DECIMAL logical type is not properly supported in ParquetInputFormat

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

[jira] [Updated] (FLINK-21347) Extract interface out of ExecutionGraph for better testability

[ https://issues.apache.org/jira/browse/FLINK-21347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21347: --- Fix Version/s: 1.13.0 > Extract interface out of ExecutionGraph for better testability > ---

[jira] [Updated] (FLINK-21076) Document how to use the declarative scheduler and its limitations

[ https://issues.apache.org/jira/browse/FLINK-21076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21076: --- Component/s: Runtime / Coordination > Document how to use the declarative scheduler and its

[jira] [Closed] (FLINK-21259) Add DeclarativeScheduler / Failing state

[ https://issues.apache.org/jira/browse/FLINK-21259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-21259. -- Resolution: Fixed Impl: https://github.com/apache/flink/commit/2179a237dc78f2292ec86584cb1495

[jira] [Assigned] (FLINK-21347) Extract interface out of ExecutionGraph for better testability

[ https://issues.apache.org/jira/browse/FLINK-21347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-21347: -- Assignee: Robert Metzger > Extract interface out of ExecutionGraph for better testabi

[jira] [Updated] (FLINK-21369) Document Checkpoint Storage

[ https://issues.apache.org/jira/browse/FLINK-21369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21369: --- Component/s: Runtime / Checkpointing > Document Checkpoint Storage > ---

[jira] [Updated] (FLINK-21359) CompatibilityResult issues with Flink 1.9.0

[ https://issues.apache.org/jira/browse/FLINK-21359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21359: --- Component/s: Command Line Client > CompatibilityResult issues with Flink 1.9.0 > ---

[jira] [Updated] (FLINK-21369) Document Checkpoint Storage

[ https://issues.apache.org/jira/browse/FLINK-21369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21369: --- Component/s: Documentation > Document Checkpoint Storage > --- > >

[jira] [Updated] (FLINK-21336) Activate bloom filter in RocksDB State Backend via Flink configuration

[ https://issues.apache.org/jira/browse/FLINK-21336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21336: --- Component/s: Runtime / State Backends > Activate bloom filter in RocksDB State Backend via F

[jira] [Commented] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs

[ https://issues.apache.org/jira/browse/FLINK-21325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17284654#comment-17284654 ] Robert Metzger commented on FLINK-21325: Can you provide the full JobManager log

[jira] [Updated] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs

[ https://issues.apache.org/jira/browse/FLINK-21325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21325: --- Component/s: Deployment / Kubernetes > NoResourceAvailableException while cancel then resubm

[jira] [Updated] (FLINK-21113) Add State access API for KeyedStream RuntimeContext.

[ https://issues.apache.org/jira/browse/FLINK-21113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21113: --- Component/s: API / Python > Add State access API for KeyedStream RuntimeContext. >

[jira] [Updated] (FLINK-21310) unexpected behavior of DataStream union

[ https://issues.apache.org/jira/browse/FLINK-21310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21310: --- Component/s: API / DataStream > unexpected behavior of DataStream union > --

[jira] [Updated] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs

[ https://issues.apache.org/jira/browse/FLINK-21325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21325: --- Component/s: Runtime / Coordination > NoResourceAvailableException while cancel then resubmi

[jira] [Updated] (FLINK-21205) Maybe remove Locality enum

[ https://issues.apache.org/jira/browse/FLINK-21205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21205: --- Component/s: Runtime / Coordination > Maybe remove Locality enum > -

[jira] [Updated] (FLINK-21288) Support redundant task managers for fine grained resource management

[ https://issues.apache.org/jira/browse/FLINK-21288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21288: --- Component/s: Runtime / Coordination > Support redundant task managers for fine grained resou

[jira] [Updated] (FLINK-21294) Support state access API for the map operation of Python ConnectedStreams

[ https://issues.apache.org/jira/browse/FLINK-21294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21294: --- Component/s: API / Python > Support state access API for the map operation of Python Connect

[jira] [Updated] (FLINK-21141) Timeout bug in data stream connect operation when one of the data stream does not have new messages very frequently

[ https://issues.apache.org/jira/browse/FLINK-21141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21141: --- Component/s: API / DataStream > Timeout bug in data stream connect operation when one of the

[jira] [Updated] (FLINK-21190) Expose extended exception history through REST handler and adapt UI accordingly

[ https://issues.apache.org/jira/browse/FLINK-21190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21190: --- Component/s: Runtime / Web Frontend > Expose extended exception history through REST handler

[jira] [Closed] (FLINK-9836) Add template for vote canceling to release guide

[ https://issues.apache.org/jira/browse/FLINK-9836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-9836. - Resolution: Won't Fix > Add template for vote canceling to release guide > --

[jira] [Commented] (FLINK-20696) Yarn Session Blob Directory is not deleted.

[ https://issues.apache.org/jira/browse/FLINK-20696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17283621#comment-17283621 ] Robert Metzger commented on FLINK-20696: Since there is no more activity on this

[jira] [Comment Edited] (FLINK-20367) Show the in-use config of job to users

[ https://issues.apache.org/jira/browse/FLINK-20367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17265925#comment-17265925 ] Robert Metzger edited comment on FLINK-20367 at 2/12/21, 11:06 AM: ---

[jira] [Commented] (FLINK-20367) Show the in-use config of job to users

[ https://issues.apache.org/jira/browse/FLINK-20367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17283620#comment-17283620 ] Robert Metzger commented on FLINK-20367: Since there's no more activity on this

[jira] [Updated] (FLINK-21146) 【SQL】Flink SQL Client not support specify the queue to submit the job

[ https://issues.apache.org/jira/browse/FLINK-21146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21146: --- Component/s: (was: Deployment / YARN) > 【SQL】Flink SQL Client not support specify the qu

[jira] [Assigned] (FLINK-12221) Distinguish long tail task based on IOMetrics

[ https://issues.apache.org/jira/browse/FLINK-12221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-12221: -- Assignee: (was: BoWang) > Distinguish long tail task based on IOMetrics > ---

[jira] [Closed] (FLINK-9747) Release guide ambigous regarding release branches

[ https://issues.apache.org/jira/browse/FLINK-9747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-9747. - Resolution: Won't Fix > Release guide ambigous regarding release branches > -

[jira] [Commented] (FLINK-9747) Release guide ambigous regarding release branches

[ https://issues.apache.org/jira/browse/FLINK-9747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17283602#comment-17283602 ] Robert Metzger commented on FLINK-9747: --- I don't think this is too much of a proble

[jira] [Commented] (FLINK-9796) Add failure handling to release guide

[ https://issues.apache.org/jira/browse/FLINK-9796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17283596#comment-17283596 ] Robert Metzger commented on FLINK-9796: --- I extended the guide about the cancellatio

[jira] [Closed] (FLINK-9796) Add failure handling to release guide

[ https://issues.apache.org/jira/browse/FLINK-9796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-9796. - Resolution: Fixed > Add failure handling to release guide > -

[jira] [Commented] (FLINK-9537) JobManager isolation in session mode

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

[jira] [Closed] (FLINK-9537) JobManager isolation in session mode

[ https://issues.apache.org/jira/browse/FLINK-9537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-9537. - Resolution: Won't Fix > JobManager isolation in session mode > --

[jira] [Closed] (FLINK-21258) Add DeclarativeScheduler / Canceling state

[ https://issues.apache.org/jira/browse/FLINK-21258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-21258. -- Resolution: Fixed Impl: https://github.com/apache/flink/commit/39996236d6a591311e15ee58a367c9

[jira] [Commented] (FLINK-21347) Extract interface out of ExecutionGraph for better testability

[ https://issues.apache.org/jira/browse/FLINK-21347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17282972#comment-17282972 ] Robert Metzger commented on FLINK-21347: I'm not sure if having an interface rea

[jira] [Updated] (FLINK-21333) Introduce stopping with savepoint state

[ https://issues.apache.org/jira/browse/FLINK-21333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21333: --- Fix Version/s: 1.13.0 > Introduce stopping with savepoint state > --

[jira] [Updated] (FLINK-21329) "Local recovery and sticky scheduling end-to-end test" does not finish within 600 seconds

[ https://issues.apache.org/jira/browse/FLINK-21329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21329: --- Fix Version/s: 1.13.0 > "Local recovery and sticky scheduling end-to-end test" does not fini

[jira] [Created] (FLINK-21360) Add resourceTimeout configuration

Robert Metzger created FLINK-21360: -- Summary: Add resourceTimeout configuration Key: FLINK-21360 URL: https://issues.apache.org/jira/browse/FLINK-21360 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17282891#comment-17282891 ] Robert Metzger commented on FLINK-16947: My best bet at this point would be usin

[jira] [Closed] (FLINK-21260) Add DeclarativeScheduler / Finished state

[ https://issues.apache.org/jira/browse/FLINK-21260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-21260. -- Resolution: Fixed Impl: https://github.com/apache/flink/commit/13018506a42e521c77d6f88f25f015

[jira] [Closed] (FLINK-21256) Add DeclarativeScheduler / Executing state

[ https://issues.apache.org/jira/browse/FLINK-21256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-21256. -- Resolution: Fixed Impl: https://github.com/apache/flink/commit/28585ac587f413135c333b1bdda816

[jira] [Closed] (FLINK-21257) Add DeclarativeScheduler / Restarting state

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

[jira] [Created] (FLINK-21348) Add tests for StateWithExecutionGraph

Robert Metzger created FLINK-21348: -- Summary: Add tests for StateWithExecutionGraph Key: FLINK-21348 URL: https://issues.apache.org/jira/browse/FLINK-21348 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-21347) Extract interface out of ExecutionGraph for better testability

Robert Metzger created FLINK-21347: -- Summary: Extract interface out of ExecutionGraph for better testability Key: FLINK-21347 URL: https://issues.apache.org/jira/browse/FLINK-21347 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-19379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17282326#comment-17282326 ] Robert Metzger commented on FLINK-19379: Yes, I will address this once the hugo

[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] [Commented] (FLINK-21103) E2e tests time out on azure

[ https://issues.apache.org/jira/browse/FLINK-21103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17282316#comment-17282316 ] Robert Metzger commented on FLINK-21103: Another case: https://dev.azure.com/ap

[jira] [Assigned] (FLINK-21260) Add DeclarativeScheduler / Finished state

[ https://issues.apache.org/jira/browse/FLINK-21260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-21260: -- Assignee: Robert Metzger > Add DeclarativeScheduler / Finished state > --

[jira] [Assigned] (FLINK-21259) Add DeclarativeScheduler / Failing state

[ https://issues.apache.org/jira/browse/FLINK-21259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-21259: -- Assignee: Robert Metzger > Add DeclarativeScheduler / Failing state > ---

[jira] [Assigned] (FLINK-21258) Add DeclarativeScheduler / Canceling state

[ https://issues.apache.org/jira/browse/FLINK-21258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-21258: -- Assignee: Robert Metzger > Add DeclarativeScheduler / Canceling state > -

[jira] [Created] (FLINK-21333) Introduce stopping with savepoint state

Robert Metzger created FLINK-21333: -- Summary: Introduce stopping with savepoint state Key: FLINK-21333 URL: https://issues.apache.org/jira/browse/FLINK-21333 Project: Flink Issue Type: Sub-t

[jira] [Closed] (FLINK-19445) Several tests for HBase connector 1.4 failed with "NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V"

[ https://issues.apache.org/jira/browse/FLINK-19445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-19445. -- Resolution: Fixed Resolved in FLINK-21006 > Several tests for HBase connector 1.4 failed with

[jira] [Closed] (FLINK-21134) Reactive mode: Introduce execution mode configuration key and check for supported ClusterEntrypoint type

[ https://issues.apache.org/jira/browse/FLINK-21134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-21134. -- Resolution: Fixed Merged to master in https://github.com/apache/flink/commit/1711f12416b91a66

[jira] [Closed] (FLINK-21102) Add ScaleUpController

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

[jira] [Created] (FLINK-21329) "Local recovery and sticky scheduling end-to-end test" does not finish within 600 seconds

Robert Metzger created FLINK-21329: -- Summary: "Local recovery and sticky scheduling end-to-end test" does not finish within 600 seconds Key: FLINK-21329 URL: https://issues.apache.org/jira/browse/FLINK-21329

[jira] [Updated] (FLINK-21134) Reactive mode: Introduce execution mode configuration key and check for supported ClusterEntrypoint type

[ https://issues.apache.org/jira/browse/FLINK-21134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21134: --- Description: According to the FLIP, introduce a "scheduler-mode" configuration key, and chec

[jira] [Closed] (FLINK-21254) Add DeclarativeScheduler / Created state

[ https://issues.apache.org/jira/browse/FLINK-21254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-21254. -- Resolution: Fixed Merged to master in https://github.com/apache/flink/commit/34dfa5c843513125

[jira] [Commented] (FLINK-21306) FlinkSecurityManager might avoid fatal system exits

[ https://issues.apache.org/jira/browse/FLINK-21306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17279734#comment-17279734 ] Robert Metzger commented on FLINK-21306: I propose introducing a {{FlinkSecurity

[jira] [Created] (FLINK-21307) Revisit activation model of FlinkSecurityManager

Robert Metzger created FLINK-21307: -- Summary: Revisit activation model of FlinkSecurityManager Key: FLINK-21307 URL: https://issues.apache.org/jira/browse/FLINK-21307 Project: Flink Issue Ty

[jira] [Created] (FLINK-21306) FlinkSecurityManager might avoid fatal system exits

Robert Metzger created FLINK-21306: -- Summary: FlinkSecurityManager might avoid fatal system exits Key: FLINK-21306 URL: https://issues.apache.org/jira/browse/FLINK-21306 Project: Flink Issue

[jira] [Closed] (FLINK-21255) Add DeclarativeScheduler / WaitingForResources state

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

[jira] [Assigned] (FLINK-21257) Add DeclarativeScheduler / Restarting state

[ https://issues.apache.org/jira/browse/FLINK-21257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-21257: -- Assignee: Robert Metzger > Add DeclarativeScheduler / Restarting state >

[jira] [Assigned] (FLINK-21102) Add ScaleUpController

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

[jira] [Updated] (FLINK-21255) Add DeclarativeScheduler / WaitingForResources state

[ https://issues.apache.org/jira/browse/FLINK-21255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21255: --- Description: This subtask of adding the declarative scheduler is about adding the WaitingFo

[jira] [Updated] (FLINK-21256) Add DeclarativeScheduler / Executing state

[ https://issues.apache.org/jira/browse/FLINK-21256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21256: --- Description: This subtask of adding the declarative scheduler is about adding the Executing

[jira] [Created] (FLINK-21259) Add DeclarativeScheduler / Failing state

Robert Metzger created FLINK-21259: -- Summary: Add DeclarativeScheduler / Failing state Key: FLINK-21259 URL: https://issues.apache.org/jira/browse/FLINK-21259 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-21260) Add DeclarativeScheduler / Finished state

Robert Metzger created FLINK-21260: -- Summary: Add DeclarativeScheduler / Finished state Key: FLINK-21260 URL: https://issues.apache.org/jira/browse/FLINK-21260 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-21258) Add DeclarativeScheduler / Canceling state

Robert Metzger created FLINK-21258: -- Summary: Add DeclarativeScheduler / Canceling state Key: FLINK-21258 URL: https://issues.apache.org/jira/browse/FLINK-21258 Project: Flink Issue Type: Su

[jira] [Updated] (FLINK-21257) Add DeclarativeScheduler / Restarting state

[ https://issues.apache.org/jira/browse/FLINK-21257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21257: --- Description: This subtask of adding the declarative scheduler is about adding the Restarting

[jira] [Created] (FLINK-21257) Add DeclarativeScheduler / Restarting state

Robert Metzger created FLINK-21257: -- Summary: Add DeclarativeScheduler / Restarting state Key: FLINK-21257 URL: https://issues.apache.org/jira/browse/FLINK-21257 Project: Flink Issue Type: S

[jira] [Created] (FLINK-21256) Add DeclarativeScheduler / Executing state

Robert Metzger created FLINK-21256: -- Summary: Add DeclarativeScheduler / Executing state Key: FLINK-21256 URL: https://issues.apache.org/jira/browse/FLINK-21256 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-21255) Add DeclarativeScheduler / WaitingForResources state

Robert Metzger created FLINK-21255: -- Summary: Add DeclarativeScheduler / WaitingForResources state Key: FLINK-21255 URL: https://issues.apache.org/jira/browse/FLINK-21255 Project: Flink Issu

[jira] [Created] (FLINK-21254) Add DeclarativeScheduler / Created state

Robert Metzger created FLINK-21254: -- Summary: Add DeclarativeScheduler / Created state Key: FLINK-21254 URL: https://issues.apache.org/jira/browse/FLINK-21254 Project: Flink Issue Type: Sub

[jira] [Assigned] (FLINK-12607) Introduce a REST API that returns the maxParallelism of a job

[ https://issues.apache.org/jira/browse/FLINK-12607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-12607: -- Assignee: John Phelan > Introduce a REST API that returns the maxParallelism of a job

[jira] [Commented] (FLINK-12607) Introduce a REST API that returns the maxParallelism of a job

[ https://issues.apache.org/jira/browse/FLINK-12607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17277709#comment-17277709 ] Robert Metzger commented on FLINK-12607: Great! Thanks a lot. I assigned you! >

[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=17277359#comment-17277359 ] Robert Metzger commented on FLINK-10407: Hey [~bytesandwich]! Thanks a lot for r

[jira] [Commented] (FLINK-13996) Maven instructions for 3.3+ do not cover all shading special cases

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

[jira] [Closed] (FLINK-21099) Introduce JobType to distinguish between batch and streaming jobs

[ https://issues.apache.org/jira/browse/FLINK-21099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-21099. -- Resolution: Fixed Resolved on master: https://github.com/apache/flink/commit/95f8b61b60d57e2d

[jira] [Closed] (FLINK-13996) Maven instructions for 3.3+ do not cover all shading special cases

[ https://issues.apache.org/jira/browse/FLINK-13996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-13996. -- Fix Version/s: 1.13.0 Resolution: Fixed Resolved in https://github.com/apache/flink/co

[jira] [Commented] (FLINK-16017) Improve attachJobGraph Performance

[ https://issues.apache.org/jira/browse/FLINK-16017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17274341#comment-17274341 ] Robert Metzger commented on FLINK-16017: [~zhuzh] can we close this ticket? > I

[jira] [Closed] (FLINK-2366) HA Without ZooKeeper

[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-2366. - Resolution: Invalid > HA Without ZooKeeper > > > Key: FLINK-

[jira] [Commented] (FLINK-2366) HA Without ZooKeeper

[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17274336#comment-17274336 ] Robert Metzger commented on FLINK-2366: --- I'm closing this ticket, since it is too b

[jira] [Assigned] (FLINK-13996) Maven instructions for 3.3+ do not cover all shading special cases

[ https://issues.apache.org/jira/browse/FLINK-13996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-13996: -- Assignee: Robert Metzger > Maven instructions for 3.3+ do not cover all shading speci

[jira] [Closed] (FLINK-12887) Schedule UnfencedMessage would lost envelope info

[ https://issues.apache.org/jira/browse/FLINK-12887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-12887. -- Resolution: Invalid Closing this ticket, as it is not about Flink, but a fork of Flink, and th

[jira] [Closed] (FLINK-12926) Main thread checking in some tests fails

[ https://issues.apache.org/jira/browse/FLINK-12926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-12926. -- Resolution: Abandoned It seems that we currently have no test instabilities caused by this. S

[jira] [Updated] (FLINK-12607) Introduce a REST API that returns the maxParallelism of a job

[ https://issues.apache.org/jira/browse/FLINK-12607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12607: --- Labels: starter (was: ) > Introduce a REST API that returns the maxParallelism of a job > -

[jira] [Closed] (FLINK-21017) Fix missing backquote in table connectors docs

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

[jira] [Updated] (FLINK-21017) Fix missing backquote in table connectors docs

[ https://issues.apache.org/jira/browse/FLINK-21017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21017: --- Component/s: Table SQL / API > Fix missing backquote in table connectors docs >

[jira] [Assigned] (FLINK-21134) Reactive mode: Introduce execution mode configuration key and check for supported ClusterEntrypoint type

[ https://issues.apache.org/jira/browse/FLINK-21134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-21134: -- Assignee: Robert Metzger > Reactive mode: Introduce execution mode configuration key

[jira] [Updated] (FLINK-21166) IllegalStateException in CheckpointMetricsBuilder surfacing in "Resuming Savepoint" e2e

[ https://issues.apache.org/jira/browse/FLINK-21166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21166: --- Summary: IllegalStateException in CheckpointMetricsBuilder surfacing in "Resuming Savepoint"

<    4   5   6   7   8   9   10   11   12   13   >