边端同步数据返回400

[Virus-Syl]

Issue Type

Running

Have you searched for existing documents and issues?

Yes

OS Platform and Distribution

arm

All_in_one Version

v0.12.0b0

Kuscia Version

kuscia-0.13.0b0.tar

What happend and What you expected to happen.

边端调用GET /sync?p=xxx的时候，会因为p参数过大导致无法同步数据,

Log output.

2026-09-17 15:14:53 [] [scheduling-8] INFO  o.s.secretpad.web.aop.LoggingAspect - Executing: void org.secretflow.secretpad.web.controller.CenterDataSyncController.ping(), Args: []
2026-09-17 15:14:54 [] [reactor-http-epoll-2] ERROR o.s.s.s.s.e.EdgeDataSyncServiceImpl - Error receiving SSE: Retries exhausted: 3/3
org.springframework.web.reactive.function.client.WebClientResponseException$BadRequest: 400 Bad Request from GET http://root-kuscia-lite-ceekuhyr/sync
        at org.springframework.web.reactive.function.client.WebClientResponseException.create(WebClientResponseException.java:321)
        Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: 
Error has been observed at the following site(s):
        *__checkpoint ⇢ 400 BAD_REQUEST from GET http://root-kuscia-lite-ceekuhyr/sync [DefaultWebClient]
Original Stack Trace:
                at org.springframework.web.reactive.function.client.WebClientResponseException.create(WebClientResponseException.java:321)
                at org.springframework.web.reactive.function.client.DefaultClientResponse.lambda$createException$1(DefaultClientResponse.java:214)
                at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:106)
                at reactor.core.publisher.FluxOnErrorReturn$ReturnSubscriber.onNext(FluxOnErrorReturn.java:162)
                at reactor.core.publisher.FluxDefaultIfEmpty$DefaultIfEmptySubscriber.onNext(FluxDefaultIfEmpty.java:122)
                at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:129)
                at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onNext(FluxContextWrite.java:107)
                at reactor.core.publisher.FluxMapFuseable$MapFuseableConditionalSubscriber.onNext(FluxMapFuseable.java:299)
                at reactor.core.publisher.FluxFilterFuseable$FilterFuseableConditionalSubscriber.onNext(FluxFilterFuseable.java:337)
                at reactor.core.publisher.Operators$BaseFluxToMonoOperator.completePossiblyEmpty(Operators.java:2097)
                at reactor.core.publisher.MonoCollect$CollectSubscriber.onComplete(MonoCollect.java:145)
                at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:144)
                at reactor.core.publisher.FluxPeek$PeekSubscriber.onComplete(FluxPeek.java:260)
                at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:144)
                at reactor.netty.channel.FluxReceive.onInboundComplete(FluxReceive.java:415)
                at reactor.netty.channel.ChannelOperations.onInboundComplete(ChannelOperations.java:445)
                at reactor.netty.channel.ChannelOperations.terminate(ChannelOperations.java:499)
                at reactor.netty.http.client.HttpClientOperations.onInboundNext(HttpClientOperations.java:800)
                at reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:115)
                at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
                at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
                at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
                at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
                at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
                at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
                at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
                at io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:436)
                at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:346)
                at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:318)
                at io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:251)
                at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442)
                at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
                at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
                at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1357)
                at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:440)
                at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
                at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:868)
                at io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:799)
                at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:501)
                at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:399)
                at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
                at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
                at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
                at java.base/java.lang.Thread.run(Thread.java:840)

[Virus-Syl]

