Closed jonasrk closed 7 years ago
There seems to be a problem with putting together my SVRG plan over at https://github.com/jonasrk/rheemstudy/blob/master/src/main/java/SvrgUnrolled.java .
In particular, I have a reduce operator that should serve as the input for a map operator and should also be broadcasted to two other map operators.
Sebastian has also reproduced this behavior with only one broadcast.
Error message: Exception in thread "main" org.qcri.rheem.core.api.exception.RheemException: No implementations that concatenate out@Alternative[2x ~Alternative[[GlobalReduce[reduce]]], 7e07db1f] with [in@Alternative[2x ~Alternative[[Map[update]]], 7334aada], mu@Alternative[2x ~Alternative[[Map[update]]], 6e20b53a], mu@Alternative[2x ~Alternative[[Map[update]]], 6aba2b86]].
Exception in thread "main" org.qcri.rheem.core.api.exception.RheemException: No implementations that concatenate out@Alternative[2x ~Alternative[[GlobalReduce[reduce]]], 7e07db1f] with [in@Alternative[2x ~Alternative[[Map[update]]], 7334aada], mu@Alternative[2x ~Alternative[[Map[update]]], 6e20b53a], mu@Alternative[2x ~Alternative[[Map[update]]], 6aba2b86]].
There seems to be a problem with putting together my SVRG plan over at https://github.com/jonasrk/rheemstudy/blob/master/src/main/java/SvrgUnrolled.java .
In particular, I have a reduce operator that should serve as the input for a map operator and should also be broadcasted to two other map operators.
Sebastian has also reproduced this behavior with only one broadcast.
Error message:
Exception in thread "main" org.qcri.rheem.core.api.exception.RheemException: No implementations that concatenate out@Alternative[2x ~Alternative[[GlobalReduce[reduce]]], 7e07db1f] with [in@Alternative[2x ~Alternative[[Map[update]]], 7334aada], mu@Alternative[2x ~Alternative[[Map[update]]], 6e20b53a], mu@Alternative[2x ~Alternative[[Map[update]]], 6aba2b86]].