gaborgsomogyi commented on code in PR #26977:
URL: https://github.com/apache/flink/pull/26977#discussion_r2338978975
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -955,13 +955,13 @@ boolean isCheckpointD
[
https://issues.apache.org/jira/browse/FLINK-38348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuo Cheng closed FLINK-38348.
--
Resolution: Won't Fix
> Fix flushing issue for append write with buffer sort and bounded source
>
gaborgsomogyi commented on code in PR #26977:
URL: https://github.com/apache/flink/pull/26977#discussion_r2338889086
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -955,13 +955,13 @@ boolean isCheckpointD
[
https://issues.apache.org/jira/browse/FLINK-38347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18019505#comment-18019505
]
Gabor Somogyi commented on FLINK-38347:
---
Ah, just see the PR opened 4 minutes ago.
[
https://issues.apache.org/jira/browse/FLINK-38347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18019504#comment-18019504
]
Gabor Somogyi commented on FLINK-38347:
---
What is the plan here? I mean complete no
[
https://issues.apache.org/jira/browse/FLINK-38347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-38347:
---
Labels: pull-request-available (was: )
> Checkpoint file-merging manager may delete the dir
wenjin272 commented on PR #107:
URL: https://github.com/apache/flink-agents/pull/107#issuecomment-3278370520
Hi, @yanand0909, thanks for your contribution.
I see you have updated the pr and address most comments, but I think there
may be still some implementation details to be clarified.
[
https://issues.apache.org/jira/browse/FLINK-38347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18019499#comment-18019499
]
Zakelly Lan commented on FLINK-38347:
-
Problematic steps:
# Job start
# The first
github-actions[bot] commented on PR #3991:
URL: https://github.com/apache/flink-cdc/pull/3991#issuecomment-3276925115
This pull request has been automatically marked as stale because it has not
had recent activity for 120 days. It will be closed in 60 days if no further
activity occurs.
-
Zakelly Lan created FLINK-38347:
---
Summary: Checkpoint file-merging manager may delete the directory
unexpectedly when some RPC messages lost
Key: FLINK-38347
URL: https://issues.apache.org/jira/browse/FLINK-38347
Matt Cuento created FLINK-38345:
---
Summary: HybridSource checkpoint recovery results in NPE if
addSource depends on previousEnumerator from SourceSwitchContext
Key: FLINK-38345
URL: https://issues.apache.org/jira/bro
xintongsong commented on code in PR #150:
URL: https://github.com/apache/flink-agents/pull/150#discussion_r2338378062
##
python/flink_agents/api/embedding_models/embedding_model.py:
##
@@ -0,0 +1,107 @@
+###
yuxiqian commented on code in PR #4101:
URL: https://github.com/apache/flink-cdc/pull/4101#discussion_r2338390820
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/external/IncrementalSourceScanFetcher.java:
[
https://issues.apache.org/jira/browse/FLINK-38344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-38344:
---
Description:
When the {{{}historyserver.web.tmpdir{}}}configuration points to a non-system
temporar
GreatEugenius commented on PR #155:
URL: https://github.com/apache/flink-agents/pull/155#issuecomment-3277203230
@Sxnan 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 use the
URL a
Sxnan opened a new pull request, #158:
URL: https://github.com/apache/flink-agents/pull/158
### Purpose of change
This PR introduces a comprehensive quickstart workflow for Flink Agents with
practical examples demonstrating how to integrate LLM-powered agents with Flink
streaming pip
twosom opened a new issue, #156:
URL: https://github.com/apache/flink-agents/issues/156
### Search before asking
- [x] I searched in the
[issues](https://github.com/apache/flink-agents/issues) and found nothing
similar.
### Description
## Summary
Add a new `integrati
[
https://issues.apache.org/jira/browse/FLINK-38344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-38344:
---
Labels: pull-request-available (was: )
> The local files of the HistoryServer may risk neve
[
https://issues.apache.org/jira/browse/FLINK-38346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dylanhz closed FLINK-38346.
---
Resolution: Invalid
> JSON_QUERY returns ARRAY of incorrect format
> ---
twosom opened a new issue, #157:
URL: https://github.com/apache/flink-agents/issues/157
### Search before asking
- [x] I searched in the
[issues](https://github.com/apache/flink-agents/issues) and found nothing
similar.
### Description
## Summary
Add support for Olla
GreatEugenius opened a new pull request, #155:
URL: https://github.com/apache/flink-agents/pull/155
Linked issue: #154
### Purpose of change
Set up Flink Agents Document Website.
### Tests
### API
### Documentation
GreatEugenius opened a new issue, #154:
URL: https://github.com/apache/flink-agents/issues/154
### Search before asking
- [x] I searched in the
[issues](https://github.com/apache/flink-agents/issues) and found nothing
similar.
### Description
Set up Flink Agents Documen
[
https://issues.apache.org/jira/browse/FLINK-38346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18019484#comment-18019484
]
dylanhz commented on FLINK-38346:
-
I Just noticed that this issue had been fixed in
[FL
RocMarshal opened a new pull request, #26976:
URL: https://github.com/apache/flink/pull/26976
## What is the purpose of the change
Fix the bug that The local files of the HistoryServer may risk never being
deleted.
## Brief change log
In the HistoryServer
[
https://issues.apache.org/jira/browse/FLINK-38346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dylanhz updated FLINK-38346:
Component/s: Table SQL / API
> JSON_QUERY returns ARRAY of incorrect format
>
[
https://issues.apache.org/jira/browse/FLINK-38346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dylanhz updated FLINK-38346:
Summary: JSON_QUERY returns ARRAY of incorrect format (was:
JSON_QUERY returns ARRAY)
> JSON_QUERY retur
[
https://issues.apache.org/jira/browse/FLINK-38346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dylanhz updated FLINK-38346:
Description:
{code:sql}
SELECT JSON_QUERY('[{"c":"c1"},{"c":"c2"}]', '$')
-- '[{"c":"c1"},{"c":"c2"}]'
SE
[
https://issues.apache.org/jira/browse/FLINK-38346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dylanhz updated FLINK-38346:
Description:
{code:sql}
SELECT JSON_QUERY('[{"c":"c1"},{"c":"c2"}]', '$')
-- '[{"c":"c1"},{"c":"c2"}]'
SE
lvyanquan commented on PR #4115:
URL: https://github.com/apache/flink-cdc/pull/4115#issuecomment-3277098856
Please add more description about this change.
--
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 t
flinkbot commented on PR #26976:
URL: https://github.com/apache/flink/pull/26976#issuecomment-3277087496
## CI report:
* 7be287df626f6c402aedccc57c34e2946d89bbe8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dylanhz created FLINK-38346:
---
Summary: JSON_QUERY returns ARRAY
Key: FLINK-38346
URL: https://issues.apache.org/jira/browse/FLINK-38346
Project: Flink
Issue Type: Bug
Reporter: dylanhz
[
https://issues.apache.org/jira/browse/FLINK-38330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vikasap updated FLINK-38330:
Priority: Minor (was: Major)
> Updating state-size in status increases the number of 409's to K8s
> -
mattcuento opened a new pull request, #26975:
URL: https://github.com/apache/flink/pull/26975
## What is the purpose of the change
*Adding a unit test to replicate a failure to recover enumerator state in
the `HybridSourceSplitEnumerator` after checkpoint recovery where the
u
[
https://issues.apache.org/jira/browse/FLINK-38345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matt Cuento updated FLINK-38345:
Description:
{{org.apache.flink.connector.base.source.hybrid.HybridSource}} upon recovery
from a
[
https://issues.apache.org/jira/browse/FLINK-38345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matt Cuento updated FLINK-38345:
Labels: (was: pull-request-available)
> HybridSource checkpoint recovery results in NPE if addSo
flinkbot commented on PR #26975:
URL: https://github.com/apache/flink/pull/26975#issuecomment-3276654360
## CI report:
* 2d677649ff24503a2f1d14e7814d444a4aea4f5c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-38345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-38345:
---
Labels: pull-request-available (was: )
> HybridSource checkpoint recovery results in NPE if
xintongsong commented on code in PR #138:
URL: https://github.com/apache/flink-agents/pull/138#discussion_r2336508433
##
runtime/src/main/java/org/apache/flink/agents/runtime/operator/ActionExecutionOperator.java:
##
@@ -138,6 +145,7 @@ public ActionExecutionOperator(
t
Zakelly Lan created FLINK-38336:
---
Summary: Unexpected data copy during failover for ForSt
statebackend
Key: FLINK-38336
URL: https://issues.apache.org/jira/browse/FLINK-38336
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-38344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-38344:
---
Description:
When the {{{}historyserver.web.tmpdir{}}}configuration points to a non-system
temporar
xintongsong opened a new issue, #151:
URL: https://github.com/apache/flink-agents/issues/151
### Search before asking
- [x] I searched in the
[issues](https://github.com/apache/flink-agents/issues) and found nothing
similar.
### Description
Design doc: #108
###
mateczagany opened a new pull request, #57:
URL: https://github.com/apache/flink-connector-hbase/pull/57
- I have kept the previous configurations, deprecated them and mapped them
to the async configurations in `HBase2DynamicTableFactory`
- I had to add `SerializableMutation` because `Mut
[
https://issues.apache.org/jira/browse/FLINK-35280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35280:
---
Labels: pull-request-available (was: )
> Migrate HBase Sink connector to use the ASync Sink
[
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-32-25-793.png
> The local files of the HistoryServer may risk never
[
https://issues.apache.org/jira/browse/FLINK-37245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-37245:
---
Affects Version/s: 2.0.0
> RowData#createFieldGetter can resurrect null values for n
RocMarshal created FLINK-38341:
--
Summary: Introduce the rescale history configuration option.
Key: FLINK-38341
URL: https://issues.apache.org/jira/browse/FLINK-38341
Project: Flink
Issue Type: S
[
https://issues.apache.org/jira/browse/FLINK-38341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-38341:
---
Component/s: Runtime / Configuration
(was: Runtime / Coordination)
> Introduce
[
https://issues.apache.org/jira/browse/FLINK-38331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18019369#comment-18019369
]
Rion Williams edited comment on FLINK-38331 at 9/10/25 2:47 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-37417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18019372#comment-18019372
]
Lorenzo Nicora commented on FLINK-37417:
[~hong] this should have component = `C
RocMarshal created FLINK-38342:
--
Summary: Support record rescale information
Key: FLINK-38342
URL: https://issues.apache.org/jira/browse/FLINK-38342
Project: Flink
Issue Type: Sub-task
RocMarshal created FLINK-38340:
--
Summary: Introduce the rescale timeline related abstraction for
performing rescale operations
Key: FLINK-38340
URL: https://issues.apache.org/jira/browse/FLINK-38340
Proj
[
https://issues.apache.org/jira/browse/FLINK-38331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18019369#comment-18019369
]
Rion Williams commented on FLINK-38331:
---
I'd be interested in taking on this work.
scottf commented on PR #26909:
URL: https://github.com/apache/flink/pull/26909#issuecomment-3275099575
Added Jira for Chinese translation
https://issues.apache.org/jira/browse/FLINK-38337
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
Scott Fauerbach created FLINK-38337:
---
Summary: Chinese translation for document PR
Key: FLINK-38337
URL: https://issues.apache.org/jira/browse/FLINK-38337
Project: Flink
Issue Type: Improve
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 opened a new issue, #152:
URL: https://github.com/apache/flink-agents/issues/152
### Search before asking
- [x] I searched in the
[issues](https://github.com/apache/flink-agents/issues) and found nothing
similar.
### Description
ntroduce ActionState related
xintongsong merged PR #94:
URL: https://github.com/apache/flink-agents/pull/94
--
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.
mxm commented on code in PR #1023:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1023#discussion_r2336365366
##
pom.xml:
##
@@ -281,13 +281,13 @@ under the License.
org.apache.maven.plugins
maven-checkstyle-plugin
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/
[
https://issues.apache.org/jira/browse/FLINK-37245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-37245.
--
Additional tests for FieldGetters added via
5ad464d8156b5094e0aba7712e4aa22b9f44e84d.
>
mxm commented on PR #26100:
URL: https://github.com/apache/flink/pull/26100#issuecomment-3274450686
Thanks for the review @ferenc-csaky @davidradl @lincoln-lil!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL a
mxm closed pull request #26100: [FLINK-37245] Add tests for FieldGetters to
test null value handling in BinaryRowData
URL: https://github.com/apache/flink/pull/26100
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
Zakelly merged PR #26972:
URL: https://github.com/apache/flink/pull/26972
--
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-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Feifan Wang updated FLINK-23886:
Affects Version/s: 1.12.2
> An exception is thrown out when recover job timers from checkpoint fil
echauchot commented on PR #37:
URL:
https://github.com/apache/flink-connector-cassandra/pull/37#issuecomment-3274300724
> > It still doesn't work on my machine somehow 😅. But I think the CI is
green, so that is good. Thank you for resolving the comments. LGTM.
>
> Regarding the CI: O
mxm commented on PR #26100:
URL: https://github.com/apache/flink/pull/26100#issuecomment-3274229017
@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 u
[
https://issues.apache.org/jira/browse/FLINK-37245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18019323#comment-18019323
]
Maximilian Michels commented on FLINK-37245:
FLINK-37643 fixed this issue.
[
https://issues.apache.org/jira/browse/FLINK-38335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-38335:
--
Description:
SplitEnumeratorContext natively only supports fixed rate scheduling for
asynchro
Hongshun Wang created FLINK-38335:
-
Summary: SplitEnumeratorContext supports fixed delay async call.
Key: FLINK-38335
URL: https://issues.apache.org/jira/browse/FLINK-38335
Project: Flink
Iss
xintongsong commented on PR #94:
URL: https://github.com/apache/flink-agents/pull/94#issuecomment-3273950204
Hi @AmenAdem,
@wenjin272 and I have updated the PR, based on the work you have already
completed, and addressed the remaining comments.
Sorry we had to take over like th
[
https://issues.apache.org/jira/browse/FLINK-38315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18019301#comment-18019301
]
Zakelly Lan commented on FLINK-38315:
-
At first glance, there appears to be a valid
71 matches
Mail list logo
