============================================================ Starting test: bgpcep-userfeatures.txt.Bgp Ipv6 Basic.bgpcep-userfeatures.txt.Bgp Ipv6 Basic.Delete_Injected_Ipv6_Routes_1 ============================================================ Starting test: bgpcep-userfeatures.txt.Bgp Ipv6 Basic.bgpcep-userfeatures.txt.Bgp Ipv6 Basic.Delete_Injected_Ipv6_Routes_2 ============================================================ Starting test: bgpcep-userfeatures.txt.Bgp Ipv6 Basic.bgpcep-userfeatures.txt.Bgp Ipv6 Basic.Stop_All_Exabgps_3 ---------------------------------------- Exception is new 2024-08-06T04:44:02,182 | WARN | kafka-producer-network-thread | ServiceHandler | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=ServiceHandler] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Node may not be available. 2024-08-06T04:44:02,182 | WARN | kafka-producer-network-thread | ServiceHandler | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=ServiceHandler] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected 2024-08-06T04:44:02,275 | WARN | kafka-producer-network-thread | ServiceListener | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=ServiceListener] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Node may not be available. 2024-08-06T04:44:02,275 | WARN | kafka-producer-network-thread | ServiceListener | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=ServiceListener] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected 2024-08-06T04:44:02,443 | WARN | pool-75-thread-1 | StateProviderImpl | 223 - org.opendaylight.bgpcep.bgp-openconfig-state - 0.21.7 | Failed to prepare Tx for BGP stats updatejava.lang.IllegalStateException: Duplicate key NeighborKey{neighborAddress=IpAddress{ipv4Address=Ipv4Address{value=10.30.170.56}}} (attempted merging values Neighbor{afiSafis=AfiSafis{afiSafi={AfiSafiKey{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}}=AfiSafi{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}}=AfiSafi{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}}=AfiSafi{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}}}, errorHandling=ErrorHandling{state=State{augmentation=[NeighborErrorHandlingStateAugmentation{erroneousUpdateMessages=0}]}}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborGracefulRestartStateAugmentation{localRestarting=false, mode=HELPERONLY, peerRestartTime=0, peerRestarting=false}]}}, neighborAddress=IpAddress{ipv4Address=Ipv4Address{value=10.30.170.56}}, state=State{augmentation=[BgpNeighborStateAugmentation{messages=Messages{received=Received{nOTIFICATION=0, uPDATE=0}, sent=Sent{nOTIFICATION=0, uPDATE=0}}}]}} and Neighbor{afiSafis=AfiSafis{afiSafi={AfiSafiKey{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}}=AfiSafi{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}}=AfiSafi{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}}=AfiSafi{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}}}, errorHandling=ErrorHandling{state=State{augmentation=[NeighborErrorHandlingStateAugmentation{erroneousUpdateMessages=0}]}}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborGracefulRestartStateAugmentation{localRestarting=false, mode=HELPERONLY, peerRestartTime=0, peerRestarting=false}]}}, neighborAddress=IpAddress{ipv4Address=Ipv4Address{value=10.30.170.56}}, state=State{augmentation=[BgpNeighborStateAugmentation{messages=Messages{received=Received{nOTIFICATION=0, uPDATE=0}, sent=Sent{nOTIFICATION=0, uPDATE=0}}}]}}) at java.util.stream.Collectors.duplicateKeyException(Collectors.java:135) ~[?:?] at java.util.stream.Collectors.lambda$uniqKeysMapAccumulator$1(Collectors.java:182) ~[?:?] at java.util.stream.ReduceOps$3ReducingSink.accept(ReduceOps.java:169) ~[?:?] at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197) ~[?:?] at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:179) ~[?:?] at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1625) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499) ~[?:?] at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:921) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:682) ~[?:?] at org.opendaylight.protocol.bgp.state.NeighborUtil.buildNeighbors(NeighborUtil.java:113) ~[bundleFile:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl.storeOperationalState(StateProviderImpl.java:188) ~[bundleFile:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl.lambda$updateBGPStats$1(StateProviderImpl.java:173) ~[bundleFile:?] at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) ~[?:?] at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:179) ~[?:?] at java.util.Collections$2.tryAdvance(Collections.java:4853) ~[?:?] at java.util.Collections$2.forEachRemaining(Collections.java:4861) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499) ~[?:?] at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150) ~[?:?] at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596) ~[?:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl.updateBGPStats(StateProviderImpl.java:168) ~[bundleFile:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl$1.run(StateProviderImpl.java:141) [bundleFile:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) [?:?] at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305) [?:?] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) [?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?] at java.lang.Thread.run(Thread.java:833) [?:?] ---------------------------------------- Exception is new 2024-08-06T04:44:07,176 | WARN | kafka-producer-network-thread | RendererListener | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=RendererListener] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Node may not be available. 2024-08-06T04:44:07,176 | WARN | kafka-producer-network-thread | RendererListener | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=RendererListener] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected 2024-08-06T04:44:07,246 | WARN | kafka-producer-network-thread | ServiceHandlerOperations | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=ServiceHandlerOperations] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Node may not be available. 2024-08-06T04:44:07,246 | WARN | kafka-producer-network-thread | ServiceHandlerOperations | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=ServiceHandlerOperations] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected 2024-08-06T04:44:07,443 | WARN | pool-75-thread-1 | StateProviderImpl | 223 - org.opendaylight.bgpcep.bgp-openconfig-state - 0.21.7 | Failed to prepare Tx for BGP stats updatejava.lang.IllegalStateException: Duplicate key NeighborKey{neighborAddress=IpAddress{ipv4Address=Ipv4Address{value=10.30.170.56}}} (attempted merging values Neighbor{afiSafis=AfiSafis{afiSafi={AfiSafiKey{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}}=AfiSafi{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}}=AfiSafi{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}}=AfiSafi{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}}}, errorHandling=ErrorHandling{state=State{augmentation=[NeighborErrorHandlingStateAugmentation{erroneousUpdateMessages=0}]}}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborGracefulRestartStateAugmentation{localRestarting=false, mode=HELPERONLY, peerRestartTime=0, peerRestarting=false}]}}, neighborAddress=IpAddress{ipv4Address=Ipv4Address{value=10.30.170.56}}, state=State{augmentation=[BgpNeighborStateAugmentation{messages=Messages{received=Received{nOTIFICATION=0, uPDATE=0}, sent=Sent{nOTIFICATION=0, uPDATE=0}}}]}} and Neighbor{afiSafis=AfiSafis{afiSafi={AfiSafiKey{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}}=AfiSafi{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}}=AfiSafi{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}}=AfiSafi{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}}}, errorHandling=ErrorHandling{state=State{augmentation=[NeighborErrorHandlingStateAugmentation{erroneousUpdateMessages=0}]}}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborGracefulRestartStateAugmentation{localRestarting=false, mode=HELPERONLY, peerRestartTime=0, peerRestarting=false}]}}, neighborAddress=IpAddress{ipv4Address=Ipv4Address{value=10.30.170.56}}, state=State{augmentation=[BgpNeighborStateAugmentation{messages=Messages{received=Received{nOTIFICATION=0, uPDATE=0}, sent=Sent{nOTIFICATION=0, uPDATE=0}}}]}}) at java.util.stream.Collectors.duplicateKeyException(Collectors.java:135) ~[?:?] at java.util.stream.Collectors.lambda$uniqKeysMapAccumulator$1(Collectors.java:182) ~[?:?] at java.util.stream.ReduceOps$3ReducingSink.accept(ReduceOps.java:169) ~[?:?] at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197) ~[?:?] at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:179) ~[?:?] at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1625) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499) ~[?:?] at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:921) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:682) ~[?:?] at org.opendaylight.protocol.bgp.state.NeighborUtil.buildNeighbors(NeighborUtil.java:113) ~[bundleFile:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl.storeOperationalState(StateProviderImpl.java:188) ~[bundleFile:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl.lambda$updateBGPStats$1(StateProviderImpl.java:173) ~[bundleFile:?] at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) ~[?:?] at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:179) ~[?:?] at java.util.Collections$2.tryAdvance(Collections.java:4853) ~[?:?] at java.util.Collections$2.forEachRemaining(Collections.java:4861) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499) ~[?:?] at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150) ~[?:?] at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596) ~[?:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl.updateBGPStats(StateProviderImpl.java:168) ~[bundleFile:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl$1.run(StateProviderImpl.java:141) [bundleFile:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) [?:?] at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305) [?:?] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) [?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?] at java.lang.Thread.run(Thread.java:833) [?:?] ---------------------------------------- Exception is new 2024-08-06T04:44:11,951 | WARN | kafka-producer-network-thread | ServiceHandlerOperations | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=ServiceHandlerOperations] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Node may not be available. 2024-08-06T04:44:11,951 | WARN | kafka-producer-network-thread | ServiceHandlerOperations | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=ServiceHandlerOperations] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected 2024-08-06T04:44:12,195 | WARN | kafka-producer-network-thread | PceListener | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=PceListener] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Node may not be available. 2024-08-06T04:44:12,195 | WARN | kafka-producer-network-thread | PceListener | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=PceListener] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected 2024-08-06T04:44:12,443 | WARN | pool-75-thread-1 | StateProviderImpl | 223 - org.opendaylight.bgpcep.bgp-openconfig-state - 0.21.7 | Failed to prepare Tx for BGP stats updatejava.lang.IllegalStateException: Duplicate key NeighborKey{neighborAddress=IpAddress{ipv4Address=Ipv4Address{value=10.30.170.56}}} (attempted merging values Neighbor{afiSafis=AfiSafis{afiSafi={AfiSafiKey{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}}=AfiSafi{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}}=AfiSafi{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}}=AfiSafi{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}}}, errorHandling=ErrorHandling{state=State{augmentation=[NeighborErrorHandlingStateAugmentation{erroneousUpdateMessages=0}]}}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborGracefulRestartStateAugmentation{localRestarting=false, mode=HELPERONLY, peerRestartTime=0, peerRestarting=false}]}}, neighborAddress=IpAddress{ipv4Address=Ipv4Address{value=10.30.170.56}}, state=State{augmentation=[BgpNeighborStateAugmentation{messages=Messages{received=Received{nOTIFICATION=0, uPDATE=0}, sent=Sent{nOTIFICATION=0, uPDATE=0}}}]}} and Neighbor{afiSafis=AfiSafis{afiSafi={AfiSafiKey{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}}=AfiSafi{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}}=AfiSafi{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}}=AfiSafi{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}}}, errorHandling=ErrorHandling{state=State{augmentation=[NeighborErrorHandlingStateAugmentation{erroneousUpdateMessages=0}]}}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborGracefulRestartStateAugmentation{localRestarting=false, mode=HELPERONLY, peerRestartTime=0, peerRestarting=false}]}}, neighborAddress=IpAddress{ipv4Address=Ipv4Address{value=10.30.170.56}}, state=State{augmentation=[BgpNeighborStateAugmentation{messages=Messages{received=Received{nOTIFICATION=0, uPDATE=0}, sent=Sent{nOTIFICATION=0, uPDATE=0}}}]}}) at java.util.stream.Collectors.duplicateKeyException(Collectors.java:135) ~[?:?] at java.util.stream.Collectors.lambda$uniqKeysMapAccumulator$1(Collectors.java:182) ~[?:?] at java.util.stream.ReduceOps$3ReducingSink.accept(ReduceOps.java:169) ~[?:?] at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197) ~[?:?] at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:179) ~[?:?] at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1625) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499) ~[?:?] at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:921) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:682) ~[?:?] at org.opendaylight.protocol.bgp.state.NeighborUtil.buildNeighbors(NeighborUtil.java:113) ~[bundleFile:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl.storeOperationalState(StateProviderImpl.java:188) ~[bundleFile:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl.lambda$updateBGPStats$1(StateProviderImpl.java:173) ~[bundleFile:?] at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) ~[?:?] at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:179) ~[?:?] at java.util.Collections$2.tryAdvance(Collections.java:4853) ~[?:?] at java.util.Collections$2.forEachRemaining(Collections.java:4861) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499) ~[?:?] at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150) ~[?:?] at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596) ~[?:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl.updateBGPStats(StateProviderImpl.java:168) ~[bundleFile:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl$1.run(StateProviderImpl.java:141) [bundleFile:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) [?:?] at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305) [?:?] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) [?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?] at java.lang.Thread.run(Thread.java:833) [?:?] ---------------------------------------- Exception is new 2024-08-06T04:44:16,744 | WARN | kafka-producer-network-thread | ServiceListener | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=ServiceListener] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Node may not be available. 2024-08-06T04:44:16,744 | WARN | kafka-producer-network-thread | ServiceListener | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=ServiceListener] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected 2024-08-06T04:44:17,056 | WARN | kafka-producer-network-thread | PceListener | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=PceListener] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Node may not be available. 2024-08-06T04:44:17,056 | WARN | kafka-producer-network-thread | PceListener | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=PceListener] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected 2024-08-06T04:44:17,443 | WARN | pool-75-thread-1 | StateProviderImpl | 223 - org.opendaylight.bgpcep.bgp-openconfig-state - 0.21.7 | Failed to prepare Tx for BGP stats updatejava.lang.IllegalStateException: Duplicate key NeighborKey{neighborAddress=IpAddress{ipv4Address=Ipv4Address{value=10.30.170.56}}} (attempted merging values Neighbor{afiSafis=AfiSafis{afiSafi={AfiSafiKey{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}}=AfiSafi{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}}=AfiSafi{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}}=AfiSafi{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}}}, errorHandling=ErrorHandling{state=State{augmentation=[NeighborErrorHandlingStateAugmentation{erroneousUpdateMessages=0}]}}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborGracefulRestartStateAugmentation{localRestarting=false, mode=HELPERONLY, peerRestartTime=0, peerRestarting=false}]}}, neighborAddress=IpAddress{ipv4Address=Ipv4Address{value=10.30.170.56}}, state=State{augmentation=[BgpNeighborStateAugmentation{messages=Messages{received=Received{nOTIFICATION=0, uPDATE=0}, sent=Sent{nOTIFICATION=0, uPDATE=0}}}]}} and Neighbor{afiSafis=AfiSafis{afiSafi={AfiSafiKey{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}}=AfiSafi{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}}=AfiSafi{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}}=AfiSafi{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}}}, errorHandling=ErrorHandling{state=State{augmentation=[NeighborErrorHandlingStateAugmentation{erroneousUpdateMessages=0}]}}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborGracefulRestartStateAugmentation{localRestarting=false, mode=HELPERONLY, peerRestartTime=0, peerRestarting=false}]}}, neighborAddress=IpAddress{ipv4Address=Ipv4Address{value=10.30.170.56}}, state=State{augmentation=[BgpNeighborStateAugmentation{messages=Messages{received=Received{nOTIFICATION=0, uPDATE=0}, sent=Sent{nOTIFICATION=0, uPDATE=0}}}]}}) at java.util.stream.Collectors.duplicateKeyException(Collectors.java:135) ~[?:?] at java.util.stream.Collectors.lambda$uniqKeysMapAccumulator$1(Collectors.java:182) ~[?:?] at java.util.stream.ReduceOps$3ReducingSink.accept(ReduceOps.java:169) ~[?:?] at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197) ~[?:?] at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:179) ~[?:?] at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1625) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499) ~[?:?] at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:921) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:682) ~[?:?] at org.opendaylight.protocol.bgp.state.NeighborUtil.buildNeighbors(NeighborUtil.java:113) ~[bundleFile:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl.storeOperationalState(StateProviderImpl.java:188) ~[bundleFile:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl.lambda$updateBGPStats$1(StateProviderImpl.java:173) ~[bundleFile:?] at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) ~[?:?] at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:179) ~[?:?] at java.util.Collections$2.tryAdvance(Collections.java:4853) ~[?:?] at java.util.Collections$2.forEachRemaining(Collections.java:4861) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499) ~[?:?] at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150) ~[?:?] at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596) ~[?:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl.updateBGPStats(StateProviderImpl.java:168) ~[bundleFile:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl$1.run(StateProviderImpl.java:141) [bundleFile:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) [?:?] at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305) [?:?] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) [?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?] at java.lang.Thread.run(Thread.java:833) [?:?] ---------------------------------------- Exception is new 2024-08-06T04:44:22,397 | WARN | kafka-producer-network-thread | ServiceHandler | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=ServiceHandler] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Node may not be available. 2024-08-06T04:44:22,397 | WARN | kafka-producer-network-thread | ServiceHandler | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=ServiceHandler] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected 2024-08-06T04:44:22,400 | WARN | kafka-producer-network-thread | RendererListener | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=RendererListener] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Node may not be available. 2024-08-06T04:44:22,400 | WARN | kafka-producer-network-thread | RendererListener | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=RendererListener] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected 2024-08-06T04:44:22,443 | WARN | pool-75-thread-1 | StateProviderImpl | 223 - org.opendaylight.bgpcep.bgp-openconfig-state - 0.21.7 | Failed to prepare Tx for BGP stats updatejava.lang.IllegalStateException: Duplicate key NeighborKey{neighborAddress=IpAddress{ipv4Address=Ipv4Address{value=10.30.170.56}}} (attempted merging values Neighbor{afiSafis=AfiSafis{afiSafi={AfiSafiKey{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}}=AfiSafi{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}}=AfiSafi{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}}=AfiSafi{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}}}, errorHandling=ErrorHandling{state=State{augmentation=[NeighborErrorHandlingStateAugmentation{erroneousUpdateMessages=0}]}}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborGracefulRestartStateAugmentation{localRestarting=false, mode=HELPERONLY, peerRestartTime=0, peerRestarting=false}]}}, neighborAddress=IpAddress{ipv4Address=Ipv4Address{value=10.30.170.56}}, state=State{augmentation=[BgpNeighborStateAugmentation{messages=Messages{received=Received{nOTIFICATION=0, uPDATE=0}, sent=Sent{nOTIFICATION=0, uPDATE=0}}}]}} and Neighbor{afiSafis=AfiSafis{afiSafi={AfiSafiKey{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}}=AfiSafi{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}}=AfiSafi{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}}=AfiSafi{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}}}, errorHandling=ErrorHandling{state=State{augmentation=[NeighborErrorHandlingStateAugmentation{erroneousUpdateMessages=0}]}}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborGracefulRestartStateAugmentation{localRestarting=false, mode=HELPERONLY, peerRestartTime=0, peerRestarting=false}]}}, neighborAddress=IpAddress{ipv4Address=Ipv4Address{value=10.30.170.56}}, state=State{augmentation=[BgpNeighborStateAugmentation{messages=Messages{received=Received{nOTIFICATION=0, uPDATE=0}, sent=Sent{nOTIFICATION=0, uPDATE=0}}}]}}) at java.util.stream.Collectors.duplicateKeyException(Collectors.java:135) ~[?:?] at java.util.stream.Collectors.lambda$uniqKeysMapAccumulator$1(Collectors.java:182) ~[?:?] at java.util.stream.ReduceOps$3ReducingSink.accept(ReduceOps.java:169) ~[?:?] at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197) ~[?:?] at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:179) ~[?:?] at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1625) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499) ~[?:?] at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:921) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:682) ~[?:?] at org.opendaylight.protocol.bgp.state.NeighborUtil.buildNeighbors(NeighborUtil.java:113) ~[bundleFile:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl.storeOperationalState(StateProviderImpl.java:188) ~[bundleFile:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl.lambda$updateBGPStats$1(StateProviderImpl.java:173) ~[bundleFile:?] at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) ~[?:?] at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:179) ~[?:?] at java.util.Collections$2.tryAdvance(Collections.java:4853) ~[?:?] at java.util.Collections$2.forEachRemaining(Collections.java:4861) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499) ~[?:?] at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150) ~[?:?] at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596) ~[?:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl.updateBGPStats(StateProviderImpl.java:168) ~[bundleFile:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl$1.run(StateProviderImpl.java:141) [bundleFile:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) [?:?] at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305) [?:?] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) [?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?] at java.lang.Thread.run(Thread.java:833) [?:?] ---------------------------------------- Exception is new 2024-08-06T04:44:27,316 | WARN | kafka-producer-network-thread | ServiceHandler | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=ServiceHandler] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Node may not be available. 2024-08-06T04:44:27,316 | WARN | kafka-producer-network-thread | ServiceHandler | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=ServiceHandler] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected 2024-08-06T04:44:27,424 | WARN | kafka-producer-network-thread | ServiceListener | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=ServiceListener] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Node may not be available. 2024-08-06T04:44:27,424 | WARN | kafka-producer-network-thread | ServiceListener | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=ServiceListener] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected 2024-08-06T04:44:27,443 | WARN | pool-75-thread-1 | StateProviderImpl | 223 - org.opendaylight.bgpcep.bgp-openconfig-state - 0.21.7 | Failed to prepare Tx for BGP stats updatejava.lang.IllegalStateException: Duplicate key NeighborKey{neighborAddress=IpAddress{ipv4Address=Ipv4Address{value=10.30.170.56}}} (attempted merging values Neighbor{afiSafis=AfiSafis{afiSafi={AfiSafiKey{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}}=AfiSafi{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}}=AfiSafi{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}}=AfiSafi{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}}}, errorHandling=ErrorHandling{state=State{augmentation=[NeighborErrorHandlingStateAugmentation{erroneousUpdateMessages=0}]}}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborGracefulRestartStateAugmentation{localRestarting=false, mode=HELPERONLY, peerRestartTime=0, peerRestarting=false}]}}, neighborAddress=IpAddress{ipv4Address=Ipv4Address{value=10.30.170.56}}, state=State{augmentation=[BgpNeighborStateAugmentation{messages=Messages{received=Received{nOTIFICATION=0, uPDATE=0}, sent=Sent{nOTIFICATION=0, uPDATE=0}}}]}} and Neighbor{afiSafis=AfiSafis{afiSafi={AfiSafiKey{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}}=AfiSafi{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}}=AfiSafi{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}}=AfiSafi{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}}}, errorHandling=ErrorHandling{state=State{augmentation=[NeighborErrorHandlingStateAugmentation{erroneousUpdateMessages=0}]}}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborGracefulRestartStateAugmentation{localRestarting=false, mode=HELPERONLY, peerRestartTime=0, peerRestarting=false}]}}, neighborAddress=IpAddress{ipv4Address=Ipv4Address{value=10.30.170.56}}, state=State{augmentation=[BgpNeighborStateAugmentation{messages=Messages{received=Received{nOTIFICATION=0, uPDATE=0}, sent=Sent{nOTIFICATION=0, uPDATE=0}}}]}}) at java.util.stream.Collectors.duplicateKeyException(Collectors.java:135) ~[?:?] at java.util.stream.Collectors.lambda$uniqKeysMapAccumulator$1(Collectors.java:182) ~[?:?] at java.util.stream.ReduceOps$3ReducingSink.accept(ReduceOps.java:169) ~[?:?] at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197) ~[?:?] at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:179) ~[?:?] at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1625) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499) ~[?:?] at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:921) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:682) ~[?:?] at org.opendaylight.protocol.bgp.state.NeighborUtil.buildNeighbors(NeighborUtil.java:113) ~[bundleFile:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl.storeOperationalState(StateProviderImpl.java:188) ~[bundleFile:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl.lambda$updateBGPStats$1(StateProviderImpl.java:173) ~[bundleFile:?] at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) ~[?:?] at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:179) ~[?:?] at java.util.Collections$2.tryAdvance(Collections.java:4853) ~[?:?] at java.util.Collections$2.forEachRemaining(Collections.java:4861) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499) ~[?:?] at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150) ~[?:?] at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596) ~[?:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl.updateBGPStats(StateProviderImpl.java:168) ~[bundleFile:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl$1.run(StateProviderImpl.java:141) [bundleFile:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) [?:?] at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305) [?:?] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) [?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?] at java.lang.Thread.run(Thread.java:833) [?:?] ---------------------------------------- Exception is new 2024-08-06T04:44:31,957 | WARN | kafka-producer-network-thread | RendererListener | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=RendererListener] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Node may not be available. 2024-08-06T04:44:31,957 | WARN | kafka-producer-network-thread | RendererListener | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=RendererListener] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected 2024-08-06T04:44:32,370 | WARN | kafka-producer-network-thread | ServiceHandler | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=ServiceHandler] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Node may not be available. 2024-08-06T04:44:32,370 | WARN | kafka-producer-network-thread | ServiceHandler | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=ServiceHandler] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected 2024-08-06T04:44:32,443 | WARN | pool-75-thread-1 | StateProviderImpl | 223 - org.opendaylight.bgpcep.bgp-openconfig-state - 0.21.7 | Failed to prepare Tx for BGP stats updatejava.lang.IllegalStateException: Duplicate key NeighborKey{neighborAddress=IpAddress{ipv4Address=Ipv4Address{value=10.30.170.56}}} (attempted merging values Neighbor{afiSafis=AfiSafis{afiSafi={AfiSafiKey{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}}=AfiSafi{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}}=AfiSafi{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}}=AfiSafi{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}}}, errorHandling=ErrorHandling{state=State{augmentation=[NeighborErrorHandlingStateAugmentation{erroneousUpdateMessages=0}]}}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborGracefulRestartStateAugmentation{localRestarting=false, mode=HELPERONLY, peerRestartTime=0, peerRestarting=false}]}}, neighborAddress=IpAddress{ipv4Address=Ipv4Address{value=10.30.170.56}}, state=State{augmentation=[BgpNeighborStateAugmentation{messages=Messages{received=Received{nOTIFICATION=0, uPDATE=0}, sent=Sent{nOTIFICATION=0, uPDATE=0}}}]}} and Neighbor{afiSafis=AfiSafis{afiSafi={AfiSafiKey{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}}=AfiSafi{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}}=AfiSafi{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}}=AfiSafi{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}}}, errorHandling=ErrorHandling{state=State{augmentation=[NeighborErrorHandlingStateAugmentation{erroneousUpdateMessages=0}]}}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborGracefulRestartStateAugmentation{localRestarting=false, mode=HELPERONLY, peerRestartTime=0, peerRestarting=false}]}}, neighborAddress=IpAddress{ipv4Address=Ipv4Address{value=10.30.170.56}}, state=State{augmentation=[BgpNeighborStateAugmentation{messages=Messages{received=Received{nOTIFICATION=0, uPDATE=0}, sent=Sent{nOTIFICATION=0, uPDATE=0}}}]}}) at java.util.stream.Collectors.duplicateKeyException(Collectors.java:135) ~[?:?] at java.util.stream.Collectors.lambda$uniqKeysMapAccumulator$1(Collectors.java:182) ~[?:?] at java.util.stream.ReduceOps$3ReducingSink.accept(ReduceOps.java:169) ~[?:?] at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197) ~[?:?] at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:179) ~[?:?] at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1625) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499) ~[?:?] at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:921) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:682) ~[?:?] at org.opendaylight.protocol.bgp.state.NeighborUtil.buildNeighbors(NeighborUtil.java:113) ~[bundleFile:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl.storeOperationalState(StateProviderImpl.java:188) ~[bundleFile:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl.lambda$updateBGPStats$1(StateProviderImpl.java:173) ~[bundleFile:?] at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) ~[?:?] at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:179) ~[?:?] at java.util.Collections$2.tryAdvance(Collections.java:4853) ~[?:?] at java.util.Collections$2.forEachRemaining(Collections.java:4861) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499) ~[?:?] at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150) ~[?:?] at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596) ~[?:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl.updateBGPStats(StateProviderImpl.java:168) ~[bundleFile:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl$1.run(StateProviderImpl.java:141) [bundleFile:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) [?:?] at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305) [?:?] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) [?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?] at java.lang.Thread.run(Thread.java:833) [?:?] ---------------------------------------- Exception is new 2024-08-06T04:44:37,031 | WARN | kafka-producer-network-thread | ServiceHandler | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=ServiceHandler] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Node may not be available. 2024-08-06T04:44:37,031 | WARN | kafka-producer-network-thread | ServiceHandler | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=ServiceHandler] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected 2024-08-06T04:44:37,160 | WARN | kafka-producer-network-thread | ServiceListener | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=ServiceListener] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Node may not be available. 2024-08-06T04:44:37,160 | WARN | kafka-producer-network-thread | ServiceListener | NetworkClient | 556 - wrap_file__tmp_karaf-0.20.2_system_org_apache_kafka_kafka-clients_3.7.0_kafka-clients-3.7.0.jar - 0.0.0 | [Producer clientId=ServiceListener] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected 2024-08-06T04:44:37,443 | WARN | pool-75-thread-1 | StateProviderImpl | 223 - org.opendaylight.bgpcep.bgp-openconfig-state - 0.21.7 | Failed to prepare Tx for BGP stats updatejava.lang.IllegalStateException: Duplicate key NeighborKey{neighborAddress=IpAddress{ipv4Address=Ipv4Address{value=10.30.170.56}}} (attempted merging values Neighbor{afiSafis=AfiSafis{afiSafi={AfiSafiKey{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}}=AfiSafi{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}}=AfiSafi{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}}=AfiSafi{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}}}, errorHandling=ErrorHandling{state=State{augmentation=[NeighborErrorHandlingStateAugmentation{erroneousUpdateMessages=0}]}}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborGracefulRestartStateAugmentation{localRestarting=false, mode=HELPERONLY, peerRestartTime=0, peerRestarting=false}]}}, neighborAddress=IpAddress{ipv4Address=Ipv4Address{value=10.30.170.56}}, state=State{augmentation=[BgpNeighborStateAugmentation{messages=Messages{received=Received{nOTIFICATION=0, uPDATE=0}, sent=Sent{nOTIFICATION=0, uPDATE=0}}}]}} and Neighbor{afiSafis=AfiSafis{afiSafi={AfiSafiKey{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}}=AfiSafi{afiSafiName=IPV6UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV6-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}}=AfiSafi{afiSafiName=LINKSTATE{qname=(urn:opendaylight:params:xml:ns:yang:bgp:openconfig-extensions?revision=2018-03-29)LINKSTATE}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}, AfiSafiKey{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}}=AfiSafi{afiSafiName=IPV4UNICAST{qname=(http://openconfig.net/yang/bgp-types?revision=2015-10-09)IPV4-UNICAST}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborAfiSafiGracefulRestartStateAugmentation{advertised=false, llAdvertised=false, llReceived=false, llStaleTimer=0, received=false}]}}, state=State{augmentation=[NeighborAfiSafiStateAugmentation{active=false}]}}}}, errorHandling=ErrorHandling{state=State{augmentation=[NeighborErrorHandlingStateAugmentation{erroneousUpdateMessages=0}]}}, gracefulRestart=GracefulRestart{state=State{augmentation=[NeighborGracefulRestartStateAugmentation{localRestarting=false, mode=HELPERONLY, peerRestartTime=0, peerRestarting=false}]}}, neighborAddress=IpAddress{ipv4Address=Ipv4Address{value=10.30.170.56}}, state=State{augmentation=[BgpNeighborStateAugmentation{messages=Messages{received=Received{nOTIFICATION=0, uPDATE=0}, sent=Sent{nOTIFICATION=0, uPDATE=0}}}]}}) at java.util.stream.Collectors.duplicateKeyException(Collectors.java:135) ~[?:?] at java.util.stream.Collectors.lambda$uniqKeysMapAccumulator$1(Collectors.java:182) ~[?:?] at java.util.stream.ReduceOps$3ReducingSink.accept(ReduceOps.java:169) ~[?:?] at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197) ~[?:?] at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:179) ~[?:?] at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1625) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499) ~[?:?] at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:921) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:682) ~[?:?] at org.opendaylight.protocol.bgp.state.NeighborUtil.buildNeighbors(NeighborUtil.java:113) ~[bundleFile:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl.storeOperationalState(StateProviderImpl.java:188) ~[bundleFile:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl.lambda$updateBGPStats$1(StateProviderImpl.java:173) ~[bundleFile:?] at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) ~[?:?] at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:179) ~[?:?] at java.util.Collections$2.tryAdvance(Collections.java:4853) ~[?:?] at java.util.Collections$2.forEachRemaining(Collections.java:4861) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499) ~[?:?] at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150) ~[?:?] at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:596) ~[?:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl.updateBGPStats(StateProviderImpl.java:168) ~[bundleFile:?] at org.opendaylight.protocol.bgp.state.StateProviderImpl$1.run(StateProviderImpl.java:141) [bundleFile:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) [?:?] at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305) [?:?] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) [?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) [?:?] at java.lang.Thread.run(Thread.java:833) [?:?]