Skip to content

Instantly share code, notes, and snippets.

@kien-truong
Created May 11, 2019 04:40
Show Gist options
  • Save kien-truong/33e2c15ccaef2be317c4ea5bfc88b413 to your computer and use it in GitHub Desktop.
Save kien-truong/33e2c15ccaef2be317c4ea5bfc88b413 to your computer and use it in GitHub Desktop.
Sample data for Prometheus graphite_exporter bug#90
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
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