kyrozetera

{
  "id": "/spark-streaming-labels-dev",
  "cmd": "/usr/local/spark-2.1.1/bin/spark-submit --class com.koddi.etl.spark.streaming.LabelStream --master mesos://leader.mesos:5050 --conf spark.ssl.noCertVerification=true --conf spark.mesos.executor.docker.image=koddidev/spark:mesos-1.0.1 --conf spark.executor.home=/usr/local/spark-2.1.1 --executor-memory 2g /mnt/mesos/sandbox/spark-streaming.jar dev",
  "cpus": 1,
  "mem": 1024,
  "disk": 1024,
  "instances": 0,
  "container": {
    "type": "DOCKER",
    "volumes": [],

kyrozetera

[2017-01-31 16:59:42,330] INFO  ocalContextSupervisorActor [] [akka://JobServer/user/context-supervisor] - Creating a SparkContext named test-context
[2017-01-31 16:59:42,336] INFO  .jobserver.JobManagerActor [] [akka://JobServer/user/context-supervisor/test-context] - Starting actor spark.jobserver.JobManagerActor
[2017-01-31 16:59:42,382] INFO  k.jobserver.JobStatusActor [] [akka://JobServer/user/context-supervisor/test-context/$a] - Starting actor spark.jobserver.JobStatusActor
[2017-01-31 16:59:42,382] INFO  k.jobserver.JobResultActor [] [akka://JobServer/user/context-supervisor/test-context/$b] - Starting actor spark.jobserver.JobResultActor
[2017-01-31 16:59:42,441] WARN  org.apache.spark.SparkConf [] [akka://JobServer/user/context-supervisor/test-context] - The configuration key spark.akka.threads is not supported any more because Spark doesn't use Akka since 2.0
[2017-01-31 16:59:42,483] INFO  parkContextFactory$$anon$1 [] [akka://JobServer/user/context-supervisor/test-context] - Running Spark version

kyrozetera

{
  "id": "/spark-jobserver",
  "cmd": null,
  "cpus": 0.5,
  "mem": 1024,
  "disk": 100,
  "instances": 1,
  "container": {
    "type": "DOCKER",
    "volumes": [],

kyrozetera

io.netty.channel.ChannelException: Unable to create Channel from class class io.netty.channel.epoll.EpollSocketChannel: java.io.IOException
java.io.IOException: io.netty.channel.ChannelException: Unable to create Channel from class class io.netty.channel.epoll.EpollSocketChannel
at alluxio.client.netty.NettyUnderFileSystemFileWriter.write(NettyUnderFileSystemFileWriter.java:103)
at alluxio.client.file.UnderFileSystemFileOutStream.writeToWorker(UnderFileSystemFileOutStream.java:161)
at alluxio.client.file.UnderFileSystemFileOutStream.flush(UnderFileSystemFileOutStream.java:85)
at alluxio.client.file.UnderFileSystemFileOutStream.close(UnderFileSystemFileOutStream.java:75)
at alluxio.client.file.FileOutStream.close(FileOutStream.java:162)
at com.koddi.etl.lambda.SparkLauncher.writeFileToAlluxio(SparkLauncher.scala:127)
at com.koddi.etl.lambda.SparkLauncher$$anonfun$handleRequest$1.apply(SparkLauncher.scala:55)
at com.koddi.etl.lambda.SparkLauncher$$anonfun$handleRequest$1.apply(SparkLauncher.scala:46)

kyrozetera

$thing = 50 * (1.1);
var_dump($thing);
var_dump(55 == $thing);

/* Output:
 * float(55)
 * bool(false)
 */

$thing = 50 + (50 * (.1));