Skip to content

Instantly share code, notes, and snippets.

Addison Higham addisonj

  • Provo, UT
Block or report user

Report or block addisonj

Hide content and notifications from this user.

Learn more about blocking users

Contact Support about this user’s behavior.

Learn more about reporting abuse

Report abuse
View GitHub Profile
@addisonj
addisonj / file-file.diff
Created Dec 17, 2018
A fix for s3 issues on StreamingFileSInk
View file-file.diff
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;
View gist:b89fb5b3508017d05d73e044e017357d
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::*;
View failure-suite.sh
#!/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"
View docker.conf
deploy {
manager-start-cmd = "/app/manager_start.sh"
}
spark {
#
master = "local[4]"
master = ${?SPARK_MASTER}
jobserver {
port = 8090
View manager_start.sh
#!/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
View manager_start.sh
#!/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
View gist:b7f9b480e5164132f93585c2128def93
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)
View VideoCore.jsx
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 {
View -
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')
View -
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)
You can’t perform that action at this time.