[jira] [Created] (FLINK-2262) ParameterTool API misnamed function

2015-06-22 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2262: - Summary: ParameterTool API misnamed function Key: FLINK-2262 URL: https://issues.apache.org/jira/browse/FLINK-2262 Project: Flink Issue Type: Bug

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

2015-08-18 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2545: - Summary: NegativeArraySizeException while creating hash table bloom filters Key: FLINK-2545 URL: https://issues.apache.org/jira/browse/FLINK-2545 Project: Flink

[jira] [Updated] (FLINK-2569) CsvReader support for ValueTypes

2015-08-24 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-2569: -- Description: From the Flink Programming Guide section on Data Sources: {quote} readCsvFile(path) /

[jira] [Created] (FLINK-2569) CsvReader support for ValueTypes

2015-08-24 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2569: - Summary: CsvReader support for ValueTypes Key: FLINK-2569 URL: https://issues.apache.org/jira/browse/FLINK-2569 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2907) Bloom filter for Join

2015-10-23 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2907: - Summary: Bloom filter for Join Key: FLINK-2907 URL: https://issues.apache.org/jira/browse/FLINK-2907 Project: Flink Issue Type: New Feature Components:

[jira] [Created] (FLINK-2908) Web interface redraw web plan when browser resized

2015-10-23 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2908: - Summary: Web interface redraw web plan when browser resized Key: FLINK-2908 URL: https://issues.apache.org/jira/browse/FLINK-2908 Project: Flink Issue Type:

[jira] [Created] (FLINK-2903) Web interface numeric localization

2015-10-22 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2903: - Summary: Web interface numeric localization Key: FLINK-2903 URL: https://issues.apache.org/jira/browse/FLINK-2903 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2904) Web interface truncated task counts

2015-10-22 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2904: - Summary: Web interface truncated task counts Key: FLINK-2904 URL: https://issues.apache.org/jira/browse/FLINK-2904 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2902) Web interface sort tasks newest first

2015-10-22 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2902: - Summary: Web interface sort tasks newest first Key: FLINK-2902 URL: https://issues.apache.org/jira/browse/FLINK-2902 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2897) Use distinct initial indices for OutputEmitter round-robin

2015-10-22 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2897: - Summary: Use distinct initial indices for OutputEmitter round-robin Key: FLINK-2897 URL: https://issues.apache.org/jira/browse/FLINK-2897 Project: Flink Issue

[jira] [Commented] (FLINK-2909) Gelly Graph Generators

2015-10-26 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14974985#comment-14974985 ] Greg Hogan commented on FLINK-2909: --- My thought was to initially implement one or two of each to prove

[jira] [Created] (FLINK-2895) Duplicate immutable object creation

2015-10-22 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2895: - Summary: Duplicate immutable object creation Key: FLINK-2895 URL: https://issues.apache.org/jira/browse/FLINK-2895 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-2865) OutOfMemory error (Direct buffer memory)

2015-10-19 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14963384#comment-14963384 ] Greg Hogan commented on FLINK-2865: --- Thanks for the explanation. I used {{-XX:MaxDirectMemorySize=1T}}

[jira] [Created] (FLINK-2834) Global round-robin for temporary directories

2015-10-08 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2834: - Summary: Global round-robin for temporary directories Key: FLINK-2834 URL: https://issues.apache.org/jira/browse/FLINK-2834 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2865) OutOfMemory error (Direct buffer memory)

2015-10-18 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2865: - Summary: OutOfMemory error (Direct buffer memory) Key: FLINK-2865 URL: https://issues.apache.org/jira/browse/FLINK-2865 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2876) Minutiae

2015-10-20 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2876: - Summary: Minutiae Key: FLINK-2876 URL: https://issues.apache.org/jira/browse/FLINK-2876 Project: Flink Issue Type: Improvement Components: Documentation

[jira] [Created] (FLINK-2881) WebRuntimeMonitor overly restrictive file patterns

2015-10-20 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2881: - Summary: WebRuntimeMonitor overly restrictive file patterns Key: FLINK-2881 URL: https://issues.apache.org/jira/browse/FLINK-2881 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2820) Configuration not passed to JobGraphGenerator

2015-10-05 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2820: - Summary: Configuration not passed to JobGraphGenerator Key: FLINK-2820 URL: https://issues.apache.org/jira/browse/FLINK-2820 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-2716) Checksum method for DataSet and Graph

2015-10-09 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14950446#comment-14950446 ] Greg Hogan commented on FLINK-2716: --- {{TaskConfig}} has {{getInputSerializer(int, ClassLoader)}} and

[jira] [Created] (FLINK-2603) Flink hangs before starting execution

2015-09-01 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2603: - Summary: Flink hangs before starting execution Key: FLINK-2603 URL: https://issues.apache.org/jira/browse/FLINK-2603 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2625) Configuration not passed to JobGraphGenerator

2015-09-05 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2625: - Summary: Configuration not passed to JobGraphGenerator Key: FLINK-2625 URL: https://issues.apache.org/jira/browse/FLINK-2625 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-2603) Flink hangs before starting execution

2015-09-02 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14727286#comment-14727286 ] Greg Hogan commented on FLINK-2603: --- Thanks, [~StephanEwen]. Changing {code}akka.framesize{code} to 100

[jira] [Comment Edited] (FLINK-2603) Flink hangs before starting execution

2015-09-02 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14727286#comment-14727286 ] Greg Hogan edited comment on FLINK-2603 at 9/2/15 12:54 PM: Thanks,

[jira] [Comment Edited] (FLINK-2603) Flink hangs before starting execution

2015-09-02 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14727286#comment-14727286 ] Greg Hogan edited comment on FLINK-2603 at 9/2/15 12:58 PM: Thanks,

[jira] [Created] (FLINK-2653) Enable object reuse in MergeIterator

2015-09-10 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2653: - Summary: Enable object reuse in MergeIterator Key: FLINK-2653 URL: https://issues.apache.org/jira/browse/FLINK-2653 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2655) Minimize intermediate merging of spilled buffers

2015-09-10 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2655: - Summary: Minimize intermediate merging of spilled buffers Key: FLINK-2655 URL: https://issues.apache.org/jira/browse/FLINK-2655 Project: Flink Issue Type:

[jira] [Updated] (FLINK-2668) ProjectOperator method to close projection

2015-09-14 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-2668: -- Description: I have come across an issue in my code where I called project(...) on a DataSet which was

[jira] [Updated] (FLINK-2668) ProjectOperator method to close projection

2015-09-14 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-2668: -- Description: I have come across an issue in my code where I called {noformat}project(...){noformat} on

[jira] [Created] (FLINK-2659) Object reuse in UnionWithTempOperator

2015-09-11 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2659: - Summary: Object reuse in UnionWithTempOperator Key: FLINK-2659 URL: https://issues.apache.org/jira/browse/FLINK-2659 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-2668) ProjectOperator method to close projection

2015-09-15 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-2668: -- Description: I have come across an issue in my code where I called project(...) on a {{DataSet}} which

[jira] [Updated] (FLINK-2685) TaskManager deadlock on NetworkBufferPool

2015-09-15 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-2685: -- Description: This deadlock occurs intermittently. I have a {{join}} followed by a

[jira] [Updated] (FLINK-2685) TaskManager deadlock on NetworkBufferPool

2015-09-15 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-2685: -- Description: This deadlock occurs intermittently. I have a {{join}} followed by a

[jira] [Created] (FLINK-2685) TaskManager deadlock on NetworkBufferPool

2015-09-15 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2685: - Summary: TaskManager deadlock on NetworkBufferPool Key: FLINK-2685 URL: https://issues.apache.org/jira/browse/FLINK-2685 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-2653) Enable object reuse in MergeIterator

2015-09-17 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan reassigned FLINK-2653: - Assignee: Greg Hogan > Enable object reuse in MergeIterator >

[jira] [Created] (FLINK-2698) Add trailing newline to flink-conf.yaml

2015-09-17 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2698: - Summary: Add trailing newline to flink-conf.yaml Key: FLINK-2698 URL: https://issues.apache.org/jira/browse/FLINK-2698 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-2668) ProjectOperator method to close projection

2015-09-14 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-2668: -- Description: I have come across an issue in my code where I called {monospace}project(...){noformat}

[jira] [Created] (FLINK-2668) ProjectOperator method to close projection

2015-09-14 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2668: - Summary: ProjectOperator method to close projection Key: FLINK-2668 URL: https://issues.apache.org/jira/browse/FLINK-2668 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-2668) ProjectOperator method to close projection

2015-09-14 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-2668: -- Description: I have come across an issue in my code where I called

[jira] [Comment Edited] (FLINK-2668) ProjectOperator method to close projection

2015-09-15 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14745391#comment-14745391 ] Greg Hogan edited comment on FLINK-2668 at 9/15/15 12:52 PM: - The project

[jira] [Commented] (FLINK-2668) ProjectOperator method to close projection

2015-09-15 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14745391#comment-14745391 ] Greg Hogan commented on FLINK-2668: --- The project methods work well, particularly for interleaving

[jira] [Closed] (FLINK-2763) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers.

2015-09-29 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-2763. - Success! > Bug in Hybrid Hash Join: Request to spill a partition with less than two > buffers. >

[jira] [Commented] (FLINK-2810) Warn user if bc not installed

2015-10-02 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14941172#comment-14941172 ] Greg Hogan commented on FLINK-2810: --- Bash arithmetic evaluation is limited to integers. > Warn user if

[jira] [Updated] (FLINK-2810) Warn user if bc not installed

2015-10-02 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-2810: -- Description: taskmanager.sh will print the following message when starting the cluster if bc is not

[jira] [Created] (FLINK-2810) Warn user if bc not installed

2015-10-02 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2810: - Summary: Warn user if bc not installed Key: FLINK-2810 URL: https://issues.apache.org/jira/browse/FLINK-2810 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-2716) Checksum method for DataSet and Graph

2015-10-02 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14941379#comment-14941379 ] Greg Hogan commented on FLINK-2716: --- [~StephanEwen], I would like to use {{TypeComparator.hash}} within

[jira] [Created] (FLINK-2814) DeltaIteration: DualInputPlanNode cannot be cast to SingleInputPlanNode

2015-10-02 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2814: - Summary: DeltaIteration: DualInputPlanNode cannot be cast to SingleInputPlanNode Key: FLINK-2814 URL: https://issues.apache.org/jira/browse/FLINK-2814 Project: Flink

[jira] [Created] (FLINK-2762) Job Runtime: -1 ms

2015-09-24 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2762: - Summary: Job Runtime: -1 ms Key: FLINK-2762 URL: https://issues.apache.org/jira/browse/FLINK-2762 Project: Flink Issue Type: Bug Components: other

[jira] [Created] (FLINK-2723) CopyableValue method to copy into new instance

2015-09-21 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2723: - Summary: CopyableValue method to copy into new instance Key: FLINK-2723 URL: https://issues.apache.org/jira/browse/FLINK-2723 Project: Flink Issue Type: New

[jira] [Created] (FLINK-2725) Max/Min/Sum Aggregation of mutable types

2015-09-21 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2725: - Summary: Max/Min/Sum Aggregation of mutable types Key: FLINK-2725 URL: https://issues.apache.org/jira/browse/FLINK-2725 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2716) Checksum method for DataSet and Graph

2015-09-20 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2716: - Summary: Checksum method for DataSet and Graph Key: FLINK-2716 URL: https://issues.apache.org/jira/browse/FLINK-2716 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2763) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers.

2015-09-25 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2763: - Summary: Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers. Key: FLINK-2763 URL: https://issues.apache.org/jira/browse/FLINK-2763 Project:

[jira] [Commented] (FLINK-2897) Use distinct initial indices for OutputEmitter round-robin

2015-12-07 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045031#comment-15045031 ] Greg Hogan commented on FLINK-2897: --- Thanks for checking that. I saw the "Yes, +1 for merging" and

[jira] [Commented] (FLINK-2897) Use distinct initial indices for OutputEmitter round-robin

2015-12-02 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15036316#comment-15036316 ] Greg Hogan commented on FLINK-2897: --- I've been out for a while but I see this is still open and

[jira] [Created] (FLINK-3160) Aggregate operator statistics by TaskManager

2015-12-11 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3160: - Summary: Aggregate operator statistics by TaskManager Key: FLINK-3160 URL: https://issues.apache.org/jira/browse/FLINK-3160 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3161) Externalize cluster start-up and tear-down when available

2015-12-11 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3161: - Summary: Externalize cluster start-up and tear-down when available Key: FLINK-3161 URL: https://issues.apache.org/jira/browse/FLINK-3161 Project: Flink Issue

[jira] [Assigned] (FLINK-3166) The first program in ObjectReuseITCase has the wrong expected result, and it succeeds

2015-12-14 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan reassigned FLINK-3166: - Assignee: Greg Hogan > The first program in ObjectReuseITCase has the wrong expected result, and

[jira] [Created] (FLINK-3162) Configure number of TaskManager slots as ratio of available processors

2015-12-11 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3162: - Summary: Configure number of TaskManager slots as ratio of available processors Key: FLINK-3162 URL: https://issues.apache.org/jira/browse/FLINK-3162 Project: Flink

[jira] [Commented] (FLINK-3160) Aggregate operator statistics by TaskManager

2015-12-17 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15062208#comment-15062208 ] Greg Hogan commented on FLINK-3160: --- Currently when clicking a JobVertex the table expands to display a

[jira] [Assigned] (FLINK-3160) Aggregate operator statistics by TaskManager

2015-12-17 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan reassigned FLINK-3160: - Assignee: Greg Hogan > Aggregate operator statistics by TaskManager >

[jira] [Created] (FLINK-3164) Spread out scheduling strategy

2015-12-11 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3164: - Summary: Spread out scheduling strategy Key: FLINK-3164 URL: https://issues.apache.org/jira/browse/FLINK-3164 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3163) Configure Flink for NUMA systems

2015-12-11 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3163: - Summary: Configure Flink for NUMA systems Key: FLINK-3163 URL: https://issues.apache.org/jira/browse/FLINK-3163 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3206) Heap size for non-pre-allocated off-heap memory

2016-01-06 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3206: - Summary: Heap size for non-pre-allocated off-heap memory Key: FLINK-3206 URL: https://issues.apache.org/jira/browse/FLINK-3206 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-3206) Heap size for non-pre-allocated off-heap memory

2016-01-06 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15085839#comment-15085839 ] Greg Hogan commented on FLINK-3206: --- No, running standalone. > Heap size for non-pre-allocated off-heap

[jira] [Commented] (FLINK-3056) Show bytes sent/received as MBs/GB and so on in web interface

2015-11-21 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15020423#comment-15020423 ] Greg Hogan commented on FLINK-3056: --- Would this be a configuration option (whether or not the default)?

[jira] [Created] (FLINK-4013) GraphAlgorithms to simplify directed and undirected graphs

2016-06-02 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4013: - Summary: GraphAlgorithms to simplify directed and undirected graphs Key: FLINK-4013 URL: https://issues.apache.org/jira/browse/FLINK-4013 Project: Flink Issue

[jira] [Closed] (FLINK-3980) Remove ExecutionConfig.PARALLELISM_UNKNOWN

2016-06-07 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3980. - Resolution: Implemented Implemented in 21454973ed4edfb3e27bc50ed0279f5708d54fa2 > Remove

[jira] [Closed] (FLINK-4013) GraphAlgorithms to simplify directed and undirected graphs

2016-06-07 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-4013. - Resolution: Fixed Implemented in 7160a681240deab693aa4d69c24c4a8a63bb58ba > GraphAlgorithms to simplify

[jira] [Updated] (FLINK-3907) Directed Clustering Coefficient

2016-06-07 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-3907: -- Fix Version/s: 1.1.0 > Directed Clustering Coefficient > --- > >

[jira] [Updated] (FLINK-3806) Revert use of DataSet.count() in Gelly

2016-05-25 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-3806: -- Fix Version/s: 1.1.0 > Revert use of DataSet.count() in Gelly > --

[jira] [Commented] (FLINK-3978) Add contains methods to RuntimeContext

2016-05-26 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15302133#comment-15302133 ] Greg Hogan commented on FLINK-3978: --- Thanks! I removed that bit from the description. Only looking at

[jira] [Updated] (FLINK-3978) Add contains methods to RuntimeContext

2016-05-26 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-3978: -- Description: The javadocs for {{RuntimeContext}} state that {{getAccumulator}} "throws an exception if

[jira] [Updated] (FLINK-3978) Add contains methods to RuntimeContext

2016-05-26 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-3978: -- Description: The javadocs for `RuntimeContext` state that `getAccumulator` "throws an exception if the

[jira] [Closed] (FLINK-3906) Global Clustering Coefficient

2016-06-07 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3906. - Resolution: Implemented Implemented in 8da1a75ceb30ef1bce27a2426dab3a0f66b94b64 > Global Clustering

[jira] [Closed] (FLINK-4003) Use intrinsics for MathUtils logarithms

2016-06-07 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-4003. - Resolution: Implemented Implemented in 1bbc1fb4d7b8701c38e6f6a78f3709448181d559 > Use intrinsics for

[jira] [Updated] (FLINK-3978) Add containsBroadcastVariable method to RuntimeContext

2016-05-26 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-3978: -- Summary: Add containsBroadcastVariable method to RuntimeContext (was: Add containsBroadcastVariable

[jira] [Updated] (FLINK-3978) Add containsBroadcastVariable methods to RuntimeContext

2016-05-26 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-3978: -- Summary: Add containsBroadcastVariable methods to RuntimeContext (was: Add contains methods to

[jira] [Commented] (FLINK-3978) Add containsBroadcastVariable method to RuntimeContext

2016-05-26 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15302501#comment-15302501 ] Greg Hogan commented on FLINK-3978: --- That was my first thought, and I wanted to name the ticket "add

[jira] [Updated] (FLINK-3978) Add hasBroadcastVariable method to RuntimeContext

2016-05-26 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-3978: -- Summary: Add hasBroadcastVariable method to RuntimeContext (was: Add containsBroadcastVariable method

[jira] [Commented] (FLINK-3291) Object reuse bug in MergeIterator.HeadStream.nextHead

2016-05-27 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15304234#comment-15304234 ] Greg Hogan commented on FLINK-3291: --- The {{inputStream}} field causing the {{IllegalArgumentException}}

[jira] [Commented] (FLINK-4009) Scala Shell fails to find library for inclusion in test

2016-06-02 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15312234#comment-15312234 ] Greg Hogan commented on FLINK-4009: --- Is this fix related to [~till.rohrmann]'s suggested fix for

[jira] [Closed] (FLINK-3806) Revert use of DataSet.count() in Gelly

2016-06-02 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3806. - Resolution: Fixed Fixed in 36ad78c0821fdae0a69371c67602dd2a7955e4a8 > Revert use of DataSet.count() in

[jira] [Closed] (FLINK-3945) Degree annotation for directed graphs

2016-06-02 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3945. - Resolution: Implemented Implemented in 65545c2ed46c17df6abd85299b91bad2529cd42c > Degree annotation for

[jira] [Commented] (FLINK-4009) Scala Shell fails to find library for inclusion in test

2016-06-02 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15312269#comment-15312269 ] Greg Hogan commented on FLINK-4009: --- I'm not seeing this a duplicate but rather that FLINK-3454 depends

[jira] [Created] (FLINK-3980) Remove ExecutionConfig.PARALLELISM_UNKNOWN

2016-05-26 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3980: - Summary: Remove ExecutionConfig.PARALLELISM_UNKNOWN Key: FLINK-3980 URL: https://issues.apache.org/jira/browse/FLINK-3980 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-3910) New self-join operator

2016-05-26 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15302853#comment-15302853 ] Greg Hogan commented on FLINK-3910: --- I see this case as part of flushing out the remaining join

[jira] [Updated] (FLINK-3978) Add hasBroadcastVariable method to RuntimeContext

2016-05-26 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-3978: -- Fix Version/s: 1.1.0 > Add hasBroadcastVariable method to RuntimeContext >

[jira] [Commented] (FLINK-3910) New self-join operator

2016-05-26 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15302852#comment-15302852 ] Greg Hogan commented on FLINK-3910: --- I see this case as part of flushing out the remaining join

[jira] [Issue Comment Deleted] (FLINK-3910) New self-join operator

2016-05-26 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-3910: -- Comment: was deleted (was: I see this case as part of flushing out the remaining join operators. Flink

[jira] [Created] (FLINK-3978) Add contains methods to RuntimeContext

2016-05-26 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3978: - Summary: Add contains methods to RuntimeContext Key: FLINK-3978 URL: https://issues.apache.org/jira/browse/FLINK-3978 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-4003) Use intrinsics for MathUtils logarithms

2016-06-01 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4003: - Summary: Use intrinsics for MathUtils logarithms Key: FLINK-4003 URL: https://issues.apache.org/jira/browse/FLINK-4003 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-3996) Add addition, subtraction and multiply by scalar to DenseVector.scala and SparseVector.scala

2016-05-31 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-3996: -- Component/s: Machine Learning Library > Add addition, subtraction and multiply by scalar to

[jira] [Created] (FLINK-3997) PRNG Skip-ahead

2016-05-31 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3997: - Summary: PRNG Skip-ahead Key: FLINK-3997 URL: https://issues.apache.org/jira/browse/FLINK-3997 Project: Flink Issue Type: Improvement Components: Gelly

[jira] [Commented] (FLINK-1815) Add methods to read and write a Graph as adjacency list

2016-06-22 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15344503#comment-15344503 ] Greg Hogan commented on FLINK-1815: --- [~fobeligi] If you are using IntelliJ, look in Settings under

[jira] [Created] (FLINK-4102) Test failure with checkpoint barriers

2016-06-22 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4102: - Summary: Test failure with checkpoint barriers Key: FLINK-4102 URL: https://issues.apache.org/jira/browse/FLINK-4102 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-3868) Specialized CopyableValue serializers and comparators

2016-06-22 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3868. - Resolution: Fixed Implemented in 08b075aa5d5dbc90e909f1bbc3f81712c0604615 > Specialized CopyableValue

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

2016-06-22 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15344286#comment-15344286 ] Greg Hogan commented on FLINK-3879: --- When I tested the performance of FLINK-3879 it was significantly

[jira] [Closed] (FLINK-3789) Overload methods which trigger program execution to allow naming job

2016-06-22 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3789. - Resolution: Won't Fix As discussed in the comments, it is better to solve this externally, e.g.

[jira] [Created] (FLINK-4104) Restructure Gelly docs

2016-06-22 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4104: - Summary: Restructure Gelly docs Key: FLINK-4104 URL: https://issues.apache.org/jira/browse/FLINK-4104 Project: Flink Issue Type: Improvement Components:

[jira] [Created] (FLINK-4106) Restructure Gelly docs

2016-06-22 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4106: - Summary: Restructure Gelly docs Key: FLINK-4106 URL: https://issues.apache.org/jira/browse/FLINK-4106 Project: Flink Issue Type: Improvement Components:

[jira] [Created] (FLINK-4107) Restructure Gelly docs

2016-06-22 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4107: - Summary: Restructure Gelly docs Key: FLINK-4107 URL: https://issues.apache.org/jira/browse/FLINK-4107 Project: Flink Issue Type: Improvement Components:

  1   2   3   4   5   6   7   8   9   10   >