search

secretflow / secretpad

SecretPad is a privacy-preserving computing web platform based on the Kuscia framework, designed to provide easy access to privacy-preserving data intelligence and machine learning functions.
https://www.secretflow.org.cn
Apache License 2.0
36 stars 21 forks source link

kuscia API调用最新版本1.4.0的psi求交 #35

Open T-ze-yu opened 4 months ago

T-ze-yu commented 4 months ago

参考https://www.secretflow.org.cn/docs/secretflow/v1.3.0b0/zh-Hans/component/comp_list#psi，以及https://github.com/secretflow/secretflow/blob/v1.4.0.dev240129/docker/comp_list.json Task Input Config请求参数设置如下： { "sf_datasource_config": { "p170": { "id": "default-data-source" }, "p169": { "id": "default-data-source" } }, "sf_cluster_desc": { "parties": [ "p170", "p169" ], "devices": [ { "name": "spu", "type": "spu", "parties": [ "p170", "p169" ], "config": "{\"runtime_config\":{\"protocol\":\"REF2K\",\"field\":\"FM64\"},\"link_desc\":{\"connect_retry_times\":60,\"connect_retry_interval_ms\":1000,\"brpc_channel_protocol\":\"http\",\"brpc_channel_connection_type\":\"pooled\",\"recv_timeout_ms\":1200000,\"http_timeout_ms\":1200000}}" }, { "name": "heu", "type": "heu", "parties": [ "p170", "p169" ], "config": "{\"mode\": \"PHEU\", \"schema\": \"paillier\", \"key_size\": 2048}" } ], "ray_fed_config": { "cross_silo_comm_backend": "brpc_link" } }, "sf_node_eval_param": { "domain": "data_prep", "name": "psi", "version": "0.0.2", "attr_paths": [ "input/receiver_input/key", "input/sender_input/key", "protocol", "disable_alignment", "skip_duplicates_check", "check_hash_digest", "ecdh_curve" ], "attrs": [ { "ss": [ "id2" ] }, { "ss": [ "id1" ] }, { "s": "PROTOCOL_RR22" }, { "b": true }, { "b": true }, { "b": true }, { "s": "CURVE_FOURQ" } ] }, "sf_input_ids": [ "099d2476d53f11ee856500505695d109", "cff53002d54211eeb19c00505695ad3a" ], "sf_output_ids": [ "f20deb6a-6697-4f3d-bfae-2fd7c38c71ea-intersection-output" ], "sf_output_uris": [ "jobs/202402271508388120280/f20deb6a-6697-4f3d-bfae-2fd7c38c71ea-intersection-output" ] } 然而并未运行成功

T-ze-yu commented 4 months ago

补充日志文件如下： 2024-02-27T16:51:02.12693446+08:00 stderr F WARNING:root:Since the GPL-licensed package unidecode is not installed, using Python's unicodedata package which yields worse results.

2024-02-27T16:51:03.934050148+08:00 stdout F 2024-02-27 08:51:03,933|p170|INFO|secretflow|entry.py:start_ray:56| ray_conf: RayConfig(ray_node_ip_address='lsazz6gmzy3w1ric-0-global.p170.svc', ray_node_manager_port=0, ray_object_manager_port=0, ray_client_server_port=0, ray_worker_ports=[], ray_gcs_port=8081)

2024-02-27T16:51:03.93407721+08:00 stdout F 2024-02-27 08:51:03,933|p170|INFO|secretflow|entry.py:start_ray:60| Trying to start ray head node at lsazz6gmzy3w1ric-0-global.p170.svc, start command: RAY_BACKEND_LOG_LEVEL=debug RAY_grpc_enable_http_proxy=true OMP_NUM_THREADS=4 ray start --head --include-dashboard=false --disable-usage-stats --num-cpus=32 --node-ip-address=lsazz6gmzy3w1ric-0-global.p170.svc --port=8081

2024-02-27T16:51:07.76495032+08:00 stdout F 2024-02-27 08:51:07,763|p170|INFO|secretflow|entry.py:start_ray:77| 2024-02-27 08:51:04,508 INFO usage_lib.py:490 -- Usage stats collection is disabled.

2024-02-27T16:51:07.764976519+08:00 stdout F 2024-02-27 08:51:04,508 INFO scripts.py:702 -- Local node IP: lsazz6gmzy3w1ric-0-global.p170.svc

2024-02-27T16:51:07.764981054+08:00 stdout F 2024-02-27 08:51:07,665 SUCC scripts.py:739 -- --------------------

2024-02-27T16:51:07.764983696+08:00 stdout F 2024-02-27 08:51:07,665 SUCC scripts.py:740 -- Ray runtime started.

2024-02-27T16:51:07.764986155+08:00 stdout F 2024-02-27 08:51:07,665 SUCC scripts.py:741 -- --------------------

2024-02-27T16:51:07.764988886+08:00 stdout F 2024-02-27 08:51:07,665 INFO scripts.py:743 -- Next steps

2024-02-27T16:51:07.76499165+08:00 stdout F 2024-02-27 08:51:07,665 INFO scripts.py:744 -- To connect to this Ray runtime from another node, run

2024-02-27T16:51:07.764994193+08:00 stdout F 2024-02-27 08:51:07,665 INFO scripts.py:747 -- ray start --address='lsazz6gmzy3w1ric-0-global.p170.svc:8081'

2024-02-27T16:51:07.76499656+08:00 stdout F 2024-02-27 08:51:07,665 INFO scripts.py:763 -- Alternatively, use the following Python code:

2024-02-27T16:51:07.764999422+08:00 stdout F 2024-02-27 08:51:07,665 INFO scripts.py:765 -- import ray

2024-02-27T16:51:07.765002109+08:00 stdout F 2024-02-27 08:51:07,665 INFO scripts.py:769 -- ray.init(address='auto', _node_ip_address='lsazz6gmzy3w1ric-0-global.p170.svc')

2024-02-27T16:51:07.765004495+08:00 stdout F 2024-02-27 08:51:07,665 INFO scripts.py:781 -- To connect to this Ray runtime from outside of the cluster, for example to

2024-02-27T16:51:07.765006846+08:00 stdout F 2024-02-27 08:51:07,665 INFO scripts.py:785 -- connect to a remote cluster from your laptop directly, use the following

2024-02-27T16:51:07.765009273+08:00 stdout F 2024-02-27 08:51:07,665 INFO scripts.py:789 -- Python code:

2024-02-27T16:51:07.765011616+08:00 stdout F 2024-02-27 08:51:07,665 INFO scripts.py:791 -- import ray

2024-02-27T16:51:07.765014252+08:00 stdout F 2024-02-27 08:51:07,666 INFO scripts.py:792 -- ray.init(address='ray://:10001')

2024-02-27T16:51:07.765016603+08:00 stdout F 2024-02-27 08:51:07,666 INFO scripts.py:801 -- To see the status of the cluster, use

2024-02-27T16:51:07.7650191+08:00 stdout F 2024-02-27 08:51:07,666 INFO scripts.py:802 -- ray status

2024-02-27T16:51:07.765021549+08:00 stdout F 2024-02-27 08:51:07,666 INFO scripts.py:812 -- If connection fails, check your firewall settings and network configuration.

2024-02-27T16:51:07.765023949+08:00 stdout F 2024-02-27 08:51:07,666 INFO scripts.py:820 -- To terminate the Ray runtime, run

2024-02-27T16:51:07.765026287+08:00 stdout F 2024-02-27 08:51:07,666 INFO scripts.py:821 -- ray stop

2024-02-27T16:51:07.765028508+08:00 stdout F

2024-02-27T16:51:07.765031182+08:00 stdout F 2024-02-27 08:51:07,764|p170|INFO|secretflow|entry.py:start_ray:78| Succeeded to start ray head node at lsazz6gmzy3w1ric-0-global.p170.svc.

2024-02-27T16:51:07.776158264+08:00 stdout F 2024-02-27 08:51:07,773|p170|WARNING|secretflow|meta_conversion.py:convert_domain_data_to_individual_table:29| kuscia adapter has to deduce dist data from domain data at this moment.

2024-02-27T16:51:07.785154055+08:00 stderr F 2024-02-27 08:51:07,783 INFO worker.py:1352 -- Connecting to existing Ray cluster at address: lsazz6gmzy3w1ric-0-global.p170.svc:8081...

2024-02-27T16:51:07.785176495+08:00 stdout F 2024-02-27 08:51:07,781|p170|WARNING|secretflow|meta_conversion.py:convert_domain_data_to_individual_table:29| kuscia adapter has to deduce dist data from domain data at this moment.

2024-02-27T16:51:07.785180233+08:00 stdout F 2024-02-27 08:51:07,781|p170|WARNING|secretflow|entry.py:comp_eval:148|

2024-02-27T16:51:07.785183106+08:00 stdout F --

2024-02-27T16:51:07.785185659+08:00 stdout F param

2024-02-27T16:51:07.785187984+08:00 stdout F

2024-02-27T16:51:07.785194939+08:00 stdout F domain: "data_prep"

2024-02-27T16:51:07.785197672+08:00 stdout F name: "psi"

2024-02-27T16:51:07.785200159+08:00 stdout F version: "0.0.2"

2024-02-27T16:51:07.785203098+08:00 stdout F attr_paths: "input/receiver_input/key"

2024-02-27T16:51:07.785205576+08:00 stdout F attr_paths: "input/sender_input/key"

2024-02-27T16:51:07.785208076+08:00 stdout F attr_paths: "protocol"

2024-02-27T16:51:07.785210691+08:00 stdout F attr_paths: "disable_alignment"

2024-02-27T16:51:07.785213078+08:00 stdout F attr_paths: "skip_duplicates_check"

2024-02-27T16:51:07.785215476+08:00 stdout F attr_paths: "check_hash_digest"

2024-02-27T16:51:07.785218276+08:00 stdout F attr_paths: "ecdh_curve"

2024-02-27T16:51:07.785220711+08:00 stdout F attrs {

2024-02-27T16:51:07.785223162+08:00 stdout F ss: "id2"

2024-02-27T16:51:07.78522552+08:00 stdout F }

2024-02-27T16:51:07.785227953+08:00 stdout F attrs {

2024-02-27T16:51:07.785230303+08:00 stdout F ss: "id1"

2024-02-27T16:51:07.785232653+08:00 stdout F }

2024-02-27T16:51:07.785234962+08:00 stdout F attrs {

2024-02-27T16:51:07.785237344+08:00 stdout F s: "PROTOCOL_RR22"

2024-02-27T16:51:07.78523982+08:00 stdout F }

2024-02-27T16:51:07.785242212+08:00 stdout F attrs {

2024-02-27T16:51:07.785244605+08:00 stdout F b: true

2024-02-27T16:51:07.785246879+08:00 stdout F }

2024-02-27T16:51:07.785249263+08:00 stdout F attrs {

2024-02-27T16:51:07.785251548+08:00 stdout F b: true

2024-02-27T16:51:07.785253836+08:00 stdout F }

2024-02-27T16:51:07.785256123+08:00 stdout F attrs {

2024-02-27T16:51:07.785258438+08:00 stdout F b: true

2024-02-27T16:51:07.785260739+08:00 stdout F }

2024-02-27T16:51:07.785263044+08:00 stdout F attrs {

2024-02-27T16:51:07.78526534+08:00 stdout F s: "CURVE_FOURQ"

2024-02-27T16:51:07.785267677+08:00 stdout F }

