HI,
I am trying to group messages by message name, timestamp and then perform
aggregation on message value. My window function looks like below
metrics.keyBy("metricName")
.keyBy("timeStamp")
.timeWindow(Time.seconds(30))
.trigger(ProcessingTimeTrigger.create())
.fold(new Tuple3(
Thanks Max for a quick response. I will try it out and let you know how it goes.
-Naveen
> On Nov 25, 2016, at 6:05 AM, Maximilian Michels wrote:
>
> Fix is now in the master and everything should run smooth with MapR
> Hadoop. I'd be happy if you gave it another try.
>
> -Max
>
>
> On Thu, No
Hi,
I am trying to setup flink with yarn on MapR. I built flink using the following
command and build finished successfully.
mvn clean install -DskipTests -Pvendor-repos -Dhadoop.version=2.7.0-mapr-1607
-Dhadoop.vendor=MapR
Now when I try to start yarn session I am seeing the below error
2016
