[jira] [Resolved] (FLINK-22726) Hive GROUPING__ID returns different value in older versions

[ https://issues.apache.org/jira/browse/FLINK-22726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-22726. Resolution: Fixed Fixed in master: 6d8c02f90a5a3054015f2f1ee83be821d925ccd1 Fixed in release-1.13:

[GitHub] [flink] flinkbot commented on pull request #16117: [BP-1.13][FLINK-22889][tests] Ignore JdbcExactlyOnceSinkE2eTest temporarily

flinkbot commented on pull request #16117: URL: https://github.com/apache/flink/pull/16117#issuecomment-857402157 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Commented] (FLINK-22933) Upgrade the Flink Fabric8io/kubernetes-client version to >=5.4.0 to be FIPS compliant

[ https://issues.apache.org/jira/browse/FLINK-22933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359779#comment-17359779 ] Robert Metzger commented on FLINK-22933: Thanks a lot for opening this ticket. At first sight,

[jira] [Updated] (FLINK-22933) Upgrade the Flink Fabric8io/kubernetes-client version to >=5.4.0 to be FIPS compliant

[ https://issues.apache.org/jira/browse/FLINK-22933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22933: --- Fix Version/s: 1.14.0 > Upgrade the Flink Fabric8io/kubernetes-client version to >=5.4.0 to

[jira] [Updated] (FLINK-22933) Upgrade the Flink Fabric8io/kubernetes-client version to >=5.4.0 to be FIPS compliant

[ https://issues.apache.org/jira/browse/FLINK-22933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22933: --- Priority: Critical (was: Blocker) > Upgrade the Flink Fabric8io/kubernetes-client version

[GitHub] [flink] rkhachatryan opened a new pull request #16117: [FLINK-22889][tests] Ignore JdbcExactlyOnceSinkE2eTest temporarily

rkhachatryan opened a new pull request #16117: URL: https://github.com/apache/flink/pull/16117 backport of #16090 to 1.13 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[jira] [Closed] (FLINK-22923) Queryable state (rocksdb) with TM restart end-to-end test unstable

[ https://issues.apache.org/jira/browse/FLINK-22923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-22923. -- Fix Version/s: (was: 1.14.0) Resolution: Won't Fix > Queryable state (rocksdb)

[jira] [Commented] (FLINK-22923) Queryable state (rocksdb) with TM restart end-to-end test unstable

[ https://issues.apache.org/jira/browse/FLINK-22923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359778#comment-17359778 ] Robert Metzger commented on FLINK-22923: Since QS is defacto not maintained anymore, I'll close

[jira] [Commented] (FLINK-22938) Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout

[ https://issues.apache.org/jira/browse/FLINK-22938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359777#comment-17359777 ] Robert Metzger commented on FLINK-22938: The log you've uploaded is not the full jobmanager log

[GitHub] [flink] rkhachatryan commented on a change in pull request #15420: [FLINK-21356] Implement incremental checkpointing and recovery using state changelog

rkhachatryan commented on a change in pull request #15420: URL: https://github.com/apache/flink/pull/15420#discussion_r647985499 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogMapState.java ## @@ -71,22

[GitHub] [flink] flinkbot commented on pull request #16116: [hotfix][docs] use non deprecated syntax in SinkFunction code sample

flinkbot commented on pull request #16116: URL: https://github.com/apache/flink/pull/16116#issuecomment-857396931 ## CI report: * eaf7755e4f56b894c8ec57ff6a6053d0534c4d22 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #16104: [FLINK-22730][table-planner-blink] Add per record code when generating table function collector code for lookup joins

flinkbot edited a comment on pull request #16104: URL: https://github.com/apache/flink/pull/16104#issuecomment-856601875 ## CI report: * 1f145687c310cd0ee3a76478d8d1a95527dba8e2 Azure:

[jira] [Created] (FLINK-22939) Generalize JDK switch in azure setup

Chesnay Schepler created FLINK-22939: Summary: Generalize JDK switch in azure setup Key: FLINK-22939 URL: https://issues.apache.org/jira/browse/FLINK-22939 Project: Flink Issue Type:

[jira] [Updated] (FLINK-22938) Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout

[ https://issues.apache.org/jira/browse/FLINK-22938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhagi updated FLINK-22938: -- Attachment: flink -jobmanager logs.txt > Slot request bulk is not fulfillable! Could not allocate the

[jira] [Updated] (FLINK-22938) Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout

[ https://issues.apache.org/jira/browse/FLINK-22938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhagi updated FLINK-22938: -- Description: Hi team, I tested cluster upgrade from Flink Version 1.12.4 to 1.13.1 ,due to 1 job issues

[jira] [Updated] (FLINK-22938) Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout

[ https://issues.apache.org/jira/browse/FLINK-22938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhagi updated FLINK-22938: -- Description: Hi team, I tested cluster upgrade from Flink Version 1.12.4 to 1.13.1 ,due to 1 job issues

[jira] [Updated] (FLINK-22938) Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout

[ https://issues.apache.org/jira/browse/FLINK-22938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhagi updated FLINK-22938: -- Description: Hi team, I tested cluster upgrade from Flink Version 1.12.4 to 1.13.1 ,due to 1 job issues

[jira] [Created] (FLINK-22938) Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout

Bhagi created FLINK-22938: - Summary: Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout Key: FLINK-22938 URL: https://issues.apache.org/jira/browse/FLINK-22938

[GitHub] [flink] flinkbot edited a comment on pull request #15200: [FLINK-21355] Send changes to the state changelog

flinkbot edited a comment on pull request #15200: URL: https://github.com/apache/flink/pull/15200#issuecomment-798902665 ## CI report: * 5e1342d9916f5c4356c622a40bc27bcbdacde9d7 UNKNOWN * 24c8af22f7a4b9dcf93a143188cd7aef53f9e1b2 Azure:

[GitHub] [flink] Airblader commented on a change in pull request #16097: [FLINK-22864][table] Remove BatchTableEnvironment and related classes

Airblader commented on a change in pull request #16097: URL: https://github.com/apache/flink/pull/16097#discussion_r647968768 ## File path: flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/CsvBatchTableSourceFactory.java ## @@ -19,18 +19,18

[GitHub] [flink] flinkbot commented on pull request #16116: [hotfix][docs] use non deprecated syntax in SinkFunction code sample

flinkbot commented on pull request #16116: URL: https://github.com/apache/flink/pull/16116#issuecomment-857375610 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] sv3ndk commented on pull request #16116: use non deprecated syntax in SinkFunction code sample

sv3ndk commented on pull request #16116: URL: https://github.com/apache/flink/pull/16116#issuecomment-857374543 cc'ing @dawidwys since you commented on a previous PR on that part of the documentation :) -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] sv3ndk opened a new pull request #16116: use non deprecated syntax in SinkFunction code sample

sv3ndk opened a new pull request #16116: URL: https://github.com/apache/flink/pull/16116 ## What is the purpose of the change The current code samples in the [Testing Flink

[jira] [Commented] (FLINK-22492) KinesisTableApiITCase with wrong results

[ https://issues.apache.org/jira/browse/FLINK-22492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359758#comment-17359758 ] Xintong Song commented on FLINK-22492: -- [~AHeise], could you help take a look at this issue? >

[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: * 618314849507f4b40536ae293ed3b0d128f0880b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15200: [FLINK-21355] Send changes to the state changelog

flinkbot edited a comment on pull request #15200: URL: https://github.com/apache/flink/pull/15200#issuecomment-798902665 ## CI report: * 5e1342d9916f5c4356c622a40bc27bcbdacde9d7 UNKNOWN * e76855e230c997fc1e1507e1a54a6a08b2cf4a31 Azure:

[jira] [Commented] (FLINK-22884) Select view columns fail when store metadata with hive

[ https://issues.apache.org/jira/browse/FLINK-22884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359756#comment-17359756 ] ELLEX_SHEN commented on FLINK-22884: [~lirui][~jark] can you for help? > Select view columns fail

[GitHub] [flink] Zakelly commented on a change in pull request #15420: [FLINK-21356] Implement incremental checkpointing and recovery using state changelog

Zakelly commented on a change in pull request #15420: URL: https://github.com/apache/flink/pull/15420#discussion_r647960969 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogMapState.java ## @@ -71,22

[GitHub] [flink] lirui-apache closed pull request #15983: [FLINK-22726][hive] Support grouping__id in hive prior to 2.3.0

lirui-apache closed pull request #15983: URL: https://github.com/apache/flink/pull/15983 -- 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. For queries about this service,

[jira] [Commented] (FLINK-22900) flink 1.11.2 fileSystem source table read fileSystem sink table path multi-partition error

[ https://issues.apache.org/jira/browse/FLINK-22900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359752#comment-17359752 ] Jingsong Lee commented on FLINK-22900: -- I think we can take a look to Hive, what is this behavior

[jira] [Updated] (FLINK-22472) The real partition data produced time is behind meta(_SUCCESS) file produced

[ https://issues.apache.org/jira/browse/FLINK-22472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-22472: - Fix Version/s: 1.14.0 > The real partition data produced time is behind meta(_SUCCESS) file

[jira] [Closed] (FLINK-22472) The real partition data produced time is behind meta(_SUCCESS) file produced

[ https://issues.apache.org/jira/browse/FLINK-22472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-22472. Resolution: Fixed Fixed via: master: feedfb23cdfef3d56a8cfaedf7fbaba4c83bb7cd > The real

[GitHub] [flink] JingsongLi merged pull request #16027: [FLINK-22472][filesystem] close file of partition when partition is committable

JingsongLi merged pull request #16027: URL: https://github.com/apache/flink/pull/16027 -- 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. For queries about this service,

[jira] [Updated] (FLINK-22894) Window Top-N should allow n=1

[ https://issues.apache.org/jira/browse/FLINK-22894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-22894: - Fix Version/s: 1.13.2 1.14.0 > Window Top-N should allow n=1 >

[jira] [Closed] (FLINK-22894) Window Top-N should allow n=1

[ https://issues.apache.org/jira/browse/FLINK-22894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-22894. Resolution: Fixed Fixed via: master: fcc4b89b7568cd955b139c8ebc5aa8f46e136a53 release-1.13: 

[GitHub] [flink] JingsongLi merged pull request #16088: [FLINK-22894][table-runtime-blink] Fix rankEnd validation of WindowRank to support top1

JingsongLi merged pull request #16088: URL: https://github.com/apache/flink/pull/16088 -- 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. For queries about this service,

[GitHub] [flink] JingsongLi commented on pull request #16088: [FLINK-22894][table-runtime-blink] Fix rankEnd validation of WindowRank to support top1

JingsongLi commented on pull request #16088: URL: https://github.com/apache/flink/pull/16088#issuecomment-857360201 Thanks @beyond1920 and @alpinegizmo , merging... -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Created] (FLINK-22937) rocksdb cause jvm to crash

Piers created FLINK-22937: - Summary: rocksdb cause jvm to crash Key: FLINK-22937 URL: https://issues.apache.org/jira/browse/FLINK-22937 Project: Flink Issue Type: Bug Components: Runtime /

[GitHub] [flink] flinkbot edited a comment on pull request #16115: [FLINK-22766][connector/kafka] Report offsets and Kafka consumer metrics in Flink metric group

flinkbot edited a comment on pull request #16115: URL: https://github.com/apache/flink/pull/16115#issuecomment-857350673 ## CI report: * 64d70892f99ab436c6bf52012e124874a11cbb18 Azure:

[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: * 618314849507f4b40536ae293ed3b0d128f0880b Azure:

[jira] [Commented] (FLINK-22735) HiveTableSourceITCase.testStreamPartitionReadByCreateTime failed because of times out

[ https://issues.apache.org/jira/browse/FLINK-22735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359745#comment-17359745 ] Rui Li commented on FLINK-22735: Hi [~frank wang], I have assigned this to you. FYI that I pushed a fix

[jira] [Commented] (FLINK-22735) HiveTableSourceITCase.testStreamPartitionReadByCreateTime failed because of times out

[ https://issues.apache.org/jira/browse/FLINK-22735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359744#comment-17359744 ] Xintong Song commented on FLINK-22735: -- Thanks for volunteering, [~frank wang]. You are assigned.

[jira] [Assigned] (FLINK-22735) HiveTableSourceITCase.testStreamPartitionReadByCreateTime failed because of times out

[ https://issues.apache.org/jira/browse/FLINK-22735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-22735: Assignee: frank wang > HiveTableSourceITCase.testStreamPartitionReadByCreateTime failed

[GitHub] [flink] flinkbot commented on pull request #16115: [FLINK-22766][connector/kafka] Report offsets and Kafka consumer metrics in Flink metric group

flinkbot commented on pull request #16115: URL: https://github.com/apache/flink/pull/16115#issuecomment-857350673 ## CI report: * 64d70892f99ab436c6bf52012e124874a11cbb18 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-22922) Migrate flink website to hugo

[ https://issues.apache.org/jira/browse/FLINK-22922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359736#comment-17359736 ] Zhilong Hong commented on FLINK-22922: -- +1 Issues like FLINK-18496 may get resolved after migrating

[jira] [Comment Edited] (FLINK-22900) flink 1.11.2 fileSystem source table read fileSystem sink table path multi-partition error

[ https://issues.apache.org/jira/browse/FLINK-22900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359733#comment-17359733 ] luoyuxia edited comment on FLINK-22900 at 6/9/21, 3:34 AM: --- [~bigdataf] Yes,

[jira] [Commented] (FLINK-22900) flink 1.11.2 fileSystem source table read fileSystem sink table path multi-partition error

[ https://issues.apache.org/jira/browse/FLINK-22900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359733#comment-17359733 ] luoyuxia commented on FLINK-22900: -- [~bigdataf] Yes, but I think we need more strict validation rule

[GitHub] [flink] flinkbot edited a comment on pull request #16094: [FLINK-22454][table-planner-blink] only ignore casting on interoperable type when extracting lookup keys

flinkbot edited a comment on pull request #16094: URL: https://github.com/apache/flink/pull/16094#issuecomment-855832127 ## CI report: * c9b01c5449e872a2686b7d6d40374322e9da2233 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: * 4ee376a8e46ff17a937ed6927d86557b06dfafa4 Azure:

[GitHub] [flink] flinkbot commented on pull request #16115: [FLINK-22766][connector/kafka] Report offsets and Kafka consumer metrics in Flink metric group

flinkbot commented on pull request #16115: URL: https://github.com/apache/flink/pull/16115#issuecomment-857337927 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-22766) Report metrics of KafkaConsumer in Kafka new source

[ https://issues.apache.org/jira/browse/FLINK-22766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22766: --- Labels: pull-request-available (was: ) > Report metrics of KafkaConsumer in Kafka new

[GitHub] [flink] PatrickRen opened a new pull request #16115: [FLINK-22766][connector/kafka] Report offsets and Kafka consumer metrics in Flink metric group

PatrickRen opened a new pull request #16115: URL: https://github.com/apache/flink/pull/16115 ## What is the purpose of the change This pull request adds offset metrics for Kafka source reader, and register metrics of Kafka consumer in Flink metric group ## Brief change

[jira] [Updated] (FLINK-19142) Investigate slot hijacking from preceding pipelined regions after failover

[ https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-19142: Labels: pull-request-available (was: pull-request-available stale-assigned) > Investigate slot hijacking

[jira] [Updated] (FLINK-22769) yarnship do not support symbolic directory

[ https://issues.apache.org/jira/browse/FLINK-22769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adrian Zhong updated FLINK-22769: - Description: If we pass `-yt ` a symbolic directory, we will get an exception:

[jira] [Commented] (FLINK-22735) HiveTableSourceITCase.testStreamPartitionReadByCreateTime failed because of times out

[ https://issues.apache.org/jira/browse/FLINK-22735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359720#comment-17359720 ] frank wang commented on FLINK-22735: i can help solve this problem, pls assign to me [~maguowei]. 

[GitHub] [flink] flinkbot edited a comment on pull request #16094: [FLINK-22454][table-planner-blink] only ignore casting on interoperable type when extracting lookup keys

flinkbot edited a comment on pull request #16094: URL: https://github.com/apache/flink/pull/16094#issuecomment-855832127 ## CI report: * c9b01c5449e872a2686b7d6d40374322e9da2233 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: * 4ee376a8e46ff17a937ed6927d86557b06dfafa4 Azure:

[jira] [Comment Edited] (FLINK-22889) JdbcExactlyOnceSinkE2eTest hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359717#comment-17359717 ] Xintong Song edited comment on FLINK-22889 at 6/9/21, 2:46 AM: --- on 1.13

[jira] [Commented] (FLINK-22907) SQL Client queries fails on select statement

[ https://issues.apache.org/jira/browse/FLINK-22907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359718#comment-17359718 ] Jark Wu commented on FLINK-22907: - [~rdarling] How did you load other connector jars? Did you load them

[jira] [Commented] (FLINK-22889) JdbcExactlyOnceSinkE2eTest hangs on azure

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

[jira] [Commented] (FLINK-22936) Support column comment in Schema and ResolvedSchema

[ https://issues.apache.org/jira/browse/FLINK-22936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359711#comment-17359711 ] Jark Wu commented on FLINK-22936: - What do you think [~twalthr] [~airblader]? > Support column comment

[jira] [Created] (FLINK-22936) Support column comment in Schema and ResolvedSchema

Jark Wu created FLINK-22936: --- Summary: Support column comment in Schema and ResolvedSchema Key: FLINK-22936 URL: https://issues.apache.org/jira/browse/FLINK-22936 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-18958) Lose column comment when create table

[ https://issues.apache.org/jira/browse/FLINK-18958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359714#comment-17359714 ] Jark Wu commented on FLINK-18958: - I created FLINK-22936. > Lose column comment when create table >

[jira] [Commented] (FLINK-18958) Lose column comment when create table

[ https://issues.apache.org/jira/browse/FLINK-18958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359706#comment-17359706 ] Jark Wu commented on FLINK-18958: - Hi [~Ada.h], as I commented in the pull request:

[jira] [Updated] (FLINK-22934) Add instructions for using the " ' " escape syntax of SQL client

[ https://issues.apache.org/jira/browse/FLINK-22934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22934: Component/s: (was: Table SQL / Client) Table SQL / API > Add instructions for using

[jira] [Commented] (FLINK-22921) SQL Client can't resolve the escape of " ' " correctly.

[ https://issues.apache.org/jira/browse/FLINK-22921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359702#comment-17359702 ] Roc Marshal commented on FLINK-22921: - I'm glad to do it. The target JIRA ID is FLINK-22934 > SQL

[jira] [Created] (FLINK-22935) Can not start standalone cluster

Lyubing Qiang created FLINK-22935: - Summary: Can not start standalone cluster Key: FLINK-22935 URL: https://issues.apache.org/jira/browse/FLINK-22935 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-22934) Add instructions for using the " ' " escape syntax of SQL client

[ https://issues.apache.org/jira/browse/FLINK-22934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-22934: Description: # FLINK-22921 > Add instructions for using the " ' " escape syntax of SQL client >

[jira] [Created] (FLINK-22934) Add instructions for using the " ' " escape syntax of SQL client

Roc Marshal created FLINK-22934: --- Summary: Add instructions for using the " ' " escape syntax of SQL client Key: FLINK-22934 URL: https://issues.apache.org/jira/browse/FLINK-22934 Project: Flink

[jira] [Comment Edited] (FLINK-22900) flink 1.11.2 fileSystem source table read fileSystem sink table path multi-partition error

[ https://issues.apache.org/jira/browse/FLINK-22900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359222#comment-17359222 ] luoyuxia edited comment on FLINK-22900 at 6/9/21, 2:02 AM: --- [~bigdataf]  Hi,

[jira] [Comment Edited] (FLINK-22900) flink 1.11.2 fileSystem source table read fileSystem sink table path multi-partition error

[ https://issues.apache.org/jira/browse/FLINK-22900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359222#comment-17359222 ] luoyuxia edited comment on FLINK-22900 at 6/9/21, 2:02 AM: --- [~bigdataf]  Hi,

[jira] [Commented] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

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

[jira] [Comment Edited] (FLINK-22900) flink 1.11.2 fileSystem source table read fileSystem sink table path multi-partition error

[ https://issues.apache.org/jira/browse/FLINK-22900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359222#comment-17359222 ] luoyuxia edited comment on FLINK-22900 at 6/9/21, 1:47 AM: --- [~bigdataf]  Hi,

[jira] [Comment Edited] (FLINK-22900) flink 1.11.2 fileSystem source table read fileSystem sink table path multi-partition error

[ https://issues.apache.org/jira/browse/FLINK-22900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359299#comment-17359299 ] bigdataf edited comment on FLINK-22900 at 6/9/21, 1:35 AM: --- [~luoyuxia] 

[jira] [Commented] (FLINK-18958) Lose column comment when create table

[ https://issues.apache.org/jira/browse/FLINK-18958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359674#comment-17359674 ] Ada Huang commented on FLINK-18958: --- I hope to be assigned this issue if no one takes. This problem

[jira] [Updated] (FLINK-22933) Upgrade the Flink Fabric8io/kubernetes-client version to >=5.4.0 to be FIPS compliant

[ https://issues.apache.org/jira/browse/FLINK-22933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fuyao Li updated FLINK-22933: - Description: The current Fabric8io version in Flink is 4.9.2 See link:

[jira] [Updated] (FLINK-22933) Upgrade the Flink Fabric8io/kubernetes-client version to >=5.4.0 to be FIPS compliant

[ https://issues.apache.org/jira/browse/FLINK-22933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fuyao Li updated FLINK-22933: - Description: The current Fabric8io version in Flink is 4.9.2 See link:

[jira] [Updated] (FLINK-22933) Upgrade the Flink Fabric8io/kubernetes-client version to >=5.4.0 to be FIPS compliant

[ https://issues.apache.org/jira/browse/FLINK-22933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fuyao Li updated FLINK-22933: - Description: The current Fabric8io version in Flink is 4.9.2 See link:

[jira] [Created] (FLINK-22933) Upgrade the Flink Fabric8io/kubernetes-client version to >=5.4.0 to be FIPS compliant

Fuyao Li created FLINK-22933: Summary: Upgrade the Flink Fabric8io/kubernetes-client version to >=5.4.0 to be FIPS compliant Key: FLINK-22933 URL: https://issues.apache.org/jira/browse/FLINK-22933

[jira] [Updated] (FLINK-11893) Update ecosystem page and add it to the navigation bar

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

[GitHub] [flink] flinkbot edited a comment on pull request #15200: [FLINK-21355] Send changes to the state changelog

flinkbot edited a comment on pull request #15200: URL: https://github.com/apache/flink/pull/15200#issuecomment-798902665 ## CI report: * 5e1342d9916f5c4356c622a40bc27bcbdacde9d7 UNKNOWN * df2c430e1946ea4fb3535604bcda4ca97d0f62fa Azure:

[jira] [Updated] (FLINK-16428) Fine-grained network buffer management for backpressure

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

[jira] [Updated] (FLINK-22443) can not be execute an extreme long sql under batch mode

[ https://issues.apache.org/jira/browse/FLINK-22443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22443: --- I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community

[jira] [Updated] (FLINK-22194) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers fail due to commit timeout

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

[jira] [Updated] (FLINK-11737) Support org.apache.hadoop.mapreduce.lib.output.MultipleOutputs output

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

[jira] [Updated] (FLINK-22464) OperatorEventSendingCheckpointITCase.testOperatorEventLostWithReaderFailure hangs with `AdaptiveScheduler`

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

[jira] [Updated] (FLINK-11813) Standby per job mode Dispatchers don't know job's JobSchedulingStatus

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

[jira] [Updated] (FLINK-11799) KryoSerializer/OperatorChain ignores copy failure resulting in NullPointerException

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

[jira] [Updated] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka connector

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

[jira] [Updated] (FLINK-11747) Elasticsearch 6 connector - Expose RestHighLevelClient to allow for custom sniffing

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

[jira] [Updated] (FLINK-11909) Provide default failure/timeout/backoff handling strategy for AsyncIO functions

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

[jira] [Updated] (FLINK-11818) Provide pipe transformation function for DataSet API

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

[jira] [Updated] (FLINK-11868) [filesystems] Introduce listStatusIterator API to file system

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

[jira] [Updated] (FLINK-11848) Delete outdated kafka topics caused UNKNOWN_TOPIC_EXCEPTIION

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

[jira] [Updated] (FLINK-11934) Remove the deprecate methods in TableEnvironment

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

[jira] [Updated] (FLINK-11982) BatchTableSourceFactory support Json Format File

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

[jira] [Updated] (FLINK-11968) Fix runtime SingleElementIterator.iterator and remove table.SingleElementIterator

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

[jira] [Updated] (FLINK-11936) Remove AuxiliaryConverter pull-in from calcite and fix auxiliary converter issue.

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

[jira] [Updated] (FLINK-11970) TableEnvironment#registerFunction should overwrite if the same name function existed.

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

[jira] [Updated] (FLINK-22611) add documentation about the semantics of timestamp for time window output

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

  1   2   3   4   5   >