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,
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 {
*
*
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
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
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
[
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
>
[
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+
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
[
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
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
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
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
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-
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
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
[
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
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
[
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
[
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
[
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
[
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
[
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:
[
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:
-
[
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:
-
[
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 ?
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
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
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
[
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
[
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
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
[
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:
--
[
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
[
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
[
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
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
[
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
[
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
> ---
[
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,
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
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:
+
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:
+
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:
+
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:
+
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:
+
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
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
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
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
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.
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.
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
[
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
[
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:
--
[
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
[
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
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
[
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
[
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
[
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
[
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
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
62 matches
Mail list logo
