我试图在Hazelcast 3.8.8中建立分区组。我的主要目标是将驻留在2台物理机器中的4个集群成员分为2个分区组。当我启用分区组时,它似乎不起作用,组也没有建立。您能告诉我启用分区组缺少什么吗?
我试图通过hazelcast启用分区分组。xml。使用group type=“CUSTOM”进行测试,并将驻留在my local和我们的服务器中的成员分为两个不同的成员组。成员组成了一个集群,但似乎没有建立分区组。我看不到有关此的任何错误消息,但日志中也没有确认消息。最后,我启用了“HOST\u AWARE”,在我的本地启动了两个具有相同网络接口的成员,并检查了管理中心。我所看到的是,成员的行为就像默认配置中的“PER\u MEMBER”,并继续将其备份迁移到彼此。我希望在这种情况下不会看到备份,因为两者都将构成分区组。
<hazelcast xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.hazelcast.com/schema/config
http://www.hazelcast.com/schema/config/hazelcast-config-3.6.xsd"
xmlns="http://www.hazelcast.com/schema/config">
<management-center enabled="true">
http://217.78.109.101:8080/mancenter
</manahtml" target="_blank">gement-center>
<map name="default">
<backup-count>1</backup-count>
</map>
<network>
<port auto-increment="true">5701</port>
<join>
<multicast enabled="false">
</multicast>
<tcp-ip enabled="true">
<member>217.78.109.101</member>
</tcp-ip>
</join>
</network>
<partition-group enabled="true" group-type="HOST_AWARE"/>
Kas 08, 2019 2:03:35 PM com.hazelcast.config.XmlConfigLocator
INFO: Loading 'hazelcast.xml' from classpath.
Kas 08, 2019 2:03:35 PM com.hazelcast.config.AbstractXmlConfigHelper
WARNING: Name of the hazelcast schema location incorrect using default
Kas 08, 2019 2:03:36 PM com.hazelcast.instance.AddressPicker
INFO: [LOCAL] [dev] [3.8.8] Interfaces is disabled, trying to pick one address from TCP-IP config addresses: [217.78.109.101]
Kas 08, 2019 2:03:36 PM com.hazelcast.instance.AddressPicker
INFO: [LOCAL] [dev] [3.8.8] Prefer IPv4 stack is true.
Kas 08, 2019 2:03:36 PM com.hazelcast.instance.AddressPicker
INFO: [LOCAL] [dev] [3.8.8] Picked [217.78.109.101]:5702, using socket ServerSocket[addr=/0:0:0:0:0:0:0:0,localport=5702], bind any local is true
Kas 08, 2019 2:03:36 PM com.hazelcast.system
INFO: [217.78.109.101]:5702 [dev] [3.8.8] Hazelcast 3.8.8 (20171204 - 8e24c57) starting at [217.78.109.101]:5702
Kas 08, 2019 2:03:36 PM com.hazelcast.system
INFO: [217.78.109.101]:5702 [dev] [3.8.8] Copyright (c) 2008-2016, Hazelcast, Inc. All Rights Reserved.
Kas 08, 2019 2:03:36 PM com.hazelcast.system
INFO: [217.78.109.101]:5702 [dev] [3.8.8] Configured Hazelcast Serialization version : 1
Kas 08, 2019 2:03:36 PM com.hazelcast.spi.impl.operationservice.impl.BackpressureRegulator
INFO: [217.78.109.101]:5702 [dev] [3.8.8] Backpressure is disabled
Kas 08, 2019 2:03:37 PM com.hazelcast.instance.Node
INFO: [217.78.109.101]:5702 [dev] [3.8.8] Creating TcpIpJoiner
Kas 08, 2019 2:03:37 PM com.hazelcast.spi.impl.operationexecutor.impl.OperationExecutorImpl
INFO: [217.78.109.101]:5702 [dev] [3.8.8] Starting 8 partition threads
Kas 08, 2019 2:03:37 PM com.hazelcast.spi.impl.operationexecutor.impl.OperationExecutorImpl
INFO: [217.78.109.101]:5702 [dev] [3.8.8] Starting 5 generic threads (1 dedicated for priority tasks)
Kas 08, 2019 2:03:37 PM com.hazelcast.internal.diagnostics.Diagnostics
INFO: [217.78.109.101]:5702 [dev] [3.8.8] Diagnostics started
Kas 08, 2019 2:03:37 PM com.hazelcast.internal.diagnostics.BuildInfoPlugin
INFO: [217.78.109.101]:5702 [dev] [3.8.8] Plugin:active
Kas 08, 2019 2:03:37 PM com.hazelcast.internal.diagnostics.SystemPropertiesPlugin
INFO: [217.78.109.101]:5702 [dev] [3.8.8] Plugin:active
Kas 08, 2019 2:03:37 PM com.hazelcast.internal.diagnostics.ConfigPropertiesPlugin
INFO: [217.78.109.101]:5702 [dev] [3.8.8] Plugin:active
Kas 08, 2019 2:03:37 PM com.hazelcast.internal.diagnostics.PendingInvocationsPlugin
INFO: [217.78.109.101]:5702 [dev] [3.8.8] Plugin:active: period-millis:30000 threshold:1
Kas 08, 2019 2:03:37 PM com.hazelcast.internal.diagnostics.MetricsPlugin
INFO: [217.78.109.101]:5702 [dev] [3.8.8] Plugin:active, period-millis:60000
Kas 08, 2019 2:03:37 PM com.hazelcast.internal.diagnostics.SlowOperationPlugin
INFO: [217.78.109.101]:5702 [dev] [3.8.8] Plugin:active, period-millis:30000
Kas 08, 2019 2:03:37 PM com.hazelcast.internal.diagnostics.PendingInvocationsPlugin
INFO: [217.78.109.101]:5702 [dev] [3.8.8] Plugin:active: period-millis:30000 threshold-millis:5000
Kas 08, 2019 2:03:37 PM com.hazelcast.internal.diagnostics.MemberHazelcastInstanceInfoPlugin
INFO: [217.78.109.101]:5702 [dev] [3.8.8] Plugin:active, period-millis:60000
Kas 08, 2019 2:03:37 PM com.hazelcast.internal.diagnostics.SystemLogPlugin
INFO: [217.78.109.101]:5702 [dev] [3.8.8] Plugin:active: logPartitions:false
Kas 08, 2019 2:03:37 PM com.hazelcast.internal.diagnostics.StoreLatencyPlugin
INFO: [217.78.109.101]:5702 [dev] [3.8.8] Plugin:active: period-millis:60000 resetPeriod-millis:0
Kas 08, 2019 2:03:37 PM com.hazelcast.core.LifecycleService
INFO: [217.78.109.101]:5702 [dev] [3.8.8] [217.78.109.101]:5702 is STARTING
Kas 08, 2019 2:03:37 PM com.hazelcast.nio.tcp.InitConnectionTask
INFO: [217.78.109.101]:5702 [dev] [3.8.8] Connecting to /217.78.109.101:5701, timeout: 0, bind-any: true
Kas 08, 2019 2:03:37 PM com.hazelcast.nio.tcp.InitConnectionTask
INFO: [217.78.109.101]:5702 [dev] [3.8.8] Connecting to /217.78.109.101:5703, timeout: 0, bind-any: true
Kas 08, 2019 2:03:37 PM com.hazelcast.nio.tcp.TcpIpConnectionManager
INFO: [217.78.109.101]:5702 [dev] [3.8.8] Established socket connection between /217.78.109.101:62511 and /217.78.109.101:5701
Kas 08, 2019 2:03:38 PM com.hazelcast.nio.tcp.InitConnectionTask
INFO: [217.78.109.101]:5702 [dev] [3.8.8] Could not connect to: /217.78.109.101:5703. Reason: SocketException[Connection refused: connect to address /217.78.109.101:5703]
Kas 08, 2019 2:03:38 PM com.hazelcast.cluster.impl.TcpIpJoiner
INFO: [217.78.109.101]:5702 [dev] [3.8.8] [217.78.109.101]:5703 is added to the blacklist.
Kas 08, 2019 2:03:43 PM com.hazelcast.system
INFO: [217.78.109.101]:5702 [dev] [3.8.8] Cluster version set to 3.8
Kas 08, 2019 2:03:43 PM com.hazelcast.internal.cluster.ClusterService
INFO: [217.78.109.101]:5702 [dev] [3.8.8]
Members [2] {
Member [217.78.109.101]:5701 - 4d2cf34a-d64c-4184-98f3-c0d6dc6a6a27
Member [217.78.109.101]:5702 - 6e23bacc-b0ad-4002-9325-3dffe90417d0 this
}
Kas 08, 2019 2:03:45 PM com.hazelcast.internal.management.ManagementCenterService
INFO: [217.78.109.101]:5702 [dev] [3.8.8] Hazelcast will connect to Hazelcast Management Center on address:
http://217.78.109.101:8080/mancenter
Kas 08, 2019 2:03:46 PM com.hazelcast.internal.jmx.ManagementService
INFO: [217.78.109.101]:5702 [dev] [3.8.8] Hazelcast JMX agent enabled.
Kas 08, 2019 2:03:46 PM com.hazelcast.core.LifecycleService
INFO: [217.78.109.101]:5702 [dev] [3.8.8] [217.78.109.101]:5702 is STARTED
Process Started.
Random int: 553
sequential.Customer with key 1: Hazel1
Map Size:553
Process Completed. Elapsed Time: 1195 ms
当只有单个分区组时,分区机制会回退到特殊的分区组类型,并将现有成员划分为两个分区组。这是为了确保每个分区至少有一个备份。否则将不会有任何备份,成员的丢失将导致立即数据丢失。请参阅代码库:BackupSafeMemberGroupFactory
更新:关于是否启用分区组。。。
不幸的是,除了管理中心之外,没有日志或公共API来显示分区组是否正在使用。但是你可以期望这些信息被打印在日志中。您可以在Hazelcast Github repo上提交问题。
我在同一个消费者组上启动了两个消费者,我订阅了20个主题(每个主题只有一个分区) 仅在消费者上使用: kafka消费者组--引导服务器XXXXX:9092--组foo--描述--成员--详细 我做错了什么?
问题内容: 我可以以某种方式告诉array.contains()方法不区分大小写吗? 问题答案: 只需检查列表中是否存在对象。因此,您不能在此处进行不区分大小写的查找,因为“三”与“三”是不同的对象。 解决此问题的简单方法是 然后 Java 8+版本:
我试图在kafka streams(kafka 1.0.1)和spring cloud stream(2.0.0-build-snapshot)的帮助下实现一个简单的事件源服务。我的StreamListener方法只是读取与聚合状态变化相对应的Kstream事件,并将它们应用到聚合上,并将最新的状态保存在本地状态存储(kafka提供的状态存储)中。域事件消息也具有与聚合的uuid(字符串)相同的键
我对cosmos DB的分区密钥感到困惑。我有一个数据库/容器,大约有4000条小记录。如果我使用分区键筛选器尝试sql语句,则RUs和持续时间会比不使用时长更大。 有人明白这一点吗? 在此示例中,容器的分区键是/partitionkey
我需要找到一种算法来解决以下问题: 给出了一个区间列表(leftBound、RightBound),这是在此行为中对区间进行分组的最有效算法: 间隔:(1,4)、(6,9)、(1,3)、(4,8)、(6,9)、(2,7)、(10,15) 需要的解决方案: 组(2,3)包含(1,3), (1,4), (2,7) 组(6,8)包含(4,8), (6,9) 组(10,15)包含(10,15) 当然,有不
这是将Spark dataframe保存为Hive中的动态分区表的后续操作。我试图在答案中使用建议,但无法在Spark 1.6.1中使用 任何推动这一进程的帮助都是感激的。 编辑:还创建了SPARK-14927