[jira] [Updated] (FLINK-27889) Error when the LastReconciledSpec is null

2022-06-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27889: --- Labels: pull-request-available (was: ) > Error when the LastReconciledSpec is null > --

[GitHub] [flink-kubernetes-operator] Miuler opened a new pull request, #252: [FLINK-27889] fix: Catch the error when last reconciled spec is null

2022-06-02 Thread GitBox
Miuler opened a new pull request, #252: URL: https://github.com/apache/flink-kubernetes-operator/pull/252 [[](https://github.com/apache/flink-kubernetes-operator/commit/1f47f33485f0af8d1367b55b98dccbe12db452c2)[FLINK-27889](https://issues.apache.org/jira/browse/FLINK-27889)[] fix: Catch the

[jira] [Updated] (FLINK-27889) Error when the LastReconciledSpec is null

2022-06-02 Thread Hector Miuler Malpica Gallegos (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hector Miuler Malpica Gallegos updated FLINK-27889: --- Description: My FlinkDeployment was left with erros, when he

[jira] [Updated] (FLINK-27889) Error when the LastReconciledSpec is null

2022-06-02 Thread Hector Miuler Malpica Gallegos (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hector Miuler Malpica Gallegos updated FLINK-27889: --- Attachment: scratch_7.json > Error when the LastReconciledSp

[jira] [Updated] (FLINK-27889) Error when the LastReconciledSpec is null

2022-06-02 Thread Hector Miuler Malpica Gallegos (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hector Miuler Malpica Gallegos updated FLINK-27889: --- Description: My FlinkDeployment was left with erros, when he

[jira] [Updated] (FLINK-27889) Error when the LastReconciledSpec is null

2022-06-02 Thread Hector Miuler Malpica Gallegos (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hector Miuler Malpica Gallegos updated FLINK-27889: --- Description: My FlinkDeployment was left with erros, when he

[jira] [Created] (FLINK-27889) Error when the LastReconciledSpec is null

2022-06-02 Thread Hector Miuler Malpica Gallegos (Jira)
Hector Miuler Malpica Gallegos created FLINK-27889: -- Summary: Error when the LastReconciledSpec is null Key: FLINK-27889 URL: https://issues.apache.org/jira/browse/FLINK-27889 Project:

[jira] [Updated] (FLINK-27888) SQL Error in Flink1.15

2022-06-02 Thread songwenbin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] songwenbin updated FLINK-27888: --- Docs Text: In Flink1.15 1. put attachment jar to directory: ./flink-release-1.15/build-target/lib/

[jira] [Updated] (FLINK-27888) SQL Error in Flink1.15

2022-06-02 Thread songwenbin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] songwenbin updated FLINK-27888: --- Docs Text: In Flink1.15 1. put attachment jar to directory: ./flink-release-1.15/build-target/lib/

[jira] [Updated] (FLINK-27888) SQL Error in Flink1.15

2022-06-02 Thread songwenbin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] songwenbin updated FLINK-27888: --- Summary: SQL Error in Flink1.15 (was: Flink SQL execute error in Flink1.15) > SQL Error in Flink1.1

[jira] [Created] (FLINK-27888) Flink SQL execute error in Flink1.15

2022-06-02 Thread songwenbin (Jira)
songwenbin created FLINK-27888: -- Summary: Flink SQL execute error in Flink1.15 Key: FLINK-27888 URL: https://issues.apache.org/jira/browse/FLINK-27888 Project: Flink Issue Type: Bug Co

[jira] [Closed] (FLINK-27875) Introduce TableScan and TableRead as an abstraction layer above FileStore for reading RowData

2022-06-02 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-27875. Fix Version/s: table-store-0.2.0 Assignee: Caizhi Weng Resolution: Fixed master:

[GitHub] [flink-table-store] JingsongLi merged pull request #145: [FLINK-27875] Introduce TableScan and TableRead as an abstraction layer above FileStore for reading RowData

2022-06-02 Thread GitBox
JingsongLi merged PR #145: URL: https://github.com/apache/flink-table-store/pull/145 -- 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] luoyuxia commented on pull request #18958: [FLINK-15854][hive] Use the new type inference for Hive UDTF

2022-06-02 Thread GitBox
luoyuxia commented on PR #18958: URL: https://github.com/apache/flink/pull/18958#issuecomment-1145440808 @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-27887) Unable to access https://nightlies.apache.org/flink/

2022-06-02 Thread Ben Carlton (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545674#comment-17545674 ] Ben Carlton commented on FLINK-27887: - [~mvis...@pivotal.io] No error messages, just

[jira] [Commented] (FLINK-27762) Kafka WakeupException during handling splits changes

2022-06-02 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545668#comment-17545668 ] Mason Chen commented on FLINK-27762: Hi [~renqs], I also recently encountered a simi

[jira] [Updated] (FLINK-27887) Unable to access https://nightlies.apache.org/flink/

2022-06-02 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-27887: --- Priority: Major (was: Blocker) > Unable to access https://nightlies.apache.org/flink/ > ---

[jira] [Commented] (FLINK-27887) Unable to access https://nightlies.apache.org/flink/

2022-06-02 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545660#comment-17545660 ] Martijn Visser commented on FLINK-27887: [~carlton.ibm] Do you have any error me

[GitHub] [flink] snuyanzin commented on pull request #19870: [FLINK-27882][tests][table] Migrate flink-scala to JUnit5

2022-06-02 Thread GitBox
snuyanzin commented on PR #19870: URL: https://github.com/apache/flink/pull/19870#issuecomment-1145303034 The PR is based on PR/commit https://github.com/apache/flink/pull/19780 migrating `TypeSerializerUpgradeTestBaseё` to JUnit5 -- This is an automated message from the Apache Git Servic

[jira] [Created] (FLINK-27887) Unable to access https://nightlies.apache.org/flink/

2022-06-02 Thread Ben Carlton (Jira)
Ben Carlton created FLINK-27887: --- Summary: Unable to access https://nightlies.apache.org/flink/ Key: FLINK-27887 URL: https://issues.apache.org/jira/browse/FLINK-27887 Project: Flink Issue Type

[jira] [Updated] (FLINK-27887) Unable to access https://nightlies.apache.org/flink/

2022-06-02 Thread Ben Carlton (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Carlton updated FLINK-27887: Description: My organization is unable to access nightlies.apache.org/flink We believe we may hav

[jira] [Updated] (FLINK-27887) Unable to access https://nightlies.apache.org/flink/

2022-06-02 Thread Ben Carlton (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Carlton updated FLINK-27887: Labels: important (was: ) > Unable to access https://nightlies.apache.org/flink/ > --

[GitHub] [flink] snuyanzin commented on pull request #19870: [FLINK-27882][tests][table] Migrate flink-scala to JUnit5

2022-06-02 Thread GitBox
snuyanzin commented on PR #19870: URL: https://github.com/apache/flink/pull/19870#issuecomment-1145189697 @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-27872) Allow KafkaBuilder to set arbitrary subscribers

2022-06-02 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545583#comment-17545583 ] Martijn Visser commented on FLINK-27872: [~renqs] What do you think? > Allow Ka

[GitHub] [flink] afedulov commented on pull request #19286: [FLINK-25931] Add projection pushdown support for CsvFormatFactory

2022-06-02 Thread GitBox
afedulov commented on PR #19286: URL: https://github.com/apache/flink/pull/19286#issuecomment-1145107709 @godfreyhe thanks for the feedback. > I find there is no any difference of the json node after deserialized from the message between changing the csvSchema or not. See the debug info

[GitHub] [flink] afedulov commented on pull request #19856: [FLINK-27854][tests] Refactor FlinkImageBuilder and FlinkContainerBuilder

2022-06-02 Thread GitBox
afedulov commented on PR #19856: URL: https://github.com/apache/flink/pull/19856#issuecomment-1145055445 @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] afedulov commented on pull request #19856: [FLINK-27854][tests] Refactor FlinkImageBuilder and FlinkContainerBuilder

2022-06-02 Thread GitBox
afedulov commented on PR #19856: URL: https://github.com/apache/flink/pull/19856#issuecomment-1145055226 There seem to be some flakiness in Pulsar tests. The same commit passed in my branch CI: https://dev.azure.com/alexanderfedulov/Flink/_build/results?buildId=291&view=results -- This

[GitHub] [flink] godfreyhe commented on pull request #19286: [FLINK-25931] Add projection pushdown support for CsvFormatFactory

2022-06-02 Thread GitBox
godfreyhe commented on PR #19286: URL: https://github.com/apache/flink/pull/19286#issuecomment-1145020743 > @AHeise I am not sure that the proposed alternative approach makes things much easier. I personally find the implementation of the projection specification as an array of arrays somew

[jira] [Commented] (FLINK-27886) Error way for skipping shade plugin in sub-modules

2022-06-02 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545519#comment-17545519 ] Martijn Visser commented on FLINK-27886: [~chesnay] any thoughts on this? > Err

[jira] [Updated] (FLINK-27886) Error way for skipping shade plugin in sub-modules

2022-06-02 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-27886: Description: Currently in some sub-modules, for example, flink-quickstart-java flink-quickstart-scala, f

[jira] [Commented] (FLINK-27886) Error way for skipping shade plugin in sub-modules

2022-06-02 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545516#comment-17545516 ] Ran Tao commented on FLINK-27886: - [~gaoyunhaii][~jark] Hi, gaoyun, jark, can u help me

[jira] [Comment Edited] (FLINK-27886) Error way for skipping shade plugin in sub-modules

2022-06-02 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545516#comment-17545516 ] Ran Tao edited comment on FLINK-27886 at 6/2/22 3:24 PM: - [~gaoy

[GitHub] [flink] flinkbot commented on pull request #19871: [FLINK-27886][pom] Fix the error way for skipping shade plugin in sub-modules

2022-06-02 Thread GitBox
flinkbot commented on PR #19871: URL: https://github.com/apache/flink/pull/19871#issuecomment-1144992312 ## CI report: * 4e65649614e328b185312aad386b77a0bd348abd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Assigned] (FLINK-25931) Add projection pushdown support for CsvFormatFactory

2022-06-02 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25931: -- Assignee: Alexander Fedulov > Add projection pushdown support for CsvFormatFactory >

[jira] [Assigned] (FLINK-27871) Configuration change is undedected on config removal

2022-06-02 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-27871: -- Assignee: Matyas Orhidi > Configuration change is undedected on config removal >

[jira] [Updated] (FLINK-27886) Error way for skipping shade plugin in sub-modules

2022-06-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27886: --- Labels: pull-request-available (was: ) > Error way for skipping shade plugin in sub-modules

[GitHub] [flink] chucheng92 opened a new pull request, #19871: [FLINK-27886][pom] Fix the error way for skipping shade plugin in sub-modules

2022-06-02 Thread GitBox
chucheng92 opened a new pull request, #19871: URL: https://github.com/apache/flink/pull/19871 ## What is the purpose of the change Fix the error way for skipping shade plugin in sub-modules, e.g. flink-quickstart, flink-walkthroughs ## Brief change log Fix the error way

[jira] [Updated] (FLINK-27886) Error way for skipping shade plugin in sub-modules

2022-06-02 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-27886: Description: Currently in some sub-modules, for example, flink-quickstart-java flink-quickstart-scala, f

[jira] [Updated] (FLINK-27886) Error way for skipping shade plugin in sub-modules

2022-06-02 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-27886: Description: Currently in some sub-modules, for example, flink-quickstart-java flink-quickstart-scala, f

[jira] [Updated] (FLINK-27886) Error way for skipping shade plugin in sub-modules

2022-06-02 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-27886: Attachment: screenshot-2.png > Error way for skipping shade plugin in sub-modules > --

[jira] [Updated] (FLINK-27886) Error way for skipping shade plugin in sub-modules

2022-06-02 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-27886: Attachment: screenshot-1.png > Error way for skipping shade plugin in sub-modules > --

[jira] [Created] (FLINK-27886) Error way for skipping shade plugin in sub-modules

2022-06-02 Thread Ran Tao (Jira)
Ran Tao created FLINK-27886: --- Summary: Error way for skipping shade plugin in sub-modules Key: FLINK-27886 URL: https://issues.apache.org/jira/browse/FLINK-27886 Project: Flink Issue Type: Improvem

[jira] [Commented] (FLINK-27885) [JUnit5 Migration] Module: flink-csv

2022-06-02 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545506#comment-17545506 ] Ryan Skraba commented on FLINK-27885: - Can you assign this to me please? > [JUnit5

[jira] [Created] (FLINK-27885) [JUnit5 Migration] Module: flink-csv

2022-06-02 Thread Ryan Skraba (Jira)
Ryan Skraba created FLINK-27885: --- Summary: [JUnit5 Migration] Module: flink-csv Key: FLINK-27885 URL: https://issues.apache.org/jira/browse/FLINK-27885 Project: Flink Issue Type: Sub-task

[GitHub] [flink] luoyuxia commented on pull request #18958: [FLINK-15854][hive] Use the new type inference for Hive UDTF

2022-06-02 Thread GitBox
luoyuxia commented on PR #18958: URL: https://github.com/apache/flink/pull/18958#issuecomment-1144930976 @wuchong We haven't enabled the CI test for Hive 3.x. Usually I wiil run the test in my local manually for Hive 3.x with command `mvn test -Phive-3.1.1` -- This is an automated messa

[GitHub] [flink] luoyuxia commented on a diff in pull request #18958: [FLINK-15854][hive] Use the new type inference for Hive UDTF

2022-06-02 Thread GitBox
luoyuxia commented on code in PR #18958: URL: https://github.com/apache/flink/pull/18958#discussion_r888006464 ## flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/TableEnvHiveConnectorITCase.java: ## @@ -288,6 +290,15 @@ public void testUDTF()

[GitHub] [flink] luoyuxia commented on a diff in pull request #18958: [FLINK-15854][hive] Use the new type inference for Hive UDTF

2022-06-02 Thread GitBox
luoyuxia commented on code in PR #18958: URL: https://github.com/apache/flink/pull/18958#discussion_r888005853 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParserCalcitePlanner.java: ## @@ -2539,9 +2539,9 @@ private Re

[jira] [Commented] (FLINK-27884) Introduce a flush mechanism for OutputFormats

2022-06-02 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545486#comment-17545486 ] Etienne Chauchot commented on FLINK-27884: -- [~chesnay] As discussed in [this PR

[jira] [Created] (FLINK-27884) Introduce a flush mechanism for OutputFormats

2022-06-02 Thread Etienne Chauchot (Jira)
Etienne Chauchot created FLINK-27884: Summary: Introduce a flush mechanism for OutputFormats Key: FLINK-27884 URL: https://issues.apache.org/jira/browse/FLINK-27884 Project: Flink Issue T

[GitHub] [flink] echauchot commented on a diff in pull request #19680: [FLINK-27457] Implement flush() logic in Cassandra output formats

2022-06-02 Thread GitBox
echauchot commented on code in PR #19680: URL: https://github.com/apache/flink/pull/19680#discussion_r887888690 ## flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormatBase.java: ## @@ -17,130 +17,160 @@ pac

[jira] [Updated] (FLINK-27592) WebUI - Status CANCELING not showing in overview

2022-06-02 Thread Peter Schrott (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Schrott updated FLINK-27592: -- Priority: Major (was: Minor) > WebUI - Status CANCELING not showing in overview > ---

[jira] [Commented] (FLINK-27881) The key(String) in PulsarMessageBuilder returns null

2022-06-02 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545471#comment-17545471 ] Martijn Visser commented on FLINK-27881: [~syhily] Any thoughts on this? > The

[GitHub] [flink] wuchong commented on pull request #18958: [FLINK-15854][hive] Use the new type inference for Hive UDTF

2022-06-02 Thread GitBox
wuchong commented on PR #18958: URL: https://github.com/apache/flink/pull/18958#issuecomment-1144858790 I have another question that did we enable the CI test for Hive 3.x? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] wuchong commented on a diff in pull request #18958: [FLINK-15854][hive] Use the new type inference for Hive UDTF

2022-06-02 Thread GitBox
wuchong commented on code in PR #18958: URL: https://github.com/apache/flink/pull/18958#discussion_r887910344 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveFunctionArguments.java: ## @@ -0,0 +1,89 @@ +/* + * Licensed to the Apac

[GitHub] [flink] echauchot commented on a diff in pull request #19680: [FLINK-27457] Implement flush() logic in Cassandra output formats

2022-06-02 Thread GitBox
echauchot commented on code in PR #19680: URL: https://github.com/apache/flink/pull/19680#discussion_r887888690 ## flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormatBase.java: ## @@ -17,130 +17,160 @@ pac

[jira] [Commented] (FLINK-27756) Fix intermittently failing test in AsyncSinkWriterTest.checkLoggedSendTimesAreWithinBounds

2022-06-02 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545453#comment-17545453 ] Huang Xingbo commented on FLINK-27756: -- another instance https://dev.azure.com/apa

[jira] [Updated] (FLINK-27756) Fix intermittently failing test in AsyncSinkWriterTest.checkLoggedSendTimesAreWithinBounds

2022-06-02 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-27756: - Priority: Critical (was: Major) > Fix intermittently failing test in > AsyncSinkWriterTest.che

[jira] [Commented] (FLINK-27883) KafkaSubscriberTest failed with NPC

2022-06-02 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545450#comment-17545450 ] Huang Xingbo commented on FLINK-27883: -- cc [~renqs] > KafkaSubscriberTest failed w

[jira] [Created] (FLINK-27883) KafkaSubscriberTest failed with NPC

2022-06-02 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-27883: Summary: KafkaSubscriberTest failed with NPC Key: FLINK-27883 URL: https://issues.apache.org/jira/browse/FLINK-27883 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot commented on pull request #19870: [FLINK-27882][tests][table] Migrate flink-scala to JUnit5

2022-06-02 Thread GitBox
flinkbot commented on PR #19870: URL: https://github.com/apache/flink/pull/19870#issuecomment-1144792109 ## CI report: * 65bb90423100074cd2aef8ad64075c99a1b735f2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-27882) [JUnit5 Migration] Module: flink-scala

2022-06-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27882: --- Labels: pull-request-available (was: ) > [JUnit5 Migration] Module: flink-scala > -

[GitHub] [flink] snuyanzin opened a new pull request, #19870: [FLINK-27882][tests][table] Migrate flink-scala to JUnit5

2022-06-02 Thread GitBox
snuyanzin opened a new pull request, #19870: URL: https://github.com/apache/flink/pull/19870 ## What is the purpose of the change Update the flink-scala module to AssertJ and JUnit 5 following the [JUnit 5 Migration Guide](https://docs.google.com/document/d/1514Wa_aNB9bJUen4xm5uiuXOo

[jira] [Closed] (FLINK-27630) maven-source-plugin for table planner values connector for debug

2022-06-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-27630. --- Fix Version/s: 1.16.0 Assignee: jackylau Resolution: Fixed Fixed in master: 5493a386ae4f3cfb

[GitHub] [flink] wuchong merged pull request #19746: [FLINK-27630][table-planner] Add maven-source-plugin for table planne…

2022-06-02 Thread GitBox
wuchong merged PR #19746: URL: https://github.com/apache/flink/pull/19746 -- 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.apach

[jira] [Commented] (FLINK-27791) SlotCountExceedingParallelismTest tests failed with NoResourceAvailableException

2022-06-02 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545443#comment-17545443 ] Huang Xingbo commented on FLINK-27791: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] snuyanzin commented on pull request #18601: [FLINK-25699][table] Use HashMap for MAP value constructors

2022-06-02 Thread GitBox
snuyanzin commented on PR #18601: URL: https://github.com/apache/flink/pull/18601#issuecomment-1144786922 @MartijnVisser , @twalthr sorry for the poke. Since the PR has been already approved, could you please help with merging this? -- This is an automated message from the Apache Git S

[jira] [Commented] (FLINK-27869) AdaptiveSchedulerITCase. testStopWithSavepointFailOnStop failed with FAIL_ON_CHECKPOINT_COMPLETE

2022-06-02 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545442#comment-17545442 ] Huang Xingbo commented on FLINK-27869: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-27869) AdaptiveSchedulerITCase. testStopWithSavepointFailOnStop failed with FAIL_ON_CHECKPOINT_COMPLETE

2022-06-02 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-27869: - Priority: Critical (was: Major) > AdaptiveSchedulerITCase. testStopWithSavepointFailOnStop fail

[jira] [Commented] (FLINK-26721) PulsarSourceITCase.testSavepoint failed on azure pipeline

2022-06-02 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545439#comment-17545439 ] Huang Xingbo commented on FLINK-26721: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Created] (FLINK-27882) [JUnit5 Migration] Module: flink-scala

2022-06-02 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-27882: --- Summary: [JUnit5 Migration] Module: flink-scala Key: FLINK-27882 URL: https://issues.apache.org/jira/browse/FLINK-27882 Project: Flink Issue Type: Sub-

[jira] [Comment Edited] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

2022-06-02 Thread Yuri Gusev (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545434#comment-17545434 ] Yuri Gusev edited comment on FLINK-24229 at 6/2/22 11:51 AM: -

[jira] [Commented] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

2022-06-02 Thread Yuri Gusev (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545434#comment-17545434 ] Yuri Gusev commented on FLINK-24229: Thanks [~dannycranmer]. We fixed most of the

[jira] [Updated] (FLINK-27872) Allow KafkaBuilder to set arbitrary subscribers

2022-06-02 Thread Salva (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Salva updated FLINK-27872: -- Description: Currently, [KafkaSourceBuilder|https://github.com/apache/flink/blob/master/flink-connectors/flin

[GitHub] [flink] echauchot commented on a diff in pull request #19680: [FLINK-27457] Implement flush() logic in Cassandra output formats

2022-06-02 Thread GitBox
echauchot commented on code in PR #19680: URL: https://github.com/apache/flink/pull/19680#discussion_r887784305 ## flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormatBase.java: ## @@ -17,130 +17,160 @@ pac

[GitHub] [flink] flinkbot commented on pull request #19869: [FLINK-21996][python] Support Kinesis connector in Python DataStream API

2022-06-02 Thread GitBox
flinkbot commented on PR #19869: URL: https://github.com/apache/flink/pull/19869#issuecomment-1144750309 ## CI report: * 1e0b00790175a9fbd9a6ec043b69a30f55c9473d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] pengmide opened a new pull request, #19869: [FLINK-21996][python] Support Kinesis connector in Python DataStream API

2022-06-02 Thread GitBox
pengmide opened a new pull request, #19869: URL: https://github.com/apache/flink/pull/19869 ## What is the purpose of the change Support Kinesis connector in Python DataStream API ## Brief change log - Introduces the `KinesisConsumer` and `KinesisSink` to support sourc

[jira] [Created] (FLINK-27881) The key(String) in PulsarMessageBuilder returns null

2022-06-02 Thread Shuiqiang Chen (Jira)
Shuiqiang Chen created FLINK-27881: -- Summary: The key(String) in PulsarMessageBuilder returns null Key: FLINK-27881 URL: https://issues.apache.org/jira/browse/FLINK-27881 Project: Flink Issu

[jira] [Commented] (FLINK-27721) Slack: set up archive

2022-06-02 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545404#comment-17545404 ] Robert Metzger commented on FLINK-27721: flink-slack.org sounds good! Would be n

[GitHub] [flink] flinkbot commented on pull request #19868: [FLINK-12398][table] Support partitioned view in catalog API

2022-06-02 Thread GitBox
flinkbot commented on PR #19868: URL: https://github.com/apache/flink/pull/19868#issuecomment-1144684661 ## CI report: * c60564e99454778f2ecf768ac13c0cd02d2a551f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Comment Edited] (FLINK-23721) Flink SQL state TTL has no effect when using non-incremental RocksDBStateBackend

2022-06-02 Thread liangxiaokun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545393#comment-17545393 ] liangxiaokun edited comment on FLINK-23721 at 6/2/22 10:08 AM: ---

[jira] [Commented] (FLINK-23721) Flink SQL state TTL has no effect when using non-incremental RocksDBStateBackend

2022-06-02 Thread liangxiaokun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545393#comment-17545393 ] liangxiaokun commented on FLINK-23721: -- Hello! I have the same question with [~lmag

[jira] [Updated] (FLINK-12398) Support partitioned view in catalog API

2022-06-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12398: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was: auto

[GitHub] [flink] luoyuxia opened a new pull request, #19868: [FLINK-12398][table] Support partitioned view in catalog API

2022-06-02 Thread GitBox
luoyuxia opened a new pull request, #19868: URL: https://github.com/apache/flink/pull/19868 ## What is the purpose of the change To support partitioned view in catalog API. ## Brief change log - Move method `isPartitioned ` and `getPartitionKeys ` from `CatalogTable `

[jira] [Comment Edited] (FLINK-27872) Allow KafkaBuilder to set arbitrary subscribers

2022-06-02 Thread Salva (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545390#comment-17545390 ] Salva edited comment on FLINK-27872 at 6/2/22 10:02 AM: Based on

[GitHub] [flink] echauchot commented on a diff in pull request #19680: [FLINK-27457] Implement flush() logic in Cassandra output formats

2022-06-02 Thread GitBox
echauchot commented on code in PR #19680: URL: https://github.com/apache/flink/pull/19680#discussion_r887784305 ## flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormatBase.java: ## @@ -17,130 +17,160 @@ pac

[jira] [Commented] (FLINK-27872) Allow KafkaBuilder to set arbitrary subscribers

2022-06-02 Thread Salva (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17545390#comment-17545390 ] Salva commented on FLINK-27872: --- Based on a quick experiment, it seems that using a custom

[jira] [Updated] (FLINK-23721) Flink SQL state TTL has no effect when using non-incremental RocksDBStateBackend

2022-06-02 Thread liangxiaokun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liangxiaokun updated FLINK-23721: - Attachment: image-2022-06-02-17-59-38-542.png > Flink SQL state TTL has no effect when using non

[jira] [Updated] (FLINK-27872) Allow KafkaBuilder to set arbitrary subscribers

2022-06-02 Thread Salva (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Salva updated FLINK-27872: -- Description: Currently, [KafkaBuilder|https://github.com/apache/flink/blob/master/flink-connectors/flink-conn

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #145: [FLINK-27875] Introduce TableScan and TableRead as an abstraction layer above FileStore for reading RowData

2022-06-02 Thread GitBox
JingsongLi commented on code in PR #145: URL: https://github.com/apache/flink-table-store/pull/145#discussion_r887754365 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/table/AppendOnlyFileStoreTable.java: ## @@ -0,0 +1,98 @@ +/* + * Licensed to the Apache S

[jira] [Assigned] (FLINK-27877) Improve performance of several feature engineering algorithms

2022-06-02 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang reassigned FLINK-27877: - Assignee: Zhipeng Zhang > Improve performance of several feature engineering algorithms

[jira] [Updated] (FLINK-27879) Translate the "Documentation Style Guide" page into Chinese

2022-06-02 Thread zhenyu xing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhenyu xing updated FLINK-27879: Description: The "Documentation Style Guide" need to be translated in Chinese. Related files:  

[jira] [Assigned] (FLINK-27878) Add Retry Support For Async I/O In DataStream API

2022-06-02 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-27878: -- Assignee: lincoln lee > Add Retry Support For Async I/O In DataStream API > -

[jira] [Created] (FLINK-27880) CI runs keep getting stuck

2022-06-02 Thread Alexander Preuss (Jira)
Alexander Preuss created FLINK-27880: Summary: CI runs keep getting stuck Key: FLINK-27880 URL: https://issues.apache.org/jira/browse/FLINK-27880 Project: Flink Issue Type: Bug Affect

[jira] [Created] (FLINK-27879) Translate the "Documentation Style Guide" page into Chinese

2022-06-02 Thread zhenyu xing (Jira)
zhenyu xing created FLINK-27879: --- Summary: Translate the "Documentation Style Guide" page into Chinese Key: FLINK-27879 URL: https://issues.apache.org/jira/browse/FLINK-27879 Project: Flink Is

[GitHub] [flink] flinkbot commented on pull request #19867: Flink 12398

2022-06-02 Thread GitBox
flinkbot commented on PR #19867: URL: https://github.com/apache/flink/pull/19867#issuecomment-1144597561 ## CI report: * 47f4d4188ea333adb40576529a5426354f98cbc9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] luoyuxia opened a new pull request, #19867: Flink 12398

2022-06-02 Thread GitBox
luoyuxia opened a new pull request, #19867: URL: https://github.com/apache/flink/pull/19867 ## 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

[jira] [Created] (FLINK-27878) Add Retry Support For Async I/O In DataStream API

2022-06-02 Thread lincoln lee (Jira)
lincoln lee created FLINK-27878: --- Summary: Add Retry Support For Async I/O In DataStream API Key: FLINK-27878 URL: https://issues.apache.org/jira/browse/FLINK-27878 Project: Flink Issue Type: N

[GitHub] [flink-table-store] tsreaper commented on a diff in pull request #145: [FLINK-27875] Introduce TableScan and TableRead as an abstraction layer above FileStore for reading RowData

2022-06-02 Thread GitBox
tsreaper commented on code in PR #145: URL: https://github.com/apache/flink-table-store/pull/145#discussion_r887672733 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/table/AppendOnlyFileStoreTable.java: ## @@ -0,0 +1,98 @@ +/* + * Licensed to the Apache Sof

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #145: [FLINK-27875] Introduce TableScan and TableRead as an abstraction layer above FileStore for reading RowData

2022-06-02 Thread GitBox
JingsongLi commented on code in PR #145: URL: https://github.com/apache/flink-table-store/pull/145#discussion_r887643249 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/table/source/TableScan.java: ## @@ -0,0 +1,151 @@ +/* + * Licensed to the Apache Software

[jira] [Closed] (FLINK-27720) Slack: Update the project website regarding communication channels

2022-06-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-27720. Resolution: Done Subsumed by FLINK-27722 > Slack: Update the project website regarding communicat

  1   2   >