gearpump-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (GEARPUMP-267) Kafka integration test failure due to docker-kafka version incompatibility
Date Wed, 22 Feb 2017 09:02:44 GMT

    [ https://issues.apache.org/jira/browse/GEARPUMP-267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15877808#comment-15877808
] 

ASF GitHub Bot commented on GEARPUMP-267:
-----------------------------------------

Github user karol-brejna-i commented on the issue:

    https://github.com/apache/incubator-gearpump/pull/158
  
    The good news is, Kafka "cluster" is up again (during integration tests).
    The bad news, there is some error running Kafka example.
    I found this in application logs:
    ```
    INFO] [02/22/2017 08:20:08.282] [Executor@app2exec1] Executor received restart tasks
    [WARN] [02/22/2017 08:20:08.282] [ProducerConfig] The configuration value.serializer =
class org.apache.kafka.common.serialization.ByteArraySerializer was supplied but isn't a known
config.
    [WARN] [02/22/2017 08:20:08.283] [ProducerConfig] The configuration key.serializer = class
org.apache.kafka.common.serialization.ByteArraySerializer was supplied but isn't a known config.
    [INFO] [02/22/2017 08:20:08.283] [KafkaSource] created checkpoint store for [topic3,0]
    [ERROR] [02/22/2017 08:20:08.283] [Executor@app2exec1] We got java.lang.ArithmeticException
from Some(TaskId(0,0)), we will treat it as MessageLoss, so that the system will replay all
lost message
    java.lang.ArithmeticException: long overflow
            at java.lang.Math.multiplyExact(Math.java:892)
            at java.time.Instant.toEpochMilli(Instant.java:1232)
            at org.apache.gearpump.streaming.kafka.lib.source.AbstractKafkaSource.open(AbstractKafkaSource.scala:94)
            at org.apache.gearpump.streaming.source.DataSourceTask.onStart(DataSourceTask.scala:71)
            at org.apache.gearpump.streaming.task.TaskWrapper.onStart(TaskWrapper.scala:96)
            at org.apache.gearpump.streaming.task.TaskActor.onStart(TaskActor.scala:107)
            at org.apache.gearpump.streaming.task.TaskActor.org$apache$gearpump$streaming$task$TaskActor$$onStartClock(TaskActor.scala:195)
            at org.apache.gearpump.streaming.task.TaskActor$$anonfun$waitForStartClock$1.applyOrElse(TaskActor.scala:212)
            at akka.actor.Actor$class.aroundReceive(Actor.scala:496)
            at org.apache.gearpump.streaming.task.TaskActor.aroundReceive(TaskActor.scala:42)
            at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
            at akka.actor.ActorCell.invoke(ActorCell.scala:495)
            at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
            at akka.dispatch.Mailbox.run(Mailbox.scala:224)
            at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
            at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
            at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
            at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
            at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
    [WARN] [02/22/2017 08:20:08.284] [OneForOneStrategy] long overflow
    [INFO] [02/22/2017 08:20:08.285] [DataSourceTask@app2exec1TaskId(0,0)] closing data source...
    [INFO] [02/22/2017 08:20:08.283] [DataSinkTask@app2exec1TaskId(1,0)] closing data sink...
    ```



> Kafka integration test failure due to docker-kafka version incompatibility
> --------------------------------------------------------------------------
>
>                 Key: GEARPUMP-267
>                 URL: https://issues.apache.org/jira/browse/GEARPUMP-267
>             Project: Apache Gearpump
>          Issue Type: Bug
>          Components: integrationtest
>            Reporter: Manu Zhang
>            Assignee: Karol Brejna
>
> The current "spotify/kafka" has been updated to kafka 0.10 while Gearpump depends on
kafka 0.8, and the author doesn't provide history tags.  There is an open [issue|https://github.com/spotify/docker-kafka/issues/61]
but the repo doesn't seem to be under active development. An alternative is https://github.com/wurstmeister/kafka-docker



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Mime
View raw message