[jira] [Commented] (FLINK-26454) Improve operator logging

2022-03-09 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503572#comment-17503572 ] Nicholas Jiang commented on FLINK-26454: [~gyfora], I would like to start the discussion thread

[jira] [Assigned] (FLINK-26506) Support StreamExecutionEnvironment.registerCachedFile in Python DataStream API

2022-03-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-26506: --- Assignee: Nicholas Jiang > Support StreamExecutionEnvironment.registerCachedFile in Python

[GitHub] [flink] zentol commented on a change in pull request #18987: [FLINK-26494][runtime] Cleanup does not reveal exceptions

2022-03-09 Thread GitBox
zentol commented on a change in pull request #18987: URL: https://github.com/apache/flink/pull/18987#discussion_r822615319 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStore.java ## @@ -165,8 +171,16 @@ public boolean

[GitHub] [flink] flinkbot edited a comment on pull request #19017: [FLINK-26542][hive] fix "schema of both sides of union should match" exception with Hive dialect

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19017: URL: https://github.com/apache/flink/pull/19017#issuecomment-1062742669 ## CI report: * 6c5a21cd9c95112a97ef3195eac68d6e4899616c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19008: [FLINK-26536] [python] Fix PyFlink RemoteKeyedStateBackend#merge_namespaces bugs

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19008: URL: https://github.com/apache/flink/pull/19008#issuecomment-1061583264 ## CI report: * 290c71daa6e7502d0715349a784d43ee27c1c2dd Azure:

[jira] [Closed] (FLINK-26292) FlinkKafkaProducerITCase.testScaleUpAfterScalingDown failed on azure

2022-03-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-26292. --- Resolution: Duplicate > FlinkKafkaProducerITCase.testScaleUpAfterScalingDown failed on azure >

[GitHub] [flink] flinkbot edited a comment on pull request #19017: [FLINK-26542][hive] fix "schema of both sides of union should match" exception with Hive dialect

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19017: URL: https://github.com/apache/flink/pull/19017#issuecomment-1062742669 ## CI report: * 6c5a21cd9c95112a97ef3195eac68d6e4899616c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19016: [BP-1.13][FLINK-26352][runtime-web] Add missing license headers to WebUI source files

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19016: URL: https://github.com/apache/flink/pull/19016#issuecomment-1062691826 ## CI report: * 8f4ac39faeec28c2845831b049a745c119ebd918 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19008: [FLINK-26536] [python] Fix PyFlink RemoteKeyedStateBackend#merge_namespaces bugs

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19008: URL: https://github.com/apache/flink/pull/19008#issuecomment-1061583264 ## CI report: * 290c71daa6e7502d0715349a784d43ee27c1c2dd Azure:

[GitHub] [flink] XComp commented on a change in pull request #18987: [FLINK-26494][runtime] Cleanup does not reveal exceptions

2022-03-09 Thread GitBox
XComp commented on a change in pull request #18987: URL: https://github.com/apache/flink/pull/18987#discussion_r822605578 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/cleanup/DefaultResourceCleaner.java ## @@ -97,8 +104,8 @@ private

[GitHub] [flink] flinkbot edited a comment on pull request #19008: [FLINK-26536] [python] Fix PyFlink RemoteKeyedStateBackend#merge_namespaces bugs

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19008: URL: https://github.com/apache/flink/pull/19008#issuecomment-1061583264 ## CI report: * 290c71daa6e7502d0715349a784d43ee27c1c2dd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19017: [FLINK-26542][hive] fix "schema of both sides of union should match" exception with Hive dialect

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19017: URL: https://github.com/apache/flink/pull/19017#issuecomment-1062742669 ## CI report: * 6c5a21cd9c95112a97ef3195eac68d6e4899616c Azure:

[jira] [Commented] (FLINK-26416) Release Testing: Sink V2 sanity checks

2022-03-09 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503566#comment-17503566 ] Liu commented on FLINK-26416: - [~fpaul], thanks. I have test the three cases and all of them passed. I

