Local Flink config läuft Standalone von IDE

Wenn ich eine Flink-App lokal direkt in Intellij ausführen möchte, aber Konfigurationsparameter angeben muss (z. B. fs.hdfs.hdfssite, um den S3-Zugriff einzurichten), können diese Konfigurationsparameter auch auf andere Weise bereitgestellt werdenExecutionEnvironment.createLocalEnvironment(conf)? Was ist, wenn ich @ verwenden möchtStreamExecutionEnvironment.getExecutionEnvironment? Kann ich eine Flink-Konfiguration in meinem Projekt haben und die lokale App darauf verweisen?

Ist das der richtige Weg? Oder möchten Sie Ihre IDE so einrichten, dass die App an eine echte lokale Flink-Instanz gesendet wird?

Antworten auf die Frage(4)

Ihre Antwort auf die Frage