Skip to content
This repository was archived by the owner on Apr 4, 2021. It is now read-only.

Conversation

@PracheerAgarwal-zz
Copy link
Contributor

No description provided.

PracheerAgarwal-zz and others added 27 commits December 20, 2016 10:19
@PracheerAgarwal-zz
Copy link
Contributor Author

I will be pasting the results of dev testing soon.

@PracheerAgarwal-zz PracheerAgarwal-zz changed the title FALCON-795, Backlog Metrics Workflow Failure FALCON-795, Backlog Metrics Workflow Failure Aug 4, 2017
@PracheerAgarwal-zz PracheerAgarwal-zz changed the title FALCON-795, Backlog Metrics Workflow Failure FALCON-795, Backlog Metrics Workflow Failure Fix Aug 4, 2017
@PracheerAgarwal-zz PracheerAgarwal-zz changed the title FALCON-795, Backlog Metrics Workflow Failure Fix FALCON-2300, Backlog Metrics Workflow Failure Fix Aug 4, 2017
@PracheerAgarwal-zz
Copy link
Contributor Author

Added two process with sla as 5 minutes.
Entries got added to pending instances.

mysql> select * from PENDING_INSTANCES;
+------+--------------+-------------+-------------+---------------------+
| id | cluster_name | entity_name | entity_type | nominal_time |
+------+--------------+-------------+-------------+---------------------+
| 1551 | local | process3-1 | process | 2017-08-04 16:30:00 |
| 1552 | local | process3-1 | process | 2017-08-04 16:35:00 |
| 1553 | local | process3-1 | process | 2017-08-04 16:40:00 |
| 1554 | local | process3-1 | process | 2017-08-04 16:45:00 |
| 1555 | local | process3-1 | process | 2017-08-04 16:50:00 |
| 1556 | local | process3-1 | process | 2017-08-04 16:55:00 |
| 1557 | local | process3-1 | process | 2017-08-04 17:00:00 |
| 1558 | local | process3-1 | process | 2017-08-04 17:05:00 |
| 1559 | local | process3-1 | process | 2017-08-04 17:10:00 |
| 1560 | local | process3-1 | process | 2017-08-04 17:15:00 |
| 1561 | local | process3-1 | process | 2017-08-04 17:20:00 |
| 1562 | local | process3-1 | process | 2017-08-04 17:25:00 |
| 1563 | local | process3-1 | process | 2017-08-04 17:30:00 |
| 1564 | local | process3-1 | process | 2017-08-04 17:35:00 |
| 1565 | local | process3-2 | process | 2017-08-04 16:30:00 |
| 1566 | local | process3-2 | process | 2017-08-04 16:35:00 |
| 1567 | local | process3-2 | process | 2017-08-04 16:40:00 |
| 1568 | local | process3-2 | process | 2017-08-04 16:45:00 |
| 1569 | local | process3-2 | process | 2017-08-04 16:50:00 |
| 1570 | local | process3-2 | process | 2017-08-04 16:55:00 |
| 1571 | local | process3-2 | process | 2017-08-04 17:00:00 |
| 1572 | local | process3-2 | process | 2017-08-04 17:05:00 |
| 1573 | local | process3-2 | process | 2017-08-04 17:10:00 |
| 1574 | local | process3-2 | process | 2017-08-04 17:15:00 |
| 1575 | local | process3-2 | process | 2017-08-04 17:20:00 |
| 1576 | local | process3-2 | process | 2017-08-04 17:25:00 |
| 1577 | local | process3-2 | process | 2017-08-04 17:30:00 |
| 1578 | local | process3-2 | process | 2017-08-04 17:35:00 |

than deleted entry for process3-2, to check if process3-1 will get picked for SLA alerts or not. It get picket, that means replacing break with continue works.

mysql> select * from ENTITY_SLA_ALERTS;
+------+--------------+-------------+-------------+-----------------+----------------+---------------------+---------------------+--------------------+
| id | cluster_name | entity_name | entity_type | sla_high_missed | sla_low_missed | nominal_time | sla_high_alert_sent | sla_low_alert_sent |
+------+--------------+-------------+-------------+-----------------+----------------+---------------------+---------------------+--------------------+
| 1477 | local | process3-1 | process | � | � | 2017-08-04 12:07:54 | NULL | NULL |
| 1479 | local | process3-1 | process | � | � | 2017-08-04 12:07:54 | NULL | NULL |
| 1481 | local | process3-1 | process | � | � | 2017-08-04 12:07:55 | NULL | NULL |
| 1483 | local | process3-1 | process | � | � | 2017-08-04 12:07:55 | NULL | NULL |
| 1485 | local | process3-1 | process | � | � | 2017-08-04 12:07:56 | NULL | NULL |
| 1487 | local | process3-1 | process | � | � | 2017-08-04 12:07:56 | NULL | NULL |
| 1489 | local | process3-1 | process | � | � | 2017-08-04 12:07:56 | NULL | NULL |
| 1491 | local | process3-1 | process | � | � | 2017-08-04 12:07:57 | NULL | NULL |
| 1493 | local | process3-1 | process | � | � | 2017-08-04 12:07:57 | NULL | NULL |
| 1495 | local | process3-1 | process | � | � | 2017-08-04 12:07:57 | NULL | NULL |
| 1497 | local | process3-1 | process | � | � | 2017-08-04 12:07:58 | NULL | NULL |
| 1499 | local | process3-1 | process | � | � | 2017-08-04 12:07:58 | NULL | NULL |
| 1651 | local | process3-1 | process | � | � | 2017-08-04 12:07:58 | NULL | NULL |
| 1653 | local | process3-1 | process | � | � | 2017-08-04 12:07:59 | NULL | NULL |
+------+--------------+-------------+-------------+-----------------+----------------+---------------------+---------------------+--------------------+
14 rows in set (0.00 sec)

+ "instanceTime:{}", entity.getName(), clusterName, nominalTime, entityType);
AbstractWorkflowEngine wfEngine = WorkflowEngineFactory.getWorkflowEngine();

if ((System.currentTimeMillis() - nominalTime.getTime())/(1000*60*60*24) >= Integer.parseInt(

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Move this to the else part of if (instancesResult.getInstances().length > 0) .. Lets not eagerly assume the instance info is not available.

AbstractWorkflowEngine wfEngine = WorkflowEngineFactory.getWorkflowEngine();

if ((System.currentTimeMillis() - nominalTime.getTime())/(1000*60*60*24) >= Integer.parseInt(
RuntimeProperties.get().getProperty("worklflow.expiration.period", "7"))) {

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Make the property name to a constant field. Also, the property name can be : workflow.history.expiration.period.days (more intuitive and also indicates the time unit)

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants