Striim 4.0.4 documentation

Using the MON command

The monitor command's syntax is:

mon[itor]
  [ <node>
  | <namespace>.<application name> [ <node> ]
  | <namespace>.<component name> [ <node> ] ]
[-follow [ seconds ] ]
[-start '<time>']
[-end '<time>']

Node names begin with S or A to indicate server or Forwarding Agent, followed by the node's IP address with hyphens instead of periods. For example, a server with the IP address 192.168.1.12 would be named S192-168-1-12. Use the command LIST SERVERS; to return a list of nodes in the current cluster.

If you include the -follow option, the display will be refreshed every five seconds. You may specify a different refresh period in seconds, such as -follow 30.

Use the -start and/or -end options when specifying a node, application, or component to return the most recent data within the specified range. Time may be specified as HH:mm (current day), yyyy/MM/dd-HH:mmyyyy/MM/dd-HH:mm:ss, or yyyy/MM/dd-HH:mm:ss:SSS.

mon;

Returns a summary of the cluster's applications, nodes, and Elasticsearch usage. For example:

╒════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════╕
│                                                          Striim Applications                                                           │
├────────────────────────────────────────┬────────────────┬────────┬────────────────┬────────┬────────┬──────────────────────────────────┤
│ Name                                   │ Status         │ Rate   │ SourceRate     │ CPU%   │ Nodes  │ Activity                         │
├────────────────────────────────────────┼────────────────┼────────┼────────────────┼────────┼────────┼──────────────────────────────────┤
│ Samples.MultiLogApp                    │ RUNNING        │ 333,82 │ 22,836         │ 95%    │ 1      │ 2021-04-28 16:42:44              │
│                                        │                │ 8      │                │        │        │                                  │
│ Samples.PosApp                         │ RUNNING        │ 90,754 │ 10,088         │ 20%    │ 1      │ 2021-04-28 16:42:44              │
╞════════════════════════════════════════╧════════════════╧════════╧════════════════╧════════╧════════╧══════════════════════════════════╡
│                                                          Striim Cluster Nodes                                                          │
├────────────────────────────────────────┬────────────────────────┬────────────────┬────────────────┬────────────────────────────────────┤
│ Name                                   │ Version                │ Free Mem       │ CPU%           │ Uptime                             │
├────────────────────────────────────────┼────────────────────────┼────────────────┼────────────────┼────────────────────────────────────┤
│ S192_168_7_91                          │ (982647b992)           │ 392.85Mb       │ 318%           │ 06H:04M:51S                        │
╞════════════════════════════════════════╧════════════════════════╧════════════════╧════════════════╧════════════════════════════════════╡
│                                                             ElasticSearch                                                              │
├───────────────────────────────────────────────────────────┬────────────────────────────────────────────────────────────────────────────┤
│ Elasticsearch Receive Throughput                          │ 0                                                                          │
│ Elasticsearch Transmit Throughput                         │ 0                                                                          │
│ Elasticsearch Cluster Storage Free                        │ 488,682,848,256                                                            │
│ Elasticsearch Cluster Storage Total                       │ 499,963,174,912                                                            │
└───────────────────────────────────────────────────────────┴────────────────────────────────────────────────────────────────────────────┘
mon <node>;

Returns details for every component in every namespace in the specified node and a summary of its Elasticsearch usage and threads. For example:

╒══════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════╕
│                                                                            NODE S192_168_7_91                                                                            │
├───────────────────────────────────────────────────┬───────────────────────────────┬────────────────────┬────────────────────┬────────────────────────────────────────────┤
│ Name                                              │ Version                       │ Free Mem           │ CPU%               │ Uptime                                     │
├───────────────────────────────────────────────────┼───────────────────────────────┼────────────────────┼────────────────────┼────────────────────────────────────────────┤
│ S192_168_7_91                                     │ (982647b992)                  │ 2.62Gb             │ 23%                │ 06H:15M:51S                                │
│ Global.MonitoringProcessApp                       │                               │                    │ 0.2%               │                                            │
│  Global.MonitoringStream1                         │                               │                    │ 0.2%               │                                            │
│  Global.MonitoringCQ                              │                               │                    │ 0.2%               │                                            │
│ Samples.PosApp                                    │                               │                    │ 0.024%             │                                            │
│  Samples.CsvToPosData                             │                               │                    │ 8%                 │                                            │
│  Samples.GenerateMerchantTxRateOnly               │                               │                    │ 0%                 │                                            │
│  Samples.GenerateMerchantTxRateWithStatus         │                               │                    │ 0.275%             │                                            │
│  Samples.GenerateWactionContext                   │                               │                    │ 0%                 │                                            │
...
│ Samples.MultiLogApp                               │                               │                    │ 0.306%             │                                            │
│  Samples.MonitorLogs                              │                               │                    │                    │                                            │
│   Samples.ParseAccessLog                          │                               │                    │ 27%                │                                            │
│   Samples.ParseLog4J                              │                               │                    │ 4%                 │                                            │
│   Samples.AccessLogEntry                          │                               │                    │                    │                                            │
│   Samples.Log4JEntry                              │                               │                    │                    │                                            │
...
│  Samples.ErrorsAndWarnings                        │                               │                    │                    │                                            │
│   Samples.GetLog4JErrorWarning                    │                               │                    │ 2%                 │                                            │
│   Samples.Log4JErrorWarningActivity               │                               │                    │                    │                                            │
│   Samples.Log4ErrorWarningStream                  │                               │                    │ 0%                 │                                            │
│  Samples.HackerCheck                              │                               │                    │                    │                                            │
│   Samples.FindHackers                             │                               │                    │ 0%                 │                                            │
│   Samples.GenerateHackerContext                   │                               │                    │ 0.048%             │                                            │
│   Samples.SendHackingAlerts                       │                               │                    │ 0.029%             │                                            │
...
│ Global.MonitoringSourceApp                        │                               │                    │ 0.104%             │                                            │
│  Global.MonitoringSourceStream                    │                               │                    │ 0.104%             │                                            │
│  Global.MonitoringSourceFlow                      │                               │                    │                    │                                            │
│   Global.MonitoringSource1                        │                               │                    │ 0.095%             │                                            │
│  Global.MonitoringSourceFlowAgent                 │                               │                    │                    │                                            │
│   Global.MonitoringSourceAgent                    │                               │                    │                    │                                            │
│ System$Alerts.AlertingApp                         │                               │                    │ 16%                │                                            │
│  System$Alerts.validateAlertStream                │                               │                    │ 14%                │                                            │
│  System$Alerts.EmailOutputStream                  │                               │                    │                    │                                            │
│  System$Alerts.AlertJoinedMointorStream           │                               │                    │ 2%                 │                                            │
...
│  System$Alerts.WebAlertFilter                     │                               │                    │ 0.05%              │                                            │
╞═══════════════════════════════════════════════════╧═══════════════════════════════╧════════════════════╧════════════════════╧════════════════════════════════════════════╡
│                                                                              ElasticSearch                                                                               │
├──────────────────────────────────────────────────────────────────────────┬───────────────────────────────────────────────────────────────────────────────────────────────┤
│ Elasticsearch Receive Throughput                                         │ 0                                                                                             │
│ Elasticsearch Transmit Throughput                                        │ 0                                                                                             │
│ Elasticsearch Cluster Storage Free                                       │ 488,682,848,256                                                                               │
│ Elasticsearch Cluster Storage Total                                      │ 499,963,174,912                                                                               │
├──────────────────────────────────────────────────────────────────────────┴───────────────────────────────────────────────────────────────────────────────────────────────┤
│ Hot Threads: S192_168_7_91:                                                                                                                                              │
│ Hot threads at 2021-04-28T23:53:39.690Z, interval=500ms, busiestThreads=3, ignoreIdleThreads=true:                                                                       │
│                                                                                                                                                                          │
│  0.1% (535micros out of 500ms) cpu usage by thread                                                                                                                       |
|   'Global:showStream:03624c7d-2292-4535-bbe5-e376c5f5bc42:01eba848-de40-9c21-8a82-8cae4cf129d6:Async-Sender'                                                             │
│   10/10 snapshots sharing following 5 elements                                                                                                                           │
│     sun.misc.Unsafe.park(Native Method)                                                                                                                                  │
│     java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)                                                                                               │
│     org.jctools.queues.MpscCompoundQueue.awaitNotEmpty(MpscCompoundQueue.java:308)                                                                                       │
│     org.jctools.queues.MpscCompoundQueue.poll(MpscCompoundQueue.java:286)                                                                                                │
│     com.webaction.jmqmessaging.AsyncSender$AsyncSenderThread.run(AsyncSender.java:119)                                                                                   │
│                                                                                                                                                                          │
│  0.1% (445micros out of 500ms) cpu usage by thread 'hz._hzInstance_1_robertmac.cached.thread-6'                                                                          │
│   5/10 snapshots sharing following 4 elements                                                                                                                            │
│     java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)                                                                                      │
│     java.lang.Thread.run(Thread.java:748)                                                                                                                                │
│     com.hazelcast.util.executor.HazelcastManagedThread.executeRun(HazelcastManagedThread.java:64)                                                                        │
│     com.hazelcast.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:80)                                                                               │
...
└──────────────────────────────────────────────────────────────────────────┴───────────────────────────────────────────────────────────────────────────────────────────────┘
mon <namespace>.<application name>;

Returns details for every component in the specified application. For example:

╒═══════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════╕
│                                                          Application Samples.MultiLogApp                                                          │
├───────────────────────────────────────────┬─────────────────┬────────┬─────────────────┬────────┬────────┬────────────────────────────────────────┤
│ Name                                      │ Status          │ Rate   │ SourceRate      │ CPU%   │ Nodes  │ Activity                               │
├───────────────────────────────────────────┼─────────────────┼────────┼─────────────────┼────────┼────────┼────────────────────────────────────────┤
│ Samples.MultiLogApp                       │ RUNNING         │ 571,01 │ 40,958          │ 66%    │ 1      │ 2021-04-28 17:02:14                    │
│                                           │                 │ 0      │                 │        │        │                                        │
│ Samples.ApiFlow                           │                 │ 0      │ 0               │        │ 1      │                                        │
│  Samples.GetApiSummaryUsage               │                 │ 176    │ 0               │ 0%     │ 1      │ 2021-04-28 17:02:13                    │
│  Samples.GetApiUsage                      │                 │ 26,142 │ 0               │ 0%     │ 1      │ 2021-04-28 17:02:13                    │
│  Samples.ApiSummaryWindow                 │                 │ 0      │ 0               │        │ 1      │ 2021-04-28 17:02:13                    │
...
│ Samples.ZeroContentCheck                  │                 │ 0      │ 0               │        │ 1      │                                        │
│  Samples.FindZeroContent                  │                 │ 19,550 │ 0               │ 7%     │ 1      │ 2021-04-28 17:02:14                    │
│  Samples.GenerateZeroContentContext       │                 │ 0      │ 0               │ 0.02%  │ 1      │ 2021-04-28 17:02:03                    │
...
│  Samples.ZeroContentEventList             │                 │ 0      │ 0               │ 0%     │ 1      │ 2021-04-28 17:02:03                    │
│  Samples.ZeroContentAlertSub              │                 │ 0      │ 0               │ 0%     │ 1      │ 2021-04-28 17:02:03                    │
└───────────────────────────────────────────┴─────────────────┴────────┴─────────────────┴────────┴────────┴────────────────────────────────────────┘
mon <namespace>.<application name> <node>;

Returns details for the specified application on the specified node. This is useful to drill down on an application deployed on multiple nodes. For example:

╒═════════════════════════════════════════════════════════════════════════════════════════════════════════╕
│                                     APPLICATION Samples.MultiLogApp                                     │
├──────────────────────────────┬──────────────────────────────────────────────────────────────────────────┤
│ Property                     │ Value                                                                    │
├──────────────────────────────┼──────────────────────────────────────────────────────────────────────────┤
│ Nodes                        │ 1                                                                        │
│ Status Change                │ Object UUID    : 01eba87b-324d-1b91-8a82-8cae4cf129d6                    │
│                              │ Name           : Samples.MultiLogApp                                     │
│                              │ Type           : APPLICATION                                             │
│                              │ Previous Status: STOPPED                                                 │
│                              │ Current Status : RUNNING                                                 │
│                              │ Timestamp      : 2021/04/28-17:06:31                                     │
│ Timestamp                    │ 2021-04-28 17:06:31                                                      │
└──────────────────────────────┴──────────────────────────────────────────────────────────────────────────┘
mon <namespace>.<component name> [ <node> ]

Returns details for only the specified component. For example:

╒═════════════════════════════════════════════════════════════════════════════════════════════════════════╕
│                                       STREAM Samples.AlertStream                                        │
├──────────────────────────────┬──────────────────────────────────────────────────────────────────────────┤
│ Property                     │ Value                                                                    │
├──────────────────────────────┼──────────────────────────────────────────────────────────────────────────┤
│ CPU                          │ 0.00                                                                     │
│ CPU Rate Per Node            │ 0%                                                                       │
│ CPU Rate                     │ 0%                                                                       │
│ Number of events seen per    │ 0                                                                        │
│ monitor snapshot interval    │                                                                          │
│ Input                        │ 3,825                                                                    │
│ Input Rate                   │ 0                                                                        │
│ Latest Activity              │ 2021-04-28 17:12:01                                                      │
│ Nodes                        │ 1                                                                        │
│ Rate                         │ 0                                                                        │
│ Stream Full                  │ False                                                                    │
│ Timestamp                    │ 2021-04-28 17:12:01                                                      │
└──────────────────────────────┴──────────────────────────────────────────────────────────────────────────┘

For a DatabaseWriter source with an input stream that is the output stream of a DatabaseReader or CDC reader source, output will include Commit Lag, which is the number of milliseconds between the timestamp of the last known operation of the database source and the current Striim system time. Note that if the database and Striim systems are in different time zones this number will be quite large.

For an OracleReader source, output will include the following:

╒════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════╕
│                                                   SOURCE ns1.ora2striim_OracleSource                                                   │
├──────────────────────────────────────┬─────────────────────────────────────────────────────────────────────────────────────────────────┤
│ Property                             │ Value                                                                                           │
├──────────────────────────────────────┼─────────────────────────────────────────────────────────────────────────────────────────────────┤
│ Catalog evolution duration           │ Not Ready                                                                                       │
│ Schema Evolution Status              │ NotApplicable                                                                                   │
│ CDC Operation                        │ {                                                                                               │
│                                      │   "No of Deletes" : 0,                                                                          │
│                                      │   "No of DDLs" : 0,                                                                             │
│                                      │   "No of PKUpdates" : 0,                                                                        │
│                                      │   "No of Updates" : 0,                                                                          │
│                                      │   "No of Inserts" : 10                                                                          │
│                                      │ }                                                                                               │
│ CPU                                  │ 0.00029                                                                                         │
│ CPU Rate Per Node                    │ 0.007%                                                                                          │
│ CPU Rate                             │ 0.029%                                                                                          │
│ Number of events seen per monitor    │ 0                                                                                               │
│ snapshot interval                    │                                                                                                 │
│ Input                                │ 10                                                                                              │
│ Input Rate                           │ 0                                                                                               │
│ Largest transaction details          │ TxnID : 8.25.946 Operation count : 12                                                           │
│ Last Event Position                  │ 01eba881-2a1b-93b1-8a82-8cae4cf129d6/*@[{OpenSCN[2466241]-CommitSCN[2467119]-SeqNum[10]} |  %]  │
│ Latest Activity                      │ 2021-04-29 12:06:09                                                                             │
│ Logminer Start Duration              │ 4ms                                                                                             │
│ Oldest Open Transactions             │ [{"3.15.924":{"# of Ops":11,"CommitSCN":"null","Sequence #":"1","StartSCN":"2467200","Rba       │
│                                      │ block #":"11","Thread #":"1","TimeStamp":"2021-04-29T19:06:16.000-07:00"}}]                     │
│ Longest transaction details          │ TxnID : 8.25.946 Open Duration : 114 seconds                                                    │
│ Open transactions in cache           │ 1                                                                                               │
│ Uninterested transactions in cache   │ 0                                                                                               │
│ Nodes                                │ 1                                                                                               │
│ Oracle Reader Current SCN            │ 2467327                                                                                         │
│ Current SCN Range                    │ 2467254-2467327                                                                                 │
│ Oracle Reader Last SCN               │ 2467254                                                                                         │
│ Oracle Reader Last Timestamp         │ 2021-04-29 12:06:35                                                                             │
│ Total Logminer Records read          │ 1209                                                                                            │
│ Redo Switch Count                    │ 0                                                                                               │
│ Rate                                 │ 0                                                                                               │
│ Read Lag                             │ -25,083,374                                                                                     │
│ Source Input                         │ 10                                                                                              │
│ Source Rate                          │ 0                                                                                               │
│ StartSCN                             │ 2466068                                                                                         │
│ Table Information                    │ {                                                                                               │
│                                      │   "HR.JOB_HISTORY" : {                                                                          │
│                                      │     "No of Deletes" : 0,                                                                        │
│                                      │     "No of DDLs" : 0,                                                                           │
│                                      │     "No of PKUpdates" : 0,                                                                      │
│                                      │     "No of Updates" : 0,                                                                        │
│                                      │     "No of Inserts" : 10                                                                        │
│                                      │   }                                                                                             │
│                                      │ }                                                                                               │
│ Timestamp                            │ 2021-04-29 12:07:14                                                                             │
│ Top Open Transactions (# of Ops)     │ [{"3.15.924":{"# of Ops":11,"CommitSCN":"null","Sequence #":"1","StartSCN":"2467200","Rba       │
│                                      │ block #":"11","Thread #":"1","TimeStamp":"2021-04-29T19:06:16.000-07:00"}}]                     │
│ Operations in the Cache              │ 11                                                                                              │
│ Total number of Reconnects           │ 0                                                                                               │
└──────────────────────────────────────┴─────────────────────────────────────────────────────────────────────────────────────────────────┘

The snapshot interval is five seconds. "Number of events seen per monitor snapshot interval" is the count for the most recent snapshot.

Known issue DEV-12638: The "Oracle Reader Last Timestamp" always uses the time zone of the Striim server, even when the Oracle server is in a different time zone.

mon <namespace>.<application or component name> [ <node> ] -format "summaryreport"

Returns a summary for the specified application or component. For example:

╒═══════════════════════════════════════════════════════════════════════════════════════════════════╕
│                                Samples.MultiLogApp Summary Report                                 │
├─────────────────────────────┬─────────────────────────────────────────────────────────────────────┤
│ Cluster Name                │ hz.client_0                                                         │
│ Striim Version              │ Version 4.0.2 (982647b992)                                          │
│ Metadata Repository Version │ 1.0.0-SNAPSHOT                                                      │
│ Nodes                       │ 1                                                                   │
├─────────────────────────────┼─────────────────────────────────────────────────────────────────────┤
│ Source Input Diff           │ 0                                                                   │
│ Output Diff                 │ 0                                                                   │
└─────────────────────────────┴─────────────────────────────────────────────────────────────────────┘
mon <namespace>.<component name> [-start "HH:MM"] [-end "HH:MM"] -format "timeseriesreport";

Returns a comma-delimited, highly verbose report for the specified component, which you may parse using your own tools. The first line is a header row.