See
<https://builds.apache.org/job/kafka-2.1-jdk8/26/display/redirect?page=changes>
Changes:
[matthias] KAFKA-7080 and KAFKA-7222: Cleanup overlapping KIP changes (#5804)
[matthias] KAFKA-7223: Suppression documentation (#5787)
[wangguoz] MINOR: Doc changes for KIP-312 (#5789)
------------------------------------------
[...truncated 437.71 KB...]
return valueSerde != null ? valueSerde.serializer() : null;
^
required: Serializer<V>
found: Serializer
where V is a type-variable:
V extends Object declared in class OptimizableRepartitionNode
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/OptimizableRepartitionNode.java>:68:
warning: [unchecked] unchecked conversion
return valueSerde != null ? valueSerde.deserializer() : null;
^
required: Deserializer<V>
found: Deserializer
where V is a type-variable:
V extends Object declared in class OptimizableRepartitionNode
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/OptimizableRepartitionNode.java>:78:
warning: [unchecked] unchecked conversion
final Serializer<K> keySerializer = keySerde != null ?
keySerde.serializer() : null;
^
required: Serializer<K>
found: Serializer
where K is a type-variable:
K extends Object declared in class OptimizableRepartitionNode
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/OptimizableRepartitionNode.java>:79:
warning: [unchecked] unchecked conversion
final Deserializer<K> keyDeserializer = keySerde != null ?
keySerde.deserializer() : null;
^
required: Deserializer<K>
found: Deserializer
where K is a type-variable:
K extends Object declared in class OptimizableRepartitionNode
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java>:131:
warning: [deprecation] fetchAll(long,long) in ReadOnlyWindowStore has been
deprecated
KeyValueIterator<Windowed<K>, V> fetchAll(long timeFrom, long timeTo);
^
where K,V are type-variables:
K extends Object declared in interface ReadOnlyWindowStore
V extends Object declared in interface ReadOnlyWindowStore
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java>:113:
warning: [deprecation] fetch(K,K,long,long) in ReadOnlyWindowStore has been
deprecated
KeyValueIterator<Windowed<K>, V> fetch(K from, K to, long timeFrom, long
timeTo);
^
where K,V are type-variables:
K extends Object declared in interface ReadOnlyWindowStore
V extends Object declared in interface ReadOnlyWindowStore
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java>:91:
warning: [deprecation] fetch(K,long,long) in ReadOnlyWindowStore has been
deprecated
WindowStoreIterator<V> fetch(K key, long timeFrom, long timeTo);
^
where K,V are type-variables:
K extends Object declared in interface ReadOnlyWindowStore
V extends Object declared in interface ReadOnlyWindowStore
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStore.java>:70:
warning: [deprecation] fetchAll(long,long) in ReadOnlyWindowStore has been
deprecated
public KeyValueIterator<Windowed<Bytes>, byte[]> fetchAll(final long
timeFrom, final long timeTo) {
^
where K,V are type-variables:
K extends Object declared in interface ReadOnlyWindowStore
V extends Object declared in interface ReadOnlyWindowStore
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStore.java>:60:
warning: [deprecation] fetch(K,K,long,long) in ReadOnlyWindowStore has been
deprecated
public KeyValueIterator<Windowed<Bytes>, byte[]> fetch(final Bytes keyFrom,
final Bytes keyTo, final long from, final long to) {
^
where K,V are type-variables:
K extends Object declared in interface ReadOnlyWindowStore
V extends Object declared in interface ReadOnlyWindowStore
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStore.java>:55:
warning: [deprecation] fetch(K,long,long) in ReadOnlyWindowStore has been
deprecated
public WindowStoreIterator<byte[]> fetch(final Bytes key, final long from,
final long to) {
^
where K,V are type-variables:
K extends Object declared in interface ReadOnlyWindowStore
V extends Object declared in interface ReadOnlyWindowStore
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java>:156:
warning: [deprecation] fetchAll(long,long) in ReadOnlyWindowStore has been
deprecated
public KeyValueIterator<Windowed<K>, V> fetchAll(final long timeFrom, final
long timeTo) {
^
where K,V are type-variables:
K extends Object declared in interface ReadOnlyWindowStore
V extends Object declared in interface ReadOnlyWindowStore
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java>:165:
warning: [deprecation] fetch(K,K,long,long) in ReadOnlyWindowStore has been
deprecated
public KeyValueIterator<Windowed<K>, V> fetch(final K from, final K to,
final long timeFrom, final long timeTo) {
^
where K,V are type-variables:
K extends Object declared in interface ReadOnlyWindowStore
V extends Object declared in interface ReadOnlyWindowStore
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java>:142:
warning: [deprecation] fetch(K,long,long) in ReadOnlyWindowStore has been
deprecated
public WindowStoreIterator<V> fetch(final K key, final long timeFrom, final
long timeTo) {
^
where K,V are type-variables:
K extends Object declared in interface ReadOnlyWindowStore
V extends Object declared in interface ReadOnlyWindowStore
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyWindowStore.java>:98:
warning: [deprecation] fetch(K,K,long,long) in ReadOnlyWindowStore has been
deprecated
public KeyValueIterator<Windowed<K>, V> fetch(final K from, final K to,
final long timeFrom, final long timeTo) {
^
where K,V are type-variables:
K extends Object declared in interface ReadOnlyWindowStore
V extends Object declared in interface ReadOnlyWindowStore
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyWindowStore.java>:104:
warning: [deprecation] fetch(K,K,long,long) in ReadOnlyWindowStore has been
deprecated
return store.fetch(from, to, timeFrom, timeTo);
^
where K,V are type-variables:
K extends Object declared in interface ReadOnlyWindowStore
V extends Object declared in interface ReadOnlyWindowStore
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java>:260:
warning: [deprecation] fetchAll(long,long) in ReadOnlyWindowStore has been
deprecated
public KeyValueIterator<Windowed<Bytes>, byte[]> fetchAll(final long
timeFrom, final long timeTo) {
^
where K,V are type-variables:
K extends Object declared in interface ReadOnlyWindowStore
V extends Object declared in interface ReadOnlyWindowStore
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java>:207:
warning: [deprecation] fetch(K,K,long,long) in ReadOnlyWindowStore has been
deprecated
public KeyValueIterator<Windowed<Bytes>, byte[]> fetch(final Bytes from,
final Bytes to, final long timeFrom, final long timeTo) {
^
where K,V are type-variables:
K extends Object declared in interface ReadOnlyWindowStore
V extends Object declared in interface ReadOnlyWindowStore
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java>:182:
warning: [deprecation] fetch(K,long,long) in ReadOnlyWindowStore has been
deprecated
public synchronized WindowStoreIterator<byte[]> fetch(final Bytes key,
final long timeFrom, final long timeTo) {
^
where K,V are type-variables:
K extends Object declared in interface ReadOnlyWindowStore
V extends Object declared in interface ReadOnlyWindowStore
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBWindowStore.java>:107:
warning: [deprecation] fetchAll(long,long) in ReadOnlyWindowStore has been
deprecated
public KeyValueIterator<Windowed<K>, V> fetchAll(final long timeFrom, final
long timeTo) {
^
where K,V are type-variables:
K extends Object declared in interface ReadOnlyWindowStore
V extends Object declared in interface ReadOnlyWindowStore
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBWindowStore.java>:95:
warning: [deprecation] fetch(K,K,long,long) in ReadOnlyWindowStore has been
deprecated
public KeyValueIterator<Windowed<K>, V> fetch(final K from, final K to,
final long timeFrom, final long timeTo) {
^
where K,V are type-variables:
K extends Object declared in interface ReadOnlyWindowStore
V extends Object declared in interface ReadOnlyWindowStore
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBWindowStore.java>:89:
warning: [deprecation] fetch(K,long,long) in ReadOnlyWindowStore has been
deprecated
public WindowStoreIterator<V> fetch(final K key, final long timeFrom, final
long timeTo) {
^
where K,V are type-variables:
K extends Object declared in interface ReadOnlyWindowStore
V extends Object declared in interface ReadOnlyWindowStore
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java>:550:
warning: [unchecked] unchecked method invocation: constructor <init> in class
KTableImpl is applied to given types
return new KTableImpl<K, Change<R>, R>(
^
required:
String,Serde<K>,Serde<V>,Set<String>,String,boolean,ProcessorSupplier<?,?>,StreamsGraphNode,InternalStreamsBuilder
found:
String,Serde<K>,Serde<R>,Set<String>,String,boolean,KTableKTableJoinMerger<K,R>,KTableKTableJoinNode<K,Change<V>,Change<V1>,Change<R>>,InternalStreamsBuilder
where K,V,R,V1 are type-variables:
K extends Object declared in class KTableImpl
V extends Object declared in class KTableImpl
R extends Object declared in method
<V1,R>buildJoin(AbstractStream<K,V1>,ValueJoiner<? super V,? super V1,? extends
R>,boolean,boolean,String,String,MaterializedInternal)
V1 extends Object declared in method
<V1,R>buildJoin(AbstractStream<K,V1>,ValueJoiner<? super V,? super V1,? extends
R>,boolean,boolean,String,String,MaterializedInternal)
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java>:198:
error: cannot find symbol
windows.segmentInterval()
^
symbol: method segmentInterval()
location: variable windows of type Windows<W>
where W is a type-variable:
W extends Window declared in class TimeWindowedKStreamImpl
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamSinkNode.java>:61:
warning: [unchecked] unchecked method invocation: constructor <init> in class
WindowedStreamPartitioner is applied to given types
final StreamPartitioner<K, V> windowedPartitioner =
(StreamPartitioner<K, V>) new WindowedStreamPartitioner<Object,
V>((WindowedSerializer) keySerializer);
^
required: WindowedSerializer<K>
found: WindowedSerializer
where K is a type-variable:
K extends Object declared in class WindowedStreamPartitioner
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamSinkNode.java>:61:
warning: [unchecked] unchecked conversion
final StreamPartitioner<K, V> windowedPartitioner =
(StreamPartitioner<K, V>) new WindowedStreamPartitioner<Object,
V>((WindowedSerializer) keySerializer);
^
required: WindowedSerializer<K>
found: WindowedSerializer
where K is a type-variable:
K extends Object declared in class WindowedStreamPartitioner
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamSinkNode.java>:61:
warning: [unchecked] unchecked cast
final StreamPartitioner<K, V> windowedPartitioner =
(StreamPartitioner<K, V>) new WindowedStreamPartitioner<Object,
V>((WindowedSerializer) keySerializer);
^
required: StreamPartitioner<K,V>
found: WindowedStreamPartitioner<Object,V>
where V,K are type-variables:
V extends Object declared in class StreamSinkNode
K extends Object declared in class StreamSinkNode
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/KTableKTableJoinNode.java>:88:
warning: [unchecked] unchecked method invocation: constructor <init> in class
KeyValueStoreMaterializer is applied to given types
= new
KeyValueStoreMaterializer<>(materializedInternal).materialize();
^
required: MaterializedInternal<K,V,KeyValueStore<Bytes,byte[]>>
found: MaterializedInternal
where K,V are type-variables:
K extends Object declared in class KeyValueStoreMaterializer
V extends Object declared in class KeyValueStoreMaterializer
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/KTableKTableJoinNode.java>:88:
warning: [unchecked] unchecked conversion
= new
KeyValueStoreMaterializer<>(materializedInternal).materialize();
^
required: MaterializedInternal<K,V,KeyValueStore<Bytes,byte[]>>
found: MaterializedInternal
where K,V are type-variables:
K extends Object declared in class KeyValueStoreMaterializer
V extends Object declared in class KeyValueStoreMaterializer
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/KTableKTableJoinNode.java>:88:
warning: [unchecked] unchecked conversion
= new
KeyValueStoreMaterializer<>(materializedInternal).materialize();
^
required: StoreBuilder<KeyValueStore<K,VR>>
found: StoreBuilder
where K,VR are type-variables:
K extends Object declared in class KTableKTableJoinNode
VR extends Object declared in class KTableKTableJoinNode
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableSourceNode.java>:80:
warning: [unchecked] unchecked cast
topologyBuilder.addGlobalStore((StoreBuilder<KeyValueStore>)
storeBuilder,
^
required: StoreBuilder<KeyValueStore>
found: StoreBuilder<S>
where S is a type-variable:
S extends StateStore declared in class TableSourceNode
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableSourceNode.java>:133:
warning: [unchecked] unchecked conversion
this.consumedInternal = consumedInternal;
^
required: ConsumedInternal<K,V>
found: ConsumedInternal
where K,V are type-variables:
K extends Object declared in class TableSourceNodeBuilder
V extends Object declared in class TableSourceNodeBuilder
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableProcessorNode.java>:68:
warning: [unchecked] unchecked cast
topologyBuilder.addStateStore(new
KeyValueStoreMaterializer<>((MaterializedInternal<K, V, KeyValueStore<Bytes,
byte[]>>) materializedInternal).materialize(), processorName);
^
required: MaterializedInternal<K,V,KeyValueStore<Bytes,byte[]>>
found: MaterializedInternal<K,V,S>
where K,V,S are type-variables:
K extends Object declared in class TableProcessorNode
V extends Object declared in class TableProcessorNode
S extends StateStore declared in class TableProcessorNode
1 error
37 warnings
> Task :kafka-2.1-jdk8:streams:compileJava FAILED
> Task :testScala_2_11 FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':kafka-2.1-jdk8: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. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
BUILD FAILED in 1h 48m 33s
26 actionable tasks: 17 executed, 9 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.1-jdk8/ws/> that match the pattern
**/build/reports/findbugs/*.xml
[FINDBUGS] No files found. Configuration error?
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
<Git Blamer> Using GitBlamer to create author and commit information for all
warnings.
<Git Blamer> GIT_COMMIT=5d207463eb237c0a52212ffda9f15315a859fdbb,
workspace=<https://builds.apache.org/job/kafka-2.1-jdk8/ws/>
[FINDBUGS] Computing warning deltas based on reference build #24
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 wangg...@gmail.com
