[jira] [Updated] (FLINK-33566) HBase sql-connector needs overwrite the rowKey

2023-11-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33566: --- Labels: HBase-2.0 flink-connector-hbase pull-request-available (was: HBase-2.0

Re: [PR] [FLINK-33566] HBase sql-connector needs overwrite the rowKey [flink-connector-hbase]

2023-11-15 Thread via GitHub
boring-cyborg[bot] commented on PR #34: URL: https://github.com/apache/flink-connector-hbase/pull/34#issuecomment-1813952231 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This is

Re: [PR] [FLINK-30064] Move existing Hive connector code from Flink repo to dedicated Hive repo [flink-connector-hive]

2023-11-15 Thread via GitHub
MartijnVisser commented on code in PR #5: URL: https://github.com/apache/flink-connector-hive/pull/5#discussion_r1395286033 ## .github/workflows/push_pr.yml: ## @@ -25,4 +25,4 @@ jobs: compile_and_test: uses:

[jira] [Commented] (FLINK-33532) Move the serialization of ShuffleDescriptorGroup out of the RPC main thread

2023-11-15 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786645#comment-17786645 ] Yangze Guo commented on FLINK-33532: master: 8ef71ba1f190a5cf6093adb6c40c6a6d04944d20

[jira] [Closed] (FLINK-33532) Move the serialization of ShuffleDescriptorGroup out of the RPC main thread

2023-11-15 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-33532. -- Resolution: Fixed > Move the serialization of ShuffleDescriptorGroup out of the RPC main thread >

Re: [PR] [FLINK-33532][rpc] Support configured akka remote dispatcher thread pool size [flink]

2023-11-15 Thread via GitHub
KarmaGYZ merged PR #23707: URL: https://github.com/apache/flink/pull/23707 -- 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-33428) Flink SQL CEP support 'followed','notNext' and 'notFollowedBy' semantics

2023-11-15 Thread xiaoran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786633#comment-17786633 ] xiaoran commented on FLINK-33428: - [~martijnvisser]  Could you please help me look at this problem? I

Re: [PR] Kubernetes Operator 1.7.0 [flink-web]

2023-11-15 Thread via GitHub
1996fanrui commented on code in PR #699: URL: https://github.com/apache/flink-web/pull/699#discussion_r1395221905 ## docs/data/flink_kubernetes_operator.yml: ## @@ -15,16 +15,16 @@ # specific language governing permissions and limitations # under the License +1.7: + name:

Re: [PR] Add release 1.17.2 [flink-web]

2023-11-15 Thread via GitHub
1996fanrui commented on code in PR #696: URL: https://github.com/apache/flink-web/pull/696#discussion_r1395185794 ## docs/content/posts/2023-11-13-release-1.17.2.md: ## @@ -0,0 +1,243 @@ +--- +title: "Apache Flink 1.17.2 Release Announcement" +date: "2023-11-13T00:00:00.000Z"

Re: [PR] [FLINK-32878] [FileSystems] Add entropy in temporary object name in flink gcs filesystem [flink]

2023-11-15 Thread via GitHub
flinkbot commented on PR #23729: URL: https://github.com/apache/flink/pull/23729#issuecomment-1813820618 ## CI report: * 6826b9f244bc90c08a1f677690f9f0e15ae3e073 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-32878] [FileSystems] Add entropy in temporary object name in flink gcs filesystem [flink]

2023-11-15 Thread via GitHub
bcheena opened a new pull request, #23729: URL: https://github.com/apache/flink/pull/23729 ## What is the purpose of the change Currently GCS is used as a backend for file sink. Sometimes hotspotting in GCS results in HTTP 5XX status code. As per [GCS best

[jira] [Commented] (FLINK-31449) Remove DeclarativeSlotManager related logic

2023-11-15 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786619#comment-17786619 ] Weihua Hu commented on FLINK-31449: --- [~lincoln.86xy] Thanks for the reminding.  The remove of

Re: [PR] [FLINK-33564] Implement restore tests for GroupWindowAggregate node [flink]

2023-11-15 Thread via GitHub
flinkbot commented on PR #23728: URL: https://github.com/apache/flink/pull/23728#issuecomment-1813800373 ## CI report: * 256d75bec1d9ca1b12ab799a90ece637a568d556 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-33564) Implement restore tests for GroupWindowAggregate node

2023-11-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33564: --- Labels: pull-request-available (was: ) > Implement restore tests for GroupWindowAggregate

[PR] [FLINK-33564] Implement restore tests for GroupWindowAggregate node [flink]

2023-11-15 Thread via GitHub
bvarghese1 opened a new pull request, #23728: URL: https://github.com/apache/flink/pull/23728 ## What is the purpose of the change Implement restore tests for GroupWindowAggregate node ## Verifying this change This change added tests and can be verified as

[jira] [Commented] (FLINK-18473) Optimize RocksDB disk load balancing strategy

2023-11-15 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786602#comment-17786602 ] Hangxiang Yu commented on FLINK-18473: -- Thanks [~fanrui] for pinging me here. [~yigress] It should

[jira] [Commented] (FLINK-33528) Externalize Python connector code

2023-11-15 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786595#comment-17786595 ] Dian Fu commented on FLINK-33528: - Thanks very much for the efforts (y) > Externalize Python connector

Re: [PR] [FLINK-33551][Connectors/Hive] Fix HiveTemporalJoinITCase.testProcTimeTemporalJoinHiveTable nightly CI fails [flink]

2023-11-15 Thread via GitHub
flinkbot commented on PR #23727: URL: https://github.com/apache/flink/pull/23727#issuecomment-1813729516 ## CI report: * 795fb349b1154a8661a16e27c88bcd42c2891ee6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-33566) HBase sql-connector needs overwrite the rowKey

2023-11-15 Thread JankoWilliam (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JankoWilliam updated FLINK-33566: - Environment: flink: 1.18.0 hbase: 2.2.3 flink-connector-hbase-2.2:3.0.0-1.18 was: flink:

[jira] [Commented] (FLINK-33551) HiveTemporalJoinITCase.testProcTimeTemporalJoinHiveTable failed due to unsupported feature

2023-11-15 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786587#comment-17786587 ] Jiabao Sun commented on FLINK-33551: Some of the remaining codes were not deleted, resulting in the

[jira] [Created] (FLINK-33566) HBase sql-connector needs overwrite the rowKey

2023-11-15 Thread JankoWilliam (Jira)
JankoWilliam created FLINK-33566: Summary: HBase sql-connector needs overwrite the rowKey Key: FLINK-33566 URL: https://issues.apache.org/jira/browse/FLINK-33566 Project: Flink Issue Type:

[jira] [Updated] (FLINK-33551) HiveTemporalJoinITCase.testProcTimeTemporalJoinHiveTable failed due to unsupported feature

2023-11-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33551: --- Labels: pull-request-available test-stability (was: test-stability) >

[PR] [FLINK-33551][Connectors/Hive] Fix HiveTemporalJoinITCase.testProcTimeTemporalJoinHiveTable nightly CI fails [flink]

2023-11-15 Thread via GitHub
Jiabao-Sun opened a new pull request, #23727: URL: https://github.com/apache/flink/pull/23727 ## What is the purpose of the change [FLINK-33551] Fix HiveTemporalJoinITCase.testProcTimeTemporalJoinHiveTable nightly CI fails ## Brief change log During the

Re: [PR] [FLINK-33532][rpc] Support configured akka remote dispatcher thread pool size [flink]

2023-11-15 Thread via GitHub
caodizhou commented on code in PR #23707: URL: https://github.com/apache/flink/pull/23707#discussion_r1395095311 ## flink-core/src/main/java/org/apache/flink/configuration/AkkaOptions.java: ## @@ -237,6 +237,38 @@ public static boolean

Re: [PR] [FLINK-33532][rpc] Support configured akka remote dispatcher thread pool size [flink]

2023-11-15 Thread via GitHub
KarmaGYZ commented on code in PR #23707: URL: https://github.com/apache/flink/pull/23707#discussion_r1395070298 ## flink-core/src/main/java/org/apache/flink/configuration/AkkaOptions.java: ## @@ -237,6 +237,38 @@ public static boolean

Re: [PR] [FLINK-33398][runtime] Support switching from batch to stream mode for one input stream operator [flink]

2023-11-15 Thread via GitHub
Sxnan commented on PR #23521: URL: https://github.com/apache/flink/pull/23521#issuecomment-1813700885 > Hi @Sxnan! Sorry, I understand that I'm not a reviewer, but it happened that I was testing functionality from this MR recently, and I found a bug (in my opinion). It concerns the logic

[jira] [Commented] (FLINK-33551) HiveTemporalJoinITCase.testProcTimeTemporalJoinHiveTable failed due to unsupported feature

2023-11-15 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786576#comment-17786576 ] Jiabao Sun commented on FLINK-33551: Sure >

[jira] [Created] (FLINK-33565) The concurrentExceptions doesn't work

2023-11-15 Thread Rui Fan (Jira)
Rui Fan created FLINK-33565: --- Summary: The concurrentExceptions doesn't work Key: FLINK-33565 URL: https://issues.apache.org/jira/browse/FLINK-33565 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-33472) Solve the problem that the temporary file of flink-conf.yaml in S3AFileSystem cannot be uploaded

2023-11-15 Thread zhengzhili (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786565#comment-17786565 ] zhengzhili edited comment on FLINK-33472 at 11/16/23 2:23 AM: -- [~mapohl]

Re: [PR] [FLINK-33563] Implement type inference for Agg functions [flink]

2023-11-15 Thread via GitHub
liuyongvs commented on code in PR #23724: URL: https://github.com/apache/flink/pull/23724#discussion_r1395071815 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/CollectTypeStrategy.java: ## @@ -0,0 +1,46 @@ +/* + * Licensed to

[jira] [Updated] (FLINK-33472) Solve the problem that the temporary file of flink-conf.yaml in S3AFileSystem cannot be uploaded

2023-11-15 Thread zhengzhili (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhengzhili updated FLINK-33472: --- Attachment: (was: sunlogin_20231116094752-1.bmp) > Solve the problem that the temporary file of

[jira] [Comment Edited] (FLINK-33472) Solve the problem that the temporary file of flink-conf.yaml in S3AFileSystem cannot be uploaded

2023-11-15 Thread zhengzhili (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786565#comment-17786565 ] zhengzhili edited comment on FLINK-33472 at 11/16/23 1:57 AM: -- After

[jira] [Comment Edited] (FLINK-33472) Solve the problem that the temporary file of flink-conf.yaml in S3AFileSystem cannot be uploaded

2023-11-15 Thread zhengzhili (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786565#comment-17786565 ] zhengzhili edited comment on FLINK-33472 at 11/16/23 1:56 AM: -- After

[jira] [Updated] (FLINK-33472) Solve the problem that the temporary file of flink-conf.yaml in S3AFileSystem cannot be uploaded

2023-11-15 Thread zhengzhili (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhengzhili updated FLINK-33472: --- Attachment: (was: image-2023-11-16-09-55-00-586.png) > Solve the problem that the temporary

[jira] [Updated] (FLINK-33472) Solve the problem that the temporary file of flink-conf.yaml in S3AFileSystem cannot be uploaded

2023-11-15 Thread zhengzhili (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhengzhili updated FLINK-33472: --- Attachment: (was: image-2023-11-16-09-54-08-027.png) > Solve the problem that the temporary

[jira] [Updated] (FLINK-33472) Solve the problem that the temporary file of flink-conf.yaml in S3AFileSystem cannot be uploaded

2023-11-15 Thread zhengzhili (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhengzhili updated FLINK-33472: --- Attachment: (was: sunlogin_20231116094752.bmp) > Solve the problem that the temporary file of

[jira] [Updated] (FLINK-33472) Solve the problem that the temporary file of flink-conf.yaml in S3AFileSystem cannot be uploaded

2023-11-15 Thread zhengzhili (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhengzhili updated FLINK-33472: --- Attachment: (was: image-2023-11-16-09-50-47-845.png) > Solve the problem that the temporary

[jira] [Comment Edited] (FLINK-33472) Solve the problem that the temporary file of flink-conf.yaml in S3AFileSystem cannot be uploaded

2023-11-15 Thread zhengzhili (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786565#comment-17786565 ] zhengzhili edited comment on FLINK-33472 at 11/16/23 1:55 AM: -- After

[jira] [Updated] (FLINK-33472) Solve the problem that the temporary file of flink-conf.yaml in S3AFileSystem cannot be uploaded

2023-11-15 Thread zhengzhili (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhengzhili updated FLINK-33472: --- Description: Solve the problem that the temporary file of flink-conf.yaml in S3AFileSystem cannot

[jira] [Updated] (FLINK-33472) Solve the problem that the temporary file of flink-conf.yaml in S3AFileSystem cannot be uploaded

2023-11-15 Thread zhengzhili (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhengzhili updated FLINK-33472: --- Attachment: (was: image-2023-11-07-13-46-58-907.png) > Solve the problem that the temporary

[jira] [Updated] (FLINK-33472) Solve the problem that the temporary file of flink-conf.yaml in S3AFileSystem cannot be uploaded

2023-11-15 Thread zhengzhili (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhengzhili updated FLINK-33472: --- Attachment: (was: image-2023-11-07-11-34-01-823.png) > Solve the problem that the temporary

[jira] [Updated] (FLINK-33472) Solve the problem that the temporary file of flink-conf.yaml in S3AFileSystem cannot be uploaded

2023-11-15 Thread zhengzhili (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhengzhili updated FLINK-33472: --- Attachment: (was: image-2023-11-07-11-34-29-548.png) > Solve the problem that the temporary

[jira] [Updated] (FLINK-33472) Solve the problem that the temporary file of flink-conf.yaml in S3AFileSystem cannot be uploaded

2023-11-15 Thread zhengzhili (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhengzhili updated FLINK-33472: --- Description: Solve the problem that the temporary file of flink-conf.yaml in S3AFileSystem cannot

[jira] [Updated] (FLINK-33423) Resolve the problem that YarnClusterClientFactory cannot load yarn configurations

2023-11-15 Thread zhengzhili (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhengzhili updated FLINK-33423: --- Attachment: (was: image-2023-11-03-11-05-01-182.png) > Resolve the problem that

[jira] [Updated] (FLINK-33423) Resolve the problem that YarnClusterClientFactory cannot load yarn configurations

2023-11-15 Thread zhengzhili (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhengzhili updated FLINK-33423: --- Attachment: (was: 微信截图_20231101152725.png) > Resolve the problem that YarnClusterClientFactory

[jira] [Updated] (FLINK-33423) Resolve the problem that YarnClusterClientFactory cannot load yarn configurations

2023-11-15 Thread zhengzhili (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhengzhili updated FLINK-33423: --- Attachment: (was: 微信图片_20231101151644.png) > Resolve the problem that YarnClusterClientFactory

[jira] [Updated] (FLINK-33423) Resolve the problem that YarnClusterClientFactory cannot load yarn configurations

2023-11-15 Thread zhengzhili (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhengzhili updated FLINK-33423: --- Attachment: (was: image-2023-11-03-10-35-07-868.png) > Resolve the problem that

[jira] [Updated] (FLINK-33423) Resolve the problem that YarnClusterClientFactory cannot load yarn configurations

2023-11-15 Thread zhengzhili (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhengzhili updated FLINK-33423: --- Attachment: (was: 微信图片_20231101152404.png) > Resolve the problem that YarnClusterClientFactory

[jira] [Updated] (FLINK-33423) Resolve the problem that YarnClusterClientFactory cannot load yarn configurations

2023-11-15 Thread zhengzhili (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhengzhili updated FLINK-33423: --- Attachment: (was: 微信图片_20231101152359.png) > Resolve the problem that YarnClusterClientFactory

[jira] [Updated] (FLINK-33423) Resolve the problem that YarnClusterClientFactory cannot load yarn configurations

2023-11-15 Thread zhengzhili (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhengzhili updated FLINK-33423: --- Attachment: (was: flinktest.png) > Resolve the problem that YarnClusterClientFactory cannot

[jira] [Updated] (FLINK-33423) Resolve the problem that YarnClusterClientFactory cannot load yarn configurations

2023-11-15 Thread zhengzhili (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhengzhili updated FLINK-33423: --- Attachment: (was: image-2023-11-03-09-27-59-792.png) > Resolve the problem that

[jira] [Updated] (FLINK-33423) Resolve the problem that YarnClusterClientFactory cannot load yarn configurations

2023-11-15 Thread zhengzhili (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhengzhili updated FLINK-33423: --- Attachment: (was: image-2023-11-03-03-45-05-640.png) > Resolve the problem that

[jira] [Commented] (FLINK-33472) Solve the problem that the temporary file of flink-conf.yaml in S3AFileSystem cannot be uploaded

2023-11-15 Thread zhengzhili (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786565#comment-17786565 ] zhengzhili commented on FLINK-33472: After creating the flink-conf.yaml temporary file in

[jira] [Commented] (FLINK-30064) Move existing Hive connector code from Flink repo to dedicated Hive repo

2023-11-15 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786562#comment-17786562 ] Sergey Nuyanzin commented on FLINK-30064: - [~martijnvisser] I submitted a PR after decoupling of

Re: [PR] [FLINK-30064] Move existing Hive connector code from Flink repo to dedicated Hive repo [flink-connector-hive]

2023-11-15 Thread via GitHub
boring-cyborg[bot] commented on PR #5: URL: https://github.com/apache/flink-connector-hive/pull/5#issuecomment-1813564070 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This is an

Re: [PR] [hotfix] Remove Calcite classes from Hive connector [flink]

2023-11-15 Thread via GitHub
flinkbot commented on PR #23726: URL: https://github.com/apache/flink/pull/23726#issuecomment-1813549379 ## CI report: * 053482ec16cc26bb17b1deb35fa0dd7e897ac280 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [hotfix] Remove Calcite classes from Hive connector [flink]

2023-11-15 Thread via GitHub
snuyanzin opened a new pull request, #23726: URL: https://github.com/apache/flink/pull/23726 ## What is the purpose of the change After Calcite upgrade to 1.31.0 Hive connector's version of `HintPredicates` [1] and `NodeTypeHintPredicate` became same as in Calcite [1]

[jira] [Created] (FLINK-33564) Implement restore tests for GroupWindowAggregate node

2023-11-15 Thread Bonnie Varghese (Jira)
Bonnie Varghese created FLINK-33564: --- Summary: Implement restore tests for GroupWindowAggregate node Key: FLINK-33564 URL: https://issues.apache.org/jira/browse/FLINK-33564 Project: Flink

[jira] [Resolved] (FLINK-32927) Verify that no exclusions were erroneously added to the japicmp plugin

2023-11-15 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-32927. - Resolution: Done > Verify that no exclusions were erroneously added to the japicmp

[jira] [Resolved] (FLINK-32922) Review and update documentation

2023-11-15 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-32922. - Fix Version/s: 1.19.0 1.18.1 Resolution: Fixed > Review and

[jira] [Commented] (FLINK-32922) Review and update documentation

2023-11-15 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786549#comment-17786549 ] Sergey Nuyanzin commented on FLINK-32922: - Merged as master:

Re: [PR] [BP-1.18][FLINK-32922][docs] Update compatibility matrix for release 1.18 [flink]

2023-11-15 Thread via GitHub
snuyanzin merged PR #23702: URL: https://github.com/apache/flink/pull/23702 -- 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:

Re: [PR] [FLINK-32922][docs] Update compatibility matrix for release 1.18 [flink]

2023-11-15 Thread via GitHub
snuyanzin merged PR #23701: URL: https://github.com/apache/flink/pull/23701 -- 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] [Updated] (FLINK-31371) Support subscribing non-existed topics in Pulsar source

2023-11-15 Thread Enzo Dechaene (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Enzo Dechaene updated FLINK-31371: -- Priority: Not a Priority (was: Major) > Support subscribing non-existed topics in Pulsar

[jira] [Updated] (FLINK-31371) Support subscribing non-existed topics in Pulsar source

2023-11-15 Thread Enzo Dechaene (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Enzo Dechaene updated FLINK-31371: -- Issue Type: New Feature (was: Bug) > Support subscribing non-existed topics in Pulsar source

[jira] [Comment Edited] (FLINK-32913) Update japicmp configuration

2023-11-15 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786509#comment-17786509 ] Sergey Nuyanzin edited comment on FLINK-32913 at 11/15/23 10:00 PM:

[jira] [Assigned] (FLINK-32918) Update reference data for Migration Tests

2023-11-15 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-32918: --- Assignee: Sergey Nuyanzin > Update reference data for Migration Tests >

[jira] [Updated] (FLINK-32913) Update japicmp configuration

2023-11-15 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-32913: Fix Version/s: 1.18.1 > Update japicmp configuration > > >

[jira] [Comment Edited] (FLINK-32913) Update japicmp configuration

2023-11-15 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786509#comment-17786509 ] Sergey Nuyanzin edited comment on FLINK-32913 at 11/15/23 9:59 PM: ---

Re: [PR] [BP-1.18][FLINK-32913][tests] Updates base version for japicmp check [flink]

2023-11-15 Thread via GitHub
snuyanzin merged PR #23705: URL: https://github.com/apache/flink/pull/23705 -- 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:

Re: [PR] [BP-1.18][FLINK-32913][tests] Updates base version for japicmp check [flink]

2023-11-15 Thread via GitHub
snuyanzin commented on PR #23705: URL: https://github.com/apache/flink/pull/23705#issuecomment-1813321927 Just since it is mentioned a bit different for release branch in compare with master at

[jira] [Resolved] (FLINK-32913) Update japicmp configuration

2023-11-15 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-32913. - Fix Version/s: 1.19.0 Resolution: Fixed > Update japicmp configuration >

[jira] [Commented] (FLINK-32913) Update japicmp configuration

2023-11-15 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786509#comment-17786509 ] Sergey Nuyanzin commented on FLINK-32913: - Merged to master as

Re: [PR] [FLINK-32913][tests] Updates base version for japicmp check [flink]

2023-11-15 Thread via GitHub
snuyanzin merged PR #23704: URL: https://github.com/apache/flink/pull/23704 -- 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:

Re: [PR] [FLINK-32913][tests] Updates base version for japicmp check [flink]

2023-11-15 Thread via GitHub
snuyanzin commented on PR #23704: URL: https://github.com/apache/flink/pull/23704#issuecomment-1813313335 thanks for taking a look -- 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] [Updated] (FLINK-33365) Missing filter condition in execution plan containing lookup join with mysql jdbc connector

2023-11-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33365: --- Labels: pull-request-available (was: ) > Missing filter condition in execution plan

Re: [PR] [FLINK-33365] include filters with Lookup joins [flink-connector-jdbc]

2023-11-15 Thread via GitHub
qingwei91 commented on code in PR #79: URL: https://github.com/apache/flink-connector-jdbc/pull/79#discussion_r1394734975 ## flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSource.java: ## @@ -96,21 +96,35 @@ public

Re: [PR] [FLINK-33536] Fix Flink Table API CSV streaming sink fails with IOException: Stream closed [flink]

2023-11-15 Thread via GitHub
Samrat002 commented on PR #23725: URL: https://github.com/apache/flink/pull/23725#issuecomment-1813154439 @PrabhuJoseph @MartijnVisser 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

[jira] [Commented] (FLINK-18473) Optimize RocksDB disk load balancing strategy

2023-11-15 Thread Yi Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786462#comment-17786462 ] Yi Zhang commented on FLINK-18473: -- [~masteryhx] what do you think of random initial pick and

[jira] [Assigned] (FLINK-32913) Update japicmp configuration

2023-11-15 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge reassigned FLINK-32913: --- Assignee: Sergey Nuyanzin > Update japicmp configuration > > >

[jira] [Comment Edited] (FLINK-33276) Reorganize CI stages

2023-11-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786326#comment-17786326 ] Matthias Pohl edited comment on FLINK-33276 at 11/15/23 5:35 PM: -

[jira] [Resolved] (FLINK-33276) Reorganize CI stages

2023-11-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-33276. --- Fix Version/s: 1.19.0 1.18.1 Resolution: Fixed > Reorganize CI

Re: [PR] [BP-1.18][FLINK-33276][ci] Merges connect_1 and connect_2 stages into a single one [flink]

2023-11-15 Thread via GitHub
XComp merged PR #23719: URL: https://github.com/apache/flink/pull/23719 -- 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] [Assigned] (FLINK-32927) Verify that no exclusions were erroneously added to the japicmp plugin

2023-11-15 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge reassigned FLINK-32927: --- Assignee: Sergey Nuyanzin > Verify that no exclusions were erroneously added to the japicmp plugin

[jira] [Comment Edited] (FLINK-33551) HiveTemporalJoinITCase.testProcTimeTemporalJoinHiveTable failed due to unsupported feature

2023-11-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786437#comment-17786437 ] Matthias Pohl edited comment on FLINK-33551 at 11/15/23 5:06 PM: - The

[jira] [Commented] (FLINK-33551) HiveTemporalJoinITCase.testProcTimeTemporalJoinHiveTable failed due to unsupported feature

2023-11-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786437#comment-17786437 ] Matthias Pohl commented on FLINK-33551: --- The issue started appearing in

Re: [PR] [FLINK-32563] Allow to execute archunit tests only with Flink version that connectors were built against [flink-connector-shared-utils]

2023-11-15 Thread via GitHub
echauchot commented on code in PR #23: URL: https://github.com/apache/flink-connector-shared-utils/pull/23#discussion_r1394495515 ## module-with-no-tests/src/main/java/org/apache/flink/connector/testing/SomeClass2.java: ## @@ -19,4 +19,7 @@ package

[jira] [Commented] (FLINK-33551) HiveTemporalJoinITCase.testProcTimeTemporalJoinHiveTable failed due to unsupported feature

2023-11-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786431#comment-17786431 ] Matthias Pohl commented on FLINK-33551: --- The issue is not related to the GHA work (FLINK-27075).

[jira] [Updated] (FLINK-33551) HiveTemporalJoinITCase.testProcTimeTemporalJoinHiveTable failed due to unsupported feature

2023-11-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33551: -- Summary: HiveTemporalJoinITCase.testProcTimeTemporalJoinHiveTable failed due to unsupported

[jira] [Updated] (FLINK-33551) HiveTemporalJoinITCase.testProcTimeTemporalJoinHiveTable failed due to

2023-11-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33551: -- Labels: test-stability (was: github-actions test-stability) >

Re: [PR] [FLINK-32563] Allow to execute archunit tests only with Flink version that connectors were built against [flink-connector-shared-utils]

2023-11-15 Thread via GitHub
echauchot commented on code in PR #23: URL: https://github.com/apache/flink-connector-shared-utils/pull/23#discussion_r1394491058 ## pom.xml: ## @@ -48,7 +52,41 @@ under the License. flink-test-utils-junit ${flink.version}

[jira] [Updated] (FLINK-33551) HiveTemporalJoinITCase.testProcTimeTemporalJoinHiveTable failed due to

2023-11-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33551: -- Component/s: Connectors / Hive > HiveTemporalJoinITCase.testProcTimeTemporalJoinHiveTable

[jira] [Updated] (FLINK-33551) HiveTemporalJoinITCase.testProcTimeTemporalJoinHiveTable failed due to

2023-11-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33551: -- Affects Version/s: 1.19.0 > HiveTemporalJoinITCase.testProcTimeTemporalJoinHiveTable failed

[jira] [Updated] (FLINK-33551) HiveTemporalJoinITCase.testProcTimeTemporalJoinHiveTable failed due to

2023-11-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33551: -- Parent: (was: FLINK-27075) Issue Type: Bug (was: Sub-task) >

[jira] [Commented] (FLINK-33550) "DataSet allround end-to-end test" failed due to certificate error

2023-11-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786429#comment-17786429 ] Matthias Pohl commented on FLINK-33550: --- The GHA workflow uses {{ubuntu-latest}}, i.e. 22.04,

Re: [PR] [FLINK-32563] Allow to execute archunit tests only with Flink version that connectors were built against [flink-connector-shared-utils]

2023-11-15 Thread via GitHub
echauchot commented on code in PR #23: URL: https://github.com/apache/flink-connector-shared-utils/pull/23#discussion_r1394471682 ## module-with-no-tests/.gitignore: ## @@ -0,0 +1,38 @@ +target/ +!.mvn/wrapper/maven-wrapper.jar +!**/src/main/**/target/ +!**/src/test/**/target/

[jira] [Comment Edited] (FLINK-33365) Missing filter condition in execution plan containing lookup join with mysql jdbc connector

2023-11-15 Thread david radley (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786427#comment-17786427 ] david radley edited comment on FLINK-33365 at 11/15/23 4:34 PM:

[jira] [Commented] (FLINK-33365) Missing filter condition in execution plan containing lookup join with mysql jdbc connector

2023-11-15 Thread david radley (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786427#comment-17786427 ] david radley commented on FLINK-33365: -- [~libenchao]  I have moved the code from the

Re: [PR] [FLINK-33536] Fix Flink Table API CSV streaming sink fails with IOException: Stream closed [flink]

2023-11-15 Thread via GitHub
flinkbot commented on PR #23725: URL: https://github.com/apache/flink/pull/23725#issuecomment-1812777658 ## CI report: * 063da076d0654075f0943cc5ff183495645612c1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-33536] Fix Flink Table API CSV streaming sink fails with IOException: Stream closed [flink]

2023-11-15 Thread via GitHub
Samrat002 commented on PR #23718: URL: https://github.com/apache/flink/pull/23718#issuecomment-1812776418 @ligadeprojects Please use the pr : https://github.com/apache/flink/pull/23725 Extremely sorry i messed up with the commit and git commands -- This is an automated message from

  1   2   3   >