Auto Instrumentation not Supporting Flink #13686
Labels
contribution welcome
Request makes sense, maintainers probably won't have time, contribution would be welcome
enhancement
New feature or request
new instrumentation
Is your feature request related to a problem? Please describe.
Use java annotation @WithSpan and @SpanAttribute in flink application operators(e.g. keyby operator) will create new trace rather than use same trace, seems ot java agent is not able to injectt trace_id span_id into flink data piplines.
Suggestions:
e.g. flink operator will be source from kafka -> filter(@WithSpan) -> keyby ->map(@WithSpan) ->sink
same massage will generate new traces in fliter operator and map operator when message pass throught flink pippline, but I want same msg generated spans just have one trace_id
Describe the solution you'd like
Describe alternatives you've considered
No response
Additional context
No response
The text was updated successfully, but these errors were encountered: