在同步过程中需要变换某个字段的值，但是没生效，请问如何修改

代码如下。功能就是像把phone字段的号码去掉中间4位同步出去，实际使用过程中还是原样同步过去了。

package com.alibaba.otter.node.extend.processor;

import com.alibaba.otter.shared.etl.model.EventColumn; import com.alibaba.otter.shared.etl.model.EventData;

public class PhoneUserEventProcessor extends AbstractEventProcessor {

public boolean process(EventData eventData) { for (EventColumn column : eventData.getColumns()) { //对手机号码进行转换处理 if(column.getColumnName().equalsIgnoreCase("phone")){ String oriphone = column.getColumnValue(); System.out.println("process column phone:"+oriphone); if(oriphone != null && oriphone.length() == 11){ column.setColumnValue(oriphone.substring(0, 3)+"****"+oriphone.substring(7)); } } }

return true;

}

原提问者GitHub用户 lixqhuoli