Ismaël Mejía created BEAM-4016: ---------------------------------- Summary: Direct runner incorrect lifecycle, @SplitRestriction should execute after @Setup on SplittableDoFn Key: BEAM-4016 URL: https://issues.apache.org/jira/browse/BEAM-4016 Project: Beam Issue Type: Bug Components: runner-direct Affects Versions: 2.4.0 Reporter: Ismaël Mejía Assignee: Thomas Groh
SplitRestriction is the method where we can split in advance a SDF. It makes sense to execute this after the @Setup method given that usually connections are established at Setup and can be used to ask the different data stores about the partitioning strategy. I added a test for this in the SplittableDoFnTest.SDFWithLifecycle test. -- This message was sent by Atlassian JIRA (v7.6.3#76005)