다음을 통해 공유

Azure Portal로 HDInsight on AKS 클러스터에서 SSH(Secure Shell)를 사용하여 Apache Flink® CLI 클라이언트에 액세스

  • 아티클

참고 항목

2025년 1월 31일에 Azure HDInsight on AKS가 사용 중지됩니다. 2025년 1월 31일 이전에 워크로드가 갑자기 종료되지 않도록 워크로드를 Microsoft Fabric 또는 동등한 Azure 제품으로 마이그레이션해야 합니다. 구독의 나머지 클러스터는 호스트에서 중지되고 제거됩니다.

사용 중지 날짜까지 기본 지원만 사용할 수 있습니다.

Important

이 기능은 현지 미리 보기로 제공됩니다. Microsoft Azure 미리 보기에 대한 보충 사용 약관에는 베타 또는 미리 보기로 제공되거나 아직 일반 공급으로 릴리스되지 않은 Azure 기능에 적용되는 더 많은 약관이 포함되어 있습니다. 이 특정 미리 보기에 대한 자세한 내용은 Azure HDInsight on AKS 미리 보기 정보를 참조하세요. 질문이나 기능 제안이 있는 경우 세부 정보와 함께 AskHDInsight에 요청을 제출하고 Azure HDInsight 커뮤니티에서 추가 업데이트를 보려면 팔로우하세요.

이 예제에서는 Azure Portal에서 SSH를 사용하여 HDInsight on AKS 클러스터의 Apache Flink CLI 클라이언트에 들어가는 방법을 안내합니다. SQL 및 Flink DataStream을 모두 다룹니다.

필수 조건

  • Flink 클러스터를 만드는 동안 SSH를 선택해야 합니다.

Azure Portal에서 SSH에 연결

Flink 클러스터가 만들어지면 왼쪽 창에서 Secure Shell에 액세스하기 위한 설정 옵션을 확인할 수 있습니다.

POD를 만들고 webssh에 연결하는 방법을 보여 주는 스크린샷

SQL 클라이언트에 연결

디렉터리를 /opt/flink-webssh/bin으로 변경한 다음 ./sql-client.sh를 실행해야 합니다.

sql 클라이언트 파일을 찾는 방법 스크린샷

SQL 클라이언트를 실행하는 방법을 보여 주는 스크린샷

이제 Flink의 SQL 클라이언트에 있습니다.

몇 가지 테스트를 더 수행하려면 이 문서를 참조하세요.

Flink는 JAR 파일로 패키지된 프로그램을 실행하고 그 실행을 제어하는 CLI(명령줄 인터페이스) bin/flink를 제공합니다.

CLI는 SSH(Secure Shell)의 일부이며 실행 중인 JobManager에 연결하고 conf/flink-conf.yaml에 지정된 클라이언트 구성을 사용합니다.

작업 제출은 작업의 JAR을 SSH Pod에 업로드하고 작업 실행을 시작하는 것을 의미합니다. 이 문서의 예를 설명하기 위해 examples/streaming/StateMachineExample.jar과 같은 장기 실행 작업을 선택하겠습니다.

참고 항목

종속성을 관리하기 위해 작업에 대한 fat jar을 빌드하고 제출할 것으로 기대됩니다.

  • ABFS에서 webssh로 fat job jar을 업로드합니다.

  • 사용 사례에 따라 flink-client-configs에서 Flink 구성 관리를 사용하여 클라이언트 구성을 편집해야 합니다.

  • StateMachineExample.jar을 실행하겠습니다.

    ./bin/flink run \
    --detached \
    ./examples/streaming/StateMachineExample.jar

참고 항목

--detached를 사용하여 작업을 제출하면 제출이 완료된 후 명령이 반환됩니다. 출력에는 새로 제출된 작업의 ID가 포함됩니다.

참조