lauri-suurvali-cko commented on PR #58:
URL:
https://github.com/apache/flink-connector-kafka/pull/58#issuecomment-1756966183
LGTM!
--
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 co
[
https://issues.apache.org/jira/browse/FLINK-33233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-33233.
--
Fix Version/s: 1.19.0
Resolution: Fixed
master: ea3e80c0984a61589458c0672e3f0a73495203ed
> Nul
luoyuxia merged PR #23504:
URL: https://github.com/apache/flink/pull/23504
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apac
xintongsong commented on PR #680:
URL: https://github.com/apache/flink-web/pull/680#issuecomment-1756880121
Thanks for the PR, @knaufk.
I wonder if we should add a paragraph about the deprecation works. Many APIs
are deprecated in 1.18 as preparing for the 2.0 release. It might be too
[
https://issues.apache.org/jira/browse/FLINK-26497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773909#comment-17773909
]
Yunhong Zheng commented on FLINK-26497:
---
This problem seems cannot be reproduce in
[
https://issues.apache.org/jira/browse/FLINK-33200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773908#comment-17773908
]
xuyang edited comment on FLINK-33200 at 10/11/23 6:06 AM:
--
Hi,
[
https://issues.apache.org/jira/browse/FLINK-33200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773908#comment-17773908
]
xuyang commented on FLINK-33200:
Hi, [~andyglow] . I think the issue 1 and 2 are caused
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`
[
https://issues.apache.org/jira/browse/FLINK-33236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773900#comment-17773900
]
Zhanghao Chen commented on FLINK-33236:
---
Hi [~mapohl], I've prepared a quick clean
[
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 high-availability.zookeeper.path
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
"high-avail
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
Project:
[
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
>
[
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
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: F
[
https://issues.apache.org/jira/browse/FLINK-33168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773896#comment-17773896
]
luoyuxia commented on FLINK-33168:
--
I believe the doc has been updated in FLINK-32982.
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 ScalarOperat
[
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
> ---
[
https://issues.apache.org/jira/browse/FLINK-33168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773893#comment-17773893
]
macdoor615 commented on FLINK-33168:
[~luoyuxia] table-planner-loader.jar works. Do
[
https://issues.apache.org/jira/browse/FLINK-33168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773891#comment-17773891
]
luoyuxia edited comment on FLINK-33168 at 10/11/23 4:16 AM:
[
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
exp
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`
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 wi
[
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
> --
[
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 w
[
https://issues.apache.org/jira/browse/FLINK-32072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773884#comment-17773884
]
Yanfei Lei commented on FLINK-32072:
Merged into master via 1112582fd136df47c6d356d6
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.
T
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
[
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
>
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 registerFileResource(Re
[
https://issues.apache.org/jira/browse/FLINK-33228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773872#comment-17773872
]
Yangze Guo commented on FLINK-33228:
master: 5269631af525a01d944cfa9994a116fb27b80b1
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 dropTemporarySystemFunc
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: issues-unsubscr...@flink.apac
[
https://issues.apache.org/jira/browse/FLINK-33168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773871#comment-17773871
]
luoyuxia commented on FLINK-33168:
--
[~macdoor615] Hi, could you please try using flink-
[
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: opera
[
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 skippe
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: issues-unsubscr...@flink.apac
[
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 data
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 +
[
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 Co
[
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 should
[
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
> OpensearchSinkTest.testAtLeas
[
https://issues.apache.org/jira/browse/FLINK-33020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773823#comment-17773823
]
Sergey Nuyanzin commented on FLINK-33020:
-
Time out was increased at
[87b23c46f
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
[
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
> ---
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: issues-unsubs
[
https://issues.apache.org/jira/browse/FLINK-33200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773794#comment-17773794
]
Andriy Onyshchuk commented on FLINK-33200:
--
Seems like I have caught several mo
[
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
[
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 con
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 ca
[
https://issues.apache.org/jira/browse/FLINK-33231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773790#comment-17773790
]
Tzu-Li (Gordon) Tai commented on FLINK-33231:
-
[~lauri.suurvali] I think tha
[
https://issues.apache.org/jira/browse/FLINK-33231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773784#comment-17773784
]
Lauri Suurväli commented on FLINK-33231:
[~tzulitai] thank you for the comment!
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 end-offse
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.
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 (ASF)
[
https://issues.apache.org/jira/browse/FLINK-32806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773758#comment-17773758
]
Samrat Deb commented on FLINK-32806:
[~hk__lrzy] are you working on the patch ?
>
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, pleas
[
https://issues.apache.org/jira/browse/FLINK-33231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773739#comment-17773739
]
Tzu-Li (Gordon) Tai commented on FLINK-33231:
-
Making this a blocker for the
[
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 KafkaSo
[
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 c
[
https://issues.apache.org/jira/browse/FLINK-33231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773738#comment-17773738
]
Tzu-Li (Gordon) Tai commented on FLINK-33231:
-
[~lauri.suurvali] great debug
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 S
[
https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773726#comment-17773726
]
Martijn Visser commented on FLINK-33052:
[~Zakelly] Is there any update on this
[
https://issues.apache.org/jira/browse/FLINK-32038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773719#comment-17773719
]
Martijn Visser commented on FLINK-32038:
[~pritam.agarwala] [~tzulitai] What is
[
https://issues.apache.org/jira/browse/FLINK-30400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773708#comment-17773708
]
Martijn Visser commented on FLINK-30400:
[~chesnay] How would this work for SQL
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: Te
[
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
> --
[
https://issues.apache.org/jira/browse/FLINK-33182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773700#comment-17773700
]
lincoln lee commented on FLINK-33182:
-
[~twalthr] Of course, I'll put it on my workl
[
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
> ---
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`
[
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 j
[
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.
It
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
Hiv
[
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}
org.apache.flink
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 Ty
[
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 us
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
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
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 spe
[
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
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-33149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773686#comment-17773686
]
Martijn Visser commented on FLINK-33149:
Merged in:
apache/flink-connector-kafk
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: issues-unsubsc
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.
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 to
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 t
[
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 that
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:
##
@@ -7
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: issues-unsubscr...@flink.a
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 specific
[
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
> -
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
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.
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 +1
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 +79
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 Lice
[
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 StreamGraph
[
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 wo
[
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
[
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
Affe
[
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
> ---
1 - 100 of 149 matches
Mail list logo
