[jira] [Commented] (FLINK-23614) The resulting scale of TRUNCATE(DECIMAL, ...) is not correct

[ https://issues.apache.org/jira/browse/FLINK-23614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394567#comment-17394567 ] Jingsong Lee commented on FLINK-23614: -- Thanks! > The resulting scale of TRUNCATE(

[jira] [Assigned] (FLINK-23614) The resulting scale of TRUNCATE(DECIMAL, ...) is not correct

[ https://issues.apache.org/jira/browse/FLINK-23614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-23614: Assignee: Yao Zhang (was: Jingsong Lee) > The resulting scale of TRUNCATE(DECIMAL, ...)

[jira] [Assigned] (FLINK-23614) The resulting scale of TRUNCATE(DECIMAL, ...) is not correct

[ https://issues.apache.org/jira/browse/FLINK-23614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-23614: Assignee: Jingsong Lee (was: Yao Zhang) > The resulting scale of TRUNCATE(DECIMAL, ...)

[jira] [Assigned] (FLINK-23614) The resulting scale of TRUNCATE(DECIMAL, ...) is not correct

[ https://issues.apache.org/jira/browse/FLINK-23614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk reassigned FLINK-23614: - Assignee: Yao Zhang > The resulting scale of TRUNCATE(DECIMAL, ...) is not correct > --

[GitHub] [flink] flinkbot commented on pull request #16733: [FLINK-22312][yarn][test] Fix log whitelist for AMRMClient heartbeat interruption.

flinkbot commented on pull request #16733: URL: https://github.com/apache/flink/pull/16733#issuecomment-894043073 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 pro

[jira] [Assigned] (FLINK-23607) Cleanup unnecessary dependencies in dstl pom.xml

[ https://issues.apache.org/jira/browse/FLINK-23607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei reassigned FLINK-23607: Assignee: Yuan Mei > Cleanup unnecessary dependencies in dstl pom.xml > -

[jira] [Updated] (FLINK-23607) Cleanup unnecessary dependencies in dstl pom.xml

[ https://issues.apache.org/jira/browse/FLINK-23607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-23607: - Description: - Clean up `flink-statebackend-changelog` denpendencies (move  flink-statebackend-changelog

[GitHub] [flink] flinkbot edited a comment on pull request #16732: [FLINK-21222][python] Support loopback mode to allow Python UDF worker and client reuse the same Python VM

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

[GitHub] [flink] flinkbot edited a comment on pull request #15229: [FLINK-19142][runtime] Fix slot hijacking after task failover

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

[GitHub] [flink] wuchong merged pull request #16711: [Hotfix][flink-sql-parser] Fixed typo.

wuchong merged pull request #16711: URL: https://github.com/apache/flink/pull/16711 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubsc

[jira] [Commented] (FLINK-23614) The resulting scale of TRUNCATE(DECIMAL, ...) is not correct

[ https://issues.apache.org/jira/browse/FLINK-23614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394549#comment-17394549 ] Caizhi Weng commented on FLINK-23614: - Hi [~paul8263]! I'm glad that you'd like to f

[jira] [Commented] (FLINK-23626) Migrate all TaskMG instantiations to factory method

[ https://issues.apache.org/jira/browse/FLINK-23626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394548#comment-17394548 ] liwei li commented on FLINK-23626: -- hi,Chesnay,i am interested to pick this task.. can

[GitHub] [flink] JingsongLi merged pull request #16730: Update japicmp configuration for 1.12.5

JingsongLi merged pull request #16730: URL: https://github.com/apache/flink/pull/16730 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsu

[GitHub] [flink] ZhijieYang closed pull request #16355: [hotfix] [docs] Fix document address does not match the actual web page.

ZhijieYang closed pull request #16355: URL: https://github.com/apache/flink/pull/16355 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsu

[GitHub] [flink] AHeise commented on a change in pull request #16559: [FLINK-18562] Support for Hadoop ABFS for Azure Datalake Gen2 accounts

AHeise commented on a change in pull request #16559: URL: https://github.com/apache/flink/pull/16559#discussion_r683976139 ## File path: flink-filesystems/flink-fs-hadoop-shaded/src/main/resources/META-INF/NOTICE ## @@ -33,7 +48,7 @@ See bundled license files for details. -

[jira] [Created] (FLINK-23659) Cleanup Prometheus reporter

Chesnay Schepler created FLINK-23659: Summary: Cleanup Prometheus reporter Key: FLINK-23659 URL: https://issues.apache.org/jira/browse/FLINK-23659 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-23614) The resulting scale of TRUNCATE(DECIMAL, ...) is not correct

[ https://issues.apache.org/jira/browse/FLINK-23614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394539#comment-17394539 ] Yao Zhang commented on FLINK-23614: --- I'm recently working on Flink SQL and could you p

[jira] [Created] (FLINK-23658) Cleanup JMX reporter

Chesnay Schepler created FLINK-23658: Summary: Cleanup JMX reporter Key: FLINK-23658 URL: https://issues.apache.org/jira/browse/FLINK-23658 Project: Flink Issue Type: Sub-task C

[jira] [Created] (FLINK-23657) Cleanup metric reporter modules

Chesnay Schepler created FLINK-23657: Summary: Cleanup metric reporter modules Key: FLINK-23657 URL: https://issues.apache.org/jira/browse/FLINK-23657 Project: Flink Issue Type: Technical

[GitHub] [flink] zentol commented on pull request #16720: [FLINK-23507] Use IP address of a kubernetes node when constructing node port connection string for the REST gateway.

zentol commented on pull request #16720: URL: https://github.com/apache/flink/pull/16720#issuecomment-894021231 The Kubernetes E2E tests are failing. https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=21597&view=logs&j=c88eea3b-64a0-564d-0031-9fdcd7b8abee&t=070ff179-953e

[jira] [Resolved] (FLINK-23617) Co-locate sink operators with same parallelism

[ https://issues.apache.org/jira/browse/FLINK-23617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23617. - Fix Version/s: 1.14.0 Resolution: Fixed Merged into master as 8c7da0358630bb92b8c77fb886

[GitHub] [flink] yanchenyun edited a comment on pull request #16371: [FLINK-23198][Documentation] Fix the demo of ConfigurableRocksDBOptionsFactory in Documentation.

yanchenyun edited a comment on pull request #16371: URL: https://github.com/apache/flink/pull/16371#issuecomment-894019015 I'll modify it as soon as possible, by next week at the latest! @Myasuka -- This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [flink] AHeise merged pull request #16701: [FLINK-23617][datastream] Co-locate sink operators with same parallelism

AHeise merged pull request #16701: URL: https://github.com/apache/flink/pull/16701 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr

[jira] [Commented] (FLINK-23647) UnalignedCheckpointStressITCase crashed on azure

[ https://issues.apache.org/jira/browse/FLINK-23647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394534#comment-17394534 ] Arvid Heise commented on FLINK-23647: - `listFiles` is an atomic operation afaik. The

[GitHub] [flink] yanchenyun edited a comment on pull request #16371: [FLINK-23198][Documentation] Fix the demo of ConfigurableRocksDBOptionsFactory in Documentation.

yanchenyun edited a comment on pull request #16371: URL: https://github.com/apache/flink/pull/16371#issuecomment-894019015 I'll modify it as soon as possible! @Myasuka -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] yanchenyun commented on pull request #16371: [FLINK-23198][Documentation] Fix the demo of ConfigurableRocksDBOptionsFactory in Documentation.

yanchenyun commented on pull request #16371: URL: https://github.com/apache/flink/pull/16371#issuecomment-894019015 I'll modify it as soon as possible! -- 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

[GitHub] [flink] Myasuka merged pull request #16729: Update japicmp configuration for 1.13.2

Myasuka merged pull request #16729: URL: https://github.com/apache/flink/pull/16729 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubsc

[jira] [Updated] (FLINK-23511) Fix the location error in metric page.

[ https://issues.apache.org/jira/browse/FLINK-23511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23511: - Fix Version/s: (was: 1.13.2) 1.13.3 > Fix the location error in metric page. > --

[jira] [Updated] (FLINK-23570) Documentation lists incorrect scala suffixes

[ https://issues.apache.org/jira/browse/FLINK-23570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-23570: - Summary: Documentation lists incorrect scala suffixes (was: Some of the maven dependenc

[jira] [Closed] (FLINK-23570) Some of the maven dependencies in the documentation seem to have some problems and cannot be used directly

[ https://issues.apache.org/jira/browse/FLINK-23570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-23570. Fix Version/s: 1.13.3 1.14.0 Resolution: Fixed master: 84f4cc2dd

[GitHub] [flink] Myasuka commented on pull request #16371: [FLINK-23198][Documentation] Fix the demo of ConfigurableRocksDBOptionsFactory in Documentation.

Myasuka commented on pull request #16371: URL: https://github.com/apache/flink/pull/16371#issuecomment-894015343 @yanchenyun could you update this PR with the comments? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Updated] (FLINK-23570) Some of the maven dependencies in the documentation seem to have some problems and cannot be used directly

[ https://issues.apache.org/jira/browse/FLINK-23570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-23570: - Affects Version/s: 1.14.0 > Some of the maven dependencies in the documentation seem to

[GitHub] [flink] zentol merged pull request #16660: [FLINK-23570][Documentation] Update the maven dependency of the File Sink page in the document

zentol merged pull request #16660: URL: https://github.com/apache/flink/pull/16660 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr

[jira] [Closed] (FLINK-23656) flink-sql-parser compile failed

[ https://issues.apache.org/jira/browse/FLINK-23656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-23656. --- Resolution: Invalid You need to build the project first by running {{mvn clean install -DskipTests -Dfast}}

[jira] [Updated] (FLINK-23626) Migrate all TaskMG instantiations to factory method

[ https://issues.apache.org/jira/browse/FLINK-23626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-23626: - Labels: starter (was: ) > Migrate all TaskMG instantiations to factory method > ---

[jira] [Updated] (FLINK-23627) Migrate all OperatorMG instantiations to factory method

[ https://issues.apache.org/jira/browse/FLINK-23627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-23627: - Labels: starter (was: ) > Migrate all OperatorMG instantiations to factory method > ---

[jira] [Updated] (FLINK-23625) Migrate all TaskManagerJobMG instantiations to factory method

[ https://issues.apache.org/jira/browse/FLINK-23625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-23625: - Labels: starter (was: ) > Migrate all TaskManagerJobMG instantiations to factory method

[jira] [Closed] (FLINK-23487) IRSA doesn't work with S3

[ https://issues.apache.org/jira/browse/FLINK-23487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-23487. Resolution: Fixed Hopefully fixed this time in 1.14.0: e8325ccc767740bcbe6505e2b2c64babb7714518 >

[jira] [Closed] (FLINK-23610) DefaultSchedulerTest.testProducedPartitionRegistrationTimeout fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-23610. Resolution: Fixed master: 4e69d07193fc26db163e6755f622d2eba4f63c7f > DefaultSchedulerTest

[GitHub] [flink] zentol merged pull request #16702: [FLINK-23610][tests] Harden DefaultSchedulerTest

zentol merged pull request #16702: URL: https://github.com/apache/flink/pull/16702 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr

[GitHub] [flink] twalthr closed pull request #16717: [FLINK-23487][FLINK-23635][s3] Update aws and presto-hive

twalthr closed pull request #16717: URL: https://github.com/apache/flink/pull/16717 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubsc

[jira] [Assigned] (FLINK-23625) Migrate all TaskManagerJobMG instantiations to factory method

[ https://issues.apache.org/jira/browse/FLINK-23625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-23625: Assignee: Shen Zhu > Migrate all TaskManagerJobMG instantiations to factory metho

[GitHub] [flink] flinkbot edited a comment on pull request #16723: [FLINK-22885][table] Supports 'SHOW COLUMNS' syntax.

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

[GitHub] [flink] flinkbot edited a comment on pull request #16559: [FLINK-18562] Support for Hadoop ABFS for Azure Datalake Gen2 accounts

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

[GitHub] [flink] curcur commented on a change in pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

curcur commented on a change in pull request #16606: URL: https://github.com/apache/flink/pull/16606#discussion_r683949531 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/EmbeddedRocksDBStateBackendTest.java

[jira] [Created] (FLINK-23656) flink-sql-parser compile failed

Yubin Li created FLINK-23656: Summary: flink-sql-parser compile failed Key: FLINK-23656 URL: https://issues.apache.org/jira/browse/FLINK-23656 Project: Flink Issue Type: Bug Components:

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

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

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

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

[jira] [Commented] (FLINK-22367) JobMasterStopWithSavepointITCase.terminateWithSavepointWithoutComplicationsShouldSucceedAndLeadJobToFinished times out

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

[GitHub] [flink] flinkbot edited a comment on pull request #16732: [FLINK-21222][python] Support loopback mode to allow Python UDF worker and client reuse the same Python VM

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

[GitHub] [flink] flinkbot edited a comment on pull request #16723: [FLINK-22885][table] Supports 'SHOW COLUMNS' syntax.

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

[GitHub] [flink] RocMarshal commented on pull request #16711: [Hotfix][flink-sql-parser] Fixed typo.

RocMarshal commented on pull request #16711: URL: https://github.com/apache/flink/pull/16711#issuecomment-893996474 Hi, @wuchong , there is a minor typo. Could you please help me to check it ? Thank you very much. -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot edited a comment on pull request #16687: [FLINK-22767][coordination] Optimize the initialization of LocalInputPreferredSlotSharingStrategy

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

[GitHub] [flink] flinkbot edited a comment on pull request #16575: [FLINK-23139][state] Add TaskStateRegistry

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

[GitHub] [flink] flinkbot edited a comment on pull request #16430: [FLINK-23032][hive] Refactor HiveSource to make it usable in data str…

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

[jira] [Closed] (FLINK-23655) Custom transformation name displayed on the web, when using Flink Table & SQL API, just like the name method of SingleOutputStreamOperator , or remove the SQL content dis

[ https://issues.apache.org/jira/browse/FLINK-23655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-23655. --- Resolution: Invalid > Custom transformation name displayed on the web, when using Flink Table & SQL > API,

[jira] [Commented] (FLINK-23655) Custom transformation name displayed on the web, when using Flink Table & SQL API, just like the name method of SingleOutputStreamOperator , or remove the SQL content

[ https://issues.apache.org/jira/browse/FLINK-23655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394509#comment-17394509 ] Jark Wu commented on FLINK-23655: - [~liliwei], I think the problem is secrets shouldn't

[jira] [Commented] (FLINK-23625) Migrate all TaskManagerJobMG instantiations to factory method

[ https://issues.apache.org/jira/browse/FLINK-23625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394498#comment-17394498 ] Shen Zhu commented on FLINK-23625: -- Hey Chesnay, I'm interested in working on this tic

[GitHub] [flink] flinkbot edited a comment on pull request #16731: [FLINK-23612][table-runtime] Fix compile exception for ROUND function with some numeric input arguments

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

[GitHub] [flink] flinkbot commented on pull request #16732: [FLINK-21222][python] Support loopback mode to allow Python UDF worker and client reuse the same Python VM

flinkbot commented on pull request #16732: URL: https://github.com/apache/flink/pull/16732#issuecomment-893984711 ## CI report: * 436c8922595728ab1158d2255dd766fdb4485576 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #16707: [BP-1.13][FLINK-22891][runtime] Using CompletableFuture to sync the scheduling of checkResourceRequirements

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

[GitHub] [flink] flinkbot edited a comment on pull request #16687: [FLINK-22767][coordination] Optimize the initialization of LocalInputPreferredSlotSharingStrategy

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

[GitHub] [flink] flinkbot edited a comment on pull request #16430: [FLINK-23032][hive] Refactor HiveSource to make it usable in data str…

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

[GitHub] [flink] flinkbot edited a comment on pull request #15229: [FLINK-19142][runtime] Fix slot hijacking after task failover

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

[jira] [Assigned] (FLINK-23592) Format of the "Table API & SQL >> Concepts & Common API" Chinese document is a mess

[ https://issues.apache.org/jira/browse/FLINK-23592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-23592: --- Assignee: ZhiJie Yang > Format of the "Table API & SQL >> Concepts & Common API" Chinese document i

[jira] [Updated] (FLINK-23643) Support RANK() function for TopN

[ https://issues.apache.org/jira/browse/FLINK-23643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-23643: Summary: Support RANK() function for TopN (was: I repeated the same problem: ROW/RANGE not allowed with R

[jira] [Commented] (FLINK-23643) I repeated the same problem: ROW/RANGE not allowed with RANK, DENSE_RANK or ROW_NUMBER functions

[ https://issues.apache.org/jira/browse/FLINK-23643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394493#comment-17394493 ] Jark Wu commented on FLINK-23643: - Got it. I'm +1 to support RANK(). > I repeated the

[jira] [Updated] (FLINK-23643) I repeated the same problem: ROW/RANGE not allowed with RANK, DENSE_RANK or ROW_NUMBER functions

[ https://issues.apache.org/jira/browse/FLINK-23643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-23643: Issue Type: New Feature (was: Bug) > I repeated the same problem: ROW/RANGE not allowed with RANK, DENSE_

[GitHub] [flink] flinkbot commented on pull request #16732: [FLINK-21222][python] Support loopback mode to allow Python UDF worker and client reuse the same Python VM

flinkbot commented on pull request #16732: URL: https://github.com/apache/flink/pull/16732#issuecomment-893980043 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 pro

[jira] [Commented] (FLINK-23592) Format of the "Table API & SQL >> Concepts & Common API" Chinese document is a mess

[ https://issues.apache.org/jira/browse/FLINK-23592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394490#comment-17394490 ] ZhiJie Yang commented on FLINK-23592: - [~TsReaper] ok, I will fix it.[~jark], can yo

[jira] [Assigned] (FLINK-21222) Support loopback mode to allow Python UDF worker and client reuse the same Python VM

[ https://issues.apache.org/jira/browse/FLINK-21222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-21222: Assignee: Huang Xingbo > Support loopback mode to allow Python UDF worker and client reus

[jira] [Updated] (FLINK-21222) Support loopback mode to allow Python UDF worker and client reuse the same Python VM

[ https://issues.apache.org/jira/browse/FLINK-21222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21222: --- Labels: auto-unassigned pull-request-available (was: auto-unassigned) > Support loopback mo

[GitHub] [flink] HuangXingBo opened a new pull request #16732: [FLINK-21222][python] Support loopback mode to allow Python UDF worker and client reuse the same Python VM

HuangXingBo opened a new pull request #16732: URL: https://github.com/apache/flink/pull/16732 ## What is the purpose of the change *This pull request will support loopback mode to allow Python UDF worker and client reuse the same Python VM* ## Brief change log - *Supp

[GitHub] [flink] flinkbot commented on pull request #16731: [FLINK-23612][table-runtime] Fix compile exception for ROUND function with some numeric input arguments

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

[GitHub] [flink] flinkbot edited a comment on pull request #16730: Update japicmp configuration for 1.12.5

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

[GitHub] [flink] flinkbot edited a comment on pull request #16723: [FLINK-22885][table] Supports 'SHOW COLUMNS' syntax.

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

[GitHub] [flink] flinkbot edited a comment on pull request #16707: [BP-1.13][FLINK-22891][runtime] Using CompletableFuture to sync the scheduling of checkResourceRequirements

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

[GitHub] [flink] flinkbot edited a comment on pull request #15229: [FLINK-19142][runtime] Fix slot hijacking after task failover

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

[jira] [Updated] (FLINK-23655) Custom transformation name displayed on the web, when using Flink Table & SQL API, just like the name method of SingleOutputStreamOperator , or remove the SQL content di

[ https://issues.apache.org/jira/browse/FLINK-23655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liwei li updated FLINK-23655: - Description: Currently, Flink web displays part of sql select statements(transformation name), but when

[jira] [Updated] (FLINK-23655) Custom transformation name displayed on the web, when using Flink Table & SQL API, just like the name method of SingleOutputStreamOperator , or remove the SQL content di

[ https://issues.apache.org/jira/browse/FLINK-23655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liwei li updated FLINK-23655: - Attachment: (was: image-2021-08-06-11-08-45-931.png) > Custom transformation name displayed on the w

[jira] [Updated] (FLINK-23655) Custom transformation name displayed on the web, when using Flink Table & SQL API, just like the name method of SingleOutputStreamOperator , or remove the SQL content di

[ https://issues.apache.org/jira/browse/FLINK-23655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liwei li updated FLINK-23655: - Attachment: image-2021-08-06-11-33-38-242.png > Custom transformation name displayed on the web, when us

[jira] [Comment Edited] (FLINK-23478) KubernetesSharedInformerITCase.testWatchWithBlockHandler fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394485#comment-17394485 ] Yi Tang edited comment on FLINK-23478 at 8/6/21, 3:31 AM: -- Hi [

[jira] [Comment Edited] (FLINK-23478) KubernetesSharedInformerITCase.testWatchWithBlockHandler fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394485#comment-17394485 ] Yi Tang edited comment on FLINK-23478 at 8/6/21, 3:30 AM: -- Hi [

[GitHub] [flink] beyond1920 edited a comment on pull request #16669: [FLINK-23544][table-planner]Window TVF Supports session window

beyond1920 edited a comment on pull request #16669: URL: https://github.com/apache/flink/pull/16669#issuecomment-893974306 @cshuo Thanks for advices, however I prefer the first choice fr the following reason: 1. It's better to have a clear separation from WindowAggregate and old GroupWi

[GitHub] [flink] beyond1920 edited a comment on pull request #16669: [FLINK-23544][table-planner]Window TVF Supports session window

beyond1920 edited a comment on pull request #16669: URL: https://github.com/apache/flink/pull/16669#issuecomment-893974306 @cshuo Thanks for advices, however I prefer the first choice fr the following reason: 1. It's better to have a clear separation from WindowAggregate and old GroupWi

[jira] [Commented] (FLINK-23478) KubernetesSharedInformerITCase.testWatchWithBlockHandler fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394485#comment-17394485 ] Yi Tang commented on FLINK-23478: - Hi [~dwysakowicz] [~xtsong], thanks for your report

[jira] [Updated] (FLINK-23655) Custom transformation name displayed on the web, when using Flink Table & SQL API, just like the name method of SingleOutputStreamOperator , or remove the SQL content di

[ https://issues.apache.org/jira/browse/FLINK-23655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liwei li updated FLINK-23655: - Description: Currently, Flink web displays part of sql select statements(transformation name), but when

[jira] [Created] (FLINK-23655) Custom transformation name displayed on the web, when using Flink Table & SQL API, just like the name method of SingleOutputStreamOperator , or remove the SQL content di

liwei li created FLINK-23655: Summary: Custom transformation name displayed on the web, when using Flink Table & SQL API, just like the name method of SingleOutputStreamOperator , or remove the SQL content display directly. Key: FLIN

[GitHub] [flink] beyond1920 commented on pull request #16669: [FLINK-23544][table-planner]Window TVF Supports session window

beyond1920 commented on pull request #16669: URL: https://github.com/apache/flink/pull/16669#issuecomment-893974306 @cshuo Thanks for advices, however I prefer the first choice fr the following reason: 1. It's better to have a clear separation from WindowAggregate and old GroupWindowAgg

[jira] [Commented] (FLINK-22387) UpsertKafkaTableITCase hangs when setting up kafka

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

[jira] [Commented] (FLINK-22545) JVM crashes when runing OperatorEventSendingCheckpointITCase.testOperatorEventAckLost

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

[jira] [Commented] (FLINK-22367) JobMasterStopWithSavepointITCase.terminateWithSavepointWithoutComplicationsShouldSucceedAndLeadJobToFinished times out

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

[jira] [Commented] (FLINK-23592) Format of the "Table API & SQL >> Concepts & Common API" Chinese document is a mess

[ https://issues.apache.org/jira/browse/FLINK-23592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394475#comment-17394475 ] Caizhi Weng commented on FLINK-23592: - Hi [~yangzhijie], sorry for the late reply. I

[jira] [Commented] (FLINK-22545) JVM crashes when runing OperatorEventSendingCheckpointITCase.testOperatorEventAckLost

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

[GitHub] [flink-web] Myasuka merged pull request #453: Add release 1.13.2

Myasuka merged pull request #453: URL: https://github.com/apache/flink-web/pull/453 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubsc

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

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

[jira] [Updated] (FLINK-23615) Documentation of the TRUNCATE SQL function is not correct

[ https://issues.apache.org/jira/browse/FLINK-23615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-23615: Labels: starter (was: ) > Documentation of the TRUNCATE SQL function is not correct > ---

[jira] [Comment Edited] (FLINK-22246) when use HiveCatalog create table , can't set Table owner property correctly

[ https://issues.apache.org/jira/browse/FLINK-22246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394469#comment-17394469 ] Bo Cui edited comment on FLINK-22246 at 8/6/21, 3:14 AM: - i also

[jira] [Commented] (FLINK-23556) SQLClientSchemaRegistryITCase fails with " Subject ... not found"

[ https://issues.apache.org/jira/browse/FLINK-23556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394471#comment-17394471 ] Xintong Song commented on FLINK-23556: -- [~jark], any idea who would make a best can

[jira] [Commented] (FLINK-22246) when use HiveCatalog create table , can't set Table owner property correctly

[ https://issues.apache.org/jira/browse/FLINK-22246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394469#comment-17394469 ] Bo Cui commented on FLINK-22246: i think the issue can be solved in HiveTableUtil#instan

  1   2   3   4   5   6   7   8   >