[GitHub] [flink] twalthr commented on a change in pull request #16042: [FLINK-22824][connector-kafka] Drop usages of legacy planner in Kafka module

twalthr commented on a change in pull request #16042: URL: https://github.com/apache/flink/pull/16042#discussion_r643698793 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceSinkFactoryTestBase.java #

[GitHub] [flink] JasonLeeCoding commented on a change in pull request #16049: [FLINK-22795] Throw better exception when executing remote SQL file in SQL Client

JasonLeeCoding commented on a change in pull request #16049: URL: https://github.com/apache/flink/pull/16049#discussion_r643697648 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/SqlClient.java ## @@ -179,6 +179,8 @@ protected static void

[GitHub] [flink] KarmaGYZ commented on pull request #15936: [FLINK-22683][runtime] Fix the null or incorrect value of total Flink…

KarmaGYZ commented on pull request #15936: URL: https://github.com/apache/flink/pull/15936#issuecomment-852784154 Thanks for the comments @xintongsong . PR updated. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] Airblader commented on a change in pull request #16042: [FLINK-22824][connector-kafka] Drop usages of legacy planner in Kafka module

Airblader commented on a change in pull request #16042: URL: https://github.com/apache/flink/pull/16042#discussion_r643694710 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceSinkFactoryTestBase.java ###

[GitHub] [flink] flinkbot edited a comment on pull request #16049: [FLINK-22795] Throw better exception when executing remote SQL file in SQL Client

flinkbot edited a comment on pull request #16049: URL: https://github.com/apache/flink/pull/16049#issuecomment-852187775 ## CI report: * 479324ff916f61727a62867846e2bd571e0301f9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16035: [FLINK-22808][state/changelog] Log metadata

flinkbot edited a comment on pull request #16035: URL: https://github.com/apache/flink/pull/16035#issuecomment-851611489 ## CI report: * 4cfed99fe90130b1d873d7e2b2cc41d310ec5476 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15877: [FLINK-22612][python] Restructure the coders in PyFlink

flinkbot edited a comment on pull request #15877: URL: https://github.com/apache/flink/pull/15877#issuecomment-836433504 ## CI report: * c37690c22ca78e62c968e3ea25e7e76e10324c22 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] Airblader commented on a change in pull request #16049: [FLINK-22795] Throw better exception when executing remote SQL file in SQL Client

Airblader commented on a change in pull request #16049: URL: https://github.com/apache/flink/pull/16049#discussion_r643684874 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/SqlClient.java ## @@ -179,6 +179,8 @@ protected static void star

[GitHub] [flink] flinkbot edited a comment on pull request #16049: [FLINK-22795] Throw better exception when executing remote SQL file in SQL Client

flinkbot edited a comment on pull request #16049: URL: https://github.com/apache/flink/pull/16049#issuecomment-852187775 ## CI report: * 479324ff916f61727a62867846e2bd571e0301f9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16046: [FLINK-22737][table-planner-blink] Introduce CURRENT_WATERMARK()

flinkbot edited a comment on pull request #16046: URL: https://github.com/apache/flink/pull/16046#issuecomment-852114839 ## CI report: * 3a49b8f5dbf87014ca15288e55c0a9db1f8f56cc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] stevenzwu commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

stevenzwu commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r643680862 ## File path: flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/hybrid/HybridSourceITCase.java ## @@ -0,0 +1,2

[jira] [Updated] (FLINK-21956) NPE in Kafka ingress when the key is missing

[ https://issues.apache.org/jira/browse/FLINK-21956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21956: --- Labels: pull-request-available (was: ) > NPE in Kafka ingress when the key is missing > ---

[GitHub] [flink-statefun] tzulitai opened a new pull request #238: [backport-2.2] [FLINK-21956] Improve error message when Kafka key is missing

tzulitai opened a new pull request #238: URL: https://github.com/apache/flink-statefun/pull/238 Backport of FLINK-21956 to the `release-2.2` branch. -- 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

[jira] [Closed] (FLINK-22809) Improve the exception message when a KafkaIngress receives a NULL key.

[ https://issues.apache.org/jira/browse/FLINK-22809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-22809. --- Resolution: Duplicate > Improve the exception message when a KafkaIngress receives a

[GitHub] [flink] stevenzwu commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

stevenzwu commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r643676793 ## File path: flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/hybrid/HybridSourceITCase.java ## @@ -0,0 +1,2

[jira] [Commented] (FLINK-22809) Improve the exception message when a KafkaIngress receives a NULL key.

[ https://issues.apache.org/jira/browse/FLINK-22809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355503#comment-17355503 ] Tzu-Li (Gordon) Tai commented on FLINK-22809: - This is a duplicate of FLINK-

[jira] [Updated] (FLINK-22529) StateFun Kinesis ingresses should support configs that are available via FlinkKinesisConsumer's ConsumerConfigConstants

[ https://issues.apache.org/jira/browse/FLINK-22529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22529: --- Labels: pull-request-available (was: ) > StateFun Kinesis ingresses should support configs

[GitHub] [flink-statefun] tzulitai opened a new pull request #237: [FLINK-22529] [kinese] Allow Flink's ConsumerConfigConstants and flexibility in providing AWS region and credentials

tzulitai opened a new pull request #237: URL: https://github.com/apache/flink-statefun/pull/237 This PR makes two major changes to the Kinesis ingress: 1. Configurations in Flink Kinesis connector's `ConsumerConfigConstants` are now applicable, by directly providing them in the prope

[GitHub] [flink] flinkbot edited a comment on pull request #16046: [FLINK-22737][table-planner-blink] Introduce CURRENT_WATERMARK()

flinkbot edited a comment on pull request #16046: URL: https://github.com/apache/flink/pull/16046#issuecomment-852114839 ## CI report: * 3a49b8f5dbf87014ca15288e55c0a9db1f8f56cc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15885: [FLINK-22376][runtime] RecoveredChannelStateHandler recycles the buffer if it was created inside and doesn't recycle if it was passed

flinkbot edited a comment on pull request #15885: URL: https://github.com/apache/flink/pull/15885#issuecomment-837001445 ## CI report: * 4c1a9dbb3034eb0ac880db84954b2c40fed365c2 UNKNOWN * 4c0c366897595d8b983686e41b506e43e9c125e0 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15877: [FLINK-22612][python] Restructure the coders in PyFlink

flinkbot edited a comment on pull request #15877: URL: https://github.com/apache/flink/pull/15877#issuecomment-836433504 ## CI report: * c37690c22ca78e62c968e3ea25e7e76e10324c22 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] Airblader removed a comment on pull request #16046: [FLINK-22737][table-planner-blink] Introduce CURRENT_WATERMARK()

Airblader removed a comment on pull request #16046: URL: https://github.com/apache/flink/pull/16046#issuecomment-852740603 @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

[jira] [Updated] (FLINK-22844) Add doc to introduce ExplainDetails for EXPLAIN sytnax

[ https://issues.apache.org/jira/browse/FLINK-22844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22844: Component/s: Documentation > Add doc to introduce ExplainDetails for EXPLAIN sytnax > ---

[jira] [Assigned] (FLINK-22844) Add doc to introduce ExplainDetails for EXPLAIN sytnax

[ https://issues.apache.org/jira/browse/FLINK-22844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22844: --- Assignee: WeiNan Zhao > Add doc to introduce ExplainDetails for EXPLAIN sytnax > -

[GitHub] [flink] Airblader commented on pull request #16046: [FLINK-22737][table-planner-blink] Introduce CURRENT_WATERMARK()

Airblader commented on pull request #16046: URL: https://github.com/apache/flink/pull/16046#issuecomment-852740603 @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 specifi

[GitHub] [flink] luoyuxia commented on a change in pull request #16027: [FLINK-22472][filesystem] close file of partition when partition is committable

luoyuxia commented on a change in pull request #16027: URL: https://github.com/apache/flink/pull/16027#discussion_r643631928 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/stream/StreamingFileWriter.java ## @@ -26,29 +27,52

[GitHub] [flink] luoyuxia commented on a change in pull request #16027: [FLINK-22472][filesystem] close file of partition when partition is committable

luoyuxia commented on a change in pull request #16027: URL: https://github.com/apache/flink/pull/16027#discussion_r643631928 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/stream/StreamingFileWriter.java ## @@ -26,29 +27,52

[jira] [Comment Edited] (FLINK-22785) Kafka transaction failing when there are two producers

[ https://issues.apache.org/jira/browse/FLINK-22785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355487#comment-17355487 ] Jin Xu edited comment on FLINK-22785 at 6/2/21, 5:20 AM: - should

[jira] [Commented] (FLINK-22785) Kafka transaction failing when there are two producers

[ https://issues.apache.org/jira/browse/FLINK-22785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355487#comment-17355487 ] Jin Xu commented on FLINK-22785: should not use 2 seperate producers on 1 topic,  say,

[GitHub] [flink] luoyuxia commented on a change in pull request #16027: [FLINK-22472][filesystem] close file of partition when partition is committable

luoyuxia commented on a change in pull request #16027: URL: https://github.com/apache/flink/pull/16027#discussion_r643631928 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/stream/StreamingFileWriter.java ## @@ -26,29 +27,52

[GitHub] [flink] flinkbot edited a comment on pull request #16013: [FLINK-21742][sql-client] Support REMOVE JAR statement in SQL Client

flinkbot edited a comment on pull request #16013: URL: https://github.com/apache/flink/pull/16013#issuecomment-849676995 ## CI report: * 87237d1486675216da5e403c4e88a2f22e71552b Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] luoyuxia commented on a change in pull request #16027: [FLINK-22472][filesystem] close file of partition when partition is committable

luoyuxia commented on a change in pull request #16027: URL: https://github.com/apache/flink/pull/16027#discussion_r643631928 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/stream/StreamingFileWriter.java ## @@ -26,29 +27,52

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * f0a507329244796db9a0a074dc8dd707f61d739e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15898: [FLINK-21439][core] WIP: Adds Exception History for AdaptiveScheduler

flinkbot edited a comment on pull request #15898: URL: https://github.com/apache/flink/pull/15898#issuecomment-838996225 ## CI report: * d6b55c6f681ef292e9f025341716d971aa299b82 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15885: [FLINK-22376][runtime] RecoveredChannelStateHandler recycles the buffer if it was created inside and doesn't recycle if it was passed

flinkbot edited a comment on pull request #15885: URL: https://github.com/apache/flink/pull/15885#issuecomment-837001445 ## CI report: * 4c1a9dbb3034eb0ac880db84954b2c40fed365c2 UNKNOWN * 4c0c366897595d8b983686e41b506e43e9c125e0 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15877: [FLINK-22612][python] Restructure the coders in PyFlink

flinkbot edited a comment on pull request #15877: URL: https://github.com/apache/flink/pull/15877#issuecomment-836433504 ## CI report: * c37690c22ca78e62c968e3ea25e7e76e10324c22 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15317: [FLINK-20562][SQL-Client][Table-Api] Improvements,Support ExplainDetail…

flinkbot edited a comment on pull request #15317: URL: https://github.com/apache/flink/pull/15317#issuecomment-803958506 ## CI report: * 9221c14030c5b5bdc6863c843617e414c9e007a1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-22785) Kafka transaction failing when there are two producers

[ https://issues.apache.org/jira/browse/FLINK-22785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355485#comment-17355485 ] Jin Xu commented on FLINK-22785: if you bring up 2 flink producer, transactionalid might

[GitHub] [flink] luoyuxia commented on a change in pull request #16027: [FLINK-22472][filesystem] close file of partition when partition is committable

luoyuxia commented on a change in pull request #16027: URL: https://github.com/apache/flink/pull/16027#discussion_r643631928 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/stream/StreamingFileWriter.java ## @@ -26,29 +27,52

[jira] [Updated] (FLINK-22844) Add doc to introduce ExplainDetails for EXPLAIN sytnax

[ https://issues.apache.org/jira/browse/FLINK-22844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] WeiNan Zhao updated FLINK-22844: Description: Link to FLINK-20562,add doc to introduct this new sytax. (was: Link to FLINK_20562,a

[GitHub] [flink] SteNicholas commented on pull request #16013: [FLINK-21742][sql-client] Support REMOVE JAR statement in SQL Client

SteNicholas commented on pull request #16013: URL: https://github.com/apache/flink/pull/16013#issuecomment-852723653 @wuchong , I have rebased master branch and used `SHOW JARS` to verify the implementation for `REMOVE JAR`. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] SteNicholas removed a comment on pull request #16013: [FLINK-21742][sql-client] Support REMOVE JAR statement in SQL Client

SteNicholas removed a comment on pull request #16013: URL: https://github.com/apache/flink/pull/16013#issuecomment-851465411 > I would prefer to review this PR after #16010 is merged. Then you can use `show jars` to verify `remove jar`. Yes, I would like to use `show jars` to verify

[jira] [Commented] (FLINK-22702) KafkaSourceITCase.testRedundantParallelism failed

[ https://issues.apache.org/jira/browse/FLINK-22702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355481#comment-17355481 ] Xintong Song commented on FLINK-22702: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-22844) Add doc to introduce ExplainDetails for EXPLAIN sytnax

[ https://issues.apache.org/jira/browse/FLINK-22844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355477#comment-17355477 ] WeiNan Zhao commented on FLINK-22844: - please assign this job to me. > Add doc to i

[jira] [Created] (FLINK-22844) Add doc to introduce ExplainDetails for EXPLAIN sytnax

WeiNan Zhao created FLINK-22844: --- Summary: Add doc to introduce ExplainDetails for EXPLAIN sytnax Key: FLINK-22844 URL: https://issues.apache.org/jira/browse/FLINK-22844 Project: Flink Issue T

[GitHub] [flink] flinkbot edited a comment on pull request #16013: [FLINK-21742][sql-client] Support REMOVE JAR statement in SQL Client

flinkbot edited a comment on pull request #16013: URL: https://github.com/apache/flink/pull/16013#issuecomment-849676995 ## CI report: * 87237d1486675216da5e403c4e88a2f22e71552b Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15997: [FLINK-22680][table-planner-blink] Fix IndexOutOfBoundsException when apply WatermarkAssignerChangelogNormalizeTransposeRule

flinkbot edited a comment on pull request #15997: URL: https://github.com/apache/flink/pull/15997#issuecomment-847752911 ## CI report: * 1489d3171e03833091126edaaab08038c265302b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15898: [FLINK-21439][core] WIP: Adds Exception History for AdaptiveScheduler

flinkbot edited a comment on pull request #15898: URL: https://github.com/apache/flink/pull/15898#issuecomment-838996225 ## CI report: * ef28fcc096fffe006e9a06f25926a80fce91c1d5 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15877: [FLINK-22612][python] Restructure the coders in PyFlink

flinkbot edited a comment on pull request #15877: URL: https://github.com/apache/flink/pull/15877#issuecomment-836433504 ## CI report: * c37690c22ca78e62c968e3ea25e7e76e10324c22 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15317: [FLINK-20562][SQL-Client][Table-Api] Improvements,Support ExplainDetail…

flinkbot edited a comment on pull request #15317: URL: https://github.com/apache/flink/pull/15317#issuecomment-803958506 ## CI report: * 9221c14030c5b5bdc6863c843617e414c9e007a1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13921: [FLINK-19896][table-blink] Improve first-n-row fetching in the Rank o…

flinkbot edited a comment on pull request #13921: URL: https://github.com/apache/flink/pull/13921#issuecomment-721575473 ## CI report: * ff41babdfc158e51a3e299614ed7685d758221b9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16024: [FLINK-22038][table-planner-blink] Update TopN to be without rowNumber if rowNumber field is never used by the successor Calc

flinkbot edited a comment on pull request #16024: URL: https://github.com/apache/flink/pull/16024#issuecomment-850960580 ## CI report: * d38e029356e1953280b072089f545739893931c3 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-16952) Parquet file system format support filter pushdown

[ https://issues.apache.org/jira/browse/FLINK-16952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355473#comment-17355473 ] luoyuxia commented on FLINK-16952: -- Is there anyone working on it? if not, I would like

[jira] [Created] (FLINK-22843) Document and code are inconsistent.

xiaozilong created FLINK-22843: -- Summary: Document and code are inconsistent. Key: FLINK-22843 URL: https://issues.apache.org/jira/browse/FLINK-22843 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-18346) Support partition pruning for lookup table source

[ https://issues.apache.org/jira/browse/FLINK-18346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355472#comment-17355472 ] luoyuxia commented on FLINK-18346: -- [~lzljs3620320] Does FileSystemTableSource supports

[GitHub] [flink] flinkbot edited a comment on pull request #13921: [FLINK-19896][table-blink] Improve first-n-row fetching in the Rank o…

flinkbot edited a comment on pull request #13921: URL: https://github.com/apache/flink/pull/13921#issuecomment-721575473 ## CI report: * 866cb86ec4c679e3d46327649c4483bd512f7289 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-21439) Adaptive Scheduler: Add support for exception history

[ https://issues.apache.org/jira/browse/FLINK-21439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355471#comment-17355471 ] John Phelan commented on FLINK-21439: - Okay I think I see how you are looking at it.

[GitHub] [flink] JasonLeeCoding commented on a change in pull request #16049: [FLINK-22795] Throw better exception when executing remote SQL file in SQL Client

JasonLeeCoding commented on a change in pull request #16049: URL: https://github.com/apache/flink/pull/16049#discussion_r643636534 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/SqlClient.java ## @@ -213,6 +215,20 @@ protected static voi

[jira] [Commented] (FLINK-22703) SavepointITCase.testTriggerSavepointAndResumeWithFileBasedCheckpoints failed

[ https://issues.apache.org/jira/browse/FLINK-22703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355470#comment-17355470 ] Xintong Song commented on FLINK-22703: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Created] (FLINK-22842) Streaming File Sink end-to-end test fail due to not finish after 900s

Xintong Song created FLINK-22842: Summary: Streaming File Sink end-to-end test fail due to not finish after 900s Key: FLINK-22842 URL: https://issues.apache.org/jira/browse/FLINK-22842 Project: Flink

[jira] [Updated] (FLINK-22842) Streaming File Sink end-to-end test fail due to not finish after 900s

[ https://issues.apache.org/jira/browse/FLINK-22842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22842: - Labels: test-stability (was: ) > Streaming File Sink end-to-end test fail due to not finish aft

[GitHub] [flink] tragicjun commented on a change in pull request #13921: [FLINK-19896][table-blink] Improve first-n-row fetching in the Rank o…

tragicjun commented on a change in pull request #13921: URL: https://github.com/apache/flink/pull/13921#discussion_r643634656 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecRank.java ## @@ -207,

[GitHub] [flink] LadyForest commented on pull request #16037: [FLINK-22812][hive] Fix HiveConf, HiveMetaStoreClient and upgrade avr…

LadyForest commented on pull request #16037: URL: https://github.com/apache/flink/pull/16037#issuecomment-852698912 > @LadyForest, I think you also maintain some changes in a private hive fork. Let me know if you want to incorporate anything else in this PR. I'm just wondering do we

[GitHub] [flink] luoyuxia commented on a change in pull request #16027: [FLINK-22472][filesystem] close file of partition when partition is committable

luoyuxia commented on a change in pull request #16027: URL: https://github.com/apache/flink/pull/16027#discussion_r643631928 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/stream/StreamingFileWriter.java ## @@ -26,29 +27,52

[GitHub] [flink] fsk119 commented on a change in pull request #16049: [FLINK-22795] Throw better exception when executing remote SQL file in SQL Client

fsk119 commented on a change in pull request #16049: URL: https://github.com/apache/flink/pull/16049#discussion_r643626880 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/SqlClient.java ## @@ -213,6 +215,20 @@ protected static void startC

[GitHub] [flink] JingsongLi commented on a change in pull request #16027: [FLINK-22472][filesystem] close file of partition when partition is committable

JingsongLi commented on a change in pull request #16027: URL: https://github.com/apache/flink/pull/16027#discussion_r643625383 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/stream/StreamingFileWriter.java ## @@ -26,29 +27,5

[jira] [Updated] (FLINK-22840) Assign-evenly kafkaTopicPartitions of multiple topics to flinkKafkaConsumer subtask

[ https://issues.apache.org/jira/browse/FLINK-22840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu xiaolong updated FLINK-22840: Priority: Minor (was: Major) > Assign-evenly kafkaTopicPartitions of multiple topics to flinkKafk

[jira] [Comment Edited] (FLINK-20253) `JsonRowDeserializationSchema` can not deserialize non utf-8 json string

[ https://issues.apache.org/jira/browse/FLINK-20253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355464#comment-17355464 ] luoyuxia edited comment on FLINK-20253 at 6/2/21, 3:03 AM: --- [~

[jira] [Commented] (FLINK-20253) `JsonRowDeserializationSchema` can not deserialize non utf-8 json string

[ https://issues.apache.org/jira/browse/FLINK-20253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355464#comment-17355464 ] luoyuxia commented on FLINK-20253: -- [~zouyunhe] I copy the json string and try to deser

[GitHub] [flink] JasonLeeCoding commented on pull request #16049: [FLINK-22795] Throw better exception when executing remote SQL file in SQL Client

JasonLeeCoding commented on pull request #16049: URL: https://github.com/apache/flink/pull/16049#issuecomment-852675089 @fsk119 CI failed ,but I didn't find the reason, please take a look , thanks. -- This is an automated message from the Apache Git Service. To respond to the message, ple

[jira] [Updated] (FLINK-22840) Assign-evenly kafkaTopicPartitions of multiple topics to flinkKafkaConsumer subtask

[ https://issues.apache.org/jira/browse/FLINK-22840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu xiaolong updated FLINK-22840: Description: Now ,with flink1.11 kafka connecotr,when we consume multiple kafka topics by one fli

[GitHub] [flink] flinkbot edited a comment on pull request #15936: [FLINK-22683][runtime] Fix the null or incorrect value of total Flink…

flinkbot edited a comment on pull request #15936: URL: https://github.com/apache/flink/pull/15936#issuecomment-842214419 ## CI report: * dedcd90a5d6c8f34cb89d113ceffe7335804d608 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15531: [FLINK-22147][connector/kafka] Refactor partition discovery logic in Kafka source enumerator

flinkbot edited a comment on pull request #15531: URL: https://github.com/apache/flink/pull/15531#issuecomment-816343442 ## CI report: * 7edbaed06ad47e3972b02382fc7346f8d9a57e9f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-22840) Assign-evenly kafkaTopicPartitions of multiple topics to flinkKafkaConsumer subtask

[ https://issues.apache.org/jira/browse/FLINK-22840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu xiaolong updated FLINK-22840: Description: Now ,with flink1.11 kafka connecotr,when we consume multiple kafka topics by one fli

[jira] [Created] (FLINK-22841) how to update configuration of the native kubernetes deployment model flink cluster?

lukehua created FLINK-22841: --- Summary: how to update configuration of the native kubernetes deployment model flink cluster? Key: FLINK-22841 URL: https://issues.apache.org/jira/browse/FLINK-22841 Project: F

[jira] [Comment Edited] (FLINK-22839) Assign-evenly kafkaTopicPartitions of multiple topics to flinkKafkaConsumer subtask

[ https://issues.apache.org/jira/browse/FLINK-22839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355458#comment-17355458 ] Xu xiaolong edited comment on FLINK-22839 at 6/2/21, 2:42 AM:

[jira] [Commented] (FLINK-22749) Apply a robust default State Backend Configuration

[ https://issues.apache.org/jira/browse/FLINK-22749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355460#comment-17355460 ] Yun Tang commented on FLINK-22749: -- If using rocksDB state backend by default, and plan

[jira] [Commented] (FLINK-22839) Assign-evenly kafkaTopicPartitions of multiple topics to flinkKafkaConsumer subtask

[ https://issues.apache.org/jira/browse/FLINK-22839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355458#comment-17355458 ] Xu xiaolong commented on FLINK-22839: - sorry for my poor network and me a new  bird,

[jira] [Commented] (FLINK-22837) Assign-evenly kafkaTopicPartitions of multiple topics to flinkKafkaConsumer subtask

[ https://issues.apache.org/jira/browse/FLINK-22837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355459#comment-17355459 ] Xu xiaolong commented on FLINK-22837: - sorry for my poor network and me a new  bird,

[GitHub] [flink] wuchong commented on pull request #16022: [FLINK-21301][table-planner-blink] Decouple window aggregate allow lateness with state ttl configuration

wuchong commented on pull request #16022: URL: https://github.com/apache/flink/pull/16022#issuecomment-852668471 Looks good to me. -- 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 c

[jira] [Created] (FLINK-22840) Assign-evenly kafkaTopicPartitions of multiple topics to flinkKafkaConsumer subtask

Xu xiaolong created FLINK-22840: --- Summary: Assign-evenly kafkaTopicPartitions of multiple topics to flinkKafkaConsumer subtask Key: FLINK-22840 URL: https://issues.apache.org/jira/browse/FLINK-22840 Pr

[jira] [Created] (FLINK-22839) Assign-evenly kafkaTopicPartitions of multiple topics to flinkKafkaConsumer subtask

Xu xiaolong created FLINK-22839: --- Summary: Assign-evenly kafkaTopicPartitions of multiple topics to flinkKafkaConsumer subtask Key: FLINK-22839 URL: https://issues.apache.org/jira/browse/FLINK-22839 Pr

[jira] [Created] (FLINK-22838) Flink Dashboard display incorrect Version in 1.13，actual display 1.12.2

Gao Fei created FLINK-22838: --- Summary: Flink Dashboard display incorrect Version in 1.13，actual display 1.12.2 Key: FLINK-22838 URL: https://issues.apache.org/jira/browse/FLINK-22838 Project: Flink

[jira] [Created] (FLINK-22837) Assign-evenly kafkaTopicPartitions of multiple topics to flinkKafkaConsumer subtask

Xu xiaolong created FLINK-22837: --- Summary: Assign-evenly kafkaTopicPartitions of multiple topics to flinkKafkaConsumer subtask Key: FLINK-22837 URL: https://issues.apache.org/jira/browse/FLINK-22837 Pr

[jira] [Commented] (FLINK-22198) org.apache.flink.streaming.connectors.kafka.table.KafkaTableITCase hang.

[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355455#comment-17355455 ] Xintong Song commented on FLINK-22198: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #15936: [FLINK-22683][runtime] Fix the null or incorrect value of total Flink…

flinkbot edited a comment on pull request #15936: URL: https://github.com/apache/flink/pull/15936#issuecomment-842214419 ## CI report: * dedcd90a5d6c8f34cb89d113ceffe7335804d608 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15531: [FLINK-22147][connector/kafka] Refactor partition discovery logic in Kafka source enumerator

flinkbot edited a comment on pull request #15531: URL: https://github.com/apache/flink/pull/15531#issuecomment-816343442 ## CI report: * 7edbaed06ad47e3972b02382fc7346f8d9a57e9f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-22836) OffsetsInitializerTest.testTimestampOffsetsInitializer fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22836: - Labels: test-stability (was: ) > OffsetsInitializerTest.testTimestampOffsetsInitializer fails o

[jira] [Created] (FLINK-22836) OffsetsInitializerTest.testTimestampOffsetsInitializer fails on azure

Xintong Song created FLINK-22836: Summary: OffsetsInitializerTest.testTimestampOffsetsInitializer fails on azure Key: FLINK-22836 URL: https://issues.apache.org/jira/browse/FLINK-22836 Project: Flink

[jira] [Commented] (FLINK-20928) KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:270 » Timeout

[ https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355448#comment-17355448 ] Xintong Song commented on FLINK-20928: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] godfreyhe commented on pull request #16024: [FLINK-22038][table-planner-blink] Update TopN to be without rowNumber if rowNumber field is never used by the successor Calc

godfreyhe commented on pull request #16024: URL: https://github.com/apache/flink/pull/16024#issuecomment-852659321 @beyond1920 some tests failed -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to t

[jira] [Commented] (FLINK-22068) FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355446#comment-17355446 ] Xintong Song commented on FLINK-22068: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] leonardBang commented on a change in pull request #16020: [FLINK-21911][table-api] Add built-in greatest/least functions support #15821

leonardBang commented on a change in pull request #16020: URL: https://github.com/apache/flink/pull/16020#discussion_r643601162 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/expressions/converter/DirectConvertRule.java ## @@ -

[GitHub] [flink] pensz commented on pull request #16029: [FLINK-22786][sql-client] sql-client can not create .flink-sql-history file

pensz commented on pull request #16029: URL: https://github.com/apache/flink/pull/16029#issuecomment-852648154 > @pensz Hi, the CI test fails. Please run `mvn spotless:apply` to fix the checkstyle problem. Fixed. -- This is an automated message from the Apache Git Service. To resp

[GitHub] [flink] wangwei1025 commented on pull request #15939: [FLINK-15390][Connectors/ORC][Connectors/Hive]List/Map/Struct types support for vectorized orc reader

wangwei1025 commented on pull request #15939: URL: https://github.com/apache/flink/pull/15939#issuecomment-852642901 @lirui-apache can you help me review again ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Issue Comment Deleted] (FLINK-22826) flink sql1.13.1 causes data loss based on change log stream data join

[ https://issues.apache.org/jira/browse/FLINK-22826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 徐州州 updated FLINK-22826: Comment: was deleted (was: 好的 我试下) > flink sql1.13.1 causes data loss based on change log stream data join >

[jira] [Commented] (FLINK-22826) flink sql1.13.1 causes data loss based on change log stream data join

[ https://issues.apache.org/jira/browse/FLINK-22826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355419#comment-17355419 ] 徐州州 commented on FLINK-22826: - Okay I try it > flink sql1.13.1 causes data loss based on ch

[jira] [Commented] (FLINK-22826) flink sql1.13.1 causes data loss based on change log stream data join

[ https://issues.apache.org/jira/browse/FLINK-22826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17355418#comment-17355418 ] 徐州州 commented on FLINK-22826: - 好的 我试下 > flink sql1.13.1 causes data loss based on change lo

[jira] [Updated] (FLINK-17775) Cannot set batch job name when using collect

[ https://issues.apache.org/jira/browse/FLINK-17775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17775: --- Labels: auto-deprioritized-critical stale-major (was: auto-deprioritized-critical) I am th

[jira] [Updated] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

[ https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15493: --- Labels: auto-deprioritized-critical auto-unassigned test-stability (was: auto-unassigned

  1   2   3   4   5   >