Matthias Pohl created FLINK-34224:
-
Summary:
ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest
timed out
Key: FLINK-34224
URL: https://issues.apache.org/jira/browse/FLINK-34224
mayuehappy commented on PR #24173:
URL: https://github.com/apache/flink/pull/24173#issuecomment-1907582420
@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
[
https://issues.apache.org/jira/browse/FLINK-33186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810247#comment-17810247
]
Matthias Pohl commented on FLINK-33186:
---
https://github.com/XComp/flink/actions/ru
mbalassi commented on code in PR #24065:
URL: https://github.com/apache/flink/pull/24065#discussion_r1464456656
##
docs/content.zh/docs/deployment/resource-providers/native_kubernetes.md:
##
@@ -97,14 +97,34 @@ COPY /path/of/my-flink-job.jar
$FLINK_HOME/usrlib/my-flink-job.jar
XComp commented on PR #24132:
URL: https://github.com/apache/flink/pull/24132#issuecomment-1907572028
[ci
failure](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=56790)
is caused by some infrastructure instability in the compile step of the
c
XComp commented on PR #24132:
URL: https://github.com/apache/flink/pull/24132#issuecomment-1907572233
@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.
To
mayuehappy commented on PR #24173:
URL: https://github.com/apache/flink/pull/24173#issuecomment-1907564710
@masteryhx
I found some unit tests failed after change.
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=56811&view=logs&j=0da23115-68bb-5dcd-192c-bd4c8adebd
[
https://issues.apache.org/jira/browse/FLINK-34195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34195:
--
Labels: starter (was: )
> PythonEnvUtils creates python environment instead of python3
>
[
https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810241#comment-17810241
]
Matthias Pohl commented on FLINK-31472:
---
Sure, if we are certain that this is a te
[
https://issues.apache.org/jira/browse/FLINK-34155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810238#comment-17810238
]
Matthias Pohl commented on FLINK-34155:
---
How big is the mvn.log? I'm wondering whe
[
https://issues.apache.org/jira/browse/FLINK-34155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34155:
--
Labels: test-stability (was: test)
> Recurring SqlExecutionException
> --
[
https://issues.apache.org/jira/browse/FLINK-33760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-33760:
-
Assignee: Yunhong Zheng
> Group Window agg has different result when only consuming -D
[
https://issues.apache.org/jira/browse/FLINK-33760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810232#comment-17810232
]
Yunhong Zheng commented on FLINK-33760:
---
[~xuyangzhong] It looks like a bug, I w
flinkbot commented on PR #24186:
URL: https://github.com/apache/flink/pull/24186#issuecomment-1907491277
## CI report:
* cf88c4b65ae73600d8efb25d6273a7ea16ae5b2d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gyfora commented on code in PR #755:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/755#discussion_r1464380455
##
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/reconciler/ReconciliationMetadata.java:
##
@@ -42,6 +42,7 @@ pub
flinkbot commented on PR #24185:
URL: https://github.com/apache/flink/pull/24185#issuecomment-1907481027
## CI report:
* 19b6b48ebe252e29200838665e6bbc42583d5f98 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34145:
---
Labels: pull-request-available (was: )
> File source connector support dynamic source paral
SinBex opened a new pull request, #24186:
URL: https://github.com/apache/flink/pull/24186
## What is the purpose of the change
*[FLIP-379](https://cwiki.apache.org/confluence/display/FLINK/FLIP-379%3A+Dynamic+source+parallelism+inference+for+batch+jobs)
has introduced support for dyn
[
https://issues.apache.org/jira/browse/FLINK-34223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34223:
---
Labels: pull-request-available (was: )
> Introduce a migration tool to transfer legacy conf
JunRuiLee opened a new pull request, #24185:
URL: https://github.com/apache/flink/pull/24185
## What is the purpose of the change
As we transition to new configuration files that adhere to the standard YAML
format, users are expected to manually migrate their existing
Junrui Li created FLINK-34223:
-
Summary: Introduce a migration tool to transfer legacy config file
to new config file
Key: FLINK-34223
URL: https://issues.apache.org/jira/browse/FLINK-34223
Project: Flink
Shuai Xu created FLINK-34222:
Summary: Get minibatch join operator involved
Key: FLINK-34222
URL: https://issues.apache.org/jira/browse/FLINK-34222
Project: Flink
Issue Type: Sub-task
C
Shuai Xu created FLINK-34221:
Summary: Introduce operator for minibatch join
Key: FLINK-34221
URL: https://issues.apache.org/jira/browse/FLINK-34221
Project: Flink
Issue Type: Sub-task
Shuai Xu created FLINK-34220:
Summary: introduce buffer bundle for minibatch join
Key: FLINK-34220
URL: https://issues.apache.org/jira/browse/FLINK-34220
Project: Flink
Issue Type: Sub-task
Shuai Xu created FLINK-34219:
Summary: Introduce a new join operator to support minibatch
Key: FLINK-34219
URL: https://issues.apache.org/jira/browse/FLINK-34219
Project: Flink
Issue Type: New Fe
[
https://issues.apache.org/jira/browse/FLINK-34205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-34205.
---
Fix Version/s: 1.19.0
Resolution: Done
dev-master:
44f058287cc956a620b12b6f8ed214e44dc3db77
> Update
[
https://issues.apache.org/jira/browse/FLINK-34205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-34205:
---
Assignee: Junrui Li
> Update flink-docker's Dockerfile and docker-entrypoint.sh to use
> BashJavaU
zhuzhurk merged PR #175:
URL: https://github.com/apache/flink-docker/pull/175
--
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
mayuehappy commented on PR #24173:
URL: https://github.com/apache/flink/pull/24173#issuecomment-1907411370
@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 com
fsk119 commented on code in PR #24106:
URL: https://github.com/apache/flink/pull/24106#discussion_r1464215746
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/annotation/ProcedureHint.java:
##
@@ -139,6 +139,18 @@
*/
String[] argumentNames() defa
xuyangzhong commented on PR #23505:
URL: https://github.com/apache/flink/pull/23505#issuecomment-1907407611
@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 commen
[
https://issues.apache.org/jira/browse/FLINK-34174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810199#comment-17810199
]
Rui Fan commented on FLINK-34174:
-
Merged to master(1.19.0) via : 551bb9ebdc484a41951bb3
[
https://issues.apache.org/jira/browse/FLINK-34174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-34174.
-
Fix Version/s: 1.19.0
Resolution: Fixed
> Remove SlotMatchingStrategy related logic
> ---
1996fanrui merged PR #24158:
URL: https://github.com/apache/flink/pull/24158
--
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
1996fanrui commented on PR #24158:
URL: https://github.com/apache/flink/pull/24158#issuecomment-1907376784
No any comments for 2 days, merging~
--
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-33865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-33865.
-
Fix Version/s: 1.19.0
Resolution: Fixed
> exponential-delay.attempts-before-reset-backoff doesn't
[
https://issues.apache.org/jira/browse/FLINK-33865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810198#comment-17810198
]
Rui Fan commented on FLINK-33865:
-
Merged to master(1.19.0) via:
* 393ef1cc43942ee4652e2
1996fanrui merged PR #23942:
URL: https://github.com/apache/flink/pull/23942
--
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
1996fanrui commented on PR #23942:
URL: https://github.com/apache/flink/pull/23942#issuecomment-1907374215
Thanks @RocMarshal for the review!
> Thanks @1996fanrui for the contribution, But the CI failed. could you
check it? LGTM +1.
I checked it, and it's not related to this PR
[
https://issues.apache.org/jira/browse/FLINK-34218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810197#comment-17810197
]
Rui Fan commented on FLINK-34218:
-
I run it in my local more than 30 times, all of them
JunRuiLee commented on PR #24177:
URL: https://github.com/apache/flink/pull/24177#issuecomment-1907348848
Hi @HuangXingBo , this pr includes some PyFlink changes related to the
adoption of a new configuration file, config.yaml. Could you please help review
it?
--
This is an automated mes
[
https://issues.apache.org/jira/browse/FLINK-33233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810188#comment-17810188
]
luoyuxia commented on FLINK-33233:
--
1.17:
https://github.com/apache/flink/commit/44a69
[
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.17.3
1.18.2
Resolution: Fixed
> Null point exception when n
[
https://issues.apache.org/jira/browse/FLINK-34218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810189#comment-17810189
]
Rui Fan commented on FLINK-34218:
-
Hi [~srichter], AutoRescalingITCase#testCheckpointRes
luoyuxia merged PR #24149:
URL: https://github.com/apache/flink/pull/24149
--
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
luoyuxia merged PR #24148:
URL: https://github.com/apache/flink/pull/24148
--
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-31090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-31090:
-
Fix Version/s: 1.18.0
> Flink SQL fail to select INTERVAL
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-31090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia closed FLINK-31090.
Resolution: Fixed
> Flink SQL fail to select INTERVAL
> --
>
>
Rui Fan created FLINK-34218:
---
Summary: AutoRescalingITCase#testCheckpointRescalingInKeyedState
fails
Key: FLINK-34218
URL: https://issues.apache.org/jira/browse/FLINK-34218
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-31409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810187#comment-17810187
]
luoyuxia commented on FLINK-31409:
--
[~libenchao] Thanks for reminder.
> Hive dialect s
[
https://issues.apache.org/jira/browse/FLINK-31409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-31409.
--
Fix Version/s: 1.18.0
Resolution: Fixed
> Hive dialect should use public interfaces in Hive con
[
https://issues.apache.org/jira/browse/FLINK-31409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia reopened FLINK-31409:
--
> Hive dialect should use public interfaces in Hive connector
> --
flinkbot commented on PR #24184:
URL: https://github.com/apache/flink/pull/24184#issuecomment-1907311524
## CI report:
* e807815c4ced6ae83dec3c251833a3d4586868cb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
xishuaidelin commented on PR #24159:
URL: https://github.com/apache/flink/pull/24159#issuecomment-1907309476
@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 comme
[
https://issues.apache.org/jira/browse/FLINK-34144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34144:
---
Labels: pull-request-available (was: )
> Update the documentation and configuration descrip
SinBex opened a new pull request, #24184:
URL: https://github.com/apache/flink/pull/24184
## What is the purpose of the change
*[FLIP-379](https://cwiki.apache.org/confluence/display/FLINK/FLIP-379%3A+Dynamic+source+parallelism+inference+for+batch+jobs#FLIP379:Dynamicsourceparallelism
[
https://issues.apache.org/jira/browse/FLINK-31409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810185#comment-17810185
]
Benchao Li commented on FLINK-31409:
[~luoyuxia] Could you fill the fixVersion of th
1996fanrui commented on PR #23942:
URL: https://github.com/apache/flink/pull/23942#issuecomment-1907277744
@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
yunfan123 commented on PR #24104:
URL: https://github.com/apache/flink/pull/24104#issuecomment-1907264935
@LB-Yu Hello. Thanks for your comment. I have resolved the issue in the
latest commit and supplemented it with additional unit tests
--
This is an automated message from the Apache Gi
[
https://issues.apache.org/jira/browse/FLINK-33198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-33198.
Resolution: Implemented
Implemented in master(1.19): 533ead6ae946cbc77525d276b6dea965d390181a
> A
[
https://issues.apache.org/jira/browse/FLINK-33198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-33198:
---
Priority: Major (was: Minor)
> Add timestamp with local time zone support in Avro converters
>
leonardBang merged PR #23511:
URL: https://github.com/apache/flink/pull/23511
--
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
wanglijie95 commented on code in PR #24118:
URL: https://github.com/apache/flink/pull/24118#discussion_r1464226470
##
docs/content/docs/deployment/elastic_scaling.md:
##
@@ -238,7 +238,7 @@ In addition, there are several related configuration
options that may need adjus
### Li
libenchao commented on code in PR #24128:
URL: https://github.com/apache/flink/pull/24128#discussion_r1464205544
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/SourceTransformationWrapper.java:
##
@@ -0,0 +1,72 @@
+/*
+Licensed to the Apache
xuyangzhong commented on code in PR #23505:
URL: https://github.com/apache/flink/pull/23505#discussion_r1464224820
##
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/agg/WindowAggregateTest.xml:
##
@@ -2614,6 +2614,66 @@ Calc(sel
Zakelly commented on PR #24181:
URL: https://github.com/apache/flink/pull/24181#issuecomment-1907248389
@fredia @masteryhx Would you please take a look? Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-34143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-34143.
---
Fix Version/s: 1.19.0
Resolution: Done
master/release-1.19:
97caa3c251e416640a6f54ea103912839c346f70
zhuzhurk closed pull request #24170: [FLINK-34143] Modify the effective
strategy of
`execution.batch.adaptive.auto-parallelism.default-source-parallelism`
URL: https://github.com/apache/flink/pull/24170
--
This is an automated message from the Apache Git Service.
To respond to the message, p
JunRuiLee commented on code in PR #24118:
URL: https://github.com/apache/flink/pull/24118#discussion_r1464218412
##
docs/content/docs/deployment/elastic_scaling.md:
##
@@ -238,7 +238,7 @@ In addition, there are several related configuration
options that may need adjus
### Limi
wanglijie95 commented on code in PR #24118:
URL: https://github.com/apache/flink/pull/24118#discussion_r1464214787
##
docs/content/docs/deployment/elastic_scaling.md:
##
@@ -238,7 +238,7 @@ In addition, there are several related configuration
options that may need adjus
### Li
flinkbot commented on PR #24183:
URL: https://github.com/apache/flink/pull/24183#issuecomment-1907229799
## CI report:
* 0d402864671fb4dc34f036fc44b71252f66d63db UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
hackergin opened a new pull request, #24183:
URL: https://github.com/apache/flink/pull/24183
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them
masteryhx commented on PR #24173:
URL: https://github.com/apache/flink/pull/24173#issuecomment-1907224952
@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.
X-czh commented on PR #24182:
URL: https://github.com/apache/flink/pull/24182#issuecomment-1907215961
@reswqa Could you help review it? Thx~
--
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 sp
LadyForest commented on PR #24178:
URL: https://github.com/apache/flink/pull/24178#issuecomment-1907215660
@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 commented on code in PR #24106:
URL: https://github.com/apache/flink/pull/24106#discussion_r1464193652
##
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/extraction/TypeInferenceExtractorTest.java:
##
@@ -427,8 +428,7 @@ private static Stream
[
https://issues.apache.org/jira/browse/FLINK-33958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810141#comment-17810141
]
Bonnie Varghese commented on FLINK-33958:
-
Apologize for the delayed response. I
[
https://issues.apache.org/jira/browse/FLINK-34135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810104#comment-17810104
]
Jeyhun Karimov commented on FLINK-34135:
Hi [~mapohl] yes CI seems stable again,
[
https://issues.apache.org/jira/browse/FLINK-34135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov closed FLINK-34135.
--
Resolution: Fixed
> A number of ci failures with Access to the path
> '.../_work/_temp/contai
[
https://issues.apache.org/jira/browse/FLINK-34098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov closed FLINK-34098.
--
Resolution: Fixed
It was a disk-full issue. I reported the recurring error (that leads to the
justin-chen commented on code in PR #755:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/755#discussion_r1463969344
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/ReconciliationUtils.java:
##
@@ -126,6 +126,9 @@ private
hhktseng commented on PR #70:
URL:
https://github.com/apache/flink-connector-kafka/pull/70#issuecomment-1906723207
created patch and applied after syncing to latest commit, then replaced
forked branch with latest sync + patch
--
This is an automated message from the Apache Git Service.
T
HuangZhenQiu commented on PR #23511:
URL: https://github.com/apache/flink/pull/23511#issuecomment-1906612609
@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 c
HuangZhenQiu commented on PR #23511:
URL: https://github.com/apache/flink/pull/23511#issuecomment-1906611710
Hit a code style issue which is fixed in the latest master. Rebase master
again.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/FLINK-34135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810041#comment-17810041
]
Matthias Pohl commented on FLINK-34135:
---
[~jeyhunkarimov] can't we close this issu
[
https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810038#comment-17810038
]
Matthias Pohl commented on FLINK-34007:
---
Just checking whether a new instance of \
flinkbot commented on PR #24182:
URL: https://github.com/apache/flink/pull/24182#issuecomment-1906494842
## CI report:
* db0ed2d1e4f59006cb2f6ef491d143390a5504a9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Zhanghao Chen created FLINK-34217:
-
Summary: Update Serialization-related doc with the new way of
configuration
Key: FLINK-34217
URL: https://issues.apache.org/jira/browse/FLINK-34217
Project: Flink
X-czh commented on code in PR #24182:
URL: https://github.com/apache/flink/pull/24182#discussion_r1463601347
##
flink-core/src/main/java/org/apache/flink/api/common/serialization/SerializerConfig.java:
##
@@ -229,8 +233,9 @@ public LinkedHashSet> getRegisteredPojoTypes() {
X-czh commented on code in PR #24182:
URL: https://github.com/apache/flink/pull/24182#discussion_r1463599214
##
flink-core/src/main/java/org/apache/flink/api/common/serialization/SerializerConfig.java:
##
@@ -229,8 +233,9 @@ public LinkedHashSet> getRegisteredPojoTypes() {
X-czh commented on code in PR #24182:
URL: https://github.com/apache/flink/pull/24182#discussion_r1463599214
##
flink-core/src/main/java/org/apache/flink/api/common/serialization/SerializerConfig.java:
##
@@ -229,8 +233,9 @@ public LinkedHashSet> getRegisteredPojoTypes() {
[
https://issues.apache.org/jira/browse/FLINK-34120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34120:
---
Labels: pull-request-available (was: )
> Introduce unified serialization config option for
X-czh opened a new pull request, #24182:
URL: https://github.com/apache/flink/pull/24182
## What is the purpose of the change
Introduce unified serialization config option for all Kryo, POJO and
customized serializers for parameterized serialization config based on pure
confi
Zakelly commented on PR #24169:
URL: https://github.com/apache/flink/pull/24169#issuecomment-1906452618
@masteryhx Thanks for your detailed review! I modified accordingly, PTAL.
Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
flinkbot commented on PR #24181:
URL: https://github.com/apache/flink/pull/24181#issuecomment-1906438459
## CI report:
* a1c23d06eae81a4811f7b253a5b6a91609d24502 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32075:
---
Labels: pull-request-available (was: )
> Delete merged files on checkpoint abort or subsump
Zakelly opened a new pull request, #24181:
URL: https://github.com/apache/flink/pull/24181
## What is the purpose of the change
As important part of the FLIP-306, this PR enables the file deletion on
checkpoint abort or subsumption.
## Brief change log
- Track all logi
flinkbot commented on PR #24180:
URL: https://github.com/apache/flink/pull/24180#issuecomment-1906396145
## CI report:
* 568fa38ead32fd9757def6e462eb4e6680a5feaf UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
mxm commented on code in PR #757:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/757#discussion_r1463522323
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/event/AutoscalerEventUtils.java:
##
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache Software
pvary opened a new pull request, #24180:
URL: https://github.com/apache/flink/pull/24180
## What is the purpose of the change
Currently `FileSink` uses `TwoPhaseCommittingSink` and `StatefulSink` from
the SinkV2 API. We should migrate it to use the new FLIP-372 SinkV2 API.
Ther
1 - 100 of 246 matches
Mail list logo
