[jira] [Commented] (FLINK-3586) Risk of data overflow while use sum/count to calculate AVG value

[ https://issues.apache.org/jira/browse/FLINK-3586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15295804#comment-15295804 ] Chengxiang Li commented on FLINK-3586: -- Not at all, feel free to take over it, Fabian. > Risk of

[jira] [Assigned] (FLINK-3586) Risk of data overflow while use sum/count to calculate AVG value

[ https://issues.apache.org/jira/browse/FLINK-3586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li reassigned FLINK-3586: Assignee: Chengxiang Li > Risk of data overflow while use sum/count to calculate AVG value

[jira] [Assigned] (FLINK-3475) DISTINCT aggregate function support

[ https://issues.apache.org/jira/browse/FLINK-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li reassigned FLINK-3475: Assignee: Chengxiang Li > DISTINCT aggregate function support >

[jira] [Created] (FLINK-3586) Risk of data overflow while use sum/count to calculate AVG value

Chengxiang Li created FLINK-3586: Summary: Risk of data overflow while use sum/count to calculate AVG value Key: FLINK-3586 URL: https://issues.apache.org/jira/browse/FLINK-3586 Project: Flink

[jira] [Updated] (FLINK-3473) Add partial aggregate support in Flink

[ https://issues.apache.org/jira/browse/FLINK-3473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li updated FLINK-3473: - Attachment: PartialAggregateinFlink_v2.pdf > Add partial aggregate support in Flink >

[jira] [Commented] (FLINK-3508) Add more test cases to verify the rules of logical plan optimization

[ https://issues.apache.org/jira/browse/FLINK-3508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167301#comment-15167301 ] Chengxiang Li commented on FLINK-3508: -- Merged to tableOnCalcite branch at

[jira] [Closed] (FLINK-3508) Add more test cases to verify the rules of logical plan optimization

[ https://issues.apache.org/jira/browse/FLINK-3508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li closed FLINK-3508. > Add more test cases to verify the rules of logical plan optimization >

[jira] [Resolved] (FLINK-3508) Add more test cases to verify the rules of logical plan optimization

[ https://issues.apache.org/jira/browse/FLINK-3508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li resolved FLINK-3508. -- Resolution: Fixed > Add more test cases to verify the rules of logical plan optimization >

[jira] [Created] (FLINK-3508) Add more test cases to verify the rules of logical plan optimization

Chengxiang Li created FLINK-3508: Summary: Add more test cases to verify the rules of logical plan optimization Key: FLINK-3508 URL: https://issues.apache.org/jira/browse/FLINK-3508 Project: Flink

[jira] [Created] (FLINK-3507) PruneEmptyRules does not prune empty node as expected.

Chengxiang Li created FLINK-3507: Summary: PruneEmptyRules does not prune empty node as expected. Key: FLINK-3507 URL: https://issues.apache.org/jira/browse/FLINK-3507 Project: Flink Issue

[jira] [Created] (FLINK-3506) ReduceExpressionsRule does not remove duplicate expression in Filter

Chengxiang Li created FLINK-3506: Summary: ReduceExpressionsRule does not remove duplicate expression in Filter Key: FLINK-3506 URL: https://issues.apache.org/jira/browse/FLINK-3506 Project: Flink

[jira] [Updated] (FLINK-3486) Use Project to rename all record fields would fail following Project.

[ https://issues.apache.org/jira/browse/FLINK-3486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li updated FLINK-3486: - Summary: Use Project to rename all record fields would fail following Project. (was: [SQL] Use

[jira] [Updated] (FLINK-3502) AggregateProjectPullUpConstantsRule fails on certain group keys order.

[ https://issues.apache.org/jira/browse/FLINK-3502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li updated FLINK-3502: - Summary: AggregateProjectPullUpConstantsRule fails on certain group keys order. (was: [SQL]

[jira] [Updated] (FLINK-3486) [SQL] Use Project to rename all record fields would fail following Project.

[ https://issues.apache.org/jira/browse/FLINK-3486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li updated FLINK-3486: - Component/s: Table API > [SQL] Use Project to rename all record fields would fail following

[jira] [Updated] (FLINK-3487) [SQL] FilterAggregateTransposeRule does not transform logical plan as desired.

[ https://issues.apache.org/jira/browse/FLINK-3487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li updated FLINK-3487: - Component/s: Table API > [SQL] FilterAggregateTransposeRule does not transform logical plan as

[jira] [Updated] (FLINK-3503) ProjectJoinTransposeRule fails to push down project.

[ https://issues.apache.org/jira/browse/FLINK-3503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li updated FLINK-3503: - Summary: ProjectJoinTransposeRule fails to push down project. (was: [SQL]

[jira] [Updated] (FLINK-3487) FilterAggregateTransposeRule does not transform logical plan as desired.

[ https://issues.apache.org/jira/browse/FLINK-3487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li updated FLINK-3487: - Summary: FilterAggregateTransposeRule does not transform logical plan as desired. (was: [SQL]

[jira] [Created] (FLINK-3505) JoinUnionTransposeRule fails to push Join past Union.

Chengxiang Li created FLINK-3505: Summary: JoinUnionTransposeRule fails to push Join past Union. Key: FLINK-3505 URL: https://issues.apache.org/jira/browse/FLINK-3505 Project: Flink Issue

[jira] [Updated] (FLINK-3503) [SQL] ProjectJoinTransposeRule fails to push down project.

[ https://issues.apache.org/jira/browse/FLINK-3503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li updated FLINK-3503: - Component/s: Table API > [SQL] ProjectJoinTransposeRule fails to push down project. >

[jira] [Updated] (FLINK-3504) Join fails while have expression inside join condition.

[ https://issues.apache.org/jira/browse/FLINK-3504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li updated FLINK-3504: - Summary: Join fails while have expression inside join condition. (was: [SQL] Join fails while

[jira] [Created] (FLINK-3504) [SQL] Join fails while have expression inside join condition.

Chengxiang Li created FLINK-3504: Summary: [SQL] Join fails while have expression inside join condition. Key: FLINK-3504 URL: https://issues.apache.org/jira/browse/FLINK-3504 Project: Flink

[jira] [Updated] (FLINK-3487) [SQL] FilterAggregateTransposeRule does not transform logical plan as desired.

[ https://issues.apache.org/jira/browse/FLINK-3487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li updated FLINK-3487: - Issue Type: Improvement (was: Bug) > [SQL] FilterAggregateTransposeRule does not transform

[jira] [Created] (FLINK-3503) [SQL] ProjectJoinTransposeRule fails to push down project.

Chengxiang Li created FLINK-3503: Summary: [SQL] ProjectJoinTransposeRule fails to push down project. Key: FLINK-3503 URL: https://issues.apache.org/jira/browse/FLINK-3503 Project: Flink

[jira] [Created] (FLINK-3502) [SQL] AggregateProjectPullUpConstantsRule fails on certain group keys order.

Chengxiang Li created FLINK-3502: Summary: [SQL] AggregateProjectPullUpConstantsRule fails on certain group keys order. Key: FLINK-3502 URL: https://issues.apache.org/jira/browse/FLINK-3502 Project:

[jira] [Created] (FLINK-3487) [SQL] FilterAggregateTransposeRule does not transform logical plan as desired.

Chengxiang Li created FLINK-3487: Summary: [SQL] FilterAggregateTransposeRule does not transform logical plan as desired. Key: FLINK-3487 URL: https://issues.apache.org/jira/browse/FLINK-3487

[jira] [Created] (FLINK-3486) [SQL] Use Project to rename all record fields would fail following Project.

Chengxiang Li created FLINK-3486: Summary: [SQL] Use Project to rename all record fields would fail following Project. Key: FLINK-3486 URL: https://issues.apache.org/jira/browse/FLINK-3486 Project:

[jira] [Created] (FLINK-3476) Support hash-based partial aggregate

Chengxiang Li created FLINK-3476: Summary: Support hash-based partial aggregate Key: FLINK-3476 URL: https://issues.apache.org/jira/browse/FLINK-3476 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-3473) Add partial aggregate support in Flink

[ https://issues.apache.org/jira/browse/FLINK-3473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li updated FLINK-3473: - Attachment: PartialAggregateinFlink_v1.pdf > Add partial aggregate support in Flink >

[jira] [Updated] (FLINK-3474) Partial aggregate interface design and sort-based implementation

[ https://issues.apache.org/jira/browse/FLINK-3474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li updated FLINK-3474: - Attachment: (was: PartialAggregateinFlink_v1.pdf) > Partial aggregate interface design and

[jira] [Updated] (FLINK-3474) Partial aggregate interface design and sort-based implementation

[ https://issues.apache.org/jira/browse/FLINK-3474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li updated FLINK-3474: - Attachment: PartialAggregateinFlink_v1.pdf > Partial aggregate interface design and sort-based

[jira] [Created] (FLINK-3475) DISTINCT aggregate function support

Chengxiang Li created FLINK-3475: Summary: DISTINCT aggregate function support Key: FLINK-3475 URL: https://issues.apache.org/jira/browse/FLINK-3475 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-3473) Add partial aggregate support in Flink

Chengxiang Li created FLINK-3473: Summary: Add partial aggregate support in Flink Key: FLINK-3473 URL: https://issues.apache.org/jira/browse/FLINK-3473 Project: Flink Issue Type: Improvement

[jira] [Resolved] (FLINK-3281) IndexOutOfBoundsException when range-partitioning empty DataSet

[ https://issues.apache.org/jira/browse/FLINK-3281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li resolved FLINK-3281. -- Resolution: Fixed Fix Version/s: 1.0.0 > IndexOutOfBoundsException when

[jira] [Commented] (FLINK-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs

[ https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15119050#comment-15119050 ] Chengxiang Li commented on FLINK-3226: -- [~fhueske] and [~twalthr] , this task should be blocked by me

[jira] [Resolved] (FLINK-3282) Add FlinkRelNode interface.

[ https://issues.apache.org/jira/browse/FLINK-3282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li resolved FLINK-3282. -- Resolution: Fixed > Add FlinkRelNode interface. > --- > >

[jira] [Closed] (FLINK-3282) Add FlinkRelNode interface.

[ https://issues.apache.org/jira/browse/FLINK-3282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li closed FLINK-3282. > Add FlinkRelNode interface. > --- > > Key: FLINK-3282 >

[jira] [Resolved] (FLINK-2871) Add OuterJoin strategy with HashTable on outer side

[ https://issues.apache.org/jira/browse/FLINK-2871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li resolved FLINK-2871. -- Resolution: Fixed Fix Version/s: 1.0.0 > Add OuterJoin strategy with HashTable on outer

[jira] [Created] (FLINK-3282) Add FlinkRelNode interface.

Chengxiang Li created FLINK-3282: Summary: Add FlinkRelNode interface. Key: FLINK-3282 URL: https://issues.apache.org/jira/browse/FLINK-3282 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs

[ https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115034#comment-15115034 ] Chengxiang Li commented on FLINK-3226: -- Yes, that make senes, i have create a

[jira] [Commented] (FLINK-3281) IndexOutOfBoundsException when range-partitioning empty DataSet

[ https://issues.apache.org/jira/browse/FLINK-3281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15114659#comment-15114659 ] Chengxiang Li commented on FLINK-3281: -- [~fsander], thanks for finding this, i would work on it. >

[jira] [Commented] (FLINK-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs

[ https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15106292#comment-15106292 ] Chengxiang Li commented on FLINK-3226: -- I list the mapping relationship of Calcite RelNodes, Flink

[jira] [Commented] (FLINK-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs

[ https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15095914#comment-15095914 ] Chengxiang Li commented on FLINK-3226: -- Cool, [~fhueske]. Before actual work, I would upload a

[jira] [Commented] (FLINK-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs

[ https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15095470#comment-15095470 ] Chengxiang Li commented on FLINK-3226: -- [~fhueske], i would like to contribute on this task. >

[jira] [Commented] (FLINK-2871) Add OuterJoin strategy with HashTable on outer side

[ https://issues.apache.org/jira/browse/FLINK-2871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15061322#comment-15061322 ] Chengxiang Li commented on FLINK-2871: -- I would like to contribute on this. There are 4 reserved

[jira] [Assigned] (FLINK-2871) Add OuterJoin strategy with HashTable on outer side

[ https://issues.apache.org/jira/browse/FLINK-2871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li reassigned FLINK-2871: Assignee: Chengxiang Li > Add OuterJoin strategy with HashTable on outer side >

[jira] [Created] (FLINK-3139) NULL values handling in Table API

Chengxiang Li created FLINK-3139: Summary: NULL values handling in Table API Key: FLINK-3139 URL: https://issues.apache.org/jira/browse/FLINK-3139 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-3141) Design of NULL values handling in operation

Chengxiang Li created FLINK-3141: Summary: Design of NULL values handling in operation Key: FLINK-3141 URL: https://issues.apache.org/jira/browse/FLINK-3141 Project: Flink Issue Type:

[jira] [Created] (FLINK-3140) NULL value data layout in Row Serializer/Comparator

Chengxiang Li created FLINK-3140: Summary: NULL value data layout in Row Serializer/Comparator Key: FLINK-3140 URL: https://issues.apache.org/jira/browse/FLINK-3140 Project: Flink Issue

[jira] [Resolved] (FLINK-3087) Table API do not support multi count in aggregation.

[ https://issues.apache.org/jira/browse/FLINK-3087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li resolved FLINK-3087. -- Resolution: Fixed Fix Version/s: 1.0.0 > Table API do not support multi count in

[jira] [Created] (FLINK-3098) Cast from Date to Long throw compile error.

Chengxiang Li created FLINK-3098: Summary: Cast from Date to Long throw compile error. Key: FLINK-3098 URL: https://issues.apache.org/jira/browse/FLINK-3098 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3087) Table API do not support multi count in aggregation.

Chengxiang Li created FLINK-3087: Summary: Table API do not support multi count in aggregation. Key: FLINK-3087 URL: https://issues.apache.org/jira/browse/FLINK-3087 Project: Flink Issue

[jira] [Assigned] (FLINK-2115) TableAPI throws ExpressionException for "Dangling GroupBy operation"

[ https://issues.apache.org/jira/browse/FLINK-2115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li reassigned FLINK-2115: Assignee: Chengxiang Li > TableAPI throws ExpressionException for "Dangling GroupBy

[jira] [Commented] (FLINK-2980) Add CUBE/ROLLUP/GROUPING SETS operator in Table API.

[ https://issues.apache.org/jira/browse/FLINK-2980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15010576#comment-15010576 ] Chengxiang Li commented on FLINK-2980: -- This depends on the support of null value in Table API, which

[jira] [Assigned] (FLINK-2980) Add CUBE/ROLLUP/GROUPING SETS operator in Table API.

[ https://issues.apache.org/jira/browse/FLINK-2980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li reassigned FLINK-2980: Assignee: Chengxiang Li > Add CUBE/ROLLUP/GROUPING SETS operator in Table API. >

[jira] [Created] (FLINK-2998) Support range partition comparison for multi input nodes.

Chengxiang Li created FLINK-2998: Summary: Support range partition comparison for multi input nodes. Key: FLINK-2998 URL: https://issues.apache.org/jira/browse/FLINK-2998 Project: Flink

[jira] [Created] (FLINK-2997) Support range partition with user customized data distribution.

Chengxiang Li created FLINK-2997: Summary: Support range partition with user customized data distribution. Key: FLINK-2997 URL: https://issues.apache.org/jira/browse/FLINK-2997 Project: Flink

[jira] [Assigned] (FLINK-2955) Add operations introduction in Table API page.

[ https://issues.apache.org/jira/browse/FLINK-2955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li reassigned FLINK-2955: Assignee: Chengxiang Li > Add operations introduction in Table API page. >

[jira] [Updated] (FLINK-2980) Add CUBE/ROLLUP/GROUPING SETS operator in Table API.

[ https://issues.apache.org/jira/browse/FLINK-2980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li updated FLINK-2980: - Attachment: Cube-Rollup-GroupSet design doc in Flink.pdf > Add CUBE/ROLLUP/GROUPING SETS operator

[jira] [Created] (FLINK-2980) Add CUBE/ROLLUP/GROUPING SETS operator in Table API.

Chengxiang Li created FLINK-2980: Summary: Add CUBE/ROLLUP/GROUPING SETS operator in Table API. Key: FLINK-2980 URL: https://issues.apache.org/jira/browse/FLINK-2980 Project: Flink Issue

[jira] [Created] (FLINK-2956) Migrate integration tests for Table API

Chengxiang Li created FLINK-2956: Summary: Migrate integration tests for Table API Key: FLINK-2956 URL: https://issues.apache.org/jira/browse/FLINK-2956 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-2951) Add Union operator to Table API.

Chengxiang Li created FLINK-2951: Summary: Add Union operator to Table API. Key: FLINK-2951 URL: https://issues.apache.org/jira/browse/FLINK-2951 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-2848) Refactor Flink benchmarks with JMH and move to flink-benchmark module

Chengxiang Li created FLINK-2848: Summary: Refactor Flink benchmarks with JMH and move to flink-benchmark module Key: FLINK-2848 URL: https://issues.apache.org/jira/browse/FLINK-2848 Project: Flink

[jira] [Commented] (FLINK-7) [GitHub] Enable Range Partitioner

[ https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14933125#comment-14933125 ] Chengxiang Li commented on FLINK-7: --- The sample operator has been enabled at

[jira] [Created] (FLINK-2745) Create a new module for all Flink micro benchmark.

Chengxiang Li created FLINK-2745: Summary: Create a new module for all Flink micro benchmark. Key: FLINK-2745 URL: https://issues.apache.org/jira/browse/FLINK-2745 Project: Flink Issue Type:

[jira] [Created] (FLINK-2743) Add new RNG based on XORShift algorithm

Chengxiang Li created FLINK-2743: Summary: Add new RNG based on XORShift algorithm Key: FLINK-2743 URL: https://issues.apache.org/jira/browse/FLINK-2743 Project: Flink Issue Type:

[jira] [Created] (FLINK-2754) FixedLengthRecordSorter can not write to output cross MemorySegments.

Chengxiang Li created FLINK-2754: Summary: FixedLengthRecordSorter can not write to output cross MemorySegments. Key: FLINK-2754 URL: https://issues.apache.org/jira/browse/FLINK-2754 Project: Flink

[jira] [Updated] (FLINK-2533) Gap based random sample optimization

[ https://issues.apache.org/jira/browse/FLINK-2533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li updated FLINK-2533: - Assignee: GaoLun > Gap based random sample optimization > >

[jira] [Closed] (FLINK-2535) Fixed size sample algorithm optimization

[ https://issues.apache.org/jira/browse/FLINK-2535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li closed FLINK-2535. Resolution: Won't Fix > Fixed size sample algorithm optimization >

[jira] [Commented] (FLINK-2535) Fixed size sample algorithm optimization

[ https://issues.apache.org/jira/browse/FLINK-2535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14732155#comment-14732155 ] Chengxiang Li commented on FLINK-2535: -- Thanks for your research, [~gallenvara_bg], since there is no

[jira] [Assigned] (FLINK-2596) Failing Test: RandomSamplerTest

[ https://issues.apache.org/jira/browse/FLINK-2596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li reassigned FLINK-2596: Assignee: Chengxiang Li > Failing Test: RandomSamplerTest >

[jira] [Commented] (FLINK-2545) NegativeArraySizeException while creating hash table bloom filters

[ https://issues.apache.org/jira/browse/FLINK-2545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716152#comment-14716152 ] Chengxiang Li commented on FLINK-2545: -- Hi, [~greghogan], do you mind to share how to

[jira] [Assigned] (FLINK-2545) NegativeArraySizeException while creating hash table bloom filters

[ https://issues.apache.org/jira/browse/FLINK-2545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li reassigned FLINK-2545: Assignee: Chengxiang Li NegativeArraySizeException while creating hash table bloom

[jira] [Assigned] (FLINK-2564) Failing Test: RandomSamplerTest

[ https://issues.apache.org/jira/browse/FLINK-2564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li reassigned FLINK-2564: Assignee: Chengxiang Li Failing Test: RandomSamplerTest ---

[jira] [Commented] (FLINK-2564) Failing Test: RandomSamplerTest

[ https://issues.apache.org/jira/browse/FLINK-2564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14709020#comment-14709020 ] Chengxiang Li commented on FLINK-2564: -- As discussed in

[jira] [Created] (FLINK-2549) Add topK operator for DataSet

Chengxiang Li created FLINK-2549: Summary: Add topK operator for DataSet Key: FLINK-2549 URL: https://issues.apache.org/jira/browse/FLINK-2549 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-2549) Add topK operator for DataSet

[ https://issues.apache.org/jira/browse/FLINK-2549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704244#comment-14704244 ] Chengxiang Li commented on FLINK-2549: -- The basic idea of implementation is as

[jira] [Created] (FLINK-2533) Gap based random sample optimization

Chengxiang Li created FLINK-2533: Summary: Gap based random sample optimization Key: FLINK-2533 URL: https://issues.apache.org/jira/browse/FLINK-2533 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2535) Fixed size sample algorithm optimization

Chengxiang Li created FLINK-2535: Summary: Fixed size sample algorithm optimization Key: FLINK-2535 URL: https://issues.apache.org/jira/browse/FLINK-2535 Project: Flink Issue Type:

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14638272#comment-14638272 ] Chengxiang Li commented on FLINK-1901: -- Thanks,[~till.rohrmann], i got it now. This

[jira] [Created] (FLINK-2396) Review the datasets of dynamic path and static path in iteration.

Chengxiang Li created FLINK-2396: Summary: Review the datasets of dynamic path and static path in iteration. Key: FLINK-2396 URL: https://issues.apache.org/jira/browse/FLINK-2396 Project: Flink

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14638617#comment-14638617 ] Chengxiang Li commented on FLINK-1901: -- Thanks for the analysis,

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636124#comment-14636124 ] Chengxiang Li commented on FLINK-1901: -- every point is sampled with probability 1/N

[jira] [Comment Edited] (FLINK-1901) Create sample operator for Dataset

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634622#comment-14634622 ] Chengxiang Li edited comment on FLINK-1901 at 7/22/15 2:05 AM:

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14636332#comment-14636332 ] Chengxiang Li commented on FLINK-1901: -- I write a simple example of sampling operator

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634622#comment-14634622 ] Chengxiang Li commented on FLINK-1901: -- To randomly choose a sample from a DataSet S,

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634822#comment-14634822 ] Chengxiang Li commented on FLINK-1901: -- Hi, [~sachingoel0101], I didn't find any

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634628#comment-14634628 ] Chengxiang Li commented on FLINK-1901: -- Hi, [~tvas], i would like to contribute on

[jira] [Created] (FLINK-2241) Use BloomFilter to minmize build side records which spilled to disk in Hybrid-Hash-Join

Chengxiang Li created FLINK-2241: Summary: Use BloomFilter to minmize build side records which spilled to disk in Hybrid-Hash-Join Key: FLINK-2241 URL: https://issues.apache.org/jira/browse/FLINK-2241

[jira] [Updated] (FLINK-2240) Use BloomFilter to minimize probe side records which are spilled to disk in Hybrid-Hash-Join

[ https://issues.apache.org/jira/browse/FLINK-2240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li updated FLINK-2240: - Summary: Use BloomFilter to minimize probe side records which are spilled to disk in

[jira] [Commented] (FLINK-2241) Use BloomFilter to minmize probe side records which are spilled to disk in Hybrid-Hash-Join

[ https://issues.apache.org/jira/browse/FLINK-2241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14591552#comment-14591552 ] Chengxiang Li commented on FLINK-2241: -- Oh, thanks, [~till.rohrmann], i should double

[jira] [Created] (FLINK-2240) Use BloomFilter to minmize build side records which spilled to disk in Hybrid-Hash-Join

Chengxiang Li created FLINK-2240: Summary: Use BloomFilter to minmize build side records which spilled to disk in Hybrid-Hash-Join Key: FLINK-2240 URL: https://issues.apache.org/jira/browse/FLINK-2240

[jira] [Updated] (FLINK-2241) Use BloomFilter to minmize probe side records which are spilled to disk in Hybrid-Hash-Join

[ https://issues.apache.org/jira/browse/FLINK-2241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengxiang Li updated FLINK-2241: - Summary: Use BloomFilter to minmize probe side records which are spilled to disk in