[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

[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

[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

[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

[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

[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

[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:

[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:

[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

[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

[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:

[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=17545674#comment-17545674 ] Ben Carlton commented on FLINK-27887: - [~mvis...@pivotal.io] No error messages, just never connects

[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=17545668#comment-17545668 ] Mason Chen commented on FLINK-27762: Hi [~renqs], I also recently encountered a similar issue

[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=17545660#comment-17545660 ] Martijn Visser commented on FLINK-27887: [~carlton.ibm] Do you have any error message or more

[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

[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

[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

[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

[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=17545583#comment-17545583 ] Martijn Visser commented on FLINK-27872: [~renqs] What do you think? > Allow KafkaBuilder to

[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=results -- This is

[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

[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=17545519#comment-17545519 ] Martijn Visser commented on FLINK-27886: [~chesnay] any thoughts on this? > Error way for

[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,

[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=17545516#comment-17545516 ] Ran Tao commented on FLINK-27886: - [~gaoyunhaii][~jark] Hi, gaoyun, jark, can u help me to review this

[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=17545516#comment-17545516 ] Ran Tao edited comment on FLINK-27886 at 6/2/22 3:24 PM: - [~gaoyunhaii], [~jark]

[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

[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,

[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,

[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:

[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=17545506#comment-17545506 ] Ryan Skraba commented on FLINK-27885: - Can you assign this to me please? > [JUnit5 Migration]

[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

[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

[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

[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=17545486#comment-17545486 ] Etienne Chauchot commented on FLINK-27884: -- [~chesnay] As discussed in [this

[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

[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 @@

[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=17545471#comment-17545471 ] Martijn Visser commented on FLINK-27881: [~syhily] Any thoughts on this? > The key(String) in

[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

[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 @@

[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=17545453#comment-17545453 ] Huang Xingbo commented on FLINK-27756: -- another instance

[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 >

[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=17545450#comment-17545450 ] Huang Xingbo commented on FLINK-27883: -- cc [~renqs] > KafkaSubscriberTest failed with NPC >

[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

[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:

[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:

[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=17545443#comment-17545443 ] Huang Xingbo commented on FLINK-27791: --

[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

[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=17545442#comment-17545442 ] Huang Xingbo commented on FLINK-27869: --

[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

[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=17545439#comment-17545439 ] Huang Xingbo commented on FLINK-26721: --

[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:

[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=17545434#comment-17545434 ] Yuri Gusev edited comment on FLINK-24229 at 6/2/22 11:51 AM: - Thanks

[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=17545434#comment-17545434 ] Yuri Gusev commented on FLINK-24229: Thanks [~dannycranmer]. We fixed most of the comments, there

[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,

[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 @@

[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

[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

[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=17545404#comment-17545404 ] Robert Metzger commented on FLINK-27721: flink-slack.org sounds good! Would be nice if you could

[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=17545393#comment-17545393 ] liangxiaokun edited comment on FLINK-23721 at 6/2/22 10:08 AM: --- Hello! I

[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=17545393#comment-17545393 ] liangxiaokun commented on FLINK-23721: -- Hello! I have the same question with [~lmagics] In my main

[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:

[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=17545390#comment-17545390 ] Salva edited comment on FLINK-27872 at 6/2/22 10:02 AM: Based on a quick

[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 @@

[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=17545390#comment-17545390 ] Salva commented on FLINK-27872: --- Based on a quick experiment, it seems that using a custom subscriber

[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

[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,

[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

[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

[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

[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

[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

[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:

[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

[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

[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

  1   2   >