小编Sud*_*udo的帖子

我使用Tweepy API来提取Twitter提要.我想只提取特定语言的所有Twitter提要.语言过滤器仅在track提供过滤器时有效.以下代码返回406错误:

l = StdOutListener()
auth = OAuthHandler(consumer_key, consumer_secret)
auth.set_access_token(access_token, access_token_secret)
stream = Stream(auth, l)
stream.filter(languages=["en"])

如何使用Tweepy从特定语言中提取所有推文？

我在一组集群上安装了spark standalone.我尝试通过集群启动脚本启动集群.我已将群集的IP地址添加到conf/slaves文件中.主设备通过无密码ssh连接到所有从设备.运行./bin/start-slaves.sh脚本后,我收到以下消息:

启动org.apache.spark.deploy.worker.Worker,登录到/root/spark-0.8.0-incubating/bin/../logs/spark-root-org.apache.spark.deploy.worker.Worker-1 -jbosstest2.out

但是master(localhost:8080)的webUI没有显示有关worker的任何信息.但是当我将localhost条目添加到我的conf/slaves文件时,会显示localhost的worker信息.

没有错误消息,终端上的消息表明工作人员已启动,但WebUI未显示任何工作人员.

我在3个集群上设置了hadoop2.2.0.一切都很顺利.NodeManager和Datanode在每个集群中启动.但是,当我运行wordcount示例时,会发生100%映射,并给出以下异常:

map 100% reduce 0%
13/11/28 09:57:15 INFO mapreduce.Job: Task Id : attempt_1385611768688_0001_r_000000_0, Status : FAILED
Container launch failed for container_1385611768688_0001_01_000003 : org.apache.hadoop.yarn.exceptions.
YarnException: Unauthorized request to start container.
This token is expired. current time is 1385612996018 found 1385612533275
        at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)

我已经通过互联网找出解决方案.但我找不到.帮帮我.