update rename runtinename
@@ -37,7 +37,9 @@ public class FieldRenamer implements FlatMapFunction<Event, Event> {
@Override
public void flatMap(Event in,
Collector<Event> out) throws Exception {
- in.getFieldBySelector(oldPropertyName).rename(newPropertyName);
+ AbstractField<?> propertyValue = in.getFieldBySelector(oldPropertyName);
+ in.removeFieldBySelector(oldPropertyName);
+ in.addField(newPropertyName, propertyValue);
out.collect(in);
}
