Re: [PR] [FLINK-33236][config] Remove the unused high-availability.zookeeper.pth.running-registry option [flink]

2023-10-10 Thread via GitHub
flinkbot commented on PR #23506: URL: https://github.com/apache/flink/pull/23506#issuecomment-1756844304 ## CI report: * 72b6b3a52f9efd6980941259a12281bb40a78976 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-33236) Remove the unused high-availability.zookeeper.path.running-registry option

2023-10-10 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773900#comment-17773900 ] Zhanghao Chen commented on FLINK-33236: --- Hi [~mapohl], I've prepared a quick cleanup PR for it.

[jira] [Updated] (FLINK-33236) Remove the unused high-availability.zookeeper.path.running-registry option

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

[PR] [FLINK-33236][config] Remove the unused high-availability.zookeeper.pth.running-registry option [flink]

2023-10-10 Thread via GitHub
X-czh opened a new pull request, #23506: URL: https://github.com/apache/flink/pull/23506 ## What is the purpose of the change The running registry subcomponent of Flink HA has been removed in [FLINK-25430](https://issues.apache.org/jira/browse/FLINK-25430) and the

[jira] [Created] (FLINK-33236) Remove the unused high-availability.zookeeper.path.running-registry option

2023-10-10 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-33236: - Summary: Remove the unused high-availability.zookeeper.path.running-registry option Key: FLINK-33236 URL: https://issues.apache.org/jira/browse/FLINK-33236

[jira] [Assigned] (FLINK-33209) Translate Flink OLAP quick start guide to Chinese

2023-10-10 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-33209: -- Assignee: xiangyu feng > Translate Flink OLAP quick start guide to Chinese >

[jira] [Assigned] (FLINK-33235) Quickstart guide for Flink OLAP should support building from master branch

2023-10-10 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-33235: -- Assignee: xiangyu feng > Quickstart guide for Flink OLAP should support building from master

[jira] [Created] (FLINK-33235) Quickstart guide for Flink OLAP should support building from master branch

2023-10-10 Thread xiangyu feng (Jira)
xiangyu feng created FLINK-33235: Summary: Quickstart guide for Flink OLAP should support building from master branch Key: FLINK-33235 URL: https://issues.apache.org/jira/browse/FLINK-33235 Project:

[jira] [Commented] (FLINK-33168) An error occurred when executing sql, java.lang.NoSuchFieldError: operands

2023-10-10 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773896#comment-17773896 ] luoyuxia commented on FLINK-33168: -- I believe the doc has been updated in FLINK-32982. And the release

Re: [PR] [FLINK-33171][table planner] Table SQL support Not Equal for TimePoint type and TimeString [flink]

2023-10-10 Thread via GitHub
lincoln-lil commented on code in PR #23478: URL: https://github.com/apache/flink/pull/23478#discussion_r1353989534 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala: ## @@ -488,6 +488,18 @@ object

[jira] [Closed] (FLINK-33168) An error occurred when executing sql, java.lang.NoSuchFieldError: operands

2023-10-10 Thread macdoor615 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] macdoor615 closed FLINK-33168. -- > An error occurred when executing sql, java.lang.NoSuchFieldError: operands >

[jira] [Commented] (FLINK-33168) An error occurred when executing sql, java.lang.NoSuchFieldError: operands

2023-10-10 Thread macdoor615 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773893#comment-17773893 ] macdoor615 commented on FLINK-33168: [~luoyuxia]  table-planner-loader.jar works. Docs should be

[jira] [Comment Edited] (FLINK-33168) An error occurred when executing sql, java.lang.NoSuchFieldError: operands

2023-10-10 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773891#comment-17773891 ] luoyuxia edited comment on FLINK-33168 at 10/11/23 4:16 AM: I tried with

[jira] [Resolved] (FLINK-33168) An error occurred when executing sql, java.lang.NoSuchFieldError: operands

2023-10-10 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-33168. -- Resolution: Invalid I tried with puting table-planner-loader.jar in /lib and it works. Since it's

Re: [PR] [FLINK-24024][table-planner] support session window tvf in plan [flink]

