Как зарегистрировать класс в YAML для сериализатора gremlin - Класс не зарегистрирован: org.janusgraph.graphdb.database.StandardJanusGraph - PullRequest
Новая
       23

Как зарегистрировать класс в YAML для сериализатора gremlin - Класс не зарегистрирован: org.janusgraph.graphdb.database.StandardJanusGraph

0 голосов
/ 05 сентября 2018

Я получаю следующую ошибку при создании нового графика с помощью JanusGraph ConfiguredGraphFactory (). 

179262 [gremlin-server-session-1] WARN  org.apache.tinkerpop.gremlin.driver.MessageSerializer  - Response [ResponseMessage{requestId=9cdb34da-2033-4d08-9636-724743f0b798, status=ResponseStatus{code=SUCCESS, message='', attributes={}}, result=ResponseResult{data=[standardjanusgraph[hbase:[127.0.0.1]]], meta={}}}] could not be serialized by org.apache.tinkerpop.gremlin.driver.ser.AbstractGryoMessageSerializerV1d0.
java.lang.IllegalArgumentException: Class is not registered: org.janusgraph.graphdb.database.StandardJanusGraph
Note: To register this class use:     kryo.register(org.janusgraph.graphdb.database.StandardJanusGraph.class);

Это происходит, когда я запускаю эту команду из клиента gremlin 

ConfiguredGraphFactory.create("graph");

Могу ли я узнать, как мне зарегистрировать org.janusgraph.graphdb.database.StandardJanusGraph в YAML?

gremlin-server.yaml определяется следующим образом. Я считаю, что я должен добавить что-то в раздел сериализаторов? 

host: 127.0.0.1
port: 8182
scriptEvaluationTimeout: 30000
channelizer: org.janusgraph.channelizers.JanusGraphWebSocketChannelizer
graphManager: org.janusgraph.graphdb.management.JanusGraphManager
graphs: {
  ConfigurationManagementGraph: conf/gremlin-server/janusgraph-hbase-configurationgraph.properties
}
scriptEngines: {
  gremlin-groovy: {
    plugins: { org.janusgraph.graphdb.tinkerpop.plugin.JanusGraphGremlinPlugin: {},
           org.apache.tinkerpop.gremlin.server.jsr223.GremlinServerGremlinPlugin: {},
           org.apache.tinkerpop.gremlin.tinkergraph.jsr223.TinkerGraphGremlinPlugin: {},
           org.apache.tinkerpop.gremlin.jsr223.ImportGremlinPlugin: {classImports: [java.lang.Math], methodImports: [java.lang.Math#*]},
           org.apache.tinkerpop.gremlin.jsr223.ScriptFileGremlinPlugin: {files: []}}}}
serializers:
  - { className: org.apache.tinkerpop.gremlin.driver.ser.GryoMessageSerializerV3d0, config: { ioRegistries: [org.janusgraph.graphdb.tinkerpop.JanusGraphIoRegistry] }}
  - { className: org.apache.tinkerpop.gremlin.driver.ser.GryoMessageSerializerV3d0, config: { serializeResultToString: true }}
  - { className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV3d0, config: { ioRegistries: [org.janusgraph.graphdb.tinkerpop.JanusGraphIoRegistry] }}
  # Older serialization versions for backwards compatibility:
  - { className: org.apache.tinkerpop.gremlin.driver.ser.GryoMessageSerializerV1d0, config: { ioRegistries: [org.janusgraph.graphdb.tinkerpop.JanusGraphIoRegistry] }}
  - { className: org.apache.tinkerpop.gremlin.driver.ser.GryoLiteMessageSerializerV1d0, config: {ioRegistries: [org.janusgraph.graphdb.tinkerpop.JanusGraphIoRegistry] }}
  - { className: org.apache.tinkerpop.gremlin.driver.ser.GryoMessageSerializerV1d0, config: { serializeResultToString: true }}
  - { className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerGremlinV2d0, config: { ioRegistries: [org.janusgraph.graphdb.tinkerpop.JanusGraphIoRegistry] }}
  - { className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerGremlinV1d0, config: { ioRegistries: [org.janusgraph.graphdb.tinkerpop.JanusGraphIoRegistryV1d0] }}
  - { className: org.apache.tinkerpop.gremlin.driver.ser.GraphSONMessageSerializerV1d0,     config: { ioRegistries: [org.janusgraph.graphdb.tinkerpop.JanusGraphIoRegistryV1d0] }}
processors:
  - { className: org.apache.tinkerpop.gremlin.server.op.session.SessionOpProcessor, config: { sessionTimeout: 28800000 }}
  - { className: org.apache.tinkerpop.gremlin.server.op.traversal.TraversalOpProcessor, config: { cacheExpirationTime: 600000, cacheMaxSize: 1000 }}
metrics: {
  consoleReporter: {enabled: true, interval: 180000},
  csvReporter: {enabled: true, interval: 180000, fileName: /tmp/gremlin-server-metrics.csv},
  jmxReporter: {enabled: true},
  slf4jReporter: {enabled: true, interval: 180000},
  gangliaReporter: {enabled: false, interval: 180000, addressingMode: MULTICAST},
  graphiteReporter: {enabled: false, interval: 180000}}
maxInitialLineLength: 4096
maxHeaderSize: 8192
maxChunkSize: 8192
maxContentLength: 65536
maxAccumulationBufferComponents: 1024
resultIterationBatchSize: 64
writeBufferLowWaterMark: 32768
writeBufferHighWaterMark: 65536

1 Ответ

0 голосов
/ 28 ноября 2018

Я предполагаю, что у вас есть сервер, работающий с предоставленной вами конфигурацией, теперь вы хотите подключиться к нему из Groovy-скрипта. Вот где у меня была такая же проблема. Решение было следующим: 

cluster = Cluster.open("../conf/remote.yaml")
client = cluster.connect()
client.init()
client.submit('kryo.register(org.janusgraph.graphdb.database.StandardJanusGraph.class)\n'+
              'ConfiguredGraphFactory.open("mygraph")')
GraphTraversalSource g = EmptyGraph.instance().traversal().withRemote(
                           DriverRemoteConnection.using(cluster, "mygraph_traversal"))

Это работает без консоли gremlin, поэтому вы можете напрямую скомпилировать и выполнить этот отличный сценарий (с учетом необходимых зависимостей).

...