[
https://issues.apache.org/jira/browse/FLINK-31980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31980:
--
Summary: Implement support for EFO in new KDS Source (was: Implement
support for EFO in new S
[
https://issues.apache.org/jira/browse/FLINK-31987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31987:
--
Summary: Implement KDS Table API support (was: Implement Table API support)
> Implement KDS T
[
https://issues.apache.org/jira/browse/FLINK-31987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31987:
--
Component/s: Connectors / Kinesis
> Implement KDS Table API support
>
Danny Cranmer created FLINK-34341:
-
Summary: Implement DDB Streams Table API support
Key: FLINK-34341
URL: https://issues.apache.org/jira/browse/FLINK-34341
Project: Flink
Issue Type: Sub-tas
[
https://issues.apache.org/jira/browse/FLINK-34341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-34341:
--
Reporter: Danny Cranmer (was: Hong Liang Teoh)
> Implement DDB Streams Table API support
> --
[
https://issues.apache.org/jira/browse/FLINK-34341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-34341:
--
Description:
Implement Table API support for DDB Streams Source.
Consider:
* Configuratio
snuyanzin commented on code in PR #2:
URL:
https://github.com/apache/flink-connector-jdbc/pull/2#discussion_r1475815795
##
.github/workflows/weekly.yml:
##
@@ -27,25 +27,13 @@ jobs:
strategy:
matrix:
flink_branches: [{
- flink: 1.16-SNAPSHOT,
-
snuyanzin commented on code in PR #2:
URL:
https://github.com/apache/flink-connector-jdbc/pull/2#discussion_r1475815795
##
.github/workflows/weekly.yml:
##
@@ -27,25 +27,13 @@ jobs:
strategy:
matrix:
flink_branches: [{
- flink: 1.16-SNAPSHOT,
-
[
https://issues.apache.org/jira/browse/FLINK-34340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-34340:
--
Summary: Add support for DDB Streams for DataStream API (was: Add support
for DDB Streams)
>
Danny Cranmer created FLINK-34342:
-
Summary: Address ListShards Consistency for DDB Streams Source
Key: FLINK-34342
URL: https://issues.apache.org/jira/browse/FLINK-34342
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-34342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-34342:
--
Summary: Address ListShards Consistency Issue for DDB Streams Source (was:
Address ListShards
[
https://issues.apache.org/jira/browse/FLINK-34342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-34342:
--
Summary: Address Shard Consistency Issue for DDB Streams Source (was:
Address ListShards Cons
[
https://issues.apache.org/jira/browse/FLINK-34342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-34342:
--
Description:
*Problem*
We call
[DescribeStream|https://docs.aws.amazon.com/amazondynamodb/la
xuyangzhong commented on code in PR #24239:
URL: https://github.com/apache/flink/pull/24239#discussion_r1475829008
##
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/hints/batch/NestLoopJoinHintTest.xml:
##
@@ -679,8 +680,8 @@ HashJoin(join
[
https://issues.apache.org/jira/browse/FLINK-34342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-34342:
--
Description:
*Problem*
We call
[DescribeStream|https://docs.aws.amazon.com/amazondynamodb/la
[
https://issues.apache.org/jira/browse/FLINK-31989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813602#comment-17813602
]
Danny Cranmer commented on FLINK-31989:
---
We could split this task and deliver incr
eskabetxe commented on code in PR #2:
URL:
https://github.com/apache/flink-connector-jdbc/pull/2#discussion_r1475842140
##
.github/workflows/weekly.yml:
##
@@ -27,25 +27,13 @@ jobs:
strategy:
matrix:
flink_branches: [{
- flink: 1.16-SNAPSHOT,
-
eskabetxe commented on code in PR #2:
URL:
https://github.com/apache/flink-connector-jdbc/pull/2#discussion_r1475842140
##
.github/workflows/weekly.yml:
##
@@ -27,25 +27,13 @@ jobs:
strategy:
matrix:
flink_branches: [{
- flink: 1.16-SNAPSHOT,
-
[
https://issues.apache.org/jira/browse/FLINK-34333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813603#comment-17813603
]
Yang Wang commented on FLINK-34333:
---
I am not aware of other potential issues and in f
[
https://issues.apache.org/jira/browse/FLINK-34333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813604#comment-17813604
]
Yang Wang commented on FLINK-34333:
---
+1 for what Chesnay said. We already shade the fa
StefanXiepj commented on PR #74:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/74#issuecomment-1923495793
> @StefanXiepj Are you still active on this PR?
There are another
PR[53](https://github.com/apache/flink-connector-elasticsearch/pull/53) doing
it, i don't k
1996fanrui commented on PR #20340:
URL: https://github.com/apache/flink/pull/20340#issuecomment-1923500149
@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-34229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813613#comment-17813613
]
xingbe commented on FLINK-34229:
[~FrankZou] Thanks for resolving this. I have checked t
JunRuiLee opened a new pull request, #24251:
URL: https://github.com/apache/flink/pull/24251
## What is the purpose of the change
Document FLIP-366: Support standard YAML for FLINK configuration
## Brief change log
- Add documentation of new Flink configurat
[
https://issues.apache.org/jira/browse/FLINK-34247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34247:
---
Labels: pull-request-available (was: )
> Document FLIP-366: Support standard YAML for FLINK
flinkbot commented on PR #24251:
URL: https://github.com/apache/flink/pull/24251#issuecomment-1923581075
## CI report:
* e2f376490d7922436989cf89a66269f2cd73272c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Matthias Pohl created FLINK-34343:
-
Summary: ResourceManager registration is not completed when
registering the JobMaster
Key: FLINK-34343
URL: https://issues.apache.org/jira/browse/FLINK-34343
Projec
[
https://issues.apache.org/jira/browse/FLINK-34343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813624#comment-17813624
]
Matthias Pohl commented on FLINK-34343:
---
Initially, I thought that it would be cau
[
https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813626#comment-17813626
]
Matthias Pohl commented on FLINK-34007:
---
The Azure test failure seems to be unrela
[
https://issues.apache.org/jira/browse/FLINK-34343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34343:
--
Attachment: FLINK-34343_k8s_application_cluster_e2e_test.log
> ResourceManager registration is
[
https://issues.apache.org/jira/browse/FLINK-34343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813627#comment-17813627
]
Matthias Pohl commented on FLINK-34343:
---
I attached the logs of the corresponding
[
https://issues.apache.org/jira/browse/FLINK-34343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813629#comment-17813629
]
Matthias Pohl commented on FLINK-34343:
---
[~chesnay] do you have capacity to look a
eskabetxe commented on PR #2:
URL:
https://github.com/apache/flink-connector-jdbc/pull/2#issuecomment-1923662905
@snuyanzin @MartijnVisser
I already change an test to mock Sink.InitContext as in 1.19 add a method
with a new class..
But now is falling all dialects for TIMESTAMP_LTZ th
[
https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813646#comment-17813646
]
Feifan Wang commented on FLINK-33734:
-
I found that only merging handles was not eno
[
https://issues.apache.org/jira/browse/FLINK-24239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-24239:
Assignee: Dawid Wysakowicz
> Event time temporal join should support values from
X-czh commented on PR #24230:
URL: https://github.com/apache/flink/pull/24230#issuecomment-1923775660
@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
XComp opened a new pull request, #24252:
URL: https://github.com/apache/flink/pull/24252
## What is the purpose of the change
There was a test failure in [this
build](https://github.com/XComp/flink/actions/runs/7745486791/job/21121947504#step:14:7309)
which was testing FLINK-34333 (t
flinkbot commented on PR #24252:
URL: https://github.com/apache/flink/pull/24252#issuecomment-1923919766
## CI report:
* 4d84982a1376edabc04108045e4cbd32eb9e59da UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dawidwys commented on PR #23411:
URL: https://github.com/apache/flink/pull/23411#issuecomment-1924010094
Sorry, it takes such a long time from my side. I had a vacation in the
meantime. I'll try to check it Monday. Nevertheless if you're comfortable with
the PR @snuyanzin feel free to merge
[
https://issues.apache.org/jira/browse/FLINK-24239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-24239:
---
Labels: pull-request-available (was: )
> Event time temporal join should support values fro
dawidwys opened a new pull request, #24253:
URL: https://github.com/apache/flink/pull/24253
## What is the purpose of the change
This makes it possible to use more complex keys for temporal join. It tries
pushing down join predicates before extracting join keys which makes more cases
flinkbot commented on PR #24253:
URL: https://github.com/apache/flink/pull/24253#issuecomment-1924021657
## CI report:
* e06aee059e610ce72fb153eff7c8f466cde82bfa UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813708#comment-17813708
]
lincoln lee commented on FLINK-34299:
-
[~guoyangze] Thanks for confirming!
> Releas
[
https://issues.apache.org/jira/browse/FLINK-34296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813709#comment-17813709
]
lincoln lee commented on FLINK-34296:
-
[~JunRuiLi] Thanks for confirming, will close
[
https://issues.apache.org/jira/browse/FLINK-34296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-34296.
---
Resolution: Fixed
> Release Testing Instructions: Verify FLINK-33581 Deprecate configuration
> gett
[
https://issues.apache.org/jira/browse/FLINK-34295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-34295.
---
Resolution: Fixed
[~JunRuiLi] Thanks for confirming!
> Release Testing Instructions: Verify FLINK-3
Roman Khachatryan created FLINK-34344:
-
Summary: Wrong JobID in CheckpointStatsTracker
Key: FLINK-34344
URL: https://issues.apache.org/jira/browse/FLINK-34344
Project: Flink
Issue Type: B
snuyanzin commented on PR #23411:
URL: https://github.com/apache/flink/pull/23411#issuecomment-1924052949
I think we could wait until Monday or even more since right now a feature
freeze and need to wait for cutting release branch
--
This is an automated message from the Apache Git Servic
rkhachatryan opened a new pull request, #24254:
URL: https://github.com/apache/flink/pull/24254
## 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 th
[
https://issues.apache.org/jira/browse/FLINK-34344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34344:
---
Labels: pull-request-available (was: )
> Wrong JobID in CheckpointStatsTracker
> --
[
https://issues.apache.org/jira/browse/FLINK-34122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813714#comment-17813714
]
Martijn Visser commented on FLINK-34122:
Whatever works for you!
> Deprecate o
flinkbot commented on PR #24254:
URL: https://github.com/apache/flink/pull/24254#issuecomment-1924070918
## CI report:
* 03d4cfb0053a784e0f88677dcf1e8a6e4dc3c9f4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
hlteoh37 commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#discussion_r1476176456
##
example-datastream-job/pom.xml:
##
@@ -0,0 +1,156 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-in
[
https://issues.apache.org/jira/browse/FLINK-33856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813723#comment-17813723
]
Martijn Visser commented on FLINK-33856:
There's been a change at the ASF on who
[
https://issues.apache.org/jira/browse/FLINK-23582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-23582.
--
Resolution: Duplicate
> Add documentation for session window
> ---
[
https://issues.apache.org/jira/browse/FLINK-34169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813730#comment-17813730
]
Zakelly Lan commented on FLINK-34169:
-
Thanks, closing now.
> [benchmark] CI fails
[
https://issues.apache.org/jira/browse/FLINK-34169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan closed FLINK-34169.
---
Resolution: Fixed
> [benchmark] CI fails during test running
> -
[
https://issues.apache.org/jira/browse/FLINK-33696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reopened FLINK-33696:
No it's not yet done. I still have to open a PR adding OpenTelemetry reporters.
7db2ecad was
[
https://issues.apache.org/jira/browse/FLINK-33819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813740#comment-17813740
]
Piotr Nowojski edited comment on FLINK-33819 at 2/2/24 3:52 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-33819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813740#comment-17813740
]
Piotr Nowojski commented on FLINK-33819:
Thanks [~mayuehappy].
{quote}
merged 4
[
https://issues.apache.org/jira/browse/FLINK-34343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34343:
--
Affects Version/s: 1.18.1
1.17.2
> ResourceManager registration is not
[
https://issues.apache.org/jira/browse/FLINK-34343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34343:
--
Priority: Critical (was: Blocker)
> ResourceManager registration is not completed when regist
jeyhunkarimov commented on code in PR #24239:
URL: https://github.com/apache/flink/pull/24239#discussion_r1476267210
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/RelTreeWriterImpl.scala:
##
@@ -286,4 +297,45 @@ class RelTreeWriterIm
[
https://issues.apache.org/jira/browse/FLINK-34325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexis Sarda-Espinosa updated FLINK-34325:
--
Description:
I have a job that uses broadcast state to maintain a cache of req
[
https://issues.apache.org/jira/browse/FLINK-34325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexis Sarda-Espinosa updated FLINK-34325:
--
Description:
I have a job that uses broadcast state to maintain a cache of req
reta commented on PR #53:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/53#issuecomment-1924270597
@MartijnVisser @mtfelisb it looks great, I have no more comments, it would
be great to have e2e tests added but we could also do that in separate pull
request.
--
This
[
https://issues.apache.org/jira/browse/FLINK-34152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813772#comment-17813772
]
Emanuele Pirro commented on FLINK-34152:
Thanks Maximilian for reporting this. I
boring-cyborg[bot] commented on PR #100:
URL:
https://github.com/apache/flink-connector-jdbc/pull/100#issuecomment-1924778857
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-34014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34014:
---
Labels: pull-request-available (was: )
> Jdbc connector can avoid send empty insert to data
snuyanzin opened a new pull request, #24255:
URL: https://github.com/apache/flink/pull/24255
## What is the purpose of the change
The PR is about to bump Calcite to 1.33.0
## Brief change log
*(for example:)*
- *The TaskInfo is stored in the blob store on job creatio
[
https://issues.apache.org/jira/browse/FLINK-31362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31362:
---
Labels: pull-request-available (was: )
> Upgrade to Calcite version to 1.33.0
> ---
flinkbot commented on PR #24255:
URL: https://github.com/apache/flink/pull/24255#issuecomment-1924979141
## CI report:
* b9d77b02be5ddc59ed2596babcbcce7d49f92c4a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
GOODBOY008 commented on PR #20340:
URL: https://github.com/apache/flink/pull/20340#issuecomment-1924979780
@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
1996fanrui commented on PR #20340:
URL: https://github.com/apache/flink/pull/20340#issuecomment-1925001112
Hi @GOODBOY008 , would you mind rebasing the master branch?
If I remember correctly, this ci isuue has been fixed in master branch.
--
This is an automated message from the Ap
[
https://issues.apache.org/jira/browse/FLINK-26369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-26369:
---
Assignee: Zhongqiang Gong
> Translate the part zh-page mixed with not be translated.
> ---
snuyanzin opened a new pull request, #24256:
URL: https://github.com/apache/flink/pull/24256
## What is the purpose of the change
This PR is about to upgrade Calcite to 1.34.0
it is based on https://github.com/apache/flink/pull/24255
once upgrade to 1.33.0 will be approved and me
[
https://issues.apache.org/jira/browse/FLINK-31836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31836:
---
Labels: pull-request-available (was: )
> Upgrade Calcite version to 1.34.0
> --
flinkbot commented on PR #24256:
URL: https://github.com/apache/flink/pull/24256#issuecomment-1925021000
## CI report:
* 6650bc89e66820688b8507d870762aa5f3e016b3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
GOODBOY008 commented on PR #20340:
URL: https://github.com/apache/flink/pull/20340#issuecomment-1925022155
@1996fanrui Branch has rebased, Thanks for your review.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
1996fanrui merged PR #20340:
URL: https://github.com/apache/flink/pull/20340
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.ap
[
https://issues.apache.org/jira/browse/FLINK-26369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-26369.
-
Resolution: Fixed
> Translate the part zh-page mixed with not be translated.
>
[
https://issues.apache.org/jira/browse/FLINK-26369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813872#comment-17813872
]
Rui Fan commented on FLINK-26369:
-
Merged to master(1.19.0) via : 5fe6f2024f77c03b2f2a89
[
https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813874#comment-17813874
]
Rui Fan commented on FLINK-33734:
-
Thanks [~Feifan Wang] for the effort. IIUC, the check
Caican Cai created FLINK-34345:
--
Summary: Remove TaskExecutorManager related logic
Key: FLINK-34345
URL: https://issues.apache.org/jira/browse/FLINK-34345
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-34345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caican Cai updated FLINK-34345:
---
Issue Type: Technical Debt (was: Improvement)
> Remove TaskExecutorManager related logic
>
caicancai opened a new pull request, #24257:
URL: https://github.com/apache/flink/pull/24257
## 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
[
https://issues.apache.org/jira/browse/FLINK-34345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34345:
---
Labels: pull-request-available (was: )
> Remove TaskExecutorManager related logic
> ---
flinkbot commented on PR #24257:
URL: https://github.com/apache/flink/pull/24257#issuecomment-1925162848
## CI report:
* 38fe004b350cad98d065f0619409fcf120de8c69 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
caicancai commented on PR #24257:
URL: https://github.com/apache/flink/pull/24257#issuecomment-1925162917
related to https://issues.apache.org/jira/browse/FLINK-31449
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
caicancai commented on PR #24257:
URL: https://github.com/apache/flink/pull/24257#issuecomment-1925163414
@RocMarshal @1996fanrui If you have time, can you help me review it? Thank
you.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
[
https://issues.apache.org/jira/browse/FLINK-34345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-34345:
---
Assignee: Caican Cai
> Remove TaskExecutorManager related logic
> -
[
https://issues.apache.org/jira/browse/FLINK-34345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-34345:
Affects Version/s: 1.19.0
> Remove TaskExecutorManager related logic
> ---
snuyanzin commented on code in PR #24219:
URL: https://github.com/apache/flink/pull/24219#discussion_r1475697013
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/RestoreTestCompleteness.java:
##
@@ -0,0 +1,130 @@
+/*
+ * L
[
https://issues.apache.org/jira/browse/FLINK-34330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813547#comment-17813547
]
Matthias Pohl commented on FLINK-34330:
---
Interesting, thanks for the pointer. I ca
X-czh commented on code in PR #24230:
URL: https://github.com/apache/flink/pull/24230#discussion_r1475705654
##
docs/content/docs/dev/datastream/fault-tolerance/serialization/types_serialization.md:
##
@@ -489,41 +516,39 @@ int, long, String etc. are handled by serializers we sh
[
https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813551#comment-17813551
]
Matthias Pohl commented on FLINK-22765:
---
https://github.com/apache/flink/actions/r
[
https://issues.apache.org/jira/browse/FLINK-26515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813552#comment-17813552
]
Matthias Pohl commented on FLINK-26515:
---
1.18:
https://github.com/apache/flink/ac
[
https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813554#comment-17813554
]
Matthias Pohl commented on FLINK-34202:
---
https://dev.azure.com/apache-flink/apache
X-czh commented on code in PR #24230:
URL: https://github.com/apache/flink/pull/24230#discussion_r1475713915
##
docs/content/docs/dev/datastream/fault-tolerance/serialization/types_serialization.md:
##
@@ -359,12 +385,13 @@ You can still use the same method as in Java as a
fall
X-czh commented on code in PR #24230:
URL: https://github.com/apache/flink/pull/24230#discussion_r1475713915
##
docs/content/docs/dev/datastream/fault-tolerance/serialization/types_serialization.md:
##
@@ -359,12 +385,13 @@ You can still use the same method as in Java as a
fall
1 - 100 of 130 matches
Mail list logo
