SupplyChain场景 Builder 执行报错

Open the-butterfly opened this issue 1 year ago • 5 comments
按照用户手册执行供应链demo时，遇到报错：
(openspg_venv) root@docker-desktop:/code/python/knext/knext/examples/supplychain# knext builder execute ProductChainEvent
2024-04-30 03:57:44,128 [] [] [main] INFO  c.a.o.c.i.g.GraphStoreClientDriverManager - registerDriver: com.antgroup.openspg.cloudext.impl.graphstore.tugraph.TuGraphStoreClientDriver@6200f9cb
2024-04-30 03:57:44,136 [] [] [main] INFO  c.a.o.c.u.DriverManagerUtils - DriverManager.initialize: cloudext.graphstore.drivers = null
2024-04-30 03:57:44,138 [] [] [main] INFO  c.a.o.c.i.g.GraphStoreClientDriverManager - graph-store DriverManager initialized
2024-04-30 03:57:45,083 [] [] [main] INFO  c.a.o.c.i.s.SearchEngineClientDriverManager - registerDriver: com.antgroup.openspg.cloudext.impl.searchengine.elasticsearch.ElasticSearchEngineClientDriver@47a5b70d
2024-04-30 03:57:45,085 [] [] [main] INFO  c.a.o.c.u.DriverManagerUtils - DriverManager.initialize: cloudext.searchengine.drivers = null
2024-04-30 03:57:45,086 [] [] [main] INFO  c.a.o.c.i.s.SearchEngineClientDriverManager - search-engine DriverManager initialized
2024-04-30 03:57:47,985 [] [] [localBuilderRunner--0] INFO  lube - benchmark planToBlock cost = 322
2024-04-30 03:57:47,991 [] [] [localBuilderRunner--0] INFO  lube - benchmark registerSchema cost = 4
2024-04-30 03:57:49,080 [] [] [localBuilderRunner--0] INFO  lube - └─DDLBlock(ddlOp=Set(AddPredicate(PredicateElement(belongTo,p,(e:SupplyChain.ProductChainEvent),EntityElement(价格上涨,SupplyChain.TaxOfProdEvent,o),Map(__to_id_type__->VString(value=SupplyChain.TaxOfProdEvent/价格上涨),__to_id__->VString(value=价格上涨),__from_id__->UnaryOpExpr(name=GetField(id)),__from_id_type__->VString(value=SupplyChain.ProductChainEvent)),OUT))))
    └─FilterBlock(rules=LogicRule(R2,,BinaryOpExpr(name=BEqual)))
        └─FilterBlock(rules=LogicRule(R1,,BinaryOpExpr(name=BEqual)))
            └─MatchBlock(patterns=Map(unresolved_default_path -> GraphPath(unresolved_default_path,GraphPattern(e,Map(e -> (e:SupplyChain.ProductChainEvent)),Map(),Map(e -> Set(trend, index))),false)))
                └─SourceBlock(graph=KG(Map(e -> IRNode(e,Set(trend, index))),Map()))
2024-04-30 03:57:49,087 [] [] [localBuilderRunner--0] INFO  lube - benchmark main plan plan2UnresolvedLogicalPlan cost = 1424
2024-04-30 03:57:49,092 [] [] [localBuilderRunner--0] INFO  lube - benchmark LogicalPlannerContext cost = 4
2024-04-30 03:57:49,231 [] [] [localBuilderRunner--0] INFO  lube - benchmark validate cost = 137
2024-04-30 03:57:49,360 [] [] [localBuilderRunner--0] INFO  lube - benchmark LogicalPlanner.plan cost = 127
2024-04-30 03:57:49,431 [] [] [localBuilderRunner--0] INFO  lube - benchmark logicalPlans.map cost = 69
2024-04-30 03:57:49,434 [] [] [localBuilderRunner--0] INFO  lube - subQueryEnable false
2024-04-30 03:57:49,436 [] [] [localBuilderRunner--0] INFO  lube - benchmark optimizedLogicalPlans cost = 2
2024-04-30 03:57:49,837 [] [] [localBuilderRunner--0] INFO  lube - optimized logical plan:
└─DDL(ddlOp=Set(AddPredicate(PredicateElement(belongTo,p,(e:SupplyChain.ProductChainEvent),EntityElement(价格上涨,SupplyChain.TaxOfProdEvent,o),Map(__to_id_type__->VString(value=SupplyChain.TaxOfProdEvent/价格 上涨),__to_id__->VString(value=价格上涨),__from_id__->UnaryOpExpr(name=GetField(id)),__from_id_type__->VString(value=SupplyChain.ProductChainEvent)),OUT))))
    └─Project(expr=Map(NodeVar(e,Set(id::KTObject::true)) -> Directly$), solved=SolvedModel(Map(e -> Set(SupplyChain.ProductChainEvent)),Map(e -> NodeVar(e,Set(trend::KTConcept(SupplyChain.Trend)::true, index::KTConcept(SupplyChain.Index)::true))),Map()))
        └─PatternScan(pattern=NodePattern((e:SupplyChain.ProductChainEvent,BinaryOpExpr(name=BAnd))))
            └─Start(graph=KG, alias=e, types=Set(SupplyChain.ProductChainEvent), solved=SolvedModel(Map(e -> Set(SupplyChain.ProductChainEvent)),Map(e -> NodeVar(e,Set(trend::KTConcept(SupplyChain.Trend)::true, index::KTConcept(SupplyChain.Index)::true))),Map()))

2024-04-30 03:57:49,839 [] [] [localBuilderRunner--0] INFO  lube - benchmark logical show cost = 402
2024-04-30 03:57:49,842 [] [] [localBuilderRunner--0] INFO  lube - benchmark main plan plan2LogicalPlan cost = 754
2024-04-30 03:57:50,482 [] [] [localBuilderRunner--0] INFO  lube - kgreasoner physical plan:
└─DDL(ddlOp=Set(AddPredicate(PredicateElement(belongTo,p,(e:SupplyChain.ProductChainEvent),EntityElement(价格上涨,SupplyChain.TaxOfProdEvent,o),Map(__to_id_type__->VString(value=SupplyChain.TaxOfProdEvent/价格 上涨),__to_id__->VString(value=价格上涨),__from_id__->UnaryOpExpr(name=GetField(id)),__from_id_type__->VString(value=SupplyChain.ProductChainEvent)),OUT))))
    └─Drop(fields=Set(NodeVar(e,Set(trend::KTConcept(SupplyChain.Trend)::true, index::KTConcept(SupplyChain.Index)::true))))
        └─PatternScan(pattern=NodePattern((e:SupplyChain.ProductChainEvent,BinaryOpExpr(name=BAnd))), meta=List(NodeVar(e,Set(trend::KTConcept(SupplyChain.Trend)::true, index::KTConcept(SupplyChain.Index)::true))))
            └─Start(graphName=KG, alias=e, meta=List(NodeVar(e,Set(trend::KTConcept(SupplyChain.Trend)::true, index::KTConcept(SupplyChain.Index)::true))), types=Set(SupplyChain.ProductChainEvent))

