다음을 통해 공유

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

  • 아티클

중요하다

AKS의 Azure HDInsight는 2025년 1월 31일에 사용 중지되었습니다. 이 공지 로에 대해 자세히 알아보세요.

워크로드가 갑자기 종료되는 것을 방지하기 위해 워크로드를 Microsoft Fabric 또는 동등한 Azure 제품으로 워크로드를 마이그레이션해야 합니다.

중요하다

이 기능은 현재 미리 보기로 제공됩니다. Microsoft Azure 프리뷰에 대한 보충 사용 약관()에는 일반 공급이 되지 않은 베타, 프리뷰, 또는 미리 보기 단계의 Azure 기능에 적용되는 추가적인 법적 조건들이 포함되어 있습니다. 이 특정 미리 보기에 대한 정보는 Azure HDInsight on AKS 미리 보기 정보 를 참조하세요. 질문이나 기능 제안이 있으시면 AskHDInsight에 요청을 제출해 주시고, 더 많은 업데이트를 받으시려면 Azure HDInsight Community를 팔로우해 주세요.

이 예제에서는 Azure Portal에서 SSH를 사용하여 AKS 클러스터의 HDInsight에서 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(Command-Line 인터페이스) bin/flink 제공합니다.

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

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

메모

종속성을 관리하기 위해 작업용 팻 자르를 빌드하여 제출하는 것이 요구됩니다.

  • ABFS에서 webssh로 fat Job jar를 업로드합니다.

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

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

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

메모

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

참조