草庐IT

集群NoSQL

全部标签

java - 无法在 docker 上的 spark 集群上提交 spark 作业

如标题所料,我在将spark作业提交到运行在docker上的spark集群时遇到了一些问题。我在scala中编写了一个非常简单的spark作业,订阅了一个kafka服务器,安排了一些数据并将这些数据存储在elastichsearch数据库中。kafka和elasticsearch已经在docker中运行。如果我在我的开发环境(Windows/IntelliJ)中从我的Ide运行spark作业,一切都会完美运行。然后(我根本不是Java专家),我按照以下说明添加了一个spark集群:https://github.com/big-data-europe/docker-spark在查看其仪表

hadoop - 如何将 presto 集群集成到 hadoop 集群?

我们有基于ambari的Hadoop集群由于thriftserver性能不佳,我们决定用presto替换它我们当前的Hadoop集群有以下机器960台数据节点机器(基于redhat7OS)关于presto的几句话-Presto(或PrestoDB)是一个开源的分布式SQL查询引擎,从头开始设计用于对任何大小的数据进行快速分析查询。它同时支持非关系源,例如Hadoop分布式文件系统(HDFS),我们安装了新的prestoserver如下首先我们安装了操作系统(redhat7),一共13台机器1台用于presto协调器的机器还有12台机器供prestoworker使用安装操作系统后我们成功

hadoop - 能否在 Hadoop 集群中的 Map Task 中启动特定进程?

我使用具有一个节点的Hadoop和YARN集群。所有hadoop和yarn守护进程都在这个节点中启动。我还使用ApacheNutch1.15分布式爬网启动了一个获取步骤,成功完成了注入(inject)和生成步骤。我正在尝试使用Selenium3.149.54FirefoxDriver在YarnChild容器上运行的maptask中运行Firefox浏览器。Firefox进程启动,但弹出一个窗口,提示Firefox配置文件丢失或无法访问,maptask被阻止,直到我关闭该窗口。Selenium3.141.54FirefoxDriver使用geckodriver启动Firefox,从容器用

hadoop - 在集群上运行mapreduce程序时,输入路径被视为输出路径

当我在集群上运行map-reduce程序时,输入路径被认为是输出路径,所以我总是得到关于的错误outputdirectoryalreadyexists.但是当我忽略DriverClass的参数时,程序运行成功。我真的不知道为什么会这样。我可以在IntelliJIDEA中运行这个程序,我在本地环境中得到了正确的答案。我没有弄错输入路径的索引和输出的FileInputFormat.setInputPaths(job,newPath(args[0]));FileOutputFormat.setOutputPath(job,newPath(args[1]));HDFS结构下面是我的hadoop

amazon-ec2 - EC2 上 Hadoop 集群中的按需从属生成

我计划在EC2上使用Hadoop。由于我们必须按实例使用量付费,因此拥有固定数量的实例而不是作业实际需要的数量是不好的。在我们的应用程序中,许多作业是并发执行的,我们始终不知道从属需求。是否可以用最少的从属启动hadoop集群,然后根据需求管理可用性?即按需创建/销毁奴隶子问题:hadoop集群能否同时管理多个作业?谢谢 最佳答案 hadoop中使用的默认调度器是一个简单的FIFO调度器,您可以考虑使用FairScheduler,它为每个正在运行的作业分配一个集群份额,并具有广泛的配置来控制这些份额。就EC2而言-您可以轻松地从一些

sql-server - 将 SQL Server 连接到 "NoSQL"数据库

我目前正在进行有关将MicrosoftSQLServer连接到nosql数据库的商业智能研究。我的目标是将数据从nosql表导入到基于SQLServer的关系型DWH。我发现了以下方法:MicrosoftHadoopConnectorHadoopCloudera构建一个单独的脚本并创建一个xml并通过IntegrationServices包含它(不太令人满意)如果有人以前做过类似的事情或知道某种“最佳实践”。使用NoSQL系统并不重要 最佳答案 根据“定义”,NoSQL没有标准结构。因此,根据您尝试从中导入的NoSQL后端,您将需要

hadoop - 如何在不重启hadoop集群的情况下将jar添加到类路径中并生效?

我写了一些引用一些外部jar的mapreduce作业。所以我将它们添加到“正在运行的”集群的CLASSPATH中以运行作业。一旦我尝试运行它们,我就得到类未找到异常。我用谷歌搜索了修复它的方法,我发现我需要重新启动集群才能应用更改后的CLASSPATH,它确实有效。哦,糟糕!每次我将新的jar添加到CLASSPATH时,我真的需要重新启动集群吗?我认为这没有道理。有谁知道如何在不重启的情况下应用更改?我想我需要添加一些细节来征求您的意见。我编写了一个自定义的hbase过滤器类并将其打包在一个jar中。我编写了一个使用自定义过滤器类的mapreduce作业并将其打包在另一个jar中。因为

windows - 设置 (Windows) Hadoop 集群

我已经在我的机器(Windows)上安装了Hadoop-0.20.2。我尝试设置节点集群,包括一个主节点和一个从节点。但是我无法连接机器。密码验证错误。如何解决这个问题?如果可能,请为我提供一个合适的链接,以便在Hadoop中设置多个集群。 最佳答案 对于多节点的WindowsCluster,Hortonworks网站这里有安装文档:http://docs.hortonworks.com/HDPDocuments/HDP2/HDP-2.0.6.0-Win/bk_installing_hdp_for_windows/content/w

hadoop - 集群中多个文件的并行处理

在我工作的公司,我们每天要处理几千个文件,这需要几个小时。这些操作基本上是CPU密集型的,比如将PDF转换为高分辨率图像,然后创建许多不同尺寸的此类图像。这些任务中的每一项都占用大量CPU,因此我们不能简单地在同一台机器上启动多个实例,因为没有任何处理能力可用于所有任务。因此,完成所有事情需要几个小时。在我看来,最明显的做法是对文件集进行分区,并让更多机器同时处理它们(5、10、15台机器,我还不知道需要多少台机器).我不想重新发明轮子并为任务创建一个管理器(我也不想麻烦),但我不确定应该使用哪个工具。虽然我们没有大数据,但我已经开始研究Hadoop(我们在Amazon运行),它处理节

rest - 如何通过负载均衡在 HBase 集群上使用 REST api

我有一个带有1个主节点和5个从节点的试验HBase集群。我想通过其RESTAPI访问(基本上通过GET写入广告印象数据)集群。我希望稍后能够使用Hadoop/Hive?Pig(TBD)运行聚合报告,所以我想要一张数据图片。我是在主节点上启动REST服务器并只写入该单个端点,还是在每个从节点上启动REST服务器实例并在从节点之间进行负载平衡写入?(后者似乎不正确,但我在文档中看到一些提及,所以有点困惑)。 最佳答案 我使用带有通过nginx提供的负载平衡的restapi。你的nginx配置看起来像这样......upstreamclu