2024-02-27T16:51:07.785269999+08:00 stdout F inputs {

2024-02-27T16:51:07.785272306+08:00 stdout F name: "bb"

2024-02-27T16:51:07.785274631+08:00 stdout F type: "sf.table.individual"

2024-02-27T16:51:07.785277017+08:00 stdout F meta {

2024-02-27T16:51:07.785279445+08:00 stdout F type_url: "type.googleapis.com/secretflow.spec.v1.IndividualTable"

2024-02-27T16:51:07.785282447+08:00 stdout F value: "\n\227\003\022\003id2\022\020contact_cellular\022\021contact_telephone\022\017contact_unknown\022\tmonth_apr\022\tmonth_aug\022\tmonth_dec\022\tmonth_feb\022\tmonth_jan\022\tmonth_jul\022\tmonth_jun\022\tmonth_mar\022\tmonth_may\022\tmonth_nov\022\tmonth_oct\022\tmonth_sep\022\020poutcome_failure\022\016poutcome_other\022\020poutcome_success\022\020poutcome_unknown\022\001y\003int\005float\005float\005float\005float\005float\005float\005float\005float\005float\005float\005float\005float\005float\005float\005float\005float\005float\005float\005float*\003int\020\377\377\377\377\377\377\377\377\377\001"

2024-02-27T16:51:07.78528738+08:00 stdout F }

2024-02-27T16:51:07.785289775+08:00 stdout F data_refs {

2024-02-27T16:51:07.785292377+08:00 stdout F uri: "jobs/202402271508388120280/temp_party/bob.csv"

2024-02-27T16:51:07.785294735+08:00 stdout F party: "p170"

2024-02-27T16:51:07.785297043+08:00 stdout F format: "csv"

2024-02-27T16:51:07.785299401+08:00 stdout F }

2024-02-27T16:51:07.785301736+08:00 stdout F }

2024-02-27T16:51:07.785304058+08:00 stdout F inputs {

2024-02-27T16:51:07.785311082+08:00 stdout F name: "aa"

2024-02-27T16:51:07.785313677+08:00 stdout F type: "sf.table.individual"

2024-02-27T16:51:07.785316006+08:00 stdout F meta {

2024-02-27T16:51:07.785318484+08:00 stdout F type_url: "type.googleapis.com/secretflow.spec.v1.IndividualTable"

2024-02-27T16:51:07.785322595+08:00 stdout F value: "\n\335\003\022\003id1\022\003age\022\teducation\022\007default\022\007balance\022\007housing\022\004loan\022\003day\022\010duration\022\010campaign\022\005pdays\022\010previous\022\017job_blue-collar\022\020job_entrepreneur\022\rjob_housemaid\022\016job_management\022\013job_retired\022\021job_self-employed\022\014job_services\022\013job_student\022\016job_technician\022\016job_unemployed\022\020marital_divorced\022\017marital_married\022\016marital_single\003int\005float\005float\005float\005float\005float\005float\005float\005float\005float\005float\005float\005float\005float\005float\005float\005float\005float\005float\005float\005float\005float\005float\005float*\005float\020\377\377\377\377\377\377\377\377\377\001"

2024-02-27T16:51:07.785325094+08:00 stdout F }

2024-02-27T16:51:07.785327487+08:00 stdout F data_refs {

2024-02-27T16:51:07.785330011+08:00 stdout F uri: "jobs/202402271535400139000/temp_party/alice.csv"

2024-02-27T16:51:07.785332382+08:00 stdout F party: "p169"

2024-02-27T16:51:07.785334758+08:00 stdout F format: "csv"

2024-02-27T16:51:07.785337091+08:00 stdout F }

2024-02-27T16:51:07.78533944+08:00 stdout F }

2024-02-27T16:51:07.78534202+08:00 stdout F output_uris: "jobs/202402271508388120280/f20deb6a-6697-4f3d-bfae-2fd7c38c71ea-intersection-output"

2024-02-27T16:51:07.785344282+08:00 stdout F

