[BUG] Flame Graph报500

[novvoo]

Search before asking

• [X] I had searched in the issues and found no similar feature requirement.

DeepFlow Component

Grafana Dashbaord

What you expected to happen

Distributed Tracing面板报错

How to reproduce

点击Distributed Tracing面板的Request查看服务的flame graph图，报错

DeepFlow version

deepflow v6.4版本

DeepFlow agent list

deepflow v6.4版本

Kubernetes CNI

calico cni

Operation-System/Kernel version

Linux 3.10.0-957.el7.x86_64 #1 SMP Thu Nov 8 23:39:32 UTC 2018 x86_64 x86_64 x86_64 GNU/Linux

Anything else

ClickHouse local version 24.2.1.2248 (official build)

helm部署values

cat << EOF > values-custom.yaml
app:
  service:
    type: NodePort
    ports:
    - name: app
      nodePort: 30418
      port: 20418
      targetPort: 20418
      protocol: TCP
global:
  allInOneLocalStorage: false 
  externalMySQL:
    enabled: true 
    ip: 10.10.2.85
    port: 3306 
    username: admin 
    password: admin123456
  externalClickHouse:
    enabled: true  
    type: ep
    clusterName: default
    storagePolicy: default
    username: default 
    password: admin123456
    hosts:
    - ip: 10.10.2.84
      port: 9000
clickhouse:
  enabled: false 
mysql:
  enabled: false 
grafana:
  service:
    enabled: true
    type: NodePort
    nodePort: 30388
  extraInitContainers:
    - name: init-custom-plugins
      image: "{{ .Values.global.image.repository }}/deepflowio-init-grafana:v6.4"
      imagePullPolicy: "{{ tpl .Values.global.image.pullPolicy . }}"
      volumeMounts:
      - name: custom-plugins
        mountPath: /var/lib/grafana/plugins
    - name: init-grafana-ds-dh
      image: "{{ .Values.global.image.repository }}/deepflowio-init-grafana-ds-dh:v6.4"
      imagePullPolicy: "{{ tpl .Values.global.image.pullPolicy . }}"
      volumeMounts:
      - name: deepflow-dashboards
        mountPath: /tmp/dashboards
      - name: grafana-dashboards-config
        mountPath: /etc/grafana/provisioning/dashboards
      - name: grafana-datasources-config
        mountPath: /etc/grafana/provisioning/datasources
EOF

报错内容

