See <https://builds.apache.org/job/kafka-2.2-jdk8/164/display/redirect?page=changes>
Changes: [wangguoz] KAFKA-8816: Make offsets immutable to users of RecordCollector.offsets ------------------------------------------ [...truncated 69.88 KB...] <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/unit/kafka/admin/TopicCommandTest.scala>:175: local val topic in method testListTopics is never used val topic = "testTopic" ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/unit/kafka/admin/TopicCommandWithAdminClientTest.scala>:74: Eta-expansion of zero-argument methods is deprecated. To avoid this warning, write (() => options.checkArgs()). assertExitCode(expected, options.checkArgs) ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/unit/kafka/cluster/PartitionTest.scala>:611: possible missing interpolator: detected interpolated identifier `$e` case Left(e: ApiException) => fail("Should have seen OffsetNotAvailableException, saw $e") ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/unit/kafka/cluster/PartitionTest.scala>:231: local var builder in method testMaybeReplaceCurrentWithFutureReplicaDifferentBaseOffsets is never updated: consider using immutable val var builder = MemoryRecords.builder(buffer, RecordBatch.CURRENT_MAGIC_VALUE, CompressionType.NONE, ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/unit/kafka/coordinator/group/GroupCoordinatorTest.scala>:198: local var futures in method testJoinGroupShouldReceiveErrorIfGroupOverMaxSize is never updated: consider using immutable val var futures = ArrayBuffer[Future[JoinGroupResult]]() ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/unit/kafka/coordinator/group/GroupCoordinatorTest.scala>:888: local var pendingMember in method setupGroupWithPendingMember is never updated: consider using immutable val var pendingMember = joinGroupPartial(groupId, JoinGroupRequest.UNKNOWN_MEMBER_ID, protocolType, protocols, sessionTimeout=100) ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/unit/kafka/coordinator/group/GroupMetadataTest.scala>:20: imported `GroupState' is permanently hidden by definition of trait GroupState in package group import kafka.admin.ConsumerGroupCommand.GroupState ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/unit/kafka/log/LogManagerTest.scala>:381: local val log in method testCreateAndDeleteOverlyLongTopic is never used val log = logManager.getOrCreateLog(new TopicPartition(invalidTopicName, 0), logConfig) ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/unit/kafka/server/ReplicaFetcherThreadTest.scala>:26: Unused import import org.apache.kafka.clients.ClientResponse ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/unit/kafka/server/ReplicaFetcherThreadTest.scala>:35: Unused import import org.easymock.{Capture, CaptureType, IAnswer} ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/unit/kafka/server/ReplicaFetcherThreadTest.scala>:48: private var toFail in class ReplicaFetcherThreadTest is never used private var toFail = false ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/unit/kafka/utils/TestUtils.scala>:311: This catches all Throwables. If this is really intended, use `case e : Throwable` to clear this warning. case e => throw e // let other exceptions propagate ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/unit/kafka/utils/TestUtils.scala>:353: This catches all Throwables. If this is really intended, use `case e : Throwable` to clear this warning. case e => throw e // let other exceptions propagate ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/integration/kafka/api/AdminClientIntegrationTest.scala>:1035: method close in class AdminClient is deprecated: see corresponding Javadoc for more information. client.close(2, TimeUnit.HOURS) ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/integration/kafka/api/AdminClientIntegrationTest.scala>:1039: method close in class AdminClient is deprecated: see corresponding Javadoc for more information. client.close(30, TimeUnit.MINUTES) // multiple close-with-timeout should have no effect ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/integration/kafka/api/AdminClientIntegrationTest.scala>:1055: method close in class AdminClient is deprecated: see corresponding Javadoc for more information. client.close(0, TimeUnit.MILLISECONDS) ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala>:746: method poll in class KafkaConsumer is deprecated: see corresponding Javadoc for more information. consumer.poll(50) ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala>:793: method poll in class KafkaConsumer is deprecated: see corresponding Javadoc for more information. consumer.poll(0) ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala>:819: method poll in class KafkaConsumer is deprecated: see corresponding Javadoc for more information. consumer.poll(0) ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/integration/kafka/api/BaseProducerSendTest.scala>:120: method checksum in class RecordMetadata is deprecated: see corresponding Javadoc for more information. assertNotEquals(metadata.checksum(), 0) ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/integration/kafka/api/BaseProducerSendTest.scala>:199: method close in trait Producer is deprecated: see corresponding Javadoc for more information. producer.close(timeoutMs, TimeUnit.MILLISECONDS) ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/integration/kafka/api/BaseProducerSendTest.scala>:254: method close in trait Producer is deprecated: see corresponding Javadoc for more information. producer.close(20000L, TimeUnit.MILLISECONDS) ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/integration/kafka/api/BaseProducerSendTest.scala>:451: method close in trait Producer is deprecated: see corresponding Javadoc for more information. producer.close(0, TimeUnit.MILLISECONDS) ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/integration/kafka/api/BaseProducerSendTest.scala>:460: method poll in class KafkaConsumer is deprecated: see corresponding Javadoc for more information. assertEquals("Fetch response should have no message returned.", 0, consumer.poll(50).count) ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/integration/kafka/api/BaseProducerSendTest.scala>:482: method close in trait Producer is deprecated: see corresponding Javadoc for more information. producer.close(0, TimeUnit.MILLISECONDS) ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/integration/kafka/api/BaseProducerSendTest.scala>:484: method close in trait Producer is deprecated: see corresponding Javadoc for more information. producer.close(Long.MaxValue, TimeUnit.MICROSECONDS) ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/integration/kafka/api/BaseQuotaTest.scala>:143: method poll in class KafkaConsumer is deprecated: see corresponding Javadoc for more information. consumer.poll(100) ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/integration/kafka/api/BaseQuotaTest.scala>:200: method poll in class KafkaConsumer is deprecated: see corresponding Javadoc for more information. numConsumed += consumer.poll(100).count ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/integration/kafka/api/BaseQuotaTest.scala>:209: method poll in class KafkaConsumer is deprecated: see corresponding Javadoc for more information. numConsumed += consumer.poll(100).count ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala>:111: method poll in class KafkaConsumer is deprecated: see corresponding Javadoc for more information. val records = consumer.poll(100).asScala ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala>:181: method poll in class KafkaConsumer is deprecated: see corresponding Javadoc for more information. consumer.poll(0) ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala>:479: method poll in class KafkaConsumer is deprecated: see corresponding Javadoc for more information. consumer.poll(0) ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala>:486: method poll in class KafkaConsumer is deprecated: see corresponding Javadoc for more information. otherConsumers.foreach(consumer => consumer.poll(100)) ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala>:567: method close in class KafkaConsumer is deprecated: see corresponding Javadoc for more information. consumer.close(closeTimeoutMs, TimeUnit.MILLISECONDS) ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala>:590: method poll in class KafkaConsumer is deprecated: see corresponding Javadoc for more information. consumer.poll(3000) ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/integration/kafka/api/IntegrationTestHarness.scala>:129: method close in trait Producer is deprecated: see corresponding Javadoc for more information. producers.foreach(_.close(0, TimeUnit.MILLISECONDS)) ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala>:149: method close in trait Producer is deprecated: see corresponding Javadoc for more information. producers.foreach(_.close(0, TimeUnit.MILLISECONDS)) ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala>:1496: method poll in class KafkaConsumer is deprecated: see corresponding Javadoc for more information. val records = consumer.poll(50) ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/other/kafka/ReplicationQuotasTestRig.scala>:141: object ZkUtils in package utils is deprecated (since 2.0.0): This is an internal class that is no longer used by Kafka and will be removed in a future release. Please use org.apache.kafka.clients.admin.AdminClient instead. ReassignPartitionsCommand.executeAssignment(zkClient, None, ZkUtils.getReassignmentJson(newAssignment), Throttle(config.throttle)) ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/unit/kafka/admin/PreferredReplicaLeaderElectionCommandTest.scala>:150: object ZkUtils in package utils is deprecated (since 2.0.0): This is an internal class that is no longer used by Kafka and will be removed in a future release. Please use org.apache.kafka.clients.admin.AdminClient instead. val jsonString = ZkUtils.preferredReplicaLeaderElectionZkData(partitions.map(new TopicAndPartition(_))) ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/unit/kafka/server/LogOffsetTest.scala>:120: constructor PartitionData in class PartitionData is deprecated: see corresponding Javadoc for more information. new ListOffsetRequest.PartitionData(ListOffsetRequest.LATEST_TIMESTAMP, 15)).asJava).build() ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/unit/kafka/server/LogOffsetTest.scala>:121: value offsets in class PartitionData is deprecated: see corresponding Javadoc for more information. val consumerOffsets = sendListOffsetsRequest(request).responseData.get(topicPartition).offsets.asScala ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/unit/kafka/server/LogOffsetTest.scala>:148: constructor PartitionData in class PartitionData is deprecated: see corresponding Javadoc for more information. new ListOffsetRequest.PartitionData(ListOffsetRequest.EARLIEST_TIMESTAMP, 1)).asJava).build() ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/unit/kafka/server/LogOffsetTest.scala>:149: value offsets in class PartitionData is deprecated: see corresponding Javadoc for more information. val consumerOffsets = sendListOffsetsRequest(request).responseData.get(topicPartition).offsets.asScala ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/unit/kafka/tools/MirrorMakerTest.scala>:31: class BaseConsumerRecord in package consumer is deprecated (since 0.11.0.0): This class has been deprecated and will be removed in a future release. Please use org.apache.kafka.clients.consumer.ConsumerRecord instead. val consumerRecord = BaseConsumerRecord("topic", 0, 1L, now, TimestampType.CREATE_TIME, "key".getBytes, "value".getBytes) ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/unit/kafka/tools/MirrorMakerTest.scala>:46: class BaseConsumerRecord in package consumer is deprecated (since 0.11.0.0): This class has been deprecated and will be removed in a future release. Please use org.apache.kafka.clients.consumer.ConsumerRecord instead. val consumerRecord = BaseConsumerRecord("topic", 0, 1L, RecordBatch.NO_TIMESTAMP, TimestampType.CREATE_TIME, ^ <https://builds.apache.org/job/kafka-2.2-jdk8/ws/core/src/test/scala/unit/kafka/tools/MirrorMakerTest.scala>:63: class BaseConsumerRecord in package consumer is deprecated (since 0.11.0.0): This class has been deprecated and will be removed in a future release. Please use org.apache.kafka.clients.consumer.ConsumerRecord instead. val consumerRecord = BaseConsumerRecord("topic", 0, 1L, now, TimestampType.CREATE_TIME, "key".getBytes, ^ 51 warnings found > Task :kafka-2.2-jdk8:core:processTestResources UP-TO-DATE > Task :kafka-2.2-jdk8:core:testClasses > Task :kafka-2.2-jdk8:core:checkstyleTest NO-SOURCE > Task :kafka-2.2-jdk8:spotlessScala UP-TO-DATE > Task :kafka-2.2-jdk8:spotlessScalaCheck UP-TO-DATE > Task :kafka-2.2-jdk8:core:copyDependantLibs > Task :kafka-2.2-jdk8:core:jar > Task :kafka-2.2-jdk8:connect:api:compileJava UP-TO-DATE > Task :kafka-2.2-jdk8:connect:api:processResources NO-SOURCE > Task :kafka-2.2-jdk8:connect:api:classes UP-TO-DATE > Task :kafka-2.2-jdk8:connect:api:copyDependantLibs UP-TO-DATE > Task :kafka-2.2-jdk8:connect:api:jar UP-TO-DATE > Task :kafka-2.2-jdk8:connect:json:compileJava UP-TO-DATE > Task :kafka-2.2-jdk8:connect:json:processResources NO-SOURCE > Task :kafka-2.2-jdk8:connect:json:classes UP-TO-DATE > Task :kafka-2.2-jdk8:connect:json:copyDependantLibs UP-TO-DATE > Task :kafka-2.2-jdk8:connect:json:jar UP-TO-DATE > Task :kafka-2.2-jdk8:streams:compileJava UP-TO-DATE > Task :kafka-2.2-jdk8:streams:processResources NO-SOURCE > Task :kafka-2.2-jdk8:streams:classes UP-TO-DATE > Task :kafka-2.2-jdk8:streams:copyDependantLibs > Task :kafka-2.2-jdk8:streams:jar UP-TO-DATE > Task :kafka-2.2-jdk8:streams:test-utils:compileJava UP-TO-DATE > Task :kafka-2.2-jdk8:streams:test-utils:processResources NO-SOURCE > Task :kafka-2.2-jdk8:streams:test-utils:classes UP-TO-DATE > Task :kafka-2.2-jdk8:streams:test-utils:copyDependantLibs > Task :kafka-2.2-jdk8:streams:test-utils:jar UP-TO-DATE > Task :kafka-2.2-jdk8:streams:compileTestJava <https://builds.apache.org/job/kafka-2.2-jdk8/ws/streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java>:56: error: cannot find symbol import static org.junit.Assert.assertThrows; ^ symbol: static assertThrows location: class <https://builds.apache.org/job/kafka-2.2-jdk8/ws/streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java>:171: error: cannot find symbol assertThrows(UnsupportedOperationException.class, () -> offsets.put(new TopicPartition(topic, 0), 50L)); ^ symbol: method assertThrows(Class<UnsupportedOperationException>,()->offset[...] 50L)) location: class RecordCollectorTest 2 errors > Task :kafka-2.2-jdk8:streams:compileTestJava FAILED > Task :kafka-2.2-jdk8:core:spotbugsMain The following classes needed for analysis were missing: org.apache.log4j.Logger org.apache.log4j.Level org.apache.log4j.LogManager > Task :testScala_2_12 FAILED FAILURE: Build completed with 3 failures. 1: Task 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. Run with --scan to get full insights. ============================================================================== 2: Task failed with an exception. ----------- * What went wrong: Execution failed for task ':kafka-2.2-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. ============================================================================== 3: Task failed with an exception. ----------- * What went wrong: Execution failed for task ':kafka-2.2-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 Deprecated Gradle features were used in this build, making it incompatible with Gradle 6.0. Use '--warning-mode all' to show the individual deprecation warnings. See https://docs.gradle.org/5.1.1/userguide/command_line_interface.html#sec:command_line_warnings BUILD FAILED in 7m 49s 67 actionable tasks: 42 executed, 25 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.2-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=ad14d92195140543509651f4cacf2d024fa310e2, workspace=<https://builds.apache.org/job/kafka-2.2-jdk8/ws/> [FINDBUGS] Computing warning deltas based on reference build #163 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