2024-02-27T16:51:07.78534662+08:00 stdout F --

2024-02-27T16:51:07.785348802+08:00 stdout F

2024-02-27T16:51:07.785351176+08:00 stdout F 2024-02-27 08:51:07,781|p170|WARNING|secretflow|entry.py:comp_eval:149|

2024-02-27T16:51:07.785353531+08:00 stdout F --

2024-02-27T16:51:07.785355872+08:00 stdout F storage_config

2024-02-27T16:51:07.785358053+08:00 stdout F

2024-02-27T16:51:07.78536035+08:00 stdout F type: "local_fs"

2024-02-27T16:51:07.78536277+08:00 stdout F local_fs {

2024-02-27T16:51:07.78536521+08:00 stdout F wd: "/home/kuscia/var/storage/data"

2024-02-27T16:51:07.785367586+08:00 stdout F }

2024-02-27T16:51:07.785369763+08:00 stdout F

2024-02-27T16:51:07.785372052+08:00 stdout F --

2024-02-27T16:51:07.785374226+08:00 stdout F

2024-02-27T16:51:07.785376605+08:00 stdout F 2024-02-27 08:51:07,781|p170|WARNING|secretflow|entry.py:comp_eval:150|

2024-02-27T16:51:07.785378945+08:00 stdout F --

2024-02-27T16:51:07.785381306+08:00 stdout F cluster_config

2024-02-27T16:51:07.785383542+08:00 stdout F

2024-02-27T16:51:07.785385826+08:00 stdout F desc {

2024-02-27T16:51:07.785388187+08:00 stdout F parties: "p170"

2024-02-27T16:51:07.785390604+08:00 stdout F parties: "p169"

2024-02-27T16:51:07.785392923+08:00 stdout F devices {

2024-02-27T16:51:07.785395316+08:00 stdout F name: "spu"

2024-02-27T16:51:07.78539761+08:00 stdout F type: "spu"

2024-02-27T16:51:07.785399933+08:00 stdout F parties: "p170"

2024-02-27T16:51:07.78540237+08:00 stdout F parties: "p169"

2024-02-27T16:51:07.785405213+08:00 stdout F config: "{\"runtime_config\":{\"protocol\":\"REF2K\",\"field\":\"FM64\"},\"link_desc\":{\"connect_retry_times\":60,\"connect_retry_interval_ms\":1000,\"brpc_channel_protocol\":\"http\",\"brpc_channel_connection_type\":\"pooled\",\"recv_timeout_ms\":1200000,\"http_timeout_ms\":1200000}}"

2024-02-27T16:51:07.785407554+08:00 stdout F }

2024-02-27T16:51:07.785409955+08:00 stdout F devices {

2024-02-27T16:51:07.785412464+08:00 stdout F name: "heu"

2024-02-27T16:51:07.785414962+08:00 stdout F type: "heu"

2024-02-27T16:51:07.785417342+08:00 stdout F parties: "p170"

2024-02-27T16:51:07.785419703+08:00 stdout F parties: "p169"

2024-02-27T16:51:07.785422174+08:00 stdout F config: "{\"mode\": \"PHEU\", \"schema\": \"paillier\", \"key_size\": 2048}"

2024-02-27T16:51:07.785424622+08:00 stdout F }

2024-02-27T16:51:07.785429146+08:00 stdout F ray_fed_config {

2024-02-27T16:51:07.785431761+08:00 stdout F cross_silo_comm_backend: "brpc_link"

2024-02-27T16:51:07.785434222+08:00 stdout F }

2024-02-27T16:51:07.785436636+08:00 stdout F }

