Created
May 11, 2019 04:40
-
-
Save kien-truong/33e2c15ccaef2be317c4ea5bfc88b413 to your computer and use it in GitHub Desktop.
Sample data for Prometheus graphite_exporter bug#90
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
flink.jm.test.Status.JVM.ClassLoader.ClassesUnloaded 0 1557548814 | |
flink.jm.test.Status.JVM.ClassLoader.ClassesLoaded 6831 1557548814 | |
flink.jm.test.Status.JVM.Memory.Direct.Count 18 1557548814 | |
flink.jm.test.Status.JVM.GarbageCollector.PS-Scavenge.Time 15 1557548814 | |
flink.jm.test.Status.JVM.GarbageCollector.PS-MarkSweep.Count 2 1557548814 | |
flink.jm.test.Status.JVM.GarbageCollector.PS-MarkSweep.Time 46 1557548814 | |
flink.jm.test.Status.JVM.GarbageCollector.PS-Scavenge.Count 2 1557548814 | |
flink.jm.test.Status.JVM.CPU.Load 0.00 1557548814 | |
flink.jm.test.Status.JVM.Memory.Direct.MemoryUsed 573419 1557548814 | |
flink.jm.test.Status.JVM.Memory.Heap.Committed 1029177344 1557548814 | |
flink.jm.test.Status.JVM.Memory.Heap.Used 146591072 1557548814 | |
flink.jm.test.Status.JVM.Memory.NonHeap.Used 60664392 1557548814 | |
flink.jm.test.Status.JVM.Memory.NonHeap.Committed 64159744 1557548814 | |
flink.jm.test.Status.JVM.Memory.Mapped.TotalCapacity 0 1557548814 | |
flink.jm.test.taskSlotsTotal 1 1557548814 | |
flink.jmj.test.downtime 0 1557548814 | |
flink.jm.test.taskSlotsAvailable 0 1557548814 | |
flink.jmj.test.fullRestarts 0 1557548814 | |
flink.jmj.test.lastCheckpointAlignmentBuffered -1 1557548814 | |
flink.jm.test.Status.JVM.Memory.Mapped.MemoryUsed 0 1557548814 | |
flink.jmj.test.uptime 323458 1557548814 | |
flink.jmj.test.lastCheckpointDuration -1 1557548814 | |
flink.jm.test.Status.JVM.Memory.Heap.Max 1029177344 1557548814 | |
flink.jmj.test.lastCheckpointRestoreTimestamp -1 1557548814 | |
flink.jm.test.Status.JVM.Memory.Mapped.Count 0 1557548814 | |
flink.jmj.test.lastCheckpointSize -1 1557548814 | |
flink.jm.test.Status.JVM.Threads.Count 53 1557548814 | |
flink.jm.test.numRunningJobs 1 1557548814 | |
flink.jm.test.Status.JVM.Memory.NonHeap.Max -1 1557548814 | |
flink.jmj.test.numberOfCompletedCheckpoints 0 1557548814 | |
flink.jm.test.Status.JVM.CPU.Time 15010000000 1557548814 | |
flink.jmj.test.numberOfFailedCheckpoints 0 1557548814 | |
flink.jm.test.numRegisteredTaskManagers 1 1557548814 | |
flink.jmj.test.restartingTime 0 1557548814 | |
flink.jmj.test.totalNumberOfCheckpoints 0 1557548814 | |
flink.jmj.test.numberOfInProgressCheckpoints 0 1557548814 | |
flink.jm.test.Status.JVM.Memory.Direct.TotalCapacity 573418 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Sink:-Print-to-Std--Out.0.currentOutputWatermark -9223372036854775808 1557548814 | |
flink.op.test.Source:-Socket-Stream-->-Flat-Map.Flat-Map.0.currentInputWatermark -9223372036854775808 1557548814 | |
flink.op.test.Source:-Socket-Stream-->-Flat-Map.Flat-Map.0.currentOutputWatermark -9223372036854775808 1557548814 | |
flink.op.test.Source:-Socket-Stream-->-Flat-Map.Source:-Socket-Stream.0.currentOutputWatermark -9223372036854775808 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Sink:-Print-to-Std--Out.0.currentInputWatermark -9223372036854775808 1557548814 | |
flink.tm.test.7d18ca89844260f48f3d9d5a75d75d5a.Status.JVM.GarbageCollector.G1-Old-Generation.Time 19 1557548814 | |
flink.tm.test.7d18ca89844260f48f3d9d5a75d75d5a.Status.JVM.Memory.Direct.MemoryUsed 107942335 1557548814 | |
flink.tm.test.7d18ca89844260f48f3d9d5a75d75d5a.Status.JVM.GarbageCollector.G1-Young-Generation.Count 3 1557548814 | |
flink.tm.test.7d18ca89844260f48f3d9d5a75d75d5a.Status.JVM.GarbageCollector.G1-Young-Generation.Time 27 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunctio.0.currentInputWatermark -9223372036854775808 1557548814 | |
flink.tm.test.7d18ca89844260f48f3d9d5a75d75d5a.Status.JVM.CPU.Load 0.00 1557548814 | |
flink.tm.test.7d18ca89844260f48f3d9d5a75d75d5a.Status.JVM.GarbageCollector.G1-Old-Generation.Count 1 1557548814 | |
flink.tm.test.7d18ca89844260f48f3d9d5a75d75d5a.Status.JVM.Memory.Heap.Committed 966787072 1557548814 | |
flink.tm.test.7d18ca89844260f48f3d9d5a75d75d5a.Status.JVM.Memory.Direct.Count 3291 1557548814 | |
flink.tm.test.7d18ca89844260f48f3d9d5a75d75d5a.Status.JVM.ClassLoader.ClassesUnloaded 0 1557548814 | |
flink.tm.test.7d18ca89844260f48f3d9d5a75d75d5a.Status.JVM.Memory.Mapped.Count 0 1557548814 | |
flink.tm.test.7d18ca89844260f48f3d9d5a75d75d5a.Status.JVM.Memory.Mapped.TotalCapacity 0 1557548814 | |
flink.tm.test.7d18ca89844260f48f3d9d5a75d75d5a.Status.JVM.Memory.NonHeap.Max -1 1557548814 | |
flink.tm.test.7d18ca89844260f48f3d9d5a75d75d5a.Status.JVM.Threads.Count 37 1557548814 | |
flink.tm.test.7d18ca89844260f48f3d9d5a75d75d5a.Status.Network.TotalMemorySegments 3278 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.buffers.inputQueueLength 0 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.buffers.outputQueueLength 0 1557548814 | |
flink.op.test.Source:-Socket-Stream-->-Flat-Map.Source:-Socket-Stream.0.numRecordsOut.count 0 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Sink:-Print-to-Std--Out.0.numRecordsOut.count 0 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunctio.0.numRecordsIn.count 0 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBuffersInLocal.count 0 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBuffersOut.count 0 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBytesInRemote.count 0 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numRecordsOut.count 0 1557548814 | |
flink.tm.test.7d18ca89844260f48f3d9d5a75d75d5a.Status.JVM.Memory.Heap.Max 966787072 1557548814 | |
flink.op.test.Source:-Socket-Stream-->-Flat-Map.Flat-Map.0.numRecordsInPerSecond.count 0 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBytesOut.count 0 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numRecordsIn.count 0 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Sink:-Print-to-Std--Out.0.numRecordsInPerSecond.m15_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBuffersOutPerSecond.count 0 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBuffersInRemotePerSecond.mean_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBytesInLocalPerSecond.count 0 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBuffersInRemotePerSecond.m5_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBuffersInRemotePerSecond.m15_rate 0.00 1557548814 | |
flink.op.test.Source:-Socket-Stream-->-Flat-Map.Source:-Socket-Stream.0.numRecordsOutPerSecond.mean_rate 0.00 1557548814 | |
flink.tm.test.7d18ca89844260f48f3d9d5a75d75d5a.Status.JVM.Memory.Direct.TotalCapacity 107942334 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBuffersOut.count 0 1557548814 | |
flink.op.test.Source:-Socket-Stream-->-Flat-Map.Source:-Socket-Stream.0.numRecordsOutPerSecond.m5_rate 0.00 1557548814 | |
flink.op.test.Source:-Socket-Stream-->-Flat-Map.Flat-Map.0.numRecordsInPerSecond.m1_rate 0.00 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Sink:-Print-to-Std--Out.0.numRecordsInPerSecond.mean_rate 0.00 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Sink:-Print-to-Std--Out.0.numRecordsOutPerSecond.count 0 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBytesInLocal.count 0 1557548814 | |
flink.tm.test.7d18ca89844260f48f3d9d5a75d75d5a.Status.JVM.ClassLoader.ClassesLoaded 5740 1557548814 | |
flink.tm.test.7d18ca89844260f48f3d9d5a75d75d5a.Status.JVM.CPU.Time 12530000000 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numRecordsIn.count 0 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Sink:-Print-to-Std--Out.0.numRecordsOutPerSecond.m1_rate 0.00 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunctio.0.currentOutputWatermark -9223372036854775808 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Sink:-Print-to-Std--Out.0.numRecordsOutPerSecond.m5_rate 0.00 1557548814 | |
flink.tm.test.7d18ca89844260f48f3d9d5a75d75d5a.Status.JVM.Memory.Heap.Used 68578360 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Sink:-Print-to-Std--Out.0.numRecordsOutPerSecond.mean_rate 0.00 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunctio.0.numRecordsInPerSecond.count 0 1557548814 | |
flink.op.test.Source:-Socket-Stream-->-Flat-Map.Flat-Map.0.numRecordsInPerSecond.mean_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBuffersInLocal.count 0 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunctio.0.numRecordsInPerSecond.m1_rate 0.00 1557548814 | |
flink.tm.test.7d18ca89844260f48f3d9d5a75d75d5a.Status.JVM.Memory.Mapped.MemoryUsed 0 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunctio.0.numRecordsInPerSecond.m15_rate 0.00 1557548814 | |
flink.op.test.Source:-Socket-Stream-->-Flat-Map.Flat-Map.0.numRecordsOutPerSecond.count 0 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunctio.0.numRecordsInPerSecond.mean_rate 0.00 1557548814 | |
flink.tm.test.7d18ca89844260f48f3d9d5a75d75d5a.Status.JVM.Memory.NonHeap.Committed 51707904 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunctio.0.numRecordsOutPerSecond.count 0 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunctio.0.numRecordsOutPerSecond.m1_rate 0.00 1557548814 | |
flink.tm.test.7d18ca89844260f48f3d9d5a75d75d5a.Status.JVM.Memory.NonHeap.Used 49029368 1557548814 | |
flink.op.test.Source:-Socket-Stream-->-Flat-Map.Flat-Map.0.numRecordsInPerSecond.m5_rate 0.00 1557548814 | |
flink.tm.test.7d18ca89844260f48f3d9d5a75d75d5a.Status.Network.AvailableMemorySegments 3278 1557548814 | |
flink.op.test.Source:-Socket-Stream-->-Flat-Map.Flat-Map.0.numRecordsOutPerSecond.m5_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBytesOut.count 0 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunctio.0.numRecordsOutPerSecond.m5_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.buffers.inPoolUsage 0.00 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunctio.0.numRecordsOutPerSecond.m15_rate 0.00 1557548814 | |
flink.op.test.Source:-Socket-Stream-->-Flat-Map.Flat-Map.0.numRecordsOutPerSecond.mean_rate 0.00 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunctio.0.numRecordsOutPerSecond.mean_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.buffers.outPoolUsage 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBuffersInRemotePerSecond.m1_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.buffers.outputQueueLength 0 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBuffersInLocalPerSecond.m5_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBuffersInLocalPerSecond.m15_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.buffers.inPoolUsage 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBuffersInLocalPerSecond.count 0 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBuffersInLocalPerSecond.mean_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBuffersInRemotePerSecond.count 0 1557548814 | |
flink.op.test.Source:-Socket-Stream-->-Flat-Map.Source:-Socket-Stream.0.numRecordsInPerSecond.m1_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.buffers.inputQueueLength 0 1557548814 | |
flink.op.test.Source:-Socket-Stream-->-Flat-Map.Source:-Socket-Stream.0.numRecordsInPerSecond.m5_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numRecordsOut.count 0 1557548814 | |
flink.op.test.Source:-Socket-Stream-->-Flat-Map.Flat-Map.0.numRecordsOutPerSecond.m15_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.checkpointAlignmentTime 0 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.currentInputWatermark -9223372036854775808 1557548814 | |
flink.op.test.Source:-Socket-Stream-->-Flat-Map.Source:-Socket-Stream.0.numRecordsInPerSecond.mean_rate 0.00 1557548814 | |
flink.op.test.Source:-Socket-Stream-->-Flat-Map.Flat-Map.0.numRecordsIn.count 0 1557548814 | |
flink.op.test.Source:-Socket-Stream-->-Flat-Map.Flat-Map.0.numRecordsOut.count 0 1557548814 | |
flink.op.test.Source:-Socket-Stream-->-Flat-Map.Source:-Socket-Stream.0.numRecordsIn.count 0 1557548814 | |
flink.op.test.Source:-Socket-Stream-->-Flat-Map.Source:-Socket-Stream.0.numRecordsOutPerSecond.count 0 1557548814 | |
flink.op.test.Source:-Socket-Stream-->-Flat-Map.Source:-Socket-Stream.0.numRecordsOutPerSecond.m1_rate 0.00 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Sink:-Print-to-Std--Out.0.numRecordsIn.count 0 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunctio.0.numLateRecordsDropped.count 0 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunctio.0.numRecordsOut.count 0 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBuffersInRemote.count 0 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBytesInLocal.count 0 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBytesInRemote.count 0 1557548814 | |
flink.op.test.Source:-Socket-Stream-->-Flat-Map.Flat-Map.0.numRecordsInPerSecond.m15_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numRecordsOutPerSecond.mean_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBuffersInLocalPerSecond.m1_rate 0.00 1557548814 | |
flink.op.test.Source:-Socket-Stream-->-Flat-Map.Source:-Socket-Stream.0.numRecordsOutPerSecond.m15_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBuffersInLocalPerSecond.count 0 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBuffersInRemotePerSecond.m15_rate 0.00 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Sink:-Print-to-Std--Out.0.numRecordsInPerSecond.count 0 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBuffersInLocalPerSecond.m5_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBytesInLocalPerSecond.m1_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBytesOutPerSecond.m15_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numRecordsOutPerSecond.mean_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBytesOutPerSecond.m5_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBuffersOutPerSecond.mean_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBytesOutPerSecond.mean_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numRecordsOutPerSecond.m1_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numRecordsOutPerSecond.m5_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numRecordsOutPerSecond.count 0 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBytesInLocalPerSecond.mean_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numRecordsInPerSecond.m1_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBytesInRemotePerSecond.count 0 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numRecordsInPerSecond.m5_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBytesInRemotePerSecond.m1_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numRecordsInPerSecond.m15_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBytesInRemotePerSecond.m5_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numRecordsInPerSecond.mean_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBytesInRemotePerSecond.m15_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numRecordsOutPerSecond.count 0 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBytesInRemotePerSecond.mean_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numRecordsOutPerSecond.m1_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBytesOutPerSecond.count 0 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numRecordsOutPerSecond.m15_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numRecordsOutPerSecond.m5_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBytesOutPerSecond.m1_rate 0.00 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Sink:-Print-to-Std--Out.0.numRecordsInPerSecond.m5_rate 0.00 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Sink:-Print-to-Std--Out.0.numRecordsInPerSecond.m1_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.buffers.outPoolUsage 0.00 1557548814 | |
flink.op.test.Source:-Socket-Stream-->-Flat-Map.Flat-Map.0.numRecordsOutPerSecond.m1_rate 0.00 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunctio.0.numRecordsInPerSecond.m5_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBuffersOutPerSecond.m1_rate 0.00 1557548814 | |
flink.op.test.Source:-Socket-Stream-->-Flat-Map.Source:-Socket-Stream.0.numRecordsInPerSecond.m15_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBuffersOutPerSecond.m5_rate 0.00 1557548814 | |
flink.op.test.Source:-Socket-Stream-->-Flat-Map.Source:-Socket-Stream.0.numRecordsInPerSecond.count 0 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBuffersOutPerSecond.m15_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBuffersOutPerSecond.mean_rate 0.00 1557548814 | |
flink.op.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.Sink:-Print-to-Std--Out.0.numRecordsOutPerSecond.m15_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBuffersInRemote.count 0 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBuffersInLocalPerSecond.m1_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBuffersInRemotePerSecond.mean_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBuffersOutPerSecond.count 0 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBuffersOutPerSecond.m1_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBuffersOutPerSecond.m5_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBuffersOutPerSecond.m15_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numRecordsInPerSecond.count 0 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBytesInLocalPerSecond.count 0 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBytesInLocalPerSecond.m1_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBytesInLocalPerSecond.m5_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBytesInLocalPerSecond.m15_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBytesInLocalPerSecond.mean_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBytesInRemotePerSecond.count 0 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBytesInRemotePerSecond.m1_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBytesInRemotePerSecond.m5_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBytesInRemotePerSecond.m15_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBytesInRemotePerSecond.mean_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBytesOutPerSecond.count 0 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBytesOutPerSecond.m1_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBytesOutPerSecond.m5_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBytesOutPerSecond.m15_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBytesOutPerSecond.mean_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numRecordsInPerSecond.count 0 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numRecordsInPerSecond.m1_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numRecordsInPerSecond.m5_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numRecordsInPerSecond.m15_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numRecordsInPerSecond.mean_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBytesInLocalPerSecond.m5_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numRecordsOutPerSecond.m15_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBuffersInRemotePerSecond.count 0 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBuffersInLocalPerSecond.m15_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBuffersInLocalPerSecond.mean_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBuffersInRemotePerSecond.m1_rate 0.00 1557548814 | |
flink.tsk.test.Window(TumblingProcessingTimeWindows(5000),-ProcessingTimeTrigger,-ReduceFunction$1,-PassThroughWindowFunction)-->-Sink:-Print-to-Std--Out.0.numBuffersInRemotePerSecond.m5_rate 0.00 1557548814 | |
flink.tsk.test.Source:-Socket-Stream-->-Flat-Map.0.numBytesInLocalPerSecond.m15_rate 0.00 1557548814 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
defaults: | |
glob_disable_ordering: true | |
mappings: | |
- match: flink.jmj.*.* | |
name: flink_${2} | |
labels: | |
job: $1 | |
- match: flink.jm.*.*.*.*.*.* | |
name: flink_${2}_${3}_${4}_${5}_${6} | |
labels: | |
job: $1 | |
- match: flink.jm.*.*.*.*.* | |
name: flink_${2}_${3}_${4}_${5} | |
labels: | |
job: $1 | |
- match: flink.jm.*.*.*.* | |
name: flink_${2}_${3}_${4} | |
labels: | |
job: $1 | |
- match: flink.tm.*.*.*.*.*.*.* | |
name: flink_${3}_${4}_${5}_${6}_${7} | |
labels: | |
job: $1 | |
tm: $2 | |
- match: flink.tm.*.*.*.*.*.* | |
name: flink_${3}_${4}_${5}_${6} | |
labels: | |
job: $1 | |
tm: $2 | |
- match: flink.tm.*.*.*.*.* | |
name: flink_${3}_${4}_${5} | |
labels: | |
job: $1 | |
tm: $2 | |
- match: flink.op.*.*.*.*.KafkaConsumer.* | |
name: flink_kafka_consumer_${5} | |
labels: | |
job: $1 | |
operator: $3 | |
subtask: $4 | |
task: $2 | |
- match: flink.op.*.*.*.*.KafkaProducer.* | |
name: flink_kafka_producer_${5} | |
labels: | |
job: $1 | |
operator: $3 | |
subtask: $4 | |
task: $2 | |
- match: flink.op.*.*.*.*.* | |
name: flink_${5} | |
labels: | |
job: $1 | |
operator: $3 | |
subtask: $4 | |
task: $2 | |
- match: flink.op.*.*.*.*.*.* | |
name: flink_${5}_${6} | |
labels: | |
job: $1 | |
operator: $3 | |
subtask: $4 | |
task: $2 | |
- match: flink.tsk.*.*.*.* | |
name: flink_${4} | |
labels: | |
job: $1 | |
subtask: $3 | |
task: $2 | |
- match: flink.tsk.*.*.*.*.* | |
name: flink_${4}_${5} | |
labels: | |
job: $1 | |
subtask: $3 | |
task: $2 |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment