[jira] [Updated] (FLINK-31051) Introduce `delete` action to support deleting from table

2023-02-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31051: --- Labels: pull-request-available (was: ) > Introduce `delete` action to support deleting from

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #531: [FLINK-31051] Introduce `delete` action to support deleting from table

2023-02-13 Thread via GitHub
JingsongLi commented on code in PR #531: URL: https://github.com/apache/flink-table-store/pull/531#discussion_r1105228777 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/action/AbstractActionBase.java: ## @@ -0,0 +1,67 @@ +/* + * Licensed to t

[jira] [Updated] (FLINK-30433) HiveDialectITCase#testCreateDatabase fails with "Could not execute CREATE DATABASE"

2023-02-13 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-30433: -- Description: {code:java} Feb 14 02:38:16 [ERROR] Tests run: 27, Failures: 0, Errors: 1, Skippe

[jira] [Commented] (FLINK-30433) HiveDialectITCase#testCreateDatabase fails with "Could not execute CREATE DATABASE"

2023-02-13 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688344#comment-17688344 ] Matthias Pohl commented on FLINK-30433: --- {{HiveDialectITCase.testTemporaryFunction

[jira] [Commented] (FLINK-18356) flink-table-planner Exit code 137 returned from process

2023-02-13 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688341#comment-17688341 ] Matthias Pohl commented on FLINK-18356: --- https://dev.azure.com/apache-flink/apache

[jira] [Comment Edited] (FLINK-30965) git-repo-sync doesn't pick up the 2nd-most-recently published Flink version (even though it's still supported) after a new release branch is cut

2023-02-13 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687834#comment-17687834 ] Matthias Pohl edited comment on FLINK-30965 at 2/14/23 7:42 AM: --

[GitHub] [flink] wuchong commented on a diff in pull request #21675: [FLINK-30690][javadocs][spelling] Fix java documentation and some wor…

2023-02-13 Thread via GitHub
wuchong commented on code in PR #21675: URL: https://github.com/apache/flink/pull/21675#discussion_r1105409570 ## pom.xml: ## @@ -1500,6 +1500,8 @@ under the License. flink-formats/flink-avro/src/test/resources/flink_11-kryo_registrations

[jira] [Updated] (FLINK-31046) Provide extra environment variables from field ref

2023-02-13 Thread Tamir Sagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamir Sagi updated FLINK-31046: --- Description: The operator should provide several environment variables that are available only upon

[jira] [Updated] (FLINK-31046) Provide extra environment variables from field ref

