小编Ash*_*ith的帖子

我需要在scala中创建一个函数,给定一系列日期,给出一个范围列表.我在Scala中相对较新,我无法弄清楚如何为相同的'for'循环编写.这是我到目前为止所做的:

def calculateDates(from: LocalDate, until: LocalDate): Seq[LocalDate] = {
  var dateArray = []
  //for (LocalDate date <- from; !date.isAfter(to); date <- date.plusDays(1)) 
  for(date <- from to until)
  {
        dateArray :+ date
  }
  return dateArray 
} 

我不知道如何迭代范围.

我是Hadoop的新手,所以我开始设置部分分布式的Hadoop集群localhost.我创建了一个wordcount程序jar来运行,但是当我运行这个jar时,会出现以下错误九次:

NFO ipc.Client: Retrying connect to server: localhost/127.0.0.1:9040. Already tried 9 time(s); retry policy is RetryUpToMaximumCountWithFixedSleep(maxRetries=10, sleepTime=1000 MILLISECONDS)

此外,当我键入jps命令时,我的服务启动是:

9154 DataNode

9777 NodeManager

8967 NameNode

9441 SecondaryNameNode

10060 Jps

核心的site.xml

<configuration>

  <property>
  <name>fs.default.name</name>
  <value>hdfs://localhost:9000</value>
  </property>

  <property>
  <name>hadoop.tmp.dir</name>
  <value>/usr/local/hadoop/tmp</value>
  <description>A base for other temporary directories.</description>
  </property>

  <property>
     <name>fs.file.impl</name>
     <value>org.apache.hadoop.fs.LocalFileSystem</value>
     <description>The FileSystem for file: uris.</description>
  </property>
  -
  <property>
     <name>fs.hdfs.impl</name>
     <value>org.apache.hadoop.hdfs.DistributedFileSystem</value>
     <description>The FileSystem for hdfs: uris.</description>
  </property>

</configuration>

纱的site.xml

<configuration>

  <!-- Site specific YARN configuration properties -->
  <property>
    <name>yarn.nodemanager.aux-services</name>
    <value>mapreduce_shuffle</value>
  </property> …