트레이스

트레이스 (Traces)

Flink는 트레이스를 수집하고 외부 시스템으로 노출하는 추적(tracing) 시스템을 제공해요. 사용자 함수에서 Span을 보고하고, Flink가 보고하는 시스템 트레이스를 확인할 수 있어요.

출처: 문서

본문

Flink는 외부 시스템으로 트레이스를 수집·노출할 수 있는 추적 시스템을 제공해요.

트레이스 보고 (Reporting traces)

RichFunction을 확장하는 모든 사용자 함수에서 getRuntimeContext().getMetricGroup()을 호출해 추적 시스템에 접근할 수 있어요. 이 메서드는 MetricGroup 객체를 반환하며, 이를 통해 span 트리가 있는 새 단일 트레이스를 보고할 수 있어요.

단일 Span 보고 (Reporting single Span)

Span은 Flink에서 특정 시점에 특정 기간 동안 발생한 어떤 프로세스를 나타내며, TraceReporter에 보고돼요. Span을 보고하려면 MetricGroup#addSpan(SpanBuilder) 메서드를 사용할 수 있어요.

public class MyClass {
    void doSomething() {
        // (...)
        metricGroup.addSpan(
            Span.builder(MyClass.class, "SomeAction")
                .setStartTsMillis(startTs) // Optional
                .setEndTsMillis(endTs) // Optional
                .setAttribute("foo", "bar") // Optional
                .addChild(Span.builder(MyClass.class, "ChildAction") // Optional
                .addChildren(List.of(
                    Span.builder(MyClass.class, "AnotherChildAction")); // Optional
    }
}

Python에서 Span을 보고하는 것은 현재 지원되지 않아요.

Reporter

Flink의 trace reporter를 설정하는 방법에 대한 정보는 trace reporters 문서를 참고하세요.

시스템 트레이스 (System traces)

Flink는 아래 나열된 트레이스를 보고해요. 아래 표들은 일반적으로 5개의 컬럼을 가져요.

• "Scope" 컬럼은 해당 트레이스가 보고되는 범위가 무엇인지 설명해요.
• "Name" 컬럼은 보고된 트레이스의 이름을 설명해요.
• "Attributes" 컬럼은 주어진 트레이스와 함께 보고되는 모든 속성의 이름을 나열해요.
• "Description" 컬럼은 주어진 속성이 무엇을 보고하는지에 대한 정보를 제공해요.

체크포인팅 및 초기화 (Checkpointing and initialization)

Flink는 이벤트가 종료 상태인 COMPLETED 또는 FAILED에 도달하면 전체 체크포인트와 job 초기화 이벤트에 대해 단일 span 트레이스를 보고해요.

더 알아보기 (Learn more)

• Trace Reporters
• Metrics
• Events