(flink-agents-demos) branch main updated: [hotfix] Upgrade Flink Agents version to 0.2.1 (#4)

[sxnan]

This is an automated email from the ASF dual-hosted git repository.

sxnan pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-agents-demos.git


The following commit(s) were added to refs/heads/main by this push:
     new 9c09d01  [hotfix] Upgrade Flink Agents version to 0.2.1 (#4)
9c09d01 is described below

commit 9c09d010ecdfc9684cfa9cc7a471a637808f5278
Author: Eugene <meeteugen...@gmail.com>
AuthorDate: Mon Mar 30 11:06:14 2026 +0800

    [hotfix] Upgrade Flink Agents version to 0.2.1 (#4)
---
 flink-operations-agent-demo/README.md                      |  1 -
 flink-operations-agent-demo/bin/internal/flink_config.yaml |  3 ++-
 flink-operations-agent-demo/bin/internal/setup_flink.sh    | 10 ++--------
 3 files changed, 4 insertions(+), 10 deletions(-)

diff --git a/flink-operations-agent-demo/README.md 
b/flink-operations-agent-demo/README.md
index bd562ce..7f0ecac 100644
--- a/flink-operations-agent-demo/README.md
+++ b/flink-operations-agent-demo/README.md
@@ -225,7 +225,6 @@ bin/stop_all.sh
 # Optional: Remove downloaded files
 rm -rf flink-1.20.3 flink-1.20.3-bin-scala_2.12.tgz
 rm -rf venv
-rm -f flink_agents-0.2.0-py3-none-any.whl
 ```
 
 ## License
diff --git a/flink-operations-agent-demo/bin/internal/flink_config.yaml 
b/flink-operations-agent-demo/bin/internal/flink_config.yaml
index a5270ea..f73fedf 100644
--- a/flink-operations-agent-demo/bin/internal/flink_config.yaml
+++ b/flink-operations-agent-demo/bin/internal/flink_config.yaml
@@ -299,4 +299,5 @@ web:
 classloader.parent-first-patterns.additional: jakarta.json;org.eclipse.parsson
 
 agent:
-  baseLogDir: EVENT_LOG_DIR_PLACEHOLDER
\ No newline at end of file
+  baseLogDir: EVENT_LOG_DIR_PLACEHOLDER
+  prettyPrint: true
\ No newline at end of file
diff --git a/flink-operations-agent-demo/bin/internal/setup_flink.sh 
b/flink-operations-agent-demo/bin/internal/setup_flink.sh
index 3dbecf6..a5a6509 100755
--- a/flink-operations-agent-demo/bin/internal/setup_flink.sh
+++ b/flink-operations-agent-demo/bin/internal/setup_flink.sh
@@ -75,19 +75,13 @@ fi
 # On Linux/macOS:
 source venv/bin/activate
 
-# Download flink-agents wheel (skip if already exists)
-if [ ! -f "flink_agents-0.2.0-py3-none-any.whl" ]; then
-    curl -LO 
https://archive.apache.org/dist/flink/flink-agents-0.2.0/python/flink_agents-0.2.0-py3-none-any.whl
-else
-    echo "flink_agents-0.2.0-py3-none-any.whl already exists, skipping 
download"
-fi
-
-pip install flink_agents-0.2.0-py3-none-any.whl "apache-flink==1.20.3" 
"elasticsearch~=8.19" "setuptools>=75.3,<82"
+pip install "flink-agents==0.2.1" "apache-flink==1.20.3" "elasticsearch~=8.19" 
"setuptools>=75.3,<82"
 
 # Set PYTHONPATH to your Python site-packages directory
 export PYTHONPATH=$(python -c 'import sysconfig; 
print(sysconfig.get_paths()["purelib"])')
 
 # Copy the JAR from the Python package to Flink's lib directory
+cp $PYTHONPATH/flink_agents/lib/common/flink-agents-dist-*.jar $FLINK_HOME/lib/
 cp $PYTHONPATH/flink_agents/lib/flink-1.20/flink-agents-dist-*.jar 
$FLINK_HOME/lib/
 
 # Set environment variable for metric history directory and job metadata 
directory