|
@@ -296,14 +296,14 @@ public class ExportTaskServiceImpl implements ExportTaskService {
|
|
|
e.setStatus(ExportTaskStatus.TERMINATING);
|
|
|
exportTaskRepo.save(e);
|
|
|
String key = CacheConstants.CACHE_OE_EXPORT_TASK_STOP + e.getId();
|
|
|
- redisClient.set(key, e.getId(), cacheTimeOut);
|
|
|
+ redisClient.set(key, key, cacheTimeOut);
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
public void checkStopExportTaskById(Long taskId) {
|
|
|
String key = CacheConstants.CACHE_OE_EXPORT_TASK_STOP + taskId;
|
|
|
- Long id=redisClient.get(key,Long.class);
|
|
|
- if(id!=null) {
|
|
|
+ String ob=redisClient.get(key,String.class);
|
|
|
+ if(ob!=null) {
|
|
|
redisClient.delete(key);
|
|
|
throw new ExportTaskStopException();
|
|
|
}
|