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

Feat kryo max buffersize #735

Closed

Conversation

koertkuipers
Copy link
Contributor

No description provided.

@AmplabJenkins
Copy link

Can one of the admins verify this patch?

@mateiz
Copy link
Contributor

mateiz commented May 12, 2014

Hey, so is this a new feature that was recently added to Kryo? Seems super useful, but in this case, I'd actually make the max buffer size higher by default. Or we can use the old setting as a max, and create a new setting for the initial buffer size.

@mateiz
Copy link
Contributor

mateiz commented May 12, 2014

Jenkins, this is ok to test

@AmplabJenkins
Copy link

Merged build triggered.

@AmplabJenkins
Copy link

Merged build started.

@AmplabJenkins
Copy link

Merged build finished. All automated tests passed.

@AmplabJenkins
Copy link

All automated tests passed.
Refer to this link for build results: https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/14895/

@koertkuipers
Copy link
Contributor Author

hey matei,
i think they always had this feature in kryo, at least in 2.x.

created jira here:
https://issues.apache.org/jira/browse/SPARK-1811

only reason to be careful with this feature is that there is some overhead on buffer resizing (each time a new array is created with twice the size and the data is copied), which is why i was reluctant to make the old setting as a max.

how about defaults 2MB for initial and 16MB for max?

@AmplabJenkins
Copy link

Merged build triggered.

@AmplabJenkins
Copy link

Merged build started.

@AmplabJenkins
Copy link

Merged build finished. All automated tests passed.

@AmplabJenkins
Copy link

All automated tests passed.
Refer to this link for build results: https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/14960/

@pwendell
Copy link
Contributor

This looks good to me! @koertkuipers mind updating the docs to include this (maybe wait until after #880 is merged tomorrow)? Also, mind prefixing the title here with SPARK-1811, this allows our merge script to detect the JIRA and link it.

@mateiz
Copy link
Contributor

mateiz commented May 29, 2014

Hey one other thought, is there a reason to have the max this low? It might be good to make it even higher to deal with the odd large object (e.g. people working with large text documents). I'd go for 64 MB.

@pwendell
Copy link
Contributor

pwendell commented Jun 4, 2014

@koertkuipers any interest in updating the docs and bumping the default? This would be a good change to have.

@koertkuipers
Copy link
Contributor Author

hey sorry somehow misses this conversation thread. sure will update
defaults and docs

On Wed, Jun 4, 2014 at 1:48 AM, Patrick Wendell notifications@github.com
wrote:

@koertkuipers https://github.com/koertkuipers any interest in updating
the docs and bumping the default? This would be a good change to have.


Reply to this email directly or view it on GitHub
#735 (comment).

@AmplabJenkins
Copy link

Merged build triggered.

@AmplabJenkins
Copy link

Merged build started.

@AmplabJenkins
Copy link

Merged build finished.

@AmplabJenkins
Copy link

Refer to this link for build results: https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/15984/

@koertkuipers
Copy link
Contributor Author

not sure if i am supposed to deal with these failures?

On Sat, Jun 21, 2014 at 1:52 PM, UCB AMPLab notifications@github.com
wrote:

Refer to this link for build results:
https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/15984/


Reply to this email directly or view it on GitHub
#735 (comment).

@pwendell
Copy link
Contributor

pwendell commented Jul 7, 2014

Jenkins, retest this please.

@AmplabJenkins
Copy link

Merged build triggered.

@AmplabJenkins
Copy link

Merged build started.

@AmplabJenkins
Copy link

Merged build finished. All automated tests passed.

@AmplabJenkins
Copy link

All automated tests passed.
Refer to this link for build results: https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/16372/

@mingyukim
Copy link
Contributor

Hi all, is there any update on this PR?

@koertkuipers
Copy link
Contributor Author

i updated docs and defaults as requested. currently waiting for feedback or
a merge

On Wed, Jul 9, 2014 at 6:46 PM, mingyukim notifications@github.com wrote:

Hi all, is there any update on this PR?


Reply to this email directly or view it on GitHub
#735 (comment).

@pwendell
Copy link
Contributor

Jenkins, retest this please. @koertkuipers mind creating a JIRA for this (we're trying to track all changes now). I can merge this in once we have an issue for it.

@SparkQA
Copy link

SparkQA commented Jul 17, 2014

QA tests have started for PR 735. This patch merges cleanly.
View progress: https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/16760/consoleFull

@koertkuipers
Copy link
Contributor Author

https://issues.apache.org/jira/browse/SPARK-2543

On Wed, Jul 16, 2014 at 9:53 PM, Apache Spark QA notifications@github.com
wrote:

QA tests have started for PR 735. This patch merges cleanly.
View progress:
https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/16760/consoleFull


Reply to this email directly or view it on GitHub
#735 (comment).

@SparkQA
Copy link

SparkQA commented Jul 17, 2014

QA results for PR 735:
- This patch PASSES unit tests.
- This patch merges cleanly
- This patch adds no public classes

For more information see test ouptut:
https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/16760/consoleFull

@asfgit asfgit closed this in 7c5fc28 Jul 30, 2014
@mateiz
Copy link
Contributor

mateiz commented Jul 30, 2014

Thanks for the update, Koert!

@pwendell @rxin after this, what do you guys think of lowering the initial buffer size to 1 MB or 512K? We've had some efforts to remove and reuse buffers, but not everything is doing it yet.

xiliu82 pushed a commit to xiliu82/spark that referenced this pull request Sep 4, 2014
Author: Koert Kuipers <koert@tresata.com>

Closes apache#735 from koertkuipers/feat-kryo-max-buffersize and squashes the following commits:

15f6d81 [Koert Kuipers] change default for spark.kryoserializer.buffer.max.mb to 64mb and add some documentation
1bcc22c [Koert Kuipers] Merge branch 'master' into feat-kryo-max-buffersize
0c9f8eb [Koert Kuipers] make default for kryo max buffer size 16MB
143ec4d [Koert Kuipers] test resizable buffer in kryo Output
0732445 [Koert Kuipers] support setting maxCapacity to something different than capacity in kryo Output
RolatZhang pushed a commit to RolatZhang/spark that referenced this pull request Mar 20, 2024
* KE-11534 Upgrade Janino to 3.1.6 for Calcite 1.30

* KE-11534 [Follow up]Fix for null vs true/false comparisons in TDVT SQL626 brought by Calcite 1.30
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
6 participants