我需要链接两个MapReduce作业.我使用JobControl将job2设置为job1的依赖.它工作,输出文件被创建!! 但它并没有停止!在shell中它保持这种状态:
12/09/11 19:06:24 WARN mapred.JobClient: Use GenericOptionsParser for parsing the arguments. Applications should implement Tool for the same.
12/09/11 19:06:25 INFO input.FileInputFormat: Total input paths to process : 1
12/09/11 19:06:25 INFO util.NativeCodeLoader: Loaded the native-hadoop library
12/09/11 19:06:25 WARN snappy.LoadSnappy: Snappy native library not loaded
12/09/11 19:07:00 WARN mapred.JobClient: Use GenericOptionsParser for parsing the arguments. Applications should implement Tool for the same.
12/09/11 19:07:00 INFO input.FileInputFormat: Total input paths to process : 1
Run Code Online (Sandbox Code Playgroud)
我怎么能阻止它?这是我的主要.
public static void main(String[] …Run Code Online (Sandbox Code Playgroud) 如何按减少顺序对减速器输出进行排序?我正在开发一个必须返回顶级收听歌曲的应用程序.因此歌曲必须按收听次数排序.我的应用程序以这种方式工作:
Input: songname@userid@boolean
MapOutput : songname userid
ReduceOutput : songname number_of_listening
Run Code Online (Sandbox Code Playgroud)
知道怎么做吗?
嗨,我有这个问题:为什么当我为malloc分配一个浮点数组的内存时,它会分配更多我要求的空间?例如,在这段代码中我试图分配一个十个"单元格"浮点数组,但如果我尝试访问其他单元格,则返回我没有段错误:
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
float *fk_array;
int main(int argc, char** argv){
fk_array = (float *) malloc(10 * sizeof(float));
int i;
fk_array[9] = 2.23;
fk_array[15] = 0.3;
for(i = 0; i<20 ; i++)
printf("%f\n",fk_array[i]);
free(fk_array);
return 1;
}
Run Code Online (Sandbox Code Playgroud)
它回报我:
0.000000
0.000000
0.000000
0.000000
0.000000
0.000000
0.000000
0.000000
0.000000
2.230000
0.000000
0.000000
0.000000
0.000000
0.000000
0.300000
0.000000
0.000000
0.000000
0.000000
Run Code Online (Sandbox Code Playgroud)
我错在哪里?