2024-04-30 03:57:50,507 [] [] [localBuilderRunner--0] INFO  lube - benchmark main plan plan2PhysicalPlan cost = 663
2024-04-30 03:57:50,528 [] [] [localBuilderRunner--0] INFO  lube - begin to load graph data for KG
2024-04-30 03:57:50,816 [] [] [localBuilderRunner--0] WARN  c.a.o.r.u.r.RuleRunner - rule runner replace operator, name=min
2024-04-30 03:57:50,817 [] [] [localBuilderRunner--0] WARN  c.a.o.r.u.r.RuleRunner - rule runner replace operator, name=max
2024-04-30 03:57:50,903 [] [] [localBuilderRunner--0] INFO  c.a.o.r.r.l.r.LocalRDG - LocalRDG patternScan,,pattern=NodePattern((e:SupplyChain.ProductChainEvent,BinaryOpExpr(name=BAnd))),rule=["(e.trend == \"上 涨\") && (e.index == \"价格\")"],edgeRule={}
2024-04-30 03:57:51,024 [] [] [localBuilderRunner--0] INFO  c.a.o.r.r.l.r.LocalRDG - LocalRDG patternScan,root=(e:SupplyChain.ProductChainEvent,BinaryOpExpr(name=BAnd)),matchCount=1 cost time=159
2024-04-30 03:57:51,068 [] [] [localBuilderRunner--0] INFO  c.a.o.r.r.c.SinkRelationImpl - SinkRelation,start,index=0,size=1
2024-04-30 03:57:51,143 [] [] [localBuilderRunner--0] INFO  c.a.o.r.r.l.r.LocalRDG - LocalRDG.addRelation,sinkCount=1 addPredicate=AddPredicate(PredicateElement(belongTo,p,(e:SupplyChain.ProductChainEvent),EntityElement(价格上涨,SupplyChain.TaxOfProdEvent,o),Map(__to_id_type__->VString(value=SupplyChain.TaxOfProdEvent/价格上涨),__to_id__->VString(value=价格上涨),__from_id__->UnaryOpExpr(name=GetField(id)),__from_id_type__->VString(value=SupplyChain.ProductChainEvent)),OUT))
2024-04-30 03:57:51,146 [] [] [localBuilderRunner--0] INFO  c.a.o.r.r.l.LocalReasonerRunner - dsl,index=0,result=edge_list_start
(0) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_belongTo_SupplyChain.TaxOfProdEvent,o=SupplyChain.TaxOfProdEvent_-8986897777121294833,direction=OUT,version=0,property={"__to_id__":"价格上涨","__to_id_type__":"SupplyChain.TaxOfProdEvent/价格上涨","__from_id__":"1","__from_id_type__":"SupplyChain.ProductChainEvent"})
edge_list_end
2024-04-30 03:57:51,257 [] [] [localBuilderRunner--0] INFO  lube - benchmark planToBlock cost = 106
2024-04-30 03:57:51,260 [] [] [localBuilderRunner--0] INFO  lube - benchmark registerSchema cost = 1
2024-04-30 03:57:51,590 [] [] [localBuilderRunner--0] INFO  lube - └─DDLBlock(ddlOp=Set(AddPredicate(PredicateElement(leadTo,p,EntityElement(价格上涨,SupplyChain.TaxOfProdEvent,s),EntityElement(成本上涨,SupplyChain.TaxOfCompanyEvent,o),Map(__to_id_type__->VString(value=SupplyChain.TaxOfCompanyEvent/成本上涨),__to_id__->VString(value=成本上涨),__from_id__->UnaryOpExpr(name=GetField(id)),__from_id_type__->VString(value=SupplyChain.TaxOfProdEvent/价格上涨)),OUT)), AddVertex((downEvent:SupplyChain.CompanyEvent),Map(subject -> UnaryOpExpr(name=GetField(id)), name -> Ref(refName=eventName), trend -> VString(value=上涨), index -> VString(value=成本))), AddPredicate(PredicateElement(leadTo,anonymous_13,EntityElement(价格上涨,SupplyChain.TaxOfProdEvent,s),(downEvent:SupplyChain.CompanyEvent),Map(),OUT))))
    └─ProjectBlock(projects=ProjectFields(Map(IRVariable(eventName) -> ProjectRule(IRVariable(eventName),FunctionExpr(name=concat)))))
        └─MatchBlock(patterns=Map(unresolved_default_path -> GraphPath(unresolved_default_path,GraphPattern(s,Map(s -> EntityElement(价格上涨,SupplyChain.TaxOfProdEvent,s), prod -> (prod:SupplyChain.Product), down -> (down:SupplyChain.Product), c -> (c:SupplyChain.Company)),Map(s -> Set((s)->[anonymous_7:subject]-(prod))), prod -> Set((prod)->[anonymous_9:hasSupplyChain]-(down))), down -> Set((down)<-[anonymous_11:product]-(c)))),Map(down -> Set(), s -> Set(), anonymous_9 -> Set(), anonymous_11 -> Set(), prod -> Set(), anonymous_7 -> Set(), c -> Set(name))),false)))
            └─SourceBlock(graph=KG(Map(down -> IRNode(down,Set()), prod -> IRNode(prod,Set()), s -> IRNode(s,Set()), c -> IRNode(c,Set(name))),Map(anonymous_7 -> IREdge(anonymous_7,Set()), anonymous_11 -> IREdge(anonymous_11,Set()), anonymous_9 -> IREdge(anonymous_9,Set()))))
2024-04-30 03:57:51,593 [] [] [localBuilderRunner--0] INFO  lube - benchmark main plan plan2UnresolvedLogicalPlan cost = 442
2024-04-30 03:57:51,597 [] [] [localBuilderRunner--0] INFO  lube - benchmark LogicalPlannerContext cost = 0
2024-04-30 03:57:51,658 [] [] [localBuilderRunner--0] INFO  lube - validate dslName=SupplyChain.ProductChainEvent_belongTo_SupplyChain.TaxOfProdEvent/价格上涨, dsl=GeneralSemanticRule(Define (e:SupplyChain.ProductChainEvent)-[p:belongTo]->(o:`SupplyChain.TaxOfProdEvent`/`价格上涨`) {
            Structure {
            }
            Constraint {
                R1: e.index == '价格'
                R2: e.trend == '上涨'
            }
        })
2024-04-30 03:57:51,687 [] [] [localBuilderRunner--0] INFO  lube - benchmark validate cost = 89
2024-04-30 03:57:51,766 [] [] [localBuilderRunner--0] INFO  lube - benchmark LogicalPlanner.plan cost = 78
2024-04-30 03:57:51,839 [] [] [localBuilderRunner--0] INFO  lube - benchmark logicalPlans.map cost = 66
2024-04-30 03:57:51,842 [] [] [localBuilderRunner--0] INFO  lube - subQueryEnable false
2024-04-30 03:57:51,843 [] [] [localBuilderRunner--0] INFO  lube - benchmark optimizedLogicalPlans cost = 1
2024-04-30 03:57:52,089 [] [] [localBuilderRunner--0] INFO  lube - optimized logical plan:
└─DDL(ddlOp=Set(AddPredicate(PredicateElement(belongTo,p,(e:SupplyChain.ProductChainEvent),EntityElement(价格上涨,SupplyChain.TaxOfProdEvent,o),Map(__to_id_type__->VString(value=SupplyChain.TaxOfProdEvent/价格 上涨),__to_id__->VString(value=价格上涨),__from_id__->UnaryOpExpr(name=GetField(id)),__from_id_type__->VString(value=SupplyChain.ProductChainEvent)),OUT))))
    └─Project(expr=Map(NodeVar(e,Set(id::KTObject::true)) -> Directly$), solved=SolvedModel(Map(e -> Set(SupplyChain.ProductChainEvent)),Map(e -> NodeVar(e,Set(trend::KTConcept(SupplyChain.Trend)::true, index::KTConcept(SupplyChain.Index)::true))),Map()))
        └─PatternScan(pattern=NodePattern((e:SupplyChain.ProductChainEvent,BinaryOpExpr(name=BAnd))))
            └─Start(graph=KG, alias=e, types=Set(SupplyChain.ProductChainEvent), solved=SolvedModel(Map(e -> Set(SupplyChain.ProductChainEvent)),Map(e -> NodeVar(e,Set(trend::KTConcept(SupplyChain.Trend)::true, index::KTConcept(SupplyChain.Index)::true))),Map()))

