2020-11-02 15:36:06 INFO DbMigrate:44 - Successfully applied 2 migrations to schema "PUBLIC" (execution time 00:00.083s). 2020-11-02 15:36:06 INFO MasterServer$:270 - DB started 2020-11-02 15:36:06 INFO MasterServer$:270 - LogsSystem started 2020-11-02 15:36:27 ERROR RestartSupervisor:159 - Starting child for FunctionInfoProvider failed java.lang.IllegalStateException: Initialization of FunctionInfoProvider failed of timeout at io.hydrosphere.mist.master.jobs.ActorRefWaiter$IdentityActor$$anonfun$receive$1.applyOrElse(FunctionInfoProviderRunner.scala:60) at akka.actor.Actor$class.aroundReceive(Actor.scala:517) at io.hydrosphere.mist.master.jobs.ActorRefWaiter$IdentityActor.aroundReceive(FunctionInfoProviderRunner.scala:48) at akka.actor.ActorCell.receiveMessage(ActorCell.scala:527) at akka.actor.ActorCell.invoke(ActorCell.scala:496)
Anyone seen an error like this? This happens using local[*] mode and happens during worker start and the start fails with this error:
Caused by: com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize instance of com.github.dockerjava.api.command.InspectContainerResponse out of START_ARRAY token
Hi! Have there been any plans to make the reactive api support streaming individual dataset rows? Or also support spark streaming? In some larger (timeline for example) calculations some of the data starts finishing quite fast and hence could be sent down to be processed. Right now the reactive API does support lifecycle events, but not this.
I'm solving this myself by creating another RSocket based server running on the mist master instance where these rows are written to and to which other microservices can subscribe to. This isn't very optimal as the original reactive api could support this much more seamlessly.