[
https://issues.apache.org/jira/browse/FLINK-37291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-37291:
---
Description:
The weekly Kafka CI reports producer leaks in various runs, for various JDKs:
[
https://issues.apache.org/jira/browse/FLINK-37067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17925492#comment-17925492
]
Xintong Song commented on FLINK-37067:
--
Thanks for volunteering, [~yutonghan1718].
[
https://issues.apache.org/jira/browse/FLINK-37067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-37067:
Assignee: Yutong Han
> Cross-team verification for “Introduce DataStream API V2”
> --
[
https://issues.apache.org/jira/browse/FLINK-37067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17925491#comment-17925491
]
Yutong Han commented on FLINK-37067:
I would like to contribute to this task as test
[
https://issues.apache.org/jira/browse/FLINK-37291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-37291:
---
Description:
The weekly Kafka CI reports producer leaks in various runs, for various JDKs:
Martijn Visser created FLINK-37291:
--
Summary: Weekly Kafka CI detects producer leaks
Key: FLINK-37291
URL: https://issues.apache.org/jira/browse/FLINK-37291
Project: Flink
Issue Type: Bug
xuhuang created FLINK-37290:
---
Summary: Introduce endPartition to DataStream V2 ProcessFunction
Key: FLINK-37290
URL: https://issues.apache.org/jira/browse/FLINK-37290
Project: Flink
Issue Type: New
boring-cyborg[bot] commented on PR #116:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/116#issuecomment-2647149085
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
[
https://issues.apache.org/jira/browse/FLINK-37265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37265:
---
Labels: pull-request-available (was: )
> Document of python elasticsearch connector exeampl
Milesian111 opened a new pull request, #116:
URL: https://github.com/apache/flink-connector-elasticsearch/pull/116
There is no method named "ElasticsearchEmitter.static", it should be
"ElasticsearchEmitter.static_index".
--
This is an automated message from the Apache Git Service.
To resp
beryllw commented on PR #3914:
URL: https://github.com/apache/flink-cdc/pull/3914#issuecomment-2647125566
@lvyanquan @liuxiao2shf @ruanhang1993 cc.
--
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
beryllw opened a new pull request, #3914:
URL: https://github.com/apache/flink-cdc/pull/3914
close FLINK-37275.
--
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 unsubscri
[
https://issues.apache.org/jira/browse/FLINK-37275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37275:
---
Labels: pull-request-available (was: )
> MySQL source connector supports using the base mod
Zakelly commented on code in PR #26117:
URL: https://github.com/apache/flink/pull/26117#discussion_r1948417578
##
flink-examples/flink-examples-streaming/src/test/java/org/apache/flink/streaming/test/socket/SocketWindowWordCountITCase.java:
##
@@ -60,8 +72,15 @@ public void test
yuxiqian commented on code in PR #3433:
URL: https://github.com/apache/flink-cdc/pull/3433#discussion_r1948401550
##
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/MySqlToMySqlE2eITCase.java:
##
@@ -0,0 +1,234 @@
+/*
+ * Licens
hanyuzheng7 commented on code in PR #25897:
URL: https://github.com/apache/flink/pull/25897#discussion_r1948364110
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/DateTimeUtils.java:
##
@@ -1290,6 +1353,24 @@ private static long floor(long a, long b)
hanyuzheng7 commented on PR #25897:
URL: https://github.com/apache/flink/pull/25897#issuecomment-2646880671
@snuyanzin and @davidradl I think we should consider the situation when
`utcTs < 0`, `utcTs < 0` stand for the time before 1970s.
--
This is an automated message from the Apache Git
hanyuzheng7 commented on code in PR #25897:
URL: https://github.com/apache/flink/pull/25897#discussion_r1948364110
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/DateTimeUtils.java:
##
@@ -1290,6 +1353,24 @@ private static long floor(long a, long b)
fredia commented on code in PR #26107:
URL: https://github.com/apache/flink/pull/26107#discussion_r1948355701
##
docs/content.zh/docs/dev/datastream/fault-tolerance/state_v2.md:
##
@@ -0,0 +1,603 @@
+---
+title: "Working with State V2"
+weight: 2
+type: docs
+aliases:
+ - /dev/
[
https://issues.apache.org/jira/browse/FLINK-37069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan updated FLINK-37069:
Description:
Instructions:
First of all, please read the related documents briefly (still under r
[
https://issues.apache.org/jira/browse/FLINK-37069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan updated FLINK-37069:
Description:
Instructions:
First of all, please read the related documents briefly (still under r
GOODBOY008 merged PR #25800:
URL: https://github.com/apache/flink/pull/25800
--
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.ap
[
https://issues.apache.org/jira/browse/FLINK-37276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan resolved FLINK-37276.
-
Fix Version/s: 2.0.0
Resolution: Fixed
> Missing state v2 access interfaces in `RuntimeCo
flinkbot commented on PR #26130:
URL: https://github.com/apache/flink/pull/26130#issuecomment-2646822559
## CI report:
* 3d126847fd5daa4ecfd5a1055686706c6b7c826c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-37276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17925462#comment-17925462
]
Zakelly Lan commented on FLINK-37276:
-
Merged into master:
* f2ef99a6664774d0f14fca7
Zakelly merged PR #26125:
URL: https://github.com/apache/flink/pull/26125
--
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.apach
Zakelly commented on PR #26120:
URL: https://github.com/apache/flink/pull/26120#issuecomment-2646819737
I'm merging this since there are PR for stateful example jobs waiting for
this.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
Zakelly merged PR #26120:
URL: https://github.com/apache/flink/pull/26120
--
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.apach
fredia commented on code in PR #26107:
URL: https://github.com/apache/flink/pull/26107#discussion_r1948332722
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStOptions.java:
##
@@ -52,15 +52,16 @@ public class ForStOptions {
[
https://issues.apache.org/jira/browse/FLINK-37287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17925452#comment-17925452
]
911432 edited comment on FLINK-37287 at 2/10/25 2:35 AM:
-
[~kunn
Zakelly commented on code in PR #26107:
URL: https://github.com/apache/flink/pull/26107#discussion_r1948327845
##
docs/layouts/shortcodes/generated/expert_forst_section.html:
##
@@ -0,0 +1,54 @@
+
+
+
+Key
+Default
+Type
+
[
https://issues.apache.org/jira/browse/FLINK-37287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17925452#comment-17925452
]
911432 commented on FLINK-37287:
[~kunni] It has nothing to do with unusable.
Apache Pai
lsyldliu commented on code in PR #26073:
URL: https://github.com/apache/flink/pull/26073#discussion_r1948323675
##
docs/content/docs/dev/table/materialized-table/deployment.md:
##
@@ -0,0 +1,201 @@
+---
+title: Deployment
+weight: 3
+type: docs
+aliases:
+- /dev/table/materializ
[
https://issues.apache.org/jira/browse/FLINK-37287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17925451#comment-17925451
]
ChaomingZhang commented on FLINK-37287:
---
[~kunni] He is trying to improve the over
[
https://issues.apache.org/jira/browse/FLINK-37287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ChaomingZhang updated FLINK-37287:
--
Attachment: image-2025-02-10-10-27-23-181.png
> There was Apache Paimon 0.9, but it is gone.
>
zhougit86 commented on PR #23323:
URL: https://github.com/apache/flink/pull/23323#issuecomment-2646779393
@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.
hackergin opened a new pull request, #26130:
URL: https://github.com/apache/flink/pull/26130
BP https://github.com/apache/flink/pull/26064
--
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
[
https://issues.apache.org/jira/browse/FLINK-37287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ChaomingZhang updated FLINK-37287:
--
Attachment: image-2025-02-10-10-19-56-795.png
> There was Apache Paimon 0.9, but it is gone.
>
zhougit86 commented on PR #23323:
URL: https://github.com/apache/flink/pull/23323#issuecomment-2646773205
@X-czh @ljw-hit Hi , I have fixed the conflict, please help review the code
once you have time
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-37287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17925447#comment-17925447
]
Yanquan Lv commented on FLINK-37287:
[~911432] Hi, I don't get you point, are these
[
https://issues.apache.org/jira/browse/FLINK-37087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17925444#comment-17925444
]
dalongliu commented on FLINK-37087:
---
Merged in master: 35df68585b9cd04193967d70d852430
lsyldliu merged PR #26064:
URL: https://github.com/apache/flink/pull/26064
--
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
lsyldliu commented on PR #26064:
URL: https://github.com/apache/flink/pull/26064#issuecomment-2646749332
@hackergin Can you help open a PR backport it to release-2.0 branch?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
gaborgsomogyi commented on PR #26129:
URL: https://github.com/apache/flink/pull/26129#issuecomment-2646598377
Thanks for the contribution! In the meantime I've had a deep-dive and found
the root cause of the problem.
We came to the conclusion that we can solve the problem without the need
[
https://issues.apache.org/jira/browse/FLINK-37109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17925425#comment-17925425
]
Gary Lam commented on FLINK-37109:
--
Hey [~gaborgsomogyi] [~liuml07] ,
I put up a draft
flinkbot commented on PR #26129:
URL: https://github.com/apache/flink/pull/26129#issuecomment-2646569897
## CI report:
* 27057a4c57556b9a18a8699ca3d2941d8b3d8e82 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-37109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Lam updated FLINK-37109:
-
Attachment: Flamge graph post change using 35pct cpu.png
> Improve state processor API performance when
[
https://issues.apache.org/jira/browse/FLINK-37109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Lam updated FLINK-37109:
-
Attachment: (was: Flame graph prior to change remove using 74pct of
cpu.png)
> Improve state proces
[
https://issues.apache.org/jira/browse/FLINK-37109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Lam updated FLINK-37109:
-
Attachment: Flame graph prior to change remove using 74pct of cpu.png
> Improve state processor API perf
[
https://issues.apache.org/jira/browse/FLINK-37109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Lam updated FLINK-37109:
-
Attachment: Flame graph prior to change using 74pct cpu.png
> Improve state processor API performance wh
[
https://issues.apache.org/jira/browse/FLINK-37109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Lam updated FLINK-37109:
-
Attachment: Flame graph prior to change remove using 74pct of cpu.png
> Improve state processor API perf
[
https://issues.apache.org/jira/browse/FLINK-37109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37109:
---
Labels: pull-request-available (was: )
> Improve state processor API performance when readi
gustavodemorais commented on PR #26113:
URL: https://github.com/apache/flink/pull/26113#issuecomment-2646561197
Apart from addressing the minor comments, I've made the changes to support
arrays and multisets of rows, following Calcite's implementation.
After a couple of iterations on
lamgary opened a new pull request, #26129:
URL: https://github.com/apache/flink/pull/26129
## What is the purpose of the change
Improve state processor API performance when reading keyed rocksdb state by
allowing duplicates
## Brief change log
- Add parameter to KeyedSta
laughingman7743 commented on PR #156:
URL:
https://github.com/apache/flink-connector-jdbc/pull/156#issuecomment-2646358956
I have applied code formatting using Spotless and updated the documentation.
It is ready for review.
--
This is an automated message from the Apache Git Service.
To
flinkbot commented on PR #26128:
URL: https://github.com/apache/flink/pull/26128#issuecomment-2646201839
## CI report:
* 14b8d91afb5f1a71ad4679dfd88add2bd74409b2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-37289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37289:
---
Labels: pull-request-available (was: )
> Resolve JVM bytecode size limit exceeded in metho
littleeleventhwolf opened a new pull request, #26128:
URL: https://github.com/apache/flink/pull/26128
## What is the purpose of the change
The SQL job encounters issues due to having too many fields in the DML
operations, such as a job which has over 2,000 fields. This
xintongsong commented on code in PR #26118:
URL: https://github.com/apache/flink/pull/26118#discussion_r1948044491
##
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/dsv2/wordcount/WordCount.java:
##
@@ -0,0 +1,335 @@
+/*
+ * Licensed to
59 matches
Mail list logo
