yujunjun/openspg
1
0
Fork 0
mirror of https://github.com/OpenSPG/openspg.git synced 2026-01-08 05:11:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
baifuyu 2023-12-26 17:52:34 +08:00
parent 65d5e6cc09
commit 43641f4573
3 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
builder/runner/local/src/main/java/com/antgroup/openspg/builder/runner/local/LocalBuilderMain.java
View File

@ -75,8 +75,8 @@ public class LocalBuilderMain {
ALTER_OPERATION_OPTION, ALTER_OPERATION_OPTION, true, "alter operation, upsert or delete");
options.addOption(LOG_FILE_OPTION, LOG_FILE_OPTION, true, "log file");
options.addOption(LEAD_TO_OPTION, LEAD_TO_OPTION, false, "enable leadTo");
options.addOption(GRAPH_STORE_URL, GRAPH_STORE_URL, false, "graph store url");
options.addOption(SEARCH_ENGINE_URL, SEARCH_ENGINE_URL, false, "search engine url");
options.addRequiredOption(GRAPH_STORE_URL, GRAPH_STORE_URL, true, "graph store url");
options.addRequiredOption(SEARCH_ENGINE_URL, SEARCH_ENGINE_URL, true, "search engine url");
CommandLine commandLine = null;
HelpFormatter helper = new HelpFormatter();
@ -113,7 +113,7 @@ public class LocalBuilderMain {
boolean enableLeadTo = commandLine.hasOption(LEAD_TO_OPTION);
String graphStoreUrl = commandLine.getOptionValue(GRAPH_STORE_URL);
String searchEngineUrl = commandLine.getOptionValue(GRAPH_STORE_URL);
String searchEngineUrl = commandLine.getOptionValue(SEARCH_ENGINE_URL);
ProjectSchema projectSchema = getProjectSchema(projectId, schemaUrl);
Map<SPGTypeIdentifier, ConceptList> conceptLists = getConceptLists(enableLeadTo, projectSchema);

2
cloudext/impl/graph-store/tugraph/src/main/java/com/antgroup/openspg/cloudext/impl/graphstore/tugraph/TuGraphStoreClient.java
View File

@ -131,7 +131,7 @@ public class TuGraphStoreClient extends BaseLPGGraphStoreClient {
}
private TuGraphDbRpcClient initTuGraphClient(UriComponents uriComponents) {
String host = uriComponents.getHost();
String host = String.format("%s:%s", uriComponents.getHost(), uriComponents.getPort());
String accessId = uriComponents.getQueryParams().getFirst(ApiConstants.ACCESS_ID);
String accessKey = uriComponents.getQueryParams().getFirst(ApiConstants.ACCESS_KEY);
TuGraphDbRpcClient client = null;

2
python/knext/knext/examples/riskmining/builder/operator/cert_link_operator.py
View File

@ -24,7 +24,7 @@ class CertLinkerOperator(LinkOp):
super().__init__()
self.search_client = SearchClient("RiskMining.Cert")
def eval(self, property: str, record: SPGRecord) -> List[SPGRecord]:
def invoke(self, property: str, record: SPGRecord) -> List[SPGRecord]:
has_cert = property
query = {"match": {"certNum": has_cert}}
recall_certs = self.search_client.search(query, start=0, size=10)