[GitHub] [flink] flinkbot edited a comment on pull request #19017: [FLINK-26542][hive] fix "schema of both sides of union should match" exception with Hive dialect

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19017: URL: https://github.com/apache/flink/pull/19017#issuecomment-1062742669 ## CI report: * 6c5a21cd9c95112a97ef3195eac68d6e4899616c Azure:

[GitHub] [flink] matriv commented on a change in pull request #18980: [FLINK-26421] Use only EnvironmentSettings to configure the environment

2022-03-09 Thread GitBox
matriv commented on a change in pull request #18980: URL: https://github.com/apache/flink/pull/18980#discussion_r822599085 ## File path: flink-table/flink-table-api-scala-bridge/src/main/scala/org/apache/flink/table/api/bridge/scala/internal/StreamTableEnvironmentImpl.scala

[GitHub] [flink] XComp commented on a change in pull request #18987: [FLINK-26494][runtime] Cleanup does not reveal exceptions

2022-03-09 Thread GitBox
XComp commented on a change in pull request #18987: URL: https://github.com/apache/flink/pull/18987#discussion_r822596828 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStore.java ## @@ -165,8 +171,16 @@ public boolean

[GitHub] [flink] flinkbot edited a comment on pull request #19017: [FLINK-26542][hive] fix "schema of both sides of union should match" exception with Hive dialect

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19017: URL: https://github.com/apache/flink/pull/19017#issuecomment-1062742669 ## CI report: * 6c5a21cd9c95112a97ef3195eac68d6e4899616c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19017: [FLINK-26542][hive] fix "schema of both sides of union should match" exception with Hive dialect

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19017: URL: https://github.com/apache/flink/pull/19017#issuecomment-1062742669 ## CI report: * 6c5a21cd9c95112a97ef3195eac68d6e4899616c Azure:

[jira] [Commented] (FLINK-23190) Make task-slot allocation much more evenly

2022-03-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503552#comment-17503552 ] Chesnay Schepler commented on FLINK-23190: -- [~loyi] The project is currently occupied with

[jira] [Assigned] (FLINK-26545) Ingress rules should be created in the same namespace with FlinkDeployment CR

2022-03-09 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-26545: - Assignee: Matyas Orhidi > Ingress rules should be created in the same namespace with

[GitHub] [flink] flinkbot edited a comment on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * 57d064b16b3d5864299cb48d6cef678e31d1e4ef Azure:

[jira] [Commented] (FLINK-26545) Ingress rules should be created in the same namespace with FlinkDeployment CR

2022-03-09 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503551#comment-17503551 ] Yang Wang commented on FLINK-26545: --- [~matyas] Great. You have been assigned. > Ingress rules should

[GitHub] [flink] matriv commented on a change in pull request #18980: [FLINK-26421] Use only EnvironmentSettings to configure the environment

2022-03-09 Thread GitBox
matriv commented on a change in pull request #18980: URL: https://github.com/apache/flink/pull/18980#discussion_r822590733 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java ## @@ -311,6 +311,7 @@ public

[jira] [Commented] (FLINK-26528) Trigger the updateControl when the FlinkDeployment have changed

2022-03-09 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503549#comment-17503549 ] Yang Wang commented on FLINK-26528: --- Even though the CR does not change since last reconciliation, we

[GitHub] [flink] XComp commented on a change in pull request #18987: [FLINK-26494][runtime] Cleanup does not reveal exceptions

2022-03-09 Thread GitBox
XComp commented on a change in pull request #18987: URL: https://github.com/apache/flink/pull/18987#discussion_r822589446 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/cleanup/DefaultResourceCleaner.java ## @@ -166,21 +188,49 @@ private

[GitHub] [flink] flinkbot edited a comment on pull request #19017: [FLINK-26542][hive] fix "schema of both sides of union should match" exception with Hive dialect

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19017: URL: https://github.com/apache/flink/pull/19017#issuecomment-1062742669 ## CI report: * 6c5a21cd9c95112a97ef3195eac68d6e4899616c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19022: [FLINK-26550][checkpoint] Correct the information of checkpoint failure

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19022: URL: https://github.com/apache/flink/pull/19022#issuecomment-1062855606 ## CI report: * e2a3ce71c31c2bcc1ac90697f1a08bf4fd0b3c82 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19017: [FLINK-26542][hive] fix "schema of both sides of union should match" exception with Hive dialect

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19017: URL: https://github.com/apache/flink/pull/19017#issuecomment-1062742669 ## CI report: * 6c5a21cd9c95112a97ef3195eac68d6e4899616c Azure:

[GitHub] [flink] flinkbot commented on pull request #19022: [FLINK-26550][checkpoint] Correct the information of checkpoint failure

2022-03-09 Thread GitBox
flinkbot commented on pull request #19022: URL: https://github.com/apache/flink/pull/19022#issuecomment-1062855606 ## CI report: * e2a3ce71c31c2bcc1ac90697f1a08bf4fd0b3c82 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #19017: [FLINK-26542][hive] fix "schema of both sides of union should match" exception with Hive dialect

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19017: URL: https://github.com/apache/flink/pull/19017#issuecomment-1062742669 ## CI report: * 2958fb85fccb9828a523db710cf2fcf1cf88baa3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * a36182858952a61ef43ccbdc184440354bb86110 Azure:

[jira] [Updated] (FLINK-26550) Correct the information of checkpoint failure

2022-03-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26550: --- Labels: pull-request-available (was: ) > Correct the information of checkpoint failure >

[GitHub] [flink] Myasuka opened a new pull request #19022: [FLINK-26550][checkpoint] Correct the information of checkpoint failure

2022-03-09 Thread GitBox
Myasuka opened a new pull request #19022: URL: https://github.com/apache/flink/pull/19022 ## What is the purpose of the change After [FLINK-26049], all failed checkpoint would print message with `Failed to trigger checkpoint...`, this is extremely strange as most failures do

[GitHub] [flink] flinkbot edited a comment on pull request #19021: [hotfix][docs] Clarify semantic of tolerable checkpoint failure number

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19021: URL: https://github.com/apache/flink/pull/19021#issuecomment-1062847721 ## CI report: * 3dd50180ec315c1375a79e0017928dd9e4d37b06 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19017: [FLINK-26542][hive] fix "schema of both sides of union should match" exception with Hive dialect

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19017: URL: https://github.com/apache/flink/pull/19017#issuecomment-1062742669 ## CI report: * 2958fb85fccb9828a523db710cf2fcf1cf88baa3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18976: [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18976: URL: https://github.com/apache/flink/pull/18976#issuecomment-1058916391 ## CI report: * 5613e31a28614dbfe1a3c7109371cac55e93523c Azure:

[GitHub] [flink] flinkbot commented on pull request #19021: [hotfix][docs] Clarify semantic of tolerable checkpoint failure number

2022-03-09 Thread GitBox
flinkbot commented on pull request #19021: URL: https://github.com/apache/flink/pull/19021#issuecomment-1062847721 ## CI report: * 3dd50180ec315c1375a79e0017928dd9e4d37b06 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-26546) Extract Observer Interface

2022-03-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503535#comment-17503535 ] Aitozi commented on FLINK-26546: Get it. > Extract Observer Interface > -- > >

[GitHub] [flink] flinkbot edited a comment on pull request #19017: [FLINK-26542][hive] fix "schema of both sides of union should match" exception with Hive dialect

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19017: URL: https://github.com/apache/flink/pull/19017#issuecomment-1062742669 ## CI report: * 2958fb85fccb9828a523db710cf2fcf1cf88baa3 Azure:

[GitHub] [flink] fapaul commented on a change in pull request #18996: [FLINK-26492][metric] deprecate umRecordsOutErrorsCounter

2022-03-09 Thread GitBox
fapaul commented on a change in pull request #18996: URL: https://github.com/apache/flink/pull/18996#discussion_r822573821 ## File path: flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/SinkMetricsITCase.java ## @@ -147,7 +147,7 @@ private void

[GitHub] [flink] flinkbot edited a comment on pull request #18976: [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18976: URL: https://github.com/apache/flink/pull/18976#issuecomment-1058916391 ## CI report: * 5613e31a28614dbfe1a3c7109371cac55e93523c Azure:

[jira] [Commented] (FLINK-26528) Trigger the updateControl when the FlinkDeployment have changed

2022-03-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503534#comment-17503534 ] Aitozi commented on FLINK-26528: Yes, I can take this work, I have done some poc code locally, I will

[jira] [Updated] (FLINK-26542) Fix "schema of both sides of union should match" exception when one side of union select multiple same coulmns

2022-03-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26542: - Summary: Fix "schema of both sides of union should match" exception when one side of union select

[GitHub] [flink] flinkbot edited a comment on pull request #19015: [BP-1.14][FLINK-26352][runtime-web] Add missing license headers to WebUI source files

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19015: URL: https://github.com/apache/flink/pull/19015#issuecomment-1062684744 ## CI report: * 1d494b08f78e7dd6e2d7a057a1575915d0f01536 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18976: [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18976: URL: https://github.com/apache/flink/pull/18976#issuecomment-1058916391 ## CI report: * 5613e31a28614dbfe1a3c7109371cac55e93523c Azure:

[jira] [Updated] (FLINK-26542) Fix

2022-03-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26542: - Summary: Fix (was: Hive dialect supports queries with multiple same columns in select) > Fix >

[GitHub] [flink] pnowojski opened a new pull request #19021: [hotfix][docs] Clarify semantic of tolerable checkpoint failure number

2022-03-09 Thread GitBox
pnowojski opened a new pull request #19021: URL: https://github.com/apache/flink/pull/19021 This only a documentation change that clarifies semantic of tolerable checkpoint failure number. ## Documentation - Does this pull request introduce a new feature? (yes / **no**)

[jira] [Commented] (FLINK-26545) Ingress rules should be created in the same namespace with FlinkDeployment CR

2022-03-09 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503532#comment-17503532 ] Matyas Orhidi commented on FLINK-26545: --- [~wangyang0918] if not urgent I can work on it later this

[GitHub] [flink] flinkbot edited a comment on pull request #18976: [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18976: URL: https://github.com/apache/flink/pull/18976#issuecomment-1058916391 ## CI report: * 5613e31a28614dbfe1a3c7109371cac55e93523c Azure:

[jira] [Updated] (FLINK-26542) Hive dialect supports queries with multiple same columns in select

2022-03-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26542: - Description: With Hive dialect, for union sql statement, if one side of union select multiple same

[jira] [Comment Edited] (FLINK-26542) Hive dialect supports queries with multiple same columns in select

2022-03-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503280#comment-17503280 ] luoyuxia edited comment on FLINK-26542 at 3/9/22, 11:47 AM: The main reason

[jira] [Comment Edited] (FLINK-26542) Hive dialect supports queries with multiple same columns in select

2022-03-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503280#comment-17503280 ] luoyuxia edited comment on FLINK-26542 at 3/9/22, 11:46 AM: The main reason

[jira] [Commented] (FLINK-26528) Trigger the updateControl when the FlinkDeployment have changed

2022-03-09 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503525#comment-17503525 ] Gyula Fora commented on FLINK-26528: [~aitozi] would you like me to assign this ticket to you? >

[jira] [Commented] (FLINK-26528) Trigger the updateControl when the FlinkDeployment have changed

2022-03-09 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503523#comment-17503523 ] Gyula Fora commented on FLINK-26528: I think after

[GitHub] [flink] flinkbot edited a comment on pull request #19020: [FLINK-XXX][table] Flip legacy casting to disable by default

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19020: URL: https://github.com/apache/flink/pull/19020#issuecomment-1062833750 ## CI report: * 91b6e51ce99dc6f74161a657897a6f8476ad68b0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18976: [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18976: URL: https://github.com/apache/flink/pull/18976#issuecomment-1058916391 ## CI report: * 5613e31a28614dbfe1a3c7109371cac55e93523c Azure:

[jira] [Comment Edited] (FLINK-26542) Hive dialect supports queries with multiple same columns in select

2022-03-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503280#comment-17503280 ] luoyuxia edited comment on FLINK-26542 at 3/9/22, 11:43 AM: It's a know

[jira] [Updated] (FLINK-26542) Hive dialect supports queries with multiple same columns in select

2022-03-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26542: - Description: With Hive dialect, for union sql statement, if one side of union select multiple same

[jira] [Closed] (FLINK-26261) Reconciliation should try to start job when not already started or move to permanent error

2022-03-09 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-26261. -- Resolution: Fixed merged: ee20209d95b7a155be0761eb1b60829fe489924f > Reconciliation should try to

[jira] [Updated] (FLINK-26542) Hive dialect supports queries with multiple same columns in select

2022-03-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26542: - Description: With Hive dialect, for union sql statement, if one side It can be reproduced using the

[jira] [Updated] (FLINK-26542) Hive dialect supports queries with multiple same columns in select

2022-03-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26542: - Description: With Hive dialect, for union sql statement, if one side of union select It can be

[GitHub] [flink] flinkbot commented on pull request #19020: [FLINK-XXX][table] Flip legacy casting to disable by default

2022-03-09 Thread GitBox
flinkbot commented on pull request #19020: URL: https://github.com/apache/flink/pull/19020#issuecomment-1062833750 ## CI report: * 91b6e51ce99dc6f74161a657897a6f8476ad68b0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18976: [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18976: URL: https://github.com/apache/flink/pull/18976#issuecomment-1058916391 ## CI report: * 5613e31a28614dbfe1a3c7109371cac55e93523c Azure:

[jira] [Created] (FLINK-26550) Correct the information of checkpoint failure

2022-03-09 Thread Yun Tang (Jira)
Yun Tang created FLINK-26550: Summary: Correct the information of checkpoint failure Key: FLINK-26550 URL: https://issues.apache.org/jira/browse/FLINK-26550 Project: Flink Issue Type: Bug

[GitHub] [flink] slinkydeveloper commented on a change in pull request #19020: [FLINK-XXX][table] Flip legacy casting to disable by default

2022-03-09 Thread GitBox
slinkydeveloper commented on a change in pull request #19020: URL: https://github.com/apache/flink/pull/19020#discussion_r822558605 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableITCase.java ## @@

[GitHub] [flink] slinkydeveloper opened a new pull request #19020: [FLINK-XXX][table] Flip legacy casting to disable by default

2022-03-09 Thread GitBox
slinkydeveloper opened a new pull request #19020: URL: https://github.com/apache/flink/pull/19020 ## What is the purpose of the change This PR flips the legacy cast behavior to DISABLED by default. For details about the discussion, see

[GitHub] [flink] flinkbot edited a comment on pull request #19014: [FLINK-24586][table-planner] JSON_VALUE should return STRING instead of VARCHAR(2000)

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19014: URL: https://github.com/apache/flink/pull/19014#issuecomment-1062677742 ## CI report: * 1019aa38945c228bd2b619ec83b75fe4d495df49 Azure:

[GitHub] [flink] zentol commented on pull request #18871: [FLINK-26232][tests][JUnit5 migration] Module:flink-avro

2022-03-09 Thread GitBox
zentol commented on pull request #18871: URL: https://github.com/apache/flink/pull/18871#issuecomment-1062829723 @RyanSkraba I'd focus on low-hanging fruits for now (i.e., where we can migrate an entire module at once); the core module such as flink-runtime will likely have to migrated

[GitHub] [flink] flinkbot edited a comment on pull request #18976: [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18976: URL: https://github.com/apache/flink/pull/18976#issuecomment-1058916391 ## CI report: * 5613e31a28614dbfe1a3c7109371cac55e93523c Azure:

[GitHub] [flink] zentol edited a comment on pull request #18871: [FLINK-26232][tests][JUnit5 migration] Module:flink-avro

2022-03-09 Thread GitBox
zentol edited a comment on pull request #18871: URL: https://github.com/apache/flink/pull/18871#issuecomment-1062829723 @RyanSkraba I'd focus on low-hanging fruits for now (i.e., where we can migrate an entire module at once); the core modules such as flink-runtime will likely have to

[jira] [Commented] (FLINK-26454) Improve operator logging

2022-03-09 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503520#comment-17503520 ] Gyula Fora commented on FLINK-26454: There were no discussion about this yet [~nicholasjiang]  would

[jira] [Commented] (FLINK-26545) Ingress rules should be created in the same namespace with FlinkDeployment CR

2022-03-09 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503519#comment-17503519 ] Gyula Fora commented on FLINK-26545: cc [~matyas]  > Ingress rules should be created in the same

[jira] [Closed] (FLINK-26232) [JUnit5 Migration] Module: flink-avro

2022-03-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-26232. Fix Version/s: 1.15.0 Resolution: Fixed master:

[GitHub] [flink] zentol merged pull request #18871: [FLINK-26232][tests][JUnit5 migration] Module:flink-avro

2022-03-09 Thread GitBox
zentol merged pull request #18871: URL: https://github.com/apache/flink/pull/18871 -- 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] [Assigned] (FLINK-26546) Extract Observer Interface

2022-03-09 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26546: -- Assignee: Aitozi > Extract Observer Interface > -- > >

[jira] [Commented] (FLINK-26546) Extract Observer Interface

2022-03-09 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503515#comment-17503515 ] Gyula Fora commented on FLINK-26546: thanks [~aitozi], I suggest you wait until

[GitHub] [flink] zentol commented on a change in pull request #18871: [FLINK-26232][tests][JUnit5 migration] Module:flink-avro

2022-03-09 Thread GitBox
zentol commented on a change in pull request #18871: URL: https://github.com/apache/flink/pull/18871#discussion_r822553706 ## File path: flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/AvroRecordInputFormatTest.java ## @@ -199,68 +195,63 @@ public static

[GitHub] [flink] flinkbot edited a comment on pull request #18976: [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18976: URL: https://github.com/apache/flink/pull/18976#issuecomment-1058916391 ## CI report: * 5613e31a28614dbfe1a3c7109371cac55e93523c Azure:

[jira] [Commented] (FLINK-26549) INSERT INTO with VALUES leads to wrong type inference with nested types

2022-03-09 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503513#comment-17503513 ] Francesco Guardiani commented on FLINK-26549: - Another interesting situation, If I modify

[jira] [Closed] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables timeouts on AZP

2022-03-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-25771. Resolution: Fixed > CassandraConnectorITCase.testRetrialAndDropTables timeouts on AZP >

[jira] [Comment Edited] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables timeouts on AZP

2022-03-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503512#comment-17503512 ] Chesnay Schepler edited comment on FLINK-25771 at 3/9/22, 11:28 AM:

[jira] [Commented] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables timeouts on AZP

2022-03-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503512#comment-17503512 ] Chesnay Schepler commented on FLINK-25771: -- Timeouts raised: master:

[GitHub] [flink] hongshuboy commented on pull request #18851: [hotfix][docs] Unified variable naming

2022-03-09 Thread GitBox
hongshuboy commented on pull request #18851: URL: https://github.com/apache/flink/pull/18851#issuecomment-1062823564 Code changes will involve public interfaces, so close this pr -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] hongshuboy closed pull request #18851: [hotfix][docs] Unified variable naming

2022-03-09 Thread GitBox
hongshuboy closed pull request #18851: URL: https://github.com/apache/flink/pull/18851 -- 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] hongshuboy removed a comment on pull request #18851: [hotfix][docs] Unified variable naming

2022-03-09 Thread GitBox
hongshuboy removed a comment on pull request #18851: URL: https://github.com/apache/flink/pull/18851#issuecomment-1057716786 @knaufk Copy that, should i create an improvement on [Flink’s Jira](http://issues.apache.org/jira/browse/FLINK) ? Or commit to this branch directly -- This is

[GitHub] [flink] zentol merged pull request #18973: [FLINK-25771][connectors][Cassandra][test] Raise the Cassandra driver timeouts at the Cluster level

2022-03-09 Thread GitBox
zentol merged pull request #18973: URL: https://github.com/apache/flink/pull/18973 -- 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] flinkbot edited a comment on pull request #18976: [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18976: URL: https://github.com/apache/flink/pull/18976#issuecomment-1058916391 ## CI report: * 5613e31a28614dbfe1a3c7109371cac55e93523c Azure:

[jira] [Updated] (FLINK-26549) INSERT INTO with VALUES leads to wrong type inference with nested types

2022-03-09 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani updated FLINK-26549: Description: While working on casting, I've found out we have an interesting bug

[GitHub] [flink] zentol commented on a change in pull request #18987: [FLINK-26494][runtime] Cleanup does not reveal exceptions

2022-03-09 Thread GitBox
zentol commented on a change in pull request #18987: URL: https://github.com/apache/flink/pull/18987#discussion_r822542232 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/cleanup/DefaultResourceCleaner.java ## @@ -166,21 +188,49 @@ private

[jira] [Created] (FLINK-26549) INSERT INTO with VALUES leads to wrong type inference with nested types

2022-03-09 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-26549: --- Summary: INSERT INTO with VALUES leads to wrong type inference with nested types Key: FLINK-26549 URL: https://issues.apache.org/jira/browse/FLINK-26549

[GitHub] [flink] flinkbot edited a comment on pull request #18976: [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18976: URL: https://github.com/apache/flink/pull/18976#issuecomment-1058916391 ## CI report: * 1bf57bf8486c6e23ceb5ffc9b9da161508e0c3a7 Azure:

[GitHub] [flink] wanglijie95 commented on pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

2022-03-09 Thread GitBox
wanglijie95 commented on pull request #19003: URL: https://github.com/apache/flink/pull/19003#issuecomment-1062817512 Thanks for review @zhuzhurk . I 've addressed all the comments. Please review again. -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-26548) the source parallelism is not set correctly with AdaptiveBatchScheduler

2022-03-09 Thread zl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503510#comment-17503510 ] zl commented on FLINK-26548: Hi [~wanglijie95] , can you confirm this problem?  > the source parallelism is

[GitHub] [flink] rkhachatryan commented on pull request #18976: [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

2022-03-09 Thread GitBox
rkhachatryan commented on pull request #18976: URL: https://github.com/apache/flink/pull/18976#issuecomment-1062816034 Thanks for the review! I've squashed the commits and will merge the PR as soon as the tests pass. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19003: URL: https://github.com/apache/flink/pull/19003#issuecomment-1061377385 ## CI report: * 3eab01550b5c5ee0d369d74e45fd516f698d83e6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * Unknown: [CANCELED](TBD) * 57d064b16b3d5864299cb48d6cef678e31d1e4ef Azure:

[GitHub] [flink] zentol commented on a change in pull request #18979: [FLINK-26484][fs] FileSystem.delete is not implemented consistently

2022-03-09 Thread GitBox
zentol commented on a change in pull request #18979: URL: https://github.com/apache/flink/pull/18979#discussion_r822528770 ## File path: flink-filesystems/flink-s3-fs-presto/src/main/java/org/apache/flink/fs/s3presto/FlinkS3PrestoFileSystem.java ## @@ -0,0 +1,164 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19003: URL: https://github.com/apache/flink/pull/19003#issuecomment-1061377385 ## CI report: * 3eab01550b5c5ee0d369d74e45fd516f698d83e6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * Unknown: [CANCELED](TBD) * 57d064b16b3d5864299cb48d6cef678e31d1e4ef UNKNOWN Bot commands The @flinkbot bot supports the

[jira] [Commented] (FLINK-26538) Ability to restart deployment w/o spec change

2022-03-09 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503501#comment-17503501 ] Nicholas Jiang commented on FLINK-26538: >From the user perspective, most of the users desire to

<    1   2   3   4   5   6   7   8   >