[jira] [Commented] (FLINK-23254) Upgrade Test Framework to JUnit 5

2022-10-05 Thread Duncan Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17612866#comment-17612866 ] Duncan Chan commented on FLINK-23254: - is anyone working on this task? If not, can I

[jira] [Created] (FLINK-29506) ParquetInputFormatFactory fails to create format on Flink 1.14

2022-10-05 Thread Jane Chan (Jira)
Jane Chan created FLINK-29506: - Summary: ParquetInputFormatFactory fails to create format on Flink 1.14 Key: FLINK-29506 URL: https://issues.apache.org/jira/browse/FLINK-29506 Project: Flink Iss

[jira] [Updated] (FLINK-29506) ParquetInputFormatFactory fails to create format on Flink 1.14

2022-10-05 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-29506: -- Attachment: image-2022-10-05-15-20-19-422.png > ParquetInputFormatFactory fails to create format on Fl

[jira] [Updated] (FLINK-29506) ParquetInputFormatFactory fails to create format on Flink 1.14

2022-10-05 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-29506: -- Description: The current way to instantiate format has issues. See [https://github.com/apache/flink-ta

[jira] [Commented] (FLINK-25858) Remove ArchUnit rules for JUnit 4 in ITCaseRules after the JUnit 4->5 migration is closed

2022-10-05 Thread Duncan Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17612871#comment-17612871 ] Duncan Chan commented on FLINK-25858: - can I be assigned to this task? > Remove Arc

[jira] [Updated] (FLINK-29149) Migrate E2E tests to catalog-based and enable E2E tests for Flink1.14

2022-10-05 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-29149: -- Summary: Migrate E2E tests to catalog-based and enable E2E tests for Flink1.14 (was: Migrate E2E test

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

2022-10-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17612880#comment-17612880 ] Hong Liang Teoh commented on FLINK-29365: - Thanks for the logs, [~wilsonwu]! Th

[jira] [Created] (FLINK-29507) Make e2e tests independent of the current directory

2022-10-05 Thread Gabor Somogyi (Jira)
Gabor Somogyi created FLINK-29507: - Summary: Make e2e tests independent of the current directory Key: FLINK-29507 URL: https://issues.apache.org/jira/browse/FLINK-29507 Project: Flink Issue T

[jira] [Assigned] (FLINK-29507) Make e2e tests independent of the current directory

2022-10-05 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-29507: - Assignee: Gabor Somogyi > Make e2e tests independent of the current directory > ---

[jira] [Commented] (FLINK-28229) Introduce Source API alternatives for StreamExecutionEnvironment#fromCollection() methods

2022-10-05 Thread Tigran Manasyan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17612887#comment-17612887 ] Tigran Manasyan commented on FLINK-28229: - Hello! I would like to start working

[jira] [Comment Edited] (FLINK-28229) Introduce Source API alternatives for StreamExecutionEnvironment#fromCollection() methods

2022-10-05 Thread Tigran Manasyan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17612887#comment-17612887 ] Tigran Manasyan edited comment on FLINK-28229 at 10/5/22 8:21 AM:

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

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29503: - Component/s: Runtime / REST (was: API / Core) > [OpenAPI] enum `bac

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

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-29505. Resolution: Duplicate Operation IDs will be available in 1.16.0. > [OpenAPI] Need `operat

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

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29505: - Component/s: (was: API / Core) > [OpenAPI] Need `operationId` on certain operations

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

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29505: - Component/s: Runtime / REST > [OpenAPI] Need `operationId` on certain operations > -

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

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17612908#comment-17612908 ] Chesnay Schepler commented on FLINK-29504: -- Should be straight forward to fix b

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

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-29504: Assignee: Chesnay Schepler > [OpenAPI] `application/x-java-archive` should be fol

[jira] [Updated] (FLINK-29504) Jar upload spec should define a shema

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29504: - Summary: Jar upload spec should define a shema (was: [OpenAPI] `application/x-java-arch

[jira] [Updated] (FLINK-29504) Jar upload spec should define a schema

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29504: - Summary: Jar upload spec should define a schema (was: Jar upload spec should define a s

[jira] [Updated] (FLINK-29504) Jar upload spec should define a schema

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29504: - Component/s: Runtime / REST (was: API / Core) > Jar upload spec sho

[jira] [Updated] (FLINK-29504) Jar upload spec should define a schema

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29504: - Fix Version/s: 1.16.0 1.15.3 > Jar upload spec should define a schema

[jira] [Commented] (FLINK-25858) Remove ArchUnit rules for JUnit 4 in ITCaseRules after the JUnit 4->5 migration is closed

2022-10-05 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17612916#comment-17612916 ] Jing Ge commented on FLINK-25858: - Sure. But the JUnit 4->5 migration is still WIP, whic

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

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-29503: Assignee: Chesnay Schepler > [OpenAPI] enum `backpressure-level` should be backpr

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

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17612919#comment-17612919 ] Chesnay Schepler commented on FLINK-29503: -- This is less of an issue with a spe

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

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29503: - Fix Version/s: 1.16.0 1.15.3 > [OpenAPI] enum `backpressure-level` sh

[jira] [Updated] (FLINK-29503) Add backpressureLevel field wiithout hyphens

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29503: - Summary: Add backpressureLevel field wiithout hyphens (was: [OpenAPI] enum `backpressur

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

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17612935#comment-17612935 ] Chesnay Schepler commented on FLINK-29501: -- > The user application doesn't have

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

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17612935#comment-17612935 ] Chesnay Schepler edited comment on FLINK-29501 at 10/5/22 10:21 AM: --

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

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17612935#comment-17612935 ] Chesnay Schepler edited comment on FLINK-29501 at 10/5/22 10:21 AM: --

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

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17612935#comment-17612935 ] Chesnay Schepler edited comment on FLINK-29501 at 10/5/22 10:25 AM: --

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

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17612935#comment-17612935 ] Chesnay Schepler edited comment on FLINK-29501 at 10/5/22 10:25 AM: --

[jira] [Closed] (FLINK-29487) RpcService should implement AutoCloseableAsync

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-29487. Resolution: Fixed master: e9f3ec93aad7cec795c765c937ee71807f5478cf > RpcService should im

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

2022-10-05 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17612956#comment-17612956 ] Maximilian Michels commented on FLINK-29501: What you suggest generally work

[jira] [Created] (FLINK-29508) Some NOTICE files are not checked for correctness

2022-10-05 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29508: Summary: Some NOTICE files are not checked for correctness Key: FLINK-29508 URL: https://issues.apache.org/jira/browse/FLINK-29508 Project: Flink Iss

[jira] [Commented] (FLINK-29419) HybridShuffle.testHybridFullExchangesRestart hangs

2022-10-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17612972#comment-17612972 ] Matthias Pohl commented on FLINK-29419: --- https://dev.azure.com/apache-flink/apache

[jira] [Resolved] (FLINK-27942) [JUnit5 Migration] Module: flink-connector-rabbitmq

2022-10-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-27942. --- Resolution: Fixed master: d191bda7e63a2c12416cba56090e5cd75426079b > [JUnit5 Migration] Mod

[jira] [Updated] (FLINK-27942) [JUnit5 Migration] Module: flink-connector-rabbitmq

2022-10-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-27942: -- Fix Version/s: 1.17.0 > [JUnit5 Migration] Module: flink-connector-rabbitmq >

[jira] [Created] (FLINK-29509) Set correct subtaskId during recovery of committables

2022-10-05 Thread Fabian Paul (Jira)
Fabian Paul created FLINK-29509: --- Summary: Set correct subtaskId during recovery of committables Key: FLINK-29509 URL: https://issues.apache.org/jira/browse/FLINK-29509 Project: Flink Issue Typ

[jira] [Assigned] (FLINK-27938) [JUnit5 Migration] Module: flink-connector-hbase-base

2022-10-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-27938: - Assignee: Sergey Nuyanzin > [JUnit5 Migration] Module: flink-connector-hbase-base > ---

[jira] [Resolved] (FLINK-27938) [JUnit5 Migration] Module: flink-connector-hbase-base

2022-10-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-27938. --- Fix Version/s: 1.17.0 Resolution: Fixed master: adc476a0df2355226df19c37c0834ee0d9c19

[jira] [Commented] (FLINK-29459) Sink v2 has bugs in supporting legacy v1 implementations with global committer

2022-10-05 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17612980#comment-17612980 ] Fabian Paul commented on FLINK-29459: - [~gaoyunhaii] thanks for your analysis. I am

[jira] [Commented] (FLINK-29459) Sink v2 has bugs in supporting legacy v1 implementations with global committer

2022-10-05 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17612982#comment-17612982 ] Fabian Paul commented on FLINK-29459: - It also looks like the first and second point

[jira] [Created] (FLINK-29510) Add NoticeFileChecker tests

2022-10-05 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29510: Summary: Add NoticeFileChecker tests Key: FLINK-29510 URL: https://issues.apache.org/jira/browse/FLINK-29510 Project: Flink Issue Type: Technical Deb

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

2022-10-05 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-26469. Fix Version/s: 1.17.0 1.15.3 1.16.1 Resolution

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

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-29499. Resolution: Fixed master: 3730e24cc4283f877ac35b189dff355579d1de68 > DispatcherOperationC

[jira] [Updated] (FLINK-25916) Using upsert-kafka with a flush buffer results in Null Pointer Exception

2022-10-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25916: --- Priority: Critical (was: Major) > Using upsert-kafka with a flush buffer results in Null Po

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

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-29456. Resolution: Fixed master: 8d72490377551a35851a3319c0f49b408d31a566 > Add methods that acc

[jira] [Created] (FLINK-29511) Sort properties in OpenAPI spec

2022-10-05 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29511: Summary: Sort properties in OpenAPI spec Key: FLINK-29511 URL: https://issues.apache.org/jira/browse/FLINK-29511 Project: Flink Issue Type: Technical

[jira] [Updated] (FLINK-29511) Sort properties in OpenAPI spec

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29511: - Description: The properties order is currently based on whatever order properties were

[jira] [Created] (FLINK-29512) Align SubtaskCommittableManager checkpointId with CheckpointCommittableManagerImpl checkpointId during recovery

2022-10-05 Thread Fabian Paul (Jira)
Fabian Paul created FLINK-29512: --- Summary: Align SubtaskCommittableManager checkpointId with CheckpointCommittableManagerImpl checkpointId during recovery Key: FLINK-29512 URL: https://issues.apache.org/jira/browse/

[jira] [Updated] (FLINK-29511) Sort properties/schemas in OpenAPI spec

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29511: - Summary: Sort properties/schemas in OpenAPI spec (was: Sort properties in OpenAPI spec)

[jira] [Updated] (FLINK-29511) Sort properties/schemas in OpenAPI spec

2022-10-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29511: - Description: The properties/schema order is currently based on whatever order they were

[jira] [Closed] (FLINK-26622) Azure failed due to Connection timed out

2022-10-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-26622. -- Resolution: Cannot Reproduce > Azure failed due to Connection timed out > ---

[jira] [Commented] (FLINK-9171) Flink HCatolog integration

2022-10-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17613068#comment-17613068 ] Martijn Visser commented on FLINK-9171: --- I've opened a discussion thread to remove

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

2022-10-05 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17613080#comment-17613080 ] Maximilian Michels commented on FLINK-29501: {quote}I don't really follow. W

[jira] [Commented] (FLINK-25916) Using upsert-kafka with a flush buffer results in Null Pointer Exception

2022-10-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17613117#comment-17613117 ] Martijn Visser commented on FLINK-25916: [~jjimenezMM] [~mhv] That's because no

[jira] [Created] (FLINK-29513) Update Kafka version to 3.2.3

2022-10-05 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-29513: -- Summary: Update Kafka version to 3.2.3 Key: FLINK-29513 URL: https://issues.apache.org/jira/browse/FLINK-29513 Project: Flink Issue Type: Technical Debt

[GitHub] [flink] liuzhuang2017 opened a new pull request, #20938: [hotfix][table] Add the `dayofweek` function description.

2022-10-05 Thread GitBox
liuzhuang2017 opened a new pull request, #20938: URL: https://github.com/apache/flink/pull/20938 ## What is the purpose of the change - Add the `dayofweek` function description. ## Brief change log - Add the `dayofweek` function description. ## Verifyin

[GitHub] [flink] flinkbot commented on pull request #20938: [hotfix][table] Add the `dayofweek` function description.

2022-10-05 Thread GitBox
flinkbot commented on PR #20938: URL: https://github.com/apache/flink/pull/20938#issuecomment-1264670040 ## CI report: * 1415776206501369c0bf1ca29fc2d430aabb916f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] fsk119 commented on a diff in pull request #20931: [FLINK-29486][sql-client] Implement ClientParser for implementing remote SQL client later

2022-10-05 Thread GitBox
fsk119 commented on code in PR #20931: URL: https://github.com/apache/flink/pull/20931#discussion_r985252646 ## flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/parser/StatementType.java: ## @@ -0,0 +1,30 @@ +/* + * Licensed to the Apache Software Fou

[GitHub] [flink] yuzelin commented on a diff in pull request #20931: [FLINK-29486][sql-client] Implement ClientParser for implementing remote SQL client later

2022-10-05 Thread GitBox
yuzelin commented on code in PR #20931: URL: https://github.com/apache/flink/pull/20931#discussion_r985271871 ## flink-table/flink-sql-client/pom.xml: ## @@ -511,6 +511,12 @@ under the License. provided + +org.apache

[GitHub] [flink] liuzhuang2017 commented on pull request #20938: [hotfix][table] Add the `dayofweek` function description.

2022-10-05 Thread GitBox
liuzhuang2017 commented on PR #20938: URL: https://github.com/apache/flink/pull/20938#issuecomment-1264770996 @wuchong ,Can you help me review this pr?Thank you very much. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and us

[GitHub] [flink] liuzhuang2017 commented on pull request #20939: [hotfix][docs]Fixed some typos of docs.

2022-10-05 Thread GitBox
liuzhuang2017 commented on PR #20939: URL: https://github.com/apache/flink/pull/20939#issuecomment-1264811207 @MartijnVisser , Sorry to bother you again, can you help me review this pr? Thank you. -- This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [flink] liuzhuang2017 opened a new pull request, #20939: [hotfix][docs]Fixed some typos of docs.

2022-10-05 Thread GitBox
liuzhuang2017 opened a new pull request, #20939: URL: https://github.com/apache/flink/pull/20939 ## What is the purpose of the change - Fixed some typos of docs. ## Brief change log - Fixed some typos of docs. ## Verifying this change - This chan

[GitHub] [flink] flinkbot commented on pull request #20939: [hotfix][docs]Fixed some typos of docs.

2022-10-05 Thread GitBox
flinkbot commented on PR #20939: URL: https://github.com/apache/flink/pull/20939#issuecomment-1264814652 ## CI report: * b5f403ceb76893a5e477159d87a11bbf56f6a04b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] liuzhuang2017 opened a new pull request, #20940: [hotfix][docs] Fix inaccessible ES links.

2022-10-05 Thread GitBox
liuzhuang2017 opened a new pull request, #20940: URL: https://github.com/apache/flink/pull/20940 ## What is the purpose of the change - Fix inaccessible ES links. ## Brief change log - Fix inaccessible ES links. ## Verifying this change - This ch

[GitHub] [flink] flinkbot commented on pull request #20940: [hotfix][docs] Fix inaccessible ES links.

2022-10-05 Thread GitBox
flinkbot commented on PR #20940: URL: https://github.com/apache/flink/pull/20940#issuecomment-1264870593 ## CI report: * 87dd4d3845e5f1ce4c3f1da7badf4a6036137f2d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] liuzhuang2017 commented on pull request #20940: [hotfix][docs] Fix inaccessible ES links.

2022-10-05 Thread GitBox
liuzhuang2017 commented on PR #20940: URL: https://github.com/apache/flink/pull/20940#issuecomment-1264868739 @MartijnVisser , Sorry to bother you again, can you help me review this pr? Thank you. -- This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [flink] yuzelin commented on a diff in pull request #20931: [FLINK-29486][sql-client] Implement ClientParser for implementing remote SQL client later

2022-10-05 Thread GitBox
yuzelin commented on code in PR #20931: URL: https://github.com/apache/flink/pull/20931#discussion_r985409681 ## flink-table/flink-sql-client/pom.xml: ## @@ -511,6 +511,12 @@ under the License. provided + +org.apache

[GitHub] [flink] dianfu closed pull request #20742: [FLINK-29156]Support LISTAGG in the Table API

2022-10-05 Thread GitBox
dianfu closed pull request #20742: [FLINK-29156]Support LISTAGG in the Table API URL: https://github.com/apache/flink/pull/20742 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[GitHub] [flink] liuzhuang2017 commented on pull request #20939: [hotfix][docs]Fixed some typos of docs.

2022-10-05 Thread GitBox
liuzhuang2017 commented on PR #20939: URL: https://github.com/apache/flink/pull/20939#issuecomment-1265152795 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] grzegorz8 commented on a diff in pull request #20140: [Flink 16024][Connector][JDBC] Support FilterPushdown

2022-10-05 Thread GitBox
grzegorz8 commented on code in PR #20140: URL: https://github.com/apache/flink/pull/20140#discussion_r985666582 ## flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcFilterPushdownPreparedStatementVisitor.java: ## @@ -0,0 +1,178 @@ +/*

[GitHub] [flink-ml] jiangxin369 commented on pull request #158: [FLINK-29409] Add Transformer and Estimator for VarianceThresholdSelector

2022-10-05 Thread GitBox
jiangxin369 commented on PR #158: URL: https://github.com/apache/flink-ml/pull/158#issuecomment-1265316166 > Thanks for the update. Looks good overall. Left just some minor comments. Thanks for your review, the above comments are updated. -- This is an automated message from the Apa

[GitHub] [flink] yuzelin commented on a diff in pull request #20931: [FLINK-29486][sql-client] Implement ClientParser for implementing remote SQL client later

2022-10-05 Thread GitBox
yuzelin commented on code in PR #20931: URL: https://github.com/apache/flink/pull/20931#discussion_r985673122 ## flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/parser/ClientParser.java: ## @@ -0,0 +1,104 @@ +/* + * Licensed to the Apache Software Fo

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #377: [FLINK-28979] Add owner reference to flink deployment object

2022-10-05 Thread GitBox
gyfora commented on code in PR #377: URL: https://github.com/apache/flink-kubernetes-operator/pull/377#discussion_r985697814 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java: ## @@ -97,6 +

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #388: [FLINK-29413] Make it possible to associate triggered and completed savepoints

2022-10-05 Thread GitBox
gyfora commented on code in PR #388: URL: https://github.com/apache/flink-kubernetes-operator/pull/388#discussion_r985699753 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/Savepoint.java: ## @@ -38,7 +36,42 @@ public class Savepoint {

[GitHub] [flink-connector-opensearch] reta commented on pull request #1: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors

2022-10-05 Thread GitBox
reta commented on PR #1: URL: https://github.com/apache/flink-connector-opensearch/pull/1#issuecomment-1265396809 @MartijnVisser could you please take a look? thank you :-) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] dawidwys opened a new pull request, #20941: [FLINK-22243] Sync parallelism in JobGraph with VertexParallelismStore

2022-10-05 Thread GitBox
dawidwys opened a new pull request, #20941: URL: https://github.com/apache/flink/pull/20941 ## What is the purpose of the change In adaptive scheduler the actual parallelism is encoded in the VertexParallelismStore. This has two consequences: 1. The Web UI does not show correct

[GitHub] [flink] flinkbot commented on pull request #20941: [FLINK-22243] Sync parallelism in JobGraph with VertexParallelismStore

2022-10-05 Thread GitBox
flinkbot commented on PR #20941: URL: https://github.com/apache/flink/pull/20941#issuecomment-1265412264 ## CI report: * 41b6416c2d22ccd89ec8fafce56fc97a1d4c289a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-kubernetes-operator] morhidi commented on a diff in pull request #388: [FLINK-29413] Make it possible to associate triggered and completed savepoints

2022-10-05 Thread GitBox
morhidi commented on code in PR #388: URL: https://github.com/apache/flink-kubernetes-operator/pull/388#discussion_r985735711 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/crd/status/Savepoint.java: ## @@ -38,7 +36,42 @@ public class Savepoint

[jira] [Updated] (FLINK-22243) Reactive Mode parallelism changes are not shown in the job graph visualization in the UI

2022-10-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22243: --- Labels: pull-request-available (was: ) > Reactive Mode parallelism changes are not shown in

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #388: [FLINK-29413] Make it possible to associate triggered and completed savepoints

2022-10-05 Thread GitBox
gyfora merged PR #388: URL: https://github.com/apache/flink-kubernetes-operator/pull/388 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr

[GitHub] [flink] m8719-github commented on pull request #20936: [FLINK-13703][flink-formats/flink-avro] AvroTypeInfo requires objects to be strict POJOs (mutable, with setters)

2022-10-05 Thread GitBox
m8719-github commented on PR #20936: URL: https://github.com/apache/flink/pull/20936#issuecomment-1265589920 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comme

[GitHub] [flink] leletan commented on pull request #20852: [FLINK-27101][checkpointing][rest] Add restful API to trigger checkpoints

2022-10-05 Thread GitBox
leletan commented on PR #20852: URL: https://github.com/apache/flink/pull/20852#issuecomment-1265618274 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[GitHub] [flink] fsk119 commented on a diff in pull request #20931: [FLINK-29486][sql-client] Implement ClientParser for implementing remote SQL client later

2022-10-05 Thread GitBox
fsk119 commented on code in PR #20931: URL: https://github.com/apache/flink/pull/20931#discussion_r985739642 ## flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/parser/ClientParser.java: ## @@ -0,0 +1,137 @@ +/* + * Licensed to the Apache Software Fou

[GitHub] [flink] leletan commented on pull request #20852: [FLINK-27101][checkpointing][rest] Add restful API to trigger checkpoints

2022-10-05 Thread GitBox
leletan commented on PR #20852: URL: https://github.com/apache/flink/pull/20852#issuecomment-1265689101 Thanks, @pnowojski and @stevenzwu! Combing the feedbacks and here is my plan: 1. fix the build 2. rebase all the changes so far into one commit. 3. do a follow up commit for t

[GitHub] [flink] MartijnVisser commented on pull request #20343: [FLINK-25916][connector-kafka] Using upsert-kafka with a flush buffer…

2022-10-05 Thread GitBox
MartijnVisser commented on PR #20343: URL: https://github.com/apache/flink/pull/20343#issuecomment-1265807076 @PatrickRen WDYT? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific commen

[jira] [Updated] (FLINK-28405) Update Confluent Platform images to v7.2.2

2022-10-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-28405: --- Summary: Update Confluent Platform images to v7.2.2 (was: Update Confluent Platform images

[jira] [Updated] (FLINK-28405) Update Confluent Platform images to v7.2.2

2022-10-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-28405: --- Description: We have updated the used Kafka Clients to v3.1.1 via FLINK-28060 and then to v

[jira] [Created] (FLINK-29514) Bump Minikdc to v3.2.4

2022-10-05 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-29514: -- Summary: Bump Minikdc to v3.2.4 Key: FLINK-29514 URL: https://issues.apache.org/jira/browse/FLINK-29514 Project: Flink Issue Type: Technical Debt

[GitHub] [flink] MartijnVisser opened a new pull request, #20973: [FLINK-29514][Deployment/YARN] Bump Minikdc to v3.2.4

2022-10-05 Thread GitBox
MartijnVisser opened a new pull request, #20973: URL: https://github.com/apache/flink/pull/20973 ## What is the purpose of the change * Bump Minikdc to v3.2.4 to avoid getting falsely flagged as vulnerable for CVEs which don't impact Flink ## Brief change log * Updated d

[jira] [Updated] (FLINK-29514) Bump Minikdc to v3.2.4

2022-10-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29514: --- Labels: pull-request-available (was: ) > Bump Minikdc to v3.2.4 > -- >

[GitHub] [flink] flinkbot commented on pull request #20973: [FLINK-29514][Deployment/YARN] Bump Minikdc to v3.2.4

2022-10-05 Thread GitBox
flinkbot commented on PR #20973: URL: https://github.com/apache/flink/pull/20973#issuecomment-1269046874 ## CI report: * 133d24a675cc24dc6aab61d50165f96f469c4daa UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] leletan commented on a diff in pull request #20852: [FLINK-27101][checkpointing][rest] Add restful API to trigger checkpoints

2022-10-05 Thread GitBox
leletan commented on code in PR #20852: URL: https://github.com/apache/flink/pull/20852#discussion_r988441596 ## flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointTriggerInfo.java: ## @@ -0,0 +1,78 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] leletan commented on a diff in pull request #20852: [FLINK-27101][checkpointing][rest] Add restful API to trigger checkpoints

2022-10-05 Thread GitBox
leletan commented on code in PR #20852: URL: https://github.com/apache/flink/pull/20852#discussion_r988446731 ## flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointTriggerInfo.java: ## @@ -0,0 +1,78 @@ +/* + * Licensed to the Apache Software

[jira] [Created] (FLINK-29515) Document KafkaSource behavior with deleted topics

2022-10-05 Thread Mason Chen (Jira)
Mason Chen created FLINK-29515: -- Summary: Document KafkaSource behavior with deleted topics Key: FLINK-29515 URL: https://issues.apache.org/jira/browse/FLINK-29515 Project: Flink Issue Type: Imp

[GitHub] [flink] cun8cun8 closed pull request #20944: [FLINK-29352]Support CONVERT_TZ built-in function in Table API

2022-10-05 Thread GitBox
cun8cun8 closed pull request #20944: [FLINK-29352]Support CONVERT_TZ built-in function in Table API URL: https://github.com/apache/flink/pull/20944 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to th

[jira] [Updated] (FLINK-29352) Support CONVERT_TZ built-in function in Table API

2022-10-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29352: --- Labels: pull-request-available (was: ) > Support CONVERT_TZ built-in function in Table API

[GitHub] [flink] cun8cun8 opened a new pull request, #20974: [FLINK-29352]Support CONVERT_TZ built-in function in Table API

2022-10-05 Thread GitBox
cun8cun8 opened a new pull request, #20974: URL: https://github.com/apache/flink/pull/20974 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them o

[GitHub] [flink] flinkbot commented on pull request #20974: [FLINK-29352]Support CONVERT_TZ built-in function in Table API

2022-10-05 Thread GitBox
flinkbot commented on PR #20974: URL: https://github.com/apache/flink/pull/20974#issuecomment-1269188146 ## CI report: * e9749eb63f7486bb37f5b0ba7286123c21aae9a5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

  1   2   >