bigdata-spec

From ZooKeeper to ClickHouse Keeper Table is in readonly mode (zookeeper path: /clickhouse/tables/shard01/default/st_order_mt0722), Stack trace:

2

Hello： Clickhouse Version is 21.8.5， I want to try to migration **ZooKeeper to ClickHouse Keeper** but I can't insert data，the Error is  clickhouse keeper-converter --zookeeper-logs-dir /opt/module/zookeeper-3.7.0/zkData/version-2 --zookeeper-snapshots-dir /opt/module/zookeeper-3.7.0/zkData/version-2 --output-dir...

[SUPPORT] Upgrading to 0.11.1 resulting use delete of sparksql

6

The environment is CDH6.3.2 and Hudi is 0.11.1 I want to test delete of spark sql， there are 4 records in the table ，**vehicle_model_id is [100 101 102 105]** when...

[SUPPORT]Caused by: org.apache.hudi.exception.HoodieMetadataException: Failed to retrieve list of partition from metadata

2

Environment Description Hudi version : 0.11.0 Flink version : 1.13.1 Hive version : 2.1.1-cdh6.2.0 Hadoop version : 3.0.0-cdh6.2.0 Storage (HDFS/S3/GCS..) : HDFS Running on Docker? (yes/no) : no when I...

[BUG] <title> chproxy log is incorrect, how to solve it

1

 The time zone in the chproxy log is incorrect, how to solve it？

Hello，May I ask you some questions? I want to know this picture：  my version ：0.9.2 why show None？How to modify this show？ I run `datahub ingest -c ck_to_datahub_rest.yml` ```...

关于udf中transform里面日志不打印

1

``` public class UDTFSequenceFilter implements UDTF { @Override public void validate(UDFParameterValidator validator) { int childExpressionsSize = validator.getParameters().getChildExpressionsSize(); LOG.info("childExpressionsSize "+childExpressionsSize); List childExpressions = validator.getParameters().getChildExpressions(); LOG.info("childExpressions "+childExpressions); for (int i = 0;...

请教flink-sql-iotdb-connector连接器写入iotdb的sql案例

11

请问下: 看文档介绍从1.2开始支持flinksql的连接器了，但是无法引入该jar ``` org.apache.iotdb flink-sql-iotdb-connector ${iotdb.version} ``` maven仓库没有该jar？这个jar如何引入。 另外，flink-sql-iotdb-connector 的sql形式案例有没有？例如： ``` `-- register a MySQL table 'users' in Flink SQL CREATE TABLE MyUserTable ( id BIGINT, name STRING, age INT,...

iotdb无法写入无信号key的数据

1

各位好， 我是用版本iot版本1.1.0， 使用对齐方式消费kafka写入iotdb，发现如果字段不存在，则该条数据就查不到，程序也没任何错误 日志可以看到 org.apache.iotdb.session.Session - All values are null and this submission is ignored 比如： { "uuid": "10001", "GnsAlt": "5.0", "Longtude": "119.317833", "GPSts": "3" "event_time": "2023-10-26 15:45:40" } uuid为设备，GnssAlt...

关于iotdb集群搭建事宜请教

12

各位好， 近期准备使用iotdb搭建分布式集群，版本1.1.0，想配置3台机器3c3d，看了官网资料，存在如下疑问： 1.推荐使用哪种部署模式选型，**高性能分布式模式** 还是 **强一致分布式模式** 2.关于datanode的配置参数：**dn_target_config_node_list** 应该写一台种子ConfigNode 机器的ip和端口，还是把3台ConfigNode 的ip和端口都写上？ 3.关于启停， 启：先起种子，再起其他2台ConfigNode，然后再起三台datanode？ 停：停3台ConfigNode（这三台有一台是种子，种子要不要先停），再停datanode？ 谢谢各位。