Re: [PR] [FLINK-14102] Introduce DB2Dialect. [flink-connector-jdbc]

2023-10-06 Thread via GitHub
davidradl commented on PR #8: URL: https://github.com/apache/flink-connector-jdbc/pull/8#issuecomment-1750191357 @MartijnVisser This is something we also would really like to be merged. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Commented] (FLINK-18356) flink-table-planner Exit code 137 returned from process

2023-10-06 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772493#comment-17772493 ] Sergey Nuyanzin commented on FLINK-18356: - https://dev.azure.com/apache-flink/ap

[jira] [Commented] (FLINK-18356) flink-table-planner Exit code 137 returned from process

2023-10-06 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772496#comment-17772496 ] Sergey Nuyanzin commented on FLINK-18356: - https://dev.azure.com/apache-flink/ap

[jira] [Updated] (FLINK-27076) Setup runners

2023-10-06 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-27076: -- Description: h2. GitHub Documentation * About self-hosted runners * Adding self-hosted runners

[jira] [Updated] (FLINK-27076) Setup runners

2023-10-06 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-27076: -- Description: h2. GitHub Documentation * [About self-hosted runners|https://docs.github.com/e

[jira] [Updated] (FLINK-27076) Setup runners

2023-10-06 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-27076: -- Description: Below is a collection of links around the topic of self-hosted runners and the c

[jira] [Created] (FLINK-33197) PyFlink support for ByteArraySchema

2023-10-06 Thread Liu Chong (Jira)
Liu Chong created FLINK-33197: - Summary: PyFlink support for ByteArraySchema Key: FLINK-33197 URL: https://issues.apache.org/jira/browse/FLINK-33197 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-27076) Setup runners

2023-10-06 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-27076: -- Description: Below is a collection of links around the topic of self-hosted runners and the c

[jira] [Comment Edited] (FLINK-33104) Nightly run for Flink Kafka connector fails due to architecture tests failing

2023-10-06 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17770338#comment-17770338 ] Etienne Chauchot edited comment on FLINK-33104 at 10/6/23 10:27 AM: --

[jira] [Commented] (FLINK-33104) Nightly run for Flink Kafka connector fails due to architecture tests failing

2023-10-06 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772516#comment-17772516 ] Etienne Chauchot commented on FLINK-33104: -- [~tzulitai] yes this is exactly wha

Re: [PR] [FLINK-32353] [hotfix] build against last flink 1.16 and 1.17 and enable archunit only on main flink release [flink-connector-cassandra]

2023-10-06 Thread via GitHub
echauchot commented on PR #19: URL: https://github.com/apache/flink-connector-cassandra/pull/19#issuecomment-1750384738 Hi @tzulitai yes I fell back this PR's scope to just upgrading the versions hence the self merge. But, as I just wrote in [this ticket](https://issues.apache.org/jira/bro

Re: [PR] [FLINK-33159] [build] use variables in pom file for Java and Maven versions [flink]

2023-10-06 Thread via GitHub
davidradl commented on code in PR #23469: URL: https://github.com/apache/flink/pull/23469#discussion_r1348594028 ## flink-walkthroughs/flink-walkthrough-datastream-java/src/main/resources/archetype-resources/pom.xml: ## @@ -31,7 +31,6 @@ under the License.

Re: [PR] [FLINK-33159] [build] use variables in pom file for Java and Maven versions [flink]

2023-10-06 Thread via GitHub
davidradl commented on code in PR #23469: URL: https://github.com/apache/flink/pull/23469#discussion_r1348594028 ## flink-walkthroughs/flink-walkthrough-datastream-java/src/main/resources/archetype-resources/pom.xml: ## @@ -31,7 +31,6 @@ under the License.

Re: [PR] [FLINK-33046][FLIP-333] Redesign Apache Flink website [flink-web]

2023-10-06 Thread via GitHub
dannycranmer commented on PR #676: URL: https://github.com/apache/flink-web/pull/676#issuecomment-1750463733 > Not sure if it's intended, but when hovering over the Flink logo in top left, then "Apache Flink" becomes visible (in dark mode). I think we should always display it, because the s

[PR] add announcement blog post for Flink 1.18 [flink-web]

2023-10-06 Thread via GitHub
knaufk opened a new pull request, #680: URL: https://github.com/apache/flink-web/pull/680 (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 unsubscribe, e-mai

Re: [PR] [FLINK-33159] [build] use variables in pom file for Java and Maven versions [flink]

2023-10-06 Thread via GitHub
davidradl commented on PR #23469: URL: https://github.com/apache/flink/pull/23469#issuecomment-1750644172 @ferenc-csaky thanks I have made the requested change. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

Re: [PR] [FLINK-32380] Support Java Records with PojoTypeInfo/Serializer [flink]

2023-10-06 Thread via GitHub
gyfora commented on PR #23490: URL: https://github.com/apache/flink/pull/23490#issuecomment-1750668456 I just realised that the current implementation won't work with schema evolution as we have to "remap" the parameter indexes for the constructor afterwards, also defining new primitive fie

Re: [PR] add announcement blog post for Flink 1.18 [flink-web]

2023-10-06 Thread via GitHub
davidradl commented on code in PR #680: URL: https://github.com/apache/flink-web/pull/680#discussion_r1348732092 ## docs/content/posts/2023-10-10-release-1.18.0.md: ## @@ -0,0 +1,542 @@ +--- +authors: +- JingGe: + name: "Jing Ge" + twitter: jingengineer +- KonstantinKnauf: +

Re: [PR] add announcement blog post for Flink 1.18 [flink-web]

2023-10-06 Thread via GitHub
davidradl commented on code in PR #680: URL: https://github.com/apache/flink-web/pull/680#discussion_r1348735360 ## docs/content/posts/2023-10-10-release-1.18.0.md: ## @@ -0,0 +1,542 @@ +--- +authors: +- JingGe: + name: "Jing Ge" + twitter: jingengineer +- KonstantinKnauf: +

Re: [PR] add announcement blog post for Flink 1.18 [flink-web]

2023-10-06 Thread via GitHub
snuyanzin commented on code in PR #680: URL: https://github.com/apache/flink-web/pull/680#discussion_r1348755495 ## docs/content/posts/2023-10-10-release-1.18.0.md: ## @@ -0,0 +1,542 @@ +--- +authors: +- JingGe: + name: "Jing Ge" + twitter: jingengineer +- KonstantinKnauf: +

Re: [PR] add announcement blog post for Flink 1.18 [flink-web]

2023-10-06 Thread via GitHub
snuyanzin commented on code in PR #680: URL: https://github.com/apache/flink-web/pull/680#discussion_r1348759823 ## docs/content/posts/2023-10-10-release-1.18.0.md: ## @@ -0,0 +1,542 @@ +--- +authors: +- JingGe: + name: "Jing Ge" + twitter: jingengineer +- KonstantinKnauf: +

Re: [PR] add announcement blog post for Flink 1.18 [flink-web]

2023-10-06 Thread via GitHub
snuyanzin commented on code in PR #680: URL: https://github.com/apache/flink-web/pull/680#discussion_r1348759823 ## docs/content/posts/2023-10-10-release-1.18.0.md: ## @@ -0,0 +1,542 @@ +--- +authors: +- JingGe: + name: "Jing Ge" + twitter: jingengineer +- KonstantinKnauf: +

[jira] [Created] (FLINK-33198) Add timestamp with local time zone support in Avro converters

2023-10-06 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-33198: - Summary: Add timestamp with local time zone support in Avro converters Key: FLINK-33198 URL: https://issues.apache.org/jira/browse/FLINK-33198 Project: Flink

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

2023-10-06 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772592#comment-17772592 ] lincoln lee commented on FLINK-33182: - [~twalthr] I've thought about this carefully,

[jira] [Assigned] (FLINK-33198) Add timestamp with local time zone support in Avro converters

2023-10-06 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-33198: -- Assignee: Zhenqiu Huang > Add timestamp with local time zone support in Avro converters > ---

[jira] [Updated] (FLINK-33109) Watermark alignment not applied after recovery from checkpoint

2023-10-06 Thread Yordan Pavlov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yordan Pavlov updated FLINK-33109: -- Attachment: WatermarkTest.scala > Watermark alignment not applied after recovery from checkpoi

Re: [PR] [FLINK-33187] Don't record duplicate event if no change [flink-kubernetes-operator]

2023-10-06 Thread via GitHub
gyfora commented on code in PR #683: URL: https://github.com/apache/flink-kubernetes-operator/pull/683#discussion_r1348864871 ## flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/ScalingExecutor.java: ## @@ -94,14 +94,15 @@ publi

[jira] [Commented] (FLINK-33109) Watermark alignment not applied after recovery from checkpoint

2023-10-06 Thread Yordan Pavlov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772616#comment-17772616 ] Yordan Pavlov commented on FLINK-33109: --- Hi [~fanrui]  sorry for the delay, runni

[jira] [Updated] (FLINK-33109) Watermark alignment not applied after recovery from checkpoint

2023-10-06 Thread Yordan Pavlov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yordan Pavlov updated FLINK-33109: -- Attachment: WatermarkTest-1.scala > Watermark alignment not applied after recovery from checkp

[jira] [Updated] (FLINK-33109) Watermark alignment not applied after recovery from checkpoint

2023-10-06 Thread Yordan Pavlov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yordan Pavlov updated FLINK-33109: -- Attachment: (was: WatermarkTest.scala) > Watermark alignment not applied after recovery fr

[jira] [Comment Edited] (FLINK-33109) Watermark alignment not applied after recovery from checkpoint

2023-10-06 Thread Yordan Pavlov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772616#comment-17772616 ] Yordan Pavlov edited comment on FLINK-33109 at 10/6/23 3:44 PM: --

[jira] [Created] (FLINK-33199) ArchitectureTests should test for canonical class names instead of Class objects

2023-10-06 Thread Alexander Fedulov (Jira)
Alexander Fedulov created FLINK-33199: - Summary: ArchitectureTests should test for canonical class names instead of Class objects Key: FLINK-33199 URL: https://issues.apache.org/jira/browse/FLINK-33199

[jira] [Assigned] (FLINK-33199) ArchitectureTests should test for canonical class names instead of Class objects

2023-10-06 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov reassigned FLINK-33199: - Assignee: Alexander Fedulov > ArchitectureTests should test for canonical class

[jira] [Updated] (FLINK-33199) ArchitectureTests should test for fully qualified class names instead of Class objects

2023-10-06 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-33199: -- Summary: ArchitectureTests should test for fully qualified class names instead of Clas

Re: [PR] [FLINK-31631][FileSystems] shade guava in gs-fs filesystem [flink]

2023-10-06 Thread via GitHub
singhravidutt commented on PR #23489: URL: https://github.com/apache/flink/pull/23489#issuecomment-1751097059 @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 comm

Re: [PR] [FLINK-33187] Don't record duplicate event if no change [flink-kubernetes-operator]

2023-10-06 Thread via GitHub
clarax commented on code in PR #683: URL: https://github.com/apache/flink-kubernetes-operator/pull/683#discussion_r1349036555 ## flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java: ## @@ -168,4 +168,1

Re: [PR] [FLINK-33187] Don't record duplicate event if no change [flink-kubernetes-operator]

2023-10-06 Thread via GitHub
clarax commented on code in PR #683: URL: https://github.com/apache/flink-kubernetes-operator/pull/683#discussion_r1349038012 ## flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/ScalingExecutor.java: ## @@ -94,14 +94,15 @@ publi

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

2023-10-06 Thread Enzo Dechaene (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772666#comment-17772666 ] Enzo Dechaene commented on FLINK-31371: --- Hi [~syhily], any news for this ticket ?

[jira] [Comment Edited] (FLINK-33011) Operator deletes HA data unexpectedly

2023-10-06 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772350#comment-17772350 ] Mason Chen edited comment on FLINK-33011 at 10/6/23 7:06 PM: -

[jira] [Comment Edited] (FLINK-33011) Operator deletes HA data unexpectedly

2023-10-06 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772350#comment-17772350 ] Mason Chen edited comment on FLINK-33011 at 10/6/23 7:07 PM: -

[jira] [Commented] (FLINK-33175) Nightly builds from S3 are not available for download, breaking all connector tests

2023-10-06 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772680#comment-17772680 ] Jing Ge commented on FLINK-33175: - [~mapohl] the file is ok and not public accessible:

[jira] [Comment Edited] (FLINK-33175) Nightly builds from S3 are not available for download, breaking all connector tests

2023-10-06 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772680#comment-17772680 ] Jing Ge edited comment on FLINK-33175 at 10/6/23 8:18 PM: -- [~ma

[jira] [Updated] (FLINK-32732) auto offset reset should be exposed to user

2023-10-06 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-32732: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink Ji

[jira] [Updated] (FLINK-31615) Fix some parts forgot to translate in "Table API" page of "Table API & SQL"

2023-10-06 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-31615: --- Labels: auto-deprioritized-minor chinese-translation (was: chinese-translation stale-mino

[jira] [Updated] (FLINK-32293) Support vector with long index

2023-10-06 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-32293: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink Ji

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

2023-10-06 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-33200: - Summary: ItemAt Expression validation fail in Table API due to type mismatch Key: FLINK-33200 URL: https://issues.apache.org/jira/browse/FLINK-33200 Project: Flink

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

2023-10-06 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772723#comment-17772723 ] Zhenqiu Huang commented on FLINK-33200: --- [~lzljs3620320] As StringDataTypeInfo is

Re: [PR] add announcement blog post for Flink 1.18 [flink-web]

2023-10-06 Thread via GitHub
lsyldliu commented on code in PR #680: URL: https://github.com/apache/flink-web/pull/680#discussion_r1349437120 ## docs/content/posts/2023-10-10-release-1.18.0.md: ## @@ -0,0 +1,542 @@ +--- +authors: +- JingGe: + name: "Jing Ge" + twitter: jingengineer +- KonstantinKnauf: + n

Re: [PR] [FLINK-26088][Connectors/ElasticSearch] Add Elasticsearch 8.0 support [flink-connector-elasticsearch]

2023-10-06 Thread via GitHub
rinkako commented on PR #53: URL: https://github.com/apache/flink-connector-elasticsearch/pull/53#issuecomment-1751562763 hi @mtfelisb , I read the code and found that it has no implementation for `DynamicTableSink`, hence this es8 sink cannot be used in flink-sql. Would you have any plan

Re: [PR] [FLINK-33046][FLIP-333] Redesign Apache Flink website [flink-web]

2023-10-06 Thread via GitHub
Myasuka commented on PR #676: URL: https://github.com/apache/flink-web/pull/676#issuecomment-1751567081 I found a strange behavior that when I click the nav title on the right, it will hide the head of lines: ![image](https://github.com/apache/flink-web/assets/1709104/9d641aab-1db4-4115-

Re: [PR] [FLINK-33053][zookeeper] Manually remove the leader watcher after ret… [flink]

2023-10-06 Thread via GitHub
KarmaGYZ commented on code in PR #23415: URL: https://github.com/apache/flink/pull/23415#discussion_r1349440903 ## flink-runtime/src/main/java/org/apache/flink/runtime/leaderretrieval/ZooKeeperLeaderRetrievalDriver.java: ## @@ -122,6 +125,19 @@ public void close() throws Excepti

Re: [PR] [FLINK-33053][zookeeper] Manually remove the leader watcher after ret… [flink]

2023-10-06 Thread via GitHub
KarmaGYZ commented on code in PR #23415: URL: https://github.com/apache/flink/pull/23415#discussion_r1349440740 ## flink-runtime/src/main/java/org/apache/flink/runtime/leaderretrieval/ZooKeeperLeaderRetrievalDriver.java: ## @@ -122,6 +125,19 @@ public void close() throws Excepti

Re: [PR] [FLINK-33053][zookeeper] Manually remove the leader watcher after ret… [flink]

2023-10-06 Thread via GitHub
KarmaGYZ commented on code in PR #23415: URL: https://github.com/apache/flink/pull/23415#discussion_r1349440903 ## flink-runtime/src/main/java/org/apache/flink/runtime/leaderretrieval/ZooKeeperLeaderRetrievalDriver.java: ## @@ -122,6 +125,19 @@ public void close() throws Excepti

[jira] [Commented] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

2023-10-06 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772734#comment-17772734 ] Fang Yong commented on FLINK-31275: --- [~ZhenqiuHuang] Thanks for your attention, FLIP-3

Re: [PR] add announcement blog post for Flink 1.18 [flink-web]

2023-10-06 Thread via GitHub
Myasuka commented on code in PR #680: URL: https://github.com/apache/flink-web/pull/680#discussion_r1349442579 ## docs/content/posts/2023-10-10-release-1.18.0.md: ## @@ -0,0 +1,542 @@ +--- +authors: +- JingGe: + name: "Jing Ge" + twitter: jingengineer +- KonstantinKnauf: + na

[jira] [Updated] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

2023-10-06 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-31275: -- Description: FLIP-314 has been accepted https://cwiki.apache.org/confluence/display/FLINK/FLIP-314%3A+

[jira] [Assigned] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

2023-10-06 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-31275: - Assignee: Fang Yong > Flink supports reporting and storage of source/sink tables relationship >

Re: [PR] [FLINK-33166][core][config] Make root logger level configurable [flink]

2023-10-06 Thread via GitHub
X-czh commented on PR #23476: URL: https://github.com/apache/flink/pull/23476#issuecomment-1751601862 @FangYongs, could you help review it when you have time? Many thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and us

[jira] [Created] (FLINK-33201) Memory leak in CachingTopicSelector

2023-10-06 Thread Sunyeop Lee (Jira)
Sunyeop Lee created FLINK-33201: --- Summary: Memory leak in CachingTopicSelector Key: FLINK-33201 URL: https://issues.apache.org/jira/browse/FLINK-33201 Project: Flink Issue Type: Bug C

[jira] [Created] (FLINK-33202) FLIP-327: Support switching from batch to stream mode to improve throughput when processing backlog data

2023-10-06 Thread Xuannan Su (Jira)
Xuannan Su created FLINK-33202: -- Summary: FLIP-327: Support switching from batch to stream mode to improve throughput when processing backlog data Key: FLINK-33202 URL: https://issues.apache.org/jira/browse/FLINK-332

Re: [PR] [FLINK-33060] Fix the javadoc of ListState interfaces about not allowing null value [flink]

2023-10-06 Thread via GitHub
Zakelly commented on code in PR #23441: URL: https://github.com/apache/flink/pull/23441#discussion_r1349473352 ## flink-core/src/main/java/org/apache/flink/api/common/state/AppendingState.java: ## @@ -60,8 +60,11 @@ public interface AppendingState extends State { * *

Re: [PR] [FLINK-33161] Java17 profile for benchmarking [flink-benchmarks]

2023-10-06 Thread via GitHub
Zakelly commented on PR #80: URL: https://github.com/apache/flink-benchmarks/pull/80#issuecomment-1751624381 I'm not sure if I have the right person, @pnowojski , but would you please review this one? -- This is an automated message from the Apache Git Service. To respond to the message,