2024-02-27T16:51:07.785439035+08:00 stdout F public_config {

2024-02-27T16:51:07.78544138+08:00 stdout F ray_fed_config {

2024-02-27T16:51:07.785443851+08:00 stdout F parties: "p170"

2024-02-27T16:51:07.785446164+08:00 stdout F parties: "p169"

2024-02-27T16:51:07.785448606+08:00 stdout F addresses: "0.0.0.0:8080"

2024-02-27T16:51:07.785451166+08:00 stdout F addresses: "lsazz6gmzy3w1ric-0-fed.p169.svc:80"

2024-02-27T16:51:07.785453503+08:00 stdout F }

2024-02-27T16:51:07.785457679+08:00 stdout F spu_configs {

2024-02-27T16:51:07.785460179+08:00 stdout F name: "spu"

2024-02-27T16:51:07.785462571+08:00 stdout F parties: "p170"

2024-02-27T16:51:07.785465189+08:00 stdout F parties: "p169"

2024-02-27T16:51:07.785467646+08:00 stdout F addresses: "0.0.0.0:54509"

2024-02-27T16:51:07.785470076+08:00 stdout F addresses: "http://lsazz6gmzy3w1ric-0-spu.p169.svc:80"

2024-02-27T16:51:07.78547253+08:00 stdout F }

2024-02-27T16:51:07.785475003+08:00 stdout F }

2024-02-27T16:51:07.785477405+08:00 stdout F private_config {

2024-02-27T16:51:07.78547984+08:00 stdout F self_party: "p170"

2024-02-27T16:51:07.785482366+08:00 stdout F ray_head_addr: "lsazz6gmzy3w1ric-0-global.p170.svc:8081"

2024-02-27T16:51:07.785484846+08:00 stdout F }

2024-02-27T16:51:07.785487105+08:00 stdout F

2024-02-27T16:51:07.785489527+08:00 stdout F --

2024-02-27T16:51:07.7854917+08:00 stdout F

2024-02-27T16:51:07.785495559+08:00 stdout F 2024-02-27 08:51:07,782|p170|WARNING|secretflow|driver.py:init:442| When connecting to an existing cluster, num_cpus must not be provided. Num_cpus is neglected at this moment.

2024-02-27T16:51:07.799353892+08:00 stderr F [2024-02-27 08:51:07,793 I 7 7] global_state_accessor.cc:357: This node has an IP address of 10.88.0.8, while we can not find the matched Raylet address. This maybe come from when you connect the Ray cluster with a different IP address or connect a container.

2024-02-27T16:51:07.799376039+08:00 stderr F 2024-02-27 08:51:07,795 INFO worker.py:1538 -- Connected to Ray cluster.

2024-02-27T16:51:07.823623081+08:00 stderr F 2024-02-27 08:51:07.823 INFO api.py:213 [p170] -- [Anonymous_job] Started rayfed with {'CLUSTER_ADDRESSES': {'p170': '0.0.0.0:8080', 'p169': 'http://lsazz6gmzy3w1ric-0-fed.p169.svc:80'}, 'CURRENT_PARTY_NAME': 'p170', 'TLS_CONFIG': {}}

2024-02-27T16:51:07.826165377+08:00 stderr F 2024-02-27 08:51:07.823 DEBUG message_queue.py:56 [p170] -- [Anonymous_job] Starting new thread[DataSendingQueueThread] for message polling.

2024-02-27T16:51:07.826179754+08:00 stderr F 2024-02-27 08:51:07.824 DEBUG cleanup.py:67 [p170] -- [Anonymous_job] Start check sending thread.

2024-02-27T16:51:07.826183348+08:00 stderr F 2024-02-27 08:51:07.824 DEBUG message_queue.py:56 [p170] -- [Anonymous_job] Starting new thread[ErrorSendingQueueThread] for message polling.

2024-02-27T16:51:07.826186584+08:00 stderr F 2024-02-27 08:51:07.824 DEBUG cleanup.py:69 [p170] -- [Anonymous_job] Start check error sending thread.

2024-02-27T16:51:07.826189179+08:00 stderr F 2024-02-27 08:51:07.824 INFO cleanup.py:79 [p170] -- [Anonymous_job] Start check sending monitor thread.