2024-04-30 03:57:52,420 [] [] [localBuilderRunner--0] INFO  lube - optimized logical plan:
└─DDL(ddlOp=Set(AddPredicate(PredicateElement(leadTo,p,EntityElement(价格上涨,SupplyChain.TaxOfProdEvent,s),EntityElement(成本上涨,SupplyChain.TaxOfCompanyEvent,o),Map(__to_id_type__->VString(value=SupplyChain.TaxOfCompanyEvent/成本上涨),__to_id__->VString(value=成本上涨),__from_id__->UnaryOpExpr(name=GetField(id)),__from_id_type__->VString(value=SupplyChain.TaxOfProdEvent/价格上涨)),OUT)), AddPredicate(PredicateElement(leadTo,anonymous_13,EntityElement(价格上涨,SupplyChain.TaxOfProdEvent,s),(downEvent:SupplyChain.CompanyEvent),Map(),OUT)), AddVertex((downEvent:SupplyChain.CompanyEvent),Map(subject -> UnaryOpExpr(name=GetField(id)), name -> UnaryOpExpr(name=GetField(eventName)), trend -> VString(value=上涨), index -> VString(value=成本)))))
    └─Project(expr=Map(PropertyVar(c,eventName::KTString::true) -> FunctionExpr(name=concat), NodeVar(s,Set(id::KTObject::true)) -> Directly$, NodeVar(c,Set(eventName::KTObject::true, id::KTObject::true)) -> Directly$), solved=SolvedModel(Map(down -> Set(SupplyChain.Product), s -> Set(SupplyChain.ProductChainEvent), anonymous_9 -> Set(SupplyChain.Product_hasSupplyChain_SupplyChain.Product), anonymous_11 -> Set(SupplyChain.Company_product_SupplyChain.Product), E_C_5 -> Set(SupplyChain.ProductChainEvent_belongTo_SupplyChain.TaxOfProdEvent/价格上涨), prod -> Set(SupplyChain.Product), C_5 -> Set(SupplyChain.TaxOfProdEvent/价格上涨), anonymous_7 -> Set(SupplyChain.ProductChainEvent_subject_SupplyChain.Product), c -> Set(SupplyChain.Company)),Map(down -> NodeVar(down,Set()), s -> NodeVar(s,Set(id::KTString::true)), anonymous_9 -> EdgeVar(anonymous_9,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), anonymous_11 -> EdgeVar(anonymous_11,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), E_C_5 -> EdgeVar(E_C_5,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), prod -> NodeVar(prod,Set()), C_5 -> NodeVar(C_5,Set()), anonymous_7 -> EdgeVar(anonymous_7,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), c -> NodeVar(c,Set(name::KTString::true, eventName::KTString::true))),Map(IRVariable(eventName) -> PropertyVar(c,eventName::KTString::true))))
        └─ExpandInto(target=(c:SupplyChain.Company), pattern=NodePattern((c:SupplyChain.Company)))
            └─ExpandInto(target=(down:SupplyChain.Product), pattern=PartialGraphPattern(down,Map(down -> (down:SupplyChain.Product), c -> (c:SupplyChain.Company)),Map(down -> Set((down)<-[anonymous_11:product]-(c))))))
                └─ExpandInto(target=(prod:SupplyChain.Product), pattern=PartialGraphPattern(prod,Map(down -> (down:SupplyChain.Product), prod -> (prod:SupplyChain.Product)),Map(prod -> Set((prod)->[anonymous_9:hasSupplyChain]-(down))))))
                    └─PatternScan(pattern=PartialGraphPattern(s,Map(s -> (s:SupplyChain.ProductChainEvent), prod -> (prod:SupplyChain.Product), C_5 -> (C_5:SupplyChain.TaxOfProdEvent,BinaryOpExpr(name=BEqual))),Map(s -> Set((s)->[E_C_5:belongTo]-(C_5)), (s)->[anonymous_7:subject]-(prod))))))
                        └─Start(graph=KG, alias=s, types=Set(SupplyChain.ProductChainEvent), solved=SolvedModel(Map(down -> Set(SupplyChain.Product), s -> Set(SupplyChain.ProductChainEvent), anonymous_9 -> Set(SupplyChain.Product_hasSupplyChain_SupplyChain.Product), anonymous_11 -> Set(SupplyChain.Company_product_SupplyChain.Product), E_C_5 -> Set(SupplyChain.ProductChainEvent_belongTo_SupplyChain.TaxOfProdEvent/价格上涨), prod -> Set(SupplyChain.Product), C_5 -> Set(SupplyChain.TaxOfProdEvent/价格上涨), anonymous_7 -> Set(SupplyChain.ProductChainEvent_subject_SupplyChain.Product), c -> Set(SupplyChain.Company)),Map(down -> NodeVar(down,Set()), s -> NodeVar(s,Set(id::KTString::true)), anonymous_9 -> EdgeVar(anonymous_9,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), anonymous_11 -> EdgeVar(anonymous_11,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), E_C_5 -> EdgeVar(E_C_5,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), prod -> NodeVar(prod,Set()), C_5 -> NodeVar(C_5,Set()), anonymous_7 -> EdgeVar(anonymous_7,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), c -> NodeVar(c,Set(name::KTString::true))),Map()))

2024-04-30 03:57:52,423 [] [] [localBuilderRunner--0] INFO  lube - benchmark logical show cost = 578
2024-04-30 03:57:52,425 [] [] [localBuilderRunner--0] INFO  lube - benchmark main plan plan2LogicalPlan cost = 828
2024-04-30 03:57:52,617 [] [] [localBuilderRunner--0] INFO  lube - kgreasoner physical plan:
└─DDL(ddlOp=Set(AddPredicate(PredicateElement(belongTo,p,(e:SupplyChain.ProductChainEvent),EntityElement(价格上涨,SupplyChain.TaxOfProdEvent,o),Map(__to_id_type__->VString(value=SupplyChain.TaxOfProdEvent/价格 上涨),__to_id__->VString(value=价格上涨),__from_id__->UnaryOpExpr(name=GetField(id)),__from_id_type__->VString(value=SupplyChain.ProductChainEvent)),OUT))))
    └─Drop(fields=Set(NodeVar(e,Set(trend::KTConcept(SupplyChain.Trend)::true, index::KTConcept(SupplyChain.Index)::true))))
        └─PatternScan(pattern=NodePattern((e:SupplyChain.ProductChainEvent,BinaryOpExpr(name=BAnd))), meta=List(NodeVar(e,Set(trend::KTConcept(SupplyChain.Trend)::true, index::KTConcept(SupplyChain.Index)::true))))
            └─Start(graphName=KG, alias=e, meta=List(NodeVar(e,Set(trend::KTConcept(SupplyChain.Trend)::true, index::KTConcept(SupplyChain.Index)::true))), types=Set(SupplyChain.ProductChainEvent))

2024-04-30 03:57:52,933 [] [] [localBuilderRunner--0] INFO  lube - kgreasoner physical plan:
└─DDL(ddlOp=Set(AddPredicate(PredicateElement(leadTo,p,EntityElement(价格上涨,SupplyChain.TaxOfProdEvent,s),EntityElement(成本上涨,SupplyChain.TaxOfCompanyEvent,o),Map(__to_id_type__->VString(value=SupplyChain.TaxOfCompanyEvent/成本上涨),__to_id__->VString(value=成本上涨),__from_id__->UnaryOpExpr(name=GetField(id)),__from_id_type__->VString(value=SupplyChain.TaxOfProdEvent/价格上涨)),OUT)), AddPredicate(PredicateElement(leadTo,anonymous_13,EntityElement(价格上涨,SupplyChain.TaxOfProdEvent,s),(downEvent:SupplyChain.CompanyEvent),Map(),OUT)), AddVertex((downEvent:SupplyChain.CompanyEvent),Map(subject -> UnaryOpExpr(name=GetField(id)), name -> UnaryOpExpr(name=GetField(eventName)), trend -> VString(value=上涨), index -> VString(value=成本)))))
    └─Drop(fields=Set(EdgeVar(anonymous_7,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), EdgeVar(anonymous_11,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), EdgeVar(E_C_5,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), NodeVar(c,Set(name::KTString::true)), NodeVar(C_5,Set()), NodeVar(down,Set()), NodeVar(prod,Set()), EdgeVar(anonymous_9,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true))))
        └─AddInto(fields=Map(PropertyVar(c,eventName::KTString::true) -> FunctionExpr(name=concat)))
            └─ExpandInto(target=(c:SupplyChain.Company), pattern=NodePattern((c:SupplyChain.Company)), meta=List(EdgeVar(anonymous_7,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), NodeVar(down,Set()), EdgeVar(anonymous_11,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), NodeVar(s,Set(id::KTString::true)), NodeVar(prod,Set()), EdgeVar(anonymous_9,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), EdgeVar(E_C_5,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), NodeVar(C_5,Set()), NodeVar(c,Set(name::KTString::true))))
                └─ExpandInto(target=(down:SupplyChain.Product), pattern=PartialGraphPattern(down,Map(down -> (down:SupplyChain.Product), c -> (c:SupplyChain.Company)),Map(down -> Set((down)<-[anonymous_11:product]-(c))))), meta=List(EdgeVar(anonymous_7,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), EdgeVar(anonymous_11,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), NodeVar(down,Set()), NodeVar(prod,Set()), NodeVar(s,Set(id::KTString::true)), EdgeVar(anonymous_9,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), EdgeVar(E_C_5,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), NodeVar(C_5,Set()), NodeVar(c,Set())))
                    └─ExpandInto(target=(prod:SupplyChain.Product), pattern=PartialGraphPattern(prod,Map(down -> (down:SupplyChain.Product), prod -> (prod:SupplyChain.Product)),Map(prod -> Set((prod)->[anonymous_9:hasSupplyChain]-(down))))), meta=List(EdgeVar(anonymous_7,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), NodeVar(down,Set()), NodeVar(s,Set(id::KTString::true)), NodeVar(prod,Set()), EdgeVar(anonymous_9,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), EdgeVar(E_C_5,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), NodeVar(C_5,Set())))
                        └─PatternScan(pattern=PartialGraphPattern(s,Map(s -> (s:SupplyChain.ProductChainEvent), prod -> (prod:SupplyChain.Product), C_5 -> (C_5:SupplyChain.TaxOfProdEvent,BinaryOpExpr(name=BEqual))),Map(s -> Set((s)->[E_C_5:belongTo]-(C_5)), (s)->[anonymous_7:subject]-(prod))))), meta=List(EdgeVar(anonymous_7,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), NodeVar(prod,Set()), NodeVar(s,Set(id::KTString::true)), EdgeVar(E_C_5,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), NodeVar(C_5,Set())))
                            └─Start(graphName=KG, alias=s, meta=List(NodeVar(down,Set()), NodeVar(s,Set(id::KTString::true)), EdgeVar(anonymous_9,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), EdgeVar(anonymous_11,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), EdgeVar(E_C_5,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), NodeVar(prod,Set()), NodeVar(C_5,Set()), EdgeVar(anonymous_7,Set(__to_id__::KTString::true, __from_id__::KTString::true, __to_id_type__::KTString::true, __from_id_type__::KTString::true)), NodeVar(c,Set(name::KTString::true))), types=Set(SupplyChain.ProductChainEvent))

