程序员小董_个人页

ReTairClient 2.3.5init config failed 数据量小的时候 没事 数据量一大 就有这个问题了

Re关于submit topology failedcant find topology jar fail 我刚才查了一下 edu.emory.mathcs.backport.java.util.concurrent.helpers.Utils来自backport util concurrent.jar 而这个jar包来自jstorm 集群认为这也是外包jar包 所以不行喽

Retair写进去的数据咋这么少 应该不是正确率的问题 只要你对应的key里面有数据 不管对错 都算 现在的情况只能说 你没有写进去而不是写错了

Re我的本地集群测试的数据达到40万tuple结果依然没有任何错，提交却正 我估计是你效率太低里 20分钟结束的时候 你还没用处理完所有数据 所以不能等数据都处理完了 再去给tair里写

Re提交出现没有结果的问题 我的结果与楼主的类似

Re提交后的结果显示不完全，网页出现问题 最后 我排查出来的问题是 如果直接提交就OK 有了if else 就不行 难道说 集群的时候没有给加参数? ------------------------- Re提交后的结果显示不完全，网页出现问题 最后 我排查出来的问题是 如果直接提交就OK 有了if else 就不行 难道说 集群的时候没有给加参数?

Re测试日志中出现的问题 你的topology是不是会自动结束呀? 把 下面的代码去掉试试             cluster.killTopology('xxx');             cluster.shutdown();

Re怎样将rocketmq中的数据传入jstorm？ 学习嘛 不就是自己找资料的过程么

Re关于tair的put与get 当然   namespace都是一样的 ------------------------- 回 2楼小强7657723的帖子 我用代码可以 命令行没试过 我的qq 460795365 咱们讨论讨论 ------------------------- 回 5楼程序员小董的帖子 我靠 之前可以 现在代码也不能incr了 ------------------------- 回 3楼小强7657723的帖子                 System.out.println('**********');         tairManager.put(5, 'dlf', 7);         Result resultInt=tairManager.incr(5, 'dlf', 12, 3, 0);                  Object obj=resultInt.getValue();         System.out.println('ps '+obj);         System.out.println('ks '+tairManager.get(5, 'dlf').getValue().getValue()); 打印结果是 ********** ps null ks 7 ------------------------- Re关于tair的put与get 人笨呀 我自己想把数据放入不同的namespace中好区分 可是忘了在group_info中声明配额 感谢浅弈大大

Rejstorm启动失败：Invalid initial heap sizeXms4g 如果是开发环境本地内存不足情况时启动nimbus可能会抛出异常： Error occurred during initialization of VM Could not reserve enough space for object heap 只需要在conf/storm.yaml里配置： nimbus.childopts: “-Xmx256m” supervisor.childopts: “-Xmx256m” worker.childopts: “-Xmx128m” 其中大小可根据实际情况配置

ReERROR 2016-05-29 180009 c.a.j.s.FollowerRunnable85 mainget nimbus host error 人笨 不能怪社会 把 /etc/hosts 改成 127.0.0.1    localhost 10.105.23.114   VM_23_114_centos 最重要的 设置完后须运行/etc/init.d/network restart，否则不起作用

ReRocketMq代码连接问题 使用mqbroker -c 加载配置文件的方式 启动

Re关于tair的java客户端调试 在group.conf 里 使用公网地址 即可 如果还不能搞定 再联系我