diff options
author | Kai <lukai@chinamobile.com> | 2020-10-10 09:47:29 +0800 |
---|---|---|
committer | Kai <lukai@chinamobile.com> | 2020-10-10 10:22:30 +0800 |
commit | 0a5a6e0459876316b633b3801c2475b5a92d38a5 (patch) | |
tree | 520c94efa20353204a56a292f189a2a58fdb1bd1 /dcae-analytics/dcae-analytics-tca-web/src/main | |
parent | 85abdfd0c4b791eb5a149050bfd347ace53425a1 (diff) |
fix issues
Issue-ID: DCAEGEN2-2469
Issue-ID: DCAEGEN2-2470
Signed-off-by: Kai Lu <lukai@chinamobile.com>
Change-Id: I13b0422e4f7a9f722c8c310eb76a66aa6a01679f
Diffstat (limited to 'dcae-analytics/dcae-analytics-tca-web/src/main')
-rw-r--r-- | dcae-analytics/dcae-analytics-tca-web/src/main/java/org/onap/dcae/analytics/tca/web/service/TcaProcessingServiceImpl.java | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/dcae-analytics/dcae-analytics-tca-web/src/main/java/org/onap/dcae/analytics/tca/web/service/TcaProcessingServiceImpl.java b/dcae-analytics/dcae-analytics-tca-web/src/main/java/org/onap/dcae/analytics/tca/web/service/TcaProcessingServiceImpl.java index e05026c..7f6891d 100644 --- a/dcae-analytics/dcae-analytics-tca-web/src/main/java/org/onap/dcae/analytics/tca/web/service/TcaProcessingServiceImpl.java +++ b/dcae-analytics/dcae-analytics-tca-web/src/main/java/org/onap/dcae/analytics/tca/web/service/TcaProcessingServiceImpl.java @@ -27,7 +27,6 @@ import java.util.List; import java.util.stream.Collectors; import java.util.stream.IntStream; -import org.onap.dcae.analytics.model.AnalyticsModelConstants; import org.onap.dcae.analytics.tca.core.service.GenericTcaExecutionContext; import org.onap.dcae.analytics.tca.core.service.GenericTcaProcessingContext; import org.onap.dcae.analytics.tca.core.service.GenericTcaResultContext; @@ -69,8 +68,7 @@ public class TcaProcessingServiceImpl implements TcaProcessingService { return IntStream.range(0, cefMessages.size()) // generate initial Processing contexts .mapToObj(cefMessageIndex -> GenericTcaExecutionContext.builder() - .requestId(executionRequestId + - AnalyticsModelConstants.ANALYTICS_REQUEST_ID_DELIMITER + cefMessageIndex) + .requestId(executionRequestId) .transactionId(executionTransactionId) .messageIndex(cefMessageIndex) .cefMessage(cefMessages.get(cefMessageIndex)) |