</failure>
  </testcase>
  <testcase classname="stress.python_udf" name="python_udf_module_cache_isolation" time="100.051">
    <failure message="flowId=stress/python_udf/udf_module_cache_isolation.groovy#python_udf_module_cache_isolation" type="SuiteFailure">    logger.info("Scene 9a: function works before cache deletion, result=${r9a[0][0]}")

    // 删除所有 BE 上的 UDF cache 文件（只删文件，保留目录结构）
    aliveBEs.each { be -&gt;
        execSSH(be.Host, "find /mnt/hdd01/PERFORMANCE_ENV/be/lib/udf/ -mindepth 2 -type f -delete 2&gt;/dev/null; true")
    }
    logger.info("Scene 9b: UDF cache files deleted on all BEs")

    // 再次调用，BE 应自动重新下载 zip 并执行
    def r9b = sql "SELECT cache_recover_${runId}(10)"
^^^^^^^^^^^^^^^^^^^^^^^^^^ERROR LINE^^^^^^^^^^^^^^^^^^^^^^^^^^
    assert r9b[0][0] == 787, "cache recover after delete: expected 787, got ${r9b[0][0]}"
    logger.info("Scene 9c: function works after cache deletion, result=${r9b[0][0]}")

    // 批量验证恢复后的一致性
    def r9c = sql "SELECT cache_recover_${runId}(val) FROM t_cache_batch WHERE id &lt;= 5 ORDER BY id"
    for (int i = 0; i &lt; 5; i++) {
        def expected = (i + 1) + 777
        assert r9c[i][0] == expected, "cache recover batch[${i}]: expected ${expected}, got ${r9c[i][0]}"
    }
    logger.info("Scene 9 PASS: cache auto-recovery after manual deletion — all results consistent")

java.sql.SQLException: errCode = 2, detailMessage = (172.20.49.73)[RUNTIME_ERROR]Flight stream finish failed with message: Directory contains no Python (.py) files: /mnt/hdd01/PERFORMANCE_ENV/be/lib/udf/5/1775636895621.2cfe161cc9c6f0b2ca5e7dcb6286e924.cache_recover. Detail: Python exception: Traceback (most recent call last):
  File "pyarrow/_flight.pyx", line 2315, in pyarrow._flight._do_exchange
  File "/mnt/hdd01/PERFORMANCE_ENV/be/plugins/python_udf/python_server.py", line 2493, in do_exchange
    self._handle_exchange_udf(python_udf_meta, reader, writer)
  File "/mnt/hdd01/PERFORMANCE_ENV/be/plugins/python_udf/python_server.py", line 2005, in _handle_exchange_udf
    loader = UDFLoaderFactory.get_loader(python_udf_meta)
             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/mnt/hdd01/PERFORMANCE_ENV/be/plugins/python_udf/python_server.py", line 1161, in get_loader
    if UDFLoaderFactory.check_module(location):
       ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/mnt/hdd01/PERFORMANCE_ENV/be/plugins/python_udf/python_server.py", line 1196, in check_module
    raise ValueError(
ValueError: Directory contains no Python (.py) files: /mnt/hdd01/PERFORMANCE_ENV/be/lib/udf/5/1775636895621.2cfe161cc9c6f0b2ca5e7dcb6286e924.cache_recover 

 </testcase>
  <testcase classname="stress.python_udf" name="python_udf_cross_feature_import_storage" time="0.430">
    <failure message="flowId=stress/python_udf/cross_feature_import_storage.groovy#python_udf_cross_feature_import_storage" type="SuiteFailure">    def pyVer = System.getenv('python_version') ?: '3.12.11'
    def db = context.config.getDbNameByFile(context.file)
    sql "DROP DATABASE IF EXISTS ${db} FORCE"
    sql "CREATE DATABASE IF NOT EXISTS ${db}"
    sql "USE ${db}"

    if (!python_udf_require_olap_table("python_udf_cross_feature_import_storage.src_t")) {
        return
    }
    if (!python_udf_require_inline_function("python_udf_cross_feature_import_storage.inline_runtime", pyVer)) {
^^^^^^^^^^^^^^^^^^^^^^^^^^ERROR LINE^^^^^^^^^^^^^^^^^^^^^^^^^^
        return
    }

    // ===== 1. INSERT INTO ... SELECT 中使用 UDF =====
    sql "DROP TABLE IF EXISTS src_t"
    sql """
        CREATE TABLE src_t (id INT, v INT)
        DISTRIBUTED BY HASH(id) BUCKETS 1
        PROPERTIES("replication_num"="1")
    """

java.lang.IllegalStateException: PYTHON_UDF_BLOCKED suite=python_udf_cross_feature_import_storage scenario=python_udf_cross_feature_import_storage.inline_runtime reason=inline probe failed. reason=errCode = 2, detailMessage = (172.20.49.73)[INTERNAL_ERROR]IOError: Flight stream finish failed with gRPC code 14, message: failed to connect to all addresses; last error: UNKNOWN: unix:/tmp/doris_python_udf_55799.sock: Connection refused

  </testcase>
  <testcase classname="stress.python_udf" name="python_udf_thirdparty_packages" time="6.084">
    <failure message="flowId=stress/python_udf/udf_thirdparty_packages.groovy#python_udf_thirdparty_packages" type="SuiteFailure">            versions["pandas"] = "not_found"
        try:
            import jieba
            versions["jieba"] = jieba.__version__
        except:
            versions["jieba"] = "not_found"
        return json.dumps(versions)
    \$\$
    """
    def rVer = sql("SELECT py_pkg_versions()")
^^^^^^^^^^^^^^^^^^^^^^^^^^ERROR LINE^^^^^^^^^^^^^^^^^^^^^^^^^^
    assert rVer[0][0] != null
    def verJson = new groovy.json.JsonSlurper().parseText(rVer[0][0].toString())
    logger.info("Package versions: python=${verJson.python}, numpy=${verJson.numpy}, pandas=${verJson.pandas}, jieba=${verJson.jieba}")
    // 验证包确实已安装（非 not_found）
    assert verJson.numpy != 'not_found', "numpy should be installed"
    assert verJson.pandas != 'not_found', "pandas should be installed"
    assert verJson.jieba != 'not_found', "jieba should be installed"
    logger.info("Package version verification: PASS")
    logger.warn("Package version info: skipped — PRODUCT LIMITATION: Python UDF does not support zero-argument functions")


java.sql.SQLException: errCode = 2, detailMessage = (172.20.49.73)[INVALID_ARGUMENT]Python UDF input types is empty