[
https://issues.apache.org/jira/browse/FLINK-33356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33356:
---
Labels: pull-request-available (was: )
> The navigation bar on Flink’s official website is
WencongLiu opened a new pull request, #23627:
URL: https://github.com/apache/flink/pull/23627
… website
## 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
flinkbot commented on PR #23626:
URL: https://github.com/apache/flink/pull/23626#issuecomment-1786483458
## CI report:
* e9314bf45db02132e84bfb8b7a000485c49b866d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33210:
---
Labels: pull-request-available (was: )
> Introduce lineage graph relevant interfaces
>
FangYongs opened a new pull request, #23626:
URL: https://github.com/apache/flink/pull/23626
## What is the purpose of the change
This PR aims to add lineage graph relevant interfaces such as
`LineageGraph`, `LineageVertex`, `SourceLineageVertex` and `LineageEdge`
## Brief
caicancai commented on PR #696:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/696#issuecomment-1786424302
cc @gyfora
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific
1996fanrui commented on PR #697:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/697#issuecomment-1786394585
Hi @gyfora , the flink-kubernetes-operator has 3 overlapping classes with
1.17.1, but has 10 overlapping classes, so the CI fails.
I'd like to check with you
TanYuxin-tyx commented on PR #64:
URL:
https://github.com/apache/flink-connector-kafka/pull/64#issuecomment-1786393530
@MartijnVisser Hi, Martijn, could you please help review this?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-33080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-33080:
Affects Version/s: 1.17.1
1.18.0
1.19.0
> The checkpoint
[
https://issues.apache.org/jira/browse/FLINK-33080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-33080.
---
Resolution: Fixed
Fixed via 25697476095a5b9cf38dc3b61c684d0e912b1353
> The checkpoint storage configured
zhuzhurk closed pull request #23408: [FLINK-33080][runtime] Make the configured
checkpoint storage in the job-side configuration will take effect.
URL: https://github.com/apache/flink/pull/23408
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-33401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781203#comment-17781203
]
Yuxin Tan commented on FLINK-33401:
---
[~pavelhp] Thanks for reporting this issue. I will take a look at
TanYuxin-tyx opened a new pull request, #64:
URL: https://github.com/apache/flink-connector-kafka/pull/64
Currently, Kafka Connector official documentation has a bug in the download
link and the version number.
This is the fix for https://issues.apache.org/jira/browse/FLINK-33401.
[
https://issues.apache.org/jira/browse/FLINK-33401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33401:
---
Labels: pull-request-available (was: )
> Kafka connector has broken version
>
boring-cyborg[bot] commented on PR #64:
URL:
https://github.com/apache/flink-connector-kafka/pull/64#issuecomment-1786384204
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-32108 ]
xiang1 yu deleted comment on FLINK-32108:
---
was (Author: JIRAUSER302279):
Hi, @Matthias Pohl; I tested locally and there was a print message, and exit
-1, so I'm not sure if {{assumeThat}}
Jaehyeon Kim created FLINK-33405:
Summary: ProcessJoinFunction not found in Pyflink
Key: FLINK-33405
URL: https://issues.apache.org/jira/browse/FLINK-33405
Project: Flink
Issue Type:
victor9309 commented on PR #23624:
URL: https://github.com/apache/flink/pull/23624#issuecomment-1786370390
> Thanks for picking this one up, @victor9309 . Can you provide backports
for this issue? 1.18, 1.17 should be good enough.
Thanks @XComp for the review. I changed the 1.17 and
Jaehyeon Kim created FLINK-33404:
Summary: on_timer method is missing in ProcessFunction and
CoProcessFunction of Pyflink
Key: FLINK-33404
URL: https://issues.apache.org/jira/browse/FLINK-33404
flinkbot commented on PR #23625:
URL: https://github.com/apache/flink/pull/23625#issuecomment-1786362798
## CI report:
* 398f8f4c3860ecdf009a350a2165d3dfe763af1d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #23624:
URL: https://github.com/apache/flink/pull/23624#issuecomment-1786362122
## CI report:
* b7ecb4320187e38ac21da43260c4aa3f44e411bf UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Jiabao-Sun commented on code in PR #18:
URL:
https://github.com/apache/flink-connector-mongodb/pull/18#discussion_r1376996490
##
.github/workflows/weekly.yml:
##
@@ -35,15 +35,15 @@ jobs:
}, {
flink: 1.18-SNAPSHOT,
branch: main
+}, {
+
victor9309 commented on PR #23624:
URL: https://github.com/apache/flink/pull/23624#issuecomment-1786360897
I changed `uniq `to `sort -u` and the results are shown in the figure below:
--
victor9309 opened a new pull request, #23625:
URL: https://github.com/apache/flink/pull/23625
## What is the purpose of the change
*(Running HA (hashmap, async) end-to-end test failed on azure due to unable
to find master logs.)*
## Brief change log
-
victor9309 opened a new pull request, #23624:
URL: https://github.com/apache/flink/pull/23624
## What is the purpose of the change
*(Running HA (hashmap, async) end-to-end test failed on azure due to unable
to find master logs.)*
## Brief change log
-
Jiabao-Sun commented on code in PR #18:
URL:
https://github.com/apache/flink-connector-mongodb/pull/18#discussion_r1376993865
##
.github/workflows/push_pr.yml:
##
@@ -25,7 +25,7 @@ jobs:
compile_and_test:
strategy:
matrix:
-flink: [1.17-SNAPSHOT,
gtk96 commented on code in PR #18:
URL:
https://github.com/apache/flink-connector-mongodb/pull/18#discussion_r1376993423
##
.github/workflows/weekly.yml:
##
@@ -35,15 +35,15 @@ jobs:
}, {
flink: 1.18-SNAPSHOT,
branch: main
+}, {
+
Jiabao-Sun commented on code in PR #18:
URL:
https://github.com/apache/flink-connector-mongodb/pull/18#discussion_r1376992845
##
.github/workflows/weekly.yml:
##
@@ -35,15 +35,15 @@ jobs:
}, {
flink: 1.18-SNAPSHOT,
branch: main
+}, {
+
gtk96 commented on code in PR #18:
URL:
https://github.com/apache/flink-connector-mongodb/pull/18#discussion_r1376988739
##
pom.xml:
##
@@ -119,11 +119,11 @@ under the License.
test
-
-
JunRuiLee commented on PR #23408:
URL: https://github.com/apache/flink/pull/23408#issuecomment-1786348383
The CI test case for this PR has passed successfully. However, due to
network instability in the environment, the post-job "Cache docker images" in
the E2E testing stage experienced a
[
https://issues.apache.org/jira/browse/FLINK-33403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33403:
---
Labels: pull-request-available (was: )
> Bump flink version to 1.18.0 for
1996fanrui opened a new pull request, #697:
URL: https://github.com/apache/flink-kubernetes-operator/pull/697
## What is the purpose of the change
Bump flink version to 1.18.0 for flink-kubernetes-operator
## Brief change log
- Bump flink version to 1.18.0 for
caicancai opened a new pull request, #696:
URL: https://github.com/apache/flink-kubernetes-operator/pull/696
…ed codepaths
## What is the purpose of the change
*(For example: This pull request adds a new feature to periodically create
and maintain savepoints through
Rui Fan created FLINK-33403:
---
Summary: Bump flink version to 1.18.0 for flink-kubernetes-operator
Key: FLINK-33403
URL: https://issues.apache.org/jira/browse/FLINK-33403
Project: Flink
Issue Type:
Jiabao-Sun commented on code in PR #18:
URL:
https://github.com/apache/flink-connector-mongodb/pull/18#discussion_r1376965757
##
pom.xml:
##
@@ -119,11 +119,11 @@ under the License.
test
-
-
gtk96 commented on PR #18:
URL:
https://github.com/apache/flink-connector-mongodb/pull/18#issuecomment-1786309854
@Jiabao-Sun @MartijnVisser ci pass
https://github.com/gtk96/flink-connector-mongodb/actions/runs/6700848560 PTAL
--
This is an automated message from the Apache Git
victor9309 commented on PR #23528:
URL: https://github.com/apache/flink/pull/23528#issuecomment-1786309362
Thanks @XComp for the review. make the diff smaller
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
victor9309 commented on PR #23528:
URL: https://github.com/apache/flink/pull/23528#issuecomment-1786292325
Thanks @XComp for the 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 above to go to the
flinkbot commented on PR #23623:
URL: https://github.com/apache/flink/pull/23623#issuecomment-1786250114
## CI report:
* 14b7a02379b00d4d14b1711526989bd7585478af UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
bvarghese1 opened a new pull request, #23623:
URL: https://github.com/apache/flink/pull/23623
## What is the purpose of the change
Add restore tests for Calc node
## Verifying this change
Please make sure both new and modified tests in this PR follows the
[
https://issues.apache.org/jira/browse/FLINK-33402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Varun Narayanan Chakravarthy updated FLINK-33402:
-
Description:
Hello Team,
I noticed that there is data loss when
Varun Narayanan Chakravarthy created FLINK-33402:
Summary: Hybrid Source Concurrency Race Condition Fixes and
Related Bugs
Key: FLINK-33402
URL: https://issues.apache.org/jira/browse/FLINK-33402
tzulitai closed pull request #63: [hotfix] refer to
sql_connector_download_table shortcode in the docs …
URL: https://github.com/apache/flink-connector-kafka/pull/63
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
tzulitai commented on PR #63:
URL:
https://github.com/apache/flink-connector-kafka/pull/63#issuecomment-1786150659
Merged via 979791c4c71e944c16c51419cf9a84aa1f8fea4c.
Thanks @mas-chen!
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-27758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781135#comment-17781135
]
Chao Liu commented on FLINK-27758:
--
Hi [~Sergey Nuyanzin] I'd like to work on this ticket, could I get
mas-chen opened a new pull request, #63:
URL: https://github.com/apache/flink-connector-kafka/pull/63
…to adhere to new connector versioning format
Clicking through the docs, it looks like all connector moved to using this
shortcode except for Kafka
--
This is an automated message
[
https://issues.apache.org/jira/browse/FLINK-33376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781060#comment-17781060
]
Matthias Pohl commented on FLINK-33376:
---
hm, good point.
About the different configuration
flinkbot commented on PR #23622:
URL: https://github.com/apache/flink/pull/23622#issuecomment-1785508212
## CI report:
* 916e7ff59fc86c2468432a92623530857efd5027 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dawidwys opened a new pull request, #23622:
URL: https://github.com/apache/flink/pull/23622
## What is the purpose of the change
This ports `ELEMENT/ITEM_AT/CARDINALITY` functions to the new type inference
stack. The end goal is to get rid off `PlannerTypeInferenceUtil`.
##
[
https://issues.apache.org/jira/browse/FLINK-33376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17780411#comment-17780411
]
Matthias Pohl edited comment on FLINK-33376 at 10/30/23 3:36 PM:
-
Sounds
[
https://issues.apache.org/jira/browse/FLINK-33376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17780489#comment-17780489
]
Matthias Pohl edited comment on FLINK-33376 at 10/30/23 3:35 PM:
-
It
[
https://issues.apache.org/jira/browse/FLINK-32182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-32182.
Resolution: Fixed
master: 530ebd2f4ef59f84d2aedaf13a89b030480e3808
> Use original
zentol merged PR #23594:
URL: https://github.com/apache/flink/pull/23594
--
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:
Pavel Khokhlov created FLINK-33401:
--
Summary: Kafka connector has broken version
Key: FLINK-33401
URL: https://issues.apache.org/jira/browse/FLINK-33401
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-18286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-18286:
Assignee: Dawid Wysakowicz (was: Francesco Guardiani)
> Implement type
dependabot[bot] opened a new pull request, #79:
URL: https://github.com/apache/flink-connector-elasticsearch/pull/79
Bumps
[org.elasticsearch:elasticsearch](https://github.com/elastic/elasticsearch)
from 7.10.2 to 7.17.13.
Release notes
Sourced from
RocMarshal closed pull request #22750: [FLINK-31757][runtime][scheduler]
Support balanced tasks scheduling.
URL: https://github.com/apache/flink/pull/22750
--
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
JunRuiLee commented on PR #23408:
URL: https://github.com/apache/flink/pull/23408#issuecomment-1785346603
@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
[
https://issues.apache.org/jira/browse/FLINK-4?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan closed FLINK-4.
-
> A number of json plan tests fail with comparisonfailure
>
[
https://issues.apache.org/jira/browse/FLINK-4?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan resolved FLINK-4.
---
Fix Version/s: 1.19.0
Resolution: Fixed
Fixed in master:
LadyForest merged PR #23562:
URL: https://github.com/apache/flink/pull/23562
--
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-32912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32912:
--
Description:
Once the release has been finalized (FLINK-32920), the last step of the process
[
https://issues.apache.org/jira/browse/FLINK-30768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-30768.
---
Resolution: Fixed
> flink-web version cleanup
> -
>
>
XComp merged PR #683:
URL: https://github.com/apache/flink-web/pull/683
--
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:
flinkbot commented on PR #23621:
URL: https://github.com/apache/flink/pull/23621#issuecomment-1785229315
## CI report:
* 779f3288aecfe99d43d850e94fe1d669312100dd UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33400:
---
Labels: pull-request-available (was: )
> Pulsar connector doesn't compile for Flink 1.18
MartijnVisser opened a new pull request, #62:
URL: https://github.com/apache/flink-connector-pulsar/pull/62
## Purpose of the change
* Add support for Flink 1.18
## Brief change log
* Let CI also test against Flink 1.18
* Added archunit violations that are reported
Martijn Visser created FLINK-33400:
--
Summary: Pulsar connector doesn't compile for Flink 1.18 due to
Archunit update
Key: FLINK-33400
URL: https://issues.apache.org/jira/browse/FLINK-33400
Project:
KarmaGYZ merged PR #23619:
URL: https://github.com/apache/flink/pull/23619
--
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:
flinkbot commented on PR #23620:
URL: https://github.com/apache/flink/pull/23620#issuecomment-1785043507
## CI report:
* 436d138830d46f2e81b99689067954e953636c83 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33395:
---
Labels: pull-request-available (was: )
> The join hint doesn't work when appears in
xuyangzhong opened a new pull request, #23620:
URL: https://github.com/apache/flink/pull/23620
## What is the purpose of the change
This pr try to fix that join hints should also be resolved and work when
defined in subquery.
## Brief change log
- *Modify the code in
xiangyuf commented on code in PR #23619:
URL: https://github.com/apache/flink/pull/23619#discussion_r1376075317
##
docs/content.zh/docs/dev/table/overview.md:
##
@@ -52,6 +52,7 @@ and later use the DataStream API to build alerting based on
the matched patterns
* [SQL]({{< ref
KarmaGYZ commented on code in PR #23619:
URL: https://github.com/apache/flink/pull/23619#discussion_r1376073257
##
docs/content.zh/docs/dev/table/overview.md:
##
@@ -52,6 +52,7 @@ and later use the DataStream API to build alerting based on
the matched patterns
* [SQL]({{< ref
xiangyuf commented on PR #23619:
URL: https://github.com/apache/flink/pull/23619#issuecomment-1785014318
@KarmaGYZ Pls review this 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
URL above to
liyubin117 commented on PR #78:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/78#issuecomment-1785012806
@MartijnVisser CI has succeed.
[https://github.com/liyubin117/flink-connector-elasticsearch/actions/runs/6692027990](url)
--
This is an automated message from
[
https://issues.apache.org/jira/browse/FLINK-33393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33393:
Fix Version/s: 1.19.0
(was: 1.17.1)
> flink document description error
>
[
https://issues.apache.org/jira/browse/FLINK-33393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-33393.
-
Resolution: Fixed
> flink document description error
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-33393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17780964#comment-17780964
]
Rui Fan commented on FLINK-33393:
-
Merged to master<1.19> via : 806147c3233a47eacaa630dca5fdfef83397ab31
1996fanrui merged PR #23618:
URL: https://github.com/apache/flink/pull/23618
--
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:
liyubin117 commented on code in PR #78:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/78#discussion_r1376042196
##
.github/workflows/weekly.yml:
##
@@ -35,12 +35,18 @@ jobs:
}, {
flink: 1.18-SNAPSHOT,
branch: main
+},
liyubin117 commented on code in PR #78:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/78#discussion_r1376042196
##
.github/workflows/weekly.yml:
##
@@ -35,12 +35,18 @@ jobs:
}, {
flink: 1.18-SNAPSHOT,
branch: main
+},
liyubin117 commented on code in PR #78:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/78#discussion_r1376042196
##
.github/workflows/weekly.yml:
##
@@ -35,12 +35,18 @@ jobs:
}, {
flink: 1.18-SNAPSHOT,
branch: main
+},
MartijnVisser commented on code in PR #78:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/78#discussion_r1376022350
##
.github/workflows/weekly.yml:
##
@@ -35,12 +35,18 @@ jobs:
}, {
flink: 1.18-SNAPSHOT,
branch: main
+
RocMarshal commented on code in PR #23589:
URL: https://github.com/apache/flink/pull/23589#discussion_r1376018673
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java:
##
@@ -795,6 +795,20 @@ public boolean isGraphContainingLoops() {
RocMarshal commented on code in PR #23589:
URL: https://github.com/apache/flink/pull/23589#discussion_r1376018673
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java:
##
@@ -795,6 +795,20 @@ public boolean isGraphContainingLoops() {
1996fanrui commented on code in PR #23599:
URL: https://github.com/apache/flink/pull/23599#discussion_r1376013241
##
flink-runtime/src/main/java/org/apache/flink/runtime/util/DefaultGroupCache.java:
##
@@ -0,0 +1,163 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
iemre commented on code in PR #110:
URL:
https://github.com/apache/flink-connector-aws/pull/110#discussion_r1376004352
##
flink-connector-aws/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtilTest.java:
##
@@ -1021,4
[
https://issues.apache.org/jira/browse/FLINK-30238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17780952#comment-17780952
]
Martijn Visser commented on FLINK-30238:
This ticket is pending to be closed, unless new
iemre commented on code in PR #110:
URL:
https://github.com/apache/flink-connector-aws/pull/110#discussion_r1376002503
##
docs/content.zh/docs/connectors/table/kinesis.md:
##
@@ -680,6 +680,14 @@ Connector Options
Long
The interval (in milliseconds) after which
[
https://issues.apache.org/jira/browse/FLINK-26624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-26624:
-
Assignee: xiang1 yu
> Running HA (hashmap, async) end-to-end test failed on azure due
[
https://issues.apache.org/jira/browse/FLINK-30768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-30768:
-
Assignee: xiang1 yu
> flink-web version cleanup
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-33011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33011:
Fix Version/s: kubernetes-operator-1.6.1
> Operator deletes HA data unexpectedly
>
[
https://issues.apache.org/jira/browse/FLINK-32868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-32868:
Fix Version/s: kubernetes-operator-1.7.0
kubernetes-operator-1.6.1
> Document the need
[
https://issues.apache.org/jira/browse/FLINK-32890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-32890:
Fix Version/s: kubernetes-operator-1.6.1
> Flink app rolled back with old savepoints (3 hours back in
Xuannan Su created FLINK-33399:
--
Summary: Support switching from batch to stream mode for
KeyedCoProcessOperator and IntervalJoinOperator
Key: FLINK-33399
URL: https://issues.apache.org/jira/browse/FLINK-33399
RocMarshal commented on code in PR #23599:
URL: https://github.com/apache/flink/pull/23599#discussion_r1375961136
##
flink-runtime/src/main/java/org/apache/flink/runtime/util/DefaultGroupCache.java:
##
@@ -0,0 +1,163 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
Xuannan Su created FLINK-33398:
--
Summary: Support switching from batch to stream mode for one input
stream operator
Key: FLINK-33398
URL: https://issues.apache.org/jira/browse/FLINK-33398
Project: Flink
zentol commented on PR #23594:
URL: https://github.com/apache/flink/pull/23594#issuecomment-1784893428
oh god what happened...
--
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
[
https://issues.apache.org/jira/browse/FLINK-33293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17780943#comment-17780943
]
Martijn Visser commented on FLINK-33293:
[~jredzepovic] Did you test 3.0.0-1.17?
> Data loss
1 - 100 of 207 matches
Mail list logo
