[jira] [Commented] (FLINK-5413) Convert TableEnvironmentITCases to unit tests

2017-01-14 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15822775#comment-15822775 ] GaoLun commented on FLINK-5413: --- Hi Timo, is it proper just validating the correctness of the table schema

[jira] [Assigned] (FLINK-5413) Convert TableEnvironmentITCases to unit tests

2017-01-13 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] GaoLun reassigned FLINK-5413: - Assignee: GaoLun > Convert TableEnvironmentITCases to unit tests >

[jira] [Commented] (FLINK-5434) Remove unsupported project() transformation from Scala DataStream docs

2017-01-13 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15822045#comment-15822045 ] GaoLun commented on FLINK-5434: --- Just remove from the doc as the following pr. Should we create another jira

[jira] [Commented] (FLINK-4242) Improve validation exception messages

2016-07-23 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15390749#comment-15390749 ] GaoLun commented on FLINK-4242: --- Yes, currently some messages of table exception aren't readable and clear

[jira] [Assigned] (FLINK-3940) Add support for ORDER BY OFFSET FETCH

2016-07-22 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] GaoLun reassigned FLINK-3940: - Assignee: GaoLun > Add support for ORDER BY OFFSET FETCH > - > >

[jira] [Commented] (FLINK-3940) Add support for ORDER BY OFFSET FETCH

2016-07-21 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15388752#comment-15388752 ] GaoLun commented on FLINK-3940: --- Hello, i would like to work on this issue. :) > Add support for ORDER BY

[jira] [Comment Edited] (FLINK-2985) Allow different field names for unionAll() in Table API

2016-06-06 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15317673#comment-15317673 ] GaoLun edited comment on FLINK-2985 at 6/7/16 2:12 AM: --- The refactoring work has

[jira] [Commented] (FLINK-2985) Allow different field names for unionAll() in Table API

2016-06-06 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15317673#comment-15317673 ] GaoLun commented on FLINK-2985: --- The refactoring work has been finished and i will go on with this issue. :)

[jira] [Commented] (FLINK-3971) Aggregates handle null values incorrectly.

2016-05-26 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15301660#comment-15301660 ] GaoLun commented on FLINK-3971: --- [~fhueske] If no one work on this issue, i would have a try. > Aggregates

[jira] [Commented] (FLINK-3879) Native implementation of HITS algorithm

2016-05-09 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15277514#comment-15277514 ] GaoLun commented on FLINK-3879: --- Scatter-gather model divides original iteration into two parts. For

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

2016-05-09 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15276262#comment-15276262 ] GaoLun commented on FLINK-2184: --- I will go on with this issue. :) > Cannot get last element with

[jira] [Commented] (FLINK-3879) Native implementation of HITS algorithm

2016-05-07 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15275265#comment-15275265 ] GaoLun commented on FLINK-3879: --- yes, make sense. > Native implementation of HITS algorithm >

[jira] [Commented] (FLINK-3879) Native implementation of HITS algorithm

2016-05-07 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15275242#comment-15275242 ] GaoLun commented on FLINK-3879: --- Hub values are same but authority values have a little difference. >

[jira] [Commented] (FLINK-3879) Native implementation of HITS algorithm

2016-05-07 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15275240#comment-15275240 ] GaoLun commented on FLINK-3879: --- My: (1,0.847998304005088,0.0), (2,0.5299989400031799,0.5144957554275266),

[jira] [Commented] (FLINK-3879) Native implementation of HITS algorithm

2016-05-07 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15275160#comment-15275160 ] GaoLun commented on FLINK-3879: --- Hi [~greghogan], the PR of FLINK-2044 has been updated and support

[jira] [Commented] (FLINK-2044) Implementation of Gelly HITS Algorithm

2016-05-01 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15265783#comment-15265783 ] GaoLun commented on FLINK-2044: --- I will go on with this issue. :) > Implementation of Gelly HITS Algorithm

[jira] [Commented] (FLINK-2220) Join on Pojo without hashCode() silently fails

2016-04-26 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15259367#comment-15259367 ] GaoLun commented on FLINK-2220: --- I wrote test for generictype and the problem still arose. The small fix PR

[jira] [Created] (FLINK-3783) Support weighted random sampling with reservoir

2016-04-19 Thread GaoLun (JIRA)
GaoLun created FLINK-3783: - Summary: Support weighted random sampling with reservoir Key: FLINK-3783 URL: https://issues.apache.org/jira/browse/FLINK-3783 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-3729) Several SQL tests fail on Windows OS

2016-04-12 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15237523#comment-15237523 ] GaoLun commented on FLINK-3729: --- The problem is the {{ast}} would use \r\n in Windows environment. The

[jira] [Updated] (FLINK-3192) Add explain support to print ast and sql physical execution plan.

2015-12-25 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] GaoLun updated FLINK-3192: -- Summary: Add explain support to print ast and sql physical execution plan. (was: Add explain support to print

[jira] [Created] (FLINK-3192) Add explain support to print ast and sql physical execution.

2015-12-25 Thread GaoLun (JIRA)
GaoLun created FLINK-3192: - Summary: Add explain support to print ast and sql physical execution. Key: FLINK-3192 URL: https://issues.apache.org/jira/browse/FLINK-3192 Project: Flink Issue Type:

[jira] [Updated] (FLINK-3192) Add explain support to print ast and sql physical execution plan.

2015-12-25 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] GaoLun updated FLINK-3192: -- Description: Table API doesn't support sql-explanation now. Add the explain support to print ast (abstract

[jira] [Comment Edited] (FLINK-2988) Cannot load DataSet[Row] from CSV file

