val withoutSink = source via graphFlows.fold(Fold[NormalRow])(_ via _)
val runnableFlow = withoutSink to sink
runnableFlow.run()
On Wed, Jul 8, 2015 at 2:35 AM, Allen Nie aiming...@gmail.com wrote:
Hi,
I'm trying to construct a stream pipeline automatically based on a
list of Flow:
Merged, thanks a lot! Keep on hakking :-)
--
Cheers,
Konrad 'ktoso’ Malawski
Akka @ Typesafe
On 2 July 2015 at 07:10:54, Stephen McDonald (stephen...@gmail.com) wrote:
Hi all,
I just wanted to share a project I've been working on over the last 6 months.
I've called it CurioDB [1], it's a
I am at a loss as to what I am doing wrong here. Any help would be very
much appreciated.
I have three nodes, all in separate executables.
I have the Lighthouse, which is the concept illustrated here:
Here is the code for it:
*pom.xml*
?xml version=1.0 encoding=UTF-8?
project
Thanks a lot Konrad!
PR here: https://github.com/akka/akka.github.com/pull/221
On Wed, Jul 8, 2015 at 8:06 PM, Konrad Malawski
konrad.malaw...@typesafe.com wrote:
That's pretty awesome! Thanks for sharing :-)
If you would like to we're happy to promote it on the community page:
I'm using akka cluser sharding. When akka version is 2.3.9 or 2.3.11
I get "sending HandOverToMe to [None]" messages and the
cluster is getting ready too late (35 seconds) while there is no
"sending HandOverToMe to [None]" in version 2.3.6 and also cluster
gets ready
That's pretty awesome! Thanks for sharing :-)
If you would like to we're happy to promote it on the community page:
http://akka.io/community/#projects-using-akka
Just submit a PR with your project details to
https://github.com/akka/akka.github.com/pulls and we'll happily merge it :)
--
Cheers,
Thank you!
Fred
On Friday, July 3, 2015 at 5:10:00 AM UTC-7, Patrik Nordwall wrote:
We have investigated and fixed the issue. The conclusion was that the
change of self during restarts was not needed and incorrect. We have
changed the implementation to match the documentation // Completely
Hello!
I am currently working on the problem:
There is a cluster with N nodes. Network issues take place from time to
time. We have auto downing set to some value (let it be 2 minutes), As a
result of a network issue longer than 2 minutes, sub cluster(s) appears.
The setting of minimum number
Thank you Viktor,
However, I still get this error:
val withoutSink = source via graphFlows.fold(Fold[NormalRow,
NormalRow])(_ via _)
val runnableFlow = withoutSink to sink
Error:(25, 54) object Fold in package fusing cannot be accessed in
package akka.stream.impl.fusing
sorry, Fold should be Flow
Cheers,
√
On 8 Jul 2015 18:41, Allen Nie aiming...@gmail.com wrote:
Thank you Viktor,
However, I still get this error:
val withoutSink = source via graphFlows.fold(Fold[NormalRow,
NormalRow])(_ via _)
val runnableFlow = withoutSink to sink
An intermediate conversion to/from a String appears to be the only easy way
(i.e. single operation).
A reliable implementation would have to pick apart the source uri and
assemble all the components needed to create the the target.
This problem arose when integration with a library that passes
11 matches
Mail list logo
