gaborbarna

org.apache.spark.SparkException: Job aborted due to stage failure: Task 2 in stage 50967.0 failed 30 times, most recent failure: Lost task 2.29 in stage 50967.0 (TID 611666, ip-10-134-0-32.us-west-2.compute.internal, executor 2): java.lang.NullPointerException
        at java.util.concurrent.ConcurrentHashMap.putVal(ConcurrentHashMap.java:1011)
        at java.util.concurrent.ConcurrentHashMap.putAll(ConcurrentHashMap.java:1084)
        at org.apache.spark.sql.execution.streaming.state.HDFSBackedStateStoreProvider.getStore(HDFSBackedStateStoreProvider.scala:204)
        at org.apache.spark.sql.execution.streaming.state.StateStore$.get(StateStore.scala:371)
        at org.apache.spark.sql.execution.streaming.state.StateStoreRDD.compute(StateStoreRDD.scala:88)
        at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:324)
        at org.apache.spark.rdd.RDD.iterator(RDD.scala:288)
        at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52)
        at org.apache.spark.rdd.RDD.

gaborbarna

FROM docker.util.pages/platform/openjdk:8.0

ARG VERSION
ENV VERSION ${VERSION}

WORKDIR /usr/local/oit

COPY target/scala-2.11/outcome-ingestor-tool-assembly-${VERSION}.jar ./

gaborbarna

kubectl --context data-services.us-west-2a --namespace tools apply -f job.yaml
kubectl --context data-services.us-west-2a --namespace tools get pods --selector=job-name=oit-test
kubectl --context data-services.us-west-2a --namespace tools logs <pod name>

gaborbarna

#include <Adafruit_NeoPixel.h>
#ifdef __AVR__
#include <avr/power.h>
#endif

#define PIN 8
#define NUM_LEDS 240
#define BRIGHTNESS 100
#define PI 3.1415926535897932384626433832795

gaborbarna

using EpForceDirectedGraph.cs;

public class NodeDataVR : NodeData
{
	public NodeDataVR(JSONObject entity) {
		this.jsonObject = entity;
		this.label = entity ["id"].str;
	}

	public JSONObject jsonObject { get; set; }

gaborbarna

import maf, os
maf.setBasedir( os.path.dirname( os.path.abspath( __file__ ) ) )

import pkgutil
import argparse
import management2.tasks
import inspect
from maf.application.management.application import Application
import config
from management2.registry import provide_resource

gaborbarna

(ns hash-test.core
  (:require [criterium.core :as crit]))

(defn fill-with-into [items]
  (into {} (map vec items)))

(defn no-assoc [items]
  (apply hash-map items))
 
(defn assoc-all [items]

gaborbarna

_ = require 'underscore'
http = require 'http'
fs = require 'fs'
sys = require 'sys'
os = require 'os'
exec = (require 'child_process').exec
udp = require 'dgram'
hostname = (require 'os').hostname()
iface = 'wlan0'
udp_port = 8125

gaborbarna

_ = require 'underscore'
http = require 'http'
fs = require 'fs'
sys = require 'sys'
os = require 'os'
exec = (require 'child_process').exec
udp = require 'dgram'
hostname = (require 'os').hostname()
iface = 'wlan0'
udp_port = 8125

gaborbarna

Wrote /home/lesbroot/.emacs.d/elpa/pcache-0.2.3/pcache.elc
Checking /home/lesbroot/.emacs.d/elpa/pcache-0.2.3...
Done (Total of 2 files compiled, 1 skipped)
Contacting host: marmalade-repo.org:80
Parsing tar file...done
Extracting gh-0.5.3/
Extracting gh-0.5.3/gh-common.el
Wrote /home/lesbroot/.emacs.d/elpa/gh-0.5.3/gh-common.el
Extracting gh-0.5.3/README
Wrote /home/lesbroot/.emacs.d/elpa/gh-0.5.3/README