2023-02-13 Thread Tamir Sagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamir Sagi updated FLINK-31046: --- Summary: Provide extra environment variables from field ref (was: Support extra environment variabl

[GitHub] [flink] gaoyunhaii commented on a diff in pull request #21736: [FLINK-27518][tests] Refactor migration tests to support version update automatically

2023-02-13 Thread via GitHub
gaoyunhaii commented on code in PR #21736: URL: https://github.com/apache/flink/pull/21736#discussion_r1105396272 ## flink-test-utils-parent/flink-migration-test-utils/src/main/java/org/apache/flink/test/migration/SnapshotGeneratorExecutor.java: ## @@ -0,0 +1,176 @@ +/* + * Lice

[GitHub] [flink] gaoyunhaii commented on a diff in pull request #21736: [FLINK-27518][tests] Refactor migration tests to support version update automatically

2023-02-13 Thread via GitHub
gaoyunhaii commented on code in PR #21736: URL: https://github.com/apache/flink/pull/21736#discussion_r1105395620 ## flink-test-utils-parent/flink-migration-test-utils/README.md: ## @@ -0,0 +1,93 @@ +# Add State Migration Tests + +This module is the tools that helps the state mi

[GitHub] [flink] gaoyunhaii commented on a diff in pull request #21736: [FLINK-27518][tests] Refactor migration tests to support version update automatically

2023-02-13 Thread via GitHub
gaoyunhaii commented on code in PR #21736: URL: https://github.com/apache/flink/pull/21736#discussion_r1105395620 ## flink-test-utils-parent/flink-migration-test-utils/README.md: ## @@ -0,0 +1,93 @@ +# Add State Migration Tests + +This module is the tools that helps the state mi

[GitHub] [flink] gaoyunhaii commented on a diff in pull request #21736: [FLINK-27518][tests] Refactor migration tests to support version update automatically

2023-02-13 Thread via GitHub
gaoyunhaii commented on code in PR #21736: URL: https://github.com/apache/flink/pull/21736#discussion_r1105392422 ## flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java: ## @@ -63,19 +63,11 @@

[jira] [Commented] (FLINK-31055) The dynamic flag of stream graph does not take effect when translating the transformations

2023-02-13 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688331#comment-17688331 ] Lijie Wang commented on FLINK-31055: cc [~JunRuiLi] [~zhuzh]  > The dynamic flag of

[GitHub] [flink] flinkbot commented on pull request #21925: FLINK-31053 : Example Repair the log output format of the CheckpointCoordinator

2023-02-13 Thread via GitHub
flinkbot commented on PR #21925: URL: https://github.com/apache/flink/pull/21925#issuecomment-1429239533 ## CI report: * 8b11d0ac91b6d46cc867b38740e51599399c254e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-31055) The dynamic flag of stream graph does not take effect when translating the transformations

2023-02-13 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-31055: -- Summary: The dynamic flag of stream graph does not take effect when translating the transformations Key: FLINK-31055 URL: https://issues.apache.org/jira/browse/FLINK-31055

[GitHub] [flink] zekai-li commented on a diff in pull request #21675: [FLINK-30690][javadocs][spelling] Fix java documentation and some wor…

2023-02-13 Thread via GitHub
zekai-li commented on code in PR #21675: URL: https://github.com/apache/flink/pull/21675#discussion_r1105384852 ## pom.xml: ## @@ -1500,6 +1500,8 @@ under the License. flink-formats/flink-avro/src/test/resources/flink_11-kryo_registrations

[GitHub] [flink] flinkbot commented on pull request #21924: [FLINK-30975][filesystem][s3] upgrade dependencies to aws sdk v2

2023-02-13 Thread via GitHub
flinkbot commented on PR #21924: URL: https://github.com/apache/flink/pull/21924#issuecomment-1429233915 ## CI report: * 3b3d61a407feeb0b64fac2fe3af9e3e2b1e81974 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-31053) Example Repair the log output format of the CheckpointCoordinator

2023-02-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31053: --- Labels: pull-request-available (was: ) > Example Repair the log output format of the Checkp

[GitHub] [flink] xuzhiwen1255 opened a new pull request, #21925: FLINK-31053 : Example Repair the log output format of the CheckpointCoordinator

2023-02-13 Thread via GitHub
xuzhiwen1255 opened a new pull request, #21925: URL: https://github.com/apache/flink/pull/21925 ## What is the purpose of the change At present, an unexpected situation occurs when trigger ck, and the log output format is incorrect, because the placeholder in the log does not pars

[jira] [Updated] (FLINK-30975) Upgrade aws sdk to v2

2023-02-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30975: --- Labels: pull-request-available (was: ) > Upgrade aws sdk to v2 > - > >

[GitHub] [flink] Samrat002 opened a new pull request, #21924: [FLINK-30975][filesystem][s3] upgrade dependencies to aws sdk v2

2023-02-13 Thread via GitHub
Samrat002 opened a new pull request, #21924: URL: https://github.com/apache/flink/pull/21924 ## What is the purpose of the change Remove usage of aws sdk v1 from flink-s3-base ## Brief change log ## Verifying this change ## Does this pull request poten

[jira] [Reopened] (FLINK-31053) Example Repair the log output format of the CheckpointCoordinator

2023-02-13 Thread xzw0223 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xzw0223 reopened FLINK-31053: - > Example Repair the log output format of the CheckpointCoordinator > --

[jira] [Commented] (FLINK-31007) The code generated by the IF function throws NullPointerException

2023-02-13 Thread xzw0223 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688318#comment-17688318 ] xzw0223 commented on FLINK-31007: - [~lincoln.86xy]  Ok, no problem. > The code generate

[jira] [Commented] (FLINK-31007) The code generated by the IF function throws NullPointerException

2023-02-13 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688316#comment-17688316 ] lincoln lee commented on FLINK-31007: - [~xzw0223] thank you for confirming this issu

[jira] [Closed] (FLINK-31023) Introduce ConfigOption for table store

2023-02-13 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31023. Resolution: Fixed master: 1796d3fa960169649299bb4bdaffac6d3848718e > Introduce ConfigOption for t

[jira] [Created] (FLINK-31054) Flink free to common codegen core shade

2023-02-13 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-31054: Summary: Flink free to common codegen core shade Key: FLINK-31054 URL: https://issues.apache.org/jira/browse/FLINK-31054 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-31032) Supports AND predicate in orc format for table store

2023-02-13 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31032. Fix Version/s: table-store-0.4.0 Assignee: Shammon Resolution: Fixed master: 39e8b

[GitHub] [flink-table-store] JingsongLi merged pull request #527: [FLINK-31032] Supports AND push down for orc format

2023-02-13 Thread via GitHub
JingsongLi merged PR #527: URL: https://github.com/apache/flink-table-store/pull/527 -- 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] zekai-li commented on a diff in pull request #21675: [FLINK-30690][javadocs][spelling] Fix java documentation and some wor…

2023-02-13 Thread via GitHub
zekai-li commented on code in PR #21675: URL: https://github.com/apache/flink/pull/21675#discussion_r1105339358 ## pom.xml: ## @@ -1500,6 +1500,8 @@ under the License. flink-formats/flink-avro/src/test/resources/flink_11-kryo_registrations

[GitHub] [flink] zekai-li commented on a diff in pull request #21675: [FLINK-30690][javadocs][spelling] Fix java documentation and some wor…

2023-02-13 Thread via GitHub
zekai-li commented on code in PR #21675: URL: https://github.com/apache/flink/pull/21675#discussion_r1105338820 ## pom.xml: ## @@ -1500,6 +1500,8 @@ under the License. flink-formats/flink-avro/src/test/resources/flink_11-kryo_registrations

[jira] [Commented] (FLINK-30917) The user configured max parallelism does not take effect when using adaptive batch scheduler

2023-02-13 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688303#comment-17688303 ] Lijie Wang commented on FLINK-30917: master: b3998324b685afc779954f7e54cc0d8f281267e

[jira] [Closed] (FLINK-31053) Example Repair the log output format of the CheckpointCoordinator

2023-02-13 Thread xzw0223 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xzw0223 closed FLINK-31053. --- Resolution: Fixed > Example Repair the log output format of the CheckpointCoordinator >

[jira] [Created] (FLINK-31053) Example Repair the log output format of the CheckpointCoordinator

2023-02-13 Thread xzw0223 (Jira)
xzw0223 created FLINK-31053: --- Summary: Example Repair the log output format of the CheckpointCoordinator Key: FLINK-31053 URL: https://issues.apache.org/jira/browse/FLINK-31053 Project: Flink Issu

[GitHub] [flink] gaoyunhaii commented on a diff in pull request #21736: [FLINK-27518][tests] Refactor migration tests to support version update automatically

2023-02-13 Thread via GitHub
gaoyunhaii commented on code in PR #21736: URL: https://github.com/apache/flink/pull/21736#discussion_r1105309145 ## flink-test-utils-parent/flink-migration-test-utils/README.md: ## @@ -0,0 +1,93 @@ +# Add State Migration Tests + +This module is the tools that helps the state mi

[GitHub] [flink] chucheng92 commented on pull request #21442: [FLINK-30274] Upgrade commons-collections 3.x to commons-collections4

2023-02-13 Thread via GitHub
chucheng92 commented on PR #21442: URL: https://github.com/apache/flink/pull/21442#issuecomment-1429129569 @MartijnVisser I think we can fix it completely. i will fix this and update pr ASAP. Sorry for my mistake. thanks. -- This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-30943) Hide sensitive command-line configurations

2023-02-13 Thread Bo Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688273#comment-17688273 ] Bo Cui commented on FLINK-30943: The jira tries to hidden the value who's separated from

[jira] [Updated] (FLINK-30860) Add document for hybrid shuffle with adaptive batch scheduler

2023-02-13 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-30860: - Fix Version/s: (was: 1.18.0) > Add document for hybrid shuffle with adaptive batch scheduler

[GitHub] [flink] chucheng92 commented on a diff in pull request #21917: [FLINK-31015][connectors/common] Fix SplitReader doesn't extends AutoCloseable but implements close method

2023-02-13 Thread via GitHub
chucheng92 commented on code in PR #21917: URL: https://github.com/apache/flink/pull/21917#discussion_r1105296100 ## flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/splitreader/SplitReader.java: ## @@ -33,7 +33,7 @@ * @param t

[jira] [Commented] (FLINK-31021) JavaCodeSplitter doesn't split static method properly

2023-02-13 Thread Xingcan Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688269#comment-17688269 ] Xingcan Cui commented on FLINK-31021: - [~libenchao] Thanks for the comments. I'm a

[jira] [Comment Edited] (FLINK-24851) KafkaSourceBuilder: auto.offset.reset is ignored

2023-02-13 Thread Salva (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688265#comment-17688265 ] Salva edited comment on FLINK-24851 at 2/14/23 4:10 AM: [~renqs]

[jira] [Comment Edited] (FLINK-24851) KafkaSourceBuilder: auto.offset.reset is ignored

2023-02-13 Thread Salva (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688265#comment-17688265 ] Salva edited comment on FLINK-24851 at 2/14/23 4:09 AM: [~renqs]

[jira] [Comment Edited] (FLINK-24851) KafkaSourceBuilder: auto.offset.reset is ignored

2023-02-13 Thread Salva (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688265#comment-17688265 ] Salva edited comment on FLINK-24851 at 2/14/23 4:08 AM: [~renqs]

[jira] [Commented] (FLINK-24851) KafkaSourceBuilder: auto.offset.reset is ignored

2023-02-13 Thread Salva (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688265#comment-17688265 ] Salva commented on FLINK-24851: --- [~renqs] [~liliwei] [~martijnvisser] What is the current

[GitHub] [flink] fsk119 commented on a diff in pull request #21912: [FLINK-28658][docs] Add docs for job statements

2023-02-13 Thread via GitHub
fsk119 commented on code in PR #21912: URL: https://github.com/apache/flink/pull/21912#discussion_r1105231662 ## docs/content.zh/docs/dev/table/sql/job.md: ## @@ -0,0 +1,96 @@ +--- +title: "JOB Statements" +weight: 16 +type: docs +aliases: +- /dev/table/sql/job.html +--- + + +#

[jira] [Updated] (FLINK-30938) Release Testing: Verify FLINK-29766 Adaptive Batch Scheduler should also work with hybrid shuffle mode

2023-02-13 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-30938: --- Description: The document has not been completed, this testing work should start after FLINK-30860

[jira] [Updated] (FLINK-30938) Release Testing: Verify FLINK-29766 Adaptive Batch Scheduler should also work with hybrid shuffle mode

2023-02-13 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-30938: --- Description: This ticket aims for verifying FLINK-29766: Adaptive Batch Scheduler should also work

[jira] [Updated] (FLINK-30860) Add document for hybrid shuffle with adaptive batch scheduler

2023-02-13 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-30860: --- Description: Add document for hybrid shuffle with adaptive batch scheduler. (was: Add document for

[jira] [Closed] (FLINK-30860) Add document for hybrid shuffle with adaptive batch scheduler

2023-02-13 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-30860. -- Fix Version/s: 1.18.0 Resolution: Fixed > Add document for hybrid shuffle with adaptive batch s

[jira] [Comment Edited] (FLINK-30860) Add document for hybrid shuffle with adaptive batch scheduler

2023-02-13 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688254#comment-17688254 ] Weijie Guo edited comment on FLINK-30860 at 2/14/23 3:25 AM: -

[jira] [Commented] (FLINK-30860) Add document for hybrid shuffle with adaptive batch scheduler

2023-02-13 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688254#comment-17688254 ] Weijie Guo commented on FLINK-30860: master(1.18) via : 5ceda3da20ec5ed50849d89a6297

[GitHub] [flink] wuchong commented on a diff in pull request #21675: [FLINK-30690][javadocs][spelling] Fix java documentation and some wor…

2023-02-13 Thread via GitHub
wuchong commented on code in PR #21675: URL: https://github.com/apache/flink/pull/21675#discussion_r1105249581 ## pom.xml: ## @@ -1500,6 +1500,8 @@ under the License. flink-formats/flink-avro/src/test/resources/flink_11-kryo_registrations

[GitHub] [flink] reswqa closed pull request #21890: [FLINK-30860][doc] Add document for hybrid shuffle with adaptive batch scheduler

2023-02-13 Thread via GitHub
reswqa closed pull request #21890: [FLINK-30860][doc] Add document for hybrid shuffle with adaptive batch scheduler URL: https://github.com/apache/flink/pull/21890 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

[GitHub] [flink] wanglijie95 closed pull request #21861: [FLINK-30917][runtime] Let adaptive batch scheduler also respect the user-configured max parallelism when deciding parallelism

2023-02-13 Thread via GitHub
wanglijie95 closed pull request #21861: [FLINK-30917][runtime] Let adaptive batch scheduler also respect the user-configured max parallelism when deciding parallelism URL: https://github.com/apache/flink/pull/21861 -- This is an automated message from the Apache Git Service. To respond to th

[jira] [Comment Edited] (FLINK-31048) Java doc of PulsarSourceBuilder was not updated in time

2023-02-13 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688250#comment-17688250 ] Weijie Guo edited comment on FLINK-31048 at 2/14/23 3:04 AM: -

[jira] [Closed] (FLINK-31027) Introduce annotation for table store

2023-02-13 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31027. Fix Version/s: table-store-0.4.0 Assignee: Shammon Resolution: Fixed master: 706a9

[jira] [Closed] (FLINK-31048) Java doc of PulsarSourceBuilder was not updated in time

2023-02-13 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-31048. -- Resolution: Fixed master(4.0) via : fb98096d9a67d26b1965b8ef181125317a59a5c4 > Java doc of PulsarSour

[GitHub] [flink] liming30 commented on pull request #21503: [FLINK-30251] Move the IO with DFS during abort checkpoint to an asynchronous thread pool.

2023-02-13 Thread via GitHub
liming30 commented on PR #21503: URL: https://github.com/apache/flink/pull/21503#issuecomment-1429042027 @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-table-store] JingsongLi merged pull request #526: [FLINK-31027] Introduce annotations for table store

2023-02-13 Thread via GitHub
JingsongLi merged PR #526: URL: https://github.com/apache/flink-table-store/pull/526 -- 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...@

[jira] [Updated] (FLINK-31052) Release Testing: Verify FLINK-30707 Improve slow task detection

2023-02-13 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-31052: Description: This task aims to verify [FLINK-30707|https://issues.apache.org/jira/browse/FLINK-30707] whi

[jira] [Updated] (FLINK-31052) Release Testing: Verify FLINK-30707 Improve slow task detection

2023-02-13 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-31052: Priority: Blocker (was: Major) > Release Testing: Verify FLINK-30707 Improve slow task detection > --

[jira] [Created] (FLINK-31052) Release Testing: Verify FLINK-30707 Improve slow task detection

2023-02-13 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-31052: --- Summary: Release Testing: Verify FLINK-30707 Improve slow task detection Key: FLINK-31052 URL: https://issues.apache.org/jira/browse/FLINK-31052 Project: Flink Issue

[GitHub] [flink-connector-pulsar] reswqa closed pull request #28: [FLINK-31048][Connector/Pulsar] Fix incorrect java doc in PulsarSource and PulsarSourceBuilder.

2023-02-13 Thread via GitHub
reswqa closed pull request #28: [FLINK-31048][Connector/Pulsar] Fix incorrect java doc in PulsarSource and PulsarSourceBuilder. URL: https://github.com/apache/flink-connector-pulsar/pull/28 -- This is an automated message from the Apache Git Service. To respond to the message, please log on t

[GitHub] [flink] littlecatjianjiao closed pull request #19745: [Metric]Flink-Metrics pushgateway support authentication

2023-02-13 Thread via GitHub
littlecatjianjiao closed pull request #19745: [Metric]Flink-Metrics pushgateway support authentication URL: https://github.com/apache/flink/pull/19745 -- 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

[jira] [Closed] (FLINK-30961) Remove deprecated tests_require in setup.py

2023-02-13 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-30961. --- Resolution: Fixed Merged to master via e67b141f2b2414cf9b6ddc43e817d4250dd38319 > Remove deprecated tests_r

[GitHub] [flink] dianfu merged pull request #21893: [FLINK-30961][Python] Remove deprecated "tests_require" in setup.py

2023-02-13 Thread via GitHub
dianfu merged PR #21893: URL: https://github.com/apache/flink/pull/21893 -- 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...@flink.apache

[GitHub] [flink-table-store] FangYongs closed pull request #527: [FLINK-31032] Supports AND push down for orc format

2023-02-13 Thread via GitHub
FangYongs closed pull request #527: [FLINK-31032] Supports AND push down for orc format URL: https://github.com/apache/flink-table-store/pull/527 -- 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

[GitHub] [flink-table-store] SteNicholas commented on pull request #527: [FLINK-31032] Supports AND push down for orc format

2023-02-13 Thread via GitHub
SteNicholas commented on PR #527: URL: https://github.com/apache/flink-table-store/pull/527#issuecomment-1429031516 @FangYongs, please reopen the pull request and rerun CI automatically. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Assigned] (FLINK-30961) Remove deprecated tests_require in setup.py

2023-02-13 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-30961: --- Assignee: Juntao Hu > Remove deprecated tests_require in setup.py > ---

[GitHub] [flink] liuyongvs commented on pull request #21909: [FLINK-31006][connector/kafka] Fix noMoreNewPartitionSplits is not se…

2023-02-13 Thread via GitHub
liuyongvs commented on PR #21909: URL: https://github.com/apache/flink/pull/21909#issuecomment-1429031297 @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.

[jira] [Closed] (FLINK-30962) Improve error messaging when launching py4j gateway server

2023-02-13 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-30962. --- Fix Version/s: 1.17.0 1.15.4 1.16.2 (was: 1.18.0

[GitHub] [flink] dianfu closed pull request #21894: [FLINK-30962][Python] Improve error messaging when launching py4j gateway server

2023-02-13 Thread via GitHub
dianfu closed pull request #21894: [FLINK-30962][Python] Improve error messaging when launching py4j gateway server URL: https://github.com/apache/flink/pull/21894 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

[GitHub] [flink-connector-opensearch] lilyevsky commented on pull request #9: Add FailureHandler

2023-02-13 Thread via GitHub
lilyevsky commented on PR #9: URL: https://github.com/apache/flink-connector-opensearch/pull/9#issuecomment-1429027066 @reta The validator did not like the PR title. Not sure what it wants. Could you please fix it? -- This is an automated message from the Apache Git Service. To respond t

[GitHub] [flink-connector-opensearch] lilyevsky opened a new pull request, #9: Dependabot/maven/flink connector opensearch/org.opensearch opensearch 2.5.0

2023-02-13 Thread via GitHub
lilyevsky opened a new pull request, #9: URL: https://github.com/apache/flink-connector-opensearch/pull/9 See comments on https://github.com/apache/flink-connector-opensearch/pull/8 . These are the same changes re-targeted to main branch. -- This is an automated message from the Apache

[GitHub] [flink] xintongsong commented on a diff in pull request #21890: [FLINK-30860][doc] Add document for hybrid shuffle with adaptive batch scheduler

2023-02-13 Thread via GitHub
xintongsong commented on code in PR #21890: URL: https://github.com/apache/flink/pull/21890#discussion_r1105226779 ## docs/content/docs/ops/batch/batch_shuffle.md: ## @@ -112,14 +112,27 @@ Hybrid shuffle provides two spilling strategies: ### Usage -To use hybrid shuffle mod

[jira] [Updated] (FLINK-25813) TableITCase.testCollectWithClose failed on azure

2023-02-13 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-25813: Fix Version/s: 1.17.0 1.16.2 > TableITCase.testCollectWithClose failed on azure

[jira] [Closed] (FLINK-25813) TableITCase.testCollectWithClose failed on azure

2023-02-13 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-25813. --- Resolution: Fixed master: 3a647d6bec7d0413bcbc71668ed45be57bb4bfe6 release-1.17: bb66b989188c661d9d7

[GitHub] [flink-table-store] JingsongLi closed pull request #526: [FLINK-31027] Introduce annotations for table store

2023-02-13 Thread via GitHub
JingsongLi closed pull request #526: [FLINK-31027] Introduce annotations for table store URL: https://github.com/apache/flink-table-store/pull/526 -- 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

[GitHub] [flink] tsreaper merged pull request #21922: [BP-1.16][FLINK-25813][table-planner] Fix unstable test TableITCase#testCollectWithClose

2023-02-13 Thread via GitHub
tsreaper merged PR #21922: URL: https://github.com/apache/flink/pull/21922 -- 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...@flink.apac

[GitHub] [flink] tsreaper merged pull request #18893: [FLINK-25813][table-planner] Fix unstable test TableITCase#testCollectWithClose

2023-02-13 Thread via GitHub
tsreaper merged PR #18893: URL: https://github.com/apache/flink/pull/18893 -- 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...@flink.apac

[GitHub] [flink] tsreaper merged pull request #21921: [BP-1.17][FLINK-25813][table-planner] Fix unstable test TableITCase#testCollectWithClose

2023-02-13 Thread via GitHub
tsreaper merged PR #21921: URL: https://github.com/apache/flink/pull/21921 -- 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...@flink.apac

[GitHub] [flink-table-store] JingsongLi merged pull request #530: [hotfix] Fix options in FlinkSinkBuilder

2023-02-13 Thread via GitHub
JingsongLi merged PR #530: URL: https://github.com/apache/flink-table-store/pull/530 -- 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] zekai-li commented on pull request #21675: [FLINK-30690][javadocs][spelling] Fix java documentation and some wor…

2023-02-13 Thread via GitHub
zekai-li commented on PR #21675: URL: https://github.com/apache/flink/pull/21675#issuecomment-1429008467 @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.

[jira] [Commented] (FLINK-30508) CliClientITCase.testSqlStatements failed with output not matched with expected

2023-02-13 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688237#comment-17688237 ] Shengkai Fang commented on FLINK-30508: --- Sorry for the late response. I have cherr

[jira] [Updated] (FLINK-30508) CliClientITCase.testSqlStatements failed with output not matched with expected

2023-02-13 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-30508: -- Fix Version/s: 1.16.2 > CliClientITCase.testSqlStatements failed with output not matched with

[GitHub] [flink-table-store] FangYongs commented on pull request #530: [hotfix] Fix options in FlinkSinkBuilder

2023-02-13 Thread via GitHub
FangYongs commented on PR #530: URL: https://github.com/apache/flink-table-store/pull/530#issuecomment-1428999855 @JingsongLi The master branch compilation failed, please help to review this hotfix, THX -- This is an automated message from the Apache Git Service. To respond to the messa

[jira] [Created] (FLINK-31051) Introduce `delete` action to support deleting from table

2023-02-13 Thread yuzelin (Jira)
yuzelin created FLINK-31051: --- Summary: Introduce `delete` action to support deleting from table Key: FLINK-31051 URL: https://issues.apache.org/jira/browse/FLINK-31051 Project: Flink Issue Type: Ne

[GitHub] [flink] zekai-li commented on pull request #21675: [FLINK-30690][javadocs][spelling] Fix java documentation and some wor…

2023-02-13 Thread via GitHub
zekai-li commented on PR #21675: URL: https://github.com/apache/flink/pull/21675#issuecomment-1428996963 @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] xuzifu666 commented on pull request #21914: [FLINK-31035] add warn info to user when NoNodeException happend

2023-02-13 Thread via GitHub
xuzifu666 commented on PR #21914: URL: https://github.com/apache/flink/pull/21914#issuecomment-1428992853 @zentol -- 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 unsubs

[GitHub] [flink] fsk119 merged pull request #21896: [FLINK-30640][sql-client] Fix unstable ctas test in CliClientITCase

2023-02-13 Thread via GitHub
fsk119 merged PR #21896: URL: https://github.com/apache/flink/pull/21896 -- 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...@flink.apache

[GitHub] [flink-connector-pulsar] syhily commented on pull request #28: [FLINK-31048][Connector/Pulsar] Fix incorrect java doc in PulsarSource and PulsarSourceBuilder.

2023-02-13 Thread via GitHub
syhily commented on PR #28: URL: https://github.com/apache/flink-connector-pulsar/pull/28#issuecomment-1428988859 TKS, LGTM. -- 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.

[jira] [Created] (FLINK-31050) Supports IN predicate in ORC format of table store

2023-02-13 Thread Nicholas Jiang (Jira)
Nicholas Jiang created FLINK-31050: -- Summary: Supports IN predicate in ORC format of table store Key: FLINK-31050 URL: https://issues.apache.org/jira/browse/FLINK-31050 Project: Flink Issue

[GitHub] [flink-table-store] FangYongs commented on pull request #527: [FLINK-31032] Supports AND push down for orc format

2023-02-13 Thread via GitHub
FangYongs commented on PR #527: URL: https://github.com/apache/flink-table-store/pull/527#issuecomment-1428976841 The test fails due to a known issue https://issues.apache.org/jira/browse/FLINK-31039 -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Closed] (FLINK-30997) Refactor tests in connector to extends AbstractTestBase

2023-02-13 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30997. Fix Version/s: table-store-0.4.0 Assignee: Shammon Resolution: Fixed master: 74cc7

[GitHub] [flink-table-store] JingsongLi merged pull request #512: [FLINK-30997] Refactor tests in connector to extends AbstractTestBase

2023-02-13 Thread via GitHub
JingsongLi merged PR #512: URL: https://github.com/apache/flink-table-store/pull/512 -- 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...@

[jira] [Closed] (FLINK-30979) The buckets of the secondary partition should fall on different tasks

2023-02-13 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30979. Resolution: Fixed master: 219c4de518c419eade41e99fc419d7f2ccfed213 > The buckets of the secondary

[GitHub] [flink-table-store] JingsongLi merged pull request #522: [FLINK-30979] Support shuffling data by partition

2023-02-13 Thread via GitHub
JingsongLi merged PR #522: URL: https://github.com/apache/flink-table-store/pull/522 -- 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] zekai-li commented on pull request #21675: [FLINK-30690][javadocs][spelling] Fix java documentation and some wor…

2023-02-13 Thread via GitHub
zekai-li commented on PR #21675: URL: https://github.com/apache/flink/pull/21675#issuecomment-1428954357 > All right, I'll check this out -- 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 t

[jira] [Commented] (FLINK-31007) The code generated by the IF function throws NullPointerException

2023-02-13 Thread xzw0223 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688219#comment-17688219 ] xzw0223 commented on FLINK-31007: - [~lincoln.86xy]  Yes, the problem is the same, the re

[GitHub] [flink] zekai-li commented on a diff in pull request #21675: [FLINK-30690][javadocs][spelling] Fix java documentation and some wor…

2023-02-13 Thread via GitHub
zekai-li commented on code in PR #21675: URL: https://github.com/apache/flink/pull/21675#discussion_r1105179968 ## pom.xml: ## @@ -1500,6 +1500,8 @@ under the License. flink-formats/flink-avro/src/test/resources/flink_11-kryo_registrations

  1   2   3   4   >