-
Type: Bug
-
Status: Resolved
-
Priority: Minor
-
Resolution: Fixed
-
Affects Version/s: 11.1-SNAPSHOT
-
Component/s: Streams
-
Tags:
-
Team:PLATFORM
-
Sprint:nxplatform 11.1.18, nxplatform 11.1.19
-
Story Points:2
This test is failing systematically on CI when kafka is enable:
[ERROR] Failures: [ERROR] TestLogStreamProcessorKafka>TestStreamProcessor.testComputationRecoveryPolicy:635 LogLag{lower=0, upper=2, lag=2, lowerOffset=0, upperOffset=2} expected:<1> but was:<2> [ERROR] TestLogStreamProcessorKafkaNoSubscribe>TestStreamProcessor.testComputationRecoveryPolicy:635 LogLag{lower=0, upper=2, lag=2, lowerOffset=0, upperOffset=2} expected:<1> but was:<2> [INFO] [ERROR] Tests run: 234, Failures: 2, Errors: 0, Skipped: 37 [INFO]
The problem is that there are 3 tests on the recovery mode (CQ, Kafka and KafkaNoSubscribe) only the first test works because of the usage of a static counter in ComputationRunner.