blob: 0ed29efcd9a4fde7f859b183ba3b9444db740fcc [file] [log] [blame]
gearpump {
##############################
### Required to change!!
### You need to set the actual host name here
###
hostname = "127.0.0.1"
worker.slots = 100
### When the resource cannot be allocated in the timeout, then
### the appmaster will shutdown itself.
resource-allocation-timeout-seconds = 10
application.executor-num = 1
## Application's total number of times that allowed to be restarted
application.total-retries = 1
worker.executor-process-launcher = "org.apache.gearpump.cluster.worker.DefaultExecutorProcessLauncher"
cluster {
masters = []
}
streaming.register-task-timeout-ms = 5000
transport.serializer = "org.apache.gearpump.transport.MockTransportSerializer"
serialization-framework = "org.apache.gearpump.serializer.FastKryoSerializationFramework"
}
## Configurations only visible on Linux or Mac..
gearpump-linux {
### On windows, the value must be larger than 10ms, check
### https://github.com/akka/akka/blob/master/akka-actor/src/main/scala/akka/actor/Scheduler.scala#L204
akka.scheduler.tick-duration = 1
}
### Configuration only visible to worker nodes...
gearpump-worker {
## Add worker overrided config
akka {
loglevel = "INFO"
log-dead-letters = off
log-dead-letters-during-shutdown = off
actor {
provider = "akka.remote.RemoteActorRefProvider"
}
cluster {
roles = ["worker"]
}
remote {
log-remote-lifecycle-events = off
}
}
}
### Configuration only visible to master nodes..
gearpump-master {
extensions = [
"akka.contrib.datareplication.DataReplication$"
]
akka {
loglevel = "INFO"
log-dead-letters = off
log-dead-letters-during-shutdown = off
actor {
## Master forms a akka cluster
provider = "akka.cluster.ClusterActorRefProvider"
}
cluster {
roles = ["master"]
## TODO: in integration test, 15s may be too small
## auto-down-unreachable-after = 90s
## The value of this setting will impact master HA recovery time
auto-down-unreachable-after = 15s
}
remote {
log-remote-lifecycle-events = off
}
}
}
gearpump-ui {
gearpump.ui-security {
config-file-based-authenticator = {
admins = {
"admin" = "AeGxGOxlU8QENdOXejCeLxy+isrCv0TrS37HwA=="
}
users = {
}
guests = {
"guest" = "ws+2Dy/FHX4cBb3uKGTR64kZWlWbC91XZRRoew=="
}
}
}
}
akka {
logger-startup-timeout = 30s
log-dead-letters = on
loglevel = "INFO"
actor {
creation-timeout = 60s
provider = "akka.remote.RemoteActorRefProvider"
default-mailbox {
mailbox-type = "akka.dispatch.SingleConsumerOnlyUnboundedMailbox"
}
default-dispatcher {
throughput = 10
fork-join-executor {
parallelism-factor = 2
## Change this to be bigger than 2 to work-around issue
## https://github.com/akka/akka/issues/17253 which will cause
## ActorSystem to timeout when booting
parallelism-max = 8
parallelism-min = 1
}
}
}
remote {
log-remote-lifecycle-events = on
# use-dispatcher = ""
use-dispatcher = "akka.remote.default-remote-dispatcher"
enabled-transports = ["akka.remote.netty.tcp"]
netty.tcp {
port = 0
hostname = "127.0.0.1"
server-socket-worker-pool {
pool-size-min = 1
pool-size-max = 2
}
client-socket-worker-pool {
pool-size-min = 1
pool-size-max = 2
}
}
default-remote-dispatcher {
throughput = 5
type = Dispatcher
executor = "fork-join-executor"
fork-join-executor {
parallelism-min = 1
parallelism-max = 2
}
}
startup-timeout = 600 s
shutdown-timeout = 600 s
flush-wait-on-shutdown = 2 s
command-ack-timeout = 600 s
transport-failure-detector {
heartbeat-interval = 600 s
acceptable-heartbeat-pause = 2000 s
}
watch-failure-detector {
heartbeat-interval = 600 s
acceptable-heartbeat-pause = 10 s
unreachable-nodes-reaper-interval = 600s
expected-response-after = 3 s
}
retry-gate-closed-for = 5 s
prune-quarantine-marker-after = 5 d
system-message-ack-piggyback-timeout = 600 s
resend-interval = 600 s
initial-system-message-delivery-timeout = 3 m
enabled-transports = ["akka.remote.netty.tcp"]
netty.tcp.connection-timeout = 600 s
}
}