wormhole

wormhole copied to clipboard

when use mysql to store Wormhole feedback. Table: feedback_flow_stats ,column: topics default length: VARCHAR(200) is not enough when there is multi partition with one kafka topic. so es is a...

lordk911

目前场景sink端会有更新操作。是想要将统计的结果更新到sink namespace（mysql）。 “flow”->"Sink Config"配置了：{"mutation_type":"iud"}。 而“Source Schema Config”->“UMS_Extension"这里的ums_op_字段应该如何配置？

easonliu30624700

代码js css 都是压缩的，有没有压缩的版本吗

1450031369

我kafka里的数据都是原始的nignx日志数据, 没有schema, 比如 "a,b,c,d,e,f" 这种按逗号分隔的格式, 可以将这种数据放到wormhole里在处理成table吗?

bravecharge

1、场景 新建job任务 source namesapce为 kafka，sink namespace为parquet

lblv

0.6.2 创建job时，version列表为空，提示hdfs无该namespace的数据

1

版本：0.6.2 验证场景：通过job，实现mysql与mysql之间数据同步 操作步骤 1、创建实例、数据库、命名空间 2、创建项目，分配权限 3、进入项目，创建JOB  选完命名空间后，后面version下来列表为空，后直接提示hdfs无该namespace的数据。 后台跟踪调式发下：选完命名空间后，回去后台拉取该namespace在hdfs上的一个目录文件列表，这是什么逻辑。假设去拉取，这个文件列表的写入位置在哪？

flofei

2020-02-26 10:25:43 [riderActorSystem-akka.actor.default-dispatcher-5] ERROR edp.rider.yarn.YarnStatusQuery[198] - query yarn resourceManager http://localhost:8088/ws/v1/cluster/info haState failed java.net.ConnectException: Connection refused (Connection refused) at java.net.PlainSocketImpl.socketConnect(Native Method) at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350) at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206) at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188) at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) at java.net.Socket.connect(Socket.java:589)...

daydayup-zyn

对于一个嵌套类型的Json,如果不选外层的字段，流程序运行时解析的schema为空，排查问题困难，配置时应该加上校验  

lordk911

RT 是否考虑支持kafka SASL权限验证?

MarcelLeon

dfohyes