《群面》专题

我已经上载了一个目录到hadoop集群，它的名称中有“，”，就像“mydir,name”一样，当我试图使用rmr hadoop shell命令删除这个目录时，如下所示 删除此类目录的任何解决方案。

如何从weblogic JMS队列中清除/删除消息 我的是一个集群环境，在服务中使用。 获取以下异常。

我已经用intelliJ编写了一个spark scala（sbt）应用程序，我想在Azure databricks上托管的远程集群上运行它。为了避免手动将JAR上传到dbfs中，需要遵循哪些步骤来测试代码

我正在尝试创建一个Hazelcast服务项目，在该项目中，我将订阅一个RDBMS（Oracle DB12C)数据存储，使用反射动态创建一个POJO/Java Bean，然后解析该Java Bean对象，将JDBC ResultSet作为结果行值映射到Java Bean对象中，并将这些映射对象加载到分布式映射中。 我检查了试图加载到Hazelcast IMap中的两个表的数据量，发现它们的数据量低至

问题 我们在不同的机器上安装了两个JBossAS 4.2.3，它们是集群的。我们还使用Lighttpd作为负载平衡器，它位于Tomcat服务器（Tomcat服务器不是集群服务器）和JBoss服务器之间。一旦所有服务器都启动并运行，应用程序就会完美运行。如果我关闭一台JBoss服务器，请求会像预期的那样重定向到另一台服务器。我的问题在我注销应用程序后开始出现。在尝试重新登录应用程序时，我遇到了一个异

有人有在Galera集群和独立的MySQL从机之间建立复制的经验吗？ 我在Galera集群中有三个节点，我想设置gtid复制到MySQL从服务器。问题是，所有Galera节点都编写自己的bin日志，似乎会导致重复查询。结果，我得到了无限的错误，如下所示： MySQL从属版本:5.6.27

配置：三个redis集群分区，跨越三组一主一从。当主机停机时，莴苣立即检测到停机并开始重试。然而，莴苣没有检测到关联的从属服务器已将自己升级为主服务器，并继续使用无法访问且最终超时的旧主服务器重试。尝试将各种拓扑刷新选项设置为无效。 建议的解决方案：在第一次重试失败（这是一行中第二次重试失败）后，使用提供的任何节点的拓扑（因为它们都具有相同的拓扑信息）重新运行拓扑刷新（用于在初始化期间导出拓扑）。

我在Kubernetes有一个Artemis集群，有3组主/从： 我使用Spring boot JmsListener来使用发送到通配符队列的消息，如下所示。 master-0上通配符队列的属性如下所示： 目前使用的Artemis版本是2.17.0。下面是我在master-0中的集群配置。除了被更改以匹配代理之外，其他代理的配置是相同的： 从堆栈溢出的另一个答案中，我了解到我的高可用性拓扑是冗余的

我有一个ECS集群，其中有3个EC2实例，它们都位于私有子网中。我创建了一个任务定义，使用以下环境变量运行Confluent提供的kafka-connect映像： 我在这个集群前面有一个应用程序负载均衡器，在端口8083上有一个侦听器。我已经正确地设置了目标组，以包括运行Kafka-Connect的EC2实例。因此负载均衡器应该将请求转发到集群。确实如此，但我总是得到响应。我可以ssh到EC2实例

我有一个elasticsearch查询，其中包括bool-must/should部分，我已经对这些部分进行了细化，以匹配搜索词，并在优先级字段中增强词，短语匹配等。 我想提升最受欢迎的文件。文档包括一个字段“受欢迎程度”，该字段指示文档被查看的次数。 最好是，我希望提升结果集中的任何离群点文档--这意味着受欢迎程度得分可能与结果集中的平均值相差2个标准差。 我看到聚合，但我感兴趣的是提高查询中的结

我使用Zookeeper和Kafka作为使用Java的消息传递用例。我以为当您重新启动Zookeeper和Kafka服务器时，消费者组详细信息会被删除。但他们没有。zookeeper会将消费者组详细信息保存在某种文件中吗？ 如果我想重置消费者组，我应该手动删除消费者组详细信息吗？ 任何人都可以向我澄清这一点吗？

如果将与有状态重试一起使用，以便每次重试都从代理轮询消息，则存在消费者组重新平衡的长重试周期可能导致分区被重新分配给另一个消费者的风险。因此，有状态重试周期/尝试将被重置，因为新消费者不知道重试的状态。 举个例子，如果重试最长期限是24小时，但消费者组重新平衡平均每12小时发生一次，则重试永远无法完成，一旦超过保留期限，消息（及其背后的消息）最终将从主题中过期。（假设在此时间内未解决可重试异常的原

我有一个kafka主题，有25个分区，集群已经运行了5个月。 根据我对给定主题的每个分区的理解，偏移量从0，1，2开始...(无界) 我看到log-end-offset值很高(现在- 我创建了一个新的消费群体，偏移设置为最早；因此，我预期该消费者组的客户端将从偏移量0开始的偏移量。 我用来创建一个偏移量为最早的新消费者组的命令： 我看到正在创建消费者组。我预计当前偏移量为0；然而，当我描述消费者组

更新： 通过从开始：为目标群集上的使用者设置 false 找到了解决方法。不是最好的解决方案，但它的工作原理... 由于某些原因，所有使用者组偏移量都没有复制到目标群集。例如，我在源集群上用消费者组TEST启动消费者（所有消息都被拉入），然后在复制到目标集群的同一主题上启动消费者（使用消费者组TET），结果是两个消费者都获得了所有消息。 我读过关于消费者补偿翻译功能的文章，但是没有成功。 消费者配

我提交一个火花作业到dataproc这样： gcloud dataproc作业提交spark--cluster=$cluster--region=$region--properties spark。罐。packages=com。谷歌。云spark:spark-bigquery-with-dependencies_2.11:0.19.1，spark。提交deployMode=cluster——类路径