fix

Author: JkSelf

backends-velox/src/main/scala/org/apache/gluten/execution/HashJoinExecTransformer.scala

@@ -135,9 +135,12 @@ case class BroadcastHashJoinExecTransformer(
   override def columnarInputRDDs: Seq[RDD[ColumnarBatch]] = {
     val streamedRDD = getColumnarInputRDDs(streamedPlan)
     val executionId = sparkContext.getLocalProperty(SQLExecution.EXECUTION_ID_KEY)
+    var cacheKey = ""
     if (executionId != null) {
+      cacheKey = "Gluten_Execution_" + executionId + ":" + buildHashTableId
       GlutenDriverEndpoint.collectResources(executionId, buildBroadcastTableId)
     } else {
+      cacheKey = "Gluten_Execution_" + ":" + buildHashTableId
       logWarning(
         s"Can not trace broadcast table data $buildBroadcastTableId" +
           s" because execution id is null." +
@@ -174,7 +177,7 @@ case class BroadcastHashJoinExecTransformer(
         buildPlan.output,
         filterBuildColumns,
         filterPropagatesNulls,
-        buildBroadcastTableId,
+        cacheKey,
         isNullAwareAntiJoin,
         bloomFilterPushdownSize,
         metrics.get("buildHashTableTime")

cpp/velox/compute/WholeStageResultIterator.cc

@@ -77,11 +77,7 @@ std::string getVeloxTaskId(const SparkTaskInfo& taskInfo) {
   if (taskInfo.executionId != -1) {
     return fmt::format("Gluten_Execution_{}", std::to_string(taskInfo.executionId));
   }
-  return fmt::format(
-      "Gluten_Stage_{}_TID_{}_VTID_{}",
-      std::to_string(taskInfo.stageId),
-      std::to_string(taskInfo.taskId),
-      std::to_string(taskInfo.vId));
+  return fmt::format("Gluten_Execution_{}", "");
 }
 } // namespace