Skip to content
This repository was archived by the owner on Mar 3, 2023. It is now read-only.

[Heron-3733] CI Pipeline Failures Involving the <stmgr_unittest> #3735

Merged
merged 14 commits into from
Nov 15, 2021
Merged

[Heron-3733] CI Pipeline Failures Involving the <stmgr_unittest> #3735

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
14 commits
Select commit Hold shift + click to select a range
3ccf83e
[Stmgr] <Unit Test>
surahman Nov 13, 2021
8c10c2d
[Stmgr] <Unit Test>
surahman Nov 13, 2021
721175d
[Stmgr] <Unit Test>
surahman Nov 13, 2021
dbf2455
Merge branch '3733-CI-Stmgr-Unittest-dev' into 3733-CI-Stmgr-Unittest
surahman Nov 13, 2021
bbb031b
[Stmgr] <Unit Test>
surahman Nov 13, 2021
36bbee8
[Stmgr] <Unit Test>
surahman Nov 13, 2021
9afe578
[Stmgr] <Unit Test>
surahman Nov 13, 2021
8ab8eee
Merge branch '3733-CI-Stmgr-Unittest-dev' into 3733-CI-Stmgr-Unittest
surahman Nov 13, 2021
0b04c9c
[Integration Test] <Local Test Runner>
surahman Nov 14, 2021
5fa6c99
Merge branch '3733-CI-Stmgr-Unittest-dev' into 3733-CI-Stmgr-Unittest
surahman Nov 14, 2021
be6ee30
[Stmgr] <Unit Test>
surahman Nov 14, 2021
c913ab0
Merge branch '3733-CI-Stmgr-Unittest-dev' into 3733-CI-Stmgr-Unittest
surahman Nov 14, 2021
c19c300
[Integration Test] <Python>
surahman Nov 14, 2021
69772e7
Merge branch '3733-CI-Stmgr-Unittest-dev' into 3733-CI-Stmgr-Unittest
surahman Nov 14, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
21 changes: 15 additions & 6 deletions heron/stmgr/tests/cpp/server/stmgr_unittest.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -972,14 +972,17 @@ TEST(StMgr, test_back_pressure_instance) {
common.topology_name_ = "mytopology";
common.topology_id_ = "abcd-9999";
common.setNumStmgrs(2);
common.num_spouts_ = 2;
common.num_spout_instances_ = 1;
common.num_spouts_ = 4;
common.num_spout_instances_ = 4;
common.num_bolts_ = 2;
common.num_bolt_instances_ = 1;
common.grouping_ = heron::proto::api::SHUFFLE;
// Empty so that we don't attempt to connect to the zk
// but instead connect to the local filesytem
common.zkhostportlist_ = "";
// Overwrite the default values for back pressure
common.high_watermark_ = 1_MB;
common.low_watermark_ = 500_KB;

int num_msgs_sent_by_spout_instance = 100 * 1000 * 1000; // 100M

Expand Down Expand Up @@ -1083,14 +1086,17 @@ TEST(StMgr, test_spout_death_under_backpressure) {
common.topology_name_ = "mytopology";
common.topology_id_ = "abcd-9999";
common.setNumStmgrs(2);
common.num_spouts_ = 1;
common.num_spout_instances_ = 2;
common.num_spouts_ = 4;
common.num_spout_instances_ = 4;
common.num_bolts_ = 2;
common.num_bolt_instances_ = 1;
common.grouping_ = heron::proto::api::SHUFFLE;
// Empty so that we don't attempt to connect to the zk
// but instead connect to the local filesytem
common.zkhostportlist_ = "";
// Overwrite the default values for back pressure
common.high_watermark_ = 1_MB;
common.low_watermark_ = 500_KB;

int num_msgs_sent_by_spout_instance = 100 * 1000 * 1000; // 100M

Expand Down Expand Up @@ -1340,14 +1346,17 @@ TEST(StMgr, test_back_pressure_stmgr_reconnect) {
common.topology_name_ = "mytopology";
common.topology_id_ = "abcd-9999";
common.setNumStmgrs(2);
common.num_spouts_ = 2;
common.num_spout_instances_ = 1;
common.num_spouts_ = 4;
common.num_spout_instances_ = 4;
common.num_bolts_ = 2;
common.num_bolt_instances_ = 1;
common.grouping_ = heron::proto::api::SHUFFLE;
// Empty so that we don't attempt to connect to the zk
// but instead connect to the local filesytem
common.zkhostportlist_ = "";
// Overwrite the default values for back pressure
common.high_watermark_ = 1_MB;
common.low_watermark_ = 500_KB;

int num_msgs_sent_by_spout_instance = 100 * 1000 * 1000; // 100M

Expand Down
2 changes: 1 addition & 1 deletion integration_test/src/python/local_test_runner/main.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@
]

# The location of default configure file
DEFAULT_TEST_CONF_FILE = "integration_test/src/python/local_test_runner/resources/test.conf"
DEFAULT_TEST_CONF_FILE = "resources/test.conf"

ProcessTuple = namedtuple('ProcessTuple', 'pid cmd')

Expand Down
2 changes: 1 addition & 1 deletion integration_test/src/python/test_runner/main.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@
from heron.common.src.python.utils import log

# The location of default configure file
DEFAULT_TEST_CONF_FILE = "integration_test/src/python/test_runner/resources/test.json"
DEFAULT_TEST_CONF_FILE = "resources/test.json"

RETRY_ATTEMPTS = 25
#seconds
Expand Down
2 changes: 1 addition & 1 deletion integration_test/src/python/topology_test_runner/main.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@
from heron.statemgrs.src.python.filestatemanager import FileStateManager

# The location of default configure file
DEFAULT_TEST_CONF_FILE = "integration_test/src/python/topology_test_runner/resources/test.json"
DEFAULT_TEST_CONF_FILE = "resources/test.json"

#seconds
RETRY_ATTEMPTS = 50
Expand Down