Hello flink community,
I am trying to understand the latency involved in cross operation. Below are
my tests.
In plain Java:
1. Create 2D array 1 - populated with 1 million rows and 3 columns with
randomly generated double values
2. Create 2D array 1 - populated with 100 rows and 3 columns with
checkpoints would be very helpful.
Thanks in advance for your assistance.
Regards,
Varun
> On Jan 18, 2018, at 8:11 AM, Kostas Kloudas
> wrote:
>
> Thanks a lot Varun!
>
> Kostas
>
>> On Jan 17, 2018, at 9:59 PM, Varun Dhore wrote:
>>
>> Thank you
be related to this issue:
> https://issues.apache.org/jira/browse/FLINK-8226
> which is currently fixed on the master.
>
> Could you please try the current master to see if the error persists?
>
> Thanks,
> Kostas
>
>>> On Jan 15, 2018, at 4:09 PM, Varun Dho
> Hello Flink community,
>
> I have encountered following exception while testing 1.4.0 release. This
> error is occurring intermittently and my CEP job keeps restarting after this
> exception. I am running the job with Event time semantics and checkpoints
> enabled.
>
>
> ja
