This is an automated email from the ASF dual-hosted git repository.
wenjin272 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-agents.git
The following commit(s) were added to refs/heads/main by this push:
new d2898eabc [docs] Document the successive Python job limitation on a
session cluster (#1282)
d2898eabc is described below
commit d2898eabcfc1da9448959ec84724432ca927b926
Author: Sangkyoon Nam <[email protected]>
AuthorDate: Tue Oct 20 16:10:17 2026 +0900
[docs] Document the successive Python job limitation on a session cluster
(#1282)
Generated-by: Claude Code 2.1.303 (Claude Opus 5.5)
---
docs/content/docs/get-started/quickstart/_index.md | 3 +++
docs/content/docs/get-started/setup.md | 11 +++++++++++
2 files changed, 14 insertions(+)
diff --git a/docs/content/docs/get-started/quickstart/_index.md
b/docs/content/docs/get-started/quickstart/_index.md
index ddf2329b8..6d21cbd22 100644
--- a/docs/content/docs/get-started/quickstart/_index.md
+++ b/docs/content/docs/get-started/quickstart/_index.md
@@ -108,4 +108,7 @@ in `$FLINK_HOME/conf/config.yaml` before you start the
cluster. Both the Python
Quickstarts need it. See
[JDK and Scheduling Requirements]({{< ref
"docs/development/create-agent/actions#jdk-and-scheduling-requirements" >}}).
+Restart the cluster before you submit each Python Quickstart after the first.
See
+[Known Limitation: Successive Python Jobs on a Session Cluster]({{< ref
"docs/get-started/setup#known-limitation-successive-python-jobs-on-a-session-cluster"
>}}).
+
To stop the cluster again, run `$FLINK_HOME/bin/stop-cluster.sh`.
diff --git a/docs/content/docs/get-started/setup.md
b/docs/content/docs/get-started/setup.md
index c58ee69d1..80a61fb9a 100644
--- a/docs/content/docs/get-started/setup.md
+++ b/docs/content/docs/get-started/setup.md
@@ -270,6 +270,17 @@ export PYTHONPATH=$(python -c 'import sysconfig;
print(sysconfig.get_paths()["pu
**Note:** You can add the `export PYTHONPATH=...` line to your shell profile
(`~/.bash_profile`, `~/.bashrc`, `~/.zprofile`, or `~/.zshrc`) to set it
permanently. This way, it will be automatically configured in all future
terminal sessions.
{{< /hint >}}
+### Known Limitation: Successive Python Jobs on a Session Cluster
+
+Restart the session cluster before you submit another Flink Agents job that
uses the Python
+runtime, including Java jobs whose Agents have Python components. For the
local cluster,
+run `$FLINK_HOME/bin/stop-cluster.sh` and then
`$FLINK_HOME/bin/start-cluster.sh`.
+
+Successive jobs on the same TaskManager have known Python import and cache
limitations.
+When the Flink Agents distribution JAR is not in `$FLINK_HOME/lib`, a later
job can also
+fail to start with `NoSuchFieldException: loadedLibraryNames` or a
`ClassCastException`
+on `pemja.core.object.PyObject`.
+
### Install Flink Agents Java Library (Java Flink jobs)
{{< hint info >}}
