See <https://builds.apache.org/job/kafka-2.0-jdk8/292/display/redirect?page=changes>
Changes: [wangguoz] KAFKA-8816: Make offsets immutable to users of RecordCollector.offsets ------------------------------------------ [...truncated 442.92 KB...] kafka.controller.PartitionStateMachineTest > testOnlinePartitionToOnlineTransitionForControlledShutdown STARTED kafka.controller.PartitionStateMachineTest > testOnlinePartitionToOnlineTransitionForControlledShutdown PASSED kafka.controller.PartitionStateMachineTest > testOfflinePartitionToOnlinePartitionTransitionZkUtilsExceptionFromStateLookup STARTED kafka.controller.PartitionStateMachineTest > testOfflinePartitionToOnlinePartitionTransitionZkUtilsExceptionFromStateLookup PASSED kafka.controller.PartitionStateMachineTest > testInvalidOnlinePartitionToNonexistentPartitionTransition STARTED kafka.controller.PartitionStateMachineTest > testInvalidOnlinePartitionToNonexistentPartitionTransition PASSED kafka.controller.PartitionStateMachineTest > testInvalidOfflinePartitionToNewPartitionTransition STARTED kafka.controller.PartitionStateMachineTest > testInvalidOfflinePartitionToNewPartitionTransition PASSED kafka.controller.PartitionStateMachineTest > testOfflinePartitionToOnlinePartitionTransition STARTED kafka.controller.PartitionStateMachineTest > testOfflinePartitionToOnlinePartitionTransition PASSED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testPreferredReplicaPartitionLeaderElectionPreferredReplicaNotInIsrLive STARTED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testPreferredReplicaPartitionLeaderElectionPreferredReplicaNotInIsrLive PASSED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testControlledShutdownPartitionLeaderElectionLastIsrShuttingDown STARTED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testControlledShutdownPartitionLeaderElectionLastIsrShuttingDown PASSED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testControlledShutdownPartitionLeaderElection STARTED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testControlledShutdownPartitionLeaderElection PASSED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testPreferredReplicaPartitionLeaderElectionPreferredReplicaInIsrNotLive STARTED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testPreferredReplicaPartitionLeaderElectionPreferredReplicaInIsrNotLive PASSED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testReassignPartitionLeaderElectionWithNoLiveIsr STARTED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testReassignPartitionLeaderElectionWithNoLiveIsr PASSED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testReassignPartitionLeaderElection STARTED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testReassignPartitionLeaderElection PASSED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testOfflinePartitionLeaderElection STARTED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testOfflinePartitionLeaderElection PASSED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testPreferredReplicaPartitionLeaderElection STARTED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testPreferredReplicaPartitionLeaderElection PASSED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testReassignPartitionLeaderElectionWithEmptyIsr STARTED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testReassignPartitionLeaderElectionWithEmptyIsr PASSED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testControlledShutdownPartitionLeaderElectionAllIsrSimultaneouslyShutdown STARTED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testControlledShutdownPartitionLeaderElectionAllIsrSimultaneouslyShutdown PASSED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testOfflinePartitionLeaderElectionLastIsrOfflineUncleanLeaderElectionEnabled STARTED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testOfflinePartitionLeaderElectionLastIsrOfflineUncleanLeaderElectionEnabled PASSED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testPreferredReplicaPartitionLeaderElectionPreferredReplicaNotInIsrNotLive STARTED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testPreferredReplicaPartitionLeaderElectionPreferredReplicaNotInIsrNotLive PASSED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testOfflinePartitionLeaderElectionLastIsrOfflineUncleanLeaderElectionDisabled STARTED kafka.controller.PartitionLeaderElectionAlgorithmsTest > testOfflinePartitionLeaderElectionLastIsrOfflineUncleanLeaderElectionDisabled PASSED > Task :kafka-2.0-jdk8:core:copyDependantLibs > Task :kafka-2.0-jdk8:core:jar > Task :kafka-2.0-jdk8:connect:api:compileJava > Task :kafka-2.0-jdk8:connect:api:processResources NO-SOURCE > Task :kafka-2.0-jdk8:connect:api:classes > Task :kafka-2.0-jdk8:connect:api:copyDependantLibs > Task :kafka-2.0-jdk8:connect:api:jar > Task :kafka-2.0-jdk8:connect:json:compileJava > Task :kafka-2.0-jdk8:connect:json:processResources NO-SOURCE > Task :kafka-2.0-jdk8:connect:json:classes > Task :kafka-2.0-jdk8:connect:json:copyDependantLibs > Task :kafka-2.0-jdk8:connect:json:jar > Task :kafka-2.0-jdk8:streams:compileJava <https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/StatefulSourceNode.java>:21: warning: [deprecation] StateStoreSupplier in org.apache.kafka.streams.processor has been deprecated import org.apache.kafka.streams.processor.StateStoreSupplier; ^ <https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/StatefulProcessorNode.java>:21: warning: [deprecation] StateStoreSupplier in org.apache.kafka.streams.processor has been deprecated import org.apache.kafka.streams.processor.StateStoreSupplier; ^ <https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/StatefulSourceNode.java>:35: warning: [deprecation] StateStoreSupplier in org.apache.kafka.streams.processor has been deprecated private org.apache.kafka.streams.processor.StateStoreSupplier<KeyValueStore> storeSupplier; ^ <https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/StatefulSourceNode.java>:62: warning: [deprecation] StateStoreSupplier in org.apache.kafka.streams.processor has been deprecated StateStoreSupplier<KeyValueStore> storeSupplier() { ^ <https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/StatefulSourceNode.java>:66: warning: [deprecation] StateStoreSupplier in org.apache.kafka.streams.processor has been deprecated void setStoreSupplier(StateStoreSupplier<KeyValueStore> storeSupplier) { ^ <https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/StatefulSourceNode.java>:115: warning: [deprecation] StateStoreSupplier in org.apache.kafka.streams.processor has been deprecated private StateStoreSupplier<KeyValueStore> storeSupplier; ^ <https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/StatefulSourceNode.java>:144: warning: [deprecation] StateStoreSupplier in org.apache.kafka.streams.processor has been deprecated StatefulSourceNodeBuilder<K, V> withStoreSupplier(final StateStoreSupplier<KeyValueStore> storeSupplier) { ^ <https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/StatefulProcessorNode.java>:31: warning: [deprecation] StateStoreSupplier in org.apache.kafka.streams.processor has been deprecated private final org.apache.kafka.streams.processor.StateStoreSupplier<KeyValueStore> storeSupplier; ^ <https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/StatefulProcessorNode.java>:39: warning: [deprecation] StateStoreSupplier in org.apache.kafka.streams.processor has been deprecated final org.apache.kafka.streams.processor.StateStoreSupplier<KeyValueStore> storeSupplier, ^ <https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/StatefulProcessorNode.java>:57: warning: [deprecation] StateStoreSupplier in org.apache.kafka.streams.processor has been deprecated org.apache.kafka.streams.processor.StateStoreSupplier<KeyValueStore> storeSupplier() { ^ <https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/StatefulProcessorNode.java>:81: warning: [deprecation] StateStoreSupplier in org.apache.kafka.streams.processor has been deprecated private org.apache.kafka.streams.processor.StateStoreSupplier<KeyValueStore> storeSupplier; ^ <https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/StatefulProcessorNode.java>:112: warning: [deprecation] StateStoreSupplier in org.apache.kafka.streams.processor has been deprecated StatefulProcessorNodeBuilder<K, V> withStoreSupplier(final StateStoreSupplier<KeyValueStore> storeSupplier) { ^ <https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/StatefulProcessorNode.java>:123: warning: [unchecked] unchecked method invocation: constructor <init> in class StatefulProcessorNode is applied to given types return new StatefulProcessorNode<>(parentProcessorNodeName, ^ required: String,String,ProcessorSupplier<K#1,V#1>,String[],StateStoreSupplier<KeyValueStore>,StoreBuilder<KeyValueStore<K#1,V#1>>,boolean found: String,String,ProcessorSupplier,String[],StateStoreSupplier<KeyValueStore>,StoreBuilder<KeyValueStore<K#2,V#2>>,boolean where K#1,V#1,K#2,V#2 are type-variables: K#1 extends Object declared in class StatefulProcessorNode V#1 extends Object declared in class StatefulProcessorNode K#2 extends Object declared in class StatefulProcessorNodeBuilder V#2 extends Object declared in class StatefulProcessorNodeBuilder <https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/StatefulProcessorNode.java>:125: warning: [unchecked] unchecked conversion processorSupplier, ^ required: ProcessorSupplier<K,V> found: ProcessorSupplier where K,V are type-variables: K extends Object declared in class StatefulProcessorNode V extends Object declared in class StatefulProcessorNode <https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/StatefulProcessorNode.java>:123: warning: [unchecked] unchecked conversion return new StatefulProcessorNode<>(parentProcessorNodeName, ^ required: StatefulProcessorNode<K,V> found: StatefulProcessorNode where K,V are type-variables: K extends Object declared in class StatefulProcessorNodeBuilder V extends Object declared in class StatefulProcessorNodeBuilder 15 warnings > Task :kafka-2.0-jdk8:streams:processResources NO-SOURCE > Task :kafka-2.0-jdk8:streams:classes > Task :kafka-2.0-jdk8:streams:copyDependantLibs > Task :kafka-2.0-jdk8:streams:jar > Task :kafka-2.0-jdk8:streams:test-utils:compileJava > Task :kafka-2.0-jdk8:streams:test-utils:processResources NO-SOURCE > Task :kafka-2.0-jdk8:streams:test-utils:classes > Task :kafka-2.0-jdk8:streams:test-utils:copyDependantLibs > Task :kafka-2.0-jdk8:streams:test-utils:jar > Task :kafka-2.0-jdk8:streams:compileTestJava <https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java>:54: error: cannot find symbol import static org.hamcrest.Matchers.equalTo; ^ symbol: class Matchers location: package org.hamcrest <https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java>:54: error: static import only from classes and interfaces import static org.hamcrest.Matchers.equalTo; ^ <https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java>:56: error: cannot find symbol import static org.junit.Assert.assertThrows; ^ symbol: static assertThrows location: class <https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/src/test/java/org/apache/kafka/streams/TopologyTest.java>:190: warning: non-varargs call of varargs method with inexact argument type for last parameter; topology.addProcessor("processor", new MockProcessorSupplier(), null); ^ cast to String for a varargs call cast to String[] for a non-varargs call and to suppress this warning <https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/src/test/java/org/apache/kafka/streams/TopologyTest.java>:230: warning: non-varargs call of varargs method with inexact argument type for last parameter; topology.addSink("sink", "topic-2", null); ^ cast to String for a varargs call cast to String[] for a non-varargs call and to suppress this warning <https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java>:173: error: cannot find symbol assertThat(offsets.get(topicPartition), equalTo(2L)); ^ symbol: method equalTo(long) location: class RecordCollectorTest <https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java>:174: error: cannot find symbol assertThrows(UnsupportedOperationException.class, () -> offsets.put(new TopicPartition(topic, 0), 50L)); ^ symbol: method assertThrows(Class<UnsupportedOperationException>,()->offset[...] 50L)) location: class RecordCollectorTest <https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java>:176: error: cannot find symbol assertThat(collector.offsets().get(topicPartition), equalTo(2L)); ^ symbol: method equalTo(long) location: class RecordCollectorTest <https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilderTest.java>:169: warning: non-varargs call of varargs method with inexact argument type for last parameter; builder.addProcessor("processor", new MockProcessorSupplier(), null); ^ cast to String for a varargs call cast to String[] for a non-varargs call and to suppress this warning <https://builds.apache.org/job/kafka-2.0-jdk8/ws/streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilderTest.java>:200: warning: non-varargs call of varargs method with inexact argument type for last parameter; builder.addSink("sink", "topic", null, null, null, null); ^ cast to String for a varargs call cast to String[] for a non-varargs call and to suppress this warning Note: Some input files use or override a deprecated API. Note: Recompile with -Xlint:deprecation for details. Note: Some input files use unchecked or unsafe operations. Note: Recompile with -Xlint:unchecked for details. 6 errors 4 warnings > Task :kafka-2.0-jdk8:streams:compileTestJava FAILED > Task :testScala_2_11 FAILED FAILURE: Build failed with an exception. * What went wrong: Execution failed for task ':kafka-2.0-jdk8:streams:compileTestJava'. > Compilation failed; see the compiler error output for details. * Try: Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights. * Get more help at https://help.gradle.org BUILD FAILED in 2h 5m 42s 25 actionable tasks: 2 executed, 23 up-to-date Build step 'Execute shell' marked build as failure [FINDBUGS] Collecting findbugs analysis files... Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1 [FINDBUGS] Searching for all files in <https://builds.apache.org/job/kafka-2.0-jdk8/ws/> that match the pattern **/build/reports/findbugs/*.xml [FINDBUGS] Parsing 1 file in <https://builds.apache.org/job/kafka-2.0-jdk8/ws/> [FINDBUGS] Successfully parsed file <https://builds.apache.org/job/kafka-2.0-jdk8/ws/core/build/reports/findbugs/main.xml> with 0 unique warnings and 0 duplicates. Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1 No credentials specified Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1 <Git Blamer> Using GitBlamer to create author and commit information for all warnings. <Git Blamer> GIT_COMMIT=9b35df9523c8f9789675075c8ad4db3a999f916d, workspace=<https://builds.apache.org/job/kafka-2.0-jdk8/ws/> [FINDBUGS] Computing warning deltas based on reference build #290 Recording test results Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1 Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1 Not sending mail to unregistered user b...@confluent.io Not sending mail to unregistered user wangg...@gmail.com
