我在SQOOP中运行下面的代码段,最后在代码下面列出了错误.
bin/sqoop job --create myjob import --connect jdbc:mysql:// localhost/test -username root -password root --table patient -m 1 --target-dir/Sqoop/MRJob
administrator @ ubuntu:〜/ sqoop-1.4.4.bin__hadoop-1.0.0 $ bin/sqoop job --create myjob import --connect jdbc:mysql:// localhost/test -username root -password root --table patient - m 1 --target-dir/Sqoop/MRJob警告:/ usr/lib/hcatalog不存在!HCatalog作业将失败.请将$ HCAT_HOME设置为HCatalog安装的根目录.警告:不推荐使用$ HADOOP_HOME.
16/07/16 23:23:36错误工具.BaseSqoopTool:解析作业的参数时出错:14/07/16 23:23:36错误工具.BaseSqoopTool:无法识别的参数:import 14/07/16 23:23:36 ERROR tool.BaseSqoopTool:无法识别的参数: - connect 14/07/16 23:23:36 ERROR tool.BaseSqoopTool:无法识别的参数:jdbc:mysql:// localhost/test 14/07/16 23:23:36错误工具.BaseSqoopTool:无法识别的参数:-username 14/07/16 23:23:36 ERROR tool.BaseSqoopTool:无法识别的参数:root 14/07/16 23:23:36 ERROR tool.BaseSqoopTool:无法识别的参数:-password 14/07/16 23:23:36 ERROR tool.BaseSqoopTool:无法识别的参数:root 14/07/16 23:23:36 ERROR tool.BaseSqoopTool:无法识别的参数:--table 14/07/16 23:23:36错误工具. BaseSqoopTool:无法识别的参数:patient 14/07/16 …
考虑以下SQL:
SELECT mov
FROM movie
WHERE mov IN
(
SELECT mov
FROM movie_star
GROUP BY(mov)
HAVING count(star) > 6
)
INNER JOIN movie_star
ON movie_star.mov = movie.mov;
执行此查询时出现以下错误:
.ERROR 1064(42000):您的SQL语法有错误; 检查对应于你的MySQL服务器版本的手册正确的语法使用近3线"内部联接movie_star上movie_star.mov = movie.mov"
我有一个Shell Scripts来读取输入
#!/bin/bash
echo "Type the year that you want to check (4 digits), followed by [ENTER]:"
read year
echo $year
我正在使用JAVA APi执行这个shell脚本
ProcessBuilder pb = new ProcessBuilder("/bin/bash", "/junk/leaptest.sh");
final Process process = pb.start();
InputStream is = process.getInputStream();
InputStreamReader isr = new InputStreamReader(is);
BufferedReader br = new BufferedReader(isr);
String line;
while ((line = br.readLine()) != null) {
System.out.println(line);
}
System.out.println("Program terminated!");
在Java控制台中,我可以看到输出
键入要检查的年份(4位数),然后按[ENTER]:
现在问题如何在我的脚本中将值传递给Shell脚本如何读取变量"年份"
我根据建议编辑了代码,但在我们更正的地方不起作用
ProcessBuilder pb = new ProcessBuilder("/bin/bash", "-c", "/junk/leaptest.sh");
final Process process = pb.start();
InputStream is = …执行时:
hive -e 'select * from database.table' > /localfilesystem/mytable.txt
列标题名称在表单中database.columnname,我希望它们columnname只是.在执行上述类型的查询时,有没有办法在列名中压缩数据库？
我们可以在同一个hadoop集群中同时使用Fair调度程序和Capacity Scheduler.哪种调度程序是好的和有效的.谁能帮我 ？