Jiabao-Sun commented on PR #3134:
URL: https://github.com/apache/flink-cdc/pull/3134#issuecomment-2029270957
@loserwang1024 Please correct me if I'm wrong.
In PR-2292, only unnecessary finished snapshot splits were removed from
`BinlogSplit`, which means the checkpoint is already in the
Zakelly commented on code in PR #24480:
URL: https://github.com/apache/flink/pull/24480#discussion_r1546024980
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV2V3SerializerBase.java:
##
@@ -677,6 +734,18 @@ static void serializeStreamStateHan
Zakelly commented on PR #24595:
URL: https://github.com/apache/flink/pull/24595#issuecomment-2029264788
Rebase on FLINK-34548 and introduce this in `flink-core-api`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
[
https://issues.apache.org/jira/browse/FLINK-34548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-34548.
--
Resolution: Done
master(1.20) via 28762497bdf574855e4a9293f22ce80e6c7f9002.
> FLIP-409: DataStream V2
[
https://issues.apache.org/jira/browse/FLINK-34548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-34548:
---
Fix Version/s: 1.20.0
> FLIP-409: DataStream V2 Building Blocks: DataStream, Partitioning and
> Pro
[
https://issues.apache.org/jira/browse/FLINK-34548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-34548:
---
Affects Version/s: 1.20.0
> FLIP-409: DataStream V2 Building Blocks: DataStream, Partitioning and
>
reswqa merged PR #24422:
URL: https://github.com/apache/flink/pull/24422
--
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
Sxnan commented on PR #24422:
URL: https://github.com/apache/flink/pull/24422#issuecomment-2029246823
@reswqa Thanks for the update. LGTM!
--
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 spe
loserwang1024 commented on PR #3134:
URL: https://github.com/apache/flink-cdc/pull/3134#issuecomment-2029239877
> the split that has not yet completed the meta info synchronization should
not be deleted?
What if the snapshot splits are not completed, and then removed from
tableList?
Sxnan commented on code in PR #24422:
URL: https://github.com/apache/flink/pull/24422#discussion_r1546006170
##
flink-datastream-api/src/main/java/org/apache/flink/datastream/api/ExecutionEnvironment.java:
##
@@ -0,0 +1,53 @@
+/*
+ * Licensed to the Apache Software Foundation (A
Sxnan commented on code in PR #24422:
URL: https://github.com/apache/flink/pull/24422#discussion_r1546005292
##
flink-datastream/src/main/java/org/apache/flink/datastream/impl/stream/KeyedPartitionStreamImpl.java:
##
@@ -0,0 +1,389 @@
+/*
+ * Licensed to the Apache Software Foun
Sxnan commented on code in PR #24422:
URL: https://github.com/apache/flink/pull/24422#discussion_r1546005963
##
flink-datastream/src/main/java/org/apache/flink/datastream/impl/stream/KeyedPartitionStreamImpl.java:
##
@@ -0,0 +1,389 @@
+/*
+ * Licensed to the Apache Software Foun
[
https://issues.apache.org/jira/browse/FLINK-34976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17832742#comment-17832742
]
Yun Tang commented on FLINK-34976:
--
I don't think the running Flink process would drop
Jiabao-Sun commented on PR #3134:
URL: https://github.com/apache/flink-cdc/pull/3134#issuecomment-2029229060
Thanks @loserwang1024 for investigating this issue.
IMHO, I think this fix is a bit complicated.
Can we simply consider that in the previous PR, the split that has not yet
RocMarshal commented on code in PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1545999604
##
docs/content.zh/docs/concepts/architecture.md:
##
@@ -24,57 +24,65 @@ specific language governing permissions and limitations
under the License.
[
https://issues.apache.org/jira/browse/FLINK-34975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu updated FLINK-34975:
-
Fix Version/s: 2.0.0
> FLIP-427: ForSt - Disaggregated state Store
> ---
slfan1989 commented on PR #24580:
URL: https://github.com/apache/flink/pull/24580#issuecomment-2029194510
@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.
lvyanquan commented on PR #2916:
URL: https://github.com/apache/flink-cdc/pull/2916#issuecomment-2029160857
> paimon latest version is 0.7，we should update paimon version from 0.6 to
0.7
Done and rebased to master.
--
This is an automated message from the Apache Git Service.
To res
Jinzhong Li created FLINK-34981:
---
Summary: FLIP-426: Grouping Remote State Access
Key: FLINK-34981
URL: https://issues.apache.org/jira/browse/FLINK-34981
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-34980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34980:
---
Labels: pull-request-available (was: )
> Translate overview document into Chinese
> ---
caicancai opened a new pull request, #810:
URL: https://github.com/apache/flink-kubernetes-operator/pull/810
## What is the purpose of the change
*(For example: This pull request adds a new feature to periodically create
and maintain savepoints through the `FlinkDeployment` cu
[
https://issues.apache.org/jira/browse/FLINK-34934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caican Cai resolved FLINK-34934.
Resolution: Fixed
> Translation Flink-Kubernetes-Operator document framework construction
> --
Caican Cai created FLINK-34980:
--
Summary: Translate overview document into Chinese
Key: FLINK-34980
URL: https://issues.apache.org/jira/browse/FLINK-34980
Project: Flink
Issue Type: Sub-task
flinkbot commented on PR #24595:
URL: https://github.com/apache/flink/pull/24595#issuecomment-2029154015
## CI report:
* db1e02b3972270b3f401fa796c25a490d4309b3a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Zakelly opened a new pull request, #24595:
URL: https://github.com/apache/flink/pull/24595
## What is the purpose of the change
As discussed in FLIP-424, we will introduce a new set of State APIs for
asynchronous state access. This PR provides the definition of this API as
described
[
https://issues.apache.org/jira/browse/FLINK-34978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34978:
---
Labels: pull-request-available (was: )
> Introduce Asynchronous State APIs
> --
[
https://issues.apache.org/jira/browse/FLINK-34976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaogang zhou updated FLINK-34976:
--
Description:
I am not sure if LD_PRELOAD still takes effect after drop_privs_cmd. Do we
need
[
https://issues.apache.org/jira/browse/FLINK-34976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaogang zhou updated FLINK-34976:
--
Description:
I am not sure if LD_PRELOAD still takes effect after drop_privs_cmd. Should we
slfan1989 commented on PR #24580:
URL: https://github.com/apache/flink/pull/24580#issuecomment-2029139974
@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.
Zakelly Lan created FLINK-34979:
---
Summary: Implement State Future and related utilities
Key: FLINK-34979
URL: https://issues.apache.org/jira/browse/FLINK-34979
Project: Flink
Issue Type: Sub-ta
Zakelly Lan created FLINK-34978:
---
Summary: Introduce Asynchronous State APIs
Key: FLINK-34978
URL: https://issues.apache.org/jira/browse/FLINK-34978
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-34962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubiao Feng updated FLINK-34962:
Description:
- The unnecessary codes calls
`pulsarClient.getLookup().getPartitionedTopicMetadata(
[
https://issues.apache.org/jira/browse/FLINK-34962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubiao Feng updated FLINK-34962:
Description:
- The unnecessary codes calls
`pulsarClient.getLookup().getPartitionedTopicMetadata(
masteryhx commented on code in PR #24480:
URL: https://github.com/apache/flink/pull/24480#discussion_r1545946971
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV2V3SerializerBase.java:
##
@@ -677,6 +734,18 @@ static void serializeStreamStateH
caicancai commented on code in PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1545936742
##
docs/content.zh/docs/concepts/architecture.md:
##
@@ -24,57 +24,57 @@ specific language governing permissions and limitations
under the License.
[
https://issues.apache.org/jira/browse/FLINK-34977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-34977:
---
Description: This is the umbrella ticket for FLIP-433: Config, Context and
Processing Timer Service
[
https://issues.apache.org/jira/browse/FLINK-34976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaogang zhou updated FLINK-34976:
--
Description:
I am not sure if LD_PRELOAD still takes effect after drop_privs_cmd. Do we
need
[
https://issues.apache.org/jira/browse/FLINK-34977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-34977:
---
Description: This is the umbrella ticket for FLIP-433: State Access on
DataStream API V2. (was: Thi
Weijie Guo created FLINK-34977:
--
Summary: FLIP-433: State Access on DataStream API V2
Key: FLINK-34977
URL: https://issues.apache.org/jira/browse/FLINK-34977
Project: Flink
Issue Type: Sub-task
xiaogang zhou created FLINK-34976:
-
Summary: LD_PRELOAD environment may not be effective after su to
flink user
Key: FLINK-34976
URL: https://issues.apache.org/jira/browse/FLINK-34976
Project: Flink
Hangxiang Yu created FLINK-34975:
Summary: FLIP-427: ForSt - Disaggregated state Store
Key: FLINK-34975
URL: https://issues.apache.org/jira/browse/FLINK-34975
Project: Flink
Issue Type: New F
caicancai commented on code in PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1545936742
##
docs/content.zh/docs/concepts/architecture.md:
##
@@ -24,57 +24,57 @@ specific language governing permissions and limitations
under the License.
caicancai commented on code in PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1545936400
##
docs/content.zh/docs/concepts/architecture.md:
##
@@ -24,57 +24,57 @@ specific language governing permissions and limitations
under the License.
caicancai commented on code in PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1545936400
##
docs/content.zh/docs/concepts/architecture.md:
##
@@ -24,57 +24,57 @@ specific language governing permissions and limitations
under the License.
caicancai commented on code in PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1545936400
##
docs/content.zh/docs/concepts/architecture.md:
##
@@ -24,57 +24,57 @@ specific language governing permissions and limitations
under the License.
Zakelly Lan created FLINK-34974:
---
Summary: FLIP-424: Asynchronous State APIs
Key: FLINK-34974
URL: https://issues.apache.org/jira/browse/FLINK-34974
Project: Flink
Issue Type: New Feature
Zakelly Lan created FLINK-34973:
---
Summary: FLIP-423: Disaggregated State Storage and Management
Key: FLINK-34973
URL: https://issues.apache.org/jira/browse/FLINK-34973
Project: Flink
Issue Type
RocMarshal commented on code in PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1545922843
##
docs/content.zh/docs/concepts/architecture.md:
##
@@ -24,57 +24,57 @@ specific language governing permissions and limitations
under the License.
RocMarshal commented on code in PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1545923010
##
docs/content.zh/docs/concepts/architecture.md:
##
@@ -24,57 +24,57 @@ specific language governing permissions and limitations
under the License.
RocMarshal commented on code in PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1545922843
##
docs/content.zh/docs/concepts/architecture.md:
##
@@ -24,57 +24,57 @@ specific language governing permissions and limitations
under the License.
[
https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17832695#comment-17832695
]
Weijie Guo commented on FLINK-34643:
https://dev.azure.com/apache-flink/apache-flink
[
https://issues.apache.org/jira/browse/FLINK-34948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun resolved FLINK-34948.
Assignee: Qishang Zhong
Resolution: Fixed
Fixed via cdc master: d099603ef15d9a1ed7ec33718db7
Jiabao-Sun merged PR #3130:
URL: https://github.com/apache/flink-cdc/pull/3130
--
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.
[
https://issues.apache.org/jira/browse/FLINK-34948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun updated FLINK-34948:
---
Priority: Critical (was: Minor)
> CDC RowType can not convert to flink row type
> -
flinkbot commented on PR #24594:
URL: https://github.com/apache/flink/pull/24594#issuecomment-2029006210
## CI report:
* 67877b27f002d7a43b16ef0a1fb352a625218f59 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
slfan1989 commented on PR #24580:
URL: https://github.com/apache/flink/pull/24580#issuecomment-2028949298
@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.
lincoln-lil commented on PR #24517:
URL: https://github.com/apache/flink/pull/24517#issuecomment-2028808821
@masteryhx Could you take a look again when you have time?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-34972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-34972:
Component/s: Test Infrastructure
> MigrationTestsSnapshotGenerator does not work properly for all
[
https://issues.apache.org/jira/browse/FLINK-34712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-34712:
Component/s: (was: Test Infrastructure)
> Update reference data for Migration Tests
>
[
https://issues.apache.org/jira/browse/FLINK-34712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-34712:
Component/s: Test Infrastructure
(was: Tests)
> Update reference data for Mig
[
https://issues.apache.org/jira/browse/FLINK-34712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-34712:
Component/s: Tests
> Update reference data for Migration Tests
> -
lincoln-lil commented on PR #24517:
URL: https://github.com/apache/flink/pull/24517#issuecomment-2028805753
After some debugging, seems `MigrationTestsSnapshotGenerator` cannot work
for the four failure tests (
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=58514&vie
lincoln lee created FLINK-34972:
---
Summary: MigrationTestsSnapshotGenerator does not work properly
for all subclasses of SnapshotMigrationTestBase
Key: FLINK-34972
URL: https://issues.apache.org/jira/browse/FLINK-349
flinkbot commented on PR #24593:
URL: https://github.com/apache/flink/pull/24593#issuecomment-2028711002
## CI report:
* bdaa8dc9c5ab9840c554dc537af168670bcea851 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
d20162416 opened a new pull request, #24593:
URL: https://github.com/apache/flink/pull/24593
Currently, flink does not provide the ability to regularly clean the
archives of completed jobs. I think this ability is necessary.
When flink provides this ability, users can decide whether t
d20162416 closed pull request #24592: [FLINK-34971]Add the function of History
Server cleaning job archives regularly
URL: https://github.com/apache/flink/pull/24592
--
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-34971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34971:
---
Labels: pull-request-available (was: )
> Add the function of History Server cleaning job ar
d20162416 closed pull request #24592: [FLINK-34971]Add the function of History
Server cleaning job archives regularly
URL: https://github.com/apache/flink/pull/24592
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
JK-Wang closed pull request #22463: [hotfix] Fix incomplete comment
URL: https://github.com/apache/flink/pull/22463
--
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
flinkbot commented on PR #24592:
URL: https://github.com/apache/flink/pull/24592#issuecomment-2028664146
## CI report:
* 60580f94d942fb4d7accf9b43e9c53c762183202 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
d20162416 opened a new pull request, #24592:
URL: https://github.com/apache/flink/pull/24592
Currently, flink does not provide the ability to regularly clean the
archives of completed jobs. I think this ability is necessary.
When flink provides this ability, users can decide whether to u
dengxaing created FLINK-34971:
-
Summary: Add the function of History Server cleaning job archives
regularly
Key: FLINK-34971
URL: https://issues.apache.org/jira/browse/FLINK-34971
Project: Flink
caicancai commented on code in PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1545572383
##
docs/content.zh/docs/concepts/architecture.md:
##
@@ -26,55 +26,55 @@ under the License.
# Architecture
Review Comment:
Thank you for your
[
https://issues.apache.org/jira/browse/FLINK-34738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17832554#comment-17832554
]
Vincent Woo commented on FLINK-34738:
-
I'm willing to handle this issue, could someo
[
https://issues.apache.org/jira/browse/FLINK-34736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17832553#comment-17832553
]
Vincent Woo commented on FLINK-34736:
-
I'm willing to contribute, could someone assi
75 matches
Mail list logo
