Hi everyone,
We need to implement api functions to cancel, restart and start the flink job.
Is there any way to add these functions to WebMonitor api?Is there any plan to
implement these functions to WebMonitor api?
Thanks.
Ozan
cellation should be straight forward.
>
> Restart is currently not supported via the REST API and I'm not aware
> of any plans to add this.
>
> – Ufuk
>
>
> On Mon, Jun 6, 2016 at 9:57 AM, Ozan DENİZ <ozande...@outlook.com> wrote:
> > Hi everyone,
> > We n
We are using periodic event time window with watermark. We have currently 4
parallel tasks in our Flink App.
During the streaming process, all the 4 tasks' watermark values must be close
to trigger window event.
For example;
Task 1 watermark value = 8
Task 2 watermark value =
We are using periodic event time window with watermark. We have currently 4
parallel tasks in our Flink App.
During the streaming process, all the 4 tasks' watermark values must be close
to trigger window event.
For example;
Task 1 watermark value = 8
Task 2 watermark value =
Hi everyone,
I am trying to implement savepoint mechanism for my Flink project.
Here is the scenario:
I got the snapshot of Flink application by using "flink savepoint "
command while the application is running.
After saving snapshot of application, I canceled the job from web ui than I
u please share the program before and after the savepoint?
> >
> > – Ufuk
> >
> > On Mon, Apr 18, 2016 at 3:11 PM, Ozan DENİZ <ozande...@outlook.com> wrote:
> > > Hi everyone,
> > >
> > > I am trying to implement savepoint mechanism for my Fli
Hi everyone,
We are trying to use elasticsearch (2.x) connector for Flink application.
However, we encounter a problem when we try to add mapping to elasticsearch
index.
The error message is below when we run the Flink application.
No support for request
could
you post the complete stack trace to figure out where the problem comes
from?
I've also pulled in Aljoscha, the original author of the elasticsearch
sink. Maybe he can give you a detailed answer.
Cheers,
Till
On Fri, Sep 23, 2016 at 1:41 PM, Ozan DENİZ <ozande...@outlook.com>
s a request that can only be sent using
IndicesAdminClient. In my understanding this is an administrative command
that isn't related to actually storing data in an index.
What are you trying to store with the PutMappingRequest?
Cheers,
Aljoscha
On Mon, 26 Sep 2016 at 15:16 Oz
Hi everyone,
We are currently using BucketingSink (Flink 1.2-SNAPSHOT) function for sink
operation. The BucketingSink function was working correctly. However today,
when I put the job on cluster I got this error;
java.lang.NoSuchMethodError:
+02:00 Ozan DENİZ <ozande...@outlook.com>:
> Hi everyone,
>
>
> We are currently using BucketingSink (Flink 1.2-SNAPSHOT) function for
> sink operation. The BucketingSink function was working correctly. However
> today, when I put the job on cluster I got this error;
>
11 matches
Mail list logo
