File tree 1 file changed +4
-4
lines changed
cqp-core/src/main/java/com/quantori/cqp/core/task/service
1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -56,7 +56,7 @@ public class TaskPersistenceServiceImpl implements TaskPersistenceService {
56
56
private static final Duration STALE_THRESHOLD = Duration .ofMinutes (15 );
57
57
private static final Duration OUTDATED_THRESHOLD = Duration .ofHours (24 );
58
58
private static final Duration RESTART_FLAG_THRESHOLD = Duration .ofMinutes (5 );
59
- private final ObjectMapper objectMapper = new ObjectMapper () ;
59
+ private final ObjectMapper objectMapper ;
60
60
private final ActorSystem <?> actorSystem ;
61
61
private final ActorRef <TaskServiceActor .Command > rootActorRef ;
62
62
private final Supplier <StreamTaskService > streamTaskServiceSupplier ;
@@ -76,9 +76,9 @@ public TaskPersistenceServiceImpl(
76
76
this .streamTaskServiceSupplier = streamTaskServiceSupplier ;
77
77
this .taskStatusDao = taskStatusDao ;
78
78
this .entityHolder = entityHolder ;
79
-
80
- objectMapper .setVisibility (PropertyAccessor .FIELD , JsonAutoDetect .Visibility .ANY );
81
- objectMapper .configure (SerializationFeature .FAIL_ON_EMPTY_BEANS , false );
79
+ this . objectMapper = new ObjectMapper ()
80
+ .setVisibility (PropertyAccessor .FIELD , JsonAutoDetect .Visibility .ANY )
81
+ .configure (SerializationFeature .FAIL_ON_EMPTY_BEANS , false );
82
82
83
83
this .schedulingIsEnabled = enableScheduling ;
84
84
if (enableScheduling ) {
You can’t perform that action at this time.
0 commit comments