Storm 0.10.0 как создать удаленный клиент DRPC?

С запуском Бури 0.10.0 сигнатура DRPCClient изменяется таким образом, что она включает в себя Map параметрStorm 0.10.0 как создать удаленный клиент DRPC?

//conf map, drpc server, port no, timeout for the call 
new DRPCClient(conf, "192.168.0.217", 3772, 5000);

conf по умолчанию имеет следующий

Config conf = new Config(); 
conf.setDebug(false);

Это создает исключение

java.lang.NullPointerException 
java.lang.RuntimeException: java.lang.NullPointerException 
at backtype.storm.security.auth.AuthUtils.GetTransportPlugin(AuthUtils.java:230) 
at backtype.storm.security.auth.ThriftClient.reconnect(ThriftClient.java:91)

Если я добавляю следующее, чтобы conf

conf.put("storm.thrift.transport", "backtype.storm.security.auth.SimpleTransportPlugin");

Исключение составляет

Don't know how to convert null to int 
java.lang.IllegalArgumentException: Don't know how to convert null to int 
at backtype.storm.utils.Utils.getInt(Utils.java:420) 
at backtype.storm.security.auth.ThriftClient.reconnect(ThriftClient.java:100)

шторма стартера для КОРД именно шторм Trident достигнуть на https://github.com/nathanmarz/storm-starter/blob/master/src/jvm/storm/starter/trident/TridentReach.java показывает только клиент DRPC, который является локальным.

документация на сайте для учебника является устаревшим с новым API подписью http://storm.apache.org/documentation/Trident-tutorial.html , который говорит

DRPCClient client = new DRPCClient("drpc.server.location", 3772);

Я понимаю, что есть некоторые безопасности участвуют в вызове, но где мы находим документацию по как это называется.

источник

2015-12-23 Anton Alfred

я проблема с КОРДОМ здесь http://stackoverflow.com/questions/34968869/starting-distributed-rpc-server, вы можете помочь в этом? – user5520049

 Config conf = new Config(); 
     conf.setDebug(false); 
     conf.put("storm.thrift.transport", "backtype.storm.security.auth.SimpleTransportPlugin"); 
     conf.put(Config.STORM_NIMBUS_RETRY_TIMES, 3); 
     conf.put(Config.STORM_NIMBUS_RETRY_INTERVAL, 10); 
     conf.put(Config.STORM_NIMBUS_RETRY_INTERVAL_CEILING, 20); 
     conf.put(Config.DRPC_MAX_BUFFER_SIZE, 1048576);

Добавить все это, оно работает.

источник

2016-01-15 19:09:37 user5796243

отлично, спасибо –

Где мы можем найти документацию? –

вы можете помочь на этом http://stackoverflow.com/questions/34968869/starting-distributed-rpc-server – user5520049

Config conf = new Config(); 
Map defaultConfig = Utils.readDefaultConfig(); 
conf.putAll(defaultConfig);

источник

2016-09-14 09:50:30

Storm 0.10.0 как создать удаленный клиент DRPC?

ответ

Смежные вопросы