慢慢来
发布时间:2017-07-25 17:59:30
1. Exception in thread "main" java.lang.NoClassDefFoundError: org/elasticsearch/spark/packageDetails:Exception in thread "main" java.lang.NoClassDefFoundError: org/elasticsearch/spark/package$ at com.tr.bimbqm.report.LoadAggrIns2ES$.main(loadAggrIns2ES.scala:96)&.........【阅读全文】
发布时间:2017-07-19 14:34:01
Specify input columns in hbase. val conf = HBaseConfiguration.create conf.set(TableInputFormat.INPUT_TABLE, tableName) conf.set(TableInputFormat.SCAN_COLUMNS, "d:iss d:mat")......【阅读全文】
发布时间:2017-07-12 09:46:57
1. Create one topic kafka-topics.sh --create --zookeeper c157rnb --replication-factor 2 --partitions 4 --topic test.myang2. List topics kafka-topics.sh --zookeeper c157rnb --list3. bin/kafka-run-class.sh kafka.tools.GetOffsetShell \.........【阅读全文】