addisonj

diff --git a/flink-filesystems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/utils/RefCountedBufferingFileStream.java b/flink-filesystems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/utils/RefCountedBufferingFileStream.java
index 8f3aff899f..c7a5e03f96 100644
--- a/flink-filesystems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/utils/RefCountedBufferingFileStream.java
+++ b/flink-filesystems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/utils/RefCountedBufferingFileStream.java
@@ -22,6 +22,7 @@ import org.apache.flink.annotation.Internal;
 import org.apache.flink.annotation.VisibleForTesting;
 import org.apache.flink.util.function.FunctionWithException;
 
+import java.io.BufferedInputStream;
 import java.io.File;

addisonj

error[E0432]: unresolved import `pg::Enum_OutputPluginOutputType::*`
  --> src/lib.rs:43:9
   |
43 |     use pg::Enum_OutputPluginOutputType::*;
   |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ Could not find `Enum_OutputPluginOutputType` in `pg`

error[E0432]: unresolved import `pg::Enum_ReorderBufferChangeType::*`
   --> src/lib.rs:194:13
    |
194 |         use pg::Enum_ReorderBufferChangeType::*;

addisonj

#!/bin/bash

echo "Failure mode test suite for bash"
echo "  running bash $BASH_VERSION"

try() {
    trap 'echo FAILS' EXIT
    case $1 in
        simple)
            printf "  %-34s" "simple failed command"

addisonj

deploy {
  manager-start-cmd = "/app/manager_start.sh"
}
spark {
  #
  master = "local[4]"
  master = ${?SPARK_MASTER}

  jobserver {
    port = 8090

addisonj

#!/bin/bash
# Script to start the job manager
# args: <work dir for context> <cluster address> [proxy_user]
set -e

get_abs_script_path() {
   pushd . >/dev/null
   cd $(dirname $0)
   appdir=$(pwd)
   popd  >/dev/null

addisonj

#!/bin/bash
# Script to start the job manager
# args: <work dir for context> <cluster address> [proxy_user]
set -e

get_abs_script_path() {
   pushd . >/dev/null
   cd $(dirname $0)
   appdir=$(pwd)
   popd  >/dev/null

addisonj

sjs_1     | Exception in thread "main" java.lang.NoSuchMethodError: scala.Predef$.ArrowAssoc(Ljava/lang/Object;)Ljava/lang/Object;
sjs_1     | 	at akka.cluster.protobuf.ClusterMessageSerializer.<init>(ClusterMessageSerializer.scala:34)
sjs_1     | 	at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
sjs_1     | 	at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)
sjs_1     | 	at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
sjs_1     | 	at java.lang.reflect.Constructor.newInstance(Constructor.java:526)
sjs_1     | 	at akka.actor.ReflectiveDynamicAccess$$anonfun$createInstanceFor$2.apply(DynamicAccess.scala:78)
sjs_1     | 	at scala.util.Try$.apply(Try.scala:161)
sjs_1     | 	at akka.actor.ReflectiveDynamicAccess.createInstanceFor(DynamicAccess.scala:73)
sjs_1     | 	at akka.actor.ReflectiveDynamicAccess$$anonfun$createInstanceFor$3.apply(DynamicAccess.scala:84)

addisonj

const React = require('react')
const {Paper, Card, CardHeader, CardMedia, Avatar} = require('material-ui')

navigator.getUserMedia = navigator.getUserMedia || navigator.webkitGetUserMedia || navigator.mozGetUserMedia
if (!navigator.getUserMedia) {
  throw new Error('getUserMedia not supported')
}
module.exports = React.createClass({
  getDefaultProps() {
    return {

addisonj

var gulp = require('gulp')
var source = require('vinyl-source-stream')
var gutil = require('gulp-util')
var stylus = require('gulp-stylus')
var imagemin = require('gulp-imagemin')
var del = require('del')
var nib = require('nib')
var nodemon = require('gulp-nodemon')
var browserify = require('browserify')
var watchify = require('watchify')

addisonj

diff --git a/lib/uniform_notifier.rb b/lib/uniform_notifier.rb
index f362948..41e4022 100644
--- a/lib/uniform_notifier.rb
+++ b/lib/uniform_notifier.rb
@@ -42,5 +42,13 @@ module UniformNotifier
     def raise=(exception_class)
       UniformNotifier::Raise.setup_connection(exception_class)
     end
+
+    def add_notifier(logger)