2023-10-10 Thread via GitHub
flinkbot commented on PR #23505: URL: https://github.com/apache/flink/pull/23505#issuecomment-1756729241 ## CI report: * 8302b0995123b2a536ae434f8e958dfa3d8c2302 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-24024][table-planner] support session window tvf in plan [flink]

2023-10-10 Thread via GitHub
xuyangzhong opened a new pull request, #23505: URL: https://github.com/apache/flink/pull/23505 ## What is the purpose of the change This pull request aims to introduce the support of the session window tvf in the plan. After this pr, users can use the syntax with session window tvf

[jira] [Closed] (FLINK-32072) Create and wire FileMergingSnapshotManager with TaskManagerServices

2023-10-10 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei closed FLINK-32072. -- > Create and wire FileMergingSnapshotManager with TaskManagerServices >

[jira] [Resolved] (FLINK-32072) Create and wire FileMergingSnapshotManager with TaskManagerServices

2023-10-10 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-32072. Fix Version/s: 1.19.0 (was: 1.18.0) Resolution: Fixed > Create and

[jira] [Commented] (FLINK-32072) Create and wire FileMergingSnapshotManager with TaskManagerServices

2023-10-10 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773884#comment-17773884 ] Yanfei Lei commented on FLINK-32072: Merged into master via 1112582fd136df47c6d356d6f6ad3946ad1e56d5

Re: [PR] [FLINK-32443][docs-zh] Translate "State Processor API" page into Chinese [flink]

2023-10-10 Thread via GitHub
fredia commented on PR #23496: URL: https://github.com/apache/flink/pull/23496#issuecomment-1756665330 @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 comment.

Re: [PR] [FLINK-32512] Don't register resource to user resource manager when creating temporary function [flink]

2023-10-10 Thread via GitHub
FangYongs commented on code in PR #22938: URL: https://github.com/apache/flink/pull/22938#discussion_r1353844833 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/resource/ResourceManager.java: ## @@ -65,9 +69,14 @@ public class ResourceManager implements

[jira] [Closed] (FLINK-33228) Fix the total current resource calculation when fulfilling requirements

2023-10-10 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-33228. -- Resolution: Fixed > Fix the total current resource calculation when fulfilling requirements >

Re: [PR] [FLINK-32512] Don't register resource to user resource manager when creating temporary function [flink]

2023-10-10 Thread via GitHub
FangYongs commented on code in PR #22938: URL: https://github.com/apache/flink/pull/22938#discussion_r1353833344 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/resource/ResourceManager.java: ## @@ -124,15 +136,79 @@ public String

[jira] [Commented] (FLINK-33228) Fix the total current resource calculation when fulfilling requirements

2023-10-10 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773872#comment-17773872 ] Yangze Guo commented on FLINK-33228: master: 5269631af525a01d944cfa9994a116fb27b80b1b > Fix the

Re: [PR] [FLINK-32512] Don't register resource to user resource manager when creating temporary function [flink]

2023-10-10 Thread via GitHub
FangYongs commented on code in PR #22938: URL: https://github.com/apache/flink/pull/22938#discussion_r1353833112 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/FunctionCatalog.java: ## @@ -131,10 +132,17 @@ public boolean

Re: [PR] [FLINK-33228][flink-runtime] Fix the total current resource calculation when fulfilling requirement [flink]

2023-10-10 Thread via GitHub
KarmaGYZ merged PR #23502: URL: https://github.com/apache/flink/pull/23502 -- 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-33168) An error occurred when executing sql, java.lang.NoSuchFieldError: operands

2023-10-10 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773871#comment-17773871 ] luoyuxia commented on FLINK-33168: -- [~macdoor615] Hi, could you please try using

[jira] [Assigned] (FLINK-33168) An error occurred when executing sql, java.lang.NoSuchFieldError: operands

2023-10-10 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia reassigned FLINK-33168: Assignee: Zheng yunhong > An error occurred when executing sql, java.lang.NoSuchFieldError:

[jira] [Resolved] (FLINK-25593) A redundant scan could be skipped if it is an input of join and the other input is empty after partition prune

2023-10-10 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-25593. -- Resolution: Fixed master: 1b70d25b81daa7bd4a23c048cb3a79bc43a21d5f > A redundant scan could be

Re: [PR] [FLINK-25593][table-planner] Skip redundant scan while partition table push down contains none-existent partition [flink]

2023-10-10 Thread via GitHub
luoyuxia merged PR #23423: URL: https://github.com/apache/flink/pull/23423 -- 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-33231) Memory leak in KafkaSourceReader if no data in consumed topic

2023-10-10 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-33231: --- Assignee: Tzu-Li (Gordon) Tai > Memory leak in KafkaSourceReader if no

Re: [PR] [FLINK-33191][Connector/Kafka] Remove dependency on Flink Shaded [flink-connector-kafka]

2023-10-10 Thread via GitHub
tzulitai commented on code in PR #57: URL: https://github.com/apache/flink-connector-kafka/pull/57#discussion_r1353655402 ## flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaRecordDeserializationSchemaTest.java: ## @@ -82,16

[jira] [Updated] (FLINK-33191) Kafka Connector should directly depend on 3rd-party libs instead of flink-shaded repo

2023-10-10 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-33191: Affects Version/s: kafka-3.0.0 (was: 1.18.0) > Kafka

[jira] [Updated] (FLINK-33191) Kafka Connector should directly depend on 3rd-party libs instead of flink-shaded repo

2023-10-10 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-33191: Fix Version/s: kafka-3.0.1 kafka-3.1.0 > Kafka Connector

[jira] [Resolved] (FLINK-33020) OpensearchSinkTest.testAtLeastOnceSink timed out

2023-10-10 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-33020. - Fix Version/s: opensearch-1.1.0 Resolution: Fixed >

[jira] [Commented] (FLINK-33020) OpensearchSinkTest.testAtLeastOnceSink timed out

2023-10-10 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773823#comment-17773823 ] Sergey Nuyanzin commented on FLINK-33020: - Time out was increased at

[PR] [hotfix] Bump flink version to 1.17.1 [flink-connector-opensearch]

2023-10-10 Thread via GitHub
snuyanzin opened a new pull request, #33: URL: https://github.com/apache/flink-connector-opensearch/pull/33 (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] [Assigned] (FLINK-33020) OpensearchSinkTest.testAtLeastOnceSink timed out

2023-10-10 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-33020: --- Assignee: Andriy Redko > OpensearchSinkTest.testAtLeastOnceSink timed out >

Re: [PR] [FLINK-33020] OpensearchSinkTest.testAtLeastOnceSink timed out [flink-connector-opensearch]

2023-10-10 Thread via GitHub
snuyanzin merged PR #32: URL: https://github.com/apache/flink-connector-opensearch/pull/32 -- 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-33200) ItemAt Expression validation fail in Table API due to type mismatch

