See <https://builds.apache.org/job/kafka-2.3-jdk8/96/display/redirect?page=changes>
Changes: [wangguoz] KAFKA-8412: Fix nullpointer exception thrown on flushing before closing ------------------------------------------ [...truncated 58.39 KB...] <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/main/scala/kafka/server/KafkaApis.scala>:821: constructor PartitionData in class PartitionData is deprecated: see corresponding Javadoc for more information. new ListOffsetResponse.PartitionData(Errors.TOPIC_AUTHORIZATION_FAILED, List[JLong]().asJava) ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/main/scala/kafka/server/KafkaApis.scala>:829: value maxNumOffsets in class PartitionData is deprecated: see corresponding Javadoc for more information. maxNumOffsets = partitionData.maxNumOffsets, ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/main/scala/kafka/server/KafkaApis.scala>:832: constructor PartitionData in class PartitionData is deprecated: see corresponding Javadoc for more information. (topicPartition, new ListOffsetResponse.PartitionData(Errors.NONE, offsets.map(JLong.valueOf).asJava)) ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/main/scala/kafka/server/KafkaApis.scala>:841: constructor PartitionData in class PartitionData is deprecated: see corresponding Javadoc for more information. (topicPartition, new ListOffsetResponse.PartitionData(Errors.forException(e), List[JLong]().asJava)) ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/main/scala/kafka/server/KafkaApis.scala>:844: constructor PartitionData in class PartitionData is deprecated: see corresponding Javadoc for more information. (topicPartition, new ListOffsetResponse.PartitionData(Errors.forException(e), List[JLong]().asJava)) ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/main/scala/kafka/server/KafkaConfig.scala>:231: value DEFAULT_SASL_ENABLED_MECHANISMS in class SaslConfigs is deprecated: see corresponding Javadoc for more information. val SaslEnabledMechanisms = SaslConfigs.DEFAULT_SASL_ENABLED_MECHANISMS ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/main/scala/kafka/server/ReplicaFetcherThread.scala>:235: value offsets in class PartitionData is deprecated: see corresponding Javadoc for more information. responsePartitionData.offsets.get(0) ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/main/scala/kafka/tools/ConsoleConsumer.scala>:573: method checksum in class ConsumerRecord is deprecated: see corresponding Javadoc for more information. output.println(topicStr + "checksum:" + consumerRecord.checksum) ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/main/scala/kafka/tools/MirrorMaker.scala>:197: 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. private def toBaseConsumerRecord(record: ConsumerRecord[Array[Byte], Array[Byte]]): BaseConsumerRecord = ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/main/scala/kafka/tools/MirrorMaker.scala>:198: 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. BaseConsumerRecord(record.topic, ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/main/scala/kafka/tools/MirrorMaker.scala>:417: 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. def handle(record: BaseConsumerRecord): util.List[ProducerRecord[Array[Byte], Array[Byte]]] ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/main/scala/kafka/tools/MirrorMaker.scala>:421: 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. override def handle(record: BaseConsumerRecord): util.List[ProducerRecord[Array[Byte], Array[Byte]]] = { ^ 34 warnings found Note: <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/main/scala/kafka/tools/StreamsResetter.java> uses unchecked or unsafe operations. Note: Recompile with -Xlint:unchecked for details. > Task :kafka-2.3-jdk8:core:processResources NO-SOURCE > Task :kafka-2.3-jdk8:core:classes > Task :kafka-2.3-jdk8:core:checkstyleMain > Task :kafka-2.3-jdk8:core:compileTestJava NO-SOURCE > Task :kafka-2.3-jdk8:core:compileTestScala Pruning sources from previous analysis, due to incompatible CompileSetup. <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala>:370: value DEFAULT_TIMESTAMP in class OffsetCommitRequest is deprecated: see corresponding Javadoc for more information. .setCommitTimestamp(OffsetCommitRequest.DEFAULT_TIMESTAMP) ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/test/scala/unit/kafka/integration/UncleanLeaderElectionTest.scala>:21: Unused import import org.junit.{After, Before, Ignore, Test} ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/test/scala/unit/kafka/log/LogManagerTest.scala>:386: 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.3-jdk8/ws/core/src/test/scala/unit/kafka/server/RequestQuotaTest.scala>:17: Unused import import java.nio.ByteBuffer ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/test/scala/integration/kafka/api/AdminClientIntegrationTest.scala>:1621: method alterConfigs in class AdminClient is deprecated: see corresponding Javadoc for more information. var alterResult = client.alterConfigs(Map( ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/test/scala/integration/kafka/api/AdminClientIntegrationTest.scala>:1653: method alterConfigs in class AdminClient is deprecated: see corresponding Javadoc for more information. alterResult = client.alterConfigs(Map( ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/test/scala/integration/kafka/api/AdminClientIntegrationTest.scala>:1693: method alterConfigs in class AdminClient is deprecated: see corresponding Javadoc for more information. var alterResult = client.alterConfigs(Map( ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/test/scala/integration/kafka/api/AdminClientIntegrationTest.scala>:1721: method alterConfigs in class AdminClient is deprecated: see corresponding Javadoc for more information. alterResult = client.alterConfigs(Map( ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/test/scala/integration/kafka/api/AdminClientWithPoliciesIntegrationTest.scala>:125: method alterConfigs in class AdminClient is deprecated: see corresponding Javadoc for more information. var alterResult = client.alterConfigs(Map( ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/test/scala/integration/kafka/api/AdminClientWithPoliciesIntegrationTest.scala>:155: method alterConfigs in class AdminClient is deprecated: see corresponding Javadoc for more information. alterResult = client.alterConfigs(Map( ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala>:824: method poll in class KafkaConsumer is deprecated: see corresponding Javadoc for more information. consumer.poll(50) ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala>:871: method poll in class KafkaConsumer is deprecated: see corresponding Javadoc for more information. consumer.poll(0) ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala>:897: method poll in class KafkaConsumer is deprecated: see corresponding Javadoc for more information. consumer.poll(0) ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/test/scala/integration/kafka/api/BaseProducerSendTest.scala>:122: method checksum in class RecordMetadata is deprecated: see corresponding Javadoc for more information. assertNotEquals(metadata.checksum(), 0) ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala>:100: 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.3-jdk8/ws/core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala>:394: method poll in class KafkaConsumer is deprecated: see corresponding Javadoc for more information. consumer.poll(0L) ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala>:1211: method alterConfigs in class AdminClient is deprecated: see corresponding Javadoc for more information. adminClient.alterConfigs(configs).all.get ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala>:1229: method alterConfigs in class AdminClient is deprecated: see corresponding Javadoc for more information. adminClients.head.alterConfigs(configs).all.get ^ <https://builds.apache.org/job/kafka-2.3-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.3-jdk8/ws/core/src/test/scala/unit/kafka/admin/PreferredReplicaLeaderElectionCommandTest.scala>:148: 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.3-jdk8/ws/core/src/test/scala/unit/kafka/log/TransactionIndexTest.scala>:27: class JUnitSuite in package junit is deprecated: JUnitSuite has been moved from org.scalatest.junit to org.scalatestplus.junit. Please update your imports, as this deprecated type alias will be removed in a future version of ScalaTest. class TransactionIndexTest extends JUnitSuite { ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/test/scala/unit/kafka/security/auth/AclTest.scala>:27: class JUnitSuite in package junit is deprecated: JUnitSuite has been moved from org.scalatest.junit to org.scalatestplus.junit. Please update your imports, as this deprecated type alias will be removed in a future version of ScalaTest. class AclTest extends JUnitSuite { ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/test/scala/unit/kafka/server/KafkaApisTest.scala>:513: side-effecting nullary methods are discouraged: suggest defining as `def testJoinGroupProtocolsOrder()` instead def testJoinGroupProtocolsOrder: Unit = { ^ <https://builds.apache.org/job/kafka-2.3-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.3-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.3-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.3-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.3-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.3-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.3-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, ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/test/scala/unit/kafka/utils/TestUtils.scala>:1407: method alterConfigs in class AdminClient is deprecated: see corresponding Javadoc for more information. adminClient.alterConfigs(configs) ^ <https://builds.apache.org/job/kafka-2.3-jdk8/ws/core/src/test/scala/unit/kafka/utils/TestUtils.scala>:1428: method alterConfigs in class AdminClient is deprecated: see corresponding Javadoc for more information. adminClient.alterConfigs(configs) ^ 32 warnings found > Task :kafka-2.3-jdk8:core:processTestResources UP-TO-DATE > Task :kafka-2.3-jdk8:core:testClasses > Task :kafka-2.3-jdk8:core:checkstyleTest NO-SOURCE > Task :kafka-2.3-jdk8:spotlessScala UP-TO-DATE > Task :kafka-2.3-jdk8:spotlessScalaCheck UP-TO-DATE > Task :kafka-2.3-jdk8:core:copyDependantLibs > Task :kafka-2.3-jdk8:core:jar > Task :kafka-2.3-jdk8:connect:api:compileJava UP-TO-DATE > Task :kafka-2.3-jdk8:connect:api:processResources NO-SOURCE > Task :kafka-2.3-jdk8:connect:api:classes UP-TO-DATE > Task :kafka-2.3-jdk8:connect:api:copyDependantLibs UP-TO-DATE > Task :kafka-2.3-jdk8:connect:api:jar UP-TO-DATE > Task :kafka-2.3-jdk8:connect:json:compileJava UP-TO-DATE > Task :kafka-2.3-jdk8:connect:json:processResources NO-SOURCE > Task :kafka-2.3-jdk8:connect:json:classes UP-TO-DATE > Task :kafka-2.3-jdk8:connect:json:copyDependantLibs UP-TO-DATE > Task :kafka-2.3-jdk8:connect:json:jar UP-TO-DATE > Task :kafka-2.3-jdk8:streams:compileJava UP-TO-DATE > Task :kafka-2.3-jdk8:streams:processResources NO-SOURCE > Task :kafka-2.3-jdk8:streams:classes UP-TO-DATE > Task :kafka-2.3-jdk8:streams:copyDependantLibs > Task :kafka-2.3-jdk8:streams:jar UP-TO-DATE > Task :kafka-2.3-jdk8:streams:test-utils:compileJava UP-TO-DATE > Task :kafka-2.3-jdk8:streams:test-utils:processResources NO-SOURCE > Task :kafka-2.3-jdk8:streams:test-utils:classes UP-TO-DATE > Task :kafka-2.3-jdk8:streams:test-utils:copyDependantLibs > Task :kafka-2.3-jdk8:streams:test-utils:jar UP-TO-DATE > Task :kafka-2.3-jdk8:streams:compileTestJava <https://builds.apache.org/job/kafka-2.3-jdk8/ws/streams/src/test/java/org/apache/kafka/streams/processor/internals/AssignedStreamsTasksTest.java>:511: 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) 1 error > Task :kafka-2.3-jdk8:streams:compileTestJava FAILED > Task :kafka-2.3-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.3-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.3-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.4.1/userguide/command_line_interface.html#sec:command_line_warnings BUILD FAILED in 11m 39s 68 actionable tasks: 42 executed, 26 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.3-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=e0e2dbc9d89b0fcbf49ac9bf30a7159d3c27c9f8, workspace=<https://builds.apache.org/job/kafka-2.3-jdk8/ws/> [FINDBUGS] Computing warning deltas based on reference build #94 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 g...@confluent.io Not sending mail to unregistered user wangg...@gmail.com
