Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

MergeIntoNodeBuilder: java.lang.IllegalArgumentException: transpose #605

Closed
wajda opened this issue Feb 16, 2023 · 0 comments · Fixed by #606
Closed

MergeIntoNodeBuilder: java.lang.IllegalArgumentException: transpose #605

wajda opened this issue Feb 16, 2023 · 0 comments · Fixed by #606
Assignees
Labels
bug Something isn't working dependency: Spark 3.0+
Milestone

Comments

@wajda
Copy link
Contributor

wajda commented Feb 16, 2023

java.lang.IllegalArgumentException: transpose requires all collections have the same size
	at scala.collection.generic.GenericTraversableTemplate.fail$1(GenericTraversableTemplate.scala:215)
	at scala.collection.generic.GenericTraversableTemplate.$anonfun$transpose$3(GenericTraversableTemplate.scala:222)
	at scala.collection.generic.GenericTraversableTemplate.$anonfun$transpose$3$adapted(GenericTraversableTemplate.scala:221)
	at scala.collection.immutable.List.foreach(List.scala:431)
	at scala.collection.generic.GenericTraversableTemplate.$anonfun$transpose$2(GenericTraversableTemplate.scala:221)
	at scala.collection.generic.GenericTraversableTemplate.$anonfun$transpose$2$adapted(GenericTraversableTemplate.scala:219)
	at scala.collection.immutable.List.foreach(List.scala:431)
	at scala.collection.generic.GenericTraversableTemplate.transpose(GenericTraversableTemplate.scala:219)
	at scala.collection.generic.GenericTraversableTemplate.transpose$(GenericTraversableTemplate.scala:211)
	at scala.collection.AbstractTraversable.transpose(Traversable.scala:108)
	at za.co.absa.spline.harvester.builder.plan.MergeIntoNodeBuilder.mergeInputs$lzycompute(MergeIntoNodeBuilder.scala:32)
	at za.co.absa.spline.harvester.builder.plan.MergeIntoNodeBuilder.mergeInputs(MergeIntoNodeBuilder.scala:32)
	at za.co.absa.spline.harvester.builder.plan.MergeIntoNodeBuilder.outputAttributes$lzycompute(MergeIntoNodeBuilder.scala:37)
	at za.co.absa.spline.harvester.builder.plan.MergeIntoNodeBuilder.outputAttributes(MergeIntoNodeBuilder.scala:36)
	at za.co.absa.spline.harvester.builder.plan.MergeIntoNodeBuilder.build(MergeIntoNodeBuilder.scala:61)
	at za.co.absa.spline.harvester.builder.plan.MergeIntoNodeBuilder.build(MergeIntoNodeBuilder.scala:27)
	at za.co.absa.spline.harvester.LineageHarvester.$anonfun$harvest$6(LineageHarvester.scala:72)
	at scala.collection.immutable.List.map(List.scala:297)
	at za.co.absa.spline.harvester.LineageHarvester.$anonfun$harvest$4(LineageHarvester.scala:72)
	at scala.Option.flatMap(Option.scala:271)
	at za.co.absa.spline.harvester.LineageHarvester.harvest(LineageHarvester.scala:65)
	at za.co.absa.spline.agent.SplineAgent$$anon$1.$anonfun$handle$1(SplineAgent.scala:91)
	at za.co.absa.spline.agent.SplineAgent$$anon$1.withErrorHandling(SplineAgent.scala:100)
	at za.co.absa.spline.agent.SplineAgent$$anon$1.handle(SplineAgent.scala:72)
	at za.co.absa.spline.harvester.listener.QueryExecutionListenerDelegate.onSuccess(QueryExecutionListenerDelegate.scala:28)

Originally posted by @wajda in #570 (comment)

@wajda wajda added bug Something isn't working dependency: Spark 3.0+ labels Feb 16, 2023
@wajda wajda self-assigned this Feb 16, 2023
@wajda wajda modified the milestones: 1.1.0, 1.0.5 Feb 16, 2023
wajda added a commit that referenced this issue Feb 17, 2023
wajda added a commit that referenced this issue Feb 28, 2023
wajda added a commit that referenced this issue Feb 28, 2023
…neageHarvester` to `OperationNodeBuilderFactory`, and delegate `MergeIntoCommand` children extraction logic to the `MergeIntoNodeBuilder` respectively.
wajda added a commit that referenced this issue Feb 28, 2023
…orythm to accommodate for renaming and sub-attributes in the MERGE clauses.
wajda added a commit that referenced this issue Mar 3, 2023
… as agreed on PR discussion. Use the type alias in all places where appropriate.
wajda added a commit that referenced this issue Mar 3, 2023
…606)

* spline #605 MergeIntoNodeBuilder: java.lang.IllegalArgumentException: transpose

* spline #605 Addressing PR comment: rename `src` (that is of type Option) to `maybeSrc`

* spline #605 minor code style: remove redundant `override val`

* spline #605 minor Refactoring and code style

* spline #605 Refactoring: move `extractChildren(Node)` method from `LineageHarvester` to `OperationNodeBuilderFactory`, and delegate `MergeIntoCommand` children extraction logic to the `MergeIntoNodeBuilder` respectively.

* spline #605 Reimplement MERGE INTO attribute dependency resolving algorythm to accommodate for renaming and sub-attributes in the MERGE clauses.

* spline #605 Refactoring: Rename type alias Attributes -> IOAttributes as agreed on PR discussion. Use the type alias in all places where appropriate.
@wajda wajda closed this as completed Mar 3, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
bug Something isn't working dependency: Spark 3.0+
Projects
Status: Done
Development

Successfully merging a pull request may close this issue.

1 participant