自定义flink jobId，如果传了jobId 就用指定的jobId,如果没传就使用flink自动生成的jobId
Aperta
feature-request
- Lingua principale
- Java
- Stelle
- 4.1k
- Fork
- 1.7k
- Metriche di merge delle PR
- Nessuna PR unita negli ultimi 30g
Descrizione
自定义flink jobId，如果传了jobId 就用指定的jobId,如果没传就使用flink自动生成的jobId
Guida per i contributori
Apri la guida per i contributori
Direzione di ricerca
Inizia individuando il punto di ingresso per la sottomissione dei job Flink e tracciando come viene selezionato attualmente l’ID del job. Verifica entrambi i percorsi: un ID fornito deve essere mantenuto, mentre un ID omesso deve continuare a utilizzare l’ID generato da Flink; conferma il comportamento con i test esistenti pertinenti o con una sottomissione minima di un job.
Scritto dal modello di indicizzazione a partire dal testo della issue.
Valutazione
- Stack tecnologico
- java
- Ambito
- stream-processing
- Tipo di issue
- Funzionalità
- Difficoltà
- 4/5
- Tempo stimato
- 3-5 giorni
- Stato di attività
- Ferma
- Chiarezza
- Abbastanza chiara
- Idoneità per principianti
- 35/100