flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Zach Cox (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-3483) Job graph visualization not working properly in OS X Chrome
Date Tue, 23 Feb 2016 15:40:18 GMT
Zach Cox created FLINK-3483:
-------------------------------

             Summary: Job graph visualization not working properly in OS X Chrome
                 Key: FLINK-3483
                 URL: https://issues.apache.org/jira/browse/FLINK-3483
             Project: Flink
          Issue Type: Bug
          Components: Webfrontend
    Affects Versions: 1.0.0
            Reporter: Zach Cox
            Priority: Minor


In the Chrome browser on OS X (Version 48.0.2564.116 (64-bit)) the job graph visualization
does not work properly. There are no edges displayed in the graph, and dragging the mouse
does not move the graph.

However, Safari (9.0.3) and Firefox (41.0.2) on OS X do display the job graph visualization
properly.

This is the example application I used to create the job:

{code:scala}
package com.banno

import org.apache.flink.streaming.api.scala._

object JobGraphUIProblem extends App {
  val environment = StreamExecutionEnvironment.getExecutionEnvironment
  val ints1 = environment.fromElements((1 to 100): _*)
  val ints2 = environment.fromElements((101 to 200): _*)
  ints1.union(ints2)
    .map(_.toString)
    .print()
  println(environment.getExecutionPlan)
  environment.execute("JobGraphUIProblem")
}
{code}

Here is the execution plan json:

{code:json}
{
  "nodes": [
    {
      "id": 1,
      "type": "Source: Collection Source",
      "pact": "Data Source",
      "contents": "Source: Collection Source",
      "parallelism": 1
    },
    {
      "id": 2,
      "type": "Source: Collection Source",
      "pact": "Data Source",
      "contents": "Source: Collection Source",
      "parallelism": 1
    },
    {
      "id": 4,
      "type": "Map",
      "pact": "Operator",
      "contents": "Map",
      "parallelism": 8,
      "predecessors": [
        {
          "id": 1,
          "ship_strategy": "REBALANCE",
          "side": "second"
        },
        {
          "id": 2,
          "ship_strategy": "REBALANCE",
          "side": "second"
        }
      ]
    },
    {
      "id": 5,
      "type": "Sink: Unnamed",
      "pact": "Data Sink",
      "contents": "Sink: Unnamed",
      "parallelism": 8,
      "predecessors": [
        {
          "id": 4,
          "ship_strategy": "FORWARD",
          "side": "second"
        }
      ]
    }
  ]
}
{code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message