You are viewing an old version of this page. View the current version.

Compare with Current View Page History

« Previous Version 87 Next »

JobInProgress // Information should be exported to monitor system.

Path jobFile;

Path localJobFile;

Path localJarFile;

LocalFileSystem localFs; // need higher level abstraction. decoupled from particular fs.

int restartCount; // no use.

long startTime;

long launchTime;// no use.

long finishTime;

int maxTaskAttempts;

String jobName;

private BSPJobID jobId;
final BSPMaster master;
TaskInProgress tasks[] = new TaskInProgress[0];
private long superstepCounter;

Counters counters; //See Counters In Action

int numBSPTasks = 0;
int clusterSize;
String jobSplit;

JobProifile

String user

BSPJobID jobid

String jobFile

String jobName// redundant

JobStatus

BSPJobID jobid;

long progress; // % of bsp()

long cleanupProgress; // % of cleanup()

long setupProgress;// % of setup()

State state;// runState in enum

int runState; // redudant

long startTime;

String schedulingInfo = "NA"; // no use

String user; // redudant

long superstepCount;

String name; // no use

int tasks;

long finishTime;

Counters counter; // redundant.

  • No labels