


Pourquoi signale-t-il une erreur lors de la soumission d'un travail de pyflink sur le fil?
Apr 19, 2025 pm 02:06 PMLa soumission de travail Pyflink a échoué sur le fil: analyse des causes des scripts et solutions Python manquants
Lors de la soumission d'un travail pyflink à l'aide du fil, vous pouvez rencontrer une erreur dans laquelle le script Python n'est pas trouvé, tel que:
<code>2024-05-24 16:38:02,030 info org.apache.flink.client.python.pythondriver [] - pyflink181.zip/pyflink181/bin/python: can't open file 'hdfs://nameservice1/pyflink/wc2.py': [errno 2] no such file or directory</code>
Cela se produit généralement lorsque vous utilisez les commandes suivantes:
./flink run-application -t yarn-application \ -Dyarn.Application.Name = FlinkcdCTestpython \ -Dyarn.Provided.lib.Dirs = "HDFS: // Namesservice1 / Pyflink / Flink-Dist-181" \ -pyarch hdfs: //nameservice1/pyflink/pyflink181.zip \ -pyclientexec pyflink181.zip/pyflink181/bin/python \ -pyexec pyflink181.zip/pyflink181/bin/python \ -py hdfs: //nameservice1/pyflink/wc2.py
En revanche, la soumission de Java n'a généralement pas de problèmes:
./flink run-application -t yarn-application \ -djobmanager.memory.process.size = 1024m \ -dtaskmanager.memory.process.size = 1024m \ -Dyarn.Application.Name = FlinkCDCTEST \ -Dyarn.Provided.lib.Dirs = "HDFS: // Namesservice1 / Pyflink / Flink-Dist-181" \ hdfs: //nameservice1/pyflink/statemachineexample.jar
Le travail Java a été soumis avec succès, indiquant que la configuration HDFS est correcte. Le problème est le chemin de script Python ou la configuration du travail Pyflink.
étapes de dépannage et de résolution
Vérifiez le chemin de script Python: utilisez
hdfs dfs -ls hdfs://nameservice1/pyflink/wc2.py
pour vérifier si le scriptwc2.py
existe dans le chemin HDFS spécifié. S'il n'existe pas, assurez-vous que le script est téléchargé correctement sur le chemin.Vérifiez la configuration de Pyflink: Double-vérifiez
-pyarch
,-pyclientexec
et-pyexec
pour s'assurer qu'ils pointent exactement vers l'environnement Pyflink et l'interpréteur Python.pyflink181.zip
doit contenir toutes les bibliothèques Python et les environnements d'exécution nécessaires.Problème des autorisations: Utilisez
hdfs dfs -ls -h hdfs://nameservice1/pyflink/wc2.py
pour afficher les autorisations HDFS du script. Si les autorisations sont insuffisantes, utilisezhdfs dfs -chmod 755 hdfs://nameservice1/pyflink/wc2.py
pour modifier les autorisations pour garantir que les utilisateurs de fil et de Flink ont ??lu les autorisations.Analyse du journal: activer la journalisation détaillée de Flink et du fil, analyser les journaux d'erreur pour des informations d'erreur plus spécifiques et où elle se produit.
Compatibilité de l'environnement Python: assurez-vous que la version Python utilisée par Pyflink est cohérente avec la version utilisée lors du développement de scripts et évitez les versions incompatibles qui provoquent le non-reconnu ou l'exécution du script.
Grace aux étapes ci-dessus, dépannage systématiquement le problème et ajustant la configuration en fonction de la situation réelle, vous pouvez résoudre le problème que le script Python ne peut être trouvé lorsque le travail Pyflink est soumis sur le fil. Si le problème persiste, fournissez des informations de journal de flux et de fil plus détaillées pour une analyse plus approfondie.
Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!

Outils d'IA chauds

Undress AI Tool
Images de déshabillage gratuites

Undresser.AI Undress
Application basée sur l'IA pour créer des photos de nu réalistes

AI Clothes Remover
Outil d'IA en ligne pour supprimer les vêtements des photos.

Clothoff.io
Dissolvant de vêtements AI

Video Face Swap
échangez les visages dans n'importe quelle vidéo sans effort grace à notre outil d'échange de visage AI entièrement gratuit?!

Article chaud

Outils chauds

Bloc-notes++7.3.1
éditeur de code facile à utiliser et gratuit

SublimeText3 version chinoise
Version chinoise, très simple à utiliser

Envoyer Studio 13.0.1
Puissant environnement de développement intégré PHP

Dreamweaver CS6
Outils de développement Web visuel

SublimeText3 version Mac
Logiciel d'édition de code au niveau de Dieu (SublimeText3)

Sujets chauds

Répertoire Qu'est-ce que Bitcoin? Comment fonctionne Bitcoin? Pourquoi Bitcoin n'est-il pas évolutif? Qu'est-ce que le BIP (Bitcoin Improvement Proposition)? Qu'est-ce que la mise à jour Bitcoin Taproot? Pay to Taproot (P2TR): Avantages de la racine de tapoot: Avantages de la confidentialité Sauve-Savation Conclusion de mise à niveau de la sécurité: ?BitCoin est la première monnaie numérique qui peut envoyer et recevoir des fonds sans utiliser de tiers. étant donné que Bitcoin est un logiciel, comme tout autre logiciel, il a besoin de mises à jour et de corrections de bogues. Bitcoin Taproot est une telle mise à jour qui introduit de nouvelles fonctionnalités de Bitcoin. La crypto-monnaie est maintenant un sujet br?lant. Les gens en parlent depuis des années, mais maintenant, les prix augmentant rapidement, tout le monde décide de se joindre et d'investir en eux. Message

PythonCanBeoptimizedFormemory-Boundoperations AdreductoverHeadHroughGenerators, EfficientDatastructures et ManagingObjectliFetimes.first, useGeneratorsInSteadofListStoproceSlargedataseSeItematatime, EvitingLoadingEnteryToMeToMeMory.

Le montant total de Bitcoin est de 21 millions, ce qui est une règle immuable déterminée par la conception d'algorithmes. 1. Grace au mécanisme de preuve de travail et à la règle d'émission de la moitié de tous les 210 000 blocs, l'émission de nouvelles pièces a diminué de fa?on exponentielle, et l'émission supplémentaire a finalement été arrêtée vers 2140. 2. Le montant total de 21 millions est dérivé de la résumé de la séquence à échelle égale. La récompense initiale est de 50 Bitcoins. Après chaque réduction de moitié, la somme de la somme converge à 21 millions. Il est solidifié par le code et ne peut pas être falsifié. 3. Depuis sa naissance en 2009, les quatre événements de réduction de moitié ont considérablement entra?né des prix, vérifié l'efficacité du mécanisme de rareté et constitué un consensus mondial. 4. Le total fixe donne une anti-inflation bitcoin et une métallicité jaune numérique, sa valeur marchande dépassant 2,1 billions de dollars en 2025, devenant le cinquième plus grand capital au monde

Installez PYODBC: utilisez la commande PiPInstallpyodbc pour installer la bibliothèque; 2. Connectez SQLServer: utilisez la cha?ne de connexion contenant le pilote, le serveur, la base de données, l'UID / PWD ou TrustEd_Connection via la méthode pyoDBC.Connect () et prendre en charge l'authentification SQL ou l'authentification Windows respectivement; 3. Vérifiez le pilote installé: exécutez pyodbc.Drivers () et filtrez le nom du pilote contenant ?SQLServer? pour vous assurer que le nom du pilote correct est utilisé tel que ?ODBCDriver17 pour SQLServer?; 4. Paramètres clés de la cha?ne de connexion

