• English日本語한국어
  • 로그인지금 시작하기

이 한글 문서는 사용자의 편의를 위해 기계 번역되었습니다.

영문본과 번역본이 일치하지 않는 경우 영문본이 우선합니다. 보다 자세한 내용은 이 페이지를 방문하시기 바랍니다.

문제 신고

아파치 플링크 통합

Apache Flink 대시보드를 사용하면 로그를 쉽게 추적하고 계측 소스를 주시하고 모든 애플리케이션 인스턴스의 가동 시간 및 가동 중지 시간에 대한 개요를 얻을 수 있습니다. 인프라 에이전트와 Prometheus OpenMetrics 통합으로 구축된 Flink OpenMetrics 엔드포인트 스크래핑을 활용하여 가장 중요한 모든 데이터를 한 곳에서 볼 수 있습니다.

Flink를 New Relic으로 설정하면 데이터가 이와 같은 대시보드에 바로 표시됩니다.

인프라 에이전트 및 Prometheus OpenMetrics 통합 설치

Flink 데이터를 New Relic으로 가져오기 전에 먼저 인프라 에이전트를 설치한 다음 Prometheus OpenMetrics를 설치하여 메트릭을 노출하십시오.

Apache Flink용 Prometheus OpenMetrics 구성

Prometheus OpenMetrics를 설치한 후 nri-prometheus-config.yml 파일을 구성해야 합니다. 구성 파일은 nri-prometheus 리포지토리의 스니펫과 일치해야 합니다.

integrations:
- name: nri-prometheus
config:
standalone: false
# Defaults to true. When standalone is set to `false`, `nri-prometheus` requires an infrastructure agent to send data.
emitters: infra-sdk
# When running with infrastructure agent emitters will have to include infra-sdk
cluster_name: "YOUR_CLUSTER_NAME_HERE"
# Match the name of your cluster with the name seen in New Relic.
targets:
- description: "YOUR_DESCRIPTION_HERE"
urls: ["'job-cluster:9249', 'taskmanager1:9249', 'taskmanager2:9249'"]
# tls_config:
# ca_file_path: "/etc/etcd/etcd-client-ca.crt"
# cert_file_path: "/etc/etcd/etcd-client.crt"
# key_file_path: "/etc/etcd/etcd-client.key"
verbose: false
# Defaults to false. This determines whether or not the integration should run in verbose mode.
audit: false
# Defaults to false and does not include verbose mode. Audit mode logs the uncompressed data sent to New Relic and can lead to a high log volume.
# scrape_timeout: "YOUR_TIMEOUT_DURATION"
# `scrape_timeout` is not a mandatory configuration and defaults to 30s. The HTTP client timeout when fetching data from endpoints.
scrape_duration: "5s"
# worker_threads: 4
# `worker_threads` is not a mandatory configuration and defaults to `4` for clusters with more than 400 endpoints. Slowly increase the worker thread until scrape time falls between the desired `scrape_duration`. Note: Increasing this value too much results in huge memory consumption if too many metrics are scraped at once.
insecure_skip_verify: false
# Defaults to false. Determins if the integration should skip TLS verification or not.
timeout: 10s

수동으로 로그 전달 설정

인프라 에이전트가 Flink 대시보드에 로그를 보내야 하지만 로그 전달을 수동으로 설정해야 할 수도 있습니다. 이것을하기 위해:

  • logging.yml 파일로 이동합니다.
  • 파일의 아무 곳에나 다음 스니펫을 추가합니다.
- name: flink-log
file: /home/flink-virtualbox/flink/build-target/log/flink_taskmanager.log
attributes:
logtype: flink-logs

Apache Flink 빠른 시작을 설치하면 New Relic에서 중요한 Apache Flink 데이터를 볼 수 있습니다. New Relic에서 대시보드를 찾으려면 one.newrelic.com > Dashboards 로 이동한 다음 Apache Flink를 선택합니다. 이제 데이터를 쿼리할 수 있습니다. 예를 들어:

FROM Metric SELECT sum(flink_jobmanager_job_totalNumberOfCheckpoints) AS 'Total Number of Checkpoints'

다음은 뭐지?

Apache Flink 대시보드를 추가로 사용자 정의하려면 NRQL 쿼리 작성 및 관리에 대해 자세히 알아볼 수 있습니다. New Relic UI에서:

Copyright © 2023 New Relic Inc.

This site is protected by reCAPTCHA and the Google Privacy Policy and Terms of Service apply.