什么时候支持flinkcdc通过stream load直接同步增删改的数据到StarRocks呢

[U_1679658328527_8276]

你好，我是用datastream操作的，直接在JSON添加字段，没法实现flink cdc执行删除操作，可以借鉴下你的代码么

[jingdan]

JSON里面可以加个key，{’__op’:‘1’},1表示删除，默认是0，表示upsert

[jialebi]

刚登上论坛，后面的朋友可以参考下我的源码，在这个博客里
http://t.csdnimg.cn/JKKY3

[jialebi]

您好我遇见了新的问题，还望指教；
问题：在使用streamload导入数据的时候，我使用的模拟csv字符串使用httpClient请求api:http://ip:port/api/db/table/_stream_load
当ip和port(8030)是FE的时候总是出现一次成功一次失败（必现），失败的信息Bad Request.
text is empty (possibly HTTP/0.9)；如果我把ip和port使用指定BE的时候port(8040)是可以正常执行的；
环境：java1.8,starrocks:2.5.14
关键代码：

HttpPut put = new HttpPut(loadUrl);
        StringEntity entity = new StringEntity(content, StandardCharsets.UTF_8);

        put.setHeader(HttpHeaders.EXPECT, "100-continue");
        put.setHeader(HttpHeaders.AUTHORIZATION, basicAuthHeader(starrocksUser, starrocksPassword));
        put.setHeader("column_separator", ",");
        put.setHeader("label", label);
        put.setEntity(entity);