See
<https://builds.apache.org/job/kafka-trunk-jdk9/67/display/redirect?page=changes>
Changes:
[damian.guy] KAFKA-5958; Global stores access state restore listener
[ismael] KAFKA-5960; Follow-up cleanup
[damian.guy] KAFKA-5949; User Callback Exceptions need to be handled properly
[damian.guy] KAFKA-5979; Use single AtomicCounter to generate internal names
[ismael] KAFKA-5976; Improve trace logging in RequestChannel.sendResponse
[ismael] MINOR: Use full package name when classes referenced in documentation
------------------------------------------
[...truncated 1.44 MB...]
K extends Object declared in interface KGroupedStream
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:82:
warning: [deprecation] reduce(Reducer<V>,String) in KGroupedStream has been
deprecated
public KTable<K, V> reduce(final Reducer<V> reducer,
^
where V,K are type-variables:
V extends Object declared in interface KGroupedStream
K extends Object declared in interface KGroupedStream
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:383:
warning: [deprecation] count(SessionWindows,StateStoreSupplier<SessionStore>)
in KGroupedStream has been deprecated
public KTable<Windowed<K>, Long> count(final SessionWindows sessionWindows,
^
where K is a type-variable:
K extends Object declared in interface KGroupedStream
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:378:
warning: [deprecation] count(SessionWindows) in KGroupedStream has been
deprecated
public KTable<Windowed<K>, Long> count(final SessionWindows sessionWindows)
{
^
where K is a type-variable:
K extends Object declared in interface KGroupedStream
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:371:
warning: [deprecation] count(SessionWindows,String) in KGroupedStream has been
deprecated
public KTable<Windowed<K>, Long> count(final SessionWindows sessionWindows,
final String queryableStoreName) {
^
where K is a type-variable:
K extends Object declared in interface KGroupedStream
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:284:
warning: [deprecation] <W>count(Windows<W>,StateStoreSupplier<WindowStore>) in
KGroupedStream has been deprecated
public <W extends Window> KTable<Windowed<K>, Long> count(final Windows<W>
windows,
^
where W,K are type-variables:
W extends Window declared in method
<W>count(Windows<W>,StateStoreSupplier<WindowStore>)
K extends Object declared in interface KGroupedStream
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:279:
warning: [deprecation] <W>count(Windows<W>) in KGroupedStream has been
deprecated
public <W extends Window> KTable<Windowed<K>, Long> count(final Windows<W>
windows) {
^
where W,K are type-variables:
W extends Window declared in method <W>count(Windows<W>)
K extends Object declared in interface KGroupedStream
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:272:
warning: [deprecation] <W>count(Windows<W>,String) in KGroupedStream has been
deprecated
public <W extends Window> KTable<Windowed<K>, Long> count(final Windows<W>
windows,
^
where W,K are type-variables:
W extends Window declared in method <W>count(Windows<W>,String)
K extends Object declared in interface KGroupedStream
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:262:
warning: [deprecation] count(StateStoreSupplier<KeyValueStore>) in
KGroupedStream has been deprecated
public KTable<K, Long> count(final StateStoreSupplier<KeyValueStore>
storeSupplier) {
^
where K is a type-variable:
K extends Object declared in interface KGroupedStream
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:251:
warning: [deprecation] count(String) in KGroupedStream has been deprecated
public KTable<K, Long> count(final String queryableStoreName) {
^
where K is a type-variable:
K extends Object declared in interface KGroupedStream
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:96:
warning: [deprecation] StateStoreSupplier in
org.apache.kafka.streams.processor has been deprecated
final StateStoreSupplier<KeyValueStore>
storeSupplier) {
^
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:137:
warning: [deprecation] StateStoreSupplier in
org.apache.kafka.streams.processor has been deprecated
final
StateStoreSupplier<WindowStore> storeSupplier) {
^
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:202:
warning: [deprecation] StateStoreSupplier in
org.apache.kafka.streams.processor has been deprecated
final StateStoreSupplier<KeyValueStore>
storeSupplier) {
^
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:238:
warning: [deprecation] StateStoreSupplier in
org.apache.kafka.streams.processor has been deprecated
final
StateStoreSupplier<WindowStore> storeSupplier) {
^
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:262:
warning: [deprecation] StateStoreSupplier in
org.apache.kafka.streams.processor has been deprecated
public KTable<K, Long> count(final StateStoreSupplier<KeyValueStore>
storeSupplier) {
^
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:285:
warning: [deprecation] StateStoreSupplier in
org.apache.kafka.streams.processor has been deprecated
final
StateStoreSupplier<WindowStore> storeSupplier) {
^
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:334:
warning: [deprecation] StateStoreSupplier in
org.apache.kafka.streams.processor has been deprecated
final
StateStoreSupplier<SessionStore> storeSupplier) {
^
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:384:
warning: [deprecation] StateStoreSupplier in
org.apache.kafka.streams.processor has been deprecated
final
StateStoreSupplier<SessionStore> storeSupplier) {
^
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:425:
warning: [deprecation] StateStoreSupplier in
org.apache.kafka.streams.processor has been deprecated
final StateStoreSupplier<SessionStore>
storeSupplier) {
^
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:471:
warning: [deprecation] StateStoreSupplier in
org.apache.kafka.streams.processor has been deprecated
final StateStoreSupplier storeSupplier) {
^
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java>:58:
warning: [unchecked] unchecked cast
otherWindow = (WindowStore<K, V2>)
context.getStateStore(otherWindowName);
^
required: WindowStore<K,V2>
found: StateStore
where K,V2 are type-variables:
K extends Object declared in class KStreamKStreamJoin
V2 extends Object declared in class KStreamKStreamJoin
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java>:593:
warning: [deprecation] <VO,VR>outerJoin(KTable<K,VO>,ValueJoiner<? super V,?
super VO,? extends VR>,StateStoreSupplier<KeyValueStore>) in KTable has been
deprecated
public <V1, R> KTable<K, R> outerJoin(final KTable<K, V1> other,
^
where VO,VR,K,V are type-variables:
VO extends Object declared in method
<VO,VR>outerJoin(KTable<K,VO>,ValueJoiner<? super V,? super VO,? extends
VR>,StateStoreSupplier<KeyValueStore>)
VR extends Object declared in method
<VO,VR>outerJoin(KTable<K,VO>,ValueJoiner<? super V,? super VO,? extends
VR>,StateStoreSupplier<KeyValueStore>)
K extends Object declared in interface KTable
V extends Object declared in interface KTable
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java>:585:
warning: [deprecation] <VO,VR>outerJoin(KTable<K,VO>,ValueJoiner<? super V,?
super VO,? extends VR>,Serde<VR>,String) in KTable has been deprecated
public <V1, R> KTable<K, R> outerJoin(final KTable<K, V1> other,
^
where VO,VR,K,V are type-variables:
VO extends Object declared in method
<VO,VR>outerJoin(KTable<K,VO>,ValueJoiner<? super V,? super VO,? extends
VR>,Serde<VR>,String)
VR extends Object declared in method
<VO,VR>outerJoin(KTable<K,VO>,ValueJoiner<? super V,? super VO,? extends
VR>,Serde<VR>,String)
K extends Object declared in interface KTable
V extends Object declared in interface KTable
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java>:626:
warning: [deprecation] <VO,VR>leftJoin(KTable<K,VO>,ValueJoiner<? super V,?
super VO,? extends VR>,StateStoreSupplier<KeyValueStore>) in KTable has been
deprecated
public <V1, R> KTable<K, R> leftJoin(final KTable<K, V1> other,
^
where VO,VR,K,V are type-variables:
VO extends Object declared in method
<VO,VR>leftJoin(KTable<K,VO>,ValueJoiner<? super V,? super VO,? extends
VR>,StateStoreSupplier<KeyValueStore>)
VR extends Object declared in method
<VO,VR>leftJoin(KTable<K,VO>,ValueJoiner<? super V,? super VO,? extends
VR>,StateStoreSupplier<KeyValueStore>)
K extends Object declared in interface KTable
V extends Object declared in interface KTable
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java>:618:
warning: [deprecation] <VO,VR>leftJoin(KTable<K,VO>,ValueJoiner<? super V,?
super VO,? extends VR>,Serde<VR>,String) in KTable has been deprecated
public <V1, R> KTable<K, R> leftJoin(final KTable<K, V1> other,
^
where VO,VR,K,V are type-variables:
VO extends Object declared in method
<VO,VR>leftJoin(KTable<K,VO>,ValueJoiner<? super V,? super VO,? extends
VR>,Serde<VR>,String)
VR extends Object declared in method
<VO,VR>leftJoin(KTable<K,VO>,ValueJoiner<? super V,? super VO,? extends
VR>,Serde<VR>,String)
K extends Object declared in interface KTable
V extends Object declared in interface KTable
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java>:564:
warning: [deprecation] <VO,VR>join(KTable<K,VO>,ValueJoiner<? super V,? super
VO,? extends VR>,StateStoreSupplier<KeyValueStore>) in KTable has been
deprecated
public <V1, R> KTable<K, R> join(final KTable<K, V1> other,
^
where VO,VR,K,V are type-variables:
VO extends Object declared in method <VO,VR>join(KTable<K,VO>,ValueJoiner<?
super V,? super VO,? extends VR>,StateStoreSupplier<KeyValueStore>)
VR extends Object declared in method <VO,VR>join(KTable<K,VO>,ValueJoiner<?
super V,? super VO,? extends VR>,StateStoreSupplier<KeyValueStore>)
K extends Object declared in interface KTable
V extends Object declared in interface KTable
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java>:556:
warning: [deprecation] <VO,VR>join(KTable<K,VO>,ValueJoiner<? super V,? super
VO,? extends VR>,Serde<VR>,String) in KTable has been deprecated
public <V1, R> KTable<K, R> join(final KTable<K, V1> other,
^
where VO,VR,K,V are type-variables:
VO extends Object declared in method <VO,VR>join(KTable<K,VO>,ValueJoiner<?
super V,? super VO,? extends VR>,Serde<VR>,String)
VR extends Object declared in method <VO,VR>join(KTable<K,VO>,ValueJoiner<?
super V,? super VO,? extends VR>,Serde<VR>,String)
K extends Object declared in interface KTable
V extends Object declared in interface KTable
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java>:744:
warning: [deprecation] <KR,VR>groupBy(KeyValueMapper<? super K,? super
V,KeyValue<KR,VR>>,Serde<KR>,Serde<VR>) in KTable has been deprecated
public <K1, V1> KGroupedTable<K1, V1> groupBy(final KeyValueMapper<? super
K, ? super V, KeyValue<K1, V1>> selector,
^
where KR,VR,K,V are type-variables:
KR extends Object declared in method <KR,VR>groupBy(KeyValueMapper<? super
K,? super V,KeyValue<KR,VR>>,Serde<KR>,Serde<VR>)
VR extends Object declared in method <KR,VR>groupBy(KeyValueMapper<? super
K,? super V,KeyValue<KR,VR>>,Serde<KR>,Serde<VR>)
K extends Object declared in interface KTable
V extends Object declared in interface KTable
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java>:513:
warning: [deprecation] to(Serde<K>,Serde<V>,StreamPartitioner<? super K,?
super V>,String) in KTable has been deprecated
public void to(final Serde<K> keySerde,
^
where K,V are type-variables:
K extends Object declared in interface KTable
V extends Object declared in interface KTable
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java>:506:
warning: [deprecation] to(Serde<K>,Serde<V>,String) in KTable has been
deprecated
public void to(final Serde<K> keySerde,
^
where K,V are type-variables:
K extends Object declared in interface KTable
V extends Object declared in interface KTable
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java>:500:
warning: [deprecation] to(StreamPartitioner<? super K,? super V>,String) in
KTable has been deprecated
public void to(final StreamPartitioner<? super K, ? super V> partitioner,
^
where K,V are type-variables:
K extends Object declared in interface KTable
V extends Object declared in interface KTable
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java>:495:
warning: [deprecation] to(String) in KTable has been deprecated
public void to(final String topic) {
^
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java>:425:
warning: [deprecation] through(Serde<K>,Serde<V>,StreamPartitioner<? super K,?
super V>,String) in KTable has been deprecated
public KTable<K, V> through(final Serde<K> keySerde,
^
where K,V are type-variables:
K extends Object declared in interface KTable
V extends Object declared in interface KTable
Note: Some input files additionally use or override a deprecated API.
Note: Some input files additionally use unchecked or unsafe operations.
100 warnings
:streams:processResources NO-SOURCE
:streams:classes
:streams:copyDependantLibs
:streams:jar
:jmh-benchmarks:compileJava<https://builds.apache.org/job/kafka-trunk-jdk9/ws/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/producer/ProducerRecordBenchmark.java>:44:
warning: [unchecked] unchecked call to ProducerRecord(String,V) as a member of
the raw type ProducerRecord
return new ProducerRecord("topic", "value");
^
where V is a type-variable:
V extends Object declared in class ProducerRecord
<https://builds.apache.org/job/kafka-trunk-jdk9/ws/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/producer/ProducerRecordBenchmark.java>:44:
warning: [unchecked] unchecked conversion
return new ProducerRecord("topic", "value");
^
required: ProducerRecord<String,String>
found: ProducerRecord
2 warnings
:jmh-benchmarks:processResources NO-SOURCE
:jmh-benchmarks:classes
:jmh-benchmarks:checkstyleMain
:jmh-benchmarks:compileTestJava NO-SOURCE
:jmh-benchmarks:processTestResources NO-SOURCE
:jmh-benchmarks:testClasses UP-TO-DATE
:jmh-benchmarks:checkstyleTest NO-SOURCE
:jmh-benchmarks:test NO-SOURCE
:log4j-appender:compileJava
:log4j-appender:processResources NO-SOURCE
:log4j-appender:classes
:log4j-appender:checkstyleMain
:log4j-appender:compileTestJava
:log4j-appender:processTestResources NO-SOURCE
:log4j-appender:testClasses
:log4j-appender:checkstyleTest
: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
:streams:checkstyleMain
:streams:compileTestJava<https://builds.apache.org/job/kafka-trunk-jdk9/ws/streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImplTest.java>:217:
error: method register in class GlobalStateManagerImpl cannot be applied to
given types;
stateManager.register(store1, false, stateRestoreCallback);
^
required: StateStore,StateRestoreCallback
found: NoOpReadOnlyStore<Object,Object>,boolean,TheStateRestoreCallback
reason: actual and formal argument lists differ in length
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.
1 error
FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':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.
* Get more help at https://help.gradle.org
BUILD FAILED in 50m 9s
51 actionable tasks: 50 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 [email protected]
Not sending mail to unregistered user [email protected]
