Skip to content

Conversation

@SreeramGarlapati
Copy link
Collaborator

  1. StreamingOffset stores file index as long - so changing MicroBatches.startFileIndex from int to long.
  2. renaming MicroBatches.isStarting to MicroBatches.scanAllFiles - as isStarting is when it is used, in terms of the callers state - whereas, scanAllFiles is the actual what MicroBatches.generate should do.

this is part of effort #2611 & is copied from #2272.

@github-actions github-actions bot added the core label May 21, 2021
@rdsr
Copy link
Contributor

rdsr commented May 21, 2021

Generally looks to me, but do we know why we are not checking this in as part of #2272 ?

@SreeramGarlapati
Copy link
Collaborator Author

Generally looks to me, but do we know why we are not checking this in as part of #2272 ?

@rdsr - #2272 is spark2. Its a matter of time @XuQianJin-Stars - resolves the comments and pushes it. I am trying to push spark3 connector - for SalesForce needs & needing this change.

@RussellSpitzer
Copy link
Member

I'm ok with merging this in, but let's try to wrap future patches in more logical and testable chunks.

@SreeramGarlapati
Copy link
Collaborator Author

SreeramGarlapati commented May 21, 2021

I'm ok with merging this in, but let's try to wrap future patches in more logical and testable chunks.

ack. - will keep this in mind @RussellSpitzer.

@RussellSpitzer RussellSpitzer merged commit e8b3d1e into apache:master May 24, 2021
@RussellSpitzer
Copy link
Member

Thanks @SreeramGarlapati for making progress here, but like I mentioned please try to make changes a bit more grouped in the future and testable :)

@SreeramGarlapati SreeramGarlapati deleted the refactor.microbatches branch May 24, 2021 20:53
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants