This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
2015-11-12T12:03:35.198Z INFO [d(ip-10-0-0-1.ec2.internal:2181)] [org.apache.zookeeper.ClientCnxn ]: Opening socket connection to server ip-10-0-0-1.ec2.internal/10.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error) | |
2015-11-12T12:03:35.479Z INFO [d(ip-10-0-0-1.ec2.internal:2181)] [org.apache.zookeeper.ClientCnxn ]: Client session timed out, have not heard from server in 858ms for sessionid 0x1250c5c0f1f5001c, closing socket connection and attempting reconnect | |
2015-11-12T12:03:37.398Z INFO [ad(ip-10.0.0.2.ec2.internal:2181)] [org.apache.zookeeper.ClientCnxn ]: Opening socket connection to server ip-10.0.0.2.ec2.internal/10.0.0.2:2181. Will not attempt to authenticate using SASL (unknown error) | |
2015-11-12T12:03:37.787Z INFO [main-EventThread ] [org.I0Itec.zkclient.ZkClient ]: zookeeper state changed (Disconnected) | |
2015-11-12T12:03:38.256Z INFO [ad(ip-10.0.0.2.ec2.internal:2181)] [org.apache.zookeeper.ClientCnxn ]: Client session timed out, have |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
2015-11-12T12:03:40.101Z WARN [Thread-2 ] [kafka.utils.Utils$ ]: | |
java.lang.NullPointerException | |
at org.I0Itec.zkclient.ZkConnection.readData(ZkConnection.java:117) | |
at org.I0Itec.zkclient.ZkClient$10.call(ZkClient.java:992) | |
at org.I0Itec.zkclient.ZkClient$10.call(ZkClient.java:988) | |
at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:883) | |
at org.I0Itec.zkclient.ZkClient.readData(ZkClient.java:988) | |
at org.I0Itec.zkclient.ZkClient.readData(ZkClient.java:983) | |
at kafka.utils.ZkUtils$.readDataMaybeNull(ZkUtils.scala:450) | |
at kafka.utils.ZkUtils$.getController(ZkUtils.scala:65) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
from dateutil import parser | |
import subprocess | |
import os | |
import re | |
import sys | |
import tempfile | |
import numpy as np | |
from pandas import * |