[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

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

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

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

[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

[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

[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=17355487#comment-17355487 ] Jin Xu edited comment on FLINK-22785 at 6/2/21, 5:20 AM: - should not use 2

[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=17355487#comment-17355487 ] Jin Xu commented on FLINK-22785: should not use 2 seperate producers on 1 topic,  say, e.g.,  producer1

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

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

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

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

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

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

[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=17355485#comment-17355485 ] Jin Xu commented on FLINK-22785: if you bring up 2 flink producer, transactionalid might collide >

[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 

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

[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=17355481#comment-17355481 ] Xintong Song commented on FLINK-22702: --

[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=17355477#comment-17355477 ] WeiNan Zhao commented on FLINK-22844: - please assign this job to me. > Add doc to introduce

[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

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

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

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

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

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

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

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

[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=17355473#comment-17355473 ] luoyuxia commented on FLINK-16952: -- Is there anyone working on it? if not, I would like to take this

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

[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=17355471#comment-17355471 ] John Phelan commented on FLINK-21439: - Okay I think I see how you are looking at it. I reused

[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

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

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

[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

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

[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

[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

[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

[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=17355464#comment-17355464 ] luoyuxia edited comment on FLINK-20253 at 6/2/21, 3:03 AM: --- [~zouyunhe] I copy

[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=17355464#comment-17355464 ] luoyuxia commented on FLINK-20253: -- [~zouyunhe] I copy the json string and try to deserialize it,  it

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

[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

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

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

[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

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

[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=17355458#comment-17355458 ] Xu xiaolong edited comment on FLINK-22839 at 6/2/21, 2:42 AM: -- sorry for my

[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=17355460#comment-17355460 ] Yun Tang commented on FLINK-22749: -- If using rocksDB state backend by default, and plan to enable

[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=17355458#comment-17355458 ] Xu xiaolong commented on FLINK-22839: - sorry for my poor network and me a new  bird, this issue is

[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=17355459#comment-17355459 ] Xu xiaolong commented on FLINK-22837: - sorry for my poor network and me a new  bird, this issue is

[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

[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

[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

[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

[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=17355455#comment-17355455 ] Xintong Song commented on FLINK-22198: --

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

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

[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

[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=17355448#comment-17355448 ] Xintong Song commented on FLINK-20928: --

[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

[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=17355446#comment-17355446 ] Xintong Song commented on FLINK-22068: --

[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

[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

[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=17355419#comment-17355419 ] 徐州州 commented on FLINK-22826: - Okay I try it > flink sql1.13.1 causes data loss based on change log stream

[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=17355418#comment-17355418 ] 徐州州 commented on FLINK-22826: - 好的 我试下 > flink sql1.13.1 causes data loss based on change log stream data

[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

[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

[jira] [Updated] (FLINK-22662) YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint fail

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

[jira] [Updated] (FLINK-17855) UDF with parameter Array(Row) can not work

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

[jira] [Updated] (FLINK-20431) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133->lambda$testCommitOffsetsWithoutAliveFetchers$3:134 expected:<10> but was:<1>

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

[jira] [Updated] (FLINK-13400) Remove Hive and Hadoop dependencies from SQL Client

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

[jira] [Updated] (FLINK-17784) Better detection for parquet and orc in hive

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

[jira] [Updated] (FLINK-18894) StateFun job stalls on stop-with-savepoint

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

[jira] [Updated] (FLINK-17874) Writing to hbase throws NPE

[ https://issues.apache.org/jira/browse/FLINK-17874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17874: --- Labels: auto-unassigned pull-request-available stale-major (was: auto-unassigned

[jira] [Updated] (FLINK-22312) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents due to the heartbeat exception with Yarn RM

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

[jira] [Updated] (FLINK-17916) Provide API to separate KafkaShuffle's Producer and Consumer to different jobs

[ https://issues.apache.org/jira/browse/FLINK-17916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17916: --- Labels: auto-unassigned pull-request-available stale-major (was: auto-unassigned

[jira] [Updated] (FLINK-17856) Adds the feature of monitoring directory changes for FileSystem table source connector

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

[jira] [Updated] (FLINK-17912) KafkaShuffleITCase.testAssignedToPartitionEventTime: "Watermark should always increase"

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

[jira] [Updated] (FLINK-18013) Refactor Hadoop Utility classes/functions into a common Maven module

[ https://issues.apache.org/jira/browse/FLINK-18013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18013: --- Labels: auto-unassigned pull-request-available stale-major (was: auto-unassigned

[jira] [Updated] (FLINK-17949) KafkaShuffleITCase.testSerDeIngestionTime:156->testRecordSerDe:388 expected:<310> but was:<0>

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

[jira] [Updated] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema

[ https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18049: --- Labels: auto-deprioritized-critical pull-request-available stale-major (was:

[jira] [Updated] (FLINK-18027) ROW value constructor cannot deal with complex expressions

[ https://issues.apache.org/jira/browse/FLINK-18027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18027: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-18060) Add notice for heap-based state backend of state access reference problem

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

  1   2   3   4   5   >