See
<https://builds.apache.org/job/kafka-2.1-jdk8/226/display/redirect?page=changes>
Changes:
[wangguoz] KAFKA-8412: Fix nullpointer exception thrown on flushing before
closing
------------------------------------------
[...truncated 91.06 KB...]
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/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/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/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
<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/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/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/CachingWindowStore.java>:259:
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>:206:
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>:181:
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/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
37 warnings
> Task :kafka-2.1-jdk8:streams:processResources NO-SOURCE
> Task :kafka-2.1-jdk8:streams:classes
> Task :kafka-2.1-jdk8:streams:copyDependantLibs
> Task :kafka-2.1-jdk8:streams:jar
> Task :kafka-2.1-jdk8:streams:test-utils:compileJava
> Task :kafka-2.1-jdk8:streams:test-utils:processResources NO-SOURCE
> Task :kafka-2.1-jdk8:streams:test-utils:classes
> Task :kafka-2.1-jdk8:streams:test-utils:copyDependantLibs
> Task :kafka-2.1-jdk8:streams:test-utils:jar
> Task :kafka-2.1-jdk8:core:spotbugsMain
> Task :kafka-2.1-jdk8:streams:compileTestJava FAILED
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilderTest.java>:172:
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.1-jdk8/ws/streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilderTest.java>:203:
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
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/test/java/org/apache/kafka/streams/processor/internals/AssignedStreamsTasksTest.java>:504:
error: constructor StateDirectory in class StateDirectory cannot be applied to
given types;
final StateDirectory stateDirectory = new StateDirectory(
^
required: StreamsConfig,Time
found: StreamsConfig,MockTime,boolean
reason: actual and formal argument lists differ in length
<https://builds.apache.org/job/kafka-2.1-jdk8/ws/streams/src/test/java/org/apache/kafka/streams/processor/internals/AssignedStreamsTasksTest.java>:509:
error: no suitable constructor found for
StreamTask(TaskId,Set<TopicPartition>,ProcessorTopology,MockConsumer<byte[],byte[]>,ChangelogReader,StreamsConfig,StreamsMetricsImpl,StateDirectory,<null>,MockTime,()->producer)
final StreamTask task = new StreamTask(
^
constructor
StreamTask.StreamTask(TaskId,Collection<TopicPartition>,ProcessorTopology,Consumer<byte[],byte[]>,ChangelogReader,StreamsConfig,StreamsMetricsImpl,StateDirectory,ThreadCache,Time,ProducerSupplier,Sensor)
is not applicable
(actual and formal argument lists differ in length)
constructor
StreamTask.StreamTask(TaskId,Collection<TopicPartition>,ProcessorTopology,Consumer<byte[],byte[]>,ChangelogReader,StreamsConfig,StreamsMetricsImpl,StateDirectory,ThreadCache,Time,ProducerSupplier,RecordCollector,Sensor)
is not applicable
(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.
2 errors
2 warnings
> Task :testScala_2_11 FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':kafka-2.1-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 5m 46s
26 actionable tasks: 3 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.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
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=8cdc2d6d1b2a227f5e62f148179a52684b230bd6,
workspace=<https://builds.apache.org/job/kafka-2.1-jdk8/ws/>
[FINDBUGS] Computing warning deltas based on reference build #225
Recording test results
Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1
ERROR: Step ?Publish JUnit test result report? failed: No test report files
were found. Configuration error?
Setting GRADLE_4_8_1_HOME=/home/jenkins/tools/gradle/4.8.1
Not sending mail to unregistered user wangg...@gmail.com
