| 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 |
| } |
| } |