-
Notifications
You must be signed in to change notification settings - Fork 1.3k
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
Add support for trace_v3 schema in messaging queues #6663
Add support for trace_v3 schema in messaging queues #6663
Conversation
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.
❌ Changes requested. Reviewed everything up to 7460888 in 32 seconds
More details
- Looked at
383
lines of code in2
files - Skipped
0
files when reviewing. - Skipped posting
1
drafted comments based on config settings.
1. pkg/query-service/constants/constants.go:93
- Draft comment:
The environment variableKAFKA_SPAN_EVAL
has been changed fromfalse
totrue
. This alters the default behavior of the application and should be documented or communicated to the team. - Reason this comment was not posted:
Confidence changes required:50%
The PR changes the environment variableKAFKA_SPAN_EVAL
fromfalse
totrue
. This change should be highlighted as it affects the default behavior of the application.
Workflow ID: wflow_HbsIa5fMPHIOmt9i
Want Ellipsis to fix these issues? Tag @ellipsis-dev
in a comment. You can customize Ellipsis with 👍 / 👎 feedback, review rules, user-specific overrides, quiet
mode, and more.
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.
overall changes looks good, please test all the changes before merging
@@ -90,7 +90,7 @@ func EnableHostsInfraMonitoring() bool { | |||
return GetOrDefaultEnv("ENABLE_INFRA_METRICS", "true") == "true" | |||
} | |||
|
|||
var KafkaSpanEval = GetOrDefaultEnv("KAFKA_SPAN_EVAL", "false") | |||
var KafkaSpanEval = GetOrDefaultEnv("KAFKA_SPAN_EVAL", "true") |
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.
intended change ?
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.
yes
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.
yes
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.
I am re-iterating my position on this as mentioned here #6661 (comment), this change should not be enabled by default. Please revert it.
With the trace v3, the bucket filter must exist. Otherwise, they can be really slow (it would have been better if it was suggested during review) #6666, @shivanshuraj1333, please sync with @nityanandagohain if you need to understand the bucketing. |
Supports trace_v3 now
Important
Update SQL queries to support
trace_v3
schema and enable Kafka span evaluation by default.sql.go
to usesignoz_traces.distributed_signoz_index_v3
instead ofv2
.serviceName
withresource_string_service$$name
andmsgSystem
withattribute_string_messaging$$system
in SQL queries.KafkaSpanEval
default value totrue
inconstants.go
.This description was created by
for 7460888. It will automatically update as commits are pushed.