See 
<https://builds.apache.org/job/kafka-trunk-jdk8/2203/display/redirect?page=changes>

Changes:

[wangguoz] KAFKA-6190: Use consumer.position() instead of record.offset() to

------------------------------------------
[...truncated 1.40 MB...]
org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest > 
testInvalidApiVersionsRequestSequence STARTED

org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest > 
testInvalidApiVersionsRequestSequence PASSED

org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest > 
testDisallowedKafkaRequestsBeforeAuthentication STARTED

org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest > 
testDisallowedKafkaRequestsBeforeAuthentication PASSED

org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest > 
oldSaslPlainPlaintextServerWithoutSaslAuthenticateHeader STARTED

org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest > 
oldSaslPlainPlaintextServerWithoutSaslAuthenticateHeader PASSED

org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest > 
oldSaslPlainSslServerWithoutSaslAuthenticateHeader STARTED

org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest > 
oldSaslPlainSslServerWithoutSaslAuthenticateHeader PASSED

org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest > 
testInvalidPasswordSaslPlain STARTED

org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest > 
testInvalidPasswordSaslPlain PASSED

org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest > 
testInvalidPasswordSaslScram STARTED

org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest > 
testInvalidPasswordSaslScram PASSED

org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest > 
oldSaslPlainSslServerWithoutSaslAuthenticateHeaderFailure STARTED

org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest > 
oldSaslPlainSslServerWithoutSaslAuthenticateHeaderFailure PASSED

org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest > 
testInvalidSaslPacket STARTED

org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest > 
testInvalidSaslPacket PASSED

org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest > 
testSaslHandshakeRequestWithUnsupportedVersion STARTED

org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest > 
testSaslHandshakeRequestWithUnsupportedVersion PASSED

org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest > 
testJaasConfigurationForListener STARTED

org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest > 
testJaasConfigurationForListener PASSED

org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest > 
oldSaslPlainPlaintextClientWithoutSaslAuthenticateHeaderFailure STARTED

org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest > 
oldSaslPlainPlaintextClientWithoutSaslAuthenticateHeaderFailure PASSED

org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest > 
testUnknownUserSaslScram STARTED

org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest > 
testUnknownUserSaslScram PASSED

org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest > 
oldSaslScramSslServerWithoutSaslAuthenticateHeader STARTED

org.apache.kafka.common.security.authenticator.SaslAuthenticatorTest > 
oldSaslScramSslServerWithoutSaslAuthenticateHeader PASSED

org.apache.kafka.common.security.authenticator.SaslServerAuthenticatorTest > 
testUnexpectedRequestType STARTED

org.apache.kafka.common.security.authenticator.SaslServerAuthenticatorTest > 
testUnexpectedRequestType PASSED

org.apache.kafka.common.security.authenticator.SaslServerAuthenticatorTest > 
testOversizeRequest STARTED

org.apache.kafka.common.security.authenticator.SaslServerAuthenticatorTest > 
testOversizeRequest PASSED
:clients:determineCommitId UP-TO-DATE
:clients:createVersionFile
:clients:jar UP-TO-DATE
:core:compileJava NO-SOURCE
:core:compileScala UP-TO-DATE
:core:processResources NO-SOURCE
:core:classes UP-TO-DATE
:core:copyDependantLibs
:core:jar
:examples:compileJavawarning: [options] bootstrap class path not set in 
conjunction with -source 1.7
<https://builds.apache.org/job/kafka-trunk-jdk8/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-jdk8/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-jdk8/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;
                             ^
4 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:findbugsMain
:examples:test NO-SOURCE
:log4j-appender:compileJavawarning: [options] bootstrap class path not set in 
conjunction with -source 1.7
1 warning

:log4j-appender:processResources NO-SOURCE
:log4j-appender:classes
:log4j-appender:checkstyleMain
:log4j-appender:compileTestJavawarning: [options] bootstrap class path not set 
in conjunction with -source 1.7
1 warning

:log4j-appender:processTestResources NO-SOURCE
:log4j-appender:testClasses
:log4j-appender:checkstyleTest
:log4j-appender:findbugsMain
:log4j-appender:test

org.apache.kafka.log4jappender.KafkaLog4jAppenderTest > testLog4jAppends STARTED

org.apache.kafka.log4jappender.KafkaLog4jAppenderTest > testLog4jAppends PASSED

org.apache.kafka.log4jappender.KafkaLog4jAppenderTest > testKafkaLog4jConfigs 
STARTED

org.apache.kafka.log4jappender.KafkaLog4jAppenderTest > testKafkaLog4jConfigs 
PASSED
:core:compileTestJava NO-SOURCE
:core:compileTestScala UP-TO-DATE
:core:processTestResources UP-TO-DATE
:core:testClasses UP-TO-DATE
:connect:api:compileJavawarning: [options] bootstrap class path not set in 
conjunction with -source 1.7
1 warning

:connect:api:processResources NO-SOURCE
:connect:api:classes
:connect:api:copyDependantLibs
:connect:api:jar
:connect:json:compileJavawarning: [options] bootstrap class path not set in 
conjunction with -source 1.7
1 warning

:connect:json:processResources NO-SOURCE
:connect:json:classes
:connect:json:copyDependantLibs
:connect:json:jar
:streams:compileJavawarning: [options] bootstrap class path not set in 
conjunction with -source 1.7
<https://builds.apache.org/job/kafka-trunk-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/state/Stores.java>:25:
 warning: [deprecation] InMemoryKeyValueStoreSupplier in 
org.apache.kafka.streams.state.internals has been deprecated
import org.apache.kafka.streams.state.internals.InMemoryKeyValueStoreSupplier;
                                               ^
<https://builds.apache.org/job/kafka-trunk-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/state/Stores.java>:26:
 warning: [deprecation] InMemoryLRUCacheStoreSupplier in 
org.apache.kafka.streams.state.internals has been deprecated
import org.apache.kafka.streams.state.internals.InMemoryLRUCacheStoreSupplier;
                                               ^
<https://builds.apache.org/job/kafka-trunk-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/state/Stores.java>:29:
 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-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/state/Stores.java>:30:
 warning: [deprecation] RocksDBSessionStoreSupplier in 
org.apache.kafka.streams.state.internals has been deprecated
import org.apache.kafka.streams.state.internals.RocksDBSessionStoreSupplier;
                                               ^
<https://builds.apache.org/job/kafka-trunk-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/state/Stores.java>:31:
 warning: [deprecation] RocksDBWindowStoreSupplier in 
org.apache.kafka.streams.state.internals has been deprecated
import org.apache.kafka.streams.state.internals.RocksDBWindowStoreSupplier;
                                               ^
<https://builds.apache.org/job/kafka-trunk-jdk8/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-jdk8/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-jdk8/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-jdk8/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-jdk8/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-jdk8/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-jdk8/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-jdk8/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-jdk8/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-jdk8/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-jdk8/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);
                                           ^
<https://builds.apache.org/job/kafka-trunk-jdk8/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
1 error
17 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 1h 1m 31s
46 actionable tasks: 38 executed, 8 up-to-date
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-trunk-jdk8/ws/> that match the pattern 
**/build/reports/findbugs/*.xml
[FINDBUGS] Parsing 4 files in 
<https://builds.apache.org/job/kafka-trunk-jdk8/ws/>
[FINDBUGS] Successfully parsed file 
<https://builds.apache.org/job/kafka-trunk-jdk8/ws/clients/build/reports/findbugs/main.xml>
 with 0 unique warnings and 0 duplicates.
[FINDBUGS] Successfully parsed file 
<https://builds.apache.org/job/kafka-trunk-jdk8/ws/core/build/reports/findbugs/main.xml>
 with 0 unique warnings and 0 duplicates.
[FINDBUGS] Successfully parsed file 
<https://builds.apache.org/job/kafka-trunk-jdk8/ws/examples/build/reports/findbugs/main.xml>
 with 0 unique warnings and 0 duplicates.
[FINDBUGS] Successfully parsed file 
<https://builds.apache.org/job/kafka-trunk-jdk8/ws/log4j-appender/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=66cab2f7fb72417f9bf8759fccb26dfdb33ac6ce, 
workspace=<https://builds.apache.org/job/kafka-trunk-jdk8/ws/>
[FINDBUGS] Computing warning deltas based on reference build #2202
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