fix: job execute again if exception & insert_memory_usage_limit config (

#3726)
4paradigm · Jan 31, 2024 · 7d755ff · 7d755ff
1 parent 6f2e511
commit 7d755ff
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/java/openmldb-batch/src/main/scala/com/_4paradigm/openmldb/batch/SparkPlanner.scala b/java/openmldb-batch/src/main/scala/com/_4paradigm/openmldb/batch/SparkPlanner.scala
@@ -393,7 +393,7 @@ class SparkPlanner(session: SparkSession, config: OpenmldbBatchConfig, sparkAppN
       case e: Exception =>
         println("Get exception: " + e.getMessage)
         e.printStackTrace()
-        body(sqlEngine)
+        throw e
     } finally {
       if (sqlEngine != null) {
         sqlEngine.close()

diff --git a/src/sdk/sql_cluster_router.cc b/src/sdk/sql_cluster_router.cc
@@ -2891,7 +2891,7 @@ std::shared_ptr<hybridse::sdk::ResultSet> SQLClusterRouter::ExecuteSQL(
                 ::openmldb::base::Status base_status;
                 if (is_online_mode) {
                     // Handle in online mode
-                    config.emplace("insert_memory_usage_limit",
+                    config.emplace("spark.insert_memory_usage_limit",
                             std::to_string(insert_memory_usage_limit_.load(std::memory_order_relaxed)));
                     base_status = ImportOnlineData(sql, config, database, is_sync_job, offline_job_timeout, &job_info);
                 } else {