[18/51] [abbrv] flink git commit: [FLINK-2357] [web dashboard] Add view for exceptions

[se...@apache.org]

http://git-wip-us.apache.org/repos/asf/flink/blob/ba31f83a/flink-runtime-web/web-dashboard/web/partials/jobs/job.exceptions.html
----------------------------------------------------------------------
diff --git a/flink-runtime-web/web-dashboard/web/partials/jobs/job.exceptions.html b/flink-runtime-web/web-dashboard/web/partials/jobs/job.exceptions.html
index e7f5fc2..7c88ca2 100644
--- a/flink-runtime-web/web-dashboard/web/partials/jobs/job.exceptions.html
+++ b/flink-runtime-web/web-dashboard/web/partials/jobs/job.exceptions.html
@@ -17,54 +17,14 @@ See the License for the specific language governing permissions and
 limitations under the License.
 
 -->
-<pre>org.apache.flink.client.program.ProgramInvocationException: The
-program execution failed: java.lang.Exception: The data preparation
-for task 'Reduce (SUM(2))' , caused an error: Error obtaining the
-sorted input: Thread 'SortMerger spilling thread' terminated due to an
-exception: The user-defined combiner failed in its 'open()' method.
-  at org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:472)
-  at org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:360)
-  at org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:204)
-  at java.lang.Thread.run(Thread.java:745)
-Caused by: java.lang.RuntimeException: Error obtaining the sorted
-input: Thread 'SortMerger spilling thread' terminated due to an
-exception: The user-defined combiner failed in its 'open()' method.
-  at org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:607)
-  at org.apache.flink.runtime.operators.RegularPactTask.getInput(RegularPactTask.java:1133)
-  at org.apache.flink.runtime.operators.GroupReduceDriver.prepare(GroupReduceDriver.java:94)
-  at org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:466)
-  ... 3 more
-Caused by: java.io.IOException: Thread 'SortMerger spilling thread'
-terminated due to an exception: The user-defined combiner failed in
-its 'open()' method.
-  at org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:785)
-Caused by: java.io.IOException: The user-defined combiner failed in
-its 'open()' method.
-  at org.apache.flink.runtime.operators.sort.CombiningUnilateralSortMerger$CombiningSpillingThread.go(CombiningUnilateralSortMerger.java:264)
-  at org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:781)
-Caused by: java.lang.IllegalStateException: The runtime context has
-not been initialized.
-  at org.apache.flink.api.common.functions.AbstractRichFunction.getRuntimeContext(AbstractRichFunction.java:49)
-  at org.apache.flink.api.scala.operators.ScalaAggregateOperator$AggregatingUdf.open(ScalaAggregateOperator.java:261)
-  at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:33)
-  at org.apache.flink.runtime.operators.sort.CombiningUnilateralSortMerger$CombiningSpillingThread.go(CombiningUnilateralSortMerger.java:261)
-  ... 1 more
- 
-  at org.apache.flink.client.program.Client.run(Client.java:345)
-  at org.apache.flink.client.program.Client.run(Client.java:304)
-  at org.apache.flink.client.program.Client.run(Client.java:298)
-  at org.apache.flink.client.program.ContextEnvironment.execute(ContextEnvironment.java:55)
-  at org.apache.flink.api.scala.ExecutionEnvironment.execute(ExecutionEnvironment.scala:530)
-  at com.gmp.MyJob$.main(MyJob.scala:33)
-  at com.gmp.MyJob.main(MyJob.scala)
-  at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
-  at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
-  at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
-  at java.lang.reflect.Method.invoke(Method.java:483)
-  at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:437)
-  at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:353)
-  at org.apache.flink.client.program.Client.run(Client.java:250)
-  at org.apache.flink.client.CliFrontend.executeProgram(CliFrontend.java:374)
-  at org.apache.flink.client.CliFrontend.run(CliFrontend.java:347)
-  at org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:1088)
-  at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1115)</pre>
\ No newline at end of file
+<div ng-repeat="exception in exceptions['all-exceptions']" class="panel panel-default panel-multi">
+  <div class="panel-heading clearfix">
+    <div class="panel-title">{{ exception.task }}</div>
+  </div>
+  <div class="panel-heading clearfix">
+    <div class="panel-info thin last"><span>{{ exception.location }}</span></div>
+  </div>
+  <div class="panel-body">
+    <pre class="exception">{{ exception.exception }}</pre>
+  </div>
+</div>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/flink/blob/ba31f83a/flink-runtime-web/web-dashboard/web/partials/jobs/job.html
----------------------------------------------------------------------
diff --git a/flink-runtime-web/web-dashboard/web/partials/jobs/job.html b/flink-runtime-web/web-dashboard/web/partials/jobs/job.html
index 7e9d196..3f09b53 100644
--- a/flink-runtime-web/web-dashboard/web/partials/jobs/job.html
+++ b/flink-runtime-web/web-dashboard/web/partials/jobs/job.html
@@ -37,7 +37,7 @@ limitations under the License.
   <ul class="nav nav-tabs">
     <li ui-sref-active="active"><a ui-sref=".plan">Plan</a></li>
     <li ui-sref-active="active"><a ui-sref=".statistics">Job Accumulators / Statistics</a></li>
-    <li ui-sref-active="active"><a ui-sref=".timeline">Timeline</a></li>
+    <li ui-sref-active="active" ng-if="job['end-time'] &gt; -1"><a ui-sref=".timeline">Timeline</a></li>
     <li ui-sref-active="active"><a ui-sref=".exceptions">Exceptions</a></li>
     <li ui-sref-active="active"><a ui-sref=".config">Configuration</a></li>
   </ul>