Hi guys,
I am trying to write to hdfs from streaming file sink. Where should I
provide the IP address of the name node ? Can I provide it as a part of the
flink-config.yaml file or should I provide it like this :

final StreamingFileSink<GenericRecord> sink = StreamingFileSink
        .forBulkFormat(hdfs://namenode:8020/flink/test,
ParquetAvroWriters.forGenericRecord(schema))

        .build();


Best,
Nick

Reply via email to