[
https://issues.apache.org/jira/browse/FLINK-35026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei updated FLINK-35026:
---
Component/s: Runtime / Configuration
Runtime / Task
> Introduce async-state
[
https://issues.apache.org/jira/browse/FLINK-35010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834610#comment-17834610
]
Zhongqiang Gong commented on FLINK-35010:
-
+1 , It's better to bump commons-compress version to
[
https://issues.apache.org/jira/browse/FLINK-24939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-24939:
-
Summary: Complete 'SHOW CREATE CATALOG' syntax (was: Support 'SHOW CREATE
CATALOG' syntax)
> Complete
Yanfei Lei created FLINK-35031:
--
Summary: Event timer firing under async execution model
Key: FLINK-35031
URL: https://issues.apache.org/jira/browse/FLINK-35031
Project: Flink
Issue Type:
1996fanrui commented on code in PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1554829325
##
docs/content.zh/docs/concepts/architecture.md:
##
@@ -24,57 +24,65 @@ specific language governing permissions and limitations
under the
[
https://issues.apache.org/jira/browse/FLINK-35034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yufeng.sun updated FLINK-35034:
---
Attachment: flinksql.txt
logfile.txt
protofile.txt
> codegen
yuanfenghu created FLINK-35035:
--
Summary: Reduce job pause time when cluster resources are expanded
in adaptive mode
Key: FLINK-35035
URL: https://issues.apache.org/jira/browse/FLINK-35035
Project:
1996fanrui commented on PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#issuecomment-2041350690
Also, it's better to update the PR description. We can update these items or
remove them if you think they are unneeded, thanks~
--
This is an automated message
Fly365 created FLINK-35036:
--
Summary: Flink CDC Job cancel with savepoint failed
Key: FLINK-35036
URL: https://issues.apache.org/jira/browse/FLINK-35036
Project: Flink
Issue Type: Bug
Yanfei Lei created FLINK-35028:
--
Summary: Processing timer firing under async execution model
Key: FLINK-35028
URL: https://issues.apache.org/jira/browse/FLINK-35028
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-35026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei updated FLINK-35026:
---
Summary: Introduce async execution configurations (was: Introduce
async-state configurations)
>
[
https://issues.apache.org/jira/browse/FLINK-32070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834636#comment-17834636
]
xiaogang zhou commented on FLINK-32070:
---
[~Zakelly] yes, sounds good, Let me take a look
>
Yanfei Lei created FLINK-35029:
--
Summary: Store timer in JVM heap when async execution enabled
Key: FLINK-35029
URL: https://issues.apache.org/jira/browse/FLINK-35029
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-35034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yufeng.sun updated FLINK-35034:
---
Description:
The following error messages and stack were encountered When i using Flink SQL
with
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-35035:
---
Description:
When 'jobmanager.scheduler = adaptive' , job graph changes triggered by cluster
PatrickRen commented on code in PR #3204:
URL: https://github.com/apache/flink-cdc/pull/3204#discussion_r1554855153
##
slfan1989 commented on PR #24601:
URL: https://github.com/apache/flink/pull/24601#issuecomment-2041389025
@1996fanrui Thank you very much for reviewing the code!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
loserwang1024 commented on code in PR #3204:
URL: https://github.com/apache/flink-cdc/pull/3204#discussion_r1554863395
##
[
https://issues.apache.org/jira/browse/FLINK-34915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-34915:
-
Summary: Complete `DESCRIBE CATALOG` syntax (was: Support `DESCRIBE
CATALOG` syntax)
> Complete
[
https://issues.apache.org/jira/browse/FLINK-24939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-24939:
-
Summary: Support 'SHOW CREATE CATALOG' syntax (was: Complete 'SHOW CREATE
CATALOG' syntax)
> Support
[
https://issues.apache.org/jira/browse/FLINK-32070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834620#comment-17834620
]
Zakelly Lan commented on FLINK-32070:
-
[~zhoujira86] The checkpointing part (without restoration
yuxiqian commented on code in PR #2916:
URL: https://github.com/apache/flink-cdc/pull/2916#discussion_r1549282669
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonDataSinkFactory.java:
[
https://issues.apache.org/jira/browse/FLINK-35034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yufeng.sun updated FLINK-35034:
---
Description:
The following error messages and stack were encountered When i using Flink SQL
with
lincoln-lil merged PR #24594:
URL: https://github.com/apache/flink/pull/24594
--
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:
[
https://issues.apache.org/jira/browse/FLINK-35023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834639#comment-17834639
]
Weijie Guo commented on FLINK-35023:
[
https://issues.apache.org/jira/browse/FLINK-35023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834639#comment-17834639
]
Weijie Guo edited comment on FLINK-35023 at 4/7/24 9:24 AM:
jdk17:
[
https://issues.apache.org/jira/browse/FLINK-32070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834609#comment-17834609
]
xiaogang zhou edited comment on FLINK-32070 at 4/7/24 6:36 AM:
---
Is there
1996fanrui commented on code in PR #811:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/811#discussion_r1554828200
##
flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone/StandaloneAutoscalerEntrypoint.java:
##
@@ -60,9 +60,11 @@
Yanfei Lei created FLINK-35030:
--
Summary: Introduce Epoch Manager for watermark under async
execution
Key: FLINK-35030
URL: https://issues.apache.org/jira/browse/FLINK-35030
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yufeng.sun updated FLINK-35034:
---
Description:
The following error messages and stack were encountered When i using Flink SQL
with
yufeng.sun created FLINK-35034:
--
Summary: codegen compile error raised when use kafka connector and
protobuf format
Key: FLINK-35034
URL: https://issues.apache.org/jira/browse/FLINK-35034
Project: Flink
ruanhang1993 commented on code in PR #3134:
URL: https://github.com/apache/flink-cdc/pull/3134#discussion_r1554839652
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/enumerator/IncrementalSourceEnumerator.java:
[
https://issues.apache.org/jira/browse/FLINK-34712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834634#comment-17834634
]
lincoln lee commented on FLINK-34712:
-
fixed in 1.19: 4397c9f1d0f300bd8c0f9de4e59e1a5d7883ec2c
>
PatrickRen merged PR #3200:
URL: https://github.com/apache/flink-cdc/pull/3200
--
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:
[
https://issues.apache.org/jira/browse/FLINK-34959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834638#comment-17834638
]
Qingsheng Ren commented on FLINK-34959:
---
cdc-master: 6510e670faa154d619937d97dc3f146eb162fac2
>
[
https://issues.apache.org/jira/browse/FLINK-34959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren resolved FLINK-34959.
---
Resolution: Fixed
> Update old flink-cdc-connectors artifactId
>
PatrickRen commented on code in PR #3083:
URL: https://github.com/apache/flink-cdc/pull/3083#discussion_r1554857536
##
pom.xml:
##
@@ -462,8 +462,15 @@ under the License.
submodules, ${flink.version} will be
resolved as the actual Flink
Yanfei Lei created FLINK-35027:
--
Summary: Implement checkpoint drain in AsyncExecutionController
Key: FLINK-35027
URL: https://issues.apache.org/jira/browse/FLINK-35027
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-34995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834629#comment-17834629
]
yansuopeng commented on FLINK-34995:
https://github.com/apache/flink-connector-kafka/pull/91
>
[
https://issues.apache.org/jira/browse/FLINK-35027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei updated FLINK-35027:
---
Component/s: Runtime / Checkpointing
> Implement checkpoint drain in AsyncExecutionController
>
[
https://issues.apache.org/jira/browse/FLINK-35025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei updated FLINK-35025:
---
Component/s: Runtime / Task
> Wire AsyncExecutionController to AbstractStreamOperator
>
yuxiqian commented on code in PR #2916:
URL: https://github.com/apache/flink-cdc/pull/2916#discussion_r1549225693
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonWriter.java:
Zakelly opened a new pull request, #24629:
URL: https://github.com/apache/flink/pull/24629
## What is the purpose of the change
Currently, when re-generating docs on master branch, the
`rpc_configuration.html` is generated. The `AkkaOptions` is renamed to
`RpcOptions` via
yuxiqian commented on PR #3207:
URL: https://github.com/apache/flink-cdc/pull/3207#issuecomment-2041372727
I wonder if changing `DorisEventSerializer.DATE_TIME_FORMATTER` to
`-MM-dd HH:mm:ss.SS` would fix this problem, too?
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-32070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834609#comment-17834609
]
xiaogang zhou commented on FLINK-32070:
---
Is there any Branch I can view do a POC? And I think if
[
https://issues.apache.org/jira/browse/FLINK-35006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-35006:
---
Assignee: Kirill Plugatarev
> Use try with-resource for StandaloneAutoscalerExecutor
>
yuxiqian commented on code in PR #2916:
URL: https://github.com/apache/flink-cdc/pull/2916#discussion_r1554819937
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonWriterHelper.java:
boring-cyborg[bot] commented on PR #91:
URL:
https://github.com/apache/flink-connector-kafka/pull/91#issuecomment-2041355545
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
[
https://issues.apache.org/jira/browse/FLINK-34995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34995:
---
Labels: pull-request-available (was: )
> flink kafka connector source stuck when partition
yanspirit opened a new pull request, #91:
URL: https://github.com/apache/flink-connector-kafka/pull/91
when partition leader invalid(leader=-1), the flink streaming job using
KafkaSource can't restart or start a new instance with a new groupid, it will
stuck and got following exception:
[
https://issues.apache.org/jira/browse/FLINK-34712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-34712.
---
Resolution: Fixed
> Update reference data for Migration Tests
>
[
https://issues.apache.org/jira/browse/FLINK-34712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834634#comment-17834634
]
lincoln lee edited comment on FLINK-34712 at 4/7/24 8:53 AM:
-
fixed in 1.19:
[
https://issues.apache.org/jira/browse/FLINK-34959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-34959:
-
Assignee: xleoken
> Update old flink-cdc-connectors artifactId
>
[
https://issues.apache.org/jira/browse/FLINK-35034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yufeng.sun updated FLINK-35034:
---
Description:
The following error messages and stack were encountered When i using Flink SQL
with
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-35035:
---
Description:
When 'jobmanager.scheduler = adaptive' , job graph changes triggered by cluster
flinkbot commented on PR #24629:
URL: https://github.com/apache/flink/pull/24629#issuecomment-2041363992
## CI report:
* 1eeedee02ccdb674b5b2598bec8531e8eac49bf9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
lincoln-lil merged PR #24517:
URL: https://github.com/apache/flink/pull/24517
--
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:
liuyongvs commented on PR #24526:
URL: https://github.com/apache/flink/pull/24526#issuecomment-2041370638
hi @MartijnVisser
--
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.
liyubin117 opened a new pull request, #24630:
URL: https://github.com/apache/flink/pull/24630
## What is the purpose of the change
Describe the metadata of an existing catalog. The metadata information
includes the catalog’s name, type, and comment. If the optional EXTENDED option
[
https://issues.apache.org/jira/browse/FLINK-34915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-34915:
-
Attachment: image-2024-04-07-17-54-51-203.png
Description:
Describe the metadata of an existing
[
https://issues.apache.org/jira/browse/FLINK-35037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yisha zhou updated FLINK-35037:
---
Description:
In current Implementation, relNodes with Window type will only deliver
upsert/unique
liyubin117 commented on PR #24630:
URL: https://github.com/apache/flink/pull/24630#issuecomment-2041527525
@LadyForest Hi, CI passed now, Looking forward your review, Thanks very much
:)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
yisha zhou created FLINK-35037:
--
Summary: Optimize uniqueKeys and upsertKeys inference of windows
with ROW_NUMBER
Key: FLINK-35037
URL: https://issues.apache.org/jira/browse/FLINK-35037
Project: Flink
ljz2051 commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1554960979
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/StateRequest.java:
##
@@ -0,0 +1,99 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
Ufuk Celebi created FLINK-35038:
---
Summary: Bump test dependency org.yaml:snakeyaml to 2.2
Key: FLINK-35038
URL: https://issues.apache.org/jira/browse/FLINK-35038
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-34915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34915:
---
Labels: pull-request-available (was: )
> Complete `DESCRIBE CATALOG` syntax
>
flinkbot commented on PR #24630:
URL: https://github.com/apache/flink/pull/24630#issuecomment-2041394595
## CI report:
* a1146244ce8a490c2ca1557f4c2410b59effb333 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
fredia commented on PR #22973:
URL: https://github.com/apache/flink/pull/22973#issuecomment-2041450107
@Zakelly I have rebased this PR, could you please take a look if you're
free? thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/FLINK-34955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834678#comment-17834678
]
Zhongqiang Gong commented on FLINK-34955:
-
[~slfan1989] [~mbalassi] According to
[
https://issues.apache.org/jira/browse/FLINK-34955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834681#comment-17834681
]
Shilun Fan commented on FLINK-34955:
[~gongzhongqiang] From my personal perspective, I believe
[
https://issues.apache.org/jira/browse/FLINK-34955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834682#comment-17834682
]
Shilun Fan edited comment on FLINK-34955 at 4/7/24 2:17 PM:
liyubin117 commented on PR #24630:
URL: https://github.com/apache/flink/pull/24630#issuecomment-2041411609
@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
PatrickRen commented on code in PR #3194:
URL: https://github.com/apache/flink-cdc/pull/3194#discussion_r1554892220
##
flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/utils/FlinkEnvironmentUtils.java:
##
@@ -20,18 +20,33 @@
import
[
https://issues.apache.org/jira/browse/FLINK-35037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yisha zhou updated FLINK-35037:
---
Description:
In current Implementation, relNodes with Window type will only deliver
upsert/unique
[
https://issues.apache.org/jira/browse/FLINK-34955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834682#comment-17834682
]
Shilun Fan commented on FLINK-34955:
[~gongzhongqiang] Of course, if upgrading is possible, it would
[
https://issues.apache.org/jira/browse/FLINK-34898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834685#comment-17834685
]
Feng Jin commented on FLINK-34898:
--
[~chloehe] Thank you for the update, sorry for the late reply.
gong commented on PR #3207:
URL: https://github.com/apache/flink-cdc/pull/3207#issuecomment-2041406982
> I wonder if changing `DorisEventSerializer.DATE_TIME_FORMATTER` to
`-MM-dd HH:mm:ss.SS` fixes this problem, too?
@yuxiqian I think that it can fix this problem, too.
--
GOODBOY008 commented on PR #32:
URL:
https://github.com/apache/flink-connector-mongodb/pull/32#issuecomment-2041478551
@Jiabao-Sun PR updated and version to `1.26.1`.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/FLINK-34898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Feng Jin updated FLINK-34898:
-
Attachment: 截屏2024-04-07 22.05.40.png
> Cannot create ARRAY of named STRUCTs
>
Zakelly commented on PR #24629:
URL: https://github.com/apache/flink/pull/24629#issuecomment-2041409660
@XComp Would you please take a look?
--
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
Zakelly commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1554965456
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/StateRequest.java:
##
@@ -0,0 +1,99 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
plugatarev commented on code in PR #811:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/811#discussion_r1555135563
##
flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone/StandaloneAutoscalerEntrypoint.java:
##
@@ -60,9 +60,11 @@
[
https://issues.apache.org/jira/browse/FLINK-34573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-34573.
--
Resolution: Won't Fix
> the task is stuck on the high presure
> -
[
https://issues.apache.org/jira/browse/FLINK-35036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834749#comment-17834749
]
Biao Geng commented on FLINK-35036:
---
Hi [~fly365], according to the attached screenshot, the failure
morazow commented on PR #24426:
URL: https://github.com/apache/flink/pull/24426#issuecomment-2041795538
Thanks @XComp, I am going to address your suggestions. Please have a look
once you are back
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-35040:
Description:
The performance of serializerHeavyString regresses since April 3, and had not
yet recovered
plugatarev closed pull request #811: [FLINK-35006] Use try with-resource for
StandaloneAutoscalerExecutor
URL: https://github.com/apache/flink-kubernetes-operator/pull/811
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/FLINK-35006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirill Plugatarev closed FLINK-35006.
-
Resolution: Not A Problem
> Use try with-resource for StandaloneAutoscalerExecutor
>
reswqa merged PR #24627:
URL: https://github.com/apache/flink/pull/24627
--
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:
[
https://issues.apache.org/jira/browse/FLINK-35009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834751#comment-17834751
]
Weijie Guo commented on FLINK-35009:
This change can be done in a compatible way. But one could
[
https://issues.apache.org/jira/browse/FLINK-35009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834751#comment-17834751
]
Weijie Guo edited comment on FLINK-35009 at 4/8/24 2:13 AM:
This change can
zhuzhurk closed pull request #24415: [FLINK-33984][runtime] Support batch
snapshot for OperatorCoordinator.
URL: https://github.com/apache/flink/pull/24415
--
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
[
https://issues.apache.org/jira/browse/FLINK-35039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834758#comment-17834758
]
ude commented on FLINK-35039:
-
[~Yu Chen] Please have a look, If my modification plan is fine,
morazow commented on code in PR #24426:
URL: https://github.com/apache/flink/pull/24426#discussion_r1555166750
##
.github/workflows/template.python-wheels-ci.yml:
##
@@ -0,0 +1,67 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license
[
https://issues.apache.org/jira/browse/FLINK-33934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834765#comment-17834765
]
Yun Tang commented on FLINK-33934:
--
I think it's easy to let data lost when using {{raw}} format with
[
https://issues.apache.org/jira/browse/FLINK-34966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834756#comment-17834756
]
Qingsheng Ren commented on FLINK-34966:
---
[~wanghe] Could you provide some context in the
ude created FLINK-35039:
---
Summary: Create Profiling JobManager/TaskManager Instance failed
Key: FLINK-35039
URL: https://issues.apache.org/jira/browse/FLINK-35039
Project: Flink
Issue Type:
fredia commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1555208732
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/StateRequest.java:
##
@@ -0,0 +1,99 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
[
https://issues.apache.org/jira/browse/FLINK-33986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-33986:
---
Assignee: Junrui Li
> Extend shuffleMaster to support batch snapshot.
>
[
https://issues.apache.org/jira/browse/FLINK-35036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834755#comment-17834755
]
Qingsheng Ren commented on FLINK-35036:
---
[~fly365] Thanks for reporting the issue! I agree with
1 - 100 of 133 matches
Mail list logo
