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

[BEAM-7195] BQ BatchLoads doesn't always create new tables #14238

Merged
merged 3 commits into from
Jul 27, 2021

Conversation

reuvenlax
Copy link
Contributor

Please add a meaningful description for your change here


Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily:

  • Choose reviewer(s) and mention them in a comment (R: @username).
  • Format the pull request title like [BEAM-XXX] Fixes bug in ApproximateQuantiles, where you replace BEAM-XXX with the appropriate JIRA issue, if applicable. This will automatically link the pull request to the issue.
  • Update CHANGES.md with noteworthy changes.
  • If this contribution is large, please file an Apache Individual Contributor License Agreement.

See the Contributor Guide for more tips on how to make review process smoother.

Post-Commit Tests Status (on master branch)

Lang SDK Dataflow Flink Samza Spark Twister2
Go Build Status --- Build Status --- Build Status ---
Java Build Status Build Status
Build Status
Build Status
Build Status
Build Status
Build Status
Build Status
Build Status Build Status
Build Status
Build Status
Build Status
Python Build Status
Build Status
Build Status
Build Status
Build Status
Build Status
Build Status
Build Status
--- Build Status ---
XLang Build Status Build Status Build Status --- Build Status ---

Pre-Commit Tests Status (on master branch)

--- Java Python Go Website Whitespace Typescript
Non-portable Build Status Build Status
Build Status
Build Status
Build Status
Build Status Build Status Build Status Build Status
Portable --- Build Status --- --- --- ---

See .test-infra/jenkins/README for trigger phrase, status and link of all Jenkins jobs.

GitHub Actions Tests Status (on master branch)

Build python source distribution and wheels
Python tests
Java tests

See CI.md for more information about GitHub Actions CI.

@reuvenlax reuvenlax changed the title fix BigQuery FILE_LOADS triggering. [BEAM-7195] BQ BatchLoads doesn't always create new tables Mar 16, 2021
@reuvenlax
Copy link
Contributor Author

I tried to fix these issues in pr/14238

@aaltay
Copy link
Member

aaltay commented Mar 25, 2021

@chamikaramj - Could you review this PR?

@chamikaramj
Copy link
Contributor

Yeah, looking.

Copy link
Contributor

@chamikaramj chamikaramj left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks. Seems like there's a conflict now.

abstract Boolean isFirstPane();
}

static class ResultCoder extends AtomicCoder<WriteTables.Result> {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Did you mean to redefine Result and ResultCoder classes here ? They are Already defined in the WritePartition class and definitions seems to be identical. Can we move these to new files and re-use ?

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

they are a bit different - the one in WritePartition contains a list of filenames, while this one contains a singular filename.

@@ -65,19 +65,24 @@
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import java.util.stream.Collectors;
import java.util.stream.StreamSupport;
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Is it possible to add a new unit test that would break for the previous implementation (due to pane numbers being incorrect) but would pass for the new implementation ?

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

possibly - trying to think how to best make that trigger.

@chamikaramj
Copy link
Contributor

Java PreCommit failure is probably related: https://ci-beam.apache.org/job/beam_PreCommit_Java_Commit/16793/

@tysonjh
Copy link
Contributor

tysonjh commented Jul 12, 2021

Any plans to move forward with this? Could it be causing our nightly snapshot failures as well? I added some info to BEAM-7195.

@tysonjh
Copy link
Contributor

tysonjh commented Jul 22, 2021

Checking in on the status here, is this ready to merge?

@aaltay
Copy link
Member

aaltay commented Jul 22, 2021

Checking in on the status here, is this ready to merge?

I do not think so. I fixed the merge conflict but there are bunch of tests errors and they are probably relevant (related to: testWriteTable - https://ci-beam.apache.org/job/beam_PreCommit_Java_Commit/18382/)

@reuvenlax
Copy link
Contributor Author

reuvenlax commented Jul 26, 2021 via email

@reuvenlax
Copy link
Contributor Author

rebased and fixed broken test

@aaltay
Copy link
Member

aaltay commented Jul 26, 2021

There is a check style error: INSTANCE' must match pattern '^[a-z][a-zA-Z0-9]*_?$'. [StaticVariableName]

@reuvenlax
Copy link
Contributor Author

CheckStyle fixed

@aaltay
Copy link
Member

aaltay commented Jul 27, 2021

Is it ready now? It is passing tests.

@reuvenlax
Copy link
Contributor Author

I believe.so

@aaltay
Copy link
Member

aaltay commented Jul 27, 2021

LGTM. I will merge.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

4 participants