Hello,
I am trying to measure the total time my flink app takes.
I've read it can be done with this:
val r = env.execute("NAME")
System.out.println("The job took " + r.getNetRuntime(TimeUnit.SECONDS) +
" s to execute")
The thing is, it works for some task, where all computations occur in
the sa
a:368)
[info] at org.apache.flink.runtime.taskmanager.Task.run(Task.java:711)
[info] at java.lang.Thread.run(Thread.java:748)
It seems the problem is not with the code above, but it is caused by it,
since cuts is empty.
*-- Alejandro Alcalde - elbauldelprogramador.com
<http://elbauldelpro
by: java.lang.IndexOutOfBoundsException: Index: 0, Size: 0
Best
*-- Alejandro Alcalde - elbauldelprogramador.com
<http://elbauldelprogramador.com>*
Then how I am suppose to implement that function?
On 09/14/2018 05:29 PM, æšć wrote:
> A java.util.Iterable is expected to provide iterators again and again.
>
> On Fri, Sep 14, 2018 at 10:53 PM Alejandro Alcalde
> wrote:
>
>> Hello all,
>>
>> I am trying
ouble, Double)],
out: Collector[(Double, Double)]): Unit = {
???
}
}
Where am I transversing `in` a second time? may be is the call to `asScala`?
Bests
*-- Alejandro Alcalde - elbauldelprogramador.com
<http://elbauldelprogramador.com>*
In this answer Optimizing Flink transformation
(https://stackoverflow.com/questions/52151715/optimizing-flink-transformation/52225586#52225586):
def symmetricalUncertainty(xy: DataSet[(Double, Double)]): Double = {
val su = xy.reduceGroup { in â
val invec = in.toVector
val x = invec map (_
