wenjin272 commented on code in PR #121:
URL: https://github.com/apache/flink-agents/pull/121#discussion_r2289988461
##
python/flink_agents/integrations/chat_models/tongyi_chat_model.py:
##
@@ -0,0 +1,246 @@
+###
github-actions[bot] commented on PR #26558:
URL: https://github.com/apache/flink/pull/26558#issuecomment-3209164974
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
xiangforever2014 commented on code in PR #26925:
URL: https://github.com/apache/flink/pull/26925#discussion_r2289975893
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/RoundRobinOperatorStateRepartitioner.java:
##
@@ -488,13 +489,16 @@ private static final cla
xiangforever2014 commented on code in PR #26925:
URL: https://github.com/apache/flink/pull/26925#discussion_r2289975893
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/RoundRobinOperatorStateRepartitioner.java:
##
@@ -488,13 +489,16 @@ private static final cla
wenjin272 commented on code in PR #126:
URL: https://github.com/apache/flink-agents/pull/126#discussion_r2289958467
##
python/flink_agents/api/agents/react_agent.py:
##
@@ -0,0 +1,75 @@
+
+# License
wenjin272 commented on PR #126:
URL: https://github.com/apache/flink-agents/pull/126#issuecomment-3209140161
One point that has been on my mind is whether we should implicitly inject
built-in actions into all types of Agents, including user-defined ones. My
concern is that this might reduce
wenjin272 opened a new pull request, #126:
URL: https://github.com/apache/flink-agents/pull/126
Linked issue: #57
### Purpose of change
Introduce built-in ReAct Agent.
### Tests
No
### API
Yes, provide ReActAgent
### Documentation
No
gyfora commented on code in PR #686:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/686#discussion_r2289950705
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/metrics/ScalingMetrics.java:
##
@@ -78,6 +88,45 @@ public static void computeDataRateMetri
xintongsong merged PR #124:
URL: https://github.com/apache/flink-agents/pull/124
--
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
GreatEugenius commented on code in PR #122:
URL: https://github.com/apache/flink-agents/pull/122#discussion_r2289920589
##
python/requirements/test_requirements.txt:
##
@@ -17,3 +17,4 @@ setuptools>=75.3
pytest==8.4.0
pydantic==2.11.4
apache-flink==1.20.1
+pyyaml==6.0.2
Revi
GreatEugenius opened a new issue, #125:
URL: https://github.com/apache/flink-agents/issues/125
### Search before asking
- [x] I searched in the
[issues](https://github.com/apache/flink-agents/issues) and found nothing
similar.
### Description
We currently maintain two s
[
https://issues.apache.org/jira/browse/FLINK-38226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ejaskhan updated FLINK-38226:
-
Labels: kafka (was: kaf)
> Kafka Sink Improvement: Add failOnError to Control Exception Behavior
>
Zakelly commented on code in PR #26925:
URL: https://github.com/apache/flink/pull/26925#discussion_r2289843029
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/RoundRobinOperatorStateRepartitioner.java:
##
@@ -488,13 +489,16 @@ private static final class GroupB
qining-mj commented on PR #26932:
URL: https://github.com/apache/flink/pull/26932#issuecomment-3208814553
@davidradl Teacher David Radl, I have optimized and tested the code. Please
review it again. Thank you for your guidance.
--
This is an automated message from the Apache Git Service.
github-actions[bot] commented on PR #3865:
URL: https://github.com/apache/flink-cdc/pull/3865#issuecomment-3208498999
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.
-
github-actions[bot] commented on PR #3983:
URL: https://github.com/apache/flink-cdc/pull/3983#issuecomment-3208498866
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.
-
github-actions[bot] commented on PR #3999:
URL: https://github.com/apache/flink-cdc/pull/3999#issuecomment-3208498812
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.
-
schongloo commented on PR #969:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/969#issuecomment-3208124504
@davidradl thank you for all your feedback. The past few weeks I was focused
on mostly the high level refactoring, I'll address your comments ASAP.
--
This is an auto
sharath1709 commented on code in PR #686:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/686#discussion_r2289296770
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/metrics/ScalingMetrics.java:
##
@@ -78,6 +88,45 @@ public static void computeDataRate
sharath1709 commented on code in PR #686:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/686#discussion_r2289296770
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/metrics/ScalingMetrics.java:
##
@@ -78,6 +88,45 @@ public static void computeDataRate
sharath1709 commented on code in PR #686:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/686#discussion_r2289296770
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/metrics/ScalingMetrics.java:
##
@@ -78,6 +88,45 @@ public static void computeDataRate
qining-mj closed pull request #26932: [models] support deepseek、qwen
URL: https://github.com/apache/flink/pull/26932
--
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 unsubscr
[
https://issues.apache.org/jira/browse/FLINK-38267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-38267:
Description:
h1. 1. Phenomenon:
Job cannot be recovered from UC(unaligned checkpoint) after rescaling, an
alnzng commented on code in PR #122:
URL: https://github.com/apache/flink-agents/pull/122#discussion_r2288994582
##
python/flink_agents/api/core_options.py:
##
@@ -0,0 +1,52 @@
+
+# Licensed to the
flinkbot commented on PR #26932:
URL: https://github.com/apache/flink/pull/26932#issuecomment-3207106779
## CI report:
* 3d5de3807cb803a56ff249324590131a81377811 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
qining-mj opened a new pull request, #26932:
URL: https://github.com/apache/flink/pull/26932
## What is the purpose of the change
This PR adds an implementation to Flink's Model API. This implementation
achieves prediction and inference by invoking DeepSeek APIs based on its O
qining-mj closed pull request #26930: [models] support deepseek、qwen
URL: https://github.com/apache/flink/pull/26930
--
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 unsubscr
fapaul commented on PR #49:
URL:
https://github.com/apache/flink-connector-shared-utils/pull/49#issuecomment-3206637731
Can you add a ticket number to the PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
AHeise opened a new pull request, #49:
URL: https://github.com/apache/flink-connector-shared-utils/pull/49
(no comment)
--
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
csviri opened a new pull request, #1015:
URL: https://github.com/apache/flink-kubernetes-operator/pull/1015
## What is the purpose of the change
Update samples to use yaml based configs instead of key/value pairs
## Brief change log
Updates samples
Such change is a
fapaul merged PR #26854:
URL: https://github.com/apache/flink/pull/26854
--
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
fapaul commented on code in PR #26846:
URL: https://github.com/apache/flink/pull/26846#discussion_r2288221116
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecSinkITCase.java:
##
@@ -584,34 +590,44 @@ private TestSo
flinkbot commented on PR #26931:
URL: https://github.com/apache/flink/pull/26931#issuecomment-3206235890
## CI report:
* 7c7e301582b0a7e84a06e5f460c1fee9bca98899 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-38267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-38267:
---
Labels: pull-request-available (was: )
> Job cannot be recovered from unaligned checkpoint
1996fanrui opened a new pull request, #26931:
URL: https://github.com/apache/flink/pull/26931
## What is the purpose of the change
Job cannot be recovered from UC(unaligned checkpoint) after rescaling, and
the exception is:
```
java.lang.UnsupportedOperationException: Cannot
Mrart commented on PR #4042:
URL: https://github.com/apache/flink-cdc/pull/4042#issuecomment-3206155936
@iundarigun Can you update the code and add tests case for postgres
pipeline to cover this？
--
This is an automated message from the Apache Git Service.
To respond to the message, plea
[
https://issues.apache.org/jira/browse/FLINK-38232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
suhwan updated FLINK-38232:
---
Summary: [docs] updates the connector documentation to reflect the new
features in Flink CDC 3.4.0 (was: [d
[
https://issues.apache.org/jira/browse/FLINK-38232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-38232:
---
Labels: pull-request-available (was: )
> [docs] Update “Pipeline Connectors > Overview” to
suhwan-cheon opened a new pull request, #4102:
URL: https://github.com/apache/flink-cdc/pull/4102
issue: https://issues.apache.org/jira/browse/FLINK-38232
This commit updates the connector documentation to reflect the new features
in Flink CDC 3.4.0
New connectors added
---
[
https://issues.apache.org/jira/browse/FLINK-37959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanquan Lv resolved FLINK-37959.
Fix Version/s: cdc-3.5.0
Resolution: Fixed
Fixed in master via 0842feea189e456a04cad0dfc2e3
lvyanquan merged PR #4086:
URL: https://github.com/apache/flink-cdc/pull/4086
--
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
csviri commented on code in PR #1013:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1013#discussion_r2287881779
##
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/ConfigObjectNode.java:
##
@@ -0,0 +1,84 @@
+/*
+ * Licens
csviri commented on code in PR #1013:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1013#discussion_r2287748241
##
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/ConfigObjectNode.java:
##
@@ -0,0 +1,84 @@
+/*
+ * Licens
KeGu-069 commented on issue #119:
URL: https://github.com/apache/flink-agents/issues/119#issuecomment-3205042758
I'm willing to submit a PR
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the spe
Poorvankbhatia commented on PR #26846:
URL: https://github.com/apache/flink/pull/26846#issuecomment-3205363418
@fapaul merged with master. PTAL
--
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 th
Sxnan commented on code in PR #122:
URL: https://github.com/apache/flink-agents/pull/122#discussion_r2287466823
##
python/flink_agents/runtime/local_configuration.py:
##
@@ -0,0 +1,225 @@
+
+# Licen
xintongsong closed issue #109: [Feature] [api][runtime]Introduce Memory
Reference
URL: https://github.com/apache/flink-agents/issues/109
--
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
xintongsong merged PR #110:
URL: https://github.com/apache/flink-agents/pull/110
--
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
Poorvankbhatia commented on PR #26854:
URL: https://github.com/apache/flink/pull/26854#issuecomment-3205036890
@fapaul Rebased Master and now using Test source utility. PTAL :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
wenjin272 commented on PR #110:
URL: https://github.com/apache/flink-agents/pull/110#issuecomment-3205054600
LGTM. Please take a look at your convenience @xintongsong
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
[
https://issues.apache.org/jira/browse/FLINK-37887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-37887.
--
Resolution: Invalid
> Watched namespaces not picked up automatically by the operator
> ---
[
https://issues.apache.org/jira/browse/FLINK-37391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-37391.
--
Fix Version/s: kubernetes-operator-1.13.0
Assignee: Kumar Mallikarjuna
Resolution: Fixe
gyfora merged PR #1014:
URL: https://github.com/apache/flink-kubernetes-operator/pull/1014
--
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-unsubs
csviri commented on code in PR #1013:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1013#discussion_r2287422635
##
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/ConfigObjectNode.java:
##
@@ -0,0 +1,84 @@
+/*
+ * Licens
csviri commented on code in PR #1013:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1013#discussion_r2287397503
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/controller/FlinkDeploymentControllerTest.java:
##
@@ -197,6 +197,7 @@
csviri commented on code in PR #1013:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1013#discussion_r2287415790
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/KubernetesScalingRealizer.java:
##
@@ -63,15 +62,16 @@ publ
csviri commented on code in PR #1013:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/1013#discussion_r2287403591
##
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/ConfigObjectNode.java:
##
@@ -0,0 +1,84 @@
+/*
+ * Licens
davidradl commented on code in PR #26927:
URL: https://github.com/apache/flink/pull/26927#discussion_r2287375598
##
docs/content/docs/dev/table/sql-gateway/overview.md:
##
@@ -262,6 +262,18 @@ $ ./sql-gateway -Dkey=value
Integer
The minimum number of wo
davidradl commented on code in PR #26927:
URL: https://github.com/apache/flink/pull/26927#discussion_r2287375598
##
docs/content/docs/dev/table/sql-gateway/overview.md:
##
@@ -262,6 +262,18 @@ $ ./sql-gateway -Dkey=value
Integer
The minimum number of wo
yuxiqian commented on PR #4060:
URL: https://github.com/apache/flink-cdc/pull/4060#issuecomment-3204610695
> DebeziumEventDeserializationSchema#convertToTime Should we also change the
implementation of this class etc？
Updated.
--
This is an automated message from the Apache Git Ser
fapaul merged PR #26910:
URL: https://github.com/apache/flink/pull/26910
--
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
fapaul commented on PR #26910:
URL: https://github.com/apache/flink/pull/26910#issuecomment-3204507896
CI passed
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=69421&view=results
I am going to merge
--
This is an automated message from the Apache Git Service.
To
62 matches
Mail list logo
