Skip to content

Commit fa91a3f

Browse files
Davidhua1996jefftlin
authored andcommitted
Fix the problem in deleting temporary configuration.
1 parent 509421c commit fa91a3f

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

  • streamis-jobmanager/streamis-job-launcher/streamis-job-launcher-service/src/main/java/com/webank/wedatasphere/streamis/jobmanager/launcher/dao/impl

streamis-jobmanager/streamis-job-launcher/streamis-job-launcher-service/src/main/java/com/webank/wedatasphere/streamis/jobmanager/launcher/dao/impl/StreamJobConfMapper.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@
6060
</delete>
6161

6262
<delete id="deleteTemporaryConfValue">
63-
DELETE c FROM `linkis_stream_job_config` c INNER JOIN `linkis_stream_job_config_def` d ON c.job_id = 0 AND d.id = c.ref_def_id AND d.is_temp = 1;
63+
DELETE c FROM `linkis_stream_job_config` c INNER JOIN `linkis_stream_job_config_def` d ON c.job_id = #{jobId} AND d.id = c.ref_def_id AND d.is_temp = 1;
6464
</delete>
6565
<insert id="batchInsertValues">
6666
INSERT INTO `linkis_stream_job_config`(`job_id`, `job_name`, `key`, `value`, `ref_def_id`) VALUES

0 commit comments

Comments
 (0)