Re: Compiler Exception

2015-11-19 Thread Till Rohrmann 
Hi Kien Truong,

could you share the problematic code with us?

Cheers,
Till
On Nov 18, 2015 9:54 PM, "Truong Duc Kien" <duckientru...@gmail.com> wrote:

> Hi,
>
> I'm hitting Compiler Exception with some of my data set, but not all of
> them.
>
> Exception in thread "main" org.apache.flink.optimizer.CompilerException:
> No plan meeting the requirements could be created @ Bulk Iteration (Bulk
> Iteration) (1:null). Most likely reason: Too restrictive plan hints.
>
> Can I have some hints on how to troubleshoot this ?
>
> Thanks,
> Kien Truong
>
>

Re: Compiler Exception

2015-11-19 Thread Truong Duc Kien 

Hi Till,
I have narrowed down a minimal test case, you will need 
flink-gelly-scala package to run this.


import org.apache.flink.api.common.functions.MapFunction import 
org.apache.flink.api.scala._
import org.apache.flink.graph._
import org.apache.flink.graph.scala.Graph
import org.apache.flink.types.NullValue import org.apache.flink.util.Collector 
object BulkIterationBug {
  def main(args:Array[String]):Unit = {
val environment = ExecutionEnvironment.getExecutionEnvironment val g = 
Graph.fromCsvReader[Long,Long,NullValue](
  pathEdges ="edge.in",
  vertexValueInitializer =new MapFunction[Long,Long] {
override def map(t:Long):Long =t },
  fieldDelimiterEdges =" ",
  lineDelimiterEdges ="\n",
  ignoreCommentsEdges ="%",
  env = environment
)
val vertices = g.getVertices val edges = g.getEdges val data = 
vertices.iterate(1) {
  (it) => {
it.coGroup(edges).where(0).equalTo(0) {
  (first:Iterator[Vertex[Long,Long]],
   second:Iterator[Edge[Long,NullValue]],
   collector:Collector[Vertex[Long,Long]]) => {
if (first.hasNext) {
  collector.collect(first.next)
}
  }
}
  }
}
println(data.collect())
  }
}

The input file "edge.in" contains only 1 line

1 2


Thanks,
Kien Truong


On 11/19/2015 09:36 AM, Till Rohrmann wrote:


Hi Kien Truong,

could you share the problematic code with us?

Cheers,
Till

On Nov 18, 2015 9:54 PM, "Truong Duc Kien" <duckientru...@gmail.com 
<mailto:duckientru...@gmail.com>> wrote:


Hi,

I'm hitting Compiler Exception with some of my data set, but not
all of them.

Exception in thread "main"
org.apache.flink.optimizer.CompilerException: No plan meeting the
requirements could be created @ Bulk Iteration (Bulk Iteration)
(1:null). Most likely reason: Too restrictive plan hints.

Can I have some hints on how to troubleshoot this ?

Thanks,
Kien Truong

Compiler Exception

2015-11-18 Thread Truong Duc Kien 
Hi,

I'm hitting Compiler Exception with some of my data set, but not all of
them.

Exception in thread "main" org.apache.flink.optimizer.CompilerException: No
plan meeting the requirements could be created @ Bulk Iteration (Bulk
Iteration) (1:null). Most likely reason: Too restrictive plan hints.

Can I have some hints on how to troubleshoot this ?

Thanks,
Kien Truong