2023-10-10 Thread Andriy Onyshchuk (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773794#comment-17773794 ] Andriy Onyshchuk commented on FLINK-33200: -- Seems like I have caught several more issues

[jira] [Updated] (FLINK-33200) ItemAt Expression validation fail in Table API due to type mismatch

2023-10-10 Thread Andriy Onyshchuk (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andriy Onyshchuk updated FLINK-33200: - Attachment: IssueDemo.java > ItemAt Expression validation fail in Table API due to type

[jira] [Updated] (FLINK-33231) Memory leak in KafkaSourceReader if no data in consumed topic

2023-10-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33231: --- Labels: pull-request-available (was: ) > Memory leak in KafkaSourceReader if no data in

[PR] [FLINK-33231] [source] Properly evict offsetsToCommit cache on checkpoint complete if no offsets exist [flink-connector-kafka]

2023-10-10 Thread via GitHub
tzulitai opened a new pull request, #58: URL: https://github.com/apache/flink-connector-kafka/pull/58 Prior to this fix, if the offsets to commit for a given checkpoint is empty, which can be the case if no starting offsets were retrieved from Kafka yet, then on checkpoint completion the

[jira] [Commented] (FLINK-33231) Memory leak in KafkaSourceReader if no data in consumed topic

2023-10-10 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773790#comment-17773790 ] Tzu-Li (Gordon) Tai commented on FLINK-33231: - [~lauri.suurvali] I think that would work,

[jira] [Commented] (FLINK-33231) Memory leak in KafkaSourceReader if no data in consumed topic

2023-10-10 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773784#comment-17773784 ] Lauri Suurväli commented on FLINK-33231: [~tzulitai] thank you for the comment! Would removing

Re: [PR] [FLINK-28303] Support LatestOffsetsInitializer to avoid latest-offset strategy lose data [flink-connector-kafka]

2023-10-10 Thread via GitHub
tzulitai commented on PR #52: URL: https://github.com/apache/flink-connector-kafka/pull/52#issuecomment-1755995458 @Tan-JiaLiang ok - lets try to reach consensus here. It does seem like that my approach can lead to other problems, e.g. bombarding Kafka brokers from multiple

Re: [PR] [FLINK-28303] Support LatestOffsetsInitializer to avoid latest-offset strategy lose data [flink-connector-kafka]

2023-10-10 Thread via GitHub
tzulitai commented on PR #52: URL: https://github.com/apache/flink-connector-kafka/pull/52#issuecomment-1755980007 @Tan-JiaLiang you are right, that's why it's taking me a while to open the new PR. The problem with my approach is that it can potentially read more records when restoring.

Re: [PR] [FLINK-33033][olap][haservice] Add haservice micro benchmark for olap [flink-benchmarks]

2023-10-10 Thread via GitHub
XComp commented on code in PR #78: URL: https://github.com/apache/flink-benchmarks/pull/78#discussion_r1353047609 ## src/main/java/org/apache/flink/olap/benchmark/HighAvailabilityServiceBenchmark.java: ## @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache Software Foundation

[jira] [Commented] (FLINK-32806) EmbeddedJobResultStore keeps the non-dirty job entries forever

2023-10-10 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773758#comment-17773758 ] Samrat Deb commented on FLINK-32806: [~hk__lrzy] are you working on the patch ?  >

Re: [PR] [hotfix] Backport Jetty's fix for java version parsing [flink-connector-hbase]

2023-10-10 Thread via GitHub
snuyanzin commented on PR #25: URL: https://github.com/apache/flink-connector-hbase/pull/25#issuecomment-1755768586 @MartijnVisser this should fix failing builds could you please have a look? -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-33231) Memory leak in KafkaSourceReader if no data in consumed topic

2023-10-10 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773739#comment-17773739 ] Tzu-Li (Gordon) Tai commented on FLINK-33231: - Making this a blocker for the upcoming Kafka

[jira] [Updated] (FLINK-33231) Memory leak in KafkaSourceReader if no data in consumed topic

2023-10-10 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-33231: Fix Version/s: kafka-3.0.1 kafka-3.1.0 > Memory leak in

[jira] [Updated] (FLINK-33231) Memory leak in KafkaSourceReader if no data in consumed topic

2023-10-10 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-33231: Priority: Blocker (was: Major) > Memory leak in KafkaSourceReader if no data in

[jira] [Commented] (FLINK-33231) Memory leak in KafkaSourceReader if no data in consumed topic

2023-10-10 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773738#comment-17773738 ] Tzu-Li (Gordon) Tai commented on FLINK-33231: - [~lauri.suurvali] great debugging! I think

[PR] Backport Jetty's fix for java version parsing [flink-connector-hbase]

2023-10-10 Thread via GitHub
snuyanzin opened a new pull request, #25: URL: https://github.com/apache/flink-connector-hbase/pull/25 Merge fix for jetty https://github.com/eclipse/jetty.project/pull/2331 Since it is in Jetty 9.6 and hbase depends on 9.3 and lower -- This is an automated message from the Apache Git

[jira] [Commented] (FLINK-33052) codespeed and benchmark server is down

2023-10-10 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773726#comment-17773726 ] Martijn Visser commented on FLINK-33052: [~Zakelly] Is there any update on this ticket? >

[jira] [Commented] (FLINK-32038) OffsetCommitMode.Kafka_periodic with checkpointing enabled

2023-10-10 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773719#comment-17773719 ] Martijn Visser commented on FLINK-32038: [~pritam.agarwala] [~tzulitai] What is the conclusion

[jira] [Commented] (FLINK-30400) Stop bundling connector-base in externalized connectors

2023-10-10 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773708#comment-17773708 ] Martijn Visser commented on FLINK-30400: [~chesnay] How would this work for SQL FAT jars? IIUC

[jira] [Created] (FLINK-33234) Bump used Guava version in Kafka E2E tests

2023-10-10 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-33234: -- Summary: Bump used Guava version in Kafka E2E tests Key: FLINK-33234 URL: https://issues.apache.org/jira/browse/FLINK-33234 Project: Flink Issue Type:

[jira] [Updated] (FLINK-33182) Allow metadata columns in NduAnalyzer with ChangelogNormalize

2023-10-10 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33182: Fix Version/s: 1.19.0 > Allow metadata columns in NduAnalyzer with ChangelogNormalize >

[jira] [Commented] (FLINK-33182) Allow metadata columns in NduAnalyzer with ChangelogNormalize

2023-10-10 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773700#comment-17773700 ] lincoln lee commented on FLINK-33182: - [~twalthr] Of course, I'll put it on my worklist for the next

[jira] [Assigned] (FLINK-33182) Allow metadata columns in NduAnalyzer with ChangelogNormalize

2023-10-10 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-33182: --- Assignee: lincoln lee > Allow metadata columns in NduAnalyzer with ChangelogNormalize >

Re: [PR] [FLINK-33233][hive] Fix NPE when non-native udf used in join condition in hive-parser [flink]

2023-10-10 Thread via GitHub
flinkbot commented on PR #23504: URL: https://github.com/apache/flink/pull/23504#issuecomment-1755484549 ## CI report: * 49df8d49f9a7d30f7f3d26dc2f86f95a2c77d98e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-33233) Null point exception when non-native udf used in join condition

2023-10-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33233: --- Labels: pull-request-available (was: ) > Null point exception when non-native udf used in

[jira] [Updated] (FLINK-33233) Null point exception when non-native udf used in join condition

2023-10-10 Thread yunfan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yunfan updated FLINK-33233: --- Description: Any non-native udf used in hive-parser join condition.  It will caused NullPointException.

[PR] [FLINK-33233][hive] Fix NPE when non-native udf used in join condition in hive-parser [flink]

2023-10-10 Thread via GitHub
yunfan123 opened a new pull request, #23504: URL: https://github.com/apache/flink/pull/23504 ## What is the purpose of the change Fix NPE when non-native udf used in join condition in hive-parser ## Brief change log This problem caused by not set UnparseTranslator when init

[jira] [Updated] (FLINK-33233) Null point exception when non-native udf used in join condition

2023-10-10 Thread yunfan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yunfan updated FLINK-33233: --- Environment: (was: It can reproduced by follow code by adding this test to  {code:java}

[jira] [Created] (FLINK-33233) Null point exception when non-native udf used in join condition

2023-10-10 Thread yunfan (Jira)
yunfan created FLINK-33233: -- Summary: Null point exception when non-native udf used in join condition Key: FLINK-33233 URL: https://issues.apache.org/jira/browse/FLINK-33233 Project: Flink Issue

[jira] [Updated] (FLINK-33232) Kubernetive Operator Not Able to Take Other Python paramters While Submitting Job Deployment

2023-10-10 Thread Amarjeet Singh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amarjeet Singh updated FLINK-33232: --- Description: Flink Operator Is not Able to Read the Python Cmd like -pyFiles. While apply

[jira] [Created] (FLINK-33232) Kubernetive Operator Not Able to Take Other Python paramters While Submitting Job Deployment

2023-10-10 Thread Amarjeet Singh (Jira)
Amarjeet Singh created FLINK-33232: -- Summary: Kubernetive Operator Not Able to Take Other Python paramters While Submitting Job Deployment Key: FLINK-33232 URL: https://issues.apache.org/jira/browse/FLINK-33232

[jira] [Created] (FLINK-33231) Memory leak in KafkaSourceReader if no data in consumed topic

2023-10-10 Thread Jira
Lauri Suurväli created FLINK-33231: -- Summary: Memory leak in KafkaSourceReader if no data in consumed topic Key: FLINK-33231 URL: https://issues.apache.org/jira/browse/FLINK-33231 Project: Flink

Re: [PR] Bump guava from 30.1.1-jre to 32.0.0-jre in /flink-connector-kafka-e2e-tests/flink-end-to-end-tests-common-kafka [flink-connector-kafka]

2023-10-10 Thread via GitHub
MartijnVisser commented on PR #33: URL: https://github.com/apache/flink-connector-kafka/pull/33#issuecomment-1755427837 @dependabot rebase -- 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

[jira] [Updated] (FLINK-33149) Bump snappy-java to 1.1.10.4

2023-10-10 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-33149: --- Fix Version/s: kafka-3.1.0 > Bump snappy-java to 1.1.10.4 > >

[jira] [Commented] (FLINK-33149) Bump snappy-java to 1.1.10.4

2023-10-10 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773686#comment-17773686 ] Martijn Visser commented on FLINK-33149: Merged in: apache/flink-connector-kafka:main

Re: [PR] [FLINK-33149] Bump snappy-java from 1.1.8.3 to 1.1.10.5 [flink-connector-kafka]

2023-10-10 Thread via GitHub
MartijnVisser merged PR #34: URL: https://github.com/apache/flink-connector-kafka/pull/34 -- 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-33228][flink-runtime] Fix the total current resource calculation when fulfilling requirement [flink]

2023-10-10 Thread via GitHub
KarmaGYZ commented on PR #23502: URL: https://github.com/apache/flink/pull/23502#issuecomment-1755330741 @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 comment.

Re: [PR] [FLINK-32563] Add disable-archunit-tests profile [flink-connector-shared-utils]

2023-10-10 Thread via GitHub
echauchot commented on PR #21: URL: https://github.com/apache/flink-connector-shared-utils/pull/21#issuecomment-1755288912 I submitted against main instead of parent-pom branch closing -- This is an automated message from the Apache Git Service. To respond to the message, please log on

Re: [PR] [FLINK-32563] Add disable-archunit-tests profile [flink-connector-shared-utils]

2023-10-10 Thread via GitHub
echauchot closed pull request #21: [FLINK-32563] Add disable-archunit-tests profile URL: https://github.com/apache/flink-connector-shared-utils/pull/21 -- 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] [Updated] (FLINK-32563) execute sanity checks only with Flink version that connectors were built against

2023-10-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32563: --- Labels: pull-request-available (was: ) > execute sanity checks only with Flink version

Re: [PR] [FLINK-33097][autoscaler] Initialize the generic autoscaler module and interfaces [flink-kubernetes-operator]

2023-10-10 Thread via GitHub
1996fanrui commented on code in PR #677: URL: https://github.com/apache/flink-kubernetes-operator/pull/677#discussion_r1352333625 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java: ## @@

Re: [PR] [FLINK-33229][table-planner] Moving Java class FlinkRecomputeStatisticsProgram from scala package to java package [flink]

2023-10-10 Thread via GitHub
lincoln-lil merged PR #23503: URL: https://github.com/apache/flink/pull/23503 -- 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-33229][table-planner] Moving Java class FlinkRecomputeStatisticsProgram from scala package to java package [flink]

2023-10-10 Thread via GitHub
lincoln-lil commented on PR #23503: URL: https://github.com/apache/flink/pull/23503#issuecomment-1755222956 It's a reasonable move. +1 -- 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

[jira] [Assigned] (FLINK-33230) Support Expanding ExecutionGraph to StreamGraph in Web UI

2023-10-10 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-33230: Assignee: Yu Chen > Support Expanding ExecutionGraph to StreamGraph in Web UI >

Re: [PR] [hotfix][connectors/mongodb] Fix typo and optimize log [flink-connector-mongodb]

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

Re: [PR] [FLINK-33228][flink-runtime] Fix the total current resource calculation when fulfilling requirement [flink]

2023-10-10 Thread via GitHub
KarmaGYZ commented on PR #23502: URL: https://github.com/apache/flink/pull/23502#issuecomment-1755184939 @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 comment.

Re: [PR] [FLINK-33097][autoscaler] Initialize the generic autoscaler module and interfaces [flink-kubernetes-operator]

2023-10-10 Thread via GitHub
mxm commented on code in PR #677: URL: https://github.com/apache/flink-kubernetes-operator/pull/677#discussion_r1352290023 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java: ## @@ -174,6

Re: [PR] [FLINK-33097][autoscaler] Initialize the generic autoscaler module and interfaces [flink-kubernetes-operator]

2023-10-10 Thread via GitHub
mxm commented on code in PR #677: URL: https://github.com/apache/flink-kubernetes-operator/pull/677#discussion_r1352282612 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java: ## @@ -72,7

Re: [PR] [FLINK-33097][autoscaler] Initialize the generic autoscaler module and interfaces [flink-kubernetes-operator]

2023-10-10 Thread via GitHub
1996fanrui commented on code in PR #677: URL: https://github.com/apache/flink-kubernetes-operator/pull/677#discussion_r1351975279 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/config/AutoScalerOptions.java: ## @@ -15,149 +15,180 @@ * limitations under the

[jira] [Updated] (FLINK-33230) Support Expanding ExecutionGraph to StreamGraph in Web UI

2023-10-10 Thread Yu Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Chen updated FLINK-33230: Attachment: (was: image-2023-10-10-18-45-24-486.png) > Support Expanding ExecutionGraph to

[jira] [Updated] (FLINK-33230) Support Expanding ExecutionGraph to StreamGraph in Web UI

2023-10-10 Thread Yu Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Chen updated FLINK-33230: Description: Flink Web shows users the ExecutionGraph (i.e., chained operators), but in some cases, we

[jira] [Updated] (FLINK-33230) Support Expanding ExecutionGraph to StreamGraph in Web UI

2023-10-10 Thread Yu Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Chen updated FLINK-33230: Attachment: image-2023-10-10-18-52-38-252.png > Support Expanding ExecutionGraph to StreamGraph in Web UI

[jira] [Updated] (FLINK-33230) Support Expanding ExecutionGraph to StreamGraph in Web UI

2023-10-10 Thread Yu Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Chen updated FLINK-33230: Attachment: image-2023-10-10-18-45-24-486.png Component/s: Runtime / Web Frontend

[jira] [Resolved] (FLINK-15462) Introduce TrinoSqlDialect

2023-10-10 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-15462. - Fix Version/s: jdbc-3.2.0 Resolution: Fixed > Introduce TrinoSqlDialect >

[jira] [Commented] (FLINK-15462) Introduce TrinoSqlDialect

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

Re: [PR] [FLINK-15462][connectors] Add Trino dialect [flink-connector-jdbc]

2023-10-10 Thread via GitHub
snuyanzin merged PR #3: URL: https://github.com/apache/flink-connector-jdbc/pull/3 -- 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-15462) Introduce TrinoSqlDialect

2023-10-10 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-15462: --- Assignee: Joan Schipper > Introduce TrinoSqlDialect > - >

[jira] [Updated] (FLINK-15462) Introduce TrinoSqlDialect

2023-10-10 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-15462: Summary: Introduce TrinoSqlDialect (was: Introduce PrestoSqlDialect) > Introduce

[jira] [Assigned] (FLINK-15462) Introduce TrinoSqlDialect

2023-10-10 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-15462: --- Assignee: João Boto (was: Joan Schipper) > Introduce TrinoSqlDialect >

[jira] [Created] (FLINK-33230) Support Expanding ExecutionGraph to StreamGraph in Flink

2023-10-10 Thread Yu Chen (Jira)
Yu Chen created FLINK-33230: --- Summary: Support Expanding ExecutionGraph to StreamGraph in Flink Key: FLINK-33230 URL: https://issues.apache.org/jira/browse/FLINK-33230 Project: Flink Issue Type:

Re: [PR] [FLINK-32416] initial implementation of DynamicKafkaSource with bound… [flink-connector-kafka]

2023-10-10 Thread via GitHub
mxm commented on PR #44: URL: https://github.com/apache/flink-connector-kafka/pull/44#issuecomment-1754958456 Hey Mason! Do you want a review for this? -- 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

  1   2   >