Thanks for your help. Apparently the problem was not in Akka. It seems that
when using a source .socketTextStream with maxRetry = -1, it continually
attempts to connect to the socket for the 1st time, but once it is
connected, and if no data is sent, it seems that the job is terminated.
On Fri, Fe
Its not the right forum, but, I think this really would be a extension of
what is already in ASF BigTop, which is working on packaging flink, has
kafka and zepplin, already.
Camel might go well into bigtop, and
the cassandra, drill, camel parts could be added on top possibly...
Replying on publ
Hi Nirmalya,
The aggregates will be printed 5 times because I have a rolling window with
the length of 5 minutes, which will shift 1 minute forward after each
evaluation. Because my input is within the time interval of 0 to 1 minute,
it is perfectly aligned with the windows and will fit completely
Hi,
You're right, expect that ("grace", "arctic", 25) is emitted with timestamp
90 seconds along with a for watermark 90 seconds.
I followed your advice and implemented a simple window function printing the
start + end of a window along with it's content. You can see that a window
from minute 1 t
I am planning to build a analytics platform based on Flink, Kafka , Camel,
Zeppelin , Drill and Cassandra . I am looking for co founder/partner in
Bangalore .
I am sorry if this is not a right forum to express this.
Thanks
Ashutosh
Thanks for the input Aljoscha and Ufuk! I will try out the #2 approach and
report back.
Thanks,
Zach
On Sat, Feb 20, 2016 at 7:26 AM Ufuk Celebi wrote:
> On Sat, Feb 20, 2016 at 10:12 AM, Aljoscha Krettek
> wrote:
> > IMHO the only change for 2) is that you possibly get better machine
> utili
On Sat, Feb 20, 2016 at 10:12 AM, Aljoscha Krettek wrote:
> IMHO the only change for 2) is that you possibly get better machine
> utilization because it will use more parallel threads. So I think it’s a
> valid approach.
>
> @Ufuk, could there be problems with the number of network buffers? I t
IMHO the only change for 2) is that you possibly get better machine utilization
because it will use more parallel threads. So I think it’s a valid approach.
@Ufuk, could there be problems with the number of network buffers? I think not,
because the connections are multiplexed in one channel, is
