gearpump-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From karol-brejna-i <...@git.apache.org>
Subject [GitHub] incubator-gearpump issue #158: [GEARPUMP-267] Changing docker image for Kafk...
Date Wed, 22 Feb 2017 09:02:23 GMT
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...
    ```



---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

Mime
View raw message