the expected status code returns 200, the actual return is 500, the parameter data is map[db:[flow_log] sql:[SELECT `session_length` AS `Session Total Bytes`, `request_length` AS `Request Total Bytes`, `response_length` AS `Response Total Bytes`, `sql_affected_rows` AS `SQL Affected Rows`, `direction_score` AS `Direction Score`, `response_duration` AS `Response Delay`, `metrics`, toString(_id), time, region_0, region_1, az_0, az_1, host_0, host_1, chost_0, chost_1, vpc_0, vpc_1, l2_vpc_0, l2_vpc_1, subnet_0, subnet_1, router_0, router_1, dhcpgw_0, dhcpgw_1, lb_0, lb_1, natgw_0, natgw_1, redis_0, redis_1, rds_0, rds_1, pod_cluster_0, pod_cluster_1, pod_ns_0, pod_ns_1, pod_node_0, pod_node_1, pod_service_0, pod_service_1, Enum(pod_group_type_0), Enum(pod_group_type_1), pod_group_0, pod_group_1, pod_0, pod_1, service_0, service_1, Enum(resource_gl0_type_0), Enum(resource_gl0_type_1), resource_gl0_0, resource_gl0_1, Enum(resource_gl1_type_0), Enum(resource_gl1_type_1), resource_gl1_0, resource_gl1_1, Enum(resource_gl2_type_0), Enum(resource_gl2_type_1), resource_gl2_0, resource_gl2_1, Enum(auto_instance_type_0), Enum(auto_instance_type_1), auto_instance_0, auto_instance_1, Enum(auto_service_type_0), Enum(auto_service_type_1), auto_service_0, auto_service_1, gprocess_0, gprocess_1, k8s.label_0, k8s.label_1, k8s.annotation_0, k8s.annotation_1, k8s.env_0, k8s.env_1, attribute, cloud.tag_0, cloud.tag_1, os.app_0, os.app_1, ip_0, ip_1, Enum(is_ipv4), is_internet_0, is_internet_1, Enum(protocol), Enum(tunnel_type), client_port, Enum(server_port), req_tcp_seq, resp_tcp_seq, Enum(l7_protocol), l7_protocol_str, Enum(is_tls), version, Enum(type), request_type, request_domain, request_resource, request_id, Enum(response_status), response_code, response_exception, response_result, events, app_service, app_instance, endpoint, process_id_0, process_id_1, process_kname_0, process_kname_1, trace_id, span_id, parent_span_id, Enum(span_kind), x_request_id_0, x_request_id_1, http_proxy_client, syscall_trace_id_request, syscall_trace_id_response, syscall_thread_0, syscall_thread_1, syscall_coroutine_0, syscall_coroutine_1, syscall_cap_seq_0, syscall_cap_seq_1, flow_id, toString(start_time) AS `start_time`, toString(end_time) AS `end_time`, Enum(signal_source), tap, vtap, Enum(nat_source), tap_port, tap_port_name, Enum(tap_port_type), Enum(tap_side), region_id_0, region_id_1, az_id_0, az_id_1, host_id_0, host_id_1, chost_id_0, chost_id_1, vpc_id_0, vpc_id_1, l2_vpc_id_0, l2_vpc_id_1, subnet_id_0, subnet_id_1, router_id_0, router_id_1, dhcpgw_id_0, dhcpgw_id_1, lb_id_0, lb_id_1, natgw_id_0, natgw_id_1, redis_id_0, redis_id_1, rds_id_0, rds_id_1, pod_cluster_id_0, pod_cluster_id_1, pod_ns_id_0, pod_ns_id_1, pod_node_id_0, pod_node_id_1, pod_service_id_0, pod_service_id_1, pod_group_id_0, pod_group_id_1, pod_id_0, pod_id_1, service_id_0, service_id_1, resource_gl0_id_0, resource_gl0_id_1, resource_gl1_id_0, resource_gl1_id_1, resource_gl2_id_0, resource_gl2_id_1, auto_instance_id_0, auto_instance_id_1, auto_service_id_0, auto_service_id_1, gprocess_id_0, gprocess_id_1, tap_id, vtap_id FROM l7_flow_log where _id=7344911817294518385 or _id=7344911817294517913 or _id=7344911817294518377 order by `start_time`]], and the data is
Status: 400
Object
OPT_STATUS:"FAIL"
DESCRIPTION:"code: 349, message: Cannot convert NULL value to non-Nullable type: while executing 'FUNCTION dictGetOrDefault(__dictGetOrDefault_210 :: 233, 'name' : 108, tuple('span_kind', toUInt64(span_kind)) :: 297, span_kind :: 92) -> dictGetOrDefault(flow_tag.int_enum_map, 'name', tuple('span_kind', toUInt64(span_kind)), span_kind) String : 82'"
result:null
debug:Object
error:"code: 349, message: Cannot convert NULL value to non-Nullable type: while executing 'FUNCTION dictGetOrDefault(__dictGetOrDefault_210 :: 233, 'name' : 108, tuple('span_kind', toUInt64(span_kind)) :: 297, span_kind :: 92) -> dictGetOrDefault(flow_tag.int_enum_map, 'name', tuple('span_kind', toUInt64(span_kind)), span_kind) String : 82'"
ip:"deepflow-external-clickhouse"
query_time:"0.000000000s"
query_uuid:"daeb1d89-c2e0-403d-87c2-68aecf80199d"
sql:"WITH dictGetOrDefault(flow_tag.int_enum_map, 'name', ('pod_group_type',toUInt64(dictGet(flow_tag.pod_group_map, 'pod_group_type', (toUInt64(pod_group_id_0))))), dictGet(flow_tag.pod_group_map, 'pod_group_type', (toUInt64(pod_group_id_0)))) AS `Enum(pod_group_type_0)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('pod_group_type',toUInt64(dictGet(flow_tag.pod_group_map, 'pod_group_type', (toUInt64(pod_group_id_1))))), dictGet(flow_tag.pod_group_map, 'pod_group_type', (toUInt64(pod_group_id_1)))) AS `Enum(pod_group_type_1)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('resource_gl0_type',toUInt64(auto_instance_type_0)), auto_instance_type_0) AS `Enum(resource_gl0_type_0)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('resource_gl0_type',toUInt64(auto_instance_type_1)), auto_instance_type_1) AS `Enum(resource_gl0_type_1)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('resource_gl1_type',toUInt64(auto_service_type_0)), auto_service_type_0) AS `Enum(resource_gl1_type_0)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('resource_gl1_type',toUInt64(auto_service_type_1)), auto_service_type_1) AS `Enum(resource_gl1_type_1)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('resource_gl2_type',toUInt64(auto_service_type_0)), auto_service_type_0) AS `Enum(resource_gl2_type_0)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('resource_gl2_type',toUInt64(auto_service_type_1)), auto_service_type_1) AS `Enum(resource_gl2_type_1)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('auto_instance_type',toUInt64(auto_instance_type_0)), auto_instance_type_0) AS `Enum(auto_instance_type_0)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('auto_instance_type',toUInt64(auto_instance_type_1)), auto_instance_type_1) AS `Enum(auto_instance_type_1)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('auto_service_type',toUInt64(auto_service_type_0)), auto_service_type_0) AS `Enum(auto_service_type_0)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('auto_service_type',toUInt64(auto_service_type_1)), auto_service_type_1) AS `Enum(auto_service_type_1)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('ip_type',toUInt64(is_ipv4)), is_ipv4) AS `Enum(is_ipv4)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('l7_ip_protocol',toUInt64(protocol)), protocol) AS `Enum(protocol)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('tunnel_type',toUInt64(tunnel_type)), tunnel_type) AS `Enum(tunnel_type)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('server_port',toUInt64(server_port)), server_port) AS `Enum(server_port)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('l7_protocol',toUInt64(l7_protocol)), l7_protocol) AS `Enum(l7_protocol)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('bool',toUInt64(is_tls)), is_tls) AS `Enum(is_tls)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('l7_log_type',toUInt64(type)), type) AS `Enum(type)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('response_status',toUInt64(response_status)), response_status) AS `Enum(response_status)`, if(isNull(span_kind), '', dictGetOrDefault(flow_tag.int_enum_map, 'name', ('span_kind',toUInt64(span_kind)), span_kind)) AS `Enum(span_kind)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('l7_signal_source',toUInt64(signal_source)), signal_source) AS `Enum(signal_source)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('nat_source',toUInt64(nat_source)), nat_source) AS `Enum(nat_source)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('tap_port_type',toUInt64(tap_port_type)), tap_port_type) AS `Enum(tap_port_type)`, dictGetOrDefault(flow_tag.string_enum_map, 'name', ('tap_side',tap_side), tap_side) AS `Enum(tap_side)` SELECT if(request_length>0,request_length,0)+if(response_length>0,response_length,0) AS `Session Total Bytes`, request_length AS `Request Total Bytes`, response_length AS `Response Total Bytes`, sql_affected_rows AS `SQL Affected Rows`, direction_score AS `Direction Score`, response_duration AS `Response Delay`, toJSONString(CAST((metrics_names, metrics_values), 'Map(String, Float64)')) AS `metrics`, toString(_id), time, dictGet(flow_tag.region_map, 'name', (toUInt64(region_id_0))) AS `region_0`, dictGet(flow_tag.region_map, 'name', (toUInt64(region_id_1))) AS `region_1`, dictGet(flow_tag.az_map, 'name', (toUInt64(az_id_0))) AS `az_0`, dictGet(flow_tag.az_map, 'name', (toUInt64(az_id_1))) AS `az_1`, dictGet(flow_tag.device_map, 'name', (toUInt64(6),toUInt64(host_id_0))) AS `host_0`, dictGet(flow_tag.device_map, 'name', (toUInt64(6),toUInt64(host_id_1))) AS `host_1`, if(l3_device_type_0=1, dictGet(flow_tag.device_map, 'name', (toUInt64(1),toUInt64(l3_device_id_0))), '') AS `chost_0`, if(l3_device_type_1=1, dictGet(flow_tag.device_map, 'name', (toUInt64(1),toUInt64(l3_device_id_1))), '') AS `chost_1`, dictGet(flow_tag.l3_epc_map, 'name', (toUInt64(l3_epc_id_0))) AS `vpc_0`, dictGet(flow_tag.l3_epc_map, 'name', (toUInt64(l3_epc_id_1))) AS `vpc_1`, dictGet(flow_tag.l3_epc_map, 'name', (toUInt64(epc_id_0))) AS `l2_vpc_0`, dictGet(flow_tag.l3_epc_map, 'name', (toUInt64(epc_id_1))) AS `l2_vpc_1`, dictGet(flow_tag.subnet_map, 'name', (toUInt64(subnet_id_0))) AS `subnet_0`, dictGet(flow_tag.subnet_map, 'name', (toUInt64(subnet_id_1))) AS `subnet_1`, if(l3_device_type_0=5, dictGet(flow_tag.device_map, 'name', (toUInt64(5),toUInt64(l3_device_id_0))), '') AS `router_0`, if(l3_device_type_1=5, dictGet(flow_tag.device_map, 'name', (toUInt64(5),toUInt64(l3_device_id_1))), '') AS `router_1`, if(l3_device_type_0=9, dictGet(flow_tag.device_map, 'name', (toUInt64(9),toUInt64(l3_device_id_0))), '') AS `dhcpgw_0`, if(l3_device_type_1=9, dictGet(flow_tag.device_map, 'name', (toUInt64(9),toUInt64(l3_device_id_1))), '') AS `dhcpgw_1`, if(l3_device_type_0=15, dictGet(flow_tag.device_map, 'name', (toUInt64(15),toUInt64(l3_device_id_0))), '') AS `lb_0`, if(l3_device_type_1=15, dictGet(flow_tag.device_map, 'name', (toUInt64(15),toUInt64(l3_device_id_1))), '') AS `lb_1`, if(l3_device_type_0=16, dictGet(flow_tag.device_map, 'name', (toUInt64(16),toUInt64(l3_device_id_0))), '') AS `natgw_0`, if(l3_device_type_1=16, dictGet(flow_tag.device_map, 'name', (toUInt64(16),toUInt64(l3_device_id_1))), '') AS `natgw_1`, if(l3_device_type_0=12, dictGet(flow_tag.device_map, 'name', (toUInt64(12),toUInt64(l3_device_id_0))), '') AS `redis_0`, if(l3_device_type_1=12, dictGet(flow_tag.device_map, 'name', (toUInt64(12),toUInt64(l3_device_id_1))), '') AS `redis_1`, if(l3_device_type_0=13, dictGet(flow_tag.device_map, 'name', (toUInt64(13),toUInt64(l3_device_id_0))), '') AS `rds_0`, if(l3_device_type_1=13, dictGet(flow_tag.device_map, 'name', (toUInt64(13),toUInt64(l3_device_id_1))), '') AS `rds_1`, dictGet(flow_tag.pod_cluster_map, 'name', (toUInt64(pod_cluster_id_0))) AS `pod_cluster_0`, dictGet(flow_tag.pod_cluster_map, 'name', (toUInt64(pod_cluster_id_1))) AS `pod_cluster_1`, dictGet(flow_tag.pod_ns_map, 'name', (toUInt64(pod_ns_id_0))) AS `pod_ns_0`, dictGet(flow_tag.pod_ns_map, 'name', (toUInt64(pod_ns_id_1))) AS `pod_ns_1`, dictGet(flow_tag.pod_node_map, 'name', (toUInt64(pod_node_id_0))) AS `pod_node_0`, dictGet(flow_tag.pod_node_map, 'name', (toUInt64(pod_node_id_1))) AS `pod_node_1`, dictGet(flow_tag.device_map, 'name', (toUInt64(11),toUInt64(service_id_0))) AS `pod_service_0`, dictGet(flow_tag.device_map, 'name', (toUInt64(11),toUInt64(service_id_1))) AS `pod_service_1`, `Enum(pod_group_type_0)`, `Enum(pod_group_type_1)`, dictGet(flow_tag.pod_group_map, 'name', (toUInt64(pod_group_id_0))) AS `pod_group_0`, dictGet(flow_tag.pod_group_map, 'name', (toUInt64(pod_group_id_1))) AS `pod_group_1`, dictGet(flow_tag.pod_map, 'name', (toUInt64(pod_id_0))) AS `pod_0`, dictGet(flow_tag.pod_map, 'name', (toUInt64(pod_id_1))) AS `pod_1`, dictGet(flow_tag.device_map, 'name', (toUInt64(11),toUInt64(service_id_0))) AS `service_0`, dictGet(flow_tag.device_map, 'name', (toUInt64(11),toUInt64(service_id_1))) AS `service_1`, `Enum(resource_gl0_type_0)`, `Enum(resource_gl0_type_1)`, if(auto_instance_type_0 in (0,255),if(is_ipv4=1, IPv4NumToString(ip4_0), IPv6NumToString(ip6_0)),dictGet(flow_tag.device_map, 'name', (toUInt64(auto_instance_type_0),toUInt64(auto_instance_id_0)))) AS `resource_gl0_0`, if(auto_instance_type_1 in (0,255),if(is_ipv4=1, IPv4NumToString(ip4_1), IPv6NumToString(ip6_1)),dictGet(flow_tag.device_map, 'name', (toUInt64(auto_instance_type_1),toUInt64(auto_instance_id_1)))) AS `resource_gl0_1`, `Enum(resource_gl1_type_0)`, `Enum(resource_gl1_type_1)`, if(auto_service_type_0 in (0,255),if(is_ipv4=1, IPv4NumToString(ip4_0), IPv6NumToString(ip6_0)),dictGet(flow_tag.device_map, 'name', (toUInt64(auto_service_type_0),toUInt64(auto_service_id_0)))) AS `resource_gl1_0`, if(auto_service_type_1 in (0,255),if(is_ipv4=1, IPv4NumToString(ip4_1), IPv6NumToString(ip6_1)),dictGet(flow_tag.device_map, 'name', (toUInt64(auto_service_type_1),toUInt64(auto_service_id_1)))) AS `resource_gl1_1`, `Enum(resource_gl2_type_0)`, `Enum(resource_gl2_type_1)`, if(auto_service_type_0 in (0,255),if(is_ipv4=1, IPv4NumToString(ip4_0), IPv6NumToString(ip6_0)),dictGet(flow_tag.device_map, 'name', (toUInt64(auto_service_type_0),toUInt64(auto_service_id_0)))) AS `resource_gl2_0`, if(auto_service_type_1 in (0,255),if(is_ipv4=1, IPv4NumToString(ip4_1), IPv6NumToString(ip6_1)),dictGet(flow_tag.device_map, 'name', (toUInt64(auto_service_type_1),toUInt64(auto_service_id_1)))) AS `resource_gl2_1`, `Enum(auto_instance_type_0)`, `Enum(auto_instance_type_1)`, if(auto_instance_type_0 in (0,255),if(is_ipv4=1, IPv4NumToString(ip4_0), IPv6NumToString(ip6_0)),dictGet(flow_tag.device_map, 'name', (toUInt64(auto_instance_type_0),toUInt64(auto_instance_id_0)))) AS `auto_instance_0`, if(auto_instance_type_1 in (0,255),if(is_ipv4=1, IPv4NumToString(ip4_1), IPv6NumToString(ip6_1)),dictGet(flow_tag.device_map, 'name', (toUInt64(auto_instance_type_1),toUInt64(auto_instance_id_1)))) AS `auto_instance_1`, `Enum(auto_service_type_0)`, `Enum(auto_service_type_1)`, if(auto_service_type_0 in (0,255),if(is_ipv4=1, IPv4NumToString(ip4_0), IPv6NumToString(ip6_0)),dictGet(flow_tag.device_map, 'name', (toUInt64(auto_service_type_0),toUInt64(auto_service_id_0)))) AS `auto_service_0`, if(auto_service_type_1 in (0,255),if(is_ipv4=1, IPv4NumToString(ip4_1), IPv6NumToString(ip6_1)),dictGet(flow_tag.device_map, 'name', (toUInt64(auto_service_type_1),toUInt64(auto_service_id_1)))) AS `auto_service_1`, dictGet(flow_tag.gprocess_map, 'name', (toUInt64(gprocess_id_0))) AS `gprocess_0`, dictGet(flow_tag.gprocess_map, 'name', (toUInt64(gprocess_id_1))) AS `gprocess_1`, if(dictGetOrDefault(flow_tag.pod_service_k8s_labels_map, 'labels', toUInt64(service_id_0),'{}')!='{}', dictGetOrDefault(flow_tag.pod_service_k8s_labels_map, 'labels', toUInt64(service_id_0),'{}'), dictGetOrDefault(flow_tag.pod_k8s_labels_map, 'labels', toUInt64(pod_id_0),'{}'))  AS `k8s.label_0`, if(dictGetOrDefault(flow_tag.pod_service_k8s_labels_map, 'labels', toUInt64(service_id_1),'{}')!='{}', dictGetOrDefault(flow_tag.pod_service_k8s_labels_map, 'labels', toUInt64(service_id_1),'{}'), dictGetOrDefault(flow_tag.pod_k8s_labels_map, 'labels', toUInt64(pod_id_1),'{}'))  AS `k8s.label_1`, if(dictGetOrDefault(flow_tag.pod_service_k8s_annotations_map, 'annotations', toUInt64(service_id_0),'{}')!='{}', dictGetOrDefault(flow_tag.pod_service_k8s_annotations_map, 'annotations', toUInt64(service_id_0),'{}'), dictGetOrDefault(flow_tag.pod_k8s_annotations_map, 'annotations', toUInt64(pod_id_0),'{}'))  AS `k8s.annotation_0`, if(dictGetOrDefault(flow_tag.pod_service_k8s_annotations_map, 'annotations', toUInt64(service_id_1),'{}')!='{}', dictGetOrDefault(flow_tag.pod_service_k8s_annotations_map, 'annotations', toUInt64(service_id_1),'{}'), dictGetOrDefault(flow_tag.pod_k8s_annotations_map, 'annotations', toUInt64(pod_id_1),'{}'))  AS `k8s.annotation_1`, dictGetOrDefault(flow_tag.pod_k8s_envs_map, 'envs', toUInt64(pod_id_0),'{}')  AS `k8s.env_0`, dictGetOrDefault(flow_tag.pod_k8s_envs_map, 'envs', toUInt64(pod_id_1),'{}')  AS `k8s.env_1`, toJSONString(CAST((attribute_names, attribute_values), 'Map(String, String)')) AS `attribute`, if(if(l3_device_type_0=1, dictGetOrDefault(flow_tag.chost_cloud_tags_map, 'cloud_tags', toUInt64(l3_device_id_0),'{}'), '{}')!='{}',if(l3_device_type_0=1, dictGetOrDefault(flow_tag.chost_cloud_tags_map, 'cloud_tags', toUInt64(l3_device_id_0),'{}'), '{}'), dictGetOrDefault(flow_tag.pod_ns_cloud_tags_map, 'cloud_tags', toUInt64(pod_ns_id_0),'{}'))  AS `cloud.tag_0`, if(if(l3_device_type_1=1, dictGetOrDefault(flow_tag.chost_cloud_tags_map, 'cloud_tags', toUInt64(l3_device_id_1),'{}'), '{}')!='{}',if(l3_device_type_1=1, dictGetOrDefault(flow_tag.chost_cloud_tags_map, 'cloud_tags', toUInt64(l3_device_id_1),'{}'), '{}'), dictGetOrDefault(flow_tag.pod_ns_cloud_tags_map, 'cloud_tags', toUInt64(pod_ns_id_1),'{}'))  AS `cloud.tag_1`, dictGetOrDefault(flow_tag.os_app_tags_map, 'os_app_tags', toUInt64(gprocess_id_0),'{}') AS `os.app_0`, dictGetOrDefault(flow_tag.os_app_tags_map, 'os_app_tags', toUInt64(gprocess_id_1),'{}') AS `os.app_1`, if(is_ipv4=1, IPv4NumToString(ip4_0), IPv6NumToString(ip6_0)) AS `ip_0`, if(is_ipv4=1, IPv4NumToString(ip4_1), IPv6NumToString(ip6_1)) AS `ip_1`, `Enum(is_ipv4)`, if(l3_epc_id_0=-2,1,0) AS `is_internet_0`, if(l3_epc_id_1=-2,1,0) AS `is_internet_1`, `Enum(protocol)`, `Enum(tunnel_type)`, client_port, `Enum(server_port)`, req_tcp_seq, resp_tcp_seq, `Enum(l7_protocol)`, l7_protocol_str, `Enum(is_tls)`, version, `Enum(type)`, request_type, request_domain, request_resource, request_id, `Enum(response_status)`, response_code, response_exception, response_result, events, app_service, app_instance, endpoint, process_id_0, process_id_1, process_kname_0, process_kname_1, trace_id, span_id, parent_span_id, `Enum(span_kind)`, x_request_id_0, x_request_id_1, http_proxy_client, syscall_trace_id_request, syscall_trace_id_response, syscall_thread_0, syscall_thread_1, syscall_coroutine_0, syscall_coroutine_1, syscall_cap_seq_0, syscall_cap_seq_1, flow_id, toString(start_time) AS `start_time`, toString(end_time) AS `end_time`, `Enum(signal_source)`, dictGet(flow_tag.tap_type_map, 'name', toUInt64(tap_type)) AS `tap`, dictGet(flow_tag.vtap_map, 'name', toUInt64(vtap_id)) AS `vtap`, `Enum(nat_source)`, tap_port, if(tap_port_type in (0,1,2),dictGet(flow_tag.vtap_port_map, 'name', (toUInt64(vtap_id),toUInt64(tap_port))),'') AS `tap_port_name`, `Enum(tap_port_type)`, `Enum(tap_side)`, region_id_0, region_id_1, az_id_0, az_id_1, host_id_0, host_id_1, if(l3_device_type_0=1,l3_device_id_0, 0) AS `chost_id_0`, if(l3_device_type_1=1,l3_device_id_1, 0) AS `chost_id_1`, l3_epc_id_0 AS `vpc_id_0`, l3_epc_id_1 AS `vpc_id_1`, epc_id_0 AS `l2_vpc_id_0`, epc_id_1 AS `l2_vpc_id_1`, subnet_id_0, subnet_id_1, if(l3_device_type_0=5,l3_device_id_0, 0) AS `router_id_0`, if(l3_device_type_1=5,l3_device_id_1, 0) AS `router_id_1`, if(l3_device_type_0=9,l3_device_id_0, 0) AS `dhcpgw_id_0`, if(l3_device_type_1=9,l3_device_id_1, 0) AS `dhcpgw_id_1`, if(l3_device_type_0=15,l3_device_id_0, 0) AS `lb_id_0`, if(l3_device_type_1=15,l3_device_id_1, 0) AS `lb_id_1`, if(l3_device_type_0=16,l3_device_id_0, 0) AS `natgw_id_0`, if(l3_device_type_1=16,l3_device_id_1, 0) AS `natgw_id_1`, if(l3_device_type_0=12,l3_device_id_0, 0) AS `redis_id_0`, if(l3_device_type_1=12,l3_device_id_1, 0) AS `redis_id_1`, if(l3_device_type_0=13,l3_device_id_0, 0) AS `rds_id_0`, if(l3_device_type_1=13,l3_device_id_1, 0) AS `rds_id_1`, pod_cluster_id_0, pod_cluster_id_1, pod_ns_id_0, pod_ns_id_1, pod_node_id_0, pod_node_id_1, service_id_0 AS `pod_service_id_0`, service_id_1 AS `pod_service_id_1`, pod_group_id_0, pod_group_id_1, pod_id_0, pod_id_1, service_id_0, service_id_1, if(auto_instance_type_0 in (0,255),subnet_id_0,auto_instance_id_0) AS `resource_gl0_id_0`, if(auto_instance_type_1 in (0,255),subnet_id_1,auto_instance_id_1) AS `resource_gl0_id_1`, if(auto_service_type_0 in (0,255),subnet_id_0,auto_service_id_0) AS `resource_gl1_id_0`, if(auto_service_type_1 in (0,255),subnet_id_1,auto_service_id_1) AS `resource_gl1_id_1`, if(auto_service_type_0 in (0,255),subnet_id_0,auto_service_id_0) AS `resource_gl2_id_0`, if(auto_service_type_1 in (0,255),subnet_id_1,auto_service_id_1) AS `resource_gl2_id_1`, if(auto_instance_type_0 in (0,255),subnet_id_0,auto_instance_id_0) AS `auto_instance_id_0`, if(auto_instance_type_1 in (0,255),subnet_id_1,auto_instance_id_1) AS `auto_instance_id_1`, if(auto_service_type_0 in (0,255),subnet_id_0,auto_service_id_0) AS `auto_service_id_0`, if(auto_service_type_1 in (0,255),subnet_id_1,auto_service_id_1) AS `auto_service_id_1`, gprocess_id_0, gprocess_id_1, tap_type AS `tap_id`, vtap_id FROM flow_log.`l7_flow_log` PREWHERE (((_id = 7344911817294518385 AND time=toDateTime(bitShiftRight(7344911817294518385, 32))))) OR (((_id = 7344911817294517913 AND time=toDateTime(bitShiftRight(7344911817294517913, 32))))) OR (((_id = 7344911817294518377 AND time=toDateTime(bitShiftRight(7344911817294518377, 32))))) ORDER BY `start_time` asc LIMIT 10000"






