[
https://issues.apache.org/jira/browse/FLINK-3483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zach Cox updated FLINK-3483:
----------------------------
Description:
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}
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}
{
"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}
was:
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}
> 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
> Attachments: chrome-job-graph.png, firefox-job-graph.png,
> safari-job-graph.png
>
>
> 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}
> 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}
> {
> "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)
