代码调整

eagleEye-flink_kafka/src/main/java/com/flink/achieve/doris/SimiFriendsAchi.java

@@ -277,7 +277,7 @@ public class SimiFriendsAchi extends SourceCommonBase implements Serializable {
 				        row.setField(1, StringData.fromString(friendCid));//friend_cid
 				        row.setField(2, (int)cidTotal);//cid_total
 				        row.setField(3, (int)friendCidTotal);//friend_cid_total
-				        row.setField(4, String.join(", ", overlapCids));//overlap_cid
+				        row.setField(4, StringData.fromString(String.join(", ", overlapCids)));//overlap_cid
 				        row.setField(5, overlapCids == null ? 0 : overlapCids.size());//overlap_total
 				        row.setField(6, (int)validIdCount);//overlap_third_id_total
 				        row.setField(7, overlapWhitelist == null ? 0 : overlapWhitelist.size());//overlap_whitelist_total

eagleEye-flink_kafka/src/main/resources/application.properties

@@ -3,7 +3,7 @@
 #kafka.bootstrapServers=168.138.185.142:9092,213.35.103.223:9092,129.150.49.247:9092
 kafka.bootstrapServers=10.0.0.29:9092,10.0.0.87:9092,10.0.0.18:9092
 
-doris.jdbc_url=jdbc:mysql://10.0.0.105 9030/bi?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8&nullCatalogMeansCurrent=true
+doris.jdbc_url=jdbc:mysql://10.0.0.105:9030/bi?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8&nullCatalogMeansCurrent=true
 #doris.jdbc_url=jdbc:mysql://140.245.112.44:9030/bi?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8&nullCatalogMeansCurrent=true
 #doris.fe=140.245.112.44:8030
 doris.fe=10.0.0.105:8030