Liam0205 · Liam0205 · Jul 19, 2026 · Jul 18, 2026 · Jul 18, 2026 · Jul 18, 2026
diff --git a/README.md b/README.md
@@ -40,7 +40,7 @@ Python DSL (Apple)  ──compile──>  JSON Config
 - **编译期校验** — 死代码、字段缺失、写后未读等问题在部署前拦截
 - **Lua 嵌入** — 内置 Lua 算子支持轻量自定义计算。pine-go 默认 [wangshu](https://github.com/Liam0205/wangshu)（纯 Go Lua 5.1 VM，NaN-boxing + arena GC），可通过 `-tags=lua_gopher` 切回 gopher-lua；pine-java 用 LuaJC（字节码编译），pine-cpp 用 LuaJIT。端到端开销约 1.2-2x；隔离算子级开销随运行时与计算复杂度变化（C++/LuaJIT 约 3-5x、Java 约 2-9x、Go 约 6-17x），计算密集型热路径建议写原生算子
 - **配置热加载** — 服务运行时自动无停机重载引擎配置（引用计数快照保证 in-flight 请求安全；`Watch` 开关可关闭）
-- **可嵌入 / 可扩展 server** — `server.NewServer` + `Execute`/`Acquire` 嵌入 API 支持把引擎挂进既有 HTTP 框架（如 Gin）；`Config.Routes` 自定义路由（Ingress/Egress 适配器）与内置端点共存，自定义路径自动加入有界指标标签集
+- **可嵌入 / 可扩展 server** — `server.NewServer` + `Execute`/`Acquire` 嵌入 API 支持把引擎挂进既有 HTTP 框架（如 Gin）；`Config.Routes` 自定义路由（Ingress/Egress 适配器）与内置端点共存，自定义路径自动加入有界指标标签集。多 pipeline 多 endpoint（各自独立 `log_prefix`）的三运行时示例见 `pine-go/examples/multi-pipeline/`、`pine-java/examples/MultiPipelineServer.java`、`pine-cpp/examples/multi_pipeline_server.cpp`
 - **动态资源** — 双通道资源管理：**数据型**（如静态 dict / 实时 feature store，snapshot 导出后无锁读）+ **句柄型**（如 `redis_connection`，borrow 借用 + RAII 拆除）；后台定时刷新
 - **Redis cascade-safety** — `redis_connection` 资源暴露 `{dial,read,write,pool}_timeout_ms` + `pool_size` 五参数，per-command 指标 `pine_redis_command_*`（4-state status：ok / timeout / pool_timeout / error），fail-on-error 静默降级契约
 - **白盒可观测** — 算子级 trace；`/stats` 组合响应含 `/stats.http`（请求级 4-state 指标）+ `/stats.resources`（资源池连接池/探针/per-command 4 状态分类）；可插拔 Prometheus 接口

diff --git a/apple/_version.py b/apple/_version.py
@@ -1 +1 @@
-__version__ = "0.10.13"
+__version__ = "0.10.14"
diff --git a/design_doc/06_json_config.md b/design_doc/06_json_config.md
@@ -29,7 +29,7 @@ Apple 运行 DSL 后产出 JSON 配置文件，Pine 加载并执行。JSON 格
 | `pipeline_group` | 顶层 pipeline 定义（子 flow 组合顺序） |
 | `flow_contract` | Flow 的输入输出契约 |
 | `storage_mode` | 可选，`"row"` 或 `"column"`，默认行存 |
-| `log_prefix` | 可选，全局日志前缀，应用于标准库 `log.SetPrefix()` |
+| `log_prefix` | 可选，引擎实例级日志前缀，作用于该引擎私有 logger（issue #172；不触碰进程全局 logger） |
 | `debug` | 可选，`true` 时对所有算子启用 debug 快照采集 |
 
 ## operators — 算子定义

diff --git a/design_doc/08_observability.md b/design_doc/08_observability.md
@@ -360,9 +360,9 @@ curl http://localhost:8080/dag?format=dot&collapse=0
 - 跨组的边提升为聚合边，自动去重
 - `collapse=0` 或不传 `collapse` 参数时行为完全不变
 
-### 全局日志前缀
+### 引擎日志前缀
 
-引擎支持为所有日志（包括第三方算子通过 `log.Printf` 打印的日志）统一添加前缀。底层通过 `log.SetPrefix()` 设置标准库全局 logger 前缀，确保无遗漏。
+引擎支持为其诊断日志（`[pine-debug]` 快照、`observe_log` 等 `LoggerAware` 算子输出）统一添加前缀。前缀作用于**引擎实例私有**的 logger——多个引擎同进程时各自保留自己的前缀，进程全局 `log` 包不受影响（issue #172；此前是 `log.SetPrefix()` 全局生效、first-engine-wins 的旧语义）。
 
 #### 配置方式
 
@@ -384,9 +384,9 @@ flow = Flow(
 engine, err := pine.NewEngine(jsonConfig, pine.WithLogPrefix("[svc] "))
 ```
 
-优先级：`WithLogPrefix` Option > JSON `log_prefix` 字段 > 无前缀。
+优先级：`WithLogPrefix` Option > JSON `log_prefix` 字段 > 无前缀。Option 是 nullable 三态（Go `*string` / Java nullable `String` / C++ `std::optional`）：显式传空字符串也视为已设置，会覆盖 JSON 值。
 
-`log_prefix` 是进程级全局状态，不存储在 Engine 实例上。
+`log_prefix` 存储在 Engine 实例上（Go `Engine.Logger()` / Java `Engine.logPrefix()` / C++ `Engine::log_prefix()`），作用域仅限该引擎的日志输出。
 
 #### 编程 API
 

diff --git a/doc/operators/README.md b/doc/operators/README.md
@@ -21,7 +21,7 @@
 
 | Operator | Description |
 |----------|-------------|
-| [observe_log](observe_log.md) | Reads declared input fields and writes them to Go standard log. This is a read-only operator: it produces no output fields and does not modify the DataFrame. It is exempt from dead-code detection. |
+| [observe_log](observe_log.md) | Reads declared input fields and writes them to the engine's logger. This is a read-only operator: it produces no output fields and does not modify the DataFrame. It is exempt from dead-code detection. |
 
 ## Recall
 

diff --git a/doc/operators/observe_log.md b/doc/operators/observe_log.md
@@ -2,7 +2,7 @@
 
 **Type**: Observe
 
-Reads declared input fields and writes them to Go standard log. This is a read-only operator: it produces no output fields and does not modify the DataFrame. It is exempt from dead-code detection.
+Reads declared input fields and writes them to the engine's logger. This is a read-only operator: it produces no output fields and does not modify the DataFrame. It is exempt from dead-code detection.
 
 ## Parameters
 

diff --git a/fixtures/benchmarks/large_0100_config.json b/fixtures/benchmarks/large_0100_config.json
@@ -1,5 +1,5 @@
 {
-  "_PINEAPPLE_VERSION": "0.10.13",
+  "_PINEAPPLE_VERSION": "0.10.14",
   "pipeline_config": {
     "operators": {
       "recall_a": {

diff --git a/fixtures/benchmarks/large_0500_config.json b/fixtures/benchmarks/large_0500_config.json
@@ -1,5 +1,5 @@
 {
-  "_PINEAPPLE_VERSION": "0.10.13",
+  "_PINEAPPLE_VERSION": "0.10.14",
   "pipeline_config": {
     "operators": {
       "recall_a": {

diff --git a/fixtures/benchmarks/large_1000_config.json b/fixtures/benchmarks/large_1000_config.json
@@ -1,5 +1,5 @@
 {
-  "_PINEAPPLE_VERSION": "0.10.13",
+  "_PINEAPPLE_VERSION": "0.10.14",
   "pipeline_config": {
     "operators": {
       "recall_a": {

diff --git a/fixtures/benchmarks/large_5000_config.json b/fixtures/benchmarks/large_5000_config.json
@@ -1,5 +1,5 @@
 {
-  "_PINEAPPLE_VERSION": "0.10.13",
+  "_PINEAPPLE_VERSION": "0.10.14",
   "pipeline_config": {
     "operators": {
       "recall_a": {

diff --git a/fixtures/benchmarks/medium_0100_config.json b/fixtures/benchmarks/medium_0100_config.json
@@ -1,5 +1,5 @@
 {
-  "_PINEAPPLE_VERSION": "0.10.13",
+  "_PINEAPPLE_VERSION": "0.10.14",
   "pipeline_config": {
     "operators": {
       "recall_a": {

diff --git a/fixtures/benchmarks/medium_0500_config.json b/fixtures/benchmarks/medium_0500_config.json
@@ -1,5 +1,5 @@
 {
-  "_PINEAPPLE_VERSION": "0.10.13",
+  "_PINEAPPLE_VERSION": "0.10.14",
   "pipeline_config": {
     "operators": {
       "recall_a": {

diff --git a/fixtures/benchmarks/medium_1000_config.json b/fixtures/benchmarks/medium_1000_config.json
@@ -1,5 +1,5 @@
 {
-  "_PINEAPPLE_VERSION": "0.10.13",
+  "_PINEAPPLE_VERSION": "0.10.14",
   "pipeline_config": {
     "operators": {
       "recall_a": {

diff --git a/fixtures/benchmarks/realistic_for_you_calibrated_2c4g_config.json b/fixtures/benchmarks/realistic_for_you_calibrated_2c4g_config.json
@@ -1,5 +1,5 @@
 {
-  "_PINEAPPLE_VERSION": "0.10.13",
+  "_PINEAPPLE_VERSION": "0.10.14",
   "_PINEAPPLE_CREATE_TIME": "2026-05-28T11:31:47Z",
   "pipeline_config": {
     "operators": {

diff --git a/fixtures/benchmarks/realistic_for_you_calibrated_config.json b/fixtures/benchmarks/realistic_for_you_calibrated_config.json
@@ -1,5 +1,5 @@
 {
-  "_PINEAPPLE_VERSION": "0.10.13",
+  "_PINEAPPLE_VERSION": "0.10.14",
   "_PINEAPPLE_CREATE_TIME": "2026-05-28T11:31:47Z",
   "pipeline_config": {
     "operators": {

diff --git a/fixtures/benchmarks/realistic_for_you_calibrated_itemlua_config.json b/fixtures/benchmarks/realistic_for_you_calibrated_itemlua_config.json
@@ -1,5 +1,5 @@
 {
-  "_PINEAPPLE_VERSION": "0.10.13",
+  "_PINEAPPLE_VERSION": "0.10.14",
   "_PINEAPPLE_CREATE_TIME": "2026-05-28T11:31:47Z",
   "pipeline_config": {
     "operators": {

diff --git a/fixtures/benchmarks/realistic_for_you_config.json b/fixtures/benchmarks/realistic_for_you_config.json
@@ -1,5 +1,5 @@
 {
-  "_PINEAPPLE_VERSION": "0.10.13",
+  "_PINEAPPLE_VERSION": "0.10.14",
   "_PINEAPPLE_CREATE_TIME": "2026-05-28T11:31:47Z",
   "pipeline_config": {
     "operators": {

diff --git a/fixtures/benchmarks/realistic_for_you_latency_config.json b/fixtures/benchmarks/realistic_for_you_latency_config.json
@@ -1,5 +1,5 @@
 {
-  "_PINEAPPLE_VERSION": "0.10.13",
+  "_PINEAPPLE_VERSION": "0.10.14",
   "_PINEAPPLE_CREATE_TIME": "2026-05-28T11:31:47Z",
   "pipeline_config": {
     "operators": {

diff --git a/fixtures/benchmarks/small_010_config.json b/fixtures/benchmarks/small_010_config.json
@@ -1,5 +1,5 @@
 {
-  "_PINEAPPLE_VERSION": "0.10.13",
+  "_PINEAPPLE_VERSION": "0.10.14",
   "pipeline_config": {
     "operators": {
       "recall": {

diff --git a/fixtures/benchmarks/small_050_config.json b/fixtures/benchmarks/small_050_config.json
@@ -1,5 +1,5 @@
 {
-  "_PINEAPPLE_VERSION": "0.10.13",
+  "_PINEAPPLE_VERSION": "0.10.14",
   "pipeline_config": {
     "operators": {
       "recall": {

diff --git a/fixtures/benchmarks/small_100_config.json b/fixtures/benchmarks/small_100_config.json
@@ -1,5 +1,5 @@
 {
-  "_PINEAPPLE_VERSION": "0.10.13",
+  "_PINEAPPLE_VERSION": "0.10.14",
   "pipeline_config": {
     "operators": {
       "recall": {

diff --git a/fixtures/pipelines/barrier_transform_reorder.json b/fixtures/pipelines/barrier_transform_reorder.json
@@ -1,7 +1,7 @@
 {
   "name": "barrier semantics (transform before reorder)",
   "config": {
-    "_PINEAPPLE_VERSION": "0.10.13",
+    "_PINEAPPLE_VERSION": "0.10.14",
     "pipeline_config": {
       "operators": {
         "normalize_score": {

diff --git a/fixtures/pipelines/bench_cpu_work_parity.json b/fixtures/pipelines/bench_cpu_work_parity.json
@@ -1,7 +1,7 @@
 {
   "name": "transform_bench_cpu byte-identical work output across runtimes (M12)",
   "config": {
-    "_PINEAPPLE_VERSION": "0.10.13",
+    "_PINEAPPLE_VERSION": "0.10.14",
     "pipeline_config": {
       "operators": {
         "bench": {

diff --git a/fixtures/pipelines/control_op_nil_field_no_crash.json b/fixtures/pipelines/control_op_nil_field_no_crash.json
@@ -1,7 +1,7 @@
 {
   "name": "control operator nil field does not crash — branch skipped",
   "config": {
-    "_PINEAPPLE_VERSION": "0.10.13",
+    "_PINEAPPLE_VERSION": "0.10.14",
     "pipeline_config": {
       "operators": {
         "ctrl_if": {

diff --git a/fixtures/pipelines/data_parallel.json b/fixtures/pipelines/data_parallel.json
@@ -1,7 +1,7 @@
 {
   "name": "data_parallel transform (sharded item execution)",
   "config": {
-    "_PINEAPPLE_VERSION": "0.10.13",
+    "_PINEAPPLE_VERSION": "0.10.14",
     "pipeline_config": {
       "operators": {
         "copy_tag": {

diff --git a/fixtures/pipelines/data_parallel_lua.json b/fixtures/pipelines/data_parallel_lua.json
@@ -1,7 +1,7 @@
 {
   "name": "data_parallel Lua transform (verify shard-independent computation)",
   "config": {
-    "_PINEAPPLE_VERSION": "0.10.13",
+    "_PINEAPPLE_VERSION": "0.10.14",
     "pipeline_config": {
       "operators": {
         "recall_items": {

diff --git a/fixtures/pipelines/deeply_nested_subflow.json b/fixtures/pipelines/deeply_nested_subflow.json
@@ -1,7 +1,7 @@
 {
   "name": "deeply nested SubFlow (depth-3 expansion)",
   "config": {
-    "_PINEAPPLE_VERSION": "0.10.13",
+    "_PINEAPPLE_VERSION": "0.10.14",
     "pipeline_config": {
       "operators": {
         "copy_tag": {

diff --git a/fixtures/pipelines/field_mode_nullable_vs_defaulted.json b/fixtures/pipelines/field_mode_nullable_vs_defaulted.json
@@ -1,7 +1,7 @@
 {
   "name": "three field modes — strict vs nullable vs defaulted",
   "config": {
-    "_PINEAPPLE_VERSION": "0.10.13",
+    "_PINEAPPLE_VERSION": "0.10.14",
     "pipeline_config": {
       "operators": {
         "write_nil": {

diff --git a/fixtures/pipelines/field_mode_strict_nil_error.json b/fixtures/pipelines/field_mode_strict_nil_error.json
@@ -1,7 +1,7 @@
 {
   "name": "strict field mode — nil triggers error",
   "config": {
-    "_PINEAPPLE_VERSION": "0.10.13",
+    "_PINEAPPLE_VERSION": "0.10.14",
     "pipeline_config": {
       "operators": {
         "write_nil": {

diff --git a/fixtures/pipelines/filter_removes_all.json b/fixtures/pipelines/filter_removes_all.json
@@ -1,7 +1,7 @@
 {
   "name": "filter_condition removes all items — empty result",
   "config": {
-    "_PINEAPPLE_VERSION": "0.10.13",
+    "_PINEAPPLE_VERSION": "0.10.14",
     "pipeline_config": {
       "operators": {
         "remove_banned": {

diff --git a/fixtures/pipelines/implicit_row_set_filter_common_then_item.json b/fixtures/pipelines/implicit_row_set_filter_common_then_item.json
@@ -1,7 +1,7 @@
 {
   "name": "implicit row-set: filter → common-only → item-field transform",
   "config": {
-    "_PINEAPPLE_VERSION": "0.10.13",
+    "_PINEAPPLE_VERSION": "0.10.14",
     "pipeline_config": {
       "operators": {
         "recall_items": {

diff --git a/fixtures/pipelines/implicit_row_set_filter_then_common_only.json b/fixtures/pipelines/implicit_row_set_filter_then_common_only.json
@@ -1,7 +1,7 @@
 {
   "name": "implicit row-set: filter then common-only transform (no dependency needed)",
   "config": {
-    "_PINEAPPLE_VERSION": "0.10.13",
+    "_PINEAPPLE_VERSION": "0.10.14",
     "pipeline_config": {
       "operators": {
         "recall_items": {

diff --git a/fixtures/pipelines/implicit_row_set_filter_then_item.json b/fixtures/pipelines/implicit_row_set_filter_then_item.json
@@ -1,7 +1,7 @@
 {
   "name": "implicit row-set: filter then item-field transform (no field overlap)",
   "config": {
-    "_PINEAPPLE_VERSION": "0.10.13",
+    "_PINEAPPLE_VERSION": "0.10.14",
     "pipeline_config": {
       "operators": {
         "recall_items": {

diff --git a/fixtures/pipelines/lua_e2e_conditional_sort.json b/fixtures/pipelines/lua_e2e_conditional_sort.json
@@ -1,7 +1,7 @@
 {
   "name": "Lua E2E: recall → discount → stats → conditional sort",
   "config": {
-    "_PINEAPPLE_VERSION": "0.10.13",
+    "_PINEAPPLE_VERSION": "0.10.14",
     "pipeline_config": {
       "operators": {
         "recall_items": {

diff --git a/fixtures/pipelines/multi_recall_row_set_ordering.json b/fixtures/pipelines/multi_recall_row_set_ordering.json
@@ -2,7 +2,7 @@
   "name": "multi-recall row-set ordering (ConsumesRowSet semantics)",
   "description": "Regression test for differential fuzz divergence #945: operators between recalls must wait for preceding recall via ConsumesRowSet before iterating items.",
   "config": {
-    "_PINEAPPLE_VERSION": "0.10.13",
+    "_PINEAPPLE_VERSION": "0.10.14",
     "pipeline_config": {
       "operators": {
         "recall_a": {

diff --git a/fixtures/pipelines/multi_skip.json b/fixtures/pipelines/multi_skip.json
@@ -1,7 +1,7 @@
 {
   "name": "multiple independent skip flags",
   "config": {
-    "_PINEAPPLE_VERSION": "0.10.13",
+    "_PINEAPPLE_VERSION": "0.10.14",
     "pipeline_config": {
       "operators": {
         "copy_tag": {

diff --git a/fixtures/pipelines/nested_subflow.json b/fixtures/pipelines/nested_subflow.json
@@ -1,7 +1,7 @@
 {
   "name": "nested SubFlow pipeline",
   "config": {
-    "_PINEAPPLE_VERSION": "0.10.13",
+    "_PINEAPPLE_VERSION": "0.10.14",
     "pipeline_config": {
       "operators": {
         "copy_tag": {

diff --git a/fixtures/pipelines/nullable_field_pass_through.json b/fixtures/pipelines/nullable_field_pass_through.json
@@ -1,7 +1,7 @@
 {
   "name": "nullable field mode — explicit nil pass-through vs missing error",
   "config": {
-    "_PINEAPPLE_VERSION": "0.10.13",
+    "_PINEAPPLE_VERSION": "0.10.14",
     "pipeline_config": {
       "operators": {
         "set_nil": {

diff --git a/fixtures/pipelines/recall_merge_filter_sort.json b/fixtures/pipelines/recall_merge_filter_sort.json
@@ -1,7 +1,7 @@
 {
   "name": "recall → merge → filter → sort (full pipeline)",
   "config": {
-    "_PINEAPPLE_VERSION": "0.10.13",
+    "_PINEAPPLE_VERSION": "0.10.14",
     "pipeline_config": {
       "operators": {
         "recall_hot": {

diff --git a/fixtures/pipelines/recall_rank_truncate.json b/fixtures/pipelines/recall_rank_truncate.json
@@ -1,7 +1,7 @@
 {
   "name": "recall → lua scoring → sort → truncate (recommendation pipeline)",
   "config": {
-    "_PINEAPPLE_VERSION": "0.10.13",
+    "_PINEAPPLE_VERSION": "0.10.14",
     "pipeline_config": {
       "operators": {
         "recall_candidates": {

diff --git a/fixtures/pipelines/reorder_topn_boost_parity.json b/fixtures/pipelines/reorder_topn_boost_parity.json
@@ -2,7 +2,7 @@
   "name": "reorder_topn_boost byte-identical reorder output across runtimes (H8)",
   "requires": ["bench"],
   "config": {
-    "_PINEAPPLE_VERSION": "0.10.13",
+    "_PINEAPPLE_VERSION": "0.10.14",
     "pipeline_config": {
       "operators": {
         "boost": {

diff --git a/fixtures/pipelines/resource_operators.json b/fixtures/pipelines/resource_operators.json
@@ -13,7 +13,7 @@
     ]
   },
   "config": {
-    "_PINEAPPLE_VERSION": "0.10.13",
+    "_PINEAPPLE_VERSION": "0.10.14",
     "pipeline_config": {
       "operators": {
         "recall_hot": {

diff --git a/fixtures/pipelines/size_dispatch_truncate.json b/fixtures/pipelines/size_dispatch_truncate.json
@@ -1,7 +1,7 @@
 {
   "name": "transform_size → dispatch → truncate (common↔item interaction)",
   "config": {
-    "_PINEAPPLE_VERSION": "0.10.13",
+    "_PINEAPPLE_VERSION": "0.10.14",
     "pipeline_config": {
       "operators": {
         "count_items": {

diff --git a/fixtures/pipelines/skip_branch.json b/fixtures/pipelines/skip_branch.json
@@ -1,7 +1,7 @@
 {
   "name": "skip/branch via Lua control flag",
   "config": {
-    "_PINEAPPLE_VERSION": "0.10.13",
+    "_PINEAPPLE_VERSION": "0.10.14",
     "pipeline_config": {
       "operators": {
         "set_flag": {

diff --git a/fixtures/pipelines/subflow_if_else_control_flow.json b/fixtures/pipelines/subflow_if_else_control_flow.json
@@ -1,7 +1,7 @@
 {
   "name": "SubFlow if/else control flow with namespaced fields",
   "config": {
-    "_PINEAPPLE_VERSION": "0.10.13",
+    "_PINEAPPLE_VERSION": "0.10.14",
     "pipeline_config": {
       "operators": {
         "my_sf::if_1": {

diff --git a/fixtures/pipelines/transform_then_filter.json b/fixtures/pipelines/transform_then_filter.json
@@ -1,7 +1,7 @@
 {
   "name": "transform_copy then filter_truncate",
   "config": {
-    "_PINEAPPLE_VERSION": "0.10.13",
+    "_PINEAPPLE_VERSION": "0.10.14",
     "pipeline_config": {
       "operators": {
         "copy_score": {