2024-04-30 03:57:52,936 [] [] [localBuilderRunner--0] INFO  lube - benchmark main plan plan2PhysicalPlan cost = 510
2024-04-30 03:57:52,937 [] [] [localBuilderRunner--0] INFO  lube - begin to load graph data for KG
2024-04-30 03:57:52,994 [] [] [localBuilderRunner--0] INFO  c.a.o.r.r.l.r.LocalRDG - LocalRDG patternScan,,pattern=NodePattern((e:SupplyChain.ProductChainEvent,BinaryOpExpr(name=BAnd))),rule=["(e.trend == \"上 涨\") && (e.index == \"价格\")"],edgeRule={}
2024-04-30 03:57:53,006 [] [] [localBuilderRunner--0] INFO  c.a.o.r.r.l.r.LocalRDG - LocalRDG patternScan,root=(e:SupplyChain.ProductChainEvent,BinaryOpExpr(name=BAnd)),matchCount=1 cost time=23
2024-04-30 03:57:53,010 [] [] [localBuilderRunner--0] INFO  c.a.o.r.r.c.SinkRelationImpl - SinkRelation,start,index=0,size=1
2024-04-30 03:57:53,046 [] [] [localBuilderRunner--0] INFO  c.a.o.r.r.l.r.LocalRDG - LocalRDG.addRelation,sinkCount=1 addPredicate=AddPredicate(PredicateElement(belongTo,p,(e:SupplyChain.ProductChainEvent),EntityElement(价格上涨,SupplyChain.TaxOfProdEvent,o),Map(__to_id_type__->VString(value=SupplyChain.TaxOfProdEvent/价格上涨),__to_id__->VString(value=价格上涨),__from_id__->UnaryOpExpr(name=GetField(id)),__from_id_type__->VString(value=SupplyChain.ProductChainEvent)),OUT))
2024-04-30 03:57:53,051 [] [] [localBuilderRunner--0] INFO  c.a.o.r.r.l.LocalReasonerRunner - dsl,index=0,result=edge_list_start
(0) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_belongTo_SupplyChain.TaxOfProdEvent,o=SupplyChain.TaxOfProdEvent_-8986897777121294833,direction=OUT,version=0,property={"__to_id__":"价格上涨","__to_id_type__":"SupplyChain.TaxOfProdEvent/价格上涨","__from_id__":"1","__from_id_type__":"SupplyChain.ProductChainEvent"})
edge_list_end
2024-04-30 03:57:53,073 [] [] [localBuilderRunner--0] INFO  c.a.o.r.r.l.r.LocalRDG - LocalRDG patternScan,,pattern=PartialGraphPattern(s,Map(s -> (s:SupplyChain.ProductChainEvent), prod -> (prod:SupplyChain.Product), C_5 -> (C_5:SupplyChain.TaxOfProdEvent,BinaryOpExpr(name=BEqual))),Map(s -> Set((s)->[E_C_5:belongTo]-(C_5)), (s)->[anonymous_7:subject]-(prod))))),rule=[],edgeRule={}
2024-04-30 03:57:53,100 [] [] [localBuilderRunner--0] INFO  c.a.o.r.r.l.r.LocalRDG - LocalRDG patternScan,root=(s:SupplyChain.ProductChainEvent),matchCount=1 cost time=46
2024-04-30 03:57:53,104 [] [] [localBuilderRunner--0] INFO  c.a.o.r.r.l.r.LocalRDG - ExpandInto __max_path_size__ = 3000
2024-04-30 03:57:53,122 [] [] [localBuilderRunner--0] INFO  c.a.o.r.r.l.r.LocalRDG - LocalRDG expandInto,,pattern=PartialGraphPattern(prod,Map(down -> (down:SupplyChain.Product), prod -> (prod:SupplyChain.Product)),Map(prod -> Set((prod)->[anonymous_9:hasSupplyChain]-(down))))),rule=[],edgeRule={}
2024-04-30 03:57:53,149 [] [] [localBuilderRunner--0] INFO  c.a.o.r.r.l.r.LocalRDG - LocalRDG ExpandInto,patternRoot=(prod:SupplyChain.Product),matchCount=1 cost time=44
2024-04-30 03:57:53,155 [] [] [localBuilderRunner--0] INFO  c.a.o.r.r.l.r.LocalRDG - ExpandInto __max_path_size__ = 3000
2024-04-30 03:57:53,163 [] [] [localBuilderRunner--0] INFO  c.a.o.r.r.l.r.LocalRDG - LocalRDG expandInto,,pattern=PartialGraphPattern(down,Map(down -> (down:SupplyChain.Product), c -> (c:SupplyChain.Company)),Map(down -> Set((down)<-[anonymous_11:product]-(c))))),rule=[],edgeRule={}
2024-04-30 03:57:53,209 [] [] [localBuilderRunner--0] INFO  c.a.o.r.r.l.r.LocalRDG - LocalRDG ExpandInto,patternRoot=(down:SupplyChain.Product),matchCount=7 cost time=51
2024-04-30 03:57:53,211 [] [] [localBuilderRunner--0] INFO  c.a.o.r.r.l.r.LocalRDG - ExpandInto __max_path_size__ = 3000
2024-04-30 03:57:53,218 [] [] [localBuilderRunner--0] INFO  c.a.o.r.r.l.r.LocalRDG - LocalRDG expandInto,,pattern=NodePattern((c:SupplyChain.Company)),rule=[],edgeRule={}
2024-04-30 03:57:53,274 [] [] [localBuilderRunner--0] INFO  c.a.o.r.r.l.r.LocalRDG - LocalRDG ExpandInto,patternRoot=(c:SupplyChain.Company),matchCount=47 cost time=60
2024-04-30 03:57:53,363 [] [] [localBuilderRunner--0] INFO  c.a.o.r.r.l.r.LocalRDG - LocalRDG.addVertex,sinkCount=47
2024-04-30 03:57:53,395 [] [] [localBuilderRunner--0] INFO  c.a.o.r.r.c.SinkRelationImpl - SinkRelation,start,index=0,size=1
2024-04-30 03:57:53,440 [] [] [localBuilderRunner--0] INFO  c.a.o.r.r.l.r.LocalRDG - LocalRDG.addRelation,sinkCount=1 addPredicate=AddPredicate(PredicateElement(leadTo,p,EntityElement(价格上涨,SupplyChain.TaxOfProdEvent,s),EntityElement(成本上涨,SupplyChain.TaxOfCompanyEvent,o),Map(__to_id_type__->VString(value=SupplyChain.TaxOfCompanyEvent/成本上涨),__to_id__->VString(value=成本上涨),__from_id__->UnaryOpExpr(name=GetField(id)),__from_id_type__->VString(value=SupplyChain.TaxOfProdEvent/价格上涨)),OUT))
2024-04-30 03:57:53,463 [] [] [localBuilderRunner--0] WARN  c.a.o.r.u.r.RuleRunner - RuleRunner error, rule=downEvent.id==null ? null.__to_id__ : downEvent.id,ctx={"p":{"__to_id__":"成本上涨","__label__":"leadTo","__to_id_type__":"SupplyChain.TaxOfCompanyEvent","__to_internal_id__":-6569627073882229856,"__from_id__":"1","__from_id_type__":"SupplyChain.ProductChainEvent","__from_internal_id__":4069221403129534712},"s":{"__id__":4069221403129534712,"__label__":"SupplyChain.ProductChainEvent","trend":"上涨","subject":"商品化工-橡胶-合成橡胶-顺丁橡胶","name":"顺丁橡胶成本上涨","index":"价格","belongTo":"价格上涨","id":"1"},"prod":{"__id__":-3448220233335386784,"__label__":"SupplyChain.Product","hasSupplyChain":"化工商品贸易-化工产品贸易-橡塑制品贸易,轮胎与橡胶-轮胎,轮胎与橡胶-轮胎-特种轮胎,轮胎与橡胶-轮胎-工程轮胎,轮胎与橡胶-轮胎-斜交轮胎,轮胎与橡胶-轮胎-全钢子午线轮胎,轮胎与橡胶-轮胎-半钢子午线轮胎","id":"商品化工-橡胶-合成橡胶-顺丁橡胶","belongToIndustry":"原材料-原材料-化学制品-商品化工"},"c":{"product":"建筑、农用机械与重型卡车-农业机械,汽车-汽车制造,轮胎与橡胶-轮胎,建筑、农用机械与重型卡车-工程机械-筑养路机械","__id__":1136854034829143570,"__label__":"SupplyChain.Company","eventName":"深**际控**公司成本上升事件","id":"CSF0000000100"},"downEvent":{"__id__":8896746952537859939,"__label__":"SupplyChain.CompanyEvent","trend":"上涨","subject":"CSF0000000100","name":"深**际控**公司成本上升事件","index":"成本"},"E_C_5":{"__label__":"belongTo","__to_id_type__":"SupplyChain.TaxOfProdEvent","__to_internal_id__":-8986897777121294833,"__from_internal_id__":4069221403129534712,"__from_id_type__":"SupplyChain.ProductChainEvent"},"C_5":{"__id__":-8986897777121294833,"__label__":"SupplyChain.TaxOfProdEvent"},"anonymous_11":{"__label__":"product","__to_id_type__":"SupplyChain.Product","__to_internal_id__":-7772401331382475219,"__from_internal_id__":1136854034829143570,"__from_id_type__":"SupplyChain.Company"},"anonymous_7":{"__label__":"subject","__to_id_type__":"SupplyChain.Product","__to_internal_id__":-3448220233335386784,"__from_internal_id__":4069221403129534712,"__from_id_type__":"SupplyChain.ProductChainEvent"},"down":{"__id__":-7772401331382475219,"__label__":"SupplyChain.Product","hasSupplyChain":"汽车-汽车制造,建筑、农用机械与重型卡车-环卫机械-环卫车,消闲用品-自行车,机动车贸 易-机动车零配件零售,建筑、农用机械与重型卡车-重卡及专用车,汽车,建筑、农用机械与重型卡车-工程机械-工业车辆,商业服务-综合支持服务-加工劳务-轮胎分装,建筑、农用机械与重型卡车-农业机械-农机具及其零部件-农用车辆,建筑、农用机械与重型卡车-机场服务设备-机场专用车辆","id":"轮胎与橡胶-轮胎","belongToIndustry":"非日常生活消费品-汽车与汽车零部件-汽车零配件-轮胎与橡胶"},"anonymous_9":{"__label__":"hasSupplyChain","__to_id_type__":"SupplyChain.Product","__to_internal_id__":-7772401331382475219,"__from_internal_id__":-3448220233335386784,"__from_id_type__":"SupplyChain.Product"}}
java.lang.RuntimeException: java.lang.NullPointerException
        at com.ql.util.express.ExpressUtil.getPropertyClass(ExpressUtil.java:656)
        at com.ql.util.express.instruction.opdata.OperateDataField.getType(OperateDataField.java:111)
        at com.ql.util.express.InstructionSet.execute(InstructionSet.java:172)
        at com.ql.util.express.InstructionSetRunner.execute(InstructionSetRunner.java:59)
        at com.ql.util.express.InstructionSetRunner.execute(InstructionSetRunner.java:50)
        at com.ql.util.express.InstructionSetRunner.executeOuter(InstructionSetRunner.java:22)
        at com.ql.util.express.ExpressRunner.executeReentrant(ExpressRunner.java:654)
        at com.ql.util.express.ExpressRunner.execute(ExpressRunner.java:641)
        at com.antgroup.openspg.reasoner.udf.rule.RuleRunner.executeExpression(RuleRunner.java:146)
        at com.antgroup.openspg.reasoner.rdg.common.ExtractRelationImpl.getEdgeProperty(ExtractRelationImpl.java:157)
        at com.antgroup.openspg.reasoner.rdg.common.ExtractRelationImpl.extractEdge(ExtractRelationImpl.java:131)
        at com.antgroup.openspg.reasoner.runner.local.rdg.LocalRDG.addRelation(LocalRDG.java:1075)
        at com.antgroup.openspg.reasoner.runner.local.rdg.LocalRDG.ddl(LocalRDG.java:1005)
        at com.antgroup.openspg.reasoner.runner.local.rdg.LocalRDG.ddl(LocalRDG.java:119)
        at com.antgroup.openspg.reasoner.lube.physical.operators.DDL.rdg(DDL.scala:48)
        at com.antgroup.openspg.reasoner.runner.local.LocalReasonerRunner.doRun(LocalReasonerRunner.java:185)
        at com.antgroup.openspg.reasoner.runner.local.LocalReasonerRunner.run(LocalReasonerRunner.java:68)
        at com.antgroup.openspg.builder.core.reason.impl.CausalConceptReasoner.leadTo(CausalConceptReasoner.java:122)
        at com.antgroup.openspg.builder.core.reason.impl.CausalConceptReasoner.propagate(CausalConceptReasoner.java:85)
        at com.antgroup.openspg.builder.core.reason.impl.CausalConceptReasoner.reason(CausalConceptReasoner.java:51)
        at com.antgroup.openspg.builder.core.reason.ReasonProcessor.reasoning(ReasonProcessor.java:110)
        at com.antgroup.openspg.builder.core.reason.ReasonProcessor.process(ReasonProcessor.java:92)
        at com.antgroup.openspg.builder.runner.local.LocalBuilderRunner.reason(LocalBuilderRunner.java:134)
        at com.antgroup.openspg.builder.runner.local.LocalBuilderRunner.lambda$execute$0(LocalBuilderRunner.java:114)
        at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1640)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:750)
