diff --git a/demo/docker/grafana/dashboards/nussknacker-scenario.json b/demo/docker/grafana/dashboards/nussknacker-scenario.json index c4d113324b7..9fc773fd389 100644 --- a/demo/docker/grafana/dashboards/nussknacker-scenario.json +++ b/demo/docker/grafana/dashboards/nussknacker-scenario.json @@ -16,11 +16,11 @@ "gnetId": null, "graphTooltip": 1, "id": 1, - "iteration": 1624363989790, + "iteration": 1624598641305, "links": [], "panels": [ { - "collapsed": true, + "collapsed": false, "datasource": null, "gridPos": { "h": 1, @@ -29,1317 +29,1376 @@ "y": 0 }, "id": 26, - "panels": [ + "panels": [], + "title": "Basics", + "type": "row" + }, + { + "aliasColors": {}, + "bars": false, + "dashLength": 10, + "dashes": false, + "datasource": "influx", + "editable": true, + "error": false, + "fill": 1, + "fillGradient": 0, + "grid": {}, + "gridPos": { + "h": 7, + "w": 24, + "x": 0, + "y": 1 + }, + "hiddenSeries": false, + "id": 2, + "interval": "$interval", + "legend": { + "avg": false, + "current": false, + "max": false, + "min": false, + "show": true, + "total": false, + "values": false + }, + "lines": true, + "linewidth": 2, + "links": [], + "nullPointMode": "null", + "options": { + "dataLinks": [] + }, + "percentage": false, + "pointradius": 5, + "points": false, + "renderer": "flot", + "seriesOverrides": [], + "spaceLength": 10, + "stack": false, + "steppedLine": false, + "targets": [ { - "aliasColors": {}, - "bars": false, - "dashLength": 10, - "dashes": false, - "datasource": "influx", - "editable": true, - "error": false, - "fill": 1, - "fillGradient": 0, - "grid": {}, - "gridPos": { - "h": 7, - "w": 24, - "x": 0, - "y": 1 - }, - "hiddenSeries": false, - "id": 2, - "interval": "$interval", - "legend": { - "avg": false, - "current": false, - "max": false, - "min": false, - "show": true, - "total": false, - "values": false - }, - "lines": true, - "linewidth": 2, - "links": [], - "nullPointMode": "null", - "options": { - "dataLinks": [] - }, - "percentage": false, - "pointradius": 5, - "points": false, - "renderer": "flot", - "seriesOverrides": [], - "spaceLength": 10, - "stack": false, - "steppedLine": false, - "targets": [ + "alias": "[[tag_process]]", + "dsType": "influxdb", + "groupBy": [ { - "alias": "[[tag_process]]", - "dsType": "influxdb", - "groupBy": [ - { - "params": [ - "$interval" - ], - "type": "time" - }, - { - "params": [ - "process" - ], - "type": "tag" - }, - { - "params": [ - "null" - ], - "type": "fill" - } + "params": [ + "$interval" ], - "measurement": "source.instantRate", - "orderByTime": "ASC", - "policy": "default", - "query": "SELECT sum(value)\nFROM (\n SELECT non_negative_derivative(last(\"count\"), 1s) AS value\n FROM \"source_count\"\n WHERE process =~ /^$processName$/ AND env = '$env' AND $timeFilter\n GROUP BY time($__interval), process, slot\n)\nGROUP BY time($__interval), process\n", - "rawQuery": true, - "refId": "A", - "resultFormat": "time_series", - "select": [ - [ - { - "params": [ - "value" - ], - "type": "field" - }, - { - "params": [], - "type": "mean" - } - ] + "type": "time" + }, + { + "params": [ + "process" ], - "tags": [ - { - "key": "process", - "operator": "=~", - "value": "/$processName$/" - }, - { - "condition": "AND", - "key": "env", - "operator": "=~", - "value": "/$env$/" - } - ] + "type": "tag" + }, + { + "params": [ + "null" + ], + "type": "fill" } ], - "thresholds": [], - "timeFrom": null, - "timeRegions": [], - "timeShift": null, - "title": "Source throughput", - "tooltip": { - "msResolution": false, - "shared": true, - "sort": 0, - "value_type": "cumulative" - }, - "type": "graph", - "xaxis": { - "buckets": null, - "mode": "time", - "name": null, - "show": true, - "values": [] - }, - "yaxes": [ + "measurement": "source.instantRate", + "orderByTime": "ASC", + "policy": "default", + "query": "SELECT sum(value)\nFROM (\n SELECT non_negative_derivative(last(\"count\"), 1s) AS value\n FROM \"source_count\"\n WHERE process =~ /^$processName$/ AND env = '$env' AND $timeFilter\n GROUP BY time($__interval), process, slot\n)\nGROUP BY time($__interval), process\n", + "rawQuery": true, + "refId": "A", + "resultFormat": "time_series", + "select": [ + [ + { + "params": [ + "value" + ], + "type": "field" + }, + { + "params": [], + "type": "mean" + } + ] + ], + "tags": [ { - "format": "rps", - "logBase": 1, - "max": null, - "min": "0", - "show": true + "key": "process", + "operator": "=~", + "value": "/$processName$/" }, { - "format": "short", - "logBase": 1, - "max": null, - "min": null, - "show": true + "condition": "AND", + "key": "env", + "operator": "=~", + "value": "/$env$/" } - ], - "yaxis": { - "align": false, - "alignLevel": null - } + ] + } + ], + "thresholds": [], + "timeFrom": null, + "timeRegions": [], + "timeShift": null, + "title": "Source throughput", + "tooltip": { + "msResolution": false, + "shared": true, + "sort": 0, + "value_type": "cumulative" + }, + "type": "graph", + "xaxis": { + "buckets": null, + "mode": "time", + "name": null, + "show": true, + "values": [] + }, + "yaxes": [ + { + "format": "rps", + "logBase": 1, + "max": null, + "min": "0", + "show": true }, { - "aliasColors": {}, - "bars": false, - "dashLength": 10, - "dashes": false, - "datasource": "influx", - "editable": true, - "error": false, - "fill": 1, - "fillGradient": 0, - "grid": {}, - "gridPos": { - "h": 7, - "w": 12, - "x": 0, - "y": 8 - }, - "hiddenSeries": false, - "id": 3, - "interval": "$interval", - "legend": { - "avg": false, - "current": false, - "hideEmpty": true, - "hideZero": true, - "max": false, - "min": false, - "show": true, - "total": false, - "values": false - }, - "lines": true, - "linewidth": 2, - "links": [], - "nullPointMode": "null", - "options": { - "dataLinks": [] - }, - "percentage": false, - "pointradius": 5, - "points": false, - "renderer": "flot", - "seriesOverrides": [], - "spaceLength": 10, - "stack": false, - "steppedLine": false, - "targets": [ + "format": "short", + "logBase": 1, + "max": null, + "min": null, + "show": true + } + ], + "yaxis": { + "align": false, + "alignLevel": null + } + }, + { + "aliasColors": {}, + "bars": false, + "dashLength": 10, + "dashes": false, + "datasource": "influx", + "editable": true, + "error": false, + "fill": 1, + "fillGradient": 0, + "grid": {}, + "gridPos": { + "h": 7, + "w": 12, + "x": 0, + "y": 8 + }, + "hiddenSeries": false, + "id": 3, + "interval": "$interval", + "legend": { + "avg": false, + "current": false, + "hideEmpty": true, + "hideZero": true, + "max": false, + "min": false, + "show": true, + "total": false, + "values": false + }, + "lines": true, + "linewidth": 2, + "links": [], + "nullPointMode": "null", + "options": { + "dataLinks": [] + }, + "percentage": false, + "pointradius": 5, + "points": false, + "renderer": "flot", + "seriesOverrides": [], + "spaceLength": 10, + "stack": false, + "steppedLine": false, + "targets": [ + { + "alias": "[[tag_process]] - [[tag_nodeId]]", + "dsType": "influxdb", + "groupBy": [ { - "alias": "[[tag_process]] - [[tag_nodeId]]", - "dsType": "influxdb", - "groupBy": [ - { - "params": [ - "$interval" - ], - "type": "time" - }, - { - "params": [ - "process" - ], - "type": "tag" - }, - { - "params": [ - "nodeId" - ], - "type": "tag" - }, - { - "params": [ - "null" - ], - "type": "fill" - } + "params": [ + "$interval" ], - "hide": false, - "measurement": "end.instantRate", - "orderByTime": "ASC", - "policy": "default", - "query": "SELECT sum(value)\nFROM (\n SELECT non_negative_derivative(last(\"count\"), 1s) AS value\n FROM \"end_count\"\n WHERE process =~ /^$processName$/ AND env = '$env' AND $timeFilter\n GROUP BY time($__interval), process, nodeId, slot\n)\nGROUP BY time($__interval), process, nodeId\n", - "rawQuery": true, - "refId": "A", - "resultFormat": "time_series", - "select": [ - [ - { - "params": [ - "value" - ], - "type": "field" - }, - { - "params": [], - "type": "mean" - } - ] + "type": "time" + }, + { + "params": [ + "process" ], - "tags": [ - { - "key": "process", - "operator": "=~", - "value": "/$processName$/" - }, - { - "condition": "AND", - "key": "env", - "operator": "=~", - "value": "/^$env$/" - } - ] + "type": "tag" + }, + { + "params": [ + "nodeId" + ], + "type": "tag" + }, + { + "params": [ + "null" + ], + "type": "fill" } ], - "thresholds": [], - "timeFrom": null, - "timeRegions": [], - "timeShift": null, - "title": "Events that passed whole process /s", - "tooltip": { - "msResolution": false, - "shared": true, - "sort": 0, - "value_type": "cumulative" - }, - "type": "graph", - "xaxis": { - "buckets": null, - "mode": "time", - "name": null, - "show": true, - "values": [] - }, - "yaxes": [ + "hide": false, + "measurement": "end.instantRate", + "orderByTime": "ASC", + "policy": "default", + "query": "SELECT sum(value)\nFROM (\n SELECT non_negative_derivative(last(\"count\"), 1s) AS value\n FROM \"end_count\"\n WHERE process =~ /^$processName$/ AND env = '$env' AND $timeFilter\n GROUP BY time($__interval), process, nodeId, slot\n)\nGROUP BY time($__interval), process, nodeId\n", + "rawQuery": true, + "refId": "A", + "resultFormat": "time_series", + "select": [ + [ + { + "params": [ + "value" + ], + "type": "field" + }, + { + "params": [], + "type": "mean" + } + ] + ], + "tags": [ { - "format": "short", - "logBase": 1, - "max": null, - "min": "0", - "show": true + "key": "process", + "operator": "=~", + "value": "/$processName$/" }, { - "format": "short", - "logBase": 1, - "max": null, - "min": null, - "show": true + "condition": "AND", + "key": "env", + "operator": "=~", + "value": "/^$env$/" } - ], - "yaxis": { - "align": false, - "alignLevel": null - } + ] + } + ], + "thresholds": [], + "timeFrom": null, + "timeRegions": [], + "timeShift": null, + "title": "Events that passed whole process /s", + "tooltip": { + "msResolution": false, + "shared": true, + "sort": 0, + "value_type": "cumulative" + }, + "type": "graph", + "xaxis": { + "buckets": null, + "mode": "time", + "name": null, + "show": true, + "values": [] + }, + "yaxes": [ + { + "format": "short", + "logBase": 1, + "max": null, + "min": "0", + "show": true }, { - "aliasColors": {}, - "bars": false, - "dashLength": 10, - "dashes": false, - "datasource": "influx", - "editable": true, - "error": false, - "fill": 1, - "fillGradient": 0, - "grid": {}, - "gridPos": { - "h": 7, - "w": 12, - "x": 12, - "y": 8 - }, - "hiddenSeries": false, - "id": 5, - "interval": "$interval", - "legend": { - "avg": false, - "current": false, - "hideEmpty": true, - "hideZero": true, - "max": false, - "min": false, - "show": true, - "total": false, - "values": false - }, - "lines": true, - "linewidth": 2, - "links": [], - "nullPointMode": "null", - "options": { - "dataLinks": [] - }, - "percentage": false, - "pointradius": 5, - "points": false, - "renderer": "flot", - "seriesOverrides": [], - "spaceLength": 10, - "stack": false, - "steppedLine": false, - "targets": [ + "format": "short", + "logBase": 1, + "max": null, + "min": null, + "show": true + } + ], + "yaxis": { + "align": false, + "alignLevel": null + } + }, + { + "aliasColors": {}, + "bars": false, + "dashLength": 10, + "dashes": false, + "datasource": "influx", + "editable": true, + "error": false, + "fill": 1, + "fillGradient": 0, + "grid": {}, + "gridPos": { + "h": 7, + "w": 12, + "x": 12, + "y": 8 + }, + "hiddenSeries": false, + "id": 5, + "interval": "$interval", + "legend": { + "avg": false, + "current": false, + "hideEmpty": true, + "hideZero": true, + "max": false, + "min": false, + "show": true, + "total": false, + "values": false + }, + "lines": true, + "linewidth": 2, + "links": [], + "nullPointMode": "null", + "options": { + "dataLinks": [] + }, + "percentage": false, + "pointradius": 5, + "points": false, + "renderer": "flot", + "seriesOverrides": [], + "spaceLength": 10, + "stack": false, + "steppedLine": false, + "targets": [ + { + "alias": "[[tag_process]] - [[tag_nodeId]]", + "dsType": "influxdb", + "groupBy": [ { - "alias": "[[tag_process]] - [[tag_nodeId]]", - "dsType": "influxdb", - "groupBy": [ - { - "params": [ - "$interval" - ], - "type": "time" - }, - { - "params": [ - "process" - ], - "type": "tag" - }, - { - "params": [ - "nodeId" - ], - "type": "tag" - }, - { - "params": [ - "null" - ], - "type": "fill" - } + "params": [ + "$interval" ], - "hide": false, - "measurement": "dead_end.instantRate", - "orderByTime": "ASC", - "policy": "default", - "query": "SELECT sum(value)\nFROM (\n SELECT non_negative_derivative(last(\"count\"), 1s) AS value\n FROM \"dead_end_count\"\n WHERE process =~ /^$processName$/ AND env = '$env' AND $timeFilter\n GROUP BY time($__interval), process, nodeId, slot\n)\nGROUP BY time($__interval), process, nodeId\n", - "rawQuery": true, - "refId": "A", - "resultFormat": "time_series", - "select": [ - [ - { - "params": [ - "value" - ], - "type": "field" - }, - { - "params": [], - "type": "sum" - } - ] + "type": "time" + }, + { + "params": [ + "process" ], - "tags": [ - { - "key": "process", - "operator": "=~", - "value": "/$processName$/" - }, - { - "condition": "AND", - "key": "env", - "operator": "=~", - "value": "/^$env$/" - } - ] + "type": "tag" + }, + { + "params": [ + "nodeId" + ], + "type": "tag" + }, + { + "params": [ + "null" + ], + "type": "fill" } ], - "thresholds": [], - "timeFrom": null, - "timeRegions": [], - "timeShift": null, - "title": "Rejected events /s", - "tooltip": { - "msResolution": false, - "shared": true, - "sort": 0, - "value_type": "cumulative" - }, - "type": "graph", - "xaxis": { - "buckets": null, - "mode": "time", - "name": null, - "show": true, - "values": [] - }, - "yaxes": [ + "hide": false, + "measurement": "dead_end.instantRate", + "orderByTime": "ASC", + "policy": "default", + "query": "SELECT sum(value)\nFROM (\n SELECT non_negative_derivative(last(\"count\"), 1s) AS value\n FROM \"dead_end_count\"\n WHERE process =~ /^$processName$/ AND env = '$env' AND $timeFilter\n GROUP BY time($__interval), process, nodeId, slot\n)\nGROUP BY time($__interval), process, nodeId\n", + "rawQuery": true, + "refId": "A", + "resultFormat": "time_series", + "select": [ + [ + { + "params": [ + "value" + ], + "type": "field" + }, + { + "params": [], + "type": "sum" + } + ] + ], + "tags": [ { - "decimals": null, - "format": "short", - "logBase": 1, - "max": null, - "min": "0", - "show": true + "key": "process", + "operator": "=~", + "value": "/$processName$/" }, { - "format": "short", - "logBase": 1, - "max": null, - "min": null, - "show": true + "condition": "AND", + "key": "env", + "operator": "=~", + "value": "/^$env$/" } - ], - "yaxis": { - "align": false, - "alignLevel": null - } + ] + } + ], + "thresholds": [], + "timeFrom": null, + "timeRegions": [], + "timeShift": null, + "title": "Rejected events /s", + "tooltip": { + "msResolution": false, + "shared": true, + "sort": 0, + "value_type": "cumulative" + }, + "type": "graph", + "xaxis": { + "buckets": null, + "mode": "time", + "name": null, + "show": true, + "values": [] + }, + "yaxes": [ + { + "decimals": null, + "format": "short", + "logBase": 1, + "max": null, + "min": "0", + "show": true }, { - "aliasColors": {}, - "bars": false, - "dashLength": 10, - "dashes": false, - "datasource": "influx", - "editable": true, - "error": false, - "fill": 1, - "fillGradient": 0, - "grid": {}, - "gridPos": { - "h": 7, - "w": 12, - "x": 0, - "y": 15 - }, - "hiddenSeries": false, - "id": 4, - "interval": "$interval", - "legend": { - "avg": false, - "current": false, - "hideEmpty": true, - "hideZero": true, - "max": false, - "min": false, - "show": true, - "total": false, - "values": false - }, - "lines": true, - "linewidth": 2, - "links": [], - "nullPointMode": "null", - "options": { - "dataLinks": [] - }, - "percentage": false, - "pointradius": 5, - "points": false, - "renderer": "flot", - "seriesOverrides": [], - "spaceLength": 10, - "stack": false, - "steppedLine": false, - "targets": [ + "format": "short", + "logBase": 1, + "max": null, + "min": null, + "show": true + } + ], + "yaxis": { + "align": false, + "alignLevel": null + } + }, + { + "aliasColors": {}, + "bars": false, + "dashLength": 10, + "dashes": false, + "datasource": "influx", + "editable": true, + "error": false, + "fill": 1, + "fillGradient": 0, + "grid": {}, + "gridPos": { + "h": 7, + "w": 12, + "x": 0, + "y": 15 + }, + "hiddenSeries": false, + "id": 4, + "interval": "$interval", + "legend": { + "avg": false, + "current": false, + "hideEmpty": true, + "hideZero": true, + "max": false, + "min": false, + "show": true, + "total": false, + "values": false + }, + "lines": true, + "linewidth": 2, + "links": [], + "nullPointMode": "null", + "options": { + "dataLinks": [] + }, + "percentage": false, + "pointradius": 5, + "points": false, + "renderer": "flot", + "seriesOverrides": [], + "spaceLength": 10, + "stack": false, + "steppedLine": false, + "targets": [ + { + "alias": "[[tag_process]] - [[tag_nodeId]]", + "dsType": "influxdb", + "groupBy": [ { - "alias": "[[tag_process]] - [[tag_nodeId]]", - "dsType": "influxdb", - "groupBy": [ - { - "params": [ - "$interval" - ], - "type": "time" - }, - { - "params": [ - "process" - ], - "type": "tag" - }, - { - "params": [ - "null" - ], - "type": "fill" - } + "params": [ + "$interval" ], - "measurement": "error.instantRateByNode.count.count", - "orderByTime": "ASC", - "policy": "default", - "query": "SELECT sum(value)\nFROM (\n SELECT non_negative_derivative(last(\"count\"), 1s) AS value\n FROM \"error_instantRateByNode_count\"\n WHERE process =~ /^$processName$/ AND env = '$env' AND $timeFilter\n GROUP BY time($__interval), process, slot\n)\nGROUP BY time($__interval), process, nodeId\n", - "rawQuery": true, - "refId": "A", - "resultFormat": "time_series", - "select": [ - [ - { - "params": [ - "value" - ], - "type": "field" - }, - { - "params": [], - "type": "sum" - } - ] + "type": "time" + }, + { + "params": [ + "process" ], - "tags": [ - { - "key": "process", - "operator": "=~", - "value": "/$processName$/" - }, - { - "condition": "AND", - "key": "env", - "operator": "=~", - "value": "/^$env$/" - } - ] + "type": "tag" + }, + { + "params": [ + "null" + ], + "type": "fill" } ], - "thresholds": [], - "timeFrom": null, - "timeRegions": [], - "timeShift": null, - "title": "Errors", - "tooltip": { - "msResolution": false, - "shared": true, - "sort": 0, - "value_type": "cumulative" - }, - "type": "graph", - "xaxis": { - "buckets": null, - "mode": "time", - "name": null, - "show": true, - "values": [] - }, - "yaxes": [ + "measurement": "error.instantRateByNode.count.count", + "orderByTime": "ASC", + "policy": "default", + "query": "SELECT sum(value)\nFROM (\n SELECT non_negative_derivative(last(\"count\"), 1s) AS value\n FROM \"error_instantRateByNode_count\"\n WHERE process =~ /^$processName$/ AND env = '$env' AND $timeFilter\n GROUP BY time($__interval), process, slot\n)\nGROUP BY time($__interval), process, nodeId\n", + "rawQuery": true, + "refId": "A", + "resultFormat": "time_series", + "select": [ + [ + { + "params": [ + "value" + ], + "type": "field" + }, + { + "params": [], + "type": "sum" + } + ] + ], + "tags": [ { - "format": "rps", - "logBase": 1, - "max": null, - "min": "0", - "show": true + "key": "process", + "operator": "=~", + "value": "/$processName$/" }, { - "format": "short", - "logBase": 1, - "max": null, - "min": null, - "show": true + "condition": "AND", + "key": "env", + "operator": "=~", + "value": "/^$env$/" } - ], - "yaxis": { - "align": false, - "alignLevel": null - } + ] + } + ], + "thresholds": [], + "timeFrom": null, + "timeRegions": [], + "timeShift": null, + "title": "Errors", + "tooltip": { + "msResolution": false, + "shared": true, + "sort": 0, + "value_type": "cumulative" + }, + "type": "graph", + "xaxis": { + "buckets": null, + "mode": "time", + "name": null, + "show": true, + "values": [] + }, + "yaxes": [ + { + "format": "rps", + "logBase": 1, + "max": null, + "min": "0", + "show": true }, { - "aliasColors": {}, - "bars": false, - "dashLength": 10, - "dashes": false, - "datasource": "influx", - "description": "IMPORTANT. \nThis metric does NOT show the overall lag on Kafka source; a largest lag among all the source partitions is shown.", - "editable": true, - "error": false, - "fill": 1, - "fillGradient": 0, - "grid": {}, - "gridPos": { - "h": 7, - "w": 12, - "x": 12, - "y": 15 - }, - "hiddenSeries": false, - "id": 9, - "interval": "$interval", - "legend": { - "avg": false, - "current": false, - "max": false, - "min": false, - "show": true, - "total": false, - "values": false - }, - "lines": true, - "linewidth": 2, - "links": [], - "nullPointMode": "null", - "options": { - "dataLinks": [] - }, - "percentage": false, - "pointradius": 5, - "points": false, - "renderer": "flot", - "seriesOverrides": [], - "spaceLength": 10, - "stack": false, - "steppedLine": false, - "targets": [ + "format": "short", + "logBase": 1, + "max": null, + "min": null, + "show": true + } + ], + "yaxis": { + "align": false, + "alignLevel": null + } + }, + { + "aliasColors": {}, + "bars": false, + "dashLength": 10, + "dashes": false, + "datasource": "influx", + "description": "IMPORTANT. \nThis metric does NOT show the overall lag on Kafka source; a largest lag among all the source partitions is shown.", + "editable": true, + "error": false, + "fill": 1, + "fillGradient": 0, + "grid": {}, + "gridPos": { + "h": 7, + "w": 12, + "x": 12, + "y": 15 + }, + "hiddenSeries": false, + "id": 9, + "interval": "$interval", + "legend": { + "avg": false, + "current": false, + "max": false, + "min": false, + "show": true, + "total": false, + "values": false + }, + "lines": true, + "linewidth": 2, + "links": [], + "nullPointMode": "null", + "options": { + "dataLinks": [] + }, + "percentage": false, + "pointradius": 5, + "points": false, + "renderer": "flot", + "seriesOverrides": [], + "spaceLength": 10, + "stack": false, + "steppedLine": false, + "targets": [ + { + "alias": "[[tag_process]] [[tag_operator_name]] [[tag_slot]]", + "dsType": "influxdb", + "groupBy": [ { - "alias": "$tag_process", - "dsType": "influxdb", - "groupBy": [ - { - "params": [ - "$__interval" - ], - "type": "time" - }, - { - "params": [ - "process" - ], - "type": "tag" - } + "params": [ + "$__interval" ], - "measurement": "records-lag-max", - "orderByTime": "ASC", - "policy": "default", - "query": "SELECT max(\"value\") FROM \"records-lag-max\" WHERE \"host\" =~ /$hosts$/ AND \"process\" =~ /$processName$/ AND $timeFilter GROUP BY time($interval), \"process\" fill(none)", - "refId": "A", - "resultFormat": "time_series", - "select": [ - [ - { - "params": [ - "value" - ], - "type": "field" - }, - { - "params": [], - "type": "max" - } - ] + "type": "time" + }, + { + "params": [ + "process" ], - "tags": [ - { - "key": "env", - "operator": "=~", - "value": "/^$env$/" - }, - { - "condition": "AND", - "key": "process", - "operator": "=~", - "value": "/$processName$/" - } - ] + "type": "tag" + }, + { + "params": [ + "operator_name" + ], + "type": "tag" + }, + { + "params": [ + "slot" + ], + "type": "tag" } ], - "thresholds": [], - "timeFrom": null, - "timeRegions": [], - "timeShift": null, - "title": "Max lag among Kafka source partitions (events)", - "tooltip": { - "msResolution": false, - "shared": true, - "sort": 0, - "value_type": "individual" - }, - "type": "graph", - "xaxis": { - "buckets": null, - "mode": "time", - "name": null, - "show": true, - "values": [] - }, - "yaxes": [ + "measurement": "records-lag-max", + "orderByTime": "ASC", + "policy": "default", + "query": "SELECT max(\"value\") FROM \"records-lag-max\" WHERE \"host\" =~ /$hosts$/ AND \"process\" =~ /$processName$/ AND $timeFilter GROUP BY time($interval), \"process\" fill(none)", + "refId": "A", + "resultFormat": "time_series", + "select": [ + [ + { + "params": [ + "value" + ], + "type": "field" + }, + { + "params": [], + "type": "max" + } + ] + ], + "tags": [ { - "format": "short", - "logBase": 1, - "max": null, - "min": null, - "show": true + "key": "env", + "operator": "=~", + "value": "/^$env$/" }, { - "format": "short", - "logBase": 1, - "max": null, - "min": null, - "show": true + "condition": "AND", + "key": "process", + "operator": "=~", + "value": "/$processName$/" } - ], - "yaxis": { - "align": false, - "alignLevel": null - } + ] + } + ], + "thresholds": [], + "timeFrom": null, + "timeRegions": [], + "timeShift": null, + "title": "Max lag among Kafka source partitions (events)", + "tooltip": { + "msResolution": false, + "shared": true, + "sort": 0, + "value_type": "individual" + }, + "type": "graph", + "xaxis": { + "buckets": null, + "mode": "time", + "name": null, + "show": true, + "values": [] + }, + "yaxes": [ + { + "format": "short", + "logBase": 1, + "max": null, + "min": null, + "show": true }, { - "aliasColors": {}, - "bars": false, - "dashLength": 10, - "dashes": false, - "datasource": "influx", - "editable": true, - "error": false, - "fill": 1, - "fillGradient": 0, - "grid": {}, - "gridPos": { - "h": 7, - "w": 6, - "x": 0, - "y": 22 - }, - "hiddenSeries": false, - "id": 8, - "interval": "$interval", - "legend": { - "avg": false, - "current": false, - "max": false, - "min": false, - "show": true, - "total": false, - "values": false - }, - "lines": true, - "linewidth": 2, - "links": [], - "nullPointMode": "null", - "options": { - "dataLinks": [] - }, - "percentage": false, - "pointradius": 5, - "points": false, - "renderer": "flot", - "seriesOverrides": [], - "spaceLength": 10, - "stack": false, - "steppedLine": false, - "targets": [ + "format": "short", + "logBase": 1, + "max": null, + "min": null, + "show": true + } + ], + "yaxis": { + "align": false, + "alignLevel": null + } + }, + { + "aliasColors": {}, + "bars": false, + "dashLength": 10, + "dashes": false, + "datasource": "influx", + "editable": true, + "error": false, + "fill": 1, + "fillGradient": 0, + "grid": {}, + "gridPos": { + "h": 7, + "w": 6, + "x": 0, + "y": 22 + }, + "hiddenSeries": false, + "id": 8, + "interval": "$interval", + "legend": { + "avg": false, + "current": false, + "max": false, + "min": false, + "show": true, + "total": false, + "values": false + }, + "lines": true, + "linewidth": 2, + "links": [], + "nullPointMode": "null", + "options": { + "dataLinks": [] + }, + "percentage": false, + "pointradius": 5, + "points": false, + "renderer": "flot", + "seriesOverrides": [], + "spaceLength": 10, + "stack": false, + "steppedLine": false, + "targets": [ + { + "alias": "[[tag_process]] [[tag_nodeId]] [[tag_slot]]", + "dsType": "influxdb", + "groupBy": [ { - "alias": "[[tag_process]]", - "dsType": "influxdb", - "groupBy": [ - { - "params": [ - "$__interval" - ], - "type": "time" - }, - { - "params": [ - "process" - ], - "type": "tag" - }, - { - "params": [ - "null" - ], - "type": "fill" - } + "params": [ + "$__interval" ], - "measurement": "eventtimedelay_histogram", - "orderByTime": "ASC", - "policy": "default", - "query": "SELECT min(\"min\") FROM \"eventtimedelay_histogram\" WHERE \"host\" =~ /$hosts$/ AND \"process\" =~ /$processName$/ AND $timeFilter GROUP BY time($interval), \"process\" fill(null)", - "refId": "A", - "resultFormat": "time_series", - "select": [ - [ - { - "params": [ - "min" - ], - "type": "field" - }, - { - "params": [], - "type": "min" - } - ] + "type": "time" + }, + { + "params": [ + "process" ], - "tags": [ - { - "key": "env", - "operator": "=~", - "value": "/^$env$/" - }, - { - "condition": "AND", - "key": "process", - "operator": "=~", - "value": "/$processName$/" - } - ] + "type": "tag" + }, + { + "params": [ + "slot" + ], + "type": "tag" + }, + { + "params": [ + "nodeId" + ], + "type": "tag" + }, + { + "params": [ + "null" + ], + "type": "fill" } ], - "thresholds": [], - "timeFrom": null, - "timeRegions": [], - "timeShift": null, - "title": "Delay since event occurrence - minimum", - "tooltip": { - "msResolution": false, - "shared": true, - "sort": 0, - "value_type": "cumulative" - }, - "type": "graph", - "xaxis": { - "buckets": null, - "mode": "time", - "name": null, - "show": true, - "values": [] - }, - "yaxes": [ + "measurement": "eventtimedelay_histogram", + "orderByTime": "ASC", + "policy": "default", + "query": "SELECT min(\"min\") FROM \"eventtimedelay_histogram\" WHERE \"host\" =~ /$hosts$/ AND \"process\" =~ /$processName$/ AND $timeFilter GROUP BY time($interval), \"process\" fill(null)", + "refId": "A", + "resultFormat": "time_series", + "select": [ + [ + { + "params": [ + "min" + ], + "type": "field" + }, + { + "params": [], + "type": "min" + } + ] + ], + "tags": [ { - "format": "ms", - "logBase": 1, - "max": null, - "min": null, - "show": true + "key": "env", + "operator": "=~", + "value": "/^$env$/" }, { - "format": "short", - "logBase": 1, - "max": null, - "min": null, - "show": true + "condition": "AND", + "key": "process", + "operator": "=~", + "value": "/$processName$/" } - ], - "yaxis": { - "align": false, - "alignLevel": null - } + ] + } + ], + "thresholds": [], + "timeFrom": null, + "timeRegions": [], + "timeShift": null, + "title": "Delay since event occurrence - minimum", + "tooltip": { + "msResolution": false, + "shared": true, + "sort": 0, + "value_type": "cumulative" + }, + "type": "graph", + "xaxis": { + "buckets": null, + "mode": "time", + "name": null, + "show": true, + "values": [] + }, + "yaxes": [ + { + "format": "ms", + "logBase": 1, + "max": null, + "min": null, + "show": true }, { - "aliasColors": {}, - "bars": false, - "dashLength": 10, - "dashes": false, - "datasource": "influx", - "editable": true, - "error": false, - "fill": 1, - "fillGradient": 0, - "grid": {}, - "gridPos": { - "h": 7, - "w": 6, - "x": 6, - "y": 22 - }, - "hiddenSeries": false, - "id": 6, - "interval": "$interval", - "legend": { - "avg": false, - "current": false, - "max": false, - "min": false, - "show": true, - "total": false, - "values": false - }, - "lines": true, - "linewidth": 2, - "links": [], - "nullPointMode": "null", - "options": { - "dataLinks": [] - }, - "percentage": false, - "pointradius": 5, - "points": false, - "renderer": "flot", - "seriesOverrides": [], - "spaceLength": 10, - "stack": false, - "steppedLine": false, - "targets": [ + "format": "short", + "logBase": 1, + "max": null, + "min": null, + "show": true + } + ], + "yaxis": { + "align": false, + "alignLevel": null + } + }, + { + "aliasColors": {}, + "bars": false, + "dashLength": 10, + "dashes": false, + "datasource": "influx", + "editable": true, + "error": false, + "fill": 1, + "fillGradient": 0, + "grid": {}, + "gridPos": { + "h": 7, + "w": 6, + "x": 6, + "y": 22 + }, + "hiddenSeries": false, + "id": 6, + "interval": "$interval", + "legend": { + "avg": false, + "current": false, + "max": false, + "min": false, + "show": true, + "total": false, + "values": false + }, + "lines": true, + "linewidth": 2, + "links": [], + "nullPointMode": "null", + "options": { + "dataLinks": [] + }, + "percentage": false, + "pointradius": 5, + "points": false, + "renderer": "flot", + "seriesOverrides": [], + "spaceLength": 10, + "stack": false, + "steppedLine": false, + "targets": [ + { + "alias": "[[tag_process]] [[tag_nodeId]] [[tag_slot]]", + "dsType": "influxdb", + "groupBy": [ + { + "params": [ + "$__interval" + ], + "type": "time" + }, { - "alias": "[[tag_process]]", - "dsType": "influxdb", - "groupBy": [ - { - "params": [ - "$__interval" - ], - "type": "time" - }, - { - "params": [ - "process" - ], - "type": "tag" - }, - { - "params": [ - "null" - ], - "type": "fill" - } + "params": [ + "process" ], - "measurement": "eventtimedelay_histogram", - "orderByTime": "ASC", - "policy": "default", - "query": "SELECT mean(\"p50\") FROM \"eventtimedelay_histogram\" WHERE \"host\" =~ /$hosts$/ AND \"process\" =~ /$processName$/ AND $timeFilter GROUP BY time($interval), \"process\" fill(null)", - "refId": "A", - "resultFormat": "time_series", - "select": [ - [ - { - "params": [ - "p50" - ], - "type": "field" - }, - { - "params": [], - "type": "mean" - } - ] + "type": "tag" + }, + { + "params": [ + "nodeId" ], - "tags": [ - { - "key": "env", - "operator": "=~", - "value": "/^$env$/" - }, - { - "condition": "AND", - "key": "process", - "operator": "=~", - "value": "/$processName$/" - } - ] + "type": "tag" + }, + { + "params": [ + "slot" + ], + "type": "tag" + }, + { + "params": [ + "null" + ], + "type": "fill" } ], - "thresholds": [], - "timeFrom": null, - "timeRegions": [], - "timeShift": null, - "title": "Delay since event occurrence - median", - "tooltip": { - "msResolution": false, - "shared": true, - "sort": 0, - "value_type": "cumulative" - }, - "type": "graph", - "xaxis": { - "buckets": null, - "mode": "time", - "name": null, - "show": true, - "values": [] - }, - "yaxes": [ + "measurement": "eventtimedelay_histogram", + "orderByTime": "ASC", + "policy": "default", + "query": "SELECT mean(\"p50\") FROM \"eventtimedelay_histogram\" WHERE \"host\" =~ /$hosts$/ AND \"process\" =~ /$processName$/ AND $timeFilter GROUP BY time($interval), \"process\" fill(null)", + "refId": "A", + "resultFormat": "time_series", + "select": [ + [ + { + "params": [ + "p50" + ], + "type": "field" + }, + { + "params": [], + "type": "mean" + } + ] + ], + "tags": [ { - "format": "ms", - "logBase": 1, - "max": null, - "min": null, - "show": true + "key": "env", + "operator": "=~", + "value": "/^$env$/" }, { - "format": "short", - "logBase": 1, - "max": null, - "min": null, - "show": true + "condition": "AND", + "key": "process", + "operator": "=~", + "value": "/$processName$/" } - ], - "yaxis": { - "align": false, - "alignLevel": null - } + ] + } + ], + "thresholds": [], + "timeFrom": null, + "timeRegions": [], + "timeShift": null, + "title": "Delay since event occurrence - median", + "tooltip": { + "msResolution": false, + "shared": true, + "sort": 0, + "value_type": "cumulative" + }, + "type": "graph", + "xaxis": { + "buckets": null, + "mode": "time", + "name": null, + "show": true, + "values": [] + }, + "yaxes": [ + { + "format": "ms", + "logBase": 1, + "max": null, + "min": null, + "show": true }, { - "aliasColors": {}, - "bars": false, - "dashLength": 10, - "dashes": false, - "datasource": "influx", - "editable": true, - "error": false, - "fill": 1, - "fillGradient": 0, - "grid": {}, - "gridPos": { - "h": 7, - "w": 6, - "x": 12, - "y": 22 - }, - "hiddenSeries": false, - "id": 7, - "interval": "$interval", - "legend": { - "avg": false, - "current": false, - "max": false, - "min": false, - "show": true, - "total": false, - "values": false - }, - "lines": true, - "linewidth": 2, - "links": [], - "nullPointMode": "null", - "options": { - "dataLinks": [] - }, - "percentage": false, - "pointradius": 5, - "points": false, - "renderer": "flot", - "seriesOverrides": [], - "spaceLength": 10, - "stack": false, - "steppedLine": false, - "targets": [ + "format": "short", + "logBase": 1, + "max": null, + "min": null, + "show": true + } + ], + "yaxis": { + "align": false, + "alignLevel": null + } + }, + { + "aliasColors": {}, + "bars": false, + "dashLength": 10, + "dashes": false, + "datasource": "influx", + "editable": true, + "error": false, + "fill": 1, + "fillGradient": 0, + "grid": {}, + "gridPos": { + "h": 7, + "w": 6, + "x": 12, + "y": 22 + }, + "hiddenSeries": false, + "id": 7, + "interval": "$interval", + "legend": { + "avg": false, + "current": false, + "max": false, + "min": false, + "show": true, + "total": false, + "values": false + }, + "lines": true, + "linewidth": 2, + "links": [], + "nullPointMode": "null", + "options": { + "dataLinks": [] + }, + "percentage": false, + "pointradius": 5, + "points": false, + "renderer": "flot", + "seriesOverrides": [], + "spaceLength": 10, + "stack": false, + "steppedLine": false, + "targets": [ + { + "alias": "[[tag_process]] [[tag_nodeId]] [[tag_slot]]", + "dsType": "influxdb", + "groupBy": [ { - "alias": "[[tag_process]]", - "dsType": "influxdb", - "groupBy": [ - { - "params": [ - "$__interval" - ], - "type": "time" - }, - { - "params": [ - "process" - ], - "type": "tag" - }, - { - "params": [ - "null" - ], - "type": "fill" - } - ], - "measurement": "eventtimedelay_histogram", - "orderByTime": "ASC", - "policy": "default", - "query": "SELECT max(\"max\") FROM \"eventtimedelay_histogram\" WHERE \"host\" =~ /$hosts$/ AND \"process\" =~ /$processName$/ AND $timeFilter GROUP BY time($interval), \"process\" fill(null)", - "refId": "A", - "resultFormat": "time_series", - "select": [ - [ - { - "params": [ - "max" - ], - "type": "field" - }, - { - "params": [], - "type": "max" - } - ] + "params": [ + "$__interval" ], - "tags": [ - { - "key": "env", - "operator": "=~", - "value": "/^$env$/" - }, - { - "condition": "AND", - "key": "process", - "operator": "=~", - "value": "/$processName$/" - } - ] - } - ], - "thresholds": [], - "timeFrom": null, - "timeRegions": [], - "timeShift": null, - "title": "Delay since event occurrence - maximum", - "tooltip": { - "msResolution": false, - "shared": true, - "sort": 0, - "value_type": "cumulative" - }, - "type": "graph", - "xaxis": { - "buckets": null, - "mode": "time", - "name": null, - "show": true, - "values": [] - }, - "yaxes": [ + "type": "time" + }, { - "format": "ms", - "logBase": 1, - "max": null, - "min": null, - "show": true + "params": [ + "process" + ], + "type": "tag" }, { - "format": "short", - "logBase": 1, - "max": null, - "min": null, - "show": true + "params": [ + "slot" + ], + "type": "tag" + }, + { + "params": [ + "nodeId" + ], + "type": "tag" + }, + { + "params": [ + "null" + ], + "type": "fill" } ], - "yaxis": { - "align": false, - "alignLevel": null - } + "measurement": "eventtimedelay_histogram", + "orderByTime": "ASC", + "policy": "default", + "query": "SELECT max(\"max\") FROM \"eventtimedelay_histogram\" WHERE \"host\" =~ /$hosts$/ AND \"process\" =~ /$processName$/ AND $timeFilter GROUP BY time($interval), \"process\" fill(null)", + "refId": "A", + "resultFormat": "time_series", + "select": [ + [ + { + "params": [ + "max" + ], + "type": "field" + }, + { + "params": [], + "type": "max" + } + ] + ], + "tags": [ + { + "key": "env", + "operator": "=~", + "value": "/^$env$/" + }, + { + "condition": "AND", + "key": "process", + "operator": "=~", + "value": "/$processName$/" + } + ] + } + ], + "thresholds": [], + "timeFrom": null, + "timeRegions": [], + "timeShift": null, + "title": "Delay since event occurrence - maximum", + "tooltip": { + "msResolution": false, + "shared": true, + "sort": 0, + "value_type": "cumulative" + }, + "type": "graph", + "xaxis": { + "buckets": null, + "mode": "time", + "name": null, + "show": true, + "values": [] + }, + "yaxes": [ + { + "format": "ms", + "logBase": 1, + "max": null, + "min": null, + "show": true }, { - "aliasColors": {}, - "bars": false, - "dashLength": 10, - "dashes": false, - "datasource": "influx", - "editable": true, - "error": false, - "fill": 1, - "fillGradient": 0, - "grid": {}, - "gridPos": { - "h": 7, - "w": 6, - "x": 18, - "y": 22 - }, - "hiddenSeries": false, - "id": 13, - "interval": "$interval", - "legend": { - "avg": false, - "current": false, - "max": false, - "min": false, - "show": true, - "total": false, - "values": false - }, - "lines": true, - "linewidth": 2, - "links": [], - "nullPointMode": "null", - "options": { - "dataLinks": [] - }, - "percentage": false, - "pointradius": 5, - "points": false, - "renderer": "flot", - "seriesOverrides": [], - "spaceLength": 10, - "stack": false, - "steppedLine": false, - "targets": [ + "format": "short", + "logBase": 1, + "max": null, + "min": null, + "show": true + } + ], + "yaxis": { + "align": false, + "alignLevel": null + } + }, + { + "aliasColors": {}, + "bars": false, + "dashLength": 10, + "dashes": false, + "datasource": "influx", + "editable": true, + "error": false, + "fill": 1, + "fillGradient": 0, + "grid": {}, + "gridPos": { + "h": 7, + "w": 6, + "x": 18, + "y": 22 + }, + "hiddenSeries": false, + "id": 13, + "interval": "$interval", + "legend": { + "avg": false, + "current": false, + "max": false, + "min": false, + "show": true, + "total": false, + "values": false + }, + "lines": true, + "linewidth": 2, + "links": [], + "nullPointMode": "null", + "options": { + "dataLinks": [] + }, + "percentage": false, + "pointradius": 5, + "points": false, + "renderer": "flot", + "seriesOverrides": [], + "spaceLength": 10, + "stack": false, + "steppedLine": false, + "targets": [ + { + "alias": "[[tag_process]] [[tag_nodeId]] [[tag_slot]]", + "dsType": "influxdb", + "groupBy": [ { - "alias": "[[tag_process]]", - "dsType": "influxdb", - "groupBy": [ - { - "params": [ - "$__interval" - ], - "type": "time" - }, - { - "params": [ - "process" - ], - "type": "tag" - }, - { - "params": [ - "null" - ], - "type": "fill" - } + "params": [ + "$__interval" ], - "measurement": "eventtimedelay_minimalDelay", - "orderByTime": "ASC", - "policy": "default", - "query": "SELECT min(\"value\") FROM \"eventtimedelay_histogram\" WHERE \"host\" =~ /$hosts$/ AND \"process\" =~ /$processName$/ AND $timeFilter GROUP BY time($interval), \"process\" fill(null)", - "refId": "A", - "resultFormat": "time_series", - "select": [ - [ - { - "params": [ - "value" - ], - "type": "field" - }, - { - "params": [], - "type": "min" - } - ] + "type": "time" + }, + { + "params": [ + "process" ], - "tags": [ - { - "key": "env", - "operator": "=~", - "value": "/^$env$/" - }, - { - "condition": "AND", - "key": "process", - "operator": "=~", - "value": "/$processName$/" - } - ] + "type": "tag" + }, + { + "params": [ + "nodeId" + ], + "type": "tag" + }, + { + "params": [ + "slot" + ], + "type": "tag" + }, + { + "params": [ + "null" + ], + "type": "fill" } ], - "thresholds": [], - "timeFrom": null, - "timeRegions": [], - "timeShift": null, - "title": "Time from latest event", - "tooltip": { - "msResolution": false, - "shared": true, - "sort": 0, - "value_type": "cumulative" - }, - "type": "graph", - "xaxis": { - "buckets": null, - "mode": "time", - "name": null, - "show": true, - "values": [] - }, - "yaxes": [ + "measurement": "eventtimedelay_minimalDelay", + "orderByTime": "ASC", + "policy": "default", + "query": "SELECT min(\"value\") FROM \"eventtimedelay_histogram\" WHERE \"host\" =~ /$hosts$/ AND \"process\" =~ /$processName$/ AND $timeFilter GROUP BY time($interval), \"process\" fill(null)", + "refId": "A", + "resultFormat": "time_series", + "select": [ + [ + { + "params": [ + "value" + ], + "type": "field" + }, + { + "params": [], + "type": "min" + } + ] + ], + "tags": [ { - "format": "ms", - "logBase": 1, - "max": null, - "min": null, - "show": true + "key": "env", + "operator": "=~", + "value": "/^$env$/" }, { - "format": "short", - "logBase": 1, - "max": null, - "min": null, - "show": true + "condition": "AND", + "key": "process", + "operator": "=~", + "value": "/$processName$/" } - ], - "yaxis": { - "align": false, - "alignLevel": null - } + ] } ], - "title": "Basics", - "type": "row" + "thresholds": [], + "timeFrom": null, + "timeRegions": [], + "timeShift": null, + "title": "Time from latest event", + "tooltip": { + "msResolution": false, + "shared": true, + "sort": 0, + "value_type": "cumulative" + }, + "type": "graph", + "xaxis": { + "buckets": null, + "mode": "time", + "name": null, + "show": true, + "values": [] + }, + "yaxes": [ + { + "format": "ms", + "logBase": 1, + "max": null, + "min": null, + "show": true + }, + { + "format": "short", + "logBase": 1, + "max": null, + "min": null, + "show": true + } + ], + "yaxis": { + "align": false, + "alignLevel": null + } }, { "collapsed": true, @@ -1348,7 +1407,7 @@ "h": 1, "w": 24, "x": 0, - "y": 1 + "y": 29 }, "id": 24, "panels": [ @@ -2170,7 +2229,7 @@ "h": 1, "w": 24, "x": 0, - "y": 2 + "y": 30 }, "id": 22, "panels": [ @@ -2499,7 +2558,7 @@ "h": 1, "w": 24, "x": 0, - "y": 3 + "y": 31 }, "id": 28, "panels": [], @@ -2512,7 +2571,7 @@ "h": 5, "w": 12, "x": 0, - "y": 4 + "y": 32 }, "id": 30, "options": { @@ -2619,7 +2678,7 @@ "h": 5, "w": 12, "x": 12, - "y": 4 + "y": 32 }, "id": 32, "interval": null, @@ -2750,7 +2809,7 @@ "h": 5, "w": 6, "x": 0, - "y": 9 + "y": 37 }, "id": 37, "interval": null, @@ -2878,7 +2937,7 @@ "h": 5, "w": 6, "x": 6, - "y": 9 + "y": 37 }, "id": 38, "interval": null, @@ -3006,7 +3065,7 @@ "h": 5, "w": 6, "x": 12, - "y": 9 + "y": 37 }, "id": 35, "interval": null, @@ -3137,7 +3196,7 @@ "h": 5, "w": 6, "x": 18, - "y": 9 + "y": 37 }, "id": 34, "interval": null, @@ -3247,7 +3306,7 @@ "valueName": "total" } ], - "refresh": false, + "refresh": "30s", "schemaVersion": 22, "style": "dark", "tags": [], @@ -3425,5 +3484,5 @@ "timezone": "browser", "title": "Scenario", "uid": "nussknacker-scenario", - "version": 26 -} + "version": 47 +} \ No newline at end of file diff --git a/engine/flink/api/src/main/scala/pl/touk/nussknacker/engine/flink/api/process/FlinkIntermediateRawSource.scala b/engine/flink/api/src/main/scala/pl/touk/nussknacker/engine/flink/api/process/FlinkIntermediateRawSource.scala index c073baa979e..1f42e4cc7c9 100644 --- a/engine/flink/api/src/main/scala/pl/touk/nussknacker/engine/flink/api/process/FlinkIntermediateRawSource.scala +++ b/engine/flink/api/src/main/scala/pl/touk/nussknacker/engine/flink/api/process/FlinkIntermediateRawSource.scala @@ -42,7 +42,7 @@ trait FlinkIntermediateRawSource[Raw] extends ExplicitUidInOperatorsSupport { se //1. add source and 2. set UID val rawSourceWithUid = setUidToNodeIdIfNeed(flinkNodeContext, env .addSource[Raw](sourceFunction)(typeInformation) - .name(s"${flinkNodeContext.metaData.id}-${flinkNodeContext.nodeId}-source")) + .name(flinkNodeContext.nodeId)) //3. assign timestamp and watermark policy val rawSourceWithUidAndTimestamp = timestampAssigner diff --git a/nussknacker-dist/src/universal/conf/dev-application.conf b/nussknacker-dist/src/universal/conf/dev-application.conf index 8bfea70f3d1..834d58a725e 100644 --- a/nussknacker-dist/src/universal/conf/dev-application.conf +++ b/nussknacker-dist/src/universal/conf/dev-application.conf @@ -58,11 +58,9 @@ metricsSettings { url: ${base.grafanaUrl}"/d/$dashboard?theme=dark&var-processName=$process&var-env="${environment} defaultDashboard: "nussknacker-scenario" processingTypeToDashboard: { - "streaming": "nussknacker-scenario" #Note: currently in demo docker-compose these dashboards do not exist. We keep them here, so #one can test if changing dashboard link works, you can add other dashboards locally - "streaming-generic": "flink-generic" - "request-response": "flink-standalone" + "request-response": "nussknacker-standalone" } }