This is an automated email from the ASF dual-hosted git repository.
xtsong pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-agents.git
from 6bc5f58 [metrics] Implement token usage metrics tracking for chat
models (#394)
new 11cd4ee [build] Use Unified Jackson in Flink Agents
new 6a9ca8c [build] Update default flink to 2.2.0
new 507f1e1 [build] Support Multi-Version Flink in Java
new 21b9a97 [build] Support Multi-Version Flink in Python
new 57f968a [ci] Enable testing for all Flink versions in CI
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/ci.yml | 10 +-
api/pom.xml | 1 -
.../java/org/apache/flink/agents/api/Event.java | 7 +-
.../org/apache/flink/agents/api/EventContext.java | 4 +-
.../org/apache/flink/agents/api/InputEvent.java | 4 +-
.../org/apache/flink/agents/api/OutputEvent.java | 4 +-
.../apache/flink/agents/api/agents/ReActAgent.java | 26 +--
.../agents/api/chat/messages/ChatMessage.java | 2 +-
.../flink/agents/api/context/MemoryUpdate.java | 4 +-
.../org/apache/flink/agents/api/prompt/Prompt.java | 8 +-
.../agents/api/resource/ResourceDescriptor.java | 4 +-
.../flink/agents/api/tools/ToolMetadata.java | 6 +-
.../flink/agents/api/agents/ReActAgentTest.java | 4 +-
.../apache/flink/agents/api/prompt/PromptTest.java | 4 +-
.../api/resource/ResourceDescriptorTest.java | 4 +-
{runtime => dist/flink-1.20}/pom.xml | 130 ++++++++-----
.../agents/runtime/operator/OperatorUtils.java | 18 +-
.../agents/runtime/operator/OperatorUtilsTest.java | 87 +++++++++
dist/flink-2.0/pom.xml | 91 +++++++++
dist/flink-2.1/pom.xml | 91 +++++++++
.../flink-2.2}/pom.xml | 50 ++---
dist/pom.xml | 27 ++-
.../pom.xml | 55 +++++-
.../flink/agents/examples/ReActAgentExample.java | 4 +-
.../examples/WorkflowMultipleAgentExample.java | 4 +-
plan/pom.xml | 5 -
.../org/apache/flink/agents/plan/AgentPlan.java | 6 +-
.../org/apache/flink/agents/plan/JavaFunction.java | 4 +-
.../apache/flink/agents/plan/actions/Action.java | 4 +-
.../agents/plan/resource/python/PythonTool.java | 4 +-
.../JavaSerializableResourceProvider.java | 6 +-
.../plan/resourceprovider/ResourceProvider.java | 4 +-
.../plan/serializer/ActionJsonDeserializer.java | 12 +-
.../plan/serializer/ActionJsonSerializer.java | 26 +--
.../plan/serializer/AgentPlanJsonDeserializer.java | 18 +-
.../plan/serializer/AgentPlanJsonSerializer.java | 6 +-
.../ResourceProviderJsonDeserializer.java | 12 +-
.../serializer/ResourceProviderJsonSerializer.java | 6 +-
.../flink/agents/plan/tools/FunctionTool.java | 4 +-
.../flink/agents/plan/tools/SchemaUtils.java | 4 +-
.../agents/plan/tools/ToolMetadataFactory.java | 2 +-
.../serializer/FunctionToolJsonDeserializer.java | 10 +-
.../serializer/FunctionToolJsonSerializer.java | 6 +-
.../apache/flink/agents/plan/utils/JsonUtils.java | 4 +-
.../agents/plan/AgentPlanDeclareChatModelTest.java | 2 +-
.../plan/AgentPlanDeclareToolMethodTest.java | 2 +-
.../flink/agents/plan/FunctionToolPlanTest.java | 4 +-
.../flink/agents/plan/TestEventSerializable.java | 2 +-
.../org/apache/flink/agents/plan/TestFunction.java | 2 +-
.../compatibility/CreateJavaAgentPlanFromJson.java | 2 +-
.../plan/compatibility/GenerateAgentPlanJson.java | 2 +-
.../plan/resource/python/PythonToolTest.java | 2 +-
.../serializer/ActionJsonDeserializerTest.java | 2 +-
.../plan/serializer/ActionJsonSerializerTest.java | 2 +-
.../serializer/AgentPlanJsonDeserializerTest.java | 2 +-
.../serializer/AgentPlanJsonSerializerTest.java | 2 +-
.../ResourceProviderDeserializerTest.java | 2 +-
.../serializer/ResourceProviderSerializerTest.java | 4 +-
.../flink/agents/plan/tools/FunctionToolTest.java | 2 +-
pom.xml | 18 +-
python/flink_agents/api/execution_environment.py | 30 ++-
.../api/tests/test_version_compatibility.py | 169 ++++++++++++++++
python/flink_agents/api/version_compatibility.py | 170 ++++++++++++++++
python/pyproject.toml | 3 +-
runtime/pom.xml | 9 +
.../apache/flink/agents/runtime/CompileUtils.java | 4 +-
.../actionstate/ActionStateKafkaDeserializer.java | 12 +-
.../runtime/actionstate/ActionStateKafkaSeder.java | 12 +-
.../actionstate/ActionStateKafkaSerializer.java | 12 +-
.../runtime/actionstate/ActionStateUtil.java | 4 +-
.../agents/runtime/context/RunnerContextImpl.java | 2 +-
.../agents/runtime/eventlog/EventLogRecord.java | 4 +-
.../eventlog/EventLogRecordJsonDeserializer.java | 10 +-
.../eventlog/EventLogRecordJsonSerializer.java | 6 +-
.../agents/runtime/eventlog/FileEventLogger.java | 2 +-
.../runtime/message/MessageTypeInformation.java | 86 ---------
.../runtime/operator/ActionExecutionOperator.java | 15 +-
.../operator/ActionExecutionOperatorFactory.java | 4 +-
.../OperatorUtils.java} | 16 +-
.../flink/agents/runtime/operator/StateUtils.java | 5 +-
.../agents/runtime/python/event/PythonEvent.java | 6 +-
.../apache/flink/agents/runtime/RescalingTest.java | 4 +-
.../eventlog/EventLogRecordJsonSerdeTest.java | 4 +-
.../runtime/eventlog/FileEventLoggerTest.java | 4 +-
.../runtime/python/event/PythonEventTest.java | 4 +-
tools/build.sh | 24 ++-
tools/e2e.sh | 6 +
tools/ut.sh | 215 ++++++++++++++-------
88 files changed, 1231 insertions(+), 455 deletions(-)
copy {runtime => dist/flink-1.20}/pom.xml (50%)
copy
runtime/src/main/java/org/apache/flink/agents/runtime/feedback/FeedbackConsumer.java
=>
dist/flink-1.20/src/main/java/org/apache/flink/agents/runtime/operator/OperatorUtils.java
(67%)
create mode 100644
dist/flink-1.20/src/test/java/org/apache/flink/agents/runtime/operator/OperatorUtilsTest.java
create mode 100644 dist/flink-2.0/pom.xml
create mode 100644 dist/flink-2.1/pom.xml
copy {e2e-test/flink-agents-end-to-end-tests-agent-plan-compatibility =>
dist/flink-2.2}/pom.xml (57%)
create mode 100644 python/flink_agents/api/tests/test_version_compatibility.py
create mode 100644 python/flink_agents/api/version_compatibility.py
delete mode 100644
runtime/src/main/java/org/apache/flink/agents/runtime/message/MessageTypeInformation.java
copy
runtime/src/main/java/org/apache/flink/agents/runtime/{feedback/FeedbackConsumer.java
=> operator/OperatorUtils.java} (70%)
