lvyanquan commented on code in PR #4111:
URL: https://github.com/apache/flink-cdc/pull/4111#discussion_r2352301310
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/oceanbase/OceanBaseCharsetITCase.java:
##
@
gaborgsomogyi commented on PR #26984:
URL: https://github.com/apache/flink/pull/26984#issuecomment-3284708612
@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 comm
RocMarshal created FLINK-38338:
--
Summary: Introduce the abstraction to describe a rescale event.
Key: FLINK-38338
URL: https://issues.apache.org/jira/browse/FLINK-38338
Project: Flink
Issue Type
gustavodemorais commented on code in PR #26966:
URL: https://github.com/apache/flink/pull/26966#discussion_r2344414825
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/JoinToMultiJoinRule.java:
##
@@ -723,6 +737,71 @@ private boo
Piotr Nowojski created FLINK-38353:
--
Summary: FLIP-483: Add support for children Spans
Key: FLINK-38353
URL: https://issues.apache.org/jira/browse/FLINK-38353
Project: Flink
Issue Type: New
yuanoOo opened a new pull request, #4124:
URL: https://github.com/apache/flink-cdc/pull/4124
## Description
Fixes SQL injection vulnerabilities in OceanBase connector's
`databaseExists` and `tableExists` methods by replacing string concatenation
with parameterized queries.
##
github-actions[bot] commented on PR #25410:
URL: https://github.com/apache/flink/pull/25410#issuecomment-3305600042
This PR is being marked as stale since it has not had any activity in the
last 90 days.
If you would like to keep this PR alive, please leave a comment asking for a
review
letaoj commented on code in PR #138:
URL: https://github.com/apache/flink-agents/pull/138#discussion_r2357363345
##
runtime/src/main/java/org/apache/flink/agents/runtime/operator/ActionExecutionOperator.java:
##
@@ -392,6 +447,71 @@ public void close() throws Exception {
letaoj commented on PR #138:
URL: https://github.com/apache/flink-agents/pull/138#issuecomment-3305197893
@Sxnan For the pruning logic, I implemented in a different way where I
remember the last seqNum that we did not find in the state map and for any
sequence that comes in for the same key
Zakelly opened a new pull request, #26971:
URL: https://github.com/apache/flink/pull/26971
## What is the purpose of the change
Currently, the file-merging manager’s recovery logic uses the Operator ID to
parse the destination directory, whereas the manager initialization uses the
Jo
letaoj commented on code in PR #138:
URL: https://github.com/apache/flink-agents/pull/138#discussion_r2352976072
##
api/src/main/java/org/apache/flink/agents/api/configuration/AgentConfigOptions.java:
##
@@ -23,4 +23,8 @@ public class AgentConfigOptions {
/** The config par
flinkbot commented on PR #26994:
URL: https://github.com/apache/flink/pull/26994#issuecomment-3298835755
## CI report:
* 82a273db40406c975510f274b0ff3991b476ac5c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-38375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaolong3817 updated FLINK-38375:
-
Priority: Critical (was: Major)
> Flink Resouce leak on Flink k8s
> ---
Liu created FLINK-38373:
---
Summary: Support dynamic index generation with field value suffix
Key: FLINK-38373
URL: https://issues.apache.org/jira/browse/FLINK-38373
Project: Flink
Issue Type: Improvemen
letaoj commented on code in PR #138:
URL: https://github.com/apache/flink-agents/pull/138#discussion_r2353872034
##
runtime/src/main/java/org/apache/flink/agents/runtime/operator/ActionExecutionOperator.java:
##
@@ -392,6 +440,29 @@ public void close() throws Exception {
letaoj commented on code in PR #138:
URL: https://github.com/apache/flink-agents/pull/138#discussion_r2350226001
##
runtime/src/main/java/org/apache/flink/agents/runtime/operator/ActionExecutionOperator.java:
##
@@ -301,20 +311,48 @@ private void processActionTaskForKey(Object k
[
https://issues.apache.org/jira/browse/FLINK-38375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaolong3817 updated FLINK-38375:
-
Description:
Hello, when using Flink on Kubernetes (K8s), we encountered an issue where
*TaskMa
[
https://issues.apache.org/jira/browse/FLINK-38375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaolong3817 updated FLINK-38375:
-
Description:
Hello, when using Flink on Kubernetes (K8s), we encountered an issue where
*TaskMa
[
https://issues.apache.org/jira/browse/FLINK-38375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaolong3817 updated FLINK-38375:
-
Description:
Hello, when using Flink on Kubernetes (K8s), we encountered an issue where
*TaskMa
[
https://issues.apache.org/jira/browse/FLINK-38375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaolong3817 updated FLINK-38375:
-
Affects Version/s: 1.20.2
Description:
Hello, when using Flink on Kubernetes (K8s), we
lvyanquan merged PR #3590:
URL: https://github.com/apache/flink-cdc/pull/3590
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.a
gaborgsomogyi opened a new pull request, #26984:
URL: https://github.com/apache/flink/pull/26984
## What is the purpose of the change
Since TTL migration has full support it's time to add documentation for
users. In this PR I've added that.
## Brief change log
Add state
xiaolong3817 created FLINK-38375:
Summary: Flink Resouce leak on Flink k8s
Key: FLINK-38375
URL: https://issues.apache.org/jira/browse/FLINK-38375
Project: Flink
Issue Type: Bug
Com
[
https://issues.apache.org/jira/browse/FLINK-38333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18021042#comment-18021042
]
RocMarshal commented on FLINK-38333:
*FYI:*
Since the design work of the query inter
[
https://issues.apache.org/jira/browse/FLINK-38333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-38333:
---
Summary: Umbrella: FLIP-495: Support AdaptiveScheduler record and store the
rescale history (was: U
GitHub user xintongsong edited a discussion: Time Plan for the first MVP
version of Flink Agents
We are targeting a MVP version of Flink Agents (0.1.0) in around end of
September. That is 16 weeks from now, and here is a rough time plan.
# Phase 1
- [x] Preparation
- [x] Build
- [x] CI (G
xintongsong closed issue #130: [Feature] support VectorStore and provide a
built-in Chroma implementation
URL: https://github.com/apache/flink-agents/issues/130
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
[
https://issues.apache.org/jira/browse/FLINK-38343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-38343:
---
Summary: Support store rescale history with statistics by
ExecutionGraphInfoStore. (was: Support st
GitHub user xintongsong edited a discussion: Time Plan for the first MVP
version of Flink Agents
We are targeting a MVP version of Flink Agents (0.1.0) in around end of
September. That is 16 weeks from now, and here is a rough time plan.
# Phase 1
- [x] Preparation
- [x] Build
- [x] CI (G
GitHub user xintongsong edited a discussion: Time Plan for the first MVP
version of Flink Agents
We are targeting a MVP version of Flink Agents (0.1.0) in around end of
September. That is 16 weeks from now, and here is a rough time plan.
# Phase 1
- [x] Preparation
- [x] Build
- [x] CI (G
lvyanquan commented on PR #3845:
URL: https://github.com/apache/flink-cdc/pull/3845#issuecomment-3305198667
Hi @ruanhang1993 could you take a look at this?
--
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
Sxnan commented on code in PR #138:
URL: https://github.com/apache/flink-agents/pull/138#discussion_r2357313522
##
runtime/src/main/java/org/apache/flink/agents/runtime/operator/ActionExecutionOperator.java:
##
@@ -392,6 +447,71 @@ public void close() throws Exception {
GreatEugenius commented on PR #177:
URL: https://github.com/apache/flink-agents/pull/177#issuecomment-3305133096
@Sxnan @wenjin272 I removed the name field from the resource. Please review
this PR. Thank you.
--
This is an automated message from the Apache Git Service.
To respond to the m
GreatEugenius commented on PR #169:
URL: https://github.com/apache/flink-agents/pull/169#issuecomment-3305130431
@Sxnan @wenjin272 please help take a look this PR, thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
GreatEugenius commented on PR #183:
URL: https://github.com/apache/flink-agents/pull/183#issuecomment-3305128795
@xuannan @wenjin272 please help take a look this PR, thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
GitHub user xintongsong edited a discussion: Time Plan for the first MVP
version of Flink Agents
We are targeting a MVP version of Flink Agents (0.1.0) in around end of
September. That is 16 weeks from now, and here is a rough time plan.
# Phase 1
- [x] Preparation
- [x] Build
- [x] CI (G
xintongsong merged PR #165:
URL: https://github.com/apache/flink-agents/pull/165
--
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...@flin
flinkbot commented on PR #26985:
URL: https://github.com/apache/flink/pull/26985#issuecomment-3285724631
## CI report:
* 5ae8b55ac84fd6862c7d9429ad352d4b5d1b99ea UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
lvyanquan commented on code in PR #3845:
URL: https://github.com/apache/flink-cdc/pull/3845#discussion_r2357280751
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/GtidUtils.java:
##
@@ -36,36 +38,64 @@ public c
echauchot opened a new pull request, #50:
URL: https://github.com/apache/flink-connector-shared-utils/pull/50
Replace very slow https://archive.apache.org/ by ASF infra recommended
https://dlcdn.apache.org/ to download Flink release for connectors to test
against.
The job still allow
Dawid Wysakowicz created FLINK-38356:
Summary: Regenerating files for
WATERMARK_ASSIGNER_PUSHDOWN_METADATA hangs
Key: FLINK-38356
URL: https://issues.apache.org/jira/browse/FLINK-38356
Project: Fl
davidradl commented on code in PR #26967:
URL: https://github.com/apache/flink/pull/26967#discussion_r2335940189
##
.github/workflows/community-review.sh:
##
@@ -352,6 +415,37 @@ call_github_graphql_api() {
"https://api.github.com/graphql";
}
+# =
echauchot commented on code in PR #35:
URL:
https://github.com/apache/flink-connector-cassandra/pull/35#discussion_r2348451229
##
flink-connector-cassandra/src/test/java/org/apache/flink/connector/cassandra/table/CassandraDynamicTableSourceITCase.java:
##
@@ -0,0 +1,1520 @@
+/*
lvyanquan opened a new pull request, #4123:
URL: https://github.com/apache/flink-cdc/pull/4123
Fix potential sql connection statement issue.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the sp
xintongsong merged PR #184:
URL: https://github.com/apache/flink-agents/pull/184
--
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...@flin
Sxnan merged PR #158:
URL: https://github.com/apache/flink-agents/pull/158
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apac
Sxnan commented on PR #158:
URL: https://github.com/apache/flink-agents/pull/158#issuecomment-3305093023
Conflict resolved, merging...
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific
GitHub user xintongsong edited a discussion: Community Sync
There's a community sync for discussing developing progress, technical designs
and community issues about Flink Agents.
Everyone is welcome to join.
* Schedule: 3am Wed UTC
* [Google
Calendar](https://calendar.google.com/calendar/u/
flinkbot commented on PR #27000:
URL: https://github.com/apache/flink/pull/27000#issuecomment-3304683814
## CI report:
* a6cae270310078d464475fcfdb276965fd4d8b14 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-38374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18020990#comment-18020990
]
Zander Matheson commented on FLINK-38374:
-
Current PR https://github.com/apache/
[ https://issues.apache.org/jira/browse/FLINK-38374 ]
Zander Matheson deleted comment on FLINK-38374:
-
was (Author: JIRAUSER309602):
Current PR https://github.com/apache/flink/pull/27000
> Add Artifact keyword as an option to create functio
[
https://issues.apache.org/jira/browse/FLINK-38374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-38374:
---
Labels: pull-request-available (was: )
> Add Artifact keyword as an option to create functi
awmatheson opened a new pull request, #27000:
URL: https://github.com/apache/flink/pull/27000
## Contribution Checklist
- Make sure that the change passes the automated tests, i.e., `mvn clean
verify` passes. You can set up Azure Pipelines CI to do that following [this
guide]
snuyanzin merged PR #26963:
URL: https://github.com/apache/flink/pull/26963
--
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.apa
gguptp commented on PR #202:
URL:
https://github.com/apache/flink-connector-aws/pull/202#issuecomment-3281323407
> Hi @tcerda95 ! Great to hear from you and thanks for the interest! The PR
is currently still being reviewed, and it would accelerate this PR if you could
take a look at this P
Shangshu Qian created FLINK-38367:
-
Summary: Potential Feedback Loop Between IterationHeadTask and
SynchronizationSinkTask
Key: FLINK-38367
URL: https://issues.apache.org/jira/browse/FLINK-38367
Proje
wenjin272 commented on PR #150:
URL: https://github.com/apache/flink-agents/pull/150#issuecomment-3279544032
LGTM cc @xintongsong
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific com
davidradl commented on code in PR #26977:
URL: https://github.com/apache/flink/pull/26977#discussion_r2339199136
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -990,7 +990,7 @@ void decreaseRefCountWhenCh
Zander Matheson created FLINK-38374:
---
Summary: Add Artifact keyword as an option to create function
syntax
Key: FLINK-38374
URL: https://issues.apache.org/jira/browse/FLINK-38374
Project: Flink
GitHub user xintongsong edited a discussion: Time Plan for the first MVP
version of Flink Agents
We are targeting a MVP version of Flink Agents (0.1.0) in around end of
September. That is 16 weeks from now, and here is a rough time plan.
# Phase 1
- [x] Preparation
- [x] Build
- [x] CI (G
[
https://issues.apache.org/jira/browse/FLINK-38365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-38365:
---
Labels: pull-request-available (was: )
> ClassCastException while different operations with
snuyanzin commented on code in PR #26990:
URL: https://github.com/apache/flink/pull/26990#discussion_r2352111343
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/api/internal/ShowCreateUtilTest.java:
##
@@ -272,27 +280,27 @@ private static Collection
arg
[
https://issues.apache.org/jira/browse/FLINK-38344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-38344:
---
Attachment: image-2025-09-11-00-34-54-580.png
> The local files of the HistoryServer may risk never
[
https://issues.apache.org/jira/browse/FLINK-38331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yisha zhou updated FLINK-38331:
---
Description:
In web ui, if hash keys of hash edges can be displayed like pic. below, it will
be muc
[
https://issues.apache.org/jira/browse/FLINK-35725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35725:
---
Fix Version/s: 2.1.0
> Translate new DISTRIBUTED BY documentation into Chinese
> ---
flinkbot commented on PR #26980:
URL: https://github.com/apache/flink/pull/26980#issuecomment-3281414049
## CI report:
* 133807d0b48139c7f417125c29553c7a840b89f3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-38332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-38332.
---
Resolution: Fixed
> Upgrade pemja to 0.5.5
> --
>
> Key: FLINK-38332
>
dianfu merged PR #26996:
URL: https://github.com/apache/flink/pull/26996
--
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
[
https://issues.apache.org/jira/browse/FLINK-38366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ahmad Humayun updated FLINK-38366:
--
Description:
The following is a minimized program that causes an exception in the planner
snuyanzin commented on PR #26990:
URL: https://github.com/apache/flink/pull/26990#issuecomment-3299665866
@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.
CatOrLeader commented on PR #4071:
URL: https://github.com/apache/flink-cdc/pull/4071#issuecomment-3302242100
Hello, @lvyanquan! Let me explain a little bit of the rationale behind this:
for the engineer, it is common sense to structure the environment he is working
in, so there occur situa
rkhachatryan commented on PR #26888:
URL: https://github.com/apache/flink/pull/26888#issuecomment-3304222688
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comme
[
https://issues.apache.org/jira/browse/FLINK-36735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-36735:
---
Fix Version/s: 1.20.4
(was: 1.20.3)
> SupportsRowLevelUpdate gives sink only
[
https://issues.apache.org/jira/browse/FLINK-38360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18020850#comment-18020850
]
Ruan Hang commented on FLINK-38360:
---
https://dev.azure.com/apache-flink/apache-flink/_
ferenc-csaky commented on code in PR #26967:
URL: https://github.com/apache/flink/pull/26967#discussion_r2334124425
##
.github/workflows/community-review.sh:
##
@@ -352,6 +415,37 @@ call_github_graphql_api() {
"https://api.github.com/graphql";
}
+# ==
davidradl commented on code in PR #26981:
URL: https://github.com/apache/flink/pull/26981#discussion_r2343607037
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Finished.java:
##
@@ -34,13 +35,21 @@ class Finished implements State {
private fina
Zakelly merged PR #26968:
URL: https://github.com/apache/flink/pull/26968
--
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.apach
[
https://issues.apache.org/jira/browse/FLINK-38357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xinglong Wang updated FLINK-38357:
--
Description:
h2. Problem
StreamTask:
{code:java}
map -> (filter -> Sink: sink-r, map-q)
{cod
echauchot commented on code in PR #35:
URL:
https://github.com/apache/flink-connector-cassandra/pull/35#discussion_r2348395114
##
flink-connector-cassandra/src/test/java/org/apache/flink/connector/cassandra/table/mapper/CassandraFieldMapperFactoryTest.java:
##
@@ -0,0 +1,300 @@
[
https://issues.apache.org/jira/browse/FLINK-38344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-38344:
---
Attachment: image-2025-09-11-00-31-26-595.png
> The local files of the HistoryServer may risk never
davidradl commented on code in PR #26984:
URL: https://github.com/apache/flink/pull/26984#discussion_r2343891120
##
docs/content/docs/dev/datastream/fault-tolerance/state.md:
##
@@ -542,6 +542,15 @@ where at least the first element has expired to determine
the offset of the nex
snuyanzin commented on code in PR #26866:
URL: https://github.com/apache/flink/pull/26866#discussion_r2344090073
##
flink-end-to-end-tests/README.md:
##
@@ -5,6 +5,11 @@ This module contains tests that verify end-to-end behaviour of
Flink.
The tests defined in `run-nightly-tes
MartijnVisser closed pull request #26989: now issue is resolved
URL: https://github.com/apache/flink/pull/26989
--
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,
letaoj commented on code in PR #138:
URL: https://github.com/apache/flink-agents/pull/138#discussion_r2352972513
##
api/src/main/java/org/apache/flink/agents/api/configuration/AgentConfigOptions.java:
##
@@ -23,4 +23,8 @@ public class AgentConfigOptions {
/** The config par
Sergey Nuyanzin created FLINK-38365:
---
Summary: ClassCastException while different operations with
MATERIALIZED TABLE
Key: FLINK-38365
URL: https://issues.apache.org/jira/browse/FLINK-38365
Project:
yuxiqian commented on code in PR #3590:
URL: https://github.com/apache/flink-cdc/pull/3590#discussion_r2354519364
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/test/java/org/apache/flink/cdc/connectors/mysql/source/MySqlPipelineITCase.java:
##
[
https://issues.apache.org/jira/browse/FLINK-38372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-38372:
---
Labels: pull-request-available (was: )
> Introduces whitelist to the flink-metrics-promethe
charlesdong1991 commented on code in PR #26987:
URL: https://github.com/apache/flink/pull/26987#discussion_r2354546771
##
flink-python/pyflink/table/tests/test_expression.py:
##
@@ -295,6 +295,12 @@ def test_expressions(self):
self.assertEqual("TO_TIMESTAMP_LTZ('2023-01
rkhachatryan commented on code in PR #26888:
URL: https://github.com/apache/flink/pull/26888#discussion_r2355360877
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/MiscSemanticTests.java:
##
@@ -31,6 +32,7 @@ public class Mi
rkhachatryan commented on code in PR #26888:
URL: https://github.com/apache/flink/pull/26888#discussion_r2355361655
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/JoinTestPrograms.java:
##
@@ -41,6 +45,63 @@ public class Jo
[
https://issues.apache.org/jira/browse/FLINK-36609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-36609:
---
Fix Version/s: 1.20.4
(was: 1.20.3)
> Protobuf Format not support proto3
> --
schongloo opened a new pull request, #969:
URL: https://github.com/apache/flink-kubernetes-operator/pull/969
## What is the purpose of the change
This pull request adds basic support for Blue/Green deployments as outlined
by FLIP-503
(https://cwiki.apache.org/confluence/pages
jnh5y commented on PR #189:
URL:
https://github.com/apache/flink-connector-kafka/pull/189#issuecomment-3299027027
As a high-level note, since share groups do not use transactions, there will
be some possibility for reprocessing messages. Is that ok for your use cases?
Generally, do
[
https://issues.apache.org/jira/browse/FLINK-36010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-36010:
---
Fix Version/s: 1.20.4
(was: 1.20.3)
> Duplicate Job Submission returns Succee
Poorvankbhatia commented on PR #37:
URL:
https://github.com/apache/flink-connector-cassandra/pull/37#issuecomment-3303813865
> > > > @Poorvankbhatia I have the impression that there is a build result
cache issue on github. The build is not finished but the previous built is
printed on scre
schongloo closed pull request #969: [FLINK-37515] Basic support for Blue/Green
deployments
URL: https://github.com/apache/flink-kubernetes-operator/pull/969
--
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
Maximilian Michels created FLINK-38370:
--
Summary: CommitterOperator does not checkpoint all pending
committables
Key: FLINK-38370
URL: https://issues.apache.org/jira/browse/FLINK-38370
Project: F
[
https://issues.apache.org/jira/browse/FLINK-38223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18020880#comment-18020880
]
Piotr Nowojski commented on FLINK-38223:
Another instance
https://dev.azure.com/
[
https://issues.apache.org/jira/browse/FLINK-38350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-38350:
---
Fix Version/s: 1.20.4
(was: 1.20.3)
> Update Hadoop Library to 3.4.2
> --
[
https://issues.apache.org/jira/browse/FLINK-36113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuannan Su updated FLINK-36113:
---
Fix Version/s: 1.20.4
(was: 1.20.3)
> Condition 'transform instanceof Physica
1 - 100 of 163 matches
Mail list logo
