Skip to content

Instantly share code, notes, and snippets.

Avatar

Addison Higham addisonj

View GitHub Profile
View cluster.tf
module "label" {
source = "cloudposse/label/null"
version = "0.22.0"
attributes = ["cluster"]
context = module.this.context
}
@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')