See 
<https://builds.apache.org/job/kafka-0.11.0-jdk7/301/display/redirect?page=changes>

Changes:

[jason] KAFKA-5756; Connect WorkerSourceTask synchronization issue on flush

------------------------------------------
[...truncated 2.46 MB...]

org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > 
shouldReturnNullIfKeyDoesntExist PASSED

org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > 
shouldThrowInvalidStoreExceptionDuringRebalance STARTED

org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > 
shouldThrowInvalidStoreExceptionDuringRebalance PASSED

org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > 
shouldThrowInvalidStoreExceptionOnAllDuringRebalance STARTED

org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > 
shouldThrowInvalidStoreExceptionOnAllDuringRebalance PASSED

org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > 
shouldSupportRange STARTED

org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > 
shouldSupportRange PASSED

org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > 
shouldFindValueForKeyWhenMultiStores STARTED

org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > 
shouldFindValueForKeyWhenMultiStores PASSED

org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > 
shouldThrowInvalidStoreExceptionOnRangeDuringRebalance STARTED

org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > 
shouldThrowInvalidStoreExceptionOnRangeDuringRebalance PASSED

org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > 
shouldSupportRangeAcrossMultipleKVStores STARTED

org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > 
shouldSupportRangeAcrossMultipleKVStores PASSED

org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > 
shouldSupportAllAcrossMultipleStores STARTED

org.apache.kafka.streams.state.internals.CompositeReadOnlyKeyValueStoreTest > 
shouldSupportAllAcrossMultipleStores PASSED

org.apache.kafka.streams.state.internals.SegmentsTest > 
shouldCleanupSegmentsThatHaveExpired STARTED

org.apache.kafka.streams.state.internals.SegmentsTest > 
shouldCleanupSegmentsThatHaveExpired PASSED

org.apache.kafka.streams.state.internals.SegmentsTest > 
shouldBaseSegmentIntervalOnRetentionAndNumSegments STARTED

org.apache.kafka.streams.state.internals.SegmentsTest > 
shouldBaseSegmentIntervalOnRetentionAndNumSegments PASSED

org.apache.kafka.streams.state.internals.SegmentsTest > 
shouldGetSegmentsWithinTimeRangeOutOfOrder STARTED

org.apache.kafka.streams.state.internals.SegmentsTest > 
shouldGetSegmentsWithinTimeRangeOutOfOrder PASSED

org.apache.kafka.streams.state.internals.SegmentsTest > 
shouldCloseAllOpenSegments STARTED

org.apache.kafka.streams.state.internals.SegmentsTest > 
shouldCloseAllOpenSegments PASSED

org.apache.kafka.streams.state.internals.SegmentsTest > 
shouldGetSegmentsWithinTimeRange STARTED

org.apache.kafka.streams.state.internals.SegmentsTest > 
shouldGetSegmentsWithinTimeRange PASSED

org.apache.kafka.streams.state.internals.SegmentsTest > 
shouldNotCreateSegmentThatIsAlreadyExpired STARTED

org.apache.kafka.streams.state.internals.SegmentsTest > 
shouldNotCreateSegmentThatIsAlreadyExpired PASSED

org.apache.kafka.streams.state.internals.SegmentsTest > shouldCreateSegments 
STARTED

org.apache.kafka.streams.state.internals.SegmentsTest > shouldCreateSegments 
PASSED

org.apache.kafka.streams.state.internals.SegmentsTest > 
shouldOpenExistingSegments STARTED

org.apache.kafka.streams.state.internals.SegmentsTest > 
shouldOpenExistingSegments PASSED

org.apache.kafka.streams.state.internals.SegmentsTest > 
shouldGetSegmentIdsFromTimestamp STARTED

org.apache.kafka.streams.state.internals.SegmentsTest > 
shouldGetSegmentIdsFromTimestamp PASSED

org.apache.kafka.streams.state.internals.SegmentsTest > shouldRollSegments 
STARTED

org.apache.kafka.streams.state.internals.SegmentsTest > shouldRollSegments 
PASSED

org.apache.kafka.streams.state.internals.SegmentsTest > 
shouldGetSegmentNameFromId STARTED

org.apache.kafka.streams.state.internals.SegmentsTest > 
shouldGetSegmentNameFromId PASSED

org.apache.kafka.streams.state.internals.SegmentsTest > 
shouldGetSegmentForTimestamp STARTED

org.apache.kafka.streams.state.internals.SegmentsTest > 
shouldGetSegmentForTimestamp PASSED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > 
shouldFetchExactKeys STARTED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > 
shouldFetchExactKeys PASSED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > shouldRemove 
STARTED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > shouldRemove 
PASSED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > 
shouldFindValuesWithinMergingSessionWindowRange STARTED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > 
shouldFindValuesWithinMergingSessionWindowRange PASSED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > 
shouldFetchAllSessionsWithSameRecordKey STARTED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > 
shouldFetchAllSessionsWithSameRecordKey PASSED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > 
shouldFindSessionsToMerge STARTED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > 
shouldFindSessionsToMerge PASSED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > 
shouldPutAndFindSessionsInRange STARTED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest > 
shouldPutAndFindSessionsInRange PASSED

org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreKeyValueIteratorTest
 > shouldHaveNextFromCache STARTED

org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreKeyValueIteratorTest
 > shouldHaveNextFromCache PASSED

org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreKeyValueIteratorTest
 > shouldHaveNextFromStore STARTED

org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreKeyValueIteratorTest
 > shouldHaveNextFromStore PASSED

org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreKeyValueIteratorTest
 > shouldPeekNextKeyFromCache STARTED

org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreKeyValueIteratorTest
 > shouldPeekNextKeyFromCache PASSED

org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreKeyValueIteratorTest
 > shouldPeekNextKeyFromStore STARTED

org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreKeyValueIteratorTest
 > shouldPeekNextKeyFromStore PASSED

org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreKeyValueIteratorTest
 > shouldIterateBothStoreAndCache STARTED

org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreKeyValueIteratorTest
 > shouldIterateBothStoreAndCache PASSED

org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreKeyValueIteratorTest
 > shouldGetNextFromCache STARTED

org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreKeyValueIteratorTest
 > shouldGetNextFromCache PASSED

org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreKeyValueIteratorTest
 > shouldGetNextFromStore STARTED

org.apache.kafka.streams.state.internals.MergedSortedCacheWrappedWindowStoreKeyValueIteratorTest
 > shouldGetNextFromStore PASSED

org.apache.kafka.streams.state.internals.ChangeLoggingSegmentedBytesStoreTest > 
shouldFlushUnderlyingStore STARTED

org.apache.kafka.streams.state.internals.ChangeLoggingSegmentedBytesStoreTest > 
shouldFlushUnderlyingStore PASSED

org.apache.kafka.streams.state.internals.ChangeLoggingSegmentedBytesStoreTest > 
shouldCloseUnderlyingStore STARTED

org.apache.kafka.streams.state.internals.ChangeLoggingSegmentedBytesStoreTest > 
shouldCloseUnderlyingStore PASSED

org.apache.kafka.streams.state.internals.ChangeLoggingSegmentedBytesStoreTest > 
shouldLogPuts STARTED

org.apache.kafka.streams.state.internals.ChangeLoggingSegmentedBytesStoreTest > 
shouldLogPuts PASSED

org.apache.kafka.streams.state.internals.ChangeLoggingSegmentedBytesStoreTest > 
shouldInitUnderlyingStore STARTED

org.apache.kafka.streams.state.internals.ChangeLoggingSegmentedBytesStoreTest > 
shouldInitUnderlyingStore PASSED

org.apache.kafka.streams.state.internals.ChangeLoggingSegmentedBytesStoreTest > 
shouldLogRemoves STARTED

org.apache.kafka.streams.state.internals.ChangeLoggingSegmentedBytesStoreTest > 
shouldLogRemoves PASSED

org.apache.kafka.streams.state.internals.ChangeLoggingSegmentedBytesStoreTest > 
shouldDelegateToUnderlyingStoreWhenFetching STARTED

org.apache.kafka.streams.state.internals.ChangeLoggingSegmentedBytesStoreTest > 
shouldDelegateToUnderlyingStoreWhenFetching PASSED

org.apache.kafka.streams.state.internals.WindowStoreUtilsTest > 
testSerialization STARTED

org.apache.kafka.streams.state.internals.WindowStoreUtilsTest > 
testSerialization PASSED

org.apache.kafka.streams.state.internals.RocksDBStoreTest > 
canSpecifyConfigSetterAsString STARTED

org.apache.kafka.streams.state.internals.RocksDBStoreTest > 
canSpecifyConfigSetterAsString PASSED

org.apache.kafka.streams.state.internals.RocksDBStoreTest > 
canSpecifyConfigSetterAsClass STARTED

org.apache.kafka.streams.state.internals.RocksDBStoreTest > 
canSpecifyConfigSetterAsClass PASSED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreSupplierTest > 
shouldHaveMeteredStoreWhenNotLoggedOrCached STARTED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreSupplierTest > 
shouldHaveMeteredStoreWhenNotLoggedOrCached PASSED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreSupplierTest > 
shouldReturnRocksDbStoreWhenCachingDisabled STARTED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreSupplierTest > 
shouldReturnRocksDbStoreWhenCachingDisabled PASSED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreSupplierTest > 
shouldCreateLoggingEnabledStoreWhenStoreLogged STARTED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreSupplierTest > 
shouldCreateLoggingEnabledStoreWhenStoreLogged PASSED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreSupplierTest > 
shouldReturnCachedSessionStoreWhenCachingEnabled STARTED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreSupplierTest > 
shouldReturnCachedSessionStoreWhenCachingEnabled PASSED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreSupplierTest > 
shouldNotBeLoggingEnabledStoreWhenLoggingNotEnabled STARTED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreSupplierTest > 
shouldNotBeLoggingEnabledStoreWhenLoggingNotEnabled PASSED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreSupplierTest > 
shouldHaveMeteredStoreWhenCached STARTED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreSupplierTest > 
shouldHaveMeteredStoreWhenCached PASSED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreSupplierTest > 
shouldHaveMeteredStoreWhenLogged STARTED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreSupplierTest > 
shouldHaveMeteredStoreWhenLogged PASSED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreSupplierTest > 
shouldReturnRocksDbStoreWhenCachingAndLoggingDisabled STARTED

org.apache.kafka.streams.state.internals.RocksDBSessionStoreSupplierTest > 
shouldReturnRocksDbStoreWhenCachingAndLoggingDisabled PASSED

org.apache.kafka.streams.state.StoresTest > 
shouldCreateInMemoryStoreSupplierWithLoggedConfig STARTED

org.apache.kafka.streams.state.StoresTest > 
shouldCreateInMemoryStoreSupplierWithLoggedConfig PASSED

org.apache.kafka.streams.state.StoresTest > 
shouldCreatePersistenStoreSupplierNotLogged STARTED

org.apache.kafka.streams.state.StoresTest > 
shouldCreatePersistenStoreSupplierNotLogged PASSED

org.apache.kafka.streams.state.StoresTest > 
shouldCreatePersistenStoreSupplierWithLoggedConfig STARTED

org.apache.kafka.streams.state.StoresTest > 
shouldCreatePersistenStoreSupplierWithLoggedConfig PASSED

org.apache.kafka.streams.state.StoresTest > 
shouldCreateInMemoryStoreSupplierNotLogged STARTED

org.apache.kafka.streams.state.StoresTest > 
shouldCreateInMemoryStoreSupplierNotLogged PASSED

1243 tests completed, 23 failed
:streams:test FAILED

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':streams:test'.
> There were failing tests. See the report at: 
> file://<https://builds.apache.org/job/kafka-0.11.0-jdk7/ws/streams/build/reports/tests/test/index.html>

* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug 
option to get more log output.

BUILD FAILED

Total time: 1 hrs 23 mins 53.986 secs
Build step 'Execute shell' marked build as failure
[FINDBUGS] Collecting findbugs analysis files...
Setting 
GRADLE_3_4_RC_2_HOME=/home/jenkins/jenkins-slave/tools/hudson.plugins.gradle.GradleInstallation/Gradle_3.4-rc-2
[FINDBUGS] Searching for all files in 
<https://builds.apache.org/job/kafka-0.11.0-jdk7/ws/> that match the pattern 
**/build/reports/findbugs/*.xml
[FINDBUGS] Parsing 5 files in 
<https://builds.apache.org/job/kafka-0.11.0-jdk7/ws/>
[FINDBUGS] Successfully parsed file 
<https://builds.apache.org/job/kafka-0.11.0-jdk7/ws/clients/build/reports/findbugs/main.xml>
 with 0 unique warnings and 0 duplicates.
[FINDBUGS] Successfully parsed file 
<https://builds.apache.org/job/kafka-0.11.0-jdk7/ws/core/build/reports/findbugs/main.xml>
 with 0 unique warnings and 0 duplicates.
[FINDBUGS] Successfully parsed file 
<https://builds.apache.org/job/kafka-0.11.0-jdk7/ws/examples/build/reports/findbugs/main.xml>
 with 0 unique warnings and 0 duplicates.
[FINDBUGS] Successfully parsed file 
<https://builds.apache.org/job/kafka-0.11.0-jdk7/ws/log4j-appender/build/reports/findbugs/main.xml>
 with 0 unique warnings and 0 duplicates.
[FINDBUGS] Successfully parsed file 
<https://builds.apache.org/job/kafka-0.11.0-jdk7/ws/streams/build/reports/findbugs/main.xml>
 with 0 unique warnings and 0 duplicates.
Setting 
GRADLE_3_4_RC_2_HOME=/home/jenkins/jenkins-slave/tools/hudson.plugins.gradle.GradleInstallation/Gradle_3.4-rc-2
Setting 
GRADLE_3_4_RC_2_HOME=/home/jenkins/jenkins-slave/tools/hudson.plugins.gradle.GradleInstallation/Gradle_3.4-rc-2
<Git Blamer> Using GitBlamer to create author and commit information for all 
warnings.
<Git Blamer> GIT_COMMIT=d93bd1aff96b418c22cdbf9af355c6185d1e9192, 
workspace=<https://builds.apache.org/job/kafka-0.11.0-jdk7/ws/>
[FINDBUGS] Computing warning deltas based on reference build #298
Recording test results
Setting 
GRADLE_3_4_RC_2_HOME=/home/jenkins/jenkins-slave/tools/hudson.plugins.gradle.GradleInstallation/Gradle_3.4-rc-2
Setting 
GRADLE_3_4_RC_2_HOME=/home/jenkins/jenkins-slave/tools/hudson.plugins.gradle.GradleInstallation/Gradle_3.4-rc-2
Not sending mail to unregistered user wangg...@gmail.com

Reply via email to