点编辑报错如下
the expected status code returns 200, the actual return is 500, the parameter data is map[db:[flow_log] sql:[SELECT `session_length` AS `Session Total Bytes`, `request_length` AS `Request Total Bytes`, `response_length` AS `Response Total Bytes`, `sql_affected_rows` AS `SQL Affected Rows`, `direction_score` AS `Direction Score`, `response_duration` AS `Response Delay`, `metrics`, toString(_id), time, region_0, region_1, az_0, az_1, host_0, host_1, chost_0, chost_1, vpc_0, vpc_1, l2_vpc_0, l2_vpc_1, subnet_0, subnet_1, router_0, router_1, dhcpgw_0, dhcpgw_1, lb_0, lb_1, natgw_0, natgw_1, redis_0, redis_1, rds_0, rds_1, pod_cluster_0, pod_cluster_1, pod_ns_0, pod_ns_1, pod_node_0, pod_node_1, pod_service_0, pod_service_1, Enum(pod_group_type_0), Enum(pod_group_type_1), pod_group_0, pod_group_1, pod_0, pod_1, service_0, service_1, Enum(resource_gl0_type_0), Enum(resource_gl0_type_1), resource_gl0_0, resource_gl0_1, Enum(resource_gl1_type_0), Enum(resource_gl1_type_1), resource_gl1_0, resource_gl1_1, Enum(resource_gl2_type_0), Enum(resource_gl2_type_1), resource_gl2_0, resource_gl2_1, Enum(auto_instance_type_0), Enum(auto_instance_type_1), auto_instance_0, auto_instance_1, Enum(auto_service_type_0), Enum(auto_service_type_1), auto_service_0, auto_service_1, gprocess_0, gprocess_1, k8s.label_0, k8s.label_1, k8s.annotation_0, k8s.annotation_1, k8s.env_0, k8s.env_1, attribute, cloud.tag_0, cloud.tag_1, os.app_0, os.app_1, ip_0, ip_1, Enum(is_ipv4), is_internet_0, is_internet_1, Enum(protocol), Enum(tunnel_type), client_port, Enum(server_port), req_tcp_seq, resp_tcp_seq, Enum(l7_protocol), l7_protocol_str, Enum(is_tls), version, Enum(type), request_type, request_domain, request_resource, request_id, Enum(response_status), response_code, response_exception, response_result, events, app_service, app_instance, endpoint, process_id_0, process_id_1, process_kname_0, process_kname_1, trace_id, span_id, parent_span_id, Enum(span_kind), x_request_id_0, x_request_id_1, http_proxy_client, syscall_trace_id_request, syscall_trace_id_response, syscall_thread_0, syscall_thread_1, syscall_coroutine_0, syscall_coroutine_1, syscall_cap_seq_0, syscall_cap_seq_1, flow_id, toString(start_time) AS `start_time`, toString(end_time) AS `end_time`, Enum(signal_source), tap, vtap, Enum(nat_source), tap_port, tap_port_name, Enum(tap_port_type), Enum(tap_side), region_id_0, region_id_1, az_id_0, az_id_1, host_id_0, host_id_1, chost_id_0, chost_id_1, vpc_id_0, vpc_id_1, l2_vpc_id_0, l2_vpc_id_1, subnet_id_0, subnet_id_1, router_id_0, router_id_1, dhcpgw_id_0, dhcpgw_id_1, lb_id_0, lb_id_1, natgw_id_0, natgw_id_1, redis_id_0, redis_id_1, rds_id_0, rds_id_1, pod_cluster_id_0, pod_cluster_id_1, pod_ns_id_0, pod_ns_id_1, pod_node_id_0, pod_node_id_1, pod_service_id_0, pod_service_id_1, pod_group_id_0, pod_group_id_1, pod_id_0, pod_id_1, service_id_0, service_id_1, resource_gl0_id_0, resource_gl0_id_1, resource_gl1_id_0, resource_gl1_id_1, resource_gl2_id_0, resource_gl2_id_1, auto_instance_id_0, auto_instance_id_1, auto_service_id_0, auto_service_id_1, gprocess_id_0, gprocess_id_1, tap_id, vtap_id FROM l7_flow_log where _id=7344911817294518385 or _id=7344911817294517913 or _id=7344911817294518377 order by `start_time`]], and the data is {"OPT_STATUS":"FAIL","DESCRIPTION":"code: 349, message: Cannot convert NULL value to non-Nullable type: while executing 'FUNCTION dictGetOrDefault(__dictGetOrDefault_210 :: 233, 'name' : 108, tuple('span_kind', toUInt64(span_kind)) :: 297, span_kind :: 92) -\u003e dictGetOrDefault(flow_tag.int_enum_map, 'name', tuple('span_kind', toUInt64(span_kind)), span_kind) String : 82'","result":null,"debug":{"error":"code: 349, message: Cannot convert NULL value to non-Nullable type: while executing 'FUNCTION dictGetOrDefault(__dictGetOrDefault_210 :: 233, 'name' : 108, tuple('span_kind', toUInt64(span_kind)) :: 297, span_kind :: 92) -\u003e dictGetOrDefault(flow_tag.int_enum_map, 'name', tuple('span_kind', toUInt64(span_kind)), span_kind) String : 82'","ip":"deepflow-external-clickhouse","query_time":"0.000000000s","query_uuid":"d526a2ac-c585-48ce-908b-c681f4419b7f","sql":"WITH dictGetOrDefault(flow_tag.int_enum_map, 'name', ('pod_group_type',toUInt64(dictGet(flow_tag.pod_group_map, 'pod_group_type', (toUInt64(pod_group_id_0))))), dictGet(flow_tag.pod_group_map, 'pod_group_type', (toUInt64(pod_group_id_0)))) AS `Enum(pod_group_type_0)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('pod_group_type',toUInt64(dictGet(flow_tag.pod_group_map, 'pod_group_type', (toUInt64(pod_group_id_1))))), dictGet(flow_tag.pod_group_map, 'pod_group_type', (toUInt64(pod_group_id_1)))) AS `Enum(pod_group_type_1)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('resource_gl0_type',toUInt64(auto_instance_type_0)), auto_instance_type_0) AS `Enum(resource_gl0_type_0)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('resource_gl0_type',toUInt64(auto_instance_type_1)), auto_instance_type_1) AS `Enum(resource_gl0_type_1)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('resource_gl1_type',toUInt64(auto_service_type_0)), auto_service_type_0) AS `Enum(resource_gl1_type_0)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('resource_gl1_type',toUInt64(auto_service_type_1)), auto_service_type_1) AS `Enum(resource_gl1_type_1)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('resource_gl2_type',toUInt64(auto_service_type_0)), auto_service_type_0) AS `Enum(resource_gl2_type_0)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('resource_gl2_type',toUInt64(auto_service_type_1)), auto_service_type_1) AS `Enum(resource_gl2_type_1)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('auto_instance_type',toUInt64(auto_instance_type_0)), auto_instance_type_0) AS `Enum(auto_instance_type_0)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('auto_instance_type',toUInt64(auto_instance_type_1)), auto_instance_type_1) AS `Enum(auto_instance_type_1)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('auto_service_type',toUInt64(auto_service_type_0)), auto_service_type_0) AS `Enum(auto_service_type_0)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('auto_service_type',toUInt64(auto_service_type_1)), auto_service_type_1) AS `Enum(auto_service_type_1)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('ip_type',toUInt64(is_ipv4)), is_ipv4) AS `Enum(is_ipv4)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('l7_ip_protocol',toUInt64(protocol)), protocol) AS `Enum(protocol)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('tunnel_type',toUInt64(tunnel_type)), tunnel_type) AS `Enum(tunnel_type)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('server_port',toUInt64(server_port)), server_port) AS `Enum(server_port)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('l7_protocol',toUInt64(l7_protocol)), l7_protocol) AS `Enum(l7_protocol)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('bool',toUInt64(is_tls)), is_tls) AS `Enum(is_tls)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('l7_log_type',toUInt64(type)), type) AS `Enum(type)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('response_status',toUInt64(response_status)), response_status) AS `Enum(response_status)`, if(isNull(span_kind), '', dictGetOrDefault(flow_tag.int_enum_map, 'name', ('span_kind',toUInt64(span_kind)), span_kind)) AS `Enum(span_kind)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('l7_signal_source',toUInt64(signal_source)), signal_source) AS `Enum(signal_source)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('nat_source',toUInt64(nat_source)), nat_source) AS `Enum(nat_source)`, dictGetOrDefault(flow_tag.int_enum_map, 'name', ('tap_port_type',toUInt64(tap_port_type)), tap_port_type) AS `Enum(tap_port_type)`, dictGetOrDefault(flow_tag.string_enum_map, 'name', ('tap_side',tap_side), tap_side) AS `Enum(tap_side)` SELECT if(request_length\u003e0,request_length,0)+if(response_length\u003e0,response_length,0) AS `Session Total Bytes`, request_length AS `Request Total Bytes`, response_length AS `Response Total Bytes`, sql_affected_rows AS `SQL Affected Rows`, direction_score AS `Direction Score`, response_duration AS `Response Delay`, toJSONString(CAST((metrics_names, metrics_values), 'Map(String, Float64)')) AS `metrics`, toString(_id), time, dictGet(flow_tag.region_map, 'name', (toUInt64(region_id_0))) AS `region_0`, dictGet(flow_tag.region_map, 'name', (toUInt64(region_id_1))) AS `region_1`, dictGet(flow_tag.az_map, 'name', (toUInt64(az_id_0))) AS `az_0`, dictGet(flow_tag.az_map, 'name', (toUInt64(az_id_1))) AS `az_1`, dictGet(flow_tag.device_map, 'name', (toUInt64(6),toUInt64(host_id_0))) AS `host_0`, dictGet(flow_tag.device_map, 'name', (toUInt64(6),toUInt64(host_id_1))) AS `host_1`, if(l3_device_type_0=1, dictGet(flow_tag.device_map, 'name', (toUInt64(1),toUInt64(l3_device_id_0))), '') AS `chost_0`, if(l3_device_type_1=1, dictGet(flow_tag.device_map, 'name', (toUInt64(1),toUInt64(l3_device_id_1))), '') AS `chost_1`, dictGet(flow_tag.l3_epc_map, 'name', (toUInt64(l3_epc_id_0))) AS `vpc_0`, dictGet(flow_tag.l3_epc_map, 'name', (toUInt64(l3_epc_id_1))) AS `vpc_1`, dictGet(flow_tag.l3_epc_map, 'name', (toUInt64(epc_id_0))) AS `l2_vpc_0`, dictGet(flow_tag.l3_epc_map, 'name', (toUInt64(epc_id_1))) AS `l2_vpc_1`, dictGet(flow_tag.subnet_map, 'name', (toUInt64(subnet_id_0))) AS `subnet_0`, dictGet(flow_tag.subnet_map, 'name', (toUInt64(subnet_id_1))) AS `subnet_1`, if(l3_device_type_0=5, dictGet(flow_tag.device_map, 'name', (toUInt64(5),toUInt64(l3_device_id_0))), '') AS `router_0`, if(l3_device_type_1=5, dictGet(flow_tag.device_map, 'name', (toUInt64(5),toUInt64(l3_device_id_1))), '') AS `router_1`, if(l3_device_type_0=9, dictGet(flow_tag.device_map, 'name', (toUInt64(9),toUInt64(l3_device_id_0))), '') AS `dhcpgw_0`, if(l3_device_type_1=9, dictGet(flow_tag.device_map, 'name', (toUInt64(9),toUInt64(l3_device_id_1))), '') AS `dhcpgw_1`, if(l3_device_type_0=15, dictGet(flow_tag.device_map, 'name', (toUInt64(15),toUInt64(l3_device_id_0))), '') AS `lb_0`, if(l3_device_type_1=15, dictGet(flow_tag.device_map, 'name', (toUInt64(15),toUInt64(l3_device_id_1))), '') AS `lb_1`, if(l3_device_type_0=16, dictGet(flow_tag.device_map, 'name', (toUInt64(16),toUInt64(l3_device_id_0))), '') AS `natgw_0`, if(l3_device_type_1=16, dictGet(flow_tag.device_map, 'name', (toUInt64(16),toUInt64(l3_device_id_1))), '') AS `natgw_1`, if(l3_device_type_0=12, dictGet(flow_tag.device_map, 'name', (toUInt64(12),toUInt64(l3_device_id_0))), '') AS `redis_0`, if(l3_device_type_1=12, dictGet(flow_tag.device_map, 'name', (toUInt64(12),toUInt64(l3_device_id_1))), '') AS `redis_1`, if(l3_device_type_0=13, dictGet(flow_tag.device_map, 'name', (toUInt64(13),toUInt64(l3_device_id_0))), '') AS `rds_0`, if(l3_device_type_1=13, dictGet(flow_tag.device_map, 'name', (toUInt64(13),toUInt64(l3_device_id_1))), '') AS `rds_1`, dictGet(flow_tag.pod_cluster_map, 'name', (toUInt64(pod_cluster_id_0))) AS `pod_cluster_0`, dictGet(flow_tag.pod_cluster_map, 'name', (toUInt64(pod_cluster_id_1))) AS `pod_cluster_1`, dictGet(flow_tag.pod_ns_map, 'name', (toUInt64(pod_ns_id_0))) AS `pod_ns_0`, dictGet(flow_tag.pod_ns_map, 'name', (toUInt64(pod_ns_id_1))) AS `pod_ns_1`, dictGet(flow_tag.pod_node_map, 'name', (toUInt64(pod_node_id_0))) AS `pod_node_0`, dictGet(flow_tag.pod_node_map, 'name', (toUInt64(pod_node_id_1))) AS `pod_node_1`, dictGet(flow_tag.device_map, 'name', (toUInt64(11),toUInt64(service_id_0))) AS `pod_service_0`, dictGet(flow_tag.device_map, 'name', (toUInt64(11),toUInt64(service_id_1))) AS `pod_service_1`, `Enum(pod_group_type_0)`, `Enum(pod_group_type_1)`, dictGet(flow_tag.pod_group_map, 'name', (toUInt64(pod_group_id_0))) AS `pod_group_0`, dictGet(flow_tag.pod_group_map, 'name', (toUInt64(pod_group_id_1))) AS `pod_group_1`, dictGet(flow_tag.pod_map, 'name', (toUInt64(pod_id_0))) AS `pod_0`, dictGet(flow_tag.pod_map, 'name', (toUInt64(pod_id_1))) AS `pod_1`, dictGet(flow_tag.device_map, 'name', (toUInt64(11),toUInt64(service_id_0))) AS `service_0`, dictGet(flow_tag.device_map, 'name', (toUInt64(11),toUInt64(service_id_1))) AS `service_1`, `Enum(resource_gl0_type_0)`, `Enum(resource_gl0_type_1)`, if(auto_instance_type_0 in (0,255),if(is_ipv4=1, IPv4NumToString(ip4_0), IPv6NumToString(ip6_0)),dictGet(flow_tag.device_map, 'name', (toUInt64(auto_instance_type_0),toUInt64(auto_instance_id_0)))) AS `resource_gl0_0`, if(auto_instance_type_1 in (0,255),if(is_ipv4=1, IPv4NumToString(ip4_1), IPv6NumToString(ip6_1)),dictGet(flow_tag.device_map, 'name', (toUInt64(auto_instance_type_1),toUInt64(auto_instance_id_1)))) AS `resource_gl0_1`, `Enum(resource_gl1_type_0)`, `Enum(resource_gl1_type_1)`, if(auto_service_type_0 in (0,255),if(is_ipv4=1, IPv4NumToString(ip4_0), IPv6NumToString(ip6_0)),dictGet(flow_tag.device_map, 'name', (toUInt64(auto_service_type_0),toUInt64(auto_service_id_0)))) AS `resource_gl1_0`, if(auto_service_type_1 in (0,255),if(is_ipv4=1, IPv4NumToString(ip4_1), IPv6NumToString(ip6_1)),dictGet(flow_tag.device_map, 'name', (toUInt64(auto_service_type_1),toUInt64(auto_service_id_1)))) AS `resource_gl1_1`, `Enum(resource_gl2_type_0)`, `Enum(resource_gl2_type_1)`, if(auto_service_type_0 in (0,255),if(is_ipv4=1, IPv4NumToString(ip4_0), IPv6NumToString(ip6_0)),dictGet(flow_tag.device_map, 'name', (toUInt64(auto_service_type_0),toUInt64(auto_service_id_0)))) AS `resource_gl2_0`, if(auto_service_type_1 in (0,255),if(is_ipv4=1, IPv4NumToString(ip4_1), IPv6NumToString(ip6_1)),dictGet(flow_tag.device_map, 'name', (toUInt64(auto_service_type_1),toUInt64(auto_service_id_1)))) AS `resource_gl2_1`, `Enum(auto_instance_type_0)`, `Enum(auto_instance_type_1)`, if(auto_instance_type_0 in (0,255),if(is_ipv4=1, IPv4NumToString(ip4_0), IPv6NumToString(ip6_0)),dictGet(flow_tag.device_map, 'name', (toUInt64(auto_instance_type_0),toUInt64(auto_instance_id_0)))) AS `auto_instance_0`, if(auto_instance_type_1 in (0,255),if(is_ipv4=1, IPv4NumToString(ip4_1), IPv6NumToString(ip6_1)),dictGet(flow_tag.device_map, 'name', (toUInt64(auto_instance_type_1),toUInt64(auto_instance_id_1)))) AS `auto_instance_1`, `Enum(auto_service_type_0)`, `Enum(auto_service_type_1)`, if(auto_service_type_0 in (0,255),if(is_ipv4=1, IPv4NumToString(ip4_0), IPv6NumToString(ip6_0)),dictGet(flow_tag.device_map, 'name', (toUInt64(auto_service_type_0),toUInt64(auto_service_id_0)))) AS `auto_service_0`, if(auto_service_type_1 in (0,255),if(is_ipv4=1, IPv4NumToString(ip4_1), IPv6NumToString(ip6_1)),dictGet(flow_tag.device_map, 'name', (toUInt64(auto_service_type_1),toUInt64(auto_service_id_1)))) AS `auto_service_1`, dictGet(flow_tag.gprocess_map, 'name', (toUInt64(gprocess_id_0))) AS `gprocess_0`, dictGet(flow_tag.gprocess_map, 'name', (toUInt64(gprocess_id_1))) AS `gprocess_1`, if(dictGetOrDefault(flow_tag.pod_service_k8s_labels_map, 'labels', toUInt64(service_id_0),'{}')!='{}', dictGetOrDefault(flow_tag.pod_service_k8s_labels_map, 'labels', toUInt64(service_id_0),'{}'), dictGetOrDefault(flow_tag.pod_k8s_labels_map, 'labels', toUInt64(pod_id_0),'{}')) AS `k8s.label_0`, if(dictGetOrDefault(flow_tag.pod_service_k8s_labels_map, 'labels', toUInt64(service_id_1),'{}')!='{}', dictGetOrDefault(flow_tag.pod_service_k8s_labels_map, 'labels', toUInt64(service_id_1),'{}'), dictGetOrDefault(flow_tag.pod_k8s_labels_map, 'labels', toUInt64(pod_id_1),'{}')) AS `k8s.label_1`, if(dictGetOrDefault(flow_tag.pod_service_k8s_annotations_map, 'annotations', toUInt64(service_id_0),'{}')!='{}', dictGetOrDefault(flow_tag.pod_service_k8s_annotations_map, 'annotations', toUInt64(service_id_0),'{}'), dictGetOrDefault(flow_tag.pod_k8s_annotations_map, 'annotations', toUInt64(pod_id_0),'{}')) AS `k8s.annotation_0`, if(dictGetOrDefault(flow_tag.pod_service_k8s_annotations_map, 'annotations', toUInt64(service_id_1),'{}')!='{}', dictGetOrDefault(flow_tag.pod_service_k8s_annotations_map, 'annotations', toUInt64(service_id_1),'{}'), dictGetOrDefault(flow_tag.pod_k8s_annotations_map, 'annotations', toUInt64(pod_id_1),'{}')) AS `k8s.annotation_1`, dictGetOrDefault(flow_tag.pod_k8s_envs_map, 'envs', toUInt64(pod_id_0),'{}') AS `k8s.env_0`, dictGetOrDefault(flow_tag.pod_k8s_envs_map, 'envs', toUInt64(pod_id_1),'{}') AS `k8s.env_1`, toJSONString(CAST((attribute_names, attribute_values), 'Map(String, String)')) AS `attribute`, if(if(l3_device_type_0=1, dictGetOrDefault(flow_tag.chost_cloud_tags_map, 'cloud_tags', toUInt64(l3_device_id_0),'{}'), '{}')!='{}',if(l3_device_type_0=1, dictGetOrDefault(flow_tag.chost_cloud_tags_map, 'cloud_tags', toUInt64(l3_device_id_0),'{}'), '{}'), dictGetOrDefault(flow_tag.pod_ns_cloud_tags_map, 'cloud_tags', toUInt64(pod_ns_id_0),'{}')) AS `cloud.tag_0`, if(if(l3_device_type_1=1, dictGetOrDefault(flow_tag.chost_cloud_tags_map, 'cloud_tags', toUInt64(l3_device_id_1),'{}'), '{}')!='{}',if(l3_device_type_1=1, dictGetOrDefault(flow_tag.chost_cloud_tags_map, 'cloud_tags', toUInt64(l3_device_id_1),'{}'), '{}'), dictGetOrDefault(flow_tag.pod_ns_cloud_tags_map, 'cloud_tags', toUInt64(pod_ns_id_1),'{}')) AS `cloud.tag_1`, dictGetOrDefault(flow_tag.os_app_tags_map, 'os_app_tags', toUInt64(gprocess_id_0),'{}') AS `os.app_0`, dictGetOrDefault(flow_tag.os_app_tags_map, 'os_app_tags', toUInt64(gprocess_id_1),'{}') AS `os.app_1`, if(is_ipv4=1, IPv4NumToString(ip4_0), IPv6NumToString(ip6_0)) AS `ip_0`, if(is_ipv4=1, IPv4NumToString(ip4_1), IPv6NumToString(ip6_1)) AS `ip_1`, `Enum(is_ipv4)`, if(l3_epc_id_0=-2,1,0) AS `is_internet_0`, if(l3_epc_id_1=-2,1,0) AS `is_internet_1`, `Enum(protocol)`, `Enum(tunnel_type)`, client_port, `Enum(server_port)`, req_tcp_seq, resp_tcp_seq, `Enum(l7_protocol)`, l7_protocol_str, `Enum(is_tls)`, version, `Enum(type)`, request_type, request_domain, request_resource, request_id, `Enum(response_status)`, response_code, response_exception, response_result, events, app_service, app_instance, endpoint, process_id_0, process_id_1, process_kname_0, process_kname_1, trace_id, span_id, parent_span_id, `Enum(span_kind)`, x_request_id_0, x_request_id_1, http_proxy_client, syscall_trace_id_request, syscall_trace_id_response, syscall_thread_0, syscall_thread_1, syscall_coroutine_0, syscall_coroutine_1, syscall_cap_seq_0, syscall_cap_seq_1, flow_id, toString(start_time) AS `start_time`, toString(end_time) AS `end_time`, `Enum(signal_source)`, dictGet(flow_tag.tap_type_map, 'name', toUInt64(tap_type)) AS `tap`, dictGet(flow_tag.vtap_map, 'name', toUInt64(vtap_id)) AS `vtap`, `Enum(nat_source)`, tap_port, if(tap_port_type in (0,1,2),dictGet(flow_tag.vtap_port_map, 'name', (toUInt64(vtap_id),toUInt64(tap_port))),'') AS `tap_port_name`, `Enum(tap_port_type)`, `Enum(tap_side)`, region_id_0, region_id_1, az_id_0, az_id_1, host_id_0, host_id_1, if(l3_device_type_0=1,l3_device_id_0, 0) AS `chost_id_0`, if(l3_device_type_1=1,l3_device_id_1, 0) AS `chost_id_1`, l3_epc_id_0 AS `vpc_id_0`, l3_epc_id_1 AS `vpc_id_1`, epc_id_0 AS `l2_vpc_id_0`, epc_id_1 AS `l2_vpc_id_1`, subnet_id_0, subnet_id_1, if(l3_device_type_0=5,l3_device_id_0, 0) AS `router_id_0`, if(l3_device_type_1=5,l3_device_id_1, 0) AS `router_id_1`, if(l3_device_type_0=9,l3_device_id_0, 0) AS `dhcpgw_id_0`, if(l3_device_type_1=9,l3_device_id_1, 0) AS `dhcpgw_id_1`, if(l3_device_type_0=15,l3_device_id_0, 0) AS `lb_id_0`, if(l3_device_type_1=15,l3_device_id_1, 0) AS `lb_id_1`, if(l3_device_type_0=16,l3_device_id_0, 0) AS `natgw_id_0`, if(l3_device_type_1=16,l3_device_id_1, 0) AS `natgw_id_1`, if(l3_device_type_0=12,l3_device_id_0, 0) AS `redis_id_0`, if(l3_device_type_1=12,l3_device_id_1, 0) AS `redis_id_1`, if(l3_device_type_0=13,l3_device_id_0, 0) AS `rds_id_0`, if(l3_device_type_1=13,l3_device_id_1, 0) AS `rds_id_1`, pod_cluster_id_0, pod_cluster_id_1, pod_ns_id_0, pod_ns_id_1, pod_node_id_0, pod_node_id_1, service_id_0 AS `pod_service_id_0`, service_id_1 AS `pod_service_id_1`, pod_group_id_0, pod_group_id_1, pod_id_0, pod_id_1, service_id_0, service_id_1, if(auto_instance_type_0 in (0,255),subnet_id_0,auto_instance_id_0) AS `resource_gl0_id_0`, if(auto_instance_type_1 in (0,255),subnet_id_1,auto_instance_id_1) AS `resource_gl0_id_1`, if(auto_service_type_0 in (0,255),subnet_id_0,auto_service_id_0) AS `resource_gl1_id_0`, if(auto_service_type_1 in (0,255),subnet_id_1,auto_service_id_1) AS `resource_gl1_id_1`, if(auto_service_type_0 in (0,255),subnet_id_0,auto_service_id_0) AS `resource_gl2_id_0`, if(auto_service_type_1 in (0,255),subnet_id_1,auto_service_id_1) AS `resource_gl2_id_1`, if(auto_instance_type_0 in (0,255),subnet_id_0,auto_instance_id_0) AS `auto_instance_id_0`, if(auto_instance_type_1 in (0,255),subnet_id_1,auto_instance_id_1) AS `auto_instance_id_1`, if(auto_service_type_0 in (0,255),subnet_id_0,auto_service_id_0) AS `auto_service_id_0`, if(auto_service_type_1 in (0,255),subnet_id_1,auto_service_id_1) AS `auto_service_id_1`, gprocess_id_0, gprocess_id_1, tap_type AS `tap_id`, vtap_id FROM flow_log.`l7_flow_log` PREWHERE (((_id = 7344911817294518385 AND time=toDateTime(bitShiftRight(7344911817294518385, 32))))) OR (((_id = 7344911817294517913 AND time=toDateTime(bitShiftRight(7344911817294517913, 32))))) OR (((_id = 7344911817294518377 AND time=toDateTime(bitShiftRight(7344911817294518377, 32))))) ORDER BY `start_time` asc LIMIT 10000"}}

Are you willing to submit a PR?

• [X] Yes I am willing to submit a PR!

Code of Conduct

• [X] I agree to follow this project's Code of Conduct

[xiaochaoren1]

It may be a bug in clickhouse, I have reported it to the community.