See <https://builds.apache.org/job/kafka-1.0-jdk7/141/display/redirect?page=changes>
Changes: [wangguoz] KAFKA-4969: Attempt to evenly distribute load of tasks (#4410) ------------------------------------------ [...truncated 1.44 MB...] <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java>:269: warning: [deprecation] writeAsText(String,Serde<K>,Serde<V>) in KStream has been deprecated public void writeAsText(final String filePath, ^ where K,V are type-variables: K extends Object declared in interface KStream V extends Object declared in interface KStream <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java>:262: warning: [deprecation] writeAsText(String,String) in KStream has been deprecated public void writeAsText(final String filePath, ^ <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java>:256: warning: [deprecation] writeAsText(String) in KStream has been deprecated public void writeAsText(final String filePath) { ^ <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java>:237: warning: [deprecation] print(KeyValueMapper<? super K,? super V,String>,Serde<K>,Serde<V>,String) in KStream has been deprecated public void print(final KeyValueMapper<? super K, ? super V, String> mapper, ^ where K,V are type-variables: K extends Object declared in interface KStream V extends Object declared in interface KStream <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java>:229: warning: [deprecation] print(KeyValueMapper<? super K,? super V,String>,Serde<K>,Serde<V>) in KStream has been deprecated public void print(final KeyValueMapper<? super K, ? super V, String> mapper, ^ where K,V are type-variables: K extends Object declared in interface KStream V extends Object declared in interface KStream <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java>:222: warning: [deprecation] print(KeyValueMapper<? super K,? super V,String>,String) in KStream has been deprecated public void print(final KeyValueMapper<? super K, ? super V, String> mapper, ^ where K,V are type-variables: K extends Object declared in interface KStream V extends Object declared in interface KStream <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java>:216: warning: [deprecation] print(KeyValueMapper<? super K,? super V,String>) in KStream has been deprecated public void print(final KeyValueMapper<? super K, ? super V, String> mapper) { ^ where K,V are type-variables: K extends Object declared in interface KStream V extends Object declared in interface KStream <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java>:208: warning: [deprecation] print(Serde<K>,Serde<V>,String) in KStream has been deprecated public void print(final Serde<K> keySerde, ^ where K,V are type-variables: K extends Object declared in interface KStream V extends Object declared in interface KStream <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java>:201: warning: [deprecation] print(Serde<K>,Serde<V>) in KStream has been deprecated public void print(final Serde<K> keySerde, ^ where K,V are type-variables: K extends Object declared in interface KStream V extends Object declared in interface KStream <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java>:195: warning: [deprecation] print(String) in KStream has been deprecated public void print(final String label) { ^ <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java>:189: warning: [deprecation] print() in KStream has been deprecated public void print() { ^ <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImpl.java>:130: warning: [deprecation] <VR>aggregate(Initializer<VR>,Aggregator<? super K,? super V,VR>,Aggregator<? super K,? super V,VR>,StateStoreSupplier<KeyValueStore>) in KGroupedTable has been deprecated public <T> KTable<K, T> aggregate(final Initializer<T> initializer, ^ where VR,K,V are type-variables: VR extends Object declared in method <VR>aggregate(Initializer<VR>,Aggregator<? super K,? super V,VR>,Aggregator<? super K,? super V,VR>,StateStoreSupplier<KeyValueStore>) K extends Object declared in interface KGroupedTable V extends Object declared in interface KGroupedTable <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImpl.java>:104: warning: [deprecation] <VR>aggregate(Initializer<VR>,Aggregator<? super K,? super V,VR>,Aggregator<? super K,? super V,VR>,Serde<VR>) in KGroupedTable has been deprecated public <T> KTable<K, T> aggregate(final Initializer<T> initializer, ^ where VR,K,V are type-variables: VR extends Object declared in method <VR>aggregate(Initializer<VR>,Aggregator<? super K,? super V,VR>,Aggregator<? super K,? super V,VR>,Serde<VR>) K extends Object declared in interface KGroupedTable V extends Object declared in interface KGroupedTable <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImpl.java>:93: warning: [deprecation] <VR>aggregate(Initializer<VR>,Aggregator<? super K,? super V,VR>,Aggregator<? super K,? super V,VR>,Serde<VR>,String) in KGroupedTable has been deprecated public <T> KTable<K, T> aggregate(final Initializer<T> initializer, ^ where VR,K,V are type-variables: VR extends Object declared in method <VR>aggregate(Initializer<VR>,Aggregator<? super K,? super V,VR>,Aggregator<? super K,? super V,VR>,Serde<VR>,String) K extends Object declared in interface KGroupedTable V extends Object declared in interface KGroupedTable <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImpl.java>:113: warning: [deprecation] <VR>aggregate(Initializer<VR>,Aggregator<? super K,? super V,VR>,Aggregator<? super K,? super V,VR>,String) in KGroupedTable has been deprecated public <T> KTable<K, T> aggregate(final Initializer<T> initializer, ^ where VR,K,V are type-variables: VR extends Object declared in method <VR>aggregate(Initializer<VR>,Aggregator<? super K,? super V,VR>,Aggregator<? super K,? super V,VR>,String) K extends Object declared in interface KGroupedTable V extends Object declared in interface KGroupedTable <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImpl.java>:235: warning: [deprecation] reduce(Reducer<V>,Reducer<V>,StateStoreSupplier<KeyValueStore>) in KGroupedTable has been deprecated public KTable<K, V> reduce(final Reducer<V> adder, ^ where V,K are type-variables: V extends Object declared in interface KGroupedTable K extends Object declared in interface KGroupedTable <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImpl.java>:205: warning: [deprecation] reduce(Reducer<V>,Reducer<V>,String) in KGroupedTable has been deprecated public KTable<K, V> reduce(final Reducer<V> adder, ^ where V,K are type-variables: V extends Object declared in interface KGroupedTable K extends Object declared in interface KGroupedTable <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImpl.java>:289: warning: [deprecation] count(StateStoreSupplier<KeyValueStore>) in KGroupedTable has been deprecated public KTable<K, Long> count(final org.apache.kafka.streams.processor.StateStoreSupplier<KeyValueStore> storeSupplier) { ^ where K is a type-variable: K extends Object declared in interface KGroupedTable <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImpl.java>:247: warning: [deprecation] count(String) in KGroupedTable has been deprecated public KTable<K, Long> count(final String queryableStoreName) { ^ where K is a type-variable: K extends Object declared in interface KGroupedTable <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:349: warning: [deprecation] <T>aggregate(Initializer<T>,Aggregator<? super K,? super V,T>,Merger<? super K,T>,SessionWindows,Serde<T>,StateStoreSupplier<SessionStore>) in KGroupedStream has been deprecated public <T> KTable<Windowed<K>, T> aggregate(final Initializer<T> initializer, ^ where T,K,V are type-variables: T extends Object declared in method <T>aggregate(Initializer<T>,Aggregator<? super K,? super V,T>,Merger<? super K,T>,SessionWindows,Serde<T>,StateStoreSupplier<SessionStore>) K extends Object declared in interface KGroupedStream V extends Object declared in interface KGroupedStream <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:334: warning: [deprecation] <T>aggregate(Initializer<T>,Aggregator<? super K,? super V,T>,Merger<? super K,T>,SessionWindows,Serde<T>) in KGroupedStream has been deprecated public <T> KTable<Windowed<K>, T> aggregate(final Initializer<T> initializer, ^ where T,K,V are type-variables: T extends Object declared in method <T>aggregate(Initializer<T>,Aggregator<? super K,? super V,T>,Merger<? super K,T>,SessionWindows,Serde<T>) K extends Object declared in interface KGroupedStream V extends Object declared in interface KGroupedStream <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:314: warning: [deprecation] <T>aggregate(Initializer<T>,Aggregator<? super K,? super V,T>,Merger<? super K,T>,SessionWindows,Serde<T>,String) in KGroupedStream has been deprecated public <T> KTable<Windowed<K>, T> aggregate(final Initializer<T> initializer, ^ where T,K,V are type-variables: T extends Object declared in method <T>aggregate(Initializer<T>,Aggregator<? super K,? super V,T>,Merger<? super K,T>,SessionWindows,Serde<T>,String) K extends Object declared in interface KGroupedStream V extends Object declared in interface KGroupedStream <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:243: warning: [deprecation] <W,VR>aggregate(Initializer<VR>,Aggregator<? super K,? super V,VR>,Windows<W>,StateStoreSupplier<WindowStore>) in KGroupedStream has been deprecated public <W extends Window, T> KTable<Windowed<K>, T> aggregate(final Initializer<T> initializer, ^ where W,VR,K,V are type-variables: W extends Window declared in method <W,VR>aggregate(Initializer<VR>,Aggregator<? super K,? super V,VR>,Windows<W>,StateStoreSupplier<WindowStore>) VR extends Object declared in method <W,VR>aggregate(Initializer<VR>,Aggregator<? super K,? super V,VR>,Windows<W>,StateStoreSupplier<WindowStore>) K extends Object declared in interface KGroupedStream V extends Object declared in interface KGroupedStream <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:231: warning: [deprecation] <W,VR>aggregate(Initializer<VR>,Aggregator<? super K,? super V,VR>,Windows<W>,Serde<VR>) in KGroupedStream has been deprecated public <W extends Window, T> KTable<Windowed<K>, T> aggregate(final Initializer<T> initializer, ^ where W,VR,K,V are type-variables: W extends Window declared in method <W,VR>aggregate(Initializer<VR>,Aggregator<? super K,? super V,VR>,Windows<W>,Serde<VR>) VR extends Object declared in method <W,VR>aggregate(Initializer<VR>,Aggregator<? super K,? super V,VR>,Windows<W>,Serde<VR>) K extends Object declared in interface KGroupedStream V extends Object declared in interface KGroupedStream <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:220: warning: [deprecation] <W,VR>aggregate(Initializer<VR>,Aggregator<? super K,? super V,VR>,Windows<W>,Serde<VR>,String) in KGroupedStream has been deprecated public <W extends Window, T> KTable<Windowed<K>, T> aggregate(final Initializer<T> initializer, ^ where W,VR,K,V are type-variables: W extends Window declared in method <W,VR>aggregate(Initializer<VR>,Aggregator<? super K,? super V,VR>,Windows<W>,Serde<VR>,String) VR extends Object declared in method <W,VR>aggregate(Initializer<VR>,Aggregator<? super K,? super V,VR>,Windows<W>,Serde<VR>,String) K extends Object declared in interface KGroupedStream V extends Object declared in interface KGroupedStream <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:206: warning: [deprecation] <VR>aggregate(Initializer<VR>,Aggregator<? super K,? super V,VR>,StateStoreSupplier<KeyValueStore>) in KGroupedStream has been deprecated public <T> KTable<K, T> aggregate(final Initializer<T> initializer, ^ where VR,K,V are type-variables: VR extends Object declared in method <VR>aggregate(Initializer<VR>,Aggregator<? super K,? super V,VR>,StateStoreSupplier<KeyValueStore>) K extends Object declared in interface KGroupedStream V extends Object declared in interface KGroupedStream <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:198: warning: [deprecation] <VR>aggregate(Initializer<VR>,Aggregator<? super K,? super V,VR>,Serde<VR>) in KGroupedStream has been deprecated public <T> KTable<K, T> aggregate(final Initializer<T> initializer, ^ where VR,K,V are type-variables: VR extends Object declared in method <VR>aggregate(Initializer<VR>,Aggregator<? super K,? super V,VR>,Serde<VR>) K extends Object declared in interface KGroupedStream V extends Object declared in interface KGroupedStream <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:152: warning: [deprecation] <VR>aggregate(Initializer<VR>,Aggregator<? super K,? super V,VR>,Serde<VR>,String) in KGroupedStream has been deprecated public <T> KTable<K, T> aggregate(final Initializer<T> initializer, ^ where VR,K,V are type-variables: VR extends Object declared in method <VR>aggregate(Initializer<VR>,Aggregator<? super K,? super V,VR>,Serde<VR>,String) K extends Object declared in interface KGroupedStream V extends Object declared in interface KGroupedStream <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:447: warning: [deprecation] reduce(Reducer<V>,SessionWindows,StateStoreSupplier<SessionStore>) in KGroupedStream has been deprecated public KTable<Windowed<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-1.0-jdk7/ws/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java>:439: warning: [deprecation] reduce(Reducer<V>,SessionWindows) in KGroupedStream has been deprecated public KTable<Windowed<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 Note: Some input files additionally use or override a deprecated API. Note: Some input files use unchecked or unsafe operations. Note: Recompile with -Xlint:unchecked for details. 100 warnings :streams:processResources NO-SOURCE :streams:classes :streams:checkstyleMain :streams:compileTestJava<https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamPartitionAssignorTest.java>:313: error: cannot find symbol mockTaskManager(new HashSet<TaskId>(), new HashSet<TaskId>(), uuid1, builder); ^ symbol: method mockTaskManager(HashSet<TaskId>,HashSet<TaskId>,UUID,InternalTopologyBuilder) location: class StreamPartitionAssignorTest <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamPartitionAssignorTest.java>:314: error: method configurePartitionAssignor in class StreamPartitionAssignorTest cannot be applied to given types; configurePartitionAssignor(Collections.<String, Object>emptyMap()); ^ required: int,String found: Map<String,Object> reason: actual and formal argument lists differ in length <https://builds.apache.org/job/kafka-1.0-jdk7/ws/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamPartitionAssignorTest.java>:316: error: cannot find symbol partitionAssignor.setInternalTopicManager(new MockInternalTopicManager(streamsConfig, mockClientSupplier.restoreConsumer)); ^ symbol: variable streamsConfig location: class StreamPartitionAssignorTest 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. 3 errors 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 56m 17s 48 actionable tasks: 38 executed, 10 up-to-date Build step 'Execute shell' marked build as failure [FINDBUGS] Collecting findbugs analysis files... ERROR: No tool found matching GRADLE_3_4_RC_2_HOME Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5 [FINDBUGS] Searching for all files in <https://builds.apache.org/job/kafka-1.0-jdk7/ws/> that match the pattern **/build/reports/findbugs/*.xml [FINDBUGS] Parsing 4 files in <https://builds.apache.org/job/kafka-1.0-jdk7/ws/> [FINDBUGS] Successfully parsed file <https://builds.apache.org/job/kafka-1.0-jdk7/ws/clients/build/reports/findbugs/main.xml> with 0 unique warnings and 0 duplicates. [FINDBUGS] Successfully parsed file <https://builds.apache.org/job/kafka-1.0-jdk7/ws/core/build/reports/findbugs/main.xml> with 0 unique warnings and 0 duplicates. [FINDBUGS] Successfully parsed file <https://builds.apache.org/job/kafka-1.0-jdk7/ws/examples/build/reports/findbugs/main.xml> with 0 unique warnings and 0 duplicates. [FINDBUGS] Successfully parsed file <https://builds.apache.org/job/kafka-1.0-jdk7/ws/log4j-appender/build/reports/findbugs/main.xml> with 0 unique warnings and 0 duplicates. ERROR: No tool found matching GRADLE_3_4_RC_2_HOME Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5 ERROR: No tool found matching GRADLE_3_4_RC_2_HOME Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5 <Git Blamer> Using GitBlamer to create author and commit information for all warnings. <Git Blamer> GIT_COMMIT=6edf68522853da1668a63314f2ec524ea326fe1a, workspace=<https://builds.apache.org/job/kafka-1.0-jdk7/ws/> [FINDBUGS] Computing warning deltas based on reference build #140 Recording test results ERROR: No tool found matching GRADLE_3_4_RC_2_HOME Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5 ERROR: No tool found matching GRADLE_3_4_RC_2_HOME Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5 Not sending mail to unregistered user wangg...@gmail.com
