I think I have already done that in my custom sink. @Override public String[] getFieldNames() { return this.fieldNames; }
@Override public TypeInformation<?>[] getFieldTypes() { return this.fieldTypes; } @Override public TableSink<Row> configure(String[] fieldNames, TypeInformation<?>[] fieldTypes) { this.fieldNames = fieldNames; this.fieldTypes = fieldTypes; return this; } -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/