


Kenapa ia melaporkan kesilapan ketika mengemukakan pekerjaan pyfliin di benang?
Apr 19, 2025 pm 02:06 PMPenyerahan Pekerja
Apabila mengemukakan pekerjaan PyFliink menggunakan benang, anda mungkin menghadapi ralat di mana skrip Python tidak dijumpai, seperti:
<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>
Ini biasanya berlaku apabila menggunakan arahan berikut:
./flink Run-Application -t Benang-Application \ -dyarn.application.name = Flinkcdctestpython \ -dyarn.provided.lib.dirs = "hdfs: // nameservice1/pyflink/flink-dist-181" \ -Pyarch hdfs: //nameservice1/pyfliink/pyfliink181.zip \ -pyclientexec pyfliink181.zip/pyfliink181/bin/python \ -pyexec pyfliink181.zip/pyfliink181/bin/python \ -py hdfs: //nameservice1/pyflink/wc2.py
Sebaliknya, penyerahan pekerjaan Java biasanya tidak menghadapi masalah:
./flink Run-Application -t Benang-Application \ -djobmanager.memory.process.size = 1024m \ -dtaskmanager.memory.process.size = 1024m \ -dyarn.application.name = Flinkcdctest \ -dyarn.provided.lib.dirs = "hdfs: // nameservice1/pyflink/flink-dist-181" \ hdfs: //nameservice1/pyflink/statemachineexample.jar
Pekerjaan Java berjaya diserahkan, menunjukkan bahawa konfigurasi HDFS adalah betul. Masalahnya ialah laluan skrip Python atau konfigurasi pekerjaan Pyfliink.
Langkah penyelesaian masalah dan penyelesaian
Sahkan Laluan Skrip Python: Gunakan
hdfs dfs -ls hdfs://nameservice1/pyflink/wc2.py
wc2.py
Jika ia tidak wujud, pastikan skrip dimuat naik ke jalan dengan betul.Semak Konfigurasi PyFliink: Periksa semula parameter
-pyarch
,-pyclientexec
dan-pyexec
parameter untuk memastikan mereka menunjuk tepat kepada persekitaran PyFliink dan penterjemah Python.pyflink181.zip
mesti mengandungi semua perpustakaan python yang diperlukan dan persekitaran pelaksanaan.Isu Kebenaran: Gunakan
hdfs dfs -ls -h hdfs://nameservice1/pyflink/wc2.py
untuk melihat kebenaran HDFS skrip. Sekiranya kebenaran tidak mencukupi, gunakanhdfs dfs -chmod 755 hdfs://nameservice1/pyflink/wc2.py
untuk mengubahsuai keizinan untuk memastikan pengguna benang dan flink telah membaca kebenaran.Analisis log: Dayakan pembalakan terperinci flink dan benang, menganalisis log ralat untuk maklumat ralat yang lebih spesifik dan di mana ia berlaku.
Keserasian Alam Sekitar Python: Pastikan versi Python yang digunakan oleh PyFliink selaras dengan versi yang digunakan semasa membangunkan skrip, dan mengelakkan versi yang tidak serasi yang menyebabkan skrip tidak diiktiraf atau dilaksanakan.
Melalui langkah -langkah di atas, masalah penyelesaian masalah secara sistematik dan menyesuaikan konfigurasi mengikut keadaan sebenar, anda dapat menyelesaikan masalah yang skrip Python tidak dapat dijumpai apabila kerja Pyflik diserahkan pada benang. Sekiranya masalah berterusan, berikan maklumat log yang lebih terperinci dan benang untuk analisis lanjut.
Atas ialah kandungan terperinci Kenapa ia melaporkan kesilapan ketika mengemukakan pekerjaan pyfliin di benang?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

Alat AI Hot

Undress AI Tool
Gambar buka pakaian secara percuma

Undresser.AI Undress
Apl berkuasa AI untuk mencipta foto bogel yang realistik

AI Clothes Remover
Alat AI dalam talian untuk mengeluarkan pakaian daripada foto.

Clothoff.io
Penyingkiran pakaian AI

Video Face Swap
Tukar muka dalam mana-mana video dengan mudah menggunakan alat tukar muka AI percuma kami!

Artikel Panas

Alat panas

Notepad++7.3.1
Editor kod yang mudah digunakan dan percuma

SublimeText3 versi Cina
Versi Cina, sangat mudah digunakan

Hantar Studio 13.0.1
Persekitaran pembangunan bersepadu PHP yang berkuasa

Dreamweaver CS6
Alat pembangunan web visual

SublimeText3 versi Mac
Perisian penyuntingan kod peringkat Tuhan (SublimeText3)

Topik panas

DAO adalah organisasi autonomi yang dimiliki dan diuruskan oleh ahli komuniti dan secara automatik menguatkuasakan peraturan melalui kontrak pintar. 1. Ia tidak mempunyai pengurusan tradisional, dan keputusan diputuskan oleh pengundian kolektif; 2. Tanda -tanda tadbir urus memberi ahli hak mengundi, lebih banyak token, semakin besar beratnya; 3. Cadangan dimulakan dan dipilih oleh masyarakat, dan akan dilaksanakan secara automatik oleh kontrak pintar setelah menerima sokongan majoriti. Ciri -ciri terasnya termasuk desentralisasi, autonomi dan ketelusan, dan semua peraturan dan aliran modal terbuka dan boleh diadili. Kepentingan DAO adalah untuk mewujudkan model kerjasama yang lebih adil, cekap dan kohesif, memecahkan sekatan serantau dan identiti, dan meningkatkan kecekapan dan kecekapan operasi.

Kenaikan bulan Julai Bitcoin adalah hasil daripada kesan gabungan pelbagai faktor, termasuk persekitaran makroekonomi yang lebih baik, peningkatan keyakinan terhadap pelabur institusi dan pemulihan dalam sentimen pasaran. 1. Kelembapan Fed dalam kenaikan kadar faedah melemahkan daya tarikan dolar AS, dan penyejukan inflasi mencetuskan jangkaan peralihan dasar monetari; 2. Permohonan BlackRock untuk Bitcoin ETF meningkatkan keyakinan pasaran, menunjukkan bahawa sejumlah besar dana institusi boleh mengalir masuk; 3. Kejayaan teknikal tahap rintangan utama menarik peniaga untuk mengambil bahagian, dan perubahan dalam hubungan bekalan dan permintaan peningkatan harga sokongan selanjutnya.

Di Python, kaedah melintasi tupel dengan gelung termasuk secara langsung melelehkan unsur -unsur, mendapatkan indeks dan elemen pada masa yang sama, dan memproses tuple bersarang. 1. Gunakan gelung untuk terus mengakses setiap elemen dalam urutan tanpa menguruskan indeks; 2. Gunakan penghitungan () untuk mendapatkan indeks dan nilai pada masa yang sama. Indeks lalai adalah 0, dan parameter permulaan juga boleh ditentukan; 3. Di samping itu, tuple tidak berubah dan kandungan tidak dapat diubah suai dalam gelung. Nilai yang tidak diingini boleh diabaikan oleh \ _. Adalah disyorkan untuk memeriksa sama ada tuple kosong sebelum melintasi untuk mengelakkan kesilapan.

Fungsi tulen dalam Python merujuk kepada fungsi yang sentiasa mengembalikan output yang sama tanpa kesan sampingan yang diberikan input yang sama. Certinya termasuk: 1. Determinisme, iaitu, input yang sama selalu menghasilkan output yang sama; 2. Tiada kesan sampingan, iaitu, tiada pembolehubah luaran, tiada data input, dan tiada interaksi dengan dunia luar. Sebagai contoh, Defadd (a, b): Returna B adalah fungsi tulen kerana tidak kira berapa kali menambah (2,3) dipanggil, ia sentiasa mengembalikan 5 tanpa mengubah kandungan lain dalam program ini. Sebaliknya, fungsi yang mengubahsuai pembolehubah global atau menukar parameter input adalah fungsi bukan tujuan. Kelebihan fungsi tulen adalah: lebih mudah untuk diuji, lebih sesuai untuk pelaksanaan serentak, hasil cache untuk meningkatkan prestasi, dan boleh dipadankan dengan baik dengan alat pengaturcaraan berfungsi seperti MAP () dan penapis ().

Direktori akar web lalai Apache adalah/var/www/html dalam kebanyakan pengagihan Linux. Ini kerana pelayan Apache menyediakan fail dari direktori akar dokumen tertentu. Jika konfigurasi tidak disesuaikan, sistem seperti Ubuntu, CentOS, dan Fedora menggunakan/var/www/html, manakala macOS (menggunakan homebrew) biasanya/usr/local/var/www, dan windows (xampp) adalah c: \ xampp \ htdocs; Untuk mengesahkan laluan semasa, anda boleh menyemak fail konfigurasi Apache seperti httpd.conf atau apache2.conf, atau buat p dengan phpinfo ()

Ifelse adalah infrastruktur yang digunakan dalam Python untuk penghakiman bersyarat, dan blok kod yang berlainan dilaksanakan melalui kesahihan keadaan. Ia menyokong penggunaan ELIF untuk menambah cawangan apabila penghakiman pelbagai syarat, dan lekukan adalah kunci sintaks; Jika num = 15, program itu mengeluarkan "nombor ini lebih besar daripada 10"; Sekiranya logik tugasan diperlukan, pengendali ternary seperti status = "dewasa" ifage> = 18else "kecil" boleh digunakan. 1. Ifelse memilih laluan pelaksanaan mengikut keadaan yang benar atau palsu; 2. ELIF boleh menambah pelbagai cawangan keadaan; 3. Indentasi menentukan pemilikan kod, kesilapan akan membawa kepada pengecualian; 4. Operator Ternary sesuai untuk senario tugasan mudah.

Ya, apythonclasscanhavemulleConstructorsThoughalternetechniques.1.usedefaultargumentsIntheS

Di Python, walaupun tidak ada kata kunci akhir terbina dalam, ia boleh mensimulasikan kaedah yang tidak dapat dilalui melalui penulisan semula nama, pengecualian runtime, penghias, dan lain-lain. 2. Hakim jenis pemanggil dalam kaedah dan buang pengecualian untuk mencegah penetapan semula subclass; 3. Gunakan penghias tersuai untuk menandakan kaedah sebagai muktamad, dan periksa ia digabungkan dengan metaclass atau penghias kelas; 4. Tingkah laku boleh dikemas sebagai sifat harta untuk mengurangkan kemungkinan diubahsuai. Kaedah ini memberikan pelbagai perlindungan, tetapi tidak satu pun dari mereka menyekat tingkah laku liputan.
