[jira] [Commented] (FLINK-29179) Translate "Temporal Table Function" page of "Streaming Concepts" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-29179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612842#comment-17612842 ] astalyliu commented on FLINK-29179: --- {{{}hi,[~jark] ,if i want to translate template table function

[jira] [Created] (FLINK-29505) [OpenAPI] Need `operationId` on certain operations

Tiger (Apache) Wang created FLINK-29505: --- Summary: [OpenAPI] Need `operationId` on certain operations Key: FLINK-29505 URL: https://issues.apache.org/jira/browse/FLINK-29505 Project: Flink

[jira] [Updated] (FLINK-29503) [OpenAPI] enum `backpressure-level` should be backpressurelevel so code generator recognizes it

[ https://issues.apache.org/jira/browse/FLINK-29503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tiger (Apache) Wang updated FLINK-29503: Description: Install nodejs and run {{$ npx --yes --package

[jira] [Updated] (FLINK-29503) [OpenAPI] enum `backpressure-level` should be backpressurelevel so code generator recognizes it

[ https://issues.apache.org/jira/browse/FLINK-29503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tiger (Apache) Wang updated FLINK-29503: Priority: Major (was: Blocker) > [OpenAPI] enum `backpressure-level` should be

[jira] [Updated] (FLINK-29504) [OpenAPI] `application/x-java-archive` should be followed by a structure instead of `{}`

[ https://issues.apache.org/jira/browse/FLINK-29504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tiger (Apache) Wang updated FLINK-29504: Description: Install nodejs and run {{$ npx --yes

[jira] [Created] (FLINK-29504) [OpenAPI] `application/x-java-archive` should be followed by a structure instead of `{}`

Tiger (Apache) Wang created FLINK-29504: --- Summary: [OpenAPI] `application/x-java-archive` should be followed by a structure instead of `{}` Key: FLINK-29504 URL:

[jira] [Updated] (FLINK-29503) [OpenAPI] enum `backpressure-level` should be backpressurelevel so code generator recognizes it

[ https://issues.apache.org/jira/browse/FLINK-29503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tiger (Apache) Wang updated FLINK-29503: Labels: openapi (was: ) > [OpenAPI] enum `backpressure-level` should be

[jira] [Created] (FLINK-29503) [OpenAPI] enum `backpressure-level` should be backpressurelevel so code generator recognizes it

Tiger (Apache) Wang created FLINK-29503: --- Summary: [OpenAPI] enum `backpressure-level` should be backpressurelevel so code generator recognizes it Key: FLINK-29503 URL:

[jira] [Commented] (FLINK-29365) Millisecond behind latest jumps after Flink 1.15.2 upgrade

[ https://issues.apache.org/jira/browse/FLINK-29365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612830#comment-17612830 ] Wilson Wu commented on FLINK-29365: --- Hi [~liangtl]  Thank you so much for looking into this,

[jira] [Updated] (FLINK-29365) Millisecond behind latest jumps after Flink 1.15.2 upgrade

[ https://issues.apache.org/jira/browse/FLINK-29365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wilson Wu updated FLINK-29365: -- Attachment: 2022-09-14T17_00_00.000Z - 2022-09-14T18_03_44.089Z_14.4-15.2.numbers

[jira] [Commented] (FLINK-29131) Kubernetes operator webhook can use hostPort

[ https://issues.apache.org/jira/browse/FLINK-29131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612774#comment-17612774 ] Gyula Fora commented on FLINK-29131: If you feel that it would be enough to extend/rework our helm

[jira] [Created] (FLINK-29502) Update the Hadoop implementation for filesystems to 3.3.4

Martijn Visser created FLINK-29502: -- Summary: Update the Hadoop implementation for filesystems to 3.3.4 Key: FLINK-29502 URL: https://issues.apache.org/jira/browse/FLINK-29502 Project: Flink

[jira] [Commented] (FLINK-29501) Allow overriding JobVertex parallelisms during job submission

[ https://issues.apache.org/jira/browse/FLINK-29501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612668#comment-17612668 ] Maximilian Michels commented on FLINK-29501: Good question. How would that work? The user

[jira] [Comment Edited] (FLINK-29131) Kubernetes operator webhook can use hostPort

[ https://issues.apache.org/jira/browse/FLINK-29131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612621#comment-17612621 ] Dylan Meissner edited comment on FLINK-29131 at 10/4/22 3:14 PM: - In the

[jira] [Commented] (FLINK-29501) Allow overriding JobVertex parallelisms during job submission

[ https://issues.apache.org/jira/browse/FLINK-29501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612640#comment-17612640 ] Chesnay Schepler commented on FLINK-29501: -- Why can't this be handled within the application

[jira] [Created] (FLINK-29501) Allow overriding JobVertex parallelisms during job submission

Maximilian Michels created FLINK-29501: -- Summary: Allow overriding JobVertex parallelisms during job submission Key: FLINK-29501 URL: https://issues.apache.org/jira/browse/FLINK-29501 Project:

[jira] [Comment Edited] (FLINK-29498) Flink Async I/O Retry Strategies Do Not Work for Scala AsyncDataStream API

[ https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612625#comment-17612625 ] Eric Xiao edited comment on FLINK-29498 at 10/4/22 2:03 PM: > For your case,

[jira] [Commented] (FLINK-29498) Flink Async I/O Retry Strategies Do Not Work for Scala AsyncDataStream API

[ https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612625#comment-17612625 ] Eric Xiao commented on FLINK-29498: --- [~lincoln.86xy], is there a reason why the `AsyncRetryStrategies`

[jira] [Commented] (FLINK-29131) Kubernetes operator webhook can use hostPort

[ https://issues.apache.org/jira/browse/FLINK-29131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612621#comment-17612621 ] Dylan Meissner commented on FLINK-29131: In the course of all these investigations, my team and

[jira] [Assigned] (FLINK-29495) PulsarSinkE2ECase hang

[ https://issues.apache.org/jira/browse/FLINK-29495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-29495: -- Assignee: Yufan Sheng > PulsarSinkE2ECase hang > -- > >

[jira] [Assigned] (FLINK-29399) TableITCase is unstable

[ https://issues.apache.org/jira/browse/FLINK-29399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-29399: Assignee: Chesnay Schepler > TableITCase is unstable > --- >

[jira] [Commented] (FLINK-29330) Provide better logs of MiniCluster shutdown procedure

[ https://issues.apache.org/jira/browse/FLINK-29330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612592#comment-17612592 ] Matthias Pohl commented on FLINK-29330: --- I guess, my initial intention was to implement the close

[jira] [Created] (FLINK-29500) InitializeOnMaster uses wrong parallelism with AdaptiveScheduler

Dawid Wysakowicz created FLINK-29500: Summary: InitializeOnMaster uses wrong parallelism with AdaptiveScheduler Key: FLINK-29500 URL: https://issues.apache.org/jira/browse/FLINK-29500 Project:

[jira] [Created] (FLINK-29499) DispatcherOperationCaches should implement AutoCloseableAsync

Chesnay Schepler created FLINK-29499: Summary: DispatcherOperationCaches should implement AutoCloseableAsync Key: FLINK-29499 URL: https://issues.apache.org/jira/browse/FLINK-29499 Project: Flink

[jira] [Updated] (FLINK-29456) Add methods that accept OperatorIdentifier

[ https://issues.apache.org/jira/browse/FLINK-29456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29456: - Summary: Add methods that accept OperatorIdentifier (was: Add methods that acept

[jira] [Closed] (FLINK-29403) Streamline SimpleCondition usage

[ https://issues.apache.org/jira/browse/FLINK-29403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-29403. Resolution: Fixed master: 990a7dac90af5ea7e8450521a63802c2563f4548 > Streamline

[jira] [Closed] (FLINK-29455) Add OperatorIdentifier

[ https://issues.apache.org/jira/browse/FLINK-29455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-29455. Resolution: Fixed master: 306c3c4ce3025bb29b84e5f6045cb3c745feb893 > Add

[jira] [Closed] (FLINK-29488) MetricRegistryImpl should implement AutoCloseableAsync

[ https://issues.apache.org/jira/browse/FLINK-29488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-29488. Resolution: Fixed master: 149785a5725a4727287d2f133b3b3abbb23f99a9 > MetricRegistryImpl

[jira] [Commented] (FLINK-29495) PulsarSinkE2ECase hang

[ https://issues.apache.org/jira/browse/FLINK-29495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612528#comment-17612528 ] Xingbo Huang commented on FLINK-29495: --

[jira] [Commented] (FLINK-29495) PulsarSinkE2ECase hang

[ https://issues.apache.org/jira/browse/FLINK-29495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612527#comment-17612527 ] Xingbo Huang commented on FLINK-29495: --

[jira] [Commented] (FLINK-29485) TypeSerializerUpgradeTestBase still uses 1.15 as the current version on master and release-1.16

[ https://issues.apache.org/jira/browse/FLINK-29485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612505#comment-17612505 ] Matthias Pohl commented on FLINK-29485: --- I misinterpreted the

[jira] [Updated] (FLINK-29485) TypeSerializerUpgradeTestBase still uses 1.15 as the current version on master and release-1.16

[ https://issues.apache.org/jira/browse/FLINK-29485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29485: -- Affects Version/s: 1.15.2 1.16.0 > TypeSerializerUpgradeTestBase still

[jira] [Assigned] (FLINK-29485) TypeSerializerUpgradeTestBase still uses 1.15 as the current version on master and release-1.16

[ https://issues.apache.org/jira/browse/FLINK-29485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-29485: - Assignee: (was: Matthias Pohl) > TypeSerializerUpgradeTestBase still uses 1.15 as

[jira] [Updated] (FLINK-29485) TypeSerializerUpgradeTestBase still uses 1.15 as the current version on master and release-1.16

[ https://issues.apache.org/jira/browse/FLINK-29485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29485: -- Affects Version/s: 1.17.0 (was: 1.16.0) >

[jira] [Updated] (FLINK-29485) TypeSerializerUpgradeTestBase still uses 1.15 as the current version on master and release-1.16

[ https://issues.apache.org/jira/browse/FLINK-29485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29485: -- Description: -TypeSerializerUpgradeTestBase still refers to 1.15 as the current version. We

[jira] [Updated] (FLINK-29485) TypeSerializerUpgradeTestBase still uses 1.15 as the current version on master and release-1.16

[ https://issues.apache.org/jira/browse/FLINK-29485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29485: -- Component/s: Documentation > TypeSerializerUpgradeTestBase still uses 1.15 as the current

[jira] [Updated] (FLINK-29485) TypeSerializerUpgradeTestBase still uses 1.15 as the current version on master and release-1.16

[ https://issues.apache.org/jira/browse/FLINK-29485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29485: -- Description: -TypeSerializerUpgradeTestBase still refers to 1.15 as the current version. We

[jira] [Commented] (FLINK-29245) [JUnit 5 Migration] Remove RetryRule

[ https://issues.apache.org/jira/browse/FLINK-29245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612501#comment-17612501 ] Matthias Pohl commented on FLINK-29245: --- Hi [~nagarajtantri], thanks for volunteering to fix this

[jira] [Commented] (FLINK-25920) Allow receiving updates of CommittableSummary

[ https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612499#comment-17612499 ] Bastien DINE commented on FLINK-25920: -- I encountered the same issue, but with aligned checkpoint : 

[jira] [Comment Edited] (FLINK-25920) Allow receiving updates of CommittableSummary

[ https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612499#comment-17612499 ] Bastien DINE edited comment on FLINK-25920 at 10/4/22 7:25 AM: --- I

[jira] [Updated] (FLINK-29485) TypeSerializerUpgradeTestBase still uses 1.15 as the current version on master and release-1.16

[ https://issues.apache.org/jira/browse/FLINK-29485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29485: -- Priority: Minor (was: Blocker) > TypeSerializerUpgradeTestBase still uses 1.15 as the

[jira] [Assigned] (FLINK-26469) Adaptive job shows error in WebUI when not enough resource are available

[ https://issues.apache.org/jira/browse/FLINK-26469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-26469: Assignee: Dawid Wysakowicz > Adaptive job shows error in WebUI when not enough

[jira] [Commented] (FLINK-29498) Flink Async I/O Retry Strategies Do Not Work for Scala AsyncDataStream API

[ https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612486#comment-17612486 ] lincoln lee commented on FLINK-29498: - [~eric.xiao] There's a separate