Skip to content

Instantly share code, notes, and snippets.

@Fluxx
Created July 28, 2017 01:10
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save Fluxx/89f41cd98813358566efe03f30f032cd to your computer and use it in GitHub Desktop.
Save Fluxx/89f41cd98813358566efe03f30f032cd to your computer and use it in GitHub Desktop.
src/main/java/com/pinterest/secor/common/KafkaClient.java:109: throw new RuntimeException("Error fetching offset data. Reason: " +
src/main/java/com/pinterest/secor/common/KafkaClient.java:130: throw new RuntimeException("Error fetching offset data. Reason: " +
src/main/java/com/pinterest/secor/common/KafkaClient.java:178: throw new RuntimeException("Expected one metadata for topic " + topic + " found " +
src/main/java/com/pinterest/secor/common/LogFilePath.java:83: throw new RuntimeException("Unable to find mdt digest.", e);
src/main/java/com/pinterest/secor/common/LogFilePath.java:184: throw new RuntimeException(e);
src/main/java/com/pinterest/secor/common/SecorConfig.java:50: throw new RuntimeException("Error loading configuration from " + configProperty);
src/main/java/com/pinterest/secor/common/SecorConfig.java:440: throw new RuntimeException("secor.file.reader.Delimiter length can not be greater than 1 character");
src/main/java/com/pinterest/secor/common/SecorConfig.java:448: throw new RuntimeException("secor.file.writer.Delimiter length can not be greater than 1 character");
src/main/java/com/pinterest/secor/common/SecorConfig.java:542: throw new RuntimeException("Failed to find required configuration option '" +
src/main/java/com/pinterest/secor/consumer/Consumer.java:90: throw new RuntimeException("Failed to initialize the consumer", e);
src/main/java/com/pinterest/secor/consumer/Consumer.java:117: throw new RuntimeException("Failed to apply upload policy", e);
src/main/java/com/pinterest/secor/consumer/Consumer.java:140: throw new RuntimeException("Failed to adjust offset.", e);
src/main/java/com/pinterest/secor/consumer/Consumer.java:154: throw new RuntimeException("Failed to parse message " + rawMessage, e);
src/main/java/com/pinterest/secor/consumer/Consumer.java:166: throw new RuntimeException("Failed to write message " + parsedMessage, e);
src/main/java/com/pinterest/secor/io/impl/FlexibleDelimitedFileReaderWriterFactory.java:89: throw new RuntimeException("Error loading configuration from getFileReaderDelimiter()");
src/main/java/com/pinterest/secor/io/impl/FlexibleDelimitedFileReaderWriterFactory.java:146: throw new RuntimeException("Error loading configuration from getFileWriterDelimiter()");
src/main/java/com/pinterest/secor/parser/Iso8601MessageParser.java:49: throw new RuntimeException("Missing timestamp field for message: " + message);
src/main/java/com/pinterest/secor/parser/Iso8601MessageParser.java:58: throw new RuntimeException("Bad timestamp field for message: " + message);
src/main/java/com/pinterest/secor/parser/JsonMessageParser.java:45: throw new RuntimeException("Missing timestamp field for message: " + message);
src/main/java/com/pinterest/secor/parser/QuboleClient.java:74: throw new RuntimeException("command " + url + " body " + body + " unexpected " +
src/main/java/com/pinterest/secor/parser/QuboleClient.java:79: throw new RuntimeException("command " + url + " with body " + body + " failed " +
src/main/java/com/pinterest/secor/parser/SplitByFieldMessageParser.java:55: throw new RuntimeException("Failed to parse message as Json object");
src/main/java/com/pinterest/secor/parser/SplitByFieldMessageParser.java:78: throw new RuntimeException("Could not find key " + mSplitFieldName + " in Json message");
src/main/java/com/pinterest/secor/parser/SplitByFieldMessageParser.java:88: throw new RuntimeException("Failed to extract timestamp from the message");
src/main/java/com/pinterest/secor/reader/MessageReader.java:72: throw new RuntimeException("Topic filter and blacklist cannot be both specified.");
src/main/java/com/pinterest/secor/timestamp/KafkaMessageTimestampFactory.java:16: throw new RuntimeException(e);
src/main/java/com/pinterest/secor/tools/LogFileVerifier.java:137: throw new RuntimeException("Message count of " + previousMessageCount +
src/main/java/com/pinterest/secor/tools/LogFileVerifier.java:149: throw new RuntimeException("Message count " + aggregateMessageCount +
src/main/java/com/pinterest/secor/tools/LogFileVerifier.java:159: throw new RuntimeException("duplicate key " + record.getOffset() + " found in file " +
src/main/java/com/pinterest/secor/tools/ProgressMonitor.java:119: throw new RuntimeException("url " + url + " with body " + body + " failed " +
src/main/java/com/pinterest/secor/tools/TestLogMessageProducer.java:76: throw new RuntimeException("Undefined message encoding type: " + mType);
src/main/java/com/pinterest/secor/tools/TestLogMessageProducer.java:93: throw new RuntimeException("Failed to serialize message " + testMessage, e);
src/main/java/com/pinterest/secor/uploader/AzureUploadManager.java:65: throw new RuntimeException(e);
src/main/java/com/pinterest/secor/uploader/AzureUploadManager.java:67: throw new RuntimeException(e);
src/main/java/com/pinterest/secor/uploader/AzureUploadManager.java:69: throw new RuntimeException(e);
src/main/java/com/pinterest/secor/uploader/AzureUploadManager.java:71: throw new RuntimeException(e);
src/main/java/com/pinterest/secor/uploader/GsUploadManager.java:102: throw new RuntimeException(e);
src/main/java/com/pinterest/secor/uploader/GsUploadManager.java:125: throw new RuntimeException("Failed to load Google credentials : " + credentialsPath, e);
src/main/java/com/pinterest/secor/uploader/HadoopS3UploadManager.java:68: throw new RuntimeException(e);
src/main/java/com/pinterest/secor/util/ProtobufUtil.java:115: throw new RuntimeException("Can't parse protobuf message, since parseMethod() is not callable. "
src/main/java/com/pinterest/secor/util/ProtobufUtil.java:118: throw new RuntimeException("Can't parse protobuf message, since parseMethod() is not accessible. "
src/main/java/com/pinterest/secor/util/ProtobufUtil.java:121: throw new RuntimeException("Error parsing protobuf message", e);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment