emaxerrno

{
  "zookeeper_hosts": "104.155.142.242:2181",
  "zookeeper_path": "/concord",
  "executable_arguments": ["sink.py"],
  "executable_name": "runner.bash",
  "compress_files": ["sink.py", "runner.bash"],
  "computation_name": "b",
  "docker_container": "concord/runtime_executor:0.4.3.2",
  "mem": 256,
  "cpus": 0.5,

emaxerrno

// Generated by the smf_gen.
// Any local changes WILL BE LOST.
// source: /home/agallego/workspace/smurf/src/flatbuffers/raft
#pragma once
#ifndef SMF_RAFT__INCLUDED
#define SMF_RAFT__INCLUDED

#include "raft_generated.h"

#include <experimental/optional>

emaxerrno

I0413 19:47:42.202162 31355 exec.cpp:143] Version: 0.28.0
I0413 19:47:42.204401 31361 exec.cpp:217] Executor registered on slave df110eaf-9d50-4727-818f-6021a9946d5b-S4
+++ echo FOOBAR
+++ export LD_LIBRARY_PATH=:/usr/lib/hadoop/lib/native
+++ LD_LIBRARY_PATH=:/usr/lib/hadoop/lib/native
+++ export HADOOP_CONF_DIR=/etc/hadoop/conf
+++ HADOOP_CONF_DIR=/etc/hadoop/conf
+++ export SPARK_LOG_DIR=/var/log/spark
+++ SPARK_LOG_DIR=/var/log/spark
+++ export SPARK_PID_DIR=/run/spark

emaxerrno

package io.concord;
import java.util.{ HashSet => MutableHashSet}
import io.concord._
import io.concord.swift._
import com.typesafe.scalalogging.LazyLogging
import org.apache.kafka.clients.consumer.KafkaConsumer
import org.apache.kafka.common.TopicPartition
import com.google.common.base.Verify.verify
import com.google.common.base.Preconditions.checkNotNull
import java.util.concurrent.ConcurrentLinkedQueue

emaxerrno

#pragma once
#include <glog/logging.h>
#include <folly/io/async/EventBase.h>
#include <proxygen/httpserver/RequestHandler.h>
#include <proxygen/httpserver/ResponseBuilder.h>
#include <folly/MoveWrapper.h>

#include "http_common/client/HTTPClient.hpp"

namespace concord {

emaxerrno

# Build the GRPC Java server which is used for interop testing.
# Interface defined here 
# https://github.com/grpc/grpc-java/blob/master/interop-testing/src/main/proto/io/grpc/testing/integration/test.proto 
./gradlew :grpc-interop-testing:installDist

# Run it with TLS turned on so ALPN is enabled. Uses a dummy cert
./interop-testing/build/install/grpc-interop-testing/bin/test-server --port=8080 --use_tls=true

# Run the awesome nghttp2 as a proxy in front of it. 
# See https://nghttp2.org/documentation/package_README.html#building-from-git

emaxerrno

#!/bin/bash --login

device=$(find /sys/devices/platform/i8042 -name name | xargs grep -Fl TrackPoint | sed 's/\/input\/input[0-9]*\/name$//')
echo 255 | sudo tee $device/sensitivity
echo 255 | sudo tee $device/speed

emaxerrno

References from my talk 'Without Resilience, Nothing Else Matters'

• Drift into Failure
• How Complex Systems Fail
• Antifragile: Things That Gain from Disorder
• Leverage Points: Places to Intervene in a System
• Going Solid: A Model of System Dynamics and Consequences for Patient Safety
• Resilience in Complex Adaptive Systems: Operating at the Edge of Failure
• Puppies! Now that I’ve got your attention, Complexity Theory
• [Towards Resilient Architectures: Biology

emaxerrno

/*
 *
 * Copyright 2015, Google Inc.
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions are
 * met:
 *
 *     * Redistributions of source code must retain the above copyright

emaxerrno

(defun concord-deploy (json-file)
  "Prompt user to enter a file path, with file name completion and input history support."
  (interactive (list (read-file-name "Open directory:")) )
  (message (shell-command-to-string (concat "concord deploy " json-file)))
  )