我写了一个测试脚本，sync-p.json内容如下：[{"lastUpdateTime":"2026-09-17 01:14:19","tableName":"org.secretflow.secretpad.persistence.entity.ProjectDO"},{"lastUpdateTime":"2026-09-17 01:14:19","tableName":"org.secretflow.secretpad.persistence.entity.ProjectNodeDO"},{"lastUpdateTime":"0","tableName":"org.secretflow.secretpad.persistence.entity.NodeDO"},{"lastUpdateTime":"0","tableName":"org.secretflow.secretpad.persistence.entity.NodeRouteDO"},{"lastUpdateTime":"0","tableName":"org.secretflow.secretpad.persistence.entity.ProjectJobDO"},{"lastUpdateTime":"0","tableName":"org.secretflow.secretpad.persistence.entity.ProjectTaskDO"},{"lastUpdateTime":"2026-09-17 01:15:53","tableName":"org.secretflow.secretpad.persistence.entity.ProjectDatatableDO"},{"lastUpdateTime":"2026-09-17 01:16:21","tableName":"org.secretflow.secretpad.persistence.entity.VoteRequestDO"},{"lastUpdateTime":"2026-09-17 01:16:21","tableName":"org.secretflow.secretpad.persistence.entity.VoteInviteDO"},{"lastUpdateTime":"0","tableName":"org.secretflow.secretpad.persistence.entity.TeeDownLoadAuditConfigDO"},{"lastUpdateTime":"2026-09-17 01:16:21","tableName":"org.secretflow.secretpad.persistence.entity.NodeRouteApprovalConfigDO"},{"lastUpdateTime":"0","tableName":"org.secretflow.secretpad.persistence.entity.TeeNodeDatatableManagementDO"},{"lastUpdateTime":"0","tableName":"org.secretflow.secretpad.persistence.entity.ProjectModelServingDO"},{"lastUpdateTime":"0","tableName":"org.secretflow.secretpad.persistence.entity.ProjectGraphNodeKusciaParamsDO"},{"lastUpdateTime":"0","tableName":"org.secretflow.secretpad.persistence.entity.ProjectModelPackDO"},{"lastUpdateTime":"0","tableName":"org.secretflow.secretpad.persistence.entity.FeatureTableDO"},{"lastUpdateTime":"0","tableName":"org.secretflow.secretpad.persistence.entity.ProjectFeatureTableDO"},{"lastUpdateTime":"0","tableName":"org.secretflow.secretpad.persistence.entity.ProjectGraphDomainDatasourceDO"},{"lastUpdateTime":"0","tableName":"org.secretflow.secretpad.persistence.entity.ProjectScheduleDO"},{"lastUpdateTime":"0","tableName":"org.secretflow.secretpad.persistence.entity.ProjectScheduleJobDO"},{"lastUpdateTime":"0","tableName":"org.secretflow.secretpad.persistence.entity.ProjectScheduleTaskDO"}]

脚本内容:
PAD=root-kuscia-lite-secretpad-ceekuhyr
GW=root-kuscia-lite-ceekuhyr

python3 - <<'PY'
import json
with open("/tmp/sync-p.json", encoding="utf-8") as f:
data = json.load(f)
print("同步表数量:", len(data))
PY

for n in 1 5 10 15 18 19 20 21; do
ENCODED=$(python3 - "$n" <<'PY'
import json
import sys
import urllib.parse

count = int(sys.argv[1])

with open("/tmp/sync-p.json", encoding="utf-8") as f:
items = json.load(f)

data = json.dumps(
items[:count],
ensure_ascii=False,
separators=(",", ":")
)

encoded = urllib.parse.quote(
urllib.parse.quote(data, safe=""),
safe=""
)

print(encoded)
PY
)

URI_LEN=$(( ${#ENCODED} + 8 ))

CODE=$(docker exec "$PAD" curl -sS
-o /dev/null
--max-time 3
-w '%{http_code}'
"http://$GW:80/sync?p=$ENCODED"
-H 'Host: secretpad.master.svc'
-H 'Accept: text/event-stream'
-H 'kuscia-origin-source: ceekuhyr'
2>/dev/null)

echo "tables=$n uri_length=$URI_LEN status=$CODE"
done

执行结果：
tables=1 uri_length=190 status=000
tables=5 uri_length=814 status=200
tables=10 uri_length=1674 status=000
tables=15 uri_length=2516 status=200
tables=18 uri_length=2995 status=000
tables=19 uri_length=3150 status=200
tables=20 uri_length=3308 status=000
tables=21 uri_length=3467 status=400

数据变大后，status就会变成400

[peakshen]

针对你这个问题原因
EdgeDataSyncServiceImpl → GET /sync?p=<全部20张表的JSON编码>
↑ URL 长度超过网关限制 → 400 Bad Request
→ 重试 3 次 → Retries exhausted: 3/3
原始代码中 EdgeDataSyncServiceImpl 将所有同步表信息编码后放在 URL Query 参数 p 中，当表数量多、lastUpdateTime 有值时，URL 迅速膨胀，超过网关限制。

可以有几种建议，分批次传表，避免超过参数长度。
如果通信有使用nginx转发，可以调大转发的buffer长度，
根本解决方式，还是代码层修改，可以尝试修改源码，修改接口调用方式，get转换post方式。