Azure portalı ile AKS kümelerinde HDInsight üzerinde Secure Shell (SSH) kullanarak Apache Flink® CLI istemcisine erişme

Önemli

Bu özellik şu anda önizlemededir. Microsoft Azure Önizlemeleri için Ek Kullanım Koşulları, beta, önizleme aşamasında olan veya henüz genel kullanıma sunulmamış Azure özellikleri için geçerli olan daha fazla yasal hüküm içerir. Bu belirli önizleme hakkında bilgi için bkz . AKS üzerinde Azure HDInsight önizleme bilgileri. Sorular veya özellik önerileri için lütfen AskHDInsight'ta ayrıntıları içeren bir istek gönderin ve Azure HDInsight Topluluğu hakkında daha fazla güncelleştirme için bizi takip edin.

Bu örnek, Azure portalında SSH kullanarak AKS kümelerinde HDInsight'ta Apache Flink CLI istemcisinin nasıl girilmesine yol gösterir; hem SQL hem de Flink DataStream'i ele alacağız.

Önkoşullar

• Flink Kümesi oluşturulurken SSH seçmeniz gerekir

Azure portalından SSH'ye Bağlan

Flink kümesi oluşturulduktan sonra, sol bölmede Secure Shell'e erişmek için Ayarlar seçeneğini görebilirsiniz

Apache Flink SQL

SQL İstemcisi'ne Bağlan

Dizini /opt/flink-webssh/bin olarak değiştirmeniz ve ardından yürütmeniz gerekir ./sql-client.sh

Artık Flink üzerinde SQL İstemcisi'ne bağlısınız

Birkaç test daha gerçekleştirmek için bu belgeye bakın.

Apache Flink DataStream

Flink, JAR dosyası olarak paketlenmiş programları çalıştırmak ve bunların yürütülmesini denetlemek için bir Komut Satırı Arabirimi (CLI) bin/flink sağlar.

CLI bir parça Secure Shell 'dir (SSH) ve çalışan JobManager'a bağlanır ve adresinde conf/flink-conf.yamlbelirtilen istemci yapılandırmalarını kullanır.

bir iş göndermek, işin JAR dosyasını SSH pod'a yüklemek ve iş yürütmeyi başlatma anlamına gelir. Bu makaleye bir örnek göstermek için gibi examples/streaming/StateMachineExample.jaruzun süre çalışan bir iş seçiyoruz.

Not

Bağımlılıkları yönetmek için, beklenti iş için bir yağ jar oluşturmak ve göndermektir.

• ABFS'den webssh'e yağ işi jar'ını yükleyin.

• Kullanım örneğiniz temelinde, flink-client-configs altında Flink yapılandırma yönetimini kullanarak istemci yapılandırmalarını düzenlemeniz gerekir.

• StateMachineExample.jar çalıştıralım

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

Not

kullanarak işi --detached göndermek, gönderme tamamlandıktan sonra komutun döndürülmesiyle olur. Çıktı, yeni gönderilen işin kimliğini içerir.

Başvuru

• Flink SQL İstemcisi
• Apache, Apache Flink, Flink ve ilişkili açık kaynak proje adları Apache Software Foundation'ın (ASF) ticari markalarıdır.