Package org.apache.spark.errors
Class SparkCoreErrors
Object
org.apache.spark.errors.SparkCoreErrors
Object for grouping error messages from (most) exceptions thrown during query execution.
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic Throwable
accessNonExistentAccumulatorError
(long id) static Throwable
addDirectoryError
(org.apache.hadoop.fs.Path path) static Throwable
addLocalDirectoryError
(org.apache.hadoop.fs.Path path) static Throwable
static Throwable
static Throwable
static Throwable
blockDoesNotExistError
(BlockId blockId) static Throwable
blockHaveBeenRemovedError
(String string) static Throwable
blockNotFoundError
(BlockId blockId) static Throwable
blockStatusQueryReturnedNullError
(BlockId blockId) static Throwable
static Throwable
static Throwable
static Throwable
static Throwable
static Throwable
static Throwable
checkpointFailedToSaveError
(int task, org.apache.hadoop.fs.Path path) static Throwable
checkpointRDDBlockIdNotFoundError
(RDDBlockId rddBlockId) static Throwable
checkpointRDDHasDifferentNumberOfPartitionsFromOriginalRDDError
(int originalRDDId, int originalRDDLength, int newRDDId, int newRDDLength) static Throwable
clusterSchedulerError
(String message) static Throwable
static Throwable
static Throwable
static Throwable
static Throwable
static Throwable
eofExceptionWhileReadPortNumberError
(String daemonModule, scala.Option<Object> daemonExitValue) static Throwable
failedRenameTempFileError
(File srcFile, File dstFile) static Throwable
failToCreateCheckpointPathError
(org.apache.hadoop.fs.Path checkpointDirPath) static Throwable
failToCreateDirectoryError
(String path, int maxAttempts) static Throwable
failToGetBlockWithLockError
(BlockId blockId) static Throwable
failToGetNonShuffleBlockError
(BlockId blockId, Throwable e) static Throwable
static Throwable
failToStoreBlockOnBlockManagerError
(BlockManagerId blockManagerId, BlockId blockId) static Throwable
fetchFailedError
(BlockManagerId bmAddress, int shuffleId, long mapId, int mapIndex, int reduceId, String message, Throwable cause) static Throwable
graphiteSinkInvalidProtocolError
(String invalidProtocol) static Throwable
graphiteSinkPropertyMissingError
(String missingProperty) static Throwable
static Throwable
static Throwable
static Throwable
invalidCheckpointFileError
(org.apache.hadoop.fs.Path path) static Throwable
static Throwable
static Throwable
nonEmptyEventQueueAfterTimeoutError
(long timeoutMillis) static Throwable
static Throwable
numPartitionsGreaterThanMaxNumConcurrentTasksError
(int numPartitions, int maxNumConcurrentTasks) static OutOfMemoryError
outOfMemoryError
(long requestedBytes, long receivedBytes) static Throwable
pathNotSupportedError
(String path) static Throwable
rddBlockNotFoundError
(BlockId blockId, int id) static Throwable
static Throwable
readLockedBlockNotFoundError
(BlockId blockId) static Throwable
static Throwable
static Throwable
sparkError
(String errorMsg) static Throwable
static Throwable
taskHasNotLockedBlockError
(long currentTaskAttemptId, BlockId blockId) static String
static String
static Throwable
static Throwable
static Throwable
unexpectedPy4JServerError
(Object other) static Throwable
unexpectedShuffleBlockWithUnsupportedResolverError
(org.apache.spark.shuffle.ShuffleManager shuffleManager, BlockId blockId) static Throwable
static Throwable
unrecognizedSchedulerModePropertyError
(String schedulerModeProperty, String schedulingModeConf) static Throwable
unsupportedDataTypeError
(Object other) static Throwable
static Throwable
static Throwable
-
Constructor Details
-
SparkCoreErrors
public SparkCoreErrors()
-
-
Method Details
-
unexpectedPy4JServerError
-
eofExceptionWhileReadPortNumberError
-
unsupportedDataTypeError
-
rddBlockNotFoundError
-
blockHaveBeenRemovedError
-
histogramOnEmptyRDDOrContainingInfinityOrNaNError
-
emptyRDDError
-
pathNotSupportedError
-
checkpointRDDBlockIdNotFoundError
-
endOfStreamError
-
cannotUseMapSideCombiningWithArrayKeyError
-
hashPartitionerCannotPartitionArrayKeyError
-
reduceByKeyLocallyNotSupportArrayKeysError
-
rddLacksSparkContextError
-
cannotChangeStorageLevelError
-
canOnlyZipRDDsWithSamePartitionSizeError
-
emptyCollectionError
-
countByValueApproxNotSupportArraysError
-
checkpointDirectoryHasNotBeenSetInSparkContextError
-
invalidCheckpointFileError
-
failToCreateCheckpointPathError
public static Throwable failToCreateCheckpointPathError(org.apache.hadoop.fs.Path checkpointDirPath) -
checkpointRDDHasDifferentNumberOfPartitionsFromOriginalRDDError
public static Throwable checkpointRDDHasDifferentNumberOfPartitionsFromOriginalRDDError(int originalRDDId, int originalRDDLength, int newRDDId, int newRDDLength) -
checkpointFailedToSaveError
-
mustSpecifyCheckpointDirError
-
askStandaloneSchedulerToShutDownExecutorsError
-
stopStandaloneSchedulerDriverEndpointError
-
noExecutorIdleError
-
barrierStageWithRDDChainPatternError
-
barrierStageWithDynamicAllocationError
-
numPartitionsGreaterThanMaxNumConcurrentTasksError
public static Throwable numPartitionsGreaterThanMaxNumConcurrentTasksError(int numPartitions, int maxNumConcurrentTasks) -
cannotRunSubmitMapStageOnZeroPartitionRDDError
-
accessNonExistentAccumulatorError
-
sendResubmittedTaskStatusForShuffleMapStagesOnlyError
-
nonEmptyEventQueueAfterTimeoutError
-
durationCalledOnUnfinishedTaskError
-
unrecognizedSchedulerModePropertyError
-
sparkError
-
clusterSchedulerError
-
failToSerializeTaskError
-
unrecognizedBlockIdError
-
taskHasNotLockedBlockError
-
blockDoesNotExistError
-
cannotSaveBlockOnDecommissionedExecutorError
-
waitingForReplicationToFinishError
-
unableToRegisterWithExternalShuffleServerError
-
waitingForAsyncReregistrationError
-
unexpectedShuffleBlockWithUnsupportedResolverError
-
failToStoreBlockOnBlockManagerError
public static Throwable failToStoreBlockOnBlockManagerError(BlockManagerId blockManagerId, BlockId blockId) -
readLockedBlockNotFoundError
-
failToGetBlockWithLockError
-
blockNotFoundError
-
interruptedError
-
blockStatusQueryReturnedNullError
-
unexpectedBlockManagerMasterEndpointResultError
-
failToCreateDirectoryError
-
unsupportedOperationError
-
noSuchElementError
-
fetchFailedError
public static Throwable fetchFailedError(BlockManagerId bmAddress, int shuffleId, long mapId, int mapIndex, int reduceId, String message, Throwable cause) -
failToGetNonShuffleBlockError
-
graphiteSinkInvalidProtocolError
-
graphiteSinkPropertyMissingError
-
outOfMemoryError
-
failedRenameTempFileError
-
addLocalDirectoryError
-
addDirectoryError
-
toConf
-
toConfVal
-