Skip to content

Commit

Permalink
[misc] Minor fixed to config docs and minor code cleanups in Client
Browse files Browse the repository at this point in the history
  • Loading branch information
StephanEwen committed Nov 10, 2015
1 parent 2bb5799 commit 0de13b5
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 10 deletions.
11 changes: 6 additions & 5 deletions docs/setup/config.md
Original file line number Diff line number Diff line change
Expand Up @@ -210,18 +210,19 @@ the JVMs running Flink's services.

Supported backends:

- `jobmanager` (in-memory)
- `filesystem` (all filesystems supported by Flink, for example HDFS)
- `jobmanager`: In-memory state, backup to JobManager's/ZooKeeper's memory. Should be used only for minimal state (Kafka offsets) or testing and local debugging.
- `filesystem`: State is in-memory on the TaskManagers, and state snapshots are stored in a file system. Supported are all filesystems supported by Flink, for example HDFS, S3, ...

- `state.backend.fs.checkpointdir`: Directory for storing checkpoints in a flink supported filesystem
Note: State backend must be accessible from the JobManager, use file:https:// only for local setups.

- `blob.storage.directory`: Directory for storing blobs (such as user jar's) on the TaskManagers.

- `execution-retries.delay`: Delay between execution retries. Default value "100 s". Note that values
- `execution-retries.delay`: Delay between execution retries. Default value "5 s". Note that values
have to be specified as strings with a unit.

- `execution-retries.default`: Default number of execution retries (Can also be set on a per-job basis).
- `execution-retries.default`: Default number of execution retries, used by jobs that do not explicitly
specify that value on the execution environment. Default value is zero.

## Full Reference

Expand Down Expand Up @@ -503,4 +504,4 @@ The command line value therefore is called `-p` (for parallelism). In addition,
to [set the number of slots in the programming APIs]({{site.baseurl}}/apis/programming_guide.html#parallel-execution) for
the whole application and individual operators.

<img src="fig/slots_parallelism.svg" class="img-responsive" />
<img src="fig/slots_parallelism.svg" class="img-responsive" />
Original file line number Diff line number Diff line change
Expand Up @@ -69,11 +69,8 @@
public class Client {

private static final Logger LOG = LoggerFactory.getLogger(Client.class);

/**
* The configuration to use for the client (optimizer, timeouts, ...) and to connect to the
* JobManager.
*/


/** The optimizer used in the optimization of batch programs */
final Optimizer compiler;

Expand Down Expand Up @@ -150,6 +147,7 @@ public Client(Configuration config, int maxSlots) throws IOException {
timeout = AkkaUtils.getTimeout(config);
lookupTimeout = AkkaUtils.getTimeout(config);
}

// ------------------------------------------------------------------------
// Startup & Shutdown
// ------------------------------------------------------------------------
Expand Down

0 comments on commit 0de13b5

Please sign in to comment.