-
Notifications
You must be signed in to change notification settings - Fork 453
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Fix write fanouts with aggregated namespaces #991
Conversation
echo "Wait until data begins being written to remote storage for the aggregated namespace" | ||
ATTEMPTS=10 TIMEOUT=2 retry_with_backoff \ | ||
'[[ $(curl -sSf 0.0.0.0:9090/api/v1/query?query=database_write_tagged_success\\{namespace=\"agg\"\\} | jq -r .data.result[0].value[1]) -gt 0 ]]' | ||
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
remove the docker compose down below
@@ -11,6 +11,13 @@ echo "Run m3dbnode and m3coordinator containers" | |||
docker-compose -f ${COMPOSE_FILE} up -d dbnode01 | |||
docker-compose -f ${COMPOSE_FILE} up -d coordinator01 | |||
|
|||
# think of this as a defer func() in golang | |||
function defer { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
fancy!
@@ -6,9 +6,43 @@ echo "Bringing up nodes in the backgorund with docker compose, remember to run . | |||
docker-compose -f docker-compose.yml up -d --renew-anon-volumes | |||
echo "Nodes online" | |||
|
|||
sleep 10 |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
drop changes to m3_stack
from the pr
curl -vvvsSf -X DELETE 0.0.0.0:7201/api/v1/namespace/default |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
nit: newline
@@ -359,7 +360,7 @@ func newDownsampler( | |||
RulesKVStore: kvStore, | |||
AutoMappingRules: autoMappingRules, | |||
ClockOptions: clock.NewOptions(), | |||
InstrumentOptions: instrumentOpts, | |||
InstrumentOptions: instrumentOpts.SetMetricsScope(tally.NoopScope), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
nit: put a reference to 992
TODO: remove after https://github.com/m3db/m3/issues/992 is fixed
src/query/server/server.go
Outdated
@@ -58,6 +58,7 @@ import ( | |||
"github.com/m3db/m3x/pool" | |||
xsync "github.com/m3db/m3x/sync" | |||
xtime "github.com/m3db/m3x/time" | |||
"github.com/uber-go/tally" |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
metalinter is going to complain about this
Codecov Report
@@ Coverage Diff @@
## master #991 +/- ##
==========================================
+ Coverage 55.91% 77.82% +21.9%
==========================================
Files 407 411 +4
Lines 34318 34516 +198
==========================================
+ Hits 19188 26861 +7673
+ Misses 13322 5783 -7539
- Partials 1808 1872 +64
Continue to review full report at Codecov.
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM once build passes
No description provided.