Les pièces stables sont des crypto-monnaies dont la valeur est liée à des actifs stables tels que le dollar américain. Ils visent à résoudre le problème des grandes fluctuations des prix telles que le bitcoin. Il existe trois types principaux: 1. Les stablescoins garanties de la monnaie fiduciaire, tels que l'USDT et l'USDC, sont soutenues par les réserves de l'émetteur de monnaies fiduciaires équivalentes; 2. Les stablescoins garanties en argent, tels que DAI, sont générés par des actifs cryptographiques trop collatéralisés; 3. Stablecoins algorithmiques, s'appuyant sur des contrats intelligents pour ajuster l'offre et la demande pour maintenir la stabilité des prix. La raison pour laquelle les stablecoins peuvent changer l'avenir est: 1. Il s'agit d'un pont reliant le financement traditionnel et le monde de la cryptographie, réduisant le seuil pour l'entrée des utilisateurs; 2. Réaliser des paiements et des règlements mondiaux efficaces et à faible co?t, améliorant considérablement l'efficacité du flux de capital transfrontalier; 3. Il forme la pierre angulaire de la finance décentralisée (DEFI), pour les prêts, les transactions, etc.

L'introduction à l'arbitrage statistique L'arbitrage statistique est une méthode commerciale qui capture l'inadéquation des prix sur le marché financier basé sur des modèles mathématiques. Sa philosophie principale découle de la régression moyenne, c'est-à-dire que les prix des actifs peuvent s'écarter des tendances à long terme à court terme, mais reviendront éventuellement à leur moyenne historique. Les traders utilisent des méthodes statistiques pour analyser la corrélation entre les actifs et rechercher des portefeuilles qui changent généralement de manière synchrone. Lorsque la relation de prix de ces actifs est anormalement déviée, des opportunités d'arbitrage se présentent. Sur le marché des crypto-monnaies, l'arbitrage statistique est particulièrement répandu, principalement en raison de l'inefficacité et des fluctuations drastiques du marché lui-même. Contrairement aux marchés financiers traditionnels, les crypto-monnaies fonctionnent 24h / 24 et leurs prix sont très susceptibles de briser les nouvelles, les sentiments des médias sociaux et les améliorations technologiques. Cette fluctuation des prix constante crée fréquemment un biais de prix et fournit aux arbitrageurs un

La stratégie de choix des altcoins sur un marché haussier, et l'achat de BTC sur un marché baissier est établi car il est basé sur les lois cycliques du sentiment du marché et des attributs d'actifs: 1. Sur le marché haussier, les altcoins sont sujets à des rendements élevés en raison de leur petite valeur de marché, de leur prime narrative et de leur prime de liquidité; 2. Sur le marché des ours, le bitcoin est devenu le premier choix pour l'aversion au risque en raison de la rareté, de la liquidité et du consensus institutionnel; 3. Les données historiques montrent que l'augmentation des altcoins du marché haussier en 2017 a dépassé celle du bitcoin, et la baisse du marché baissier en 2018 était également plus élevée. En 2024, les fonds sur le marché volatil seront encore concentrés dans la BTC; 4. Le contr?le des risques doit être vigilant sur la manipulation des pièges, l'achat en bas et la gestion de la position. Il est recommandé que la position des altcoins sur un marché haussier ne soit pas dépassé 30% et que les avoirs de position de BTC sur un marché baissier puissent être augmentés à 70%; 5. à l'avenir, en raison de l'institutionnalisation, de l'innovation technologique et de l'environnement macroéconomique, la stratégie doit être ajustée dynamiquement pour s'adapter à l'évolution du marché.

Quelle est l'émission des pièces de monnaie NCT du répertoire? Analyse de l'émission de monnaie NCT et volume de circulation Volume NCT INTRODUCTION Volume d'émission totale de la pièce NCT L'impact du volume de circulation de la pièce NCT sur le marché 1. La relation entre l'offre et le prix 2. La relation entre la circulation et la profondeur du marché 3. Le contr?le de l'offre à long terme et de l'inflation du plan d'émission future de NCT Coin FAQ Stémoire What est le volume d'établissement de NCT Coin? L'analyse de l'émission et de la liquidité de la pièce NCT dans le champ de crypto-monnaie, la pièce NCT (Nucleustanked) est un actif numérique avec un potentiel élevé, et sa délivrance et sa liquidité ont toujours été les principaux problèmes auxquels les investisseurs et les analystes de marché font attention. N
