[GitHub] [flink] flinkbot commented on pull request #23144: [BP-1.17][FLINK-32261][table] Add built-in MAP_UNION function.

2023-08-04 Thread via GitHub
flinkbot commented on PR #23144: URL: https://github.com/apache/flink/pull/23144#issuecomment-1666393524 ## CI report: * ae352d372df44f4d3b8bcce8a14a16b910d056e3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] hanyuzheng7 commented on pull request #23144: [BP-1.17][FLINK-32261][table] Add built-in MAP_UNION function.

2023-08-04 Thread via GitHub
hanyuzheng7 commented on PR #23144: URL: https://github.com/apache/flink/pull/23144#issuecomment-1666393326 @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 specific

[GitHub] [flink] hanyuzheng7 opened a new pull request, #23144: [BP-1.17][FLINK-32261][table] Add built-in MAP_UNION function.

2023-08-04 Thread via GitHub
hanyuzheng7 opened a new pull request, #23144: URL: https://github.com/apache/flink/pull/23144 ## What is the purpose of the change This is an implementation of MAP_UNION Returns a map created by merging at least one map. These maps should have a common map type. If there are

[GitHub] [flink] flinkbot commented on pull request #23143: [FLINK-32759][doc] Remove the `cluster.declarative-resource-management.enabled` in doc

2023-08-04 Thread via GitHub
flinkbot commented on PR #23143: URL: https://github.com/apache/flink/pull/23143#issuecomment-1666379967 ## CI report: * 7ee09938a1c348b0d1552fc1ad3a41d598fd2beb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32759) Remove the removed config in the doc

2023-08-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32759: --- Labels: pull-request-available (was: ) > Remove the removed config in the doc >

[GitHub] [flink] 1996fanrui opened a new pull request, #23143: [FLINK-32759][doc] Remove the `cluster.declarative-resource-management.enabled` in doc

2023-08-04 Thread via GitHub
1996fanrui opened a new pull request, #23143: URL: https://github.com/apache/flink/pull/23143 ## What is the purpose of the change he cluster.declarative-resource-management.enabled was removed at

[jira] [Created] (FLINK-32759) Remove the removed config in the doc

2023-08-04 Thread Rui Fan (Jira)
Rui Fan created FLINK-32759: --- Summary: Remove the removed config in the doc Key: FLINK-32759 URL: https://issues.apache.org/jira/browse/FLINK-32759 Project: Flink Issue Type: Technical Debt

[GitHub] [flink] hanyuzheng7 commented on pull request #23098: [BP-1.17][FLINK-32262] Add MAP_ENTRIES support

2023-08-04 Thread via GitHub
hanyuzheng7 commented on PR #23098: URL: https://github.com/apache/flink/pull/23098#issuecomment-1666377009 @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 specific

[jira] [Commented] (FLINK-32755) Add quick start guide for Flink OLAP

2023-08-04 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751246#comment-17751246 ] xiangyu feng commented on FLINK-32755: -- Hi [~zjureel], the quick start guide will also include

[jira] [Comment Edited] (FLINK-32716) Give 'None' option for 'scheduler-mode'

2023-08-04 Thread Kwangin (Dennis) Jung (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17750517#comment-17750517 ] Kwangin (Dennis) Jung edited comment on FLINK-32716 at 8/5/23 1:10 AM:

[jira] [Updated] (FLINK-32716) Give 'None' option for 'scheduler-mode'

2023-08-04 Thread Kwangin (Dennis) Jung (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kwangin (Dennis) Jung updated FLINK-32716: -- Description: By setting-up scheduler-mode as 'REACTIVE', it scales-up/down by

[GitHub] [flink] hanyuzheng7 closed pull request #23142: test

2023-08-04 Thread via GitHub
hanyuzheng7 closed pull request #23142: test URL: https://github.com/apache/flink/pull/23142 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] hanyuzheng7 opened a new pull request, #23142: test

2023-08-04 Thread via GitHub
hanyuzheng7 opened a new pull request, #23142: URL: https://github.com/apache/flink/pull/23142 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring

[jira] [Created] (FLINK-32758) PyFlink bounds are overly restrictive and outdated

2023-08-04 Thread Deepyaman Datta (Jira)
Deepyaman Datta created FLINK-32758: --- Summary: PyFlink bounds are overly restrictive and outdated Key: FLINK-32758 URL: https://issues.apache.org/jira/browse/FLINK-32758 Project: Flink

[jira] [Assigned] (FLINK-32757) Update the copyright year in NOTICE files

2023-08-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-32757: --- Assignee: Jiabao Sun > Update the copyright year in NOTICE files >

[jira] [Resolved] (FLINK-32757) Update the copyright year in NOTICE files

2023-08-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-32757. - Resolution: Fixed > Update the copyright year in NOTICE files >

[jira] [Commented] (FLINK-32757) Update the copyright year in NOTICE files

2023-08-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751227#comment-17751227 ] Hong Liang Teoh commented on FLINK-32757: - Merged commit

[GitHub] [flink-kubernetes-operator] HuangZhenQiu opened a new pull request, #642: [FLINK-32729] allow new deployment with suspended state

2023-08-04 Thread via GitHub
HuangZhenQiu opened a new pull request, #642: URL: https://github.com/apache/flink-kubernetes-operator/pull/642 ## What is the purpose of the change Allow new deployment with suspended state. So that a backup application can created in advance. ## Brief change log - Change

[GitHub] [flink] XComp closed pull request #21555: [FLINK-26522][draft] Cleanup of LeaderElectionService

2023-08-04 Thread via GitHub
XComp closed pull request #21555: [FLINK-26522][draft] Cleanup of LeaderElectionService URL: https://github.com/apache/flink/pull/21555 -- 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

[GitHub] [flink] flinkbot commented on pull request #23141: [python] Remove PyFlink dependencies' upper bounds

2023-08-04 Thread via GitHub
flinkbot commented on PR #23141: URL: https://github.com/apache/flink/pull/23141#issuecomment-1666055186 ## CI report: * 118206bfb082af7903c5c0ec135d0f4ef9c6841e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] deepyaman opened a new pull request, #23141: [python] Remove PyFlink dependencies' upper bounds

2023-08-04 Thread via GitHub
deepyaman opened a new pull request, #23141: URL: https://github.com/apache/flink/pull/23141 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[jira] [Updated] (FLINK-32756) Reuse ClientHighAvailabilityServices in RestClusterClient when submitting OLAP jobs

2023-08-04 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangyu feng updated FLINK-32756: - Description: In OLAP scenario, we submit queries to flink session cluster through the

[jira] [Updated] (FLINK-32756) Reuse ClientHighAvailabilityServices in RestClusterClient when submitting OLAP jobs

2023-08-04 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangyu feng updated FLINK-32756: - Description: In OLAP scenario, we submit queries to flink session cluster through the

[jira] [Updated] (FLINK-32756) Reuse ClientHighAvailabilityServices in RestClusterClient when submitting OLAP jobs

2023-08-04 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangyu feng updated FLINK-32756: - Description: In OLAP scenario, we submit queries to flink session cluster through the

[GitHub] [flink-connector-mongodb] Jiabao-Sun commented on pull request #14: [FLINK-32757][connectors/mongodb][build] Update the copyright with year 2023

2023-08-04 Thread via GitHub
Jiabao-Sun commented on PR #14: URL: https://github.com/apache/flink-connector-mongodb/pull/14#issuecomment-1665934374 Hi @dannycranmer, Could you help review this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Updated] (FLINK-32757) Update the copyright year in NOTICE files

2023-08-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32757: --- Labels: pull-request-available (was: ) > Update the copyright year in NOTICE files >

[jira] [Created] (FLINK-32757) Update the copyright year in NOTICE files

2023-08-04 Thread Jiabao Sun (Jira)
Jiabao Sun created FLINK-32757: -- Summary: Update the copyright year in NOTICE files Key: FLINK-32757 URL: https://issues.apache.org/jira/browse/FLINK-32757 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on pull request #23140: [hotfix] Fix some typo in java doc and comments

2023-08-04 Thread via GitHub
flinkbot commented on PR #23140: URL: https://github.com/apache/flink/pull/23140#issuecomment-1665863480 ## CI report: * b2d0952def78f5a644621cbd8f852fba8120b32d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] zoltar9264 commented on pull request #23140: [hotfix] Fix some typo in java doc and comments

2023-08-04 Thread via GitHub
zoltar9264 commented on PR #23140: URL: https://github.com/apache/flink/pull/23140#issuecomment-1665861589 Hi @reswqa , I try fix some type, can you help to review it ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] zoltar9264 opened a new pull request, #23140: [hotfix] Fix some typo in java doc and comments

2023-08-04 Thread via GitHub
zoltar9264 opened a new pull request, #23140: URL: https://github.com/apache/flink/pull/23140 ## What is the purpose of the change As the title, fix some typo in java doc and comments. ## Verifying this change This change is a trivial rework / code cleanup without

[jira] [Updated] (FLINK-32756) Reuse ClientHighAvailabilityServices in RestClusterClient when submitting OLAP jobs

2023-08-04 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangyu feng updated FLINK-32756: - Description: In OLAP scenario, we submit queries to flink session cluster through the

[jira] [Updated] (FLINK-32756) Reuse ClientHighAvailabilityServices in RestClusterClient when submitting OLAP jobs

2023-08-04 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangyu feng updated FLINK-32756: - Description: In OLAP scenario, we submit queries to flink session cluster through the

[jira] [Updated] (FLINK-32756) Reuse ClientHighAvailabilityServices in RestClusterClient when submitting OLAP jobs

2023-08-04 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangyu feng updated FLINK-32756: - Summary: Reuse ClientHighAvailabilityServices in RestClusterClient when submitting OLAP jobs

[jira] [Updated] (FLINK-32756) Reues ZK connections when submitting OLAP jobs to Flink session cluster

2023-08-04 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangyu feng updated FLINK-32756: - Description: In OLAP scenario, we submit queries to flink session cluster through the

[GitHub] [flink] Samrat002 commented on a diff in pull request #21458: [FLINK-28513] Fix Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-08-04 Thread via GitHub
Samrat002 commented on code in PR #21458: URL: https://github.com/apache/flink/pull/21458#discussion_r1284570168 ## flink-filesystems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/writer/S3RecoverableFsDataOutputStream.java: ## @@ -126,7 +126,9 @@ public long

[GitHub] [flink] Samrat002 commented on pull request #21458: [FLINK-28513] Fix Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-08-04 Thread via GitHub
Samrat002 commented on PR #21458: URL: https://github.com/apache/flink/pull/21458#issuecomment-1665786834 @dannycranmer please review whenever time -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[jira] [Resolved] (FLINK-32736) Add a post to announce new connectors and connector externalisation

2023-08-04 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-32736. --- Resolution: Done > Add a post to announce new connectors and connector externalisation >

[jira] [Commented] (FLINK-32736) Add a post to announce new connectors and connector externalisation

2023-08-04 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751146#comment-17751146 ] Danny Cranmer commented on FLINK-32736: --- Merged commit

[jira] [Updated] (FLINK-32736) Add a post to announce new connectors and connector externalisation

2023-08-04 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-32736: -- Fix Version/s: (was: 1.18.0) > Add a post to announce new connectors and connector

[GitHub] [flink-web] dannycranmer merged pull request #668: [FLINK-32736] Externalized connectors

2023-08-04 Thread via GitHub
dannycranmer merged PR #668: URL: https://github.com/apache/flink-web/pull/668 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-32565) Support cast from NUMBER to BYTES

2023-08-04 Thread Hanyu Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751138#comment-17751138 ] Hanyu Zheng commented on FLINK-32565: - [~twalthr] , Through research, It seem that other vendors use

[jira] [Commented] (FLINK-32564) Support cast from BYTES to NUMBER

2023-08-04 Thread Hanyu Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751139#comment-17751139 ] Hanyu Zheng commented on FLINK-32564: - [~twalthr] , Through research, It seem that other vendors use

[jira] [Updated] (FLINK-32565) Support cast from NUMBER to BYTES

2023-08-04 Thread Hanyu Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hanyu Zheng updated FLINK-32565: Description: We are undertaking a task that requires casting from the DOUBLE type to BYTES In

[jira] [Updated] (FLINK-32565) Support cast from NUMBER to BYTES

2023-08-04 Thread Hanyu Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hanyu Zheng updated FLINK-32565: Description: We are undertaking a task that requires casting from the DOUBLE type to BYTES In

[jira] [Updated] (FLINK-32565) Support cast from NUMBER to BYTES

2023-08-04 Thread Hanyu Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hanyu Zheng updated FLINK-32565: Description: We are undertaking a task that requires casting from the DOUBLE type to BYTES In

[jira] [Updated] (FLINK-32564) Support cast from BYTES to NUMBER

2023-08-04 Thread Hanyu Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hanyu Zheng updated FLINK-32564: Description: We are dealing with a task that requires casting from the BYTES type to BIGINT.

[jira] [Updated] (FLINK-32564) Support cast from BYTES to NUMBER

2023-08-04 Thread Hanyu Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hanyu Zheng updated FLINK-32564: Description: We are dealing with a task that requires casting from the BYTES type to BIGINT.

[jira] [Updated] (FLINK-32564) Support cast from BYTES to NUMBER

2023-08-04 Thread Hanyu Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hanyu Zheng updated FLINK-32564: Description: We are dealing with a task that requires casting from the BYTES type to BIGINT.

[jira] [Updated] (FLINK-32564) Support cast from BYTES to NUMBER

2023-08-04 Thread Hanyu Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hanyu Zheng updated FLINK-32564: Description: We are dealing with a task that requires casting from the BYTES type to BIGINT.

[jira] [Updated] (FLINK-32564) Support cast from BYTES to NUMBER

2023-08-04 Thread Hanyu Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hanyu Zheng updated FLINK-32564: Description: We are dealing with a task that requires casting from the BYTES type to BIGINT.

[GitHub] [flink] Samrat002 commented on a diff in pull request #21458: [FLINK-28513] Fix Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-08-04 Thread via GitHub
Samrat002 commented on code in PR #21458: URL: https://github.com/apache/flink/pull/21458#discussion_r1284527153 ## flink-filesystems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/writer/S3RecoverableFsDataOutputStream.java: ## @@ -126,7 +126,16 @@ public long

[jira] [Updated] (FLINK-32756) Reues ZK connections when submitting OLAP jobs to Flink session cluster

2023-08-04 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangyu feng updated FLINK-32756: - Summary: Reues ZK connections when submitting OLAP jobs to Flink session cluster (was: Reues

[jira] [Resolved] (FLINK-24370) [FLIP-171] Documentation for Generic AsyncSinkBase

2023-08-04 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-24370. --- Resolution: Done > [FLIP-171] Documentation for Generic AsyncSinkBase >

[jira] [Resolved] (FLINK-24278) [FLIP-171] Async Sink Base Sink Developer Guide for Documentation

2023-08-04 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-24278. --- Resolution: Done > [FLIP-171] Async Sink Base Sink Developer Guide for Documentation >

[jira] [Commented] (FLINK-24278) [FLIP-171] Async Sink Base Sink Developer Guide for Documentation

2023-08-04 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751128#comment-17751128 ] Danny Cranmer commented on FLINK-24278: --- This is done, we published a blog

[GitHub] [flink] XComp commented on a diff in pull request #22341: [FLINK-27204][flink-runtime] Refract FileSystemJobResultStore to execute I/O operations on the ioExecutor

2023-08-04 Thread via GitHub
XComp commented on code in PR #22341: URL: https://github.com/apache/flink/pull/22341#discussion_r1284412779 ## flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java: ## @@ -561,21 +563,28 @@ public CompletableFuture submitFailedJob( return

[jira] [Updated] (FLINK-32746) Using ZGC in JDK17 to solve long time class unloading STW

2023-08-04 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangyu feng updated FLINK-32746: - Summary: Using ZGC in JDK17 to solve long time class unloading STW (was: Enable ZGC in JDK17

[GitHub] [flink-web] dannycranmer opened a new pull request, #669: MongoDB connector v1.0.2

2023-08-04 Thread via GitHub
dannycranmer opened a new pull request, #669: URL: https://github.com/apache/flink-web/pull/669 (no comment) -- 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

[jira] [Comment Edited] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP

2023-08-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751105#comment-17751105 ] Matthias Pohl edited comment on FLINK-32751 at 8/4/23 1:00 PM: --- The actual

[jira] [Commented] (FLINK-32604) PyFlink end-to-end fails with kafka-server-stop.sh: No such file or directory

2023-08-04 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751114#comment-17751114 ] Sergey Nuyanzin commented on FLINK-32604: -

[jira] [Commented] (FLINK-30719) flink-runtime-web failed due to a corrupted

2023-08-04 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751112#comment-17751112 ] Sergey Nuyanzin commented on FLINK-30719: -

[jira] [Commented] (FLINK-29913) Shared state would be discarded by mistake when maxConcurrentCheckpoint>1

2023-08-04 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1775#comment-1775 ] Feifan Wang commented on FLINK-29913: - [~roman] ,  I submitted two PRs for

[jira] [Commented] (FLINK-32667) Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster

2023-08-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751107#comment-17751107 ] Matthias Pohl commented on FLINK-32667: --- Thanks, [~zjureel]. I think it's a good idea to initiate

[jira] [Commented] (FLINK-32751) DistinctAggregateITCaseBase.testMultiDistinctAggOnDifferentColumn got stuck on AZP

2023-08-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751105#comment-17751105 ] Matthias Pohl commented on FLINK-32751: --- The actual test failure happened in

[jira] [Commented] (FLINK-32755) Add quick start guide for Flink OLAP

2023-08-04 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751101#comment-17751101 ] dalongliu commented on FLINK-32755: --- Big +1 > Add quick start guide for Flink OLAP >

[GitHub] [flink] luoyuxia commented on a diff in pull request #23109: [FLINK-32475][docs] Add doc for time travel

2023-08-04 Thread via GitHub
luoyuxia commented on code in PR #23109: URL: https://github.com/apache/flink/pull/23109#discussion_r1284335758 ## docs/content/docs/dev/table/sql/queries/time-travel.md: ## @@ -0,0 +1,68 @@ +--- +title: Time Travel +weight: 18 +type: docs +--- + + +# Time Travel + +{{< label

[jira] [Commented] (FLINK-32754) Using SplitEnumeratorContext.metricGroup() in restoreEnumerator causes NPE

2023-08-04 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751098#comment-17751098 ] Yun Tang commented on FLINK-32754: -- I think this problem still existed, and [~ruanhang1993] could you

[GitHub] [flink] luoyuxia commented on a diff in pull request #23116: [FLINK-32581][docs] Add docs for atomic CTAS and RTAS

2023-08-04 Thread via GitHub
luoyuxia commented on code in PR #23116: URL: https://github.com/apache/flink/pull/23116#discussion_r1284307429 ## docs/content.zh/docs/dev/table/sql/create.md: ## @@ -554,7 +554,13 @@ INSERT INTO my_ctas_table SELECT id, name, age FROM source_table WHERE mod(id, 1 *

[jira] [Commented] (FLINK-32667) Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster

2023-08-04 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751092#comment-17751092 ] Fang Yong commented on FLINK-32667: --- [~mapohl] I think performance testing is a good suggestion, we

[jira] [Commented] (FLINK-32755) Add quick start guide for Flink OLAP

2023-08-04 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751088#comment-17751088 ] Benchao Li commented on FLINK-32755: +1 > Add quick start guide for Flink OLAP >

[jira] [Updated] (FLINK-32756) Reues ZK CuratorFramework when submitting OLAP jobs to Flink session cluster

2023-08-04 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangyu feng updated FLINK-32756: - Component/s: Client / Job Submission > Reues ZK CuratorFramework when submitting OLAP jobs to

[jira] [Created] (FLINK-32756) Reues ZK CuratorFramework when submitting OLAP jobs to Flink session cluster

2023-08-04 Thread xiangyu feng (Jira)
xiangyu feng created FLINK-32756: Summary: Reues ZK CuratorFramework when submitting OLAP jobs to Flink session cluster Key: FLINK-32756 URL: https://issues.apache.org/jira/browse/FLINK-32756

[jira] [Updated] (FLINK-32755) Add quick start guide for Flink OLAP

2023-08-04 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangyu feng updated FLINK-32755: - Description: I propose to add a new {{QUICKSTART.md}} guide that provides instructions for

[jira] [Created] (FLINK-32755) Add quick start guide for Flink OLAP

2023-08-04 Thread xiangyu feng (Jira)
xiangyu feng created FLINK-32755: Summary: Add quick start guide for Flink OLAP Key: FLINK-32755 URL: https://issues.apache.org/jira/browse/FLINK-32755 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-32701) Potential Memory Leak in Flink CEP due to Persistent Starting States in NFAState

2023-08-04 Thread Puneet Duggal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751083#comment-17751083 ] Puneet Duggal commented on FLINK-32701: --- [~martijnvisser] [~Juntao Hu] [~nicholasjiang] During the

[jira] [Updated] (FLINK-32754) Using SplitEnumeratorContext.metricGroup() in restoreEnumerator causes NPE

2023-08-04 Thread Yu Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Chen updated FLINK-32754: Description: We registered some metrics in the `enumerator` of the flip-27 source via

[jira] [Updated] (FLINK-32754) Using SplitEnumeratorContext.metricGroup() in restoreEnumerator causes NPE

2023-08-04 Thread Yu Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Chen updated FLINK-32754: Description: We registered some metrics in the `enumerator` of the flip-27 source via

[jira] [Created] (FLINK-32754) Using SplitEnumeratorContext.metricGroup() in restoreEnumerator causes NPE

2023-08-04 Thread Yu Chen (Jira)
Yu Chen created FLINK-32754: --- Summary: Using SplitEnumeratorContext.metricGroup() in restoreEnumerator causes NPE Key: FLINK-32754 URL: https://issues.apache.org/jira/browse/FLINK-32754 Project: Flink

[jira] [Updated] (FLINK-32701) Potential Memory Leak in Flink CEP due to Persistent Starting States in NFAState

2023-08-04 Thread Puneet Duggal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Puneet Duggal updated FLINK-32701: -- Description: Our team has encountered a potential memory leak issue while working with the

[GitHub] [flink] flinkbot commented on pull request #23139: backport FLINK-29913 to release-1.17

2023-08-04 Thread via GitHub
flinkbot commented on PR #23139: URL: https://github.com/apache/flink/pull/23139#issuecomment-1665395206 ## CI report: * 47e7e3e67f61286867a5585ca92b67bc7aba4754 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-32721) agg max/min supports char type

2023-08-04 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751074#comment-17751074 ] dalongliu commented on FLINK-32721: --- [~jackylau] After tracking down and finding the history issue

[GitHub] [flink] WencongLiu closed pull request #23126: Test

2023-08-04 Thread via GitHub
WencongLiu closed pull request #23126: Test URL: https://github.com/apache/flink/pull/23126 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Closed] (FLINK-32557) API deprecations in Flink 1.18

2023-08-04 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-32557. Resolution: Done > API deprecations in Flink 1.18 > -- > >

[jira] [Closed] (FLINK-32558) Properly deprecate DataSet API

2023-08-04 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-32558. Release Note: DataSet API is formally deprecated, and will be removed in the next major release.

[GitHub] [flink] xintongsong closed pull request #23026: [FLINK-32558][flink-java] Deprecate all DataSet API

2023-08-04 Thread via GitHub
xintongsong closed pull request #23026: [FLINK-32558][flink-java] Deprecate all DataSet API URL: https://github.com/apache/flink/pull/23026 -- 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] WencongLiu commented on pull request #23026: [FLINK-32558][flink-java] Deprecate all DataSet API

2023-08-04 Thread via GitHub
WencongLiu commented on PR #23026: URL: https://github.com/apache/flink/pull/23026#issuecomment-1665359267 The CI has passed. Thanks for the careful review. @xintongsong -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] flinkbot commented on pull request #23138: [FLINK-32753] Print JVM flags on AZP

2023-08-04 Thread via GitHub
flinkbot commented on PR #23138: URL: https://github.com/apache/flink/pull/23138#issuecomment-1665316557 ## CI report: * 8b118cc7dfa52c52038f98ea0ca67f3bf9221f34 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32753) Print JVM flags on AZP

2023-08-04 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-32753: Description: I suggest printing JVM flags before the tests run, which could help investigate the

[jira] [Updated] (FLINK-32753) Print JVM flags on AZP

2023-08-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32753: --- Labels: pull-request-available (was: ) > Print JVM flags on AZP > -- >

[GitHub] [flink] Zakelly opened a new pull request, #23138: [FLINK-32753] Print JVM flags on AZP

2023-08-04 Thread via GitHub
Zakelly opened a new pull request, #23138: URL: https://github.com/apache/flink/pull/23138 ## What is the purpose of the change JVM flags could help investigate the test failures (especially memory or GC related issue). This PR prints the JVM flags before tests run. An example of

[jira] [Assigned] (FLINK-32753) Print JVM flags on AZP

2023-08-04 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan reassigned FLINK-32753: --- Assignee: Zakelly Lan > Print JVM flags on AZP > -- > >

[jira] [Updated] (FLINK-32752) Release Testing: Verify FLINK-24909 SQL syntax highlighting in SQL Client

2023-08-04 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-32752: Description: After FLINK-24909 it is possible to specify syntax highlight color schema as

[jira] [Created] (FLINK-32753) Print JVM flags on AZP

2023-08-04 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-32753: --- Summary: Print JVM flags on AZP Key: FLINK-32753 URL: https://issues.apache.org/jira/browse/FLINK-32753 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-32752) Release Testing: Verify FLINK-24909 SQL syntax highlighting in SQL Client

2023-08-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-32752: -- Labels: release-testing (was: ) > Release Testing: Verify FLINK-24909 SQL syntax

[jira] [Created] (FLINK-32752) Release Testing: Verify FLINK-24909 SQL syntax highlighting in SQL Client

2023-08-04 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-32752: --- Summary: Release Testing: Verify FLINK-24909 SQL syntax highlighting in SQL Client Key: FLINK-32752 URL: https://issues.apache.org/jira/browse/FLINK-32752

[jira] [Commented] (FLINK-32667) Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster

2023-08-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751048#comment-17751048 ] Matthias Pohl commented on FLINK-32667: --- It would be great to have these performance tests set up

[jira] [Closed] (FLINK-32656) Deprecate ManagedTable related APIs

2023-08-04 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-32656. Release Note: ManagedTable related APIs are deprecated and will be removed in a future major

[GitHub] [flink] xintongsong commented on pull request #23135: [FLINK-32741]Remove DataSet related descriptions in doc

2023-08-04 Thread via GitHub
xintongsong commented on PR #23135: URL: https://github.com/apache/flink/pull/23135#issuecomment-1665254926 Thanks, @pegasas. I think https://github.com/apache/flink/blob/master/docs/content.zh/docs/dev/dataset/hadoop_compatibility.md should be removed. Actually, this file only

[jira] [Updated] (FLINK-30629) ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable

2023-08-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-30629: -- Fix Version/s: (was: 1.17.2) > ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat

[GitHub] [flink] WencongLiu commented on a diff in pull request #22341: [FLINK-27204][flink-runtime] Refract FileSystemJobResultStore to execute I/O operations on the ioExecutor

2023-08-04 Thread via GitHub
WencongLiu commented on code in PR #22341: URL: https://github.com/apache/flink/pull/22341#discussion_r1284129028 ## flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java: ## @@ -516,7 +517,7 @@ public CompletableFuture submitJob(JobGraph jobGraph,

  1   2   >