Caused by: java.lang.NullPointerException: null
        at com.ql.util.express.ExpressUtil.getPropertyClass(ExpressUtil.java:636)
        ... 27 common frames omitted



2024-04-30 03:57:53,965 [] [] [localBuilderRunner--0] WARN  c.a.o.r.u.r.RuleRunner - RuleRunner error, rule=downEvent.id==null ? null.__to_id__ : downEvent.id,ctx={"p":{"__to_id__":"成本上涨","__label__":"leadTo","__to_id_type__":"SupplyChain.TaxOfCompanyEvent","__to_internal_id__":-6569627073882229856,"__from_id__":"1","__from_id_type__":"SupplyChain.ProductChainEvent","__from_internal_id__":4069221403129534712},"s":{"__id__":4069221403129534712,"__label__":"SupplyChain.ProductChainEvent","trend":"上涨","subject":"商品化工-橡胶-合成橡胶-顺丁橡胶","name":"顺丁橡胶成本上涨","index":"价格","belongTo":"价格上涨","id":"1"},"prod":{"__id__":-3448220233335386784,"__label__":"SupplyChain.Product","hasSupplyChain":"化工商品贸易-化工产品贸易-橡塑制品贸易,轮胎与橡胶-轮胎,轮胎与橡胶-轮胎-特种轮胎,轮胎与橡胶-轮胎-工程轮胎,轮胎与橡胶-轮胎-斜交轮胎,轮胎与橡胶-轮胎-全钢子午线轮胎,轮胎与橡胶-轮胎-半钢子午线轮胎","id":"商品化工-橡胶-合成橡胶-顺丁橡胶","belongToIndustry":"原材料-原材料-化学制品-商品化工"},"c":{"product":"建筑、农用机械与重型卡车-农业机械-农机具及其零部件-农用车辆,汽车,轮胎与橡胶-轮胎,建筑、农用机械与重型卡车","__id__":-176382253276584509,"__label__":"SupplyChain.Company","eventName":"嘉华***团*公司成本上升事件","id":"CSF0000000087"},"downEvent":{"__id__":3728690236591926833,"__label__":"SupplyChain.CompanyEvent","trend":"上涨","subject":"CSF0000000087","name":"嘉华***团*公司成本上升事件","index":"成本"},"E_C_5":{"__label__":"belongTo","__to_id_type__":"SupplyChain.TaxOfProdEvent","__to_internal_id__":-8986897777121294833,"__from_internal_id__":4069221403129534712,"__from_id_type__":"SupplyChain.ProductChainEvent"},"C_5":{"__id__":-8986897777121294833,"__label__":"SupplyChain.TaxOfProdEvent"},"anonymous_11":{"__label__":"product","__to_id_type__":"SupplyChain.Product","__to_internal_id__":-7772401331382475219,"__from_internal_id__":-176382253276584509,"__from_id_type__":"SupplyChain.Company"},"anonymous_7":{"__label__":"subject","__to_id_type__":"SupplyChain.Product","__to_internal_id__":-3448220233335386784,"__from_internal_id__":4069221403129534712,"__from_id_type__":"SupplyChain.ProductChainEvent"},"down":{"__id__":-7772401331382475219,"__label__":"SupplyChain.Product","hasSupplyChain":"汽车-汽车制造,建筑、农用机械与重型卡车-环卫机械-环卫车,消闲用品-自行车,机动车贸易- 机动车零配件零售,建筑、农用机械与重型卡车-重卡及专用车,汽车,建筑、农用机械与重型卡车-工程机械-工业车辆,商业服务-综合支持服务-加工劳务-轮胎分装,建筑、农用机械与重型卡车-农业机械-农机具及其零部件-农用车辆,建筑、 农用机械与重型卡车-机场服务设备-机场专用车辆","id":"轮胎与橡胶-轮胎","belongToIndustry":"非日常生活消费品-汽车与汽车零部件-汽车零配件-轮胎与橡胶"},"anonymous_9":{"__label__":"hasSupplyChain","__to_id_type__":"SupplyChain.Product","__to_internal_id__":-7772401331382475219,"__from_internal_id__":-3448220233335386784,"__from_id_type__":"SupplyChain.Product"}}
java.lang.RuntimeException: java.lang.NullPointerException
        at com.ql.util.express.ExpressUtil.getPropertyClass(ExpressUtil.java:656)
        at com.ql.util.express.instruction.opdata.OperateDataField.getType(OperateDataField.java:111)
        at com.ql.util.express.InstructionSet.execute(InstructionSet.java:172)
        at com.ql.util.express.InstructionSetRunner.execute(InstructionSetRunner.java:59)
        at com.ql.util.express.InstructionSetRunner.execute(InstructionSetRunner.java:50)
        at com.ql.util.express.InstructionSetRunner.executeOuter(InstructionSetRunner.java:22)
        at com.ql.util.express.ExpressRunner.executeReentrant(ExpressRunner.java:654)
        at com.ql.util.express.ExpressRunner.execute(ExpressRunner.java:641)
        at com.antgroup.openspg.reasoner.udf.rule.RuleRunner.executeExpression(RuleRunner.java:146)
        at com.antgroup.openspg.reasoner.rdg.common.ExtractRelationImpl.getEdgeProperty(ExtractRelationImpl.java:157)
        at com.antgroup.openspg.reasoner.rdg.common.ExtractRelationImpl.extractEdge(ExtractRelationImpl.java:142)
        at com.antgroup.openspg.reasoner.runner.local.rdg.LocalRDG.addRelation(LocalRDG.java:1075)
        at com.antgroup.openspg.reasoner.runner.local.rdg.LocalRDG.ddl(LocalRDG.java:1005)
        at com.antgroup.openspg.reasoner.runner.local.rdg.LocalRDG.ddl(LocalRDG.java:119)
        at com.antgroup.openspg.reasoner.lube.physical.operators.DDL.rdg(DDL.scala:48)
        at com.antgroup.openspg.reasoner.runner.local.LocalReasonerRunner.doRun(LocalReasonerRunner.java:185)
        at com.antgroup.openspg.reasoner.runner.local.LocalReasonerRunner.run(LocalReasonerRunner.java:68)
        at com.antgroup.openspg.builder.core.reason.impl.CausalConceptReasoner.leadTo(CausalConceptReasoner.java:122)
        at com.antgroup.openspg.builder.core.reason.impl.CausalConceptReasoner.propagate(CausalConceptReasoner.java:85)
        at com.antgroup.openspg.builder.core.reason.impl.CausalConceptReasoner.reason(CausalConceptReasoner.java:51)
        at com.antgroup.openspg.builder.core.reason.ReasonProcessor.reasoning(ReasonProcessor.java:110)
        at com.antgroup.openspg.builder.core.reason.ReasonProcessor.process(ReasonProcessor.java:92)
        at com.antgroup.openspg.builder.runner.local.LocalBuilderRunner.reason(LocalBuilderRunner.java:134)
        at com.antgroup.openspg.builder.runner.local.LocalBuilderRunner.lambda$execute$0(LocalBuilderRunner.java:114)
        at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1640)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:750)
Caused by: java.lang.NullPointerException: null
        at com.ql.util.express.ExpressUtil.getPropertyClass(ExpressUtil.java:636)
        ... 27 common frames omitted
2024-04-30 03:57:53,968 [] [] [localBuilderRunner--0] INFO  c.a.o.r.r.c.SinkRelationImpl - SinkRelation,start,index=0,size=94
2024-04-30 03:57:53,974 [] [] [localBuilderRunner--0] INFO  c.a.o.r.r.l.r.LocalRDG - LocalRDG.addRelation,sinkCount=94 addPredicate=AddPredicate(PredicateElement(leadTo,anonymous_13,EntityElement(价格上涨,SupplyChain.TaxOfProdEvent,s),(downEvent:SupplyChain.CompanyEvent),Map(),OUT))
2024-04-30 03:57:53,977 [] [] [localBuilderRunner--0] INFO  c.a.o.r.r.l.LocalReasonerRunner - dsl,index=1,result=vertex_list_start
(0) Vertex(s=SupplyChain.CompanyEvent_-8486836693782068822,property={trend:{0:上涨},subject:{0:CSF0000000004},name:{0:建发***资**有公司成本上升事件},index:{0:成本}})
(1) Vertex(s=SupplyChain.CompanyEvent_462974787522099821,property={trend:{0:上涨},subject:{0:CSF0000000040},name:{0:联*能***有公司成本上升事件},index:{0:成本}})
(2) Vertex(s=SupplyChain.CompanyEvent_5617176415042229704,property={trend:{0:上涨},subject:{0:CSF0000000083},name:{0:上置*团*公司成本上升事件},index:{0:成本}})
(3) Vertex(s=SupplyChain.CompanyEvent_5937196811685821075,property={trend:{0:上涨},subject:{0:CSF0000000010},name:{0:广东***通*份*公司成本上升事件},index:{0:成本}})
(4) Vertex(s=SupplyChain.CompanyEvent_-3335541146878068368,property={trend:{0:上涨},subject:{0:CSF0000000028},name:{0:中**信*份*公司成本上升事件},index:{0:成本}})
(5) Vertex(s=SupplyChain.CompanyEvent_5395682398005523424,property={trend:{0:上涨},subject:{0:CSF0000000011},name:{0:耀*集*有公司成本上升事件},index:{0:成本}})
(6) Vertex(s=SupplyChain.CompanyEvent_7827444667888821439,property={trend:{0:上涨},subject:{0:CSF0000000083},name:{0:上置*团*公司成本上升事件},index:{0:成本}})
(7) Vertex(s=SupplyChain.CompanyEvent_7077097021873686732,property={trend:{0:上涨},subject:{0:CSF0000000021},name:{0:亚洲***中**控公司成本上升事件},index:{0:成本}})
(8) Vertex(s=SupplyChain.CompanyEvent_6132249539870973851,property={trend:{0:上涨},subject:{0:CSF0000000032},name:{0:中国再****际*公司成本上升事件},index:{0:成本}})
(9) Vertex(s=SupplyChain.CompanyEvent_-338043344653927237,property={trend:{0:上涨},subject:{0:CSF0000002238},name:{0:三角***份限公司成本上升事件},index:{0:成本}})
(10) Vertex(s=SupplyChain.CompanyEvent_8469280348254035176,property={trend:{0:上涨},subject:{0:CSF0000000063},name:{0:中**气*股*公司成本上升事件},index:{0:成本}})
(11) Vertex(s=SupplyChain.CompanyEvent_-9043442913946732073,property={trend:{0:上涨},subject:{0:CSF0000000038},name:{0:协合*能*集**公司成本上升事件},index:{0:成本}})
(12) Vertex(s=SupplyChain.CompanyEvent_-1015755473651555483,property={trend:{0:上涨},subject:{0:CSF0000000069},name:{0:深**股有公司成本上升事件},index:{0:成本}})
(13) Vertex(s=SupplyChain.CompanyEvent_-6302310949166797622,property={trend:{0:上涨},subject:{0:CSF0000000098},name:{0:国***结*控*有公司成本上升事件},index:{0:成本}})
(14) Vertex(s=SupplyChain.CompanyEvent_-1114133869926420099,property={trend:{0:上涨},subject:{0:CSF0000000085},name:{0:力*科**团*公司成本上升事件},index:{0:成本}})
(15) Vertex(s=SupplyChain.CompanyEvent_7497762330945101899,property={trend:{0:上涨},subject:{0:CSF0000000040},name:{0:联*能***有公司成本上升事件},index:{0:成本}})
(16) Vertex(s=SupplyChain.CompanyEvent_8896746952537859939,property={trend:{0:上涨},subject:{0:CSF0000000100},name:{0:深**际控**公司成本上升事件},index:{0:成本}})
(17) Vertex(s=SupplyChain.CompanyEvent_-589090078410898322,property={trend:{0:上涨},subject:{0:CSF0000000050},name:{0:恒*兆*地**公司成本上升事件},index:{0:成本}})
(18) Vertex(s=SupplyChain.CompanyEvent_-769728728481246879,property={trend:{0:上涨},subject:{0:CSF0000000076},name:{0:中**信*务**有公司成本上升事件},index:{0:成本}})
(19) Vertex(s=SupplyChain.CompanyEvent_885287996187651726,property={trend:{0:上涨},subject:{0:CSF0000000002},name:{0:新晨*国***股*公司成本上升事件},index:{0:成本}})
(20) Vertex(s=SupplyChain.CompanyEvent_3644941857211719368,property={trend:{0:上涨},subject:{0:CSF0000000019},name:{0:新疆**节**溉*份*公司成本上升事件},index:{0:成本}})
(21) Vertex(s=SupplyChain.CompanyEvent_3624501879395538023,property={trend:{0:上涨},subject:{0:CSF0000000031},name:{0:首***发展股**公司成本上升事件},index:{0:成本}})
(22) Vertex(s=SupplyChain.CompanyEvent_-7778518132881646685,property={trend:{0:上涨},subject:{0:CSF0000000093},name:{0:永*国*有公司成本上升事件},index:{0:成本}})
(23) Vertex(s=SupplyChain.CompanyEvent_7402822199814974596,property={trend:{0:上涨},subject:{0:CSF0000000039},name:{0:国*零**股*公司成本上升事件},index:{0:成本}})
(24) Vertex(s=SupplyChain.CompanyEvent_3196012830900704256,property={trend:{0:上涨},subject:{0:CSF0000000066},name:{0:旭**业有公司成本上升事件},index:{0:成本}})
(25) Vertex(s=SupplyChain.CompanyEvent_1446572235996568583,property={trend:{0:上涨},subject:{0:CSF0000000077},name:{0:中*电子***技*公司成本上升事件},index:{0:成本}})
(26) Vertex(s=SupplyChain.CompanyEvent_8453867794240107192,property={trend:{0:上涨},subject:{0:CSF0000000022},name:{0:宏*集*有公司成本上升事件},index:{0:成本}})
(27) Vertex(s=SupplyChain.CompanyEvent_1212930304006877794,property={trend:{0:上涨},subject:{0:CSF0000000094},name:{0:华**酒*控*）*公司成本上升事件},index:{0:成本}})
(28) Vertex(s=SupplyChain.CompanyEvent_-4255701937956014060,property={trend:{0:上涨},subject:{0:CSF0000000015},name:{0:润中***股*公司成本上升事件},index:{0:成本}})
(29) Vertex(s=SupplyChain.CompanyEvent_-7960104771602952884,property={trend:{0:上涨},subject:{0:CSF0000000013},name:{0:中***集成电路***公司成本上升事件},index:{0:成本}})
(30) Vertex(s=SupplyChain.CompanyEvent_601990662025260031,property={trend:{0:上涨},subject:{0:CSF0000000009},name:{0:拉近*娱***公司成本上升事件},index:{0:成本}})
(31) Vertex(s=SupplyChain.CompanyEvent_5574659408609180145,property={trend:{0:上涨},subject:{0:CSF0000000028},name:{0:中**信*份*公司成本上升事件},index:{0:成本}})
(32) Vertex(s=SupplyChain.CompanyEvent_5271436563422163029,property={trend:{0:上涨},subject:{0:CSF0000002238},name:{0:三角***份限公司成本上升事件},index:{0:成本}})
(33) Vertex(s=SupplyChain.CompanyEvent_-4792492401813770531,property={trend:{0:上涨},subject:{0:CSF0000000001},name:{0:北京***能源*保****股**公司成本上升事件},index:{0:成本}})
(34) Vertex(s=SupplyChain.CompanyEvent_3135995701701297263,property={trend:{0:上涨},subject:{0:CSF0000000033},name:{0:辉**技*控股**公司成本上升事件},index:{0:成本}})
(35) Vertex(s=SupplyChain.CompanyEvent_-4052741910722185139,property={trend:{0:上涨},subject:{0:CSF0000000099},name:{0:中国*产**易*公司成本上升事件},index:{0:成本}})
(36) Vertex(s=SupplyChain.CompanyEvent_-3545054586200475048,property={trend:{0:上涨},subject:{0:CSF0000000011},name:{0:耀*集*有公司成本上升事件},index:{0:成本}})
(37) Vertex(s=SupplyChain.CompanyEvent_3728690236591926833,property={trend:{0:上涨},subject:{0:CSF0000000087},name:{0:嘉华***团*公司成本上升事件},index:{0:成本}})
(38) Vertex(s=SupplyChain.CompanyEvent_-4468377807098781344,property={trend:{0:上涨},subject:{0:CSF0000000024},name:{0:中国***份*公司成本上升事件},index:{0:成本}})
(39) Vertex(s=SupplyChain.CompanyEvent_46267093100475824,property={trend:{0:上涨},subject:{0:CSF0000000043},name:{0:奥**团*股*公司成本上升事件},index:{0:成本}})
(40) Vertex(s=SupplyChain.CompanyEvent_-4709285296247875649,property={trend:{0:上涨},subject:{0:CSF0000000051},name:{0:波司*国*控**公司成本上升事件},index:{0:成本}})
(41) Vertex(s=SupplyChain.CompanyEvent_-907651127746350284,property={trend:{0:上涨},subject:{0:CSF0000000073},name:{0:大***集*有公司成本上升事件},index:{0:成本}})
(42) Vertex(s=SupplyChain.CompanyEvent_-7989924450241827299,property={trend:{0:上涨},subject:{0:CSF0000000024},name:{0:中国***份*公司成本上升事件},index:{0:成本}})
(43) Vertex(s=SupplyChain.CompanyEvent_-2464437588173086471,property={trend:{0:上涨},subject:{0:CSF0000000058},name:{0:国*集*控**公司成本上升事件},index:{0:成本}})
(44) Vertex(s=SupplyChain.CompanyEvent_-6306438441838115452,property={trend:{0:上涨},subject:{0:CSF0000000022},name:{0:宏*集*有公司成本上升事件},index:{0:成本}})
(45) Vertex(s=SupplyChain.CompanyEvent_8952274192673481730,property={trend:{0:上涨},subject:{0:CSF0000000059},name:{0:北控***团*公司成本上升事件},index:{0:成本}})
(46) Vertex(s=SupplyChain.CompanyEvent_1991217184125426375,property={trend:{0:上涨},subject:{0:CSF0000000056},name:{0:中*动*（**）*公司成本上升事件},index:{0:成本}})
vertex_list_end
edge_list_start
(0) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_-4255701937956014060,direction=OUT,version=0,property={"__from_id__":"1"})
(1) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_1212930304006877794,direction=OUT,version=0,property={"__from_id__":"1"})
(2) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_-2464437588173086471,direction=OUT,version=0,property={"__from_id__":"1"})
(3) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.TaxOfCompanyEvent,o=SupplyChain.TaxOfCompanyEvent_-6569627073882229856,direction=OUT,version=0,property={"__to_id__":"成本上涨","__to_id_type__":"SupplyChain.TaxOfCompanyEvent/成本上涨","__from_id__":"1","__from_id_type__":"SupplyChain.TaxOfProdEvent/价格上涨"})
(4) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_-6302310949166797622,direction=OUT,version=0,property={"__from_id__":"1"})
(5) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_885287996187651726,direction=OUT,version=0,property={"__from_id__":"1"})
(6) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_-4709285296247875649,direction=OUT,version=0,property={"__from_id__":"1"})
(7) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_-7960104771602952884,direction=OUT,version=0,property={"__from_id__":"1"})
(8) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_-6306438441838115452,direction=OUT,version=0,property={"__from_id__":"1"})
(9) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_-8486836693782068822,direction=OUT,version=0,property={"__from_id__":"1"})
(10) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_1446572235996568583,direction=OUT,version=0,property={"__from_id__":"1"})
(11) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_-907651127746350284,direction=OUT,version=0,property={"__from_id__":"1"})
(12) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_3624501879395538023,direction=OUT,version=0,property={"__from_id__":"1"})
(13) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_7077097021873686732,direction=OUT,version=0,property={"__from_id__":"1"})
(14) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_-4792492401813770531,direction=OUT,version=0,property={"__from_id__":"1"})
(15) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_-7778518132881646685,direction=OUT,version=0,property={"__from_id__":"1"})
(16) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_601990662025260031,direction=OUT,version=0,property={"__from_id__":"1"})
(17) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_-4052741910722185139,direction=OUT,version=0,property={"__from_id__":"1"})
(18) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_3135995701701297263,direction=OUT,version=0,property={"__from_id__":"1"})
(19) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_-589090078410898322,direction=OUT,version=0,property={"__from_id__":"1"})
(20) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_-3545054586200475048,direction=OUT,version=0,property={"__from_id__":"1"})
(21) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_8896746952537859939,direction=OUT,version=0,property={"__from_id__":"1"})
(22) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_-7989924450241827299,direction=OUT,version=0,property={"__from_id__":"1"})
(23) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_-338043344653927237,direction=OUT,version=0,property={"__from_id__":"1"})
(24) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_3644941857211719368,direction=OUT,version=0,property={"__from_id__":"1"})
(25) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_7497762330945101899,direction=OUT,version=0,property={"__from_id__":"1"})
(26) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_5617176415042229704,direction=OUT,version=0,property={"__from_id__":"1"})
(27) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_5937196811685821075,direction=OUT,version=0,property={"__from_id__":"1"})
(28) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_-3335541146878068368,direction=OUT,version=0,property={"__from_id__":"1"})
(29) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_3196012830900704256,direction=OUT,version=0,property={"__from_id__":"1"})
(30) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_7827444667888821439,direction=OUT,version=0,property={"__from_id__":"1"})
(31) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_6132249539870973851,direction=OUT,version=0,property={"__from_id__":"1"})
(32) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_-4468377807098781344,direction=OUT,version=0,property={"__from_id__":"1"})
(33) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_7402822199814974596,direction=OUT,version=0,property={"__from_id__":"1"})
(34) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_8952274192673481730,direction=OUT,version=0,property={"__from_id__":"1"})
(35) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_8469280348254035176,direction=OUT,version=0,property={"__from_id__":"1"})
(36) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_-1015755473651555483,direction=OUT,version=0,property={"__from_id__":"1"})
(37) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_-9043442913946732073,direction=OUT,version=0,property={"__from_id__":"1"})
(38) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_-1114133869926420099,direction=OUT,version=0,property={"__from_id__":"1"})
(39) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_5395682398005523424,direction=OUT,version=0,property={"__from_id__":"1"})
(40) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_8453867794240107192,direction=OUT,version=0,property={"__from_id__":"1"})
(41) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_462974787522099821,direction=OUT,version=0,property={"__from_id__":"1"})
(42) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_5574659408609180145,direction=OUT,version=0,property={"__from_id__":"1"})
(43) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_46267093100475824,direction=OUT,version=0,property={"__from_id__":"1"})
(44) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_3728690236591926833,direction=OUT,version=0,property={"__from_id__":"1"})
(45) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_-769728728481246879,direction=OUT,version=0,property={"__from_id__":"1"})
(46) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_5271436563422163029,direction=OUT,version=0,property={"__from_id__":"1"})
(47) Edge(s=SupplyChain.ProductChainEvent_4069221403129534712,p=SupplyChain.ProductChainEvent_leadTo_SupplyChain.CompanyEvent,o=SupplyChain.CompanyEvent_1991217184125426375,direction=OUT,version=0,property={"__from_id__":"1"})
edge_list_end
2024-04-30 03:57:54,011 [] [] [main] INFO  c.a.o.b.r.l.r.BuilderMetric - type=COUNTER, name=default_job_error, count=0
2024-04-30 03:57:54,015 [] [] [main] INFO  c.a.o.b.r.l.r.BuilderMetric - type=METER, name=default_job_total, count=1, m1_rate=0.2, m5_rate=0.2, m15_rate=0.2, mean_rate=0.11307470103727493, rate_unit=events/second
2024-04-30 03:57:54,017 [] [] [main] ERROR c.a.o.b.r.l.LocalBuilderMain - unknown exception.
java.util.concurrent.ExecutionException: java.lang.NullPointerException
        at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
        at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
        at com.antgroup.openspg.builder.runner.local.LocalBuilderRunner.failFast(LocalBuilderRunner.java:149)
        at com.antgroup.openspg.builder.runner.local.LocalBuilderRunner.execute(LocalBuilderRunner.java:124)
        at com.antgroup.openspg.builder.runner.local.LocalBuilderMain.run(LocalBuilderMain.java:150)
        at com.antgroup.openspg.builder.runner.local.LocalBuilderMain.main(LocalBuilderMain.java:69)
Caused by: java.lang.NullPointerException: null
        at com.antgroup.openspg.cloudext.interfaces.graphstore.adapter.util.PropertyRecordConvertor.toSPGProperties(PropertyRecordConvertor.java:73)
        at com.antgroup.openspg.cloudext.interfaces.graphstore.adapter.util.EdgeRecordConvertor.toRelationRecord(EdgeRecordConvertor.java:80)
        at com.antgroup.openspg.builder.core.reason.ReasonerProcessorUtils.lambda$toSpgRecords$1(ReasonerProcessorUtils.java:92)
        at java.util.ArrayList.forEach(ArrayList.java:1259)
        at com.antgroup.openspg.builder.core.reason.ReasonerProcessorUtils.toSpgRecords(ReasonerProcessorUtils.java:86)
        at com.antgroup.openspg.builder.core.reason.impl.CausalConceptReasoner.leadTo(CausalConceptReasoner.java:123)
        at com.antgroup.openspg.builder.core.reason.impl.CausalConceptReasoner.propagate(CausalConceptReasoner.java:85)
        at com.antgroup.openspg.builder.core.reason.impl.CausalConceptReasoner.reason(CausalConceptReasoner.java:51)
        at com.antgroup.openspg.builder.core.reason.ReasonProcessor.reasoning(ReasonProcessor.java:110)
        at com.antgroup.openspg.builder.core.reason.ReasonProcessor.process(ReasonProcessor.java:92)
        at com.antgroup.openspg.builder.runner.local.LocalBuilderRunner.reason(LocalBuilderRunner.java:134)
        at com.antgroup.openspg.builder.runner.local.LocalBuilderRunner.lambda$execute$0(LocalBuilderRunner.java:114)
        at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1640)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:750)