2015-11-24 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15023998#comment-15023998 ] GaoLun edited comment on FLINK-2988 at 11/25/15 1:45 AM: - Hi, [~jkovacs] . Is this

[jira] [Commented] (FLINK-2988) Cannot load DataSet[Row] from CSV file

2015-11-24 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15023998#comment-15023998 ] GaoLun commented on FLINK-2988: --- Hi, [~jkovacs] . Is this problem solved? IMO, *readCsvFile* can only

[jira] [Closed] (FLINK-2884) Apply JMH on HashVsSortMiniBenchmark class.

2015-10-29 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] GaoLun closed FLINK-2884. - Resolution: Later > Apply JMH on HashVsSortMiniBenchmark class. > --- > >

[jira] [Commented] (FLINK-2884) Apply JMH on HashVsSortMiniBenchmark class.

2015-10-29 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14980348#comment-14980348 ] GaoLun commented on FLINK-2884: --- This class has some unknown faults when to run. It will be better to do

[jira] [Commented] (FLINK-2892) Apply JMH on MemorySegmentSpeedBenchmark class.

2015-10-27 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14977598#comment-14977598 ] GaoLun commented on FLINK-2892: --- IMO, if I modify this class with JMH, the result will be much more complex.

[jira] [Closed] (FLINK-2892) Apply JMH on MemorySegmentSpeedBenchmark class.

2015-10-27 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] GaoLun closed FLINK-2892. - Resolution: Not A Problem To keep the original benchmark method in MemorySegmentSpeedBenchmark class is a good

[jira] [Created] (FLINK-2920) Apply JMH on KryoVersusAvroMinibenchmark class.

2015-10-26 Thread GaoLun (JIRA)
GaoLun created FLINK-2920: - Summary: Apply JMH on KryoVersusAvroMinibenchmark class. Key: FLINK-2920 URL: https://issues.apache.org/jira/browse/FLINK-2920 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-2919) Apply JMH on FieldAccessMinibenchmark class.

2015-10-25 Thread GaoLun (JIRA)
GaoLun created FLINK-2919: - Summary: Apply JMH on FieldAccessMinibenchmark class. Key: FLINK-2919 URL: https://issues.apache.org/jira/browse/FLINK-2919 Project: Flink Issue Type: Sub-task

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

2015-10-22 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14968753#comment-14968753 ] GaoLun commented on FLINK-2848: --- Hi,Chesnay. There are eight different benchmark class to

[jira] [Created] (FLINK-2890) Apply JMH on StringSerializationSpeedBenchmark class.

2015-10-22 Thread GaoLun (JIRA)
GaoLun created FLINK-2890: - Summary: Apply JMH on StringSerializationSpeedBenchmark class. Key: FLINK-2890 URL: https://issues.apache.org/jira/browse/FLINK-2890 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-2892) Apply JMH on MemorySegmentSpeedBenchmark class.

2015-10-22 Thread GaoLun (JIRA)
GaoLun created FLINK-2892: - Summary: Apply JMH on MemorySegmentSpeedBenchmark class. Key: FLINK-2892 URL: https://issues.apache.org/jira/browse/FLINK-2892 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-2889) Apply JMH on LongSerializationSpeedBenchmark class

2015-10-21 Thread GaoLun (JIRA)
GaoLun created FLINK-2889: - Summary: Apply JMH on LongSerializationSpeedBenchmark class Key: FLINK-2889 URL: https://issues.apache.org/jira/browse/FLINK-2889 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-2884) Apply JMH on HashVsSortMiniBenchmark class.

2015-10-20 Thread GaoLun (JIRA)
GaoLun created FLINK-2884: - Summary: Apply JMH on HashVsSortMiniBenchmark class. Key: FLINK-2884 URL: https://issues.apache.org/jira/browse/FLINK-2884 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-2869) Apply JMH on IOManagerPerformanceBenchmark class.

2015-10-19 Thread GaoLun (JIRA)
GaoLun created FLINK-2869: - Summary: Apply JMH on IOManagerPerformanceBenchmark class. Key: FLINK-2869 URL: https://issues.apache.org/jira/browse/FLINK-2869 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-2853) Apply JMH on MutableHashTablePerformanceBenchmark class.

2015-10-15 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] GaoLun updated FLINK-2853: -- Summary: Apply JMH on MutableHashTablePerformanceBenchmark class. (was: Apply JMH on Flink benchmarks) >

[jira] [Created] (FLINK-2853) Apply JMH on Flink benchmarks

2015-10-14 Thread GaoLun (JIRA)
GaoLun created FLINK-2853: - Summary: Apply JMH on Flink benchmarks Key: FLINK-2853 URL: https://issues.apache.org/jira/browse/FLINK-2853 Project: Flink Issue Type: Sub-task Components:

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

2015-09-02 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14726870#comment-14726870 ] GaoLun commented on FLINK-2535: --- Hi.I have replaced the sampling algorithm with scalable simple random

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

2015-09-02 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] GaoLun updated FLINK-2535: -- Attachment: sampling.png Statistical data of rejected items' number with SRS & SSRS. > Fixed size sample

[jira] [Commented] (FLINK-2077) Rework Path class and add extend support for Windows paths

2015-08-12 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14693036#comment-14693036 ] GaoLun commented on FLINK-2077: --- Hi, Fabian. what do you mean about 'path like

[jira] [Commented] (FLINK-2077) Rework Path class and add extend support for Windows paths

2015-08-10 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14681157#comment-14681157 ] GaoLun commented on FLINK-2077: --- If no one work for this issue , i will work it. Rework