See <https://builds.apache.org/job/kafka-trunk-jdk9/186/display/redirect?page=changes>
Changes: [wangguoz] KAFKA-6190: Use consumer.position() instead of record.offset() to ------------------------------------------ [...truncated 1.42 MB...] kafka.javaapi.message.ByteBufferMessageSetTest > testIteratorIsConsistent STARTED kafka.javaapi.message.ByteBufferMessageSetTest > testIteratorIsConsistent PASSED kafka.javaapi.message.ByteBufferMessageSetTest > testEqualsWithCompression STARTED kafka.javaapi.message.ByteBufferMessageSetTest > testEqualsWithCompression PASSED kafka.javaapi.message.ByteBufferMessageSetTest > testWrittenEqualsRead STARTED kafka.javaapi.message.ByteBufferMessageSetTest > testWrittenEqualsRead PASSED kafka.javaapi.message.ByteBufferMessageSetTest > testEquals STARTED kafka.javaapi.message.ByteBufferMessageSetTest > testEquals PASSED kafka.javaapi.message.ByteBufferMessageSetTest > testSizeInBytes STARTED kafka.javaapi.message.ByteBufferMessageSetTest > testSizeInBytes PASSED kafka.security.auth.ResourceTypeTest > testJavaConversions STARTED kafka.security.auth.ResourceTypeTest > testJavaConversions PASSED kafka.security.auth.ResourceTypeTest > testFromString STARTED kafka.security.auth.ResourceTypeTest > testFromString PASSED kafka.security.auth.OperationTest > testJavaConversions STARTED kafka.security.auth.OperationTest > testJavaConversions PASSED kafka.security.auth.PermissionTypeTest > testJavaConversions STARTED kafka.security.auth.PermissionTypeTest > testJavaConversions PASSED kafka.security.auth.PermissionTypeTest > testFromString STARTED kafka.security.auth.PermissionTypeTest > testFromString PASSED kafka.security.auth.SimpleAclAuthorizerTest > testAllowAllAccess STARTED kafka.security.auth.SimpleAclAuthorizerTest > testAllowAllAccess PASSED kafka.security.auth.SimpleAclAuthorizerTest > testLocalConcurrentModificationOfResourceAcls STARTED kafka.security.auth.SimpleAclAuthorizerTest > testLocalConcurrentModificationOfResourceAcls PASSED kafka.security.auth.SimpleAclAuthorizerTest > testHighConcurrencyDeletionOfResourceAcls STARTED kafka.security.auth.SimpleAclAuthorizerTest > testHighConcurrencyDeletionOfResourceAcls PASSED kafka.security.auth.SimpleAclAuthorizerTest > testNoAclFound STARTED kafka.security.auth.SimpleAclAuthorizerTest > testNoAclFound PASSED kafka.security.auth.SimpleAclAuthorizerTest > testAclInheritance STARTED kafka.security.auth.SimpleAclAuthorizerTest > testAclInheritance PASSED kafka.security.auth.SimpleAclAuthorizerTest > testDistributedConcurrentModificationOfResourceAcls STARTED kafka.security.auth.SimpleAclAuthorizerTest > testDistributedConcurrentModificationOfResourceAcls PASSED kafka.security.auth.SimpleAclAuthorizerTest > testAclManagementAPIs STARTED kafka.security.auth.SimpleAclAuthorizerTest > testAclManagementAPIs PASSED kafka.security.auth.SimpleAclAuthorizerTest > testWildCardAcls STARTED kafka.security.auth.SimpleAclAuthorizerTest > testWildCardAcls PASSED kafka.security.auth.SimpleAclAuthorizerTest > testTopicAcl STARTED kafka.security.auth.SimpleAclAuthorizerTest > testTopicAcl PASSED kafka.security.auth.SimpleAclAuthorizerTest > testSuperUserHasAccess STARTED kafka.security.auth.SimpleAclAuthorizerTest > testSuperUserHasAccess PASSED kafka.security.auth.SimpleAclAuthorizerTest > testDenyTakesPrecedence STARTED kafka.security.auth.SimpleAclAuthorizerTest > testDenyTakesPrecedence PASSED kafka.security.auth.SimpleAclAuthorizerTest > testNoAclFoundOverride STARTED kafka.security.auth.SimpleAclAuthorizerTest > testNoAclFoundOverride PASSED kafka.security.auth.SimpleAclAuthorizerTest > testHighConcurrencyModificationOfResourceAcls STARTED kafka.security.auth.SimpleAclAuthorizerTest > testHighConcurrencyModificationOfResourceAcls PASSED kafka.security.auth.SimpleAclAuthorizerTest > testLoadCache STARTED kafka.security.auth.SimpleAclAuthorizerTest > testLoadCache PASSED kafka.security.auth.AclTest > testAclJsonConversion STARTED kafka.security.auth.AclTest > testAclJsonConversion PASSED kafka.security.auth.ZkAuthorizationTest > testIsZkSecurityEnabled STARTED kafka.security.auth.ZkAuthorizationTest > testIsZkSecurityEnabled PASSED kafka.security.auth.ZkAuthorizationTest > testZkUtils STARTED kafka.security.auth.ZkAuthorizationTest > testZkUtils PASSED kafka.security.auth.ZkAuthorizationTest > testZkAntiMigration STARTED kafka.security.auth.ZkAuthorizationTest > testZkAntiMigration PASSED kafka.security.auth.ZkAuthorizationTest > testZkMigration STARTED kafka.security.auth.ZkAuthorizationTest > testZkMigration PASSED kafka.security.auth.ZkAuthorizationTest > testChroot STARTED kafka.security.auth.ZkAuthorizationTest > testChroot PASSED kafka.security.auth.ZkAuthorizationTest > testDelete STARTED kafka.security.auth.ZkAuthorizationTest > testDelete PASSED kafka.security.auth.ZkAuthorizationTest > testDeleteRecursive STARTED kafka.security.auth.ZkAuthorizationTest > testDeleteRecursive PASSED :core:copyDependantLibs :core:jar :examples:compileJava<https://builds.apache.org/job/kafka-trunk-jdk9/ws/examples/src/main/java/kafka/examples/SimpleConsumerDemo.java>:19: warning: [deprecation] FetchRequest in kafka.api has been deprecated import kafka.api.FetchRequest; ^ <https://builds.apache.org/job/kafka-trunk-jdk9/ws/examples/src/main/java/kafka/examples/SimpleConsumerDemo.java>:20: warning: [deprecation] FetchRequestBuilder in kafka.api has been deprecated import kafka.api.FetchRequestBuilder; ^ <https://builds.apache.org/job/kafka-trunk-jdk9/ws/examples/src/main/java/kafka/examples/SimpleConsumerDemo.java>:22: warning: [deprecation] SimpleConsumer in kafka.javaapi.consumer has been deprecated import kafka.javaapi.consumer.SimpleConsumer; ^ 3 warnings :examples:processResources NO-SOURCE :examples:classes :examples:checkstyleMain :examples:compileTestJava NO-SOURCE :examples:processTestResources NO-SOURCE :examples:testClasses UP-TO-DATE :examples:checkstyleTest NO-SOURCE :examples:test NO-SOURCE :connect:api:compileJava :connect:api:processResources NO-SOURCE :connect:api:classes :connect:api:copyDependantLibs :connect:api:jar :connect:json:compileJava :connect:json:processResources NO-SOURCE :connect:json:classes :connect:json:copyDependantLibs :connect:json:jar :streams:compileJava<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/KStreamBuilder.java>:35: warning: [deprecation] RocksDBKeyValueStoreSupplier in org.apache.kafka.streams.state.internals has been deprecated import org.apache.kafka.streams.state.internals.RocksDBKeyValueStoreSupplier; ^ <https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImpl.java>:32: 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-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/Topology.java>:455: warning: [unchecked] unchecked method invocation: method addSink in class InternalTopologyBuilder is applied to given types internalTopologyBuilder.addSink(name, topic, null, null, partitioner, parentNames); ^ required: String,String,Serializer<K>,Serializer<V>,StreamPartitioner<? super K,? super V>,String[] found: String,String,<null>,<null>,StreamPartitioner,String[] where K,V are type-variables: K extends Object declared in method <K,V>addSink(String,String,Serializer<K>,Serializer<V>,StreamPartitioner<? super K,? super V>,String...) V extends Object declared in method <K,V>addSink(String,String,Serializer<K>,Serializer<V>,StreamPartitioner<? super K,? super V>,String...) <https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/Topology.java>:455: warning: [unchecked] unchecked conversion internalTopologyBuilder.addSink(name, topic, null, null, partitioner, parentNames); ^ required: StreamPartitioner<? super K,? super V> found: StreamPartitioner where K,V are type-variables: K extends Object declared in method <K,V>addSink(String,String,Serializer<K>,Serializer<V>,StreamPartitioner<? super K,? super V>,String...) V extends Object declared in method <K,V>addSink(String,String,Serializer<K>,Serializer<V>,StreamPartitioner<? super K,? super V>,String...) <https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/Topology.java>:484: warning: [unchecked] unchecked method invocation: method addSink in class InternalTopologyBuilder is applied to given types internalTopologyBuilder.addSink(name, topic, keySerializer, valueSerializer, null, parentNames); ^ required: String,String,Serializer<K>,Serializer<V>,StreamPartitioner<? super K,? super V>,String[] found: String,String,Serializer,Serializer,<null>,String[] where K,V are type-variables: K extends Object declared in method <K,V>addSink(String,String,Serializer<K>,Serializer<V>,StreamPartitioner<? super K,? super V>,String...) V extends Object declared in method <K,V>addSink(String,String,Serializer<K>,Serializer<V>,StreamPartitioner<? super K,? super V>,String...) <https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/Topology.java>:484: warning: [unchecked] unchecked conversion internalTopologyBuilder.addSink(name, topic, keySerializer, valueSerializer, null, parentNames); ^ required: Serializer<K> found: Serializer where K,V are type-variables: K extends Object declared in method <K,V>addSink(String,String,Serializer<K>,Serializer<V>,StreamPartitioner<? super K,? super V>,String...) V extends Object declared in method <K,V>addSink(String,String,Serializer<K>,Serializer<V>,StreamPartitioner<? super K,? super V>,String...) <https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/Topology.java>:484: warning: [unchecked] unchecked conversion internalTopologyBuilder.addSink(name, topic, keySerializer, valueSerializer, null, parentNames); ^ required: Serializer<V> found: Serializer where V,K are type-variables: V extends Object declared in method <K,V>addSink(String,String,Serializer<K>,Serializer<V>,StreamPartitioner<? super K,? super V>,String...) K extends Object declared in method <K,V>addSink(String,String,Serializer<K>,Serializer<V>,StreamPartitioner<? super K,? super V>,String...) <https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java>:704: warning: [unchecked] unchecked method invocation: constructor <init> in class TaskManager is applied to given types final TaskManager taskManager = new TaskManager(changelogReader, ^ required: ChangelogReader,String,Consumer<byte[],byte[]>,AbstractTaskCreator<StreamTask>,AbstractTaskCreator<StandbyTask>,AssignedStreamsTasks,AssignedStandbyTasks found: StoreChangelogReader,String,Consumer<byte[],byte[]>,AbstractTaskCreator,AbstractTaskCreator,AssignedStreamsTasks,AssignedStandbyTasks <https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java>:707: warning: [unchecked] unchecked conversion activeTaskCreator, ^ required: AbstractTaskCreator<StreamTask> found: AbstractTaskCreator <https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java>:708: warning: [unchecked] unchecked conversion standbyTaskCreator, ^ required: AbstractTaskCreator<StandbyTask> found: AbstractTaskCreator <https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java>:195: error: cannot find symbol offset = consumer.position(topicPartition); ^ symbol: variable consumer location: class GlobalStateManagerImpl <https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java>:567: warning: [unchecked] unchecked call to restoreAllInternal(Collection<KeyValue<byte[],byte[]>>) as a member of the raw type RocksDBStore rocksDBStore.restoreAllInternal(records); ^ 1 error 11 warnings FAILED FAILURE: Build failed with an exception. * What went wrong: Execution failed for task ':streams:compileJava'. > 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. * Get more help at https://help.gradle.org BUILD FAILED in 47m 57s 40 actionable tasks: 39 executed, 1 up-to-date Build step 'Execute shell' marked build as failure 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
