FEL 的 Retrieval 示例无法运行 #8
Description
运行该示例会线程阻塞，没有结果和报错信息
配置信息如下：
fel:
openai:
api-base: https://dashscope.aliyuncs.com/compatible-mode/v1
api-key: sk-xxx
example:
model:
chat: qwen-plus
embed: text-embedding-v2
以下为Tread Dump:
"flow-node-thread-pool-thread-4@6242" tid=0x47 nid=NA waiting
java.lang.Thread.State: WAITING
at jdk.internal.misc.Unsafe.park(Unsafe.java:-1)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:221)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:754)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1099)
at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:230)
at modelengine.fel.engine.flows.ConverseLatch.await(ConverseLatch.java:65)
at modelengine.fel.engine.operators.patterns.AbstractFlowPattern.lambda$sync$0(AbstractFlowPattern.java:73)
at modelengine.fel.engine.operators.patterns.AbstractFlowPattern$$Lambda/0x000001bc2e30c438.apply(Unknown Source:-1)
at modelengine.fel.engine.operators.patterns.SimplePattern.invoke(SimplePattern.java:30)
at modelengine.fel.engine.util.AiFlowSession.lambda$applyBatchPattern$0(AiFlowSession.java:71)
at modelengine.fel.engine.util.AiFlowSession$$Lambda/0x000001bc2e30d340.apply(Unknown Source:-1)
at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
at java.util.Collections$2.tryAdvance(Collections.java:5073)
at java.util.Collections$2.forEachRemaining(Collections.java:5081)
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 modelengine.fel.engine.util.AiFlowSession.applyBatchPattern(AiFlowSession.java:71)
at modelengine.fel.engine.util.AiFlowSession.applyPattern(AiFlowSession.java:55)
at modelengine.fel.engine.activities.AiStart.lambda$getPatternProcessor$19(AiStart.java:586)
at modelengine.fel.engine.activities.AiStart$$Lambda/0x000001bc2e2f7580.process(Unknown Source:-1)
at modelengine.fit.waterflow.domain.stream.nodes.To$ProcessMode$2.process(To.java:729)
at modelengine.fit.waterflow.domain.stream.nodes.To.onProcess(To.java:489)
at modelengine.fit.waterflow.domain.stream.nodes.To$ProcessMode.request(To.java:818)
at modelengine.fit.waterflow.domain.stream.nodes.To.process(To.java:357)
at modelengine.fit.waterflow.domain.stream.nodes.To.accept(To.java:285)
- locked <0x18c0> (a modelengine.fit.waterflow.domain.stream.nodes.Node)
at modelengine.fit.waterflow.domain.context.repo.flowcontext.FlowContextMessenger.send(FlowContextMessenger.java:38)
at modelengine.fit.waterflow.domain.stream.reactive.When.cache(When.java:99)
at modelengine.fit.waterflow.domain.stream.nodes.From.lambda$offer$10(From.java:328)
at modelengine.fit.waterflow.domain.stream.nodes.From$$Lambda/0x000001bc2e305db0.accept(Unknown Source:-1)
at java.util.ArrayList.forEach(ArrayList.java:1596)
at modelengine.fit.waterflow.domain.stream.nodes.From.offer(From.java:328)
at modelengine.fit.waterflow.domain.stream.nodes.ParallelNode$1.offer(ParallelNode.java:83)
at modelengine.fit.waterflow.domain.stream.nodes.Node.onNext(Node.java:221)
at modelengine.fit.waterflow.domain.stream.nodes.To.onProcess(To.java:494)
at modelengine.fit.waterflow.domain.stream.nodes.To$ProcessMode.lambda$submit$2(To.java:887)
at modelengine.fit.waterflow.domain.stream.nodes.To$ProcessMode$$Lambda/0x000001bc2e3039e8.run(Unknown Source:-1)
at modelengine.fitframework.schedule.support.DefaultTask$Builder.lambda$runnable$0(DefaultTask.java:93)
at modelengine.fitframework.schedule.support.DefaultTask$Builder$$Lambda/0x000001bc2e303c00.call(Unknown Source:-1)
at modelengine.fitframework.schedule.support.DefaultTask.call(DefaultTask.java:37)
at modelengine.fitframework.schedule.support.DefaultThreadPoolExecutor.lambda$submit$0(DefaultThreadPoolExecutor.java:46)
at modelengine.fitframework.schedule.support.DefaultThreadPoolExecutor$$Lambda/0x000001bc2e301800.call(Unknown Source:-1)
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:317)
at java.util.concurrent.FutureTask.run(FutureTask.java:-1)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
at java.lang.Thread.runWith(Thread.java:1596)
at java.lang.Thread.run(Thread.java:1583)