[
https://issues.apache.org/jira/browse/FLINK-36061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36061:
---
Labels: pull-request-available (was: )
> Support Apache iceberg for pipeline connector
> --
[
https://issues.apache.org/jira/browse/FLINK-37128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-37128:
--
Fix Version/s: cdc-3.4.0
> Binlog reader skip `shouldEmit` filter when snapshot reader skip backfill
>
[
https://issues.apache.org/jira/browse/FLINK-36876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17915946#comment-17915946
]
Gyula Fora commented on FLINK-36876:
You tell me [~stupid_pig] how you would like to
dawidwys merged PR #26038:
URL: https://github.com/apache/flink/pull/26038
--
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-37194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17915941#comment-17915941
]
Luke Chen commented on FLINK-37194:
---
[~yyhx] [~Weijie Guo] , I've figured it out why i
yoheimuta commented on PR #3876:
URL: https://github.com/apache/flink-cdc/pull/3876#issuecomment-2606494441
Here is the current difference in DataChangeEvent between renaming a single
table and renaming multiple tables:
The first log comes from renaming a single table in a single stat
showuon commented on code in PR #26048:
URL: https://github.com/apache/flink/pull/26048#discussion_r1924825295
##
flink-tests/src/test/java/org/apache/flink/test/streaming/api/datastream/WatermarkITCase.java:
##
@@ -135,6 +135,27 @@ void after() throws Exception {
}
[
https://issues.apache.org/jira/browse/FLINK-37194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37194:
---
Labels: pull-request-available (was: )
> WatermarkITCase.testAlignedWatermarkBlockUpstream
showuon opened a new pull request, #26048:
URL: https://github.com/apache/flink/pull/26048
## What is the purpose of the change
Fix NPE issue in WatermarkITCase.
The NPE is because
[here](https://github.com/apache/flink/blob/52d6691d2ef98d3a43c611c19e1eb9cc45da834d/flink-t
gaborgsomogyi commented on code in PR #26035:
URL: https://github.com/apache/flink/pull/26035#discussion_r1924819051
##
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/table/StateDynamicTableSourceFactory.java:
##
@@ -0,0 +1,355 @@
+/*
+ * License
gaborgsomogyi commented on PR #26034:
URL: https://github.com/apache/flink/pull/26034#issuecomment-2606480736
cc @gyfora
--
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-37138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reopened FLINK-37138:
---
> testDeployScriptViaSqlClient failed on AZP
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-37138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-37138:
-
Assignee: Shengkai Fang
> testDeployScriptViaSqlClient failed on AZP
>
[
https://issues.apache.org/jira/browse/FLINK-37138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-37138.
-
Resolution: Fixed
> testDeployScriptViaSqlClient failed on AZP
> ---
[
https://issues.apache.org/jira/browse/FLINK-37138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17915939#comment-17915939
]
Shengkai Fang commented on FLINK-37138:
---
[~Weijie Guo] Please use the origin issue
Zakelly merged PR #102:
URL: https://github.com/apache/flink-benchmarks/pull/102
--
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...@flin
ferenc-csaky merged PR #26026:
URL: https://github.com/apache/flink/pull/26026
--
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.
ferenc-csaky commented on PR #26026:
URL: https://github.com/apache/flink/pull/26026#issuecomment-2606445871
FYI: CI failed because of a different issue, the modified test ran
correctly, also CI run were successful for both backport PRs.
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-37183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky closed FLINK-37183.
Release Note: Symlinks can once again be used in "usrlib". (was: Symlinks
can once again be used
ferenc-csaky merged PR #26027:
URL: https://github.com/apache/flink/pull/26027
--
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.
ferenc-csaky merged PR #26028:
URL: https://github.com/apache/flink/pull/26028
--
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.
yoheimuta commented on code in PR #3876:
URL: https://github.com/apache/flink-cdc/pull/3876#discussion_r1924784146
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlRenameTablesSchemaFixITCase.java:
reswqa commented on PR #26031:
URL: https://github.com/apache/flink/pull/26031#issuecomment-2606403348
CI failure unrelated.
--
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.
ferenc-csaky commented on PR #25955:
URL: https://github.com/apache/flink/pull/25955#issuecomment-2606429228
> @ferenc-csaky could you rerun the tests without reflection and unpooled,
but with a slightly increased off-heap memory? We probably need to just find
the sweet spot to account for
yoheimuta opened a new pull request, #3876:
URL: https://github.com/apache/flink-cdc/pull/3876
This closes [FLINK-36945](https://issues.apache.org/jira/browse/FLINK-36945).
[The Vitess schema migration
tool](https://vitess.io/docs/user-guides/schema-changes/ddl-strategies/)
renames m
[
https://issues.apache.org/jira/browse/FLINK-37196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-37196:
---
Priority: Blocker (was: Major)
> Build documentation github action can't work
> ---
Weijie Guo created FLINK-37196:
--
Summary: Build documentation github action can't work
Key: FLINK-37196
URL: https://issues.apache.org/jira/browse/FLINK-37196
Project: Flink
Issue Type: Bug
reswqa opened a new pull request, #101:
URL: https://github.com/apache/flink-benchmarks/pull/101
(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
[
https://issues.apache.org/jira/browse/FLINK-37196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17915934#comment-17915934
]
Weijie Guo commented on FLINK-37196:
cc [~mapohl], Do you know if we have any update
[
https://issues.apache.org/jira/browse/FLINK-37196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-37196:
---
Description:
{code:java}
Cloning into 'flink-connector-elasticsearch'...
setup_docs.sh: line 35: rsy
reswqa merged PR #26032:
URL: https://github.com/apache/flink/pull/26032
--
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.apache
reswqa merged PR #26031:
URL: https://github.com/apache/flink/pull/26031
--
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.apache
[
https://issues.apache.org/jira/browse/FLINK-37035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17915931#comment-17915931
]
Weijie Guo commented on FLINK-37035:
Add new version 2.1 and update GHA nightly buil
dependabot[bot] opened a new pull request, #26047:
URL: https://github.com/apache/flink/pull/26047
Removes [vite](https://github.com/vitejs/vite/tree/HEAD/packages/vite). It's
no longer used after updating ancestor dependency
[@angular-devkit/build-angular](https://github.com/angular/angula
[
https://issues.apache.org/jira/browse/FLINK-37035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17915931#comment-17915931
]
Weijie Guo edited comment on FLINK-37035 at 1/22/25 6:34 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-37035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17915931#comment-17915931
]
Weijie Guo edited comment on FLINK-37035 at 1/22/25 6:34 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-37035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17915931#comment-17915931
]
Weijie Guo edited comment on FLINK-37035 at 1/22/25 6:34 AM:
-
reswqa commented on PR #26032:
URL: https://github.com/apache/flink/pull/26032#issuecomment-2606406573
CI failure unrelated.
--
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.
reswqa commented on PR #100:
URL: https://github.com/apache/flink-benchmarks/pull/100#issuecomment-2606391236
Already done in 5e2164bd.
--
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 specifi
reswqa closed pull request #100: [FLINK-37035][release] Bump Flink version to
2.1-SNAPSHOT
URL: https://github.com/apache/flink-benchmarks/pull/100
--
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 th
dingxin-tech opened a new pull request, #3875:
URL: https://github.com/apache/flink-cdc/pull/3875
After the parameters are modified, the document in the example part of the
document is not modified.
--
This is an automated message from the Apache Git Service.
To respond to the message, pl
[
https://issues.apache.org/jira/browse/FLINK-37128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37128:
---
Labels: pull-request-available (was: )
> Binlog reader skip `shouldEmit` filter when snapsh
[
https://issues.apache.org/jira/browse/FLINK-37128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JunboWang updated FLINK-37128:
--
Affects Version/s: cdc-3.3.0
(was: cdc-3.2.1)
> Binlog reader skip `shouldE
flinkbot commented on PR #26046:
URL: https://github.com/apache/flink/pull/26046#issuecomment-2606269908
## CI report:
* c8837c40652733e565de7c23a05c0b8202ea4799 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-37195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yux closed FLINK-37195.
---
Resolution: Resolved
It turns out to be caused by a miswritten projection expression typo.
Still need to add corres
yux created FLINK-37195:
---
Summary: TimestampAdd / TimestampDiff series function not
available in cluster
Key: FLINK-37195
URL: https://issues.apache.org/jira/browse/FLINK-37195
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-35623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35623:
---
Fix Version/s: mongodb-2.0.0
(was: mongodb-1.3.0)
> Bump mongo-driver version
[
https://issues.apache.org/jira/browse/FLINK-34216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-34216:
---
Fix Version/s: mongodb-2.0.0
(was: mongodb-1.3.0)
> Support fine-grained conf
[
https://issues.apache.org/jira/browse/FLINK-35616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35616:
---
Fix Version/s: mongodb-2.0.0
(was: mongodb-1.3.0)
> Support upsert into shard
[
https://issues.apache.org/jira/browse/FLINK-36075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-36075:
---
Fix Version/s: mongodb-2.0.0
(was: mongodb-1.3.0)
> Add paginate partition st
[
https://issues.apache.org/jira/browse/FLINK-34214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-34214:
---
Fix Version/s: mongodb-2.0.0
(was: mongodb-1.3.0)
> FLIP-377: Support fine-gr
[
https://issues.apache.org/jira/browse/FLINK-36074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-36074:
---
Fix Version/s: mongodb-2.0.0
(was: mongodb-1.3.0)
> Support insert overwrite
[
https://issues.apache.org/jira/browse/FLINK-35975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35975:
---
Fix Version/s: mongodb-2.0.0
(was: mongodb-1.3.0)
> MongoFilterPushDownVisito
[
https://issues.apache.org/jira/browse/FLINK-36053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-36053:
---
Fix Version/s: mongodb-2.0.0
(was: mongodb-1.3.0)
> Support multi-version int
[
https://issues.apache.org/jira/browse/FLINK-36738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-36738:
---
Fix Version/s: mongodb-2.0.0
(was: mongodb-1.3.0)
> Weekly CI for MongoDB con
Zakelly commented on code in PR #26035:
URL: https://github.com/apache/flink/pull/26035#discussion_r1924657234
##
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/table/StateDynamicTableSourceFactory.java:
##
@@ -0,0 +1,355 @@
+/*
+ * Licensed to t
Zakelly commented on code in PR #26035:
URL: https://github.com/apache/flink/pull/26035#discussion_r1924655319
##
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/table/StateDynamicTableSourceFactory.java:
##
@@ -0,0 +1,355 @@
+/*
+ * Licensed to t
[
https://issues.apache.org/jira/browse/FLINK-37194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-37194:
--
Assignee: xuhuang
> WatermarkITCase.testAlignedWatermarkBlockUpstream failed
> --
[
https://issues.apache.org/jira/browse/FLINK-36806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zjjiang updated FLINK-36806:
Description:
Currently, FlinkCDC can correctly synchronize the same time type (where the
type indicates w
[
https://issues.apache.org/jira/browse/FLINK-37194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17915902#comment-17915902
]
Weijie Guo commented on FLINK-37194:
[~yyhx] could you please take a look?
> Waterm
[
https://issues.apache.org/jira/browse/FLINK-37194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-37194:
---
Description:
{code:java}
Jan 21 04:25:55 04:25:55.721 [ERROR]
org.apache.flink.test.streaming.api.
Weijie Guo created FLINK-37194:
--
Summary: WatermarkITCase.testAlignedWatermarkBlockUpstream failed
Key: FLINK-37194
URL: https://issues.apache.org/jira/browse/FLINK-37194
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-37073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Lee updated FLINK-37073:
---
Description:
In Flink 2.0, we introduced adaptive batch execution. In this mode, the job
graph is i
[
https://issues.apache.org/jira/browse/FLINK-36876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17915892#comment-17915892
]
chenyuzhi commented on FLINK-36876:
---
Are there any further new ideas or discussions on
[
https://issues.apache.org/jira/browse/FLINK-36074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun resolved FLINK-36074.
Resolution: Fixed
Implemented via flink-connector-mongodb main:
0e31aa8890e4514c84e1f1d11e4e0d287
chenyuzhi459 commented on PR #25788:
URL: https://github.com/apache/flink/pull/25788#issuecomment-2606156814
> Reviewed by Chi on 12/12/24. Asked submitter questions
The code has been updated and the question has been answered. Please review
again.
@davidradl
--
This is an
fredia commented on PR #26033:
URL: https://github.com/apache/flink/pull/26033#issuecomment-2606154364
@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
Jiabao-Sun merged PR #43:
URL: https://github.com/apache/flink-connector-mongodb/pull/43
--
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
[
https://issues.apache.org/jira/browse/FLINK-37182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Lee updated FLINK-37182:
---
Fix Version/s: 2.1.0
> PartitionedFileWriteReadTest should remove partition files after test
> fini
[
https://issues.apache.org/jira/browse/FLINK-37182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Lee resolved FLINK-37182.
Resolution: Fixed
master：
abbfc66c905c9385a255f9a2193221ba97550884
085f37bfe694bc10e2bc216777ef4b5
JunRuiLee commented on PR #26025:
URL: https://github.com/apache/flink/pull/26025#issuecomment-2606139486
🤦♂️ It seems I've encountered a bug on GitHub. I merged the squashed
commit, but the result was that the two commits before squashing were merged
into the master. 😓
But it's okay; i
GOODBOY008 commented on PR #3873:
URL: https://github.com/apache/flink-cdc/pull/3873#issuecomment-2606130424
@morozov I’ve conducted some research on this issue, and it’s quite a
complex one. I’ve added a commit with unit tests and also included additional
fixes to address the problem more
JunRuiLee merged PR #26025:
URL: https://github.com/apache/flink/pull/26025
--
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.apa
reswqa commented on PR #203:
URL: https://github.com/apache/flink-docker/pull/203#issuecomment-2606115460
I didn't learn about any plans for 1.20 to support jdk21, or maybe I missed
some discussion.
cc @snuyanzin as you've done most of the work for jdk21 support.
--
This is an auto
[
https://issues.apache.org/jira/browse/FLINK-36694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36694:
---
Labels: pull-request-available (was: )
> Update Hadoop shaded from 3.3.4 to 3.4.1
> ---
bbrandt opened a new pull request, #26046:
URL: https://github.com/apache/flink/pull/26046
## What is the purpose of the change
*Update Hadoop for filesystems to 3.4.1*
## Brief change log
- *Update Hadoop for filesystems to 3.4.1*
- *Update NOTICE with
[
https://issues.apache.org/jira/browse/FLINK-37191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17915872#comment-17915872
]
yux commented on FLINK-37191:
-
I'm investigating this.
> MySQL 'Compile and test' stage tim
sharath1709 commented on code in PR #929:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/929#discussion_r1924523474
##
flink-autoscaler-plugin-jdbc/src/test/java/org/apache/flink/autoscaler/jdbc/state/JobStateViewTest.java:
##
@@ -36,25 +35,18 @@
class JobStateV
sharath1709 commented on code in PR #929:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/929#discussion_r1924522639
##
flink-autoscaler-plugin-jdbc/src/test/java/org/apache/flink/autoscaler/jdbc/state/AbstractJdbcStateInteractorITCase.java:
##
@@ -42,32 +42,35 @@
sharath1709 commented on code in PR #929:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/929#discussion_r1924504228
##
flink-autoscaler-standalone/src/test/java/org/apache/flink/autoscaler/standalone/AutoscalerStateStoreFactoryTest.java:
##
@@ -67,14 +66,12 @@ vo
sharath1709 commented on code in PR #929:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/929#discussion_r1924504228
##
flink-autoscaler-standalone/src/test/java/org/apache/flink/autoscaler/standalone/AutoscalerStateStoreFactoryTest.java:
##
@@ -67,14 +66,12 @@ vo
sharath1709 commented on code in PR #929:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/929#discussion_r1924462678
##
flink-autoscaler-plugin-jdbc/src/test/java/org/apache/flink/autoscaler/jdbc/event/AbstractJdbcEventInteractorITCase.java:
##
@@ -46,63 +46,63 @@
afedulov commented on PR #25955:
URL: https://github.com/apache/flink/pull/25955#issuecomment-2605683151
@ferenc-csaky could you rerun the tests without reflection and unpooled, but
with a slightly increased off-heap memory? We probably need to just find the
sweet spot to account for the in
He-Pin commented on PR #25955:
URL: https://github.com/apache/flink/pull/25955#issuecomment-2605691065
I would like to see anyone run a test with pekko 1.2.0 nightly ... I think
then @pjfanning should be happy to get that pr in
--
This is an automated message from the Apache Git Service.
asardaes commented on PR #26043:
URL: https://github.com/apache/flink/pull/26043#issuecomment-2605438309
In my experience with Netty outside of Flink, running with the default
(`io.netty.maxDirectMemory = -1`) means that the value of
`-XX:MaxDirectMemorySize` will *not* be respected by Nett
flinkbot commented on PR #26045:
URL: https://github.com/apache/flink/pull/26045#issuecomment-2605426021
## CI report:
* b6dd278bb0d3cce33d8f5d163cd646adabbd0a3e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #26044:
URL: https://github.com/apache/flink/pull/26044#issuecomment-2605424499
## CI report:
* 5bf00e2dcc255c495000bc4500bab04095bce949 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-37193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luís Costa updated FLINK-37193:
---
Summary: [flink-operator] Ingress recreated after perform a change to CR
FlinkDeployment (was: [fli
[
https://issues.apache.org/jira/browse/FLINK-37193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luís Costa updated FLINK-37193:
---
Summary: [flink-operator] Ingress recreated after perform a change to CR
https://issues.apache.org/j
[
https://issues.apache.org/jira/browse/FLINK-37193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luís Costa updated FLINK-37193:
---
Summary: [flink-operator] Ingress recreated after perform a change to CR
(was: [flink-operator] Ing
[
https://issues.apache.org/jira/browse/FLINK-37193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luís Costa updated FLINK-37193:
---
Description:
Greetings team,
I'm using flink-operator v1.7.0.
After performed somes changes on CR F
[
https://issues.apache.org/jira/browse/FLINK-37193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luís Costa updated FLINK-37193:
---
Description:
Greetings team,
I'm using flink-operator v1.7.0.
After performed somes changes CRD fie
[
https://issues.apache.org/jira/browse/FLINK-37193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luís Costa updated FLINK-37193:
---
Summary: [flink-operator] Ingress recreated after perform a change to CRD
(was: Ingress recreated a
Luís Costa created FLINK-37193:
--
Summary: Ingress recreated after perform a change to CRD
Key: FLINK-37193
URL: https://issues.apache.org/jira/browse/FLINK-37193
Project: Flink
Issue Type: Impro
afedulov commented on PR #25955:
URL: https://github.com/apache/flink/pull/25955#issuecomment-2605284063
@ferenc-csaky thanks for the clarification. It sounds like the correct way
would be to find out what is the off-heap overhead induced by Netty 4 default
settings in RPC and bump that set
ferenc-csaky commented on PR #26043:
URL: https://github.com/apache/flink/pull/26043#issuecomment-2605213796
> I asked about this in the mailing list but I think it got lost. Isn't
`io.netty.maxDirectMemory` also important? Although that seems to only be
documented [in the source
code](htt
ferenc-csaky commented on PR #25955:
URL: https://github.com/apache/flink/pull/25955#issuecomment-2605094044
After I rethink it again, it should probably be not enabled here, because
the test should verify the `flink-runtime` shuffle memory allocation, which was
on Netty4 back in 2019 as we
[
https://issues.apache.org/jira/browse/FLINK-37147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-37147:
--
Fix Version/s: 1.19.3
1.20.2
(was: 1.19.2)
juntaozhang commented on code in PR #25218:
URL: https://github.com/apache/flink/pull/25218#discussion_r1923953573
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/allocator/DefaultSlotAssignerTest.java:
##
@@ -0,0 +1,115 @@
+/*
+ * Licensed to the Apac
He-Pin commented on PR #25955:
URL: https://github.com/apache/flink/pull/25955#issuecomment-2605055844
I think the `unpooled` will affect other places of Flink
--
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
1 - 100 of 194 matches
Mail list logo