2024-02-27T16:51:07.826192251+08:00 stderr F 2024-02-27 08:51:07.824 DEBUG barriers.py:439 [p170] -- [Anonymous_job] Starting ReceiverProxyActor with options: {'max_concurrency': 1, 'max_task_retries': 3, 'max_restarts': 1, 'name': 'SenderReceiverProxyActor'}

2024-02-27T16:51:13.221244169+08:00 stderr F (raylet) [2024-02-27 08:51:08,413 I 312 312] logging.cc:230: Set ray log level from environment variable RAY_BACKEND_LOG_LEVEL to -1

2024-02-27T16:51:13.221270694+08:00 stderr F (SenderReceiverProxyActor pid=312) 2024-02-27 08:51:08.898 INFO link.py:38 [p170] -- [Anonymous_job] brpc options: {'proxy_max_restarts': 3, 'timeout_in_ms': 300000, 'recv_timeout_ms': 604800000, 'connect_retry_times': 3600, 'connect_retry_interval_ms': 1000, 'brpc_channel_protocol': 'http', 'brpc_channel_connection_type': 'pooled', 'exit_on_sending_failure': True}

2024-02-27T16:51:13.221288723+08:00 stderr F (SenderReceiverProxyActor pid=312) I0227 08:51:08.927507 312 external/com_github_brpc_brpc/src/brpc/server.cpp:1158] Server[yacl::link::transport::internal::ReceiverServiceImpl] is serving on port=8080.

2024-02-27T16:51:13.221292287+08:00 stderr F (SenderReceiverProxyActor pid=312) W0227 08:51:08.927557 312 external/com_github_brpc_brpc/src/brpc/server.cpp:1164] Builtin services are disabled according to ServerOptions.has_builtin_services

2024-02-27T16:51:13.221297017+08:00 stderr F (SenderReceiverProxyActor pid=312) I0227 08:51:10.835190 374 external/com_github_brpc_brpc/src/brpc/span.cpp:506] Opened ./rpc_data/rpcz/20240227.085110.312/id.db and ./rpc_data/rpcz/20240227.085110.312/time.db

2024-02-27T16:51:13.221300541+08:00 stderr F 2024-02-27 08:51:13.220 INFO barriers.py:459 [p170] -- [Anonymous_job] Succeeded to create receiver proxy actor.

2024-02-27T16:51:13.221349802+08:00 stderr F 2024-02-27 08:51:13.221 INFO barriers.py:503 [p170] -- [Anonymous_job] Try ping ['p169'] at 0 attemp, up to 3600 attemps.

2024-02-27T16:51:13.225756957+08:00 stderr F 2024-02-27 08:51:13.225 WARNING psi.py:212 [p170] -- [Anonymous_job] {'cluster_def': {'nodes': [{'party': 'p170', 'address': '0.0.0.0:54509', 'listen_address': ''}, {'party': 'p169', 'address': 'http://lsazz6gmzy3w1ric-0-spu.p169.svc:80', 'listen_address': ''}], 'runtime_config': {'protocol': 1, 'field': 2}}, 'link_desc': {'connect_retry_times': 60, 'connect_retry_interval_ms': 1000, 'brpc_channel_protocol': 'http', 'brpc_channel_connection_type': 'pooled', 'recv_timeout_ms': 1200000, 'http_timeout_ms': 1200000}}

2024-02-27T16:51:13.262304544+08:00 stderr F 2024-02-27 08:51:13.262 DEBUG fed_actor.py:104 [p170] -- [Anonymous_job] Actor method call: psi_v2, num_returns: 1

Chrisdehe commented 4 months ago

看起来是任务超时，请确认你参与方之间是否连接

T-ze-yu commented 4 months ago

![Uploading image.png…]() ![Uploading image.png…]() 两边的授权正常啊

zimu-yuxi commented 4 months ago

看一下kuscia日志有没有报错信息，贴一下