add protection to eager swap before consumer is fully subscribed #201
GitHub Actions / JUnit Test Report
failed
Dec 5, 2024 in 0s
6800 tests run, 6784 passed, 0 skipped, 16 failed.
Annotations
github-actions / JUnit Test Report
VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)Raw output
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)
at app//com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
at app//com.linkedin.davinci.consumer.VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener(VeniceChangelogConsumerImplTest.java:442)
github-actions / JUnit Test Report
VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)Raw output
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)
at app//com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
at app//com.linkedin.davinci.consumer.VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener(VeniceChangelogConsumerImplTest.java:442)
github-actions / JUnit Test Report
VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)Raw output
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)
at app//com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
at app//com.linkedin.davinci.consumer.VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener(VeniceChangelogConsumerImplTest.java:442)
github-actions / JUnit Test Report
VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)Raw output
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)
at app//com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
at app//com.linkedin.davinci.consumer.VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener(VeniceChangelogConsumerImplTest.java:442)
github-actions / JUnit Test Report
VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)Raw output
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)
at app//com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
at app//com.linkedin.davinci.consumer.VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener(VeniceChangelogConsumerImplTest.java:442)
github-actions / JUnit Test Report
SITWithTWiseWithoutBufferAfterLeaderTest.testOffsetSyncBeforeGracefulShutDown[0](AA_ON)
java.lang.AssertionError: pcs.getLatestProcessedLocalVersionTopicOffset() for PARTITION_FOO is expected to be zero! expected [0] but found [2]
Raw output
java.lang.AssertionError: pcs.getLatestProcessedLocalVersionTopicOffset() for PARTITION_FOO is expected to be zero! expected [0] but found [2]
at org.testng.Assert.fail(Assert.java:96)
at org.testng.Assert.failNotEquals(Assert.java:776)
at org.testng.Assert.assertEqualsImpl(Assert.java:137)
at org.testng.Assert.assertEquals(Assert.java:118)
at org.testng.Assert.assertEquals(Assert.java:547)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testOffsetSyncBeforeGracefulShutDown$113(StoreIngestionTaskTest.java:4132)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:879)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:773)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.testOffsetSyncBeforeGracefulShutDown(StoreIngestionTaskTest.java:4166)
github-actions / JUnit Test Report
NativeMetadataRepositoryTest.testNativeMetadataRepositoryStats
java.lang.AssertionError: expected [2000.0] but found [1000.0]
Raw output
java.lang.AssertionError: expected [2000.0] but found [1000.0]
at org.testng.Assert.fail(Assert.java:96)
at org.testng.Assert.failNotEquals(Assert.java:776)
at org.testng.Assert.assertEqualsImpl(Assert.java:137)
at org.testng.Assert.assertEquals(Assert.java:118)
at org.testng.Assert.assertEquals(Assert.java:442)
at com.linkedin.davinci.repository.NativeMetadataRepositoryTest.lambda$testNativeMetadataRepositoryStats$5(NativeMetadataRepositoryTest.java:136)
at com.linkedin.venice.utils.TestUtils.waitForNonDeterministicAssertion(TestUtils.java:243)
at com.linkedin.venice.utils.TestUtils.waitForNonDeterministicAssertion(TestUtils.java:228)
at com.linkedin.venice.utils.TestUtils.waitForNonDeterministicAssertion(TestUtils.java:220)
at com.linkedin.davinci.repository.NativeMetadataRepositoryTest.testNativeMetadataRepositoryStats(NativeMetadataRepositoryTest.java:133)
github-actions / JUnit Test Report
BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet
org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet() didn't finish within the time-out 5000
Raw output
org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet() didn't finish within the time-out 5000
at [email protected]/java.util.Calendar$Builder.build(Calendar.java:1520)
at [email protected]/sun.util.locale.provider.CalendarProviderImpl.getInstance(CalendarProviderImpl.java:87)
at [email protected]/java.util.Calendar.createCalendar(Calendar.java:1696)
at [email protected]/java.util.Calendar.getInstance(Calendar.java:1675)
at app//org.apache.logging.log4j.core.util.datetime.FastDatePrinter.newCalendar(FastDatePrinter.java:467)
at app//org.apache.logging.log4j.core.util.datetime.FastDatePrinter.format(FastDatePrinter.java:448)
at app//org.apache.logging.log4j.core.util.datetime.FastDateFormat.format(FastDateFormat.java:431)
at app//org.apache.logging.log4j.core.pattern.DatePatternConverter$PatternFormatter.format(DatePatternConverter.java:68)
at app//org.apache.logging.log4j.core.pattern.DatePatternConverter$CachedTime.<init>(DatePatternConverter.java:155)
at app//org.apache.logging.log4j.core.pattern.DatePatternConverter.formatWithoutThreadLocals(DatePatternConverter.java:310)
at app//org.apache.logging.log4j.core.pattern.DatePatternConverter.format(DatePatternConverter.java:290)
at app//org.apache.logging.log4j.core.pattern.DatePatternConverter.format(DatePatternConverter.java:265)
at app//org.apache.logging.log4j.core.layout.PatternLayout$NoFormatPatternSerializer.toSerializable(PatternLayout.java:343)
at app//org.apache.logging.log4j.core.layout.PatternLayout.toText(PatternLayout.java:241)
at app//org.apache.logging.log4j.core.layout.PatternLayout.encode(PatternLayout.java:226)
at app//org.apache.logging.log4j.core.layout.PatternLayout.encode(PatternLayout.java:60)
at app//org.apache.logging.log4j.core.appender.AbstractOutputStreamAppender.directEncodeEvent(AbstractOutputStreamAppender.java:197)
at app//org.apache.logging.log4j.core.appender.AbstractOutputStreamAppender.tryAppend(AbstractOutputStreamAppender.java:190)
at app//org.apache.logging.log4j.core.appender.AbstractOutputStreamAppender.append(AbstractOutputStreamAppender.java:181)
at app//org.apache.logging.log4j.core.config.AppenderControl.tryCallAppender(AppenderControl.java:161)
at app//org.apache.logging.log4j.core.config.AppenderControl.callAppender0(AppenderControl.java:134)
at app//org.apache.logging.log4j.core.config.AppenderControl.callAppenderPreventRecursion(AppenderControl.java:125)
at app//org.apache.logging.log4j.core.config.AppenderControl.callAppender(AppenderControl.java:89)
at app//org.apache.logging.log4j.core.config.LoggerConfig.callAppenders(LoggerConfig.java:542)
at app//org.apache.logging.log4j.core.config.LoggerConfig.processLogEvent(LoggerConfig.java:500)
at app//org.apache.logging.log4j.core.config.LoggerConfig.log(LoggerConfig.java:483)
at app//org.apache.logging.log4j.core.config.LoggerConfig.log(LoggerConfig.java:417)
at app//org.apache.logging.log4j.core.config.AwaitCompletionReliabilityStrategy.log(AwaitCompletionReliabilityStrategy.java:82)
at app//org.apache.logging.log4j.core.Logger.log(Logger.java:161)
at app//org.apache.logging.log4j.spi.AbstractLogger.tryLogMessage(AbstractLogger.java:2205)
at app//org.apache.logging.log4j.spi.AbstractLogger.logMessageTrackRecursion(AbstractLogger.java:2159)
at app//org.apache.logging.log4j.spi.AbstractLogger.logMessageSafely(AbstractLogger.java:2142)
at app//org.apache.logging.log4j.spi.AbstractLogger.logMessage(AbstractLogger.java:2046)
at app//org.apache.logging.log4j.spi.AbstractLogger.logIfEnabled(AbstractLogger.java:1915)
at app//org.apache.logging.log4j.spi.AbstractLogger.info(AbstractLogger.java:1454)
at app//com.linkedin.venice.fastclient.utils.TestClientSimulator.restRequest(TestClientSimulator.java:266)
at app//com.linkedin.venice.fastclient.transport.R2TransportClient.post(R2TransportClient.java:51)
at app//com.linkedin.venice.fastclient.DispatchingAvroGenericStoreClient.multiKeyStreamingRequest(DispatchingAvroGenericStoreClient.java:479)
at app//com.linkedin.venice.fastclient.DispatchingAvroGenericStoreClient.streamingBatchGet(DispatchingAvroGenericStoreClient.java:365)
at app//com.linkedin.venice.fastclient.DelegatingAvroStoreClient.streamingBatchGet(DelegatingAvroStoreClient.java:99)
at app//com.linkedin.venice.fastclient.StatsAvroGenericStoreClient.streamingBatchGet(StatsAvroGenericStoreClient.java:70)
at app//com.linkedin.venice.fastclient.InternalAvroStoreClient.streamingBatchGet(InternalAvroStoreClient.java:65)
at app//com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.callStreamingBatchGetAndVerifyResults(BatchGetAvroStoreClientUnitTest.java:770)
at app//com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.callStreamingBatchGetAndVerifyResults(BatchGetAvroStoreClientUnitTest.java:759)
at app//com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet(BatchGetAvroStoreClientUnitTest.java:65)
github-actions / JUnit Test Report
VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)Raw output
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)
at app//com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
at app//com.linkedin.davinci.consumer.VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener(VeniceChangelogConsumerImplTest.java:442)
github-actions / JUnit Test Report
VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)Raw output
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)
at app//com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
at app//com.linkedin.davinci.consumer.VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener(VeniceChangelogConsumerImplTest.java:442)
github-actions / JUnit Test Report
VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)Raw output
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)
at app//com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
at app//com.linkedin.davinci.consumer.VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener(VeniceChangelogConsumerImplTest.java:442)
github-actions / JUnit Test Report
VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)Raw output
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)
at app//com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
at app//com.linkedin.davinci.consumer.VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener(VeniceChangelogConsumerImplTest.java:442)
github-actions / JUnit Test Report
VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)Raw output
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)
at app//com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
at app//com.linkedin.davinci.consumer.VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener(VeniceChangelogConsumerImplTest.java:442)
github-actions / JUnit Test Report
SITWithTWiseWithoutBufferAfterLeaderTest.testOffsetSyncBeforeGracefulShutDown[0](AA_ON)
java.lang.AssertionError: pcs.getLatestProcessedLocalVersionTopicOffset() for PARTITION_FOO is expected to be zero! expected [0] but found [2]
Raw output
java.lang.AssertionError: pcs.getLatestProcessedLocalVersionTopicOffset() for PARTITION_FOO is expected to be zero! expected [0] but found [2]
at org.testng.Assert.fail(Assert.java:96)
at org.testng.Assert.failNotEquals(Assert.java:776)
at org.testng.Assert.assertEqualsImpl(Assert.java:137)
at org.testng.Assert.assertEquals(Assert.java:118)
at org.testng.Assert.assertEquals(Assert.java:547)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testOffsetSyncBeforeGracefulShutDown$113(StoreIngestionTaskTest.java:4132)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:879)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:773)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.testOffsetSyncBeforeGracefulShutDown(StoreIngestionTaskTest.java:4166)
github-actions / JUnit Test Report
NativeMetadataRepositoryTest.testNativeMetadataRepositoryStats
java.lang.AssertionError: expected [2000.0] but found [1000.0]
Raw output
java.lang.AssertionError: expected [2000.0] but found [1000.0]
at org.testng.Assert.fail(Assert.java:96)
at org.testng.Assert.failNotEquals(Assert.java:776)
at org.testng.Assert.assertEqualsImpl(Assert.java:137)
at org.testng.Assert.assertEquals(Assert.java:118)
at org.testng.Assert.assertEquals(Assert.java:442)
at com.linkedin.davinci.repository.NativeMetadataRepositoryTest.lambda$testNativeMetadataRepositoryStats$5(NativeMetadataRepositoryTest.java:136)
at com.linkedin.venice.utils.TestUtils.waitForNonDeterministicAssertion(TestUtils.java:243)
at com.linkedin.venice.utils.TestUtils.waitForNonDeterministicAssertion(TestUtils.java:228)
at com.linkedin.venice.utils.TestUtils.waitForNonDeterministicAssertion(TestUtils.java:220)
at com.linkedin.davinci.repository.NativeMetadataRepositoryTest.testNativeMetadataRepositoryStats(NativeMetadataRepositoryTest.java:133)
github-actions / JUnit Test Report
BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet
org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet() didn't finish within the time-out 5000
Raw output
org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet() didn't finish within the time-out 5000
at [email protected]/java.util.Calendar$Builder.build(Calendar.java:1520)
at [email protected]/sun.util.locale.provider.CalendarProviderImpl.getInstance(CalendarProviderImpl.java:87)
at [email protected]/java.util.Calendar.createCalendar(Calendar.java:1696)
at [email protected]/java.util.Calendar.getInstance(Calendar.java:1675)
at app//org.apache.logging.log4j.core.util.datetime.FastDatePrinter.newCalendar(FastDatePrinter.java:467)
at app//org.apache.logging.log4j.core.util.datetime.FastDatePrinter.format(FastDatePrinter.java:448)
at app//org.apache.logging.log4j.core.util.datetime.FastDateFormat.format(FastDateFormat.java:431)
at app//org.apache.logging.log4j.core.pattern.DatePatternConverter$PatternFormatter.format(DatePatternConverter.java:68)
at app//org.apache.logging.log4j.core.pattern.DatePatternConverter$CachedTime.<init>(DatePatternConverter.java:155)
at app//org.apache.logging.log4j.core.pattern.DatePatternConverter.formatWithoutThreadLocals(DatePatternConverter.java:310)
at app//org.apache.logging.log4j.core.pattern.DatePatternConverter.format(DatePatternConverter.java:290)
at app//org.apache.logging.log4j.core.pattern.DatePatternConverter.format(DatePatternConverter.java:265)
at app//org.apache.logging.log4j.core.layout.PatternLayout$NoFormatPatternSerializer.toSerializable(PatternLayout.java:343)
at app//org.apache.logging.log4j.core.layout.PatternLayout.toText(PatternLayout.java:241)
at app//org.apache.logging.log4j.core.layout.PatternLayout.encode(PatternLayout.java:226)
at app//org.apache.logging.log4j.core.layout.PatternLayout.encode(PatternLayout.java:60)
at app//org.apache.logging.log4j.core.appender.AbstractOutputStreamAppender.directEncodeEvent(AbstractOutputStreamAppender.java:197)
at app//org.apache.logging.log4j.core.appender.AbstractOutputStreamAppender.tryAppend(AbstractOutputStreamAppender.java:190)
at app//org.apache.logging.log4j.core.appender.AbstractOutputStreamAppender.append(AbstractOutputStreamAppender.java:181)
at app//org.apache.logging.log4j.core.config.AppenderControl.tryCallAppender(AppenderControl.java:161)
at app//org.apache.logging.log4j.core.config.AppenderControl.callAppender0(AppenderControl.java:134)
at app//org.apache.logging.log4j.core.config.AppenderControl.callAppenderPreventRecursion(AppenderControl.java:125)
at app//org.apache.logging.log4j.core.config.AppenderControl.callAppender(AppenderControl.java:89)
at app//org.apache.logging.log4j.core.config.LoggerConfig.callAppenders(LoggerConfig.java:542)
at app//org.apache.logging.log4j.core.config.LoggerConfig.processLogEvent(LoggerConfig.java:500)
at app//org.apache.logging.log4j.core.config.LoggerConfig.log(LoggerConfig.java:483)
at app//org.apache.logging.log4j.core.config.LoggerConfig.log(LoggerConfig.java:417)
at app//org.apache.logging.log4j.core.config.AwaitCompletionReliabilityStrategy.log(AwaitCompletionReliabilityStrategy.java:82)
at app//org.apache.logging.log4j.core.Logger.log(Logger.java:161)
at app//org.apache.logging.log4j.spi.AbstractLogger.tryLogMessage(AbstractLogger.java:2205)
at app//org.apache.logging.log4j.spi.AbstractLogger.logMessageTrackRecursion(AbstractLogger.java:2159)
at app//org.apache.logging.log4j.spi.AbstractLogger.logMessageSafely(AbstractLogger.java:2142)
at app//org.apache.logging.log4j.spi.AbstractLogger.logMessage(AbstractLogger.java:2046)
at app//org.apache.logging.log4j.spi.AbstractLogger.logIfEnabled(AbstractLogger.java:1915)
at app//org.apache.logging.log4j.spi.AbstractLogger.info(AbstractLogger.java:1454)
at app//com.linkedin.venice.fastclient.utils.TestClientSimulator.restRequest(TestClientSimulator.java:266)
at app//com.linkedin.venice.fastclient.transport.R2TransportClient.post(R2TransportClient.java:51)
at app//com.linkedin.venice.fastclient.DispatchingAvroGenericStoreClient.multiKeyStreamingRequest(DispatchingAvroGenericStoreClient.java:479)
at app//com.linkedin.venice.fastclient.DispatchingAvroGenericStoreClient.streamingBatchGet(DispatchingAvroGenericStoreClient.java:365)
at app//com.linkedin.venice.fastclient.DelegatingAvroStoreClient.streamingBatchGet(DelegatingAvroStoreClient.java:99)
at app//com.linkedin.venice.fastclient.StatsAvroGenericStoreClient.streamingBatchGet(StatsAvroGenericStoreClient.java:70)
at app//com.linkedin.venice.fastclient.InternalAvroStoreClient.streamingBatchGet(InternalAvroStoreClient.java:65)
at app//com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.callStreamingBatchGetAndVerifyResults(BatchGetAvroStoreClientUnitTest.java:770)
at app//com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.callStreamingBatchGetAndVerifyResults(BatchGetAvroStoreClientUnitTest.java:759)
at app//com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet(BatchGetAvroStoreClientUnitTest.java:65)
Loading