I'm looking for a way to avoid thread starvation in my tasks, by returning
future but i don't see how is that possible.
Hence i would like to know, how flink handle the case where in your job you
have to perform network calls (I use akka http or spray) or any IO
operation and use the result of it.
e you can specify
> a whole plan of operations before executing them.
>
> Cheers,
> Aljoscha
>
> On Tue, 24 May 2016 at 20:43 Maatary Okouya
> wrote:
>
>> I'm looking for a way to avoid thread starvation in my tasks, by
>> returning future but i don
ecuting them.
>
> Cheers,
> Aljoscha
>
> On Tue, 24 May 2016 at 20:43 Maatary Okouya
> wrote:
>
>> I'm looking for a way to avoid thread starvation in my tasks, by
>> returning future but i don't see how is that possible.
>>
>> Hence i would l
synchronized (checkpointLock) {
> ctx.collect(data);
> }
> }
> });
> }
> }
>
> @Override
> public void cancel() {
> running = false;
> }
> }
>
> I hope that helps.
>
> -Aljoscha
>
> On Wed, 25 May 2016 at 12:21 Maa
the
>> status? Thanks for your amazing work!
>>
>>
>>
>> *De: *Fabian Hueske
>> *Fecha: *viernes, 16 de agosto de 2019, 9:30
>> *Para: *"Casado Tejedor, Rubén"
>> *CC: *Maatary Okouya , miki haiat <
>> miko5...@gmail.com>, user
d expose access to state and timers, which
> are the core ingredients for stream processing.
> You can implement pretty much all logic of KStreams and more in these APIs.
>
> Best, Fabian
>
>
> Am Di., 23. Juli 2019 um 13:06 Uhr schrieb Maatary Okouya <
> maatarioko...@gm
depends on the semantics of the join and query that you need, how
much state the query will need to maintain.
I am not sure to understand the problem. If i have to append-only table and
perform some join on it, what's the issue ?
On Tue, Aug 6, 2019 at 8:03 PM Maatary Okouya
wrote:
> T
Fabian,
ultimately, i just want to perform a join on the last values for each keys.
On Tue, Aug 6, 2019 at 8:07 PM Maatary Okouya
wrote:
> Fabian,
>
> could you please clarify the following statement:
>
> However joining an append-only table with this view without adding
Hi,
I am a user of Kafka Stream so far. However, because i have been face with
several limitation in particular in performing Join on KTable.
I was wondering what is the appraoch in Flink to achieve (1) the concept
of KTable, i.e. a Table that represent a changeLog, i.e. only the latest
version
21, 2019 at 8:21 AM miki haiat wrote:
> Can you elaborate more about your use case .
>
>
> On Sat, Jul 20, 2019 at 1:04 AM Maatary Okouya
> wrote:
>
>> Hi,
>>
>> I am a user of Kafka Stream so far. However, because i have been face
>> with several limi
11 matches
Mail list logo
