[jira] [Commented] (FLINK-6019) Some log4j messages do not have a loglevel field set, so they can't be suppressed

2018-06-05 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501463#comment-16501463 ] Luke Hutchison commented on FLINK-6019: --- PS this is especially confusing because th

[jira] [Commented] (FLINK-6019) Some log4j messages do not have a loglevel field set, so they can't be suppressed

2018-06-05 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501456#comment-16501456 ] Luke Hutchison commented on FLINK-6019: --- Unfortunately I am so unknowledgeable abou

[jira] [Commented] (FLINK-6019) Some log4j messages do not have a loglevel field set, so they can't be suppressed

2018-06-04 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501158#comment-16501158 ] Luke Hutchison commented on FLINK-6019: --- [~StephanEwen] It looks like I don't have

[jira] [Commented] (FLINK-6019) Some log4j messages do not have a loglevel field set, so they can't be suppressed

2018-06-04 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501151#comment-16501151 ] Luke Hutchison commented on FLINK-6019: --- Yes, that was the problem, thank you. I ha

[jira] [Commented] (FLINK-6019) Some log4j messages do not have a loglevel field set, so they can't be suppressed

2018-05-31 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16497586#comment-16497586 ] Luke Hutchison commented on FLINK-6019: --- [~StephanEwen] I updated to Flink 1.5 and

[jira] [Commented] (FLINK-6016) Newlines should be valid in quoted strings in CSV

2018-05-23 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487197#comment-16487197 ] Luke Hutchison commented on FLINK-6016: --- Well, surely CSV is not the only file forma

[jira] [Commented] (FLINK-6016) Newlines should be valid in quoted strings in CSV

2018-05-23 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487151#comment-16487151 ] Luke Hutchison commented on FLINK-6016: --- [~fhueske] reading a file in parallel is no

[jira] [Commented] (FLINK-6016) Newlines should be valid in quoted strings in CSV

2018-05-22 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16486510#comment-16486510 ] Luke Hutchison commented on FLINK-6016: --- [~pshvetso]: It looks like you were able to

[jira] [Commented] (FLINK-6019) Some log4j messages do not have a loglevel field set, so they can't be suppressed

2017-10-17 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16207174#comment-16207174 ] Luke Hutchison commented on FLINK-6019: --- [~StephanEwen] yes, please see the last few

[jira] [Commented] (FLINK-6016) Newlines should be valid in quoted strings in CSV

2017-09-01 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150860#comment-16150860 ] Luke Hutchison commented on FLINK-6016: --- Yes, that's what I'm suggesting. The data d

[jira] [Commented] (FLINK-6016) Newlines should be valid in quoted strings in CSV

2017-08-31 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16149440#comment-16149440 ] Luke Hutchison commented on FLINK-6016: --- Mikhail: correct, this can't be fixed easil

[jira] [Commented] (FLINK-6019) Some log4j messages do not have a loglevel field set, so they can't be suppressed

2017-05-01 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991926#comment-15991926 ] Luke Hutchison commented on FLINK-6019: --- [~StephanEwen] No, the lines I am talking a

[jira] [Commented] (FLINK-3328) Incorrectly shaded dependencies in flink-runtime

2017-04-20 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977155#comment-15977155 ] Luke Hutchison commented on FLINK-3328: --- Right, but shading requires a complete copy

[jira] [Commented] (FLINK-3328) Incorrectly shaded dependencies in flink-runtime

2017-04-20 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976649#comment-15976649 ] Luke Hutchison commented on FLINK-3328: --- What's the advantage to Flink of including

[jira] [Comment Edited] (FLINK-3328) Incorrectly shaded dependencies in flink-runtime

2017-04-19 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15975268#comment-15975268 ] Luke Hutchison edited comment on FLINK-3328 at 4/19/17 6:43 PM:

[jira] [Commented] (FLINK-3328) Incorrectly shaded dependencies in flink-runtime

2017-04-19 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15975268#comment-15975268 ] Luke Hutchison commented on FLINK-3328: --- [~StephanEwen] It's only not a problem if y

[jira] [Commented] (FLINK-3328) Incorrectly shaded dependencies in flink-runtime

2017-04-14 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969820#comment-15969820 ] Luke Hutchison commented on FLINK-3328: --- [~rmetzger] I'm still seeing this in Flink

[jira] [Commented] (FLINK-6276) InvalidTypesException: Unknown Error. Type is null.

2017-04-08 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15961980#comment-15961980 ] Luke Hutchison commented on FLINK-6276: --- [~Zentol] Thanks for explaining. I assume t

[jira] [Commented] (FLINK-6276) InvalidTypesException: Unknown Error. Type is null.

2017-04-08 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15961936#comment-15961936 ] Luke Hutchison commented on FLINK-6276: --- [~sunjincheng121] [~Zentol] I understand th

[jira] [Commented] (FLINK-6276) InvalidTypesException: Unknown Error. Type is null.

2017-04-07 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960407#comment-15960407 ] Luke Hutchison commented on FLINK-6276: --- [~Zentol] how does my code throw away more

[jira] [Commented] (FLINK-6276) InvalidTypesException: Unknown Error. Type is null.

2017-04-06 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960367#comment-15960367 ] Luke Hutchison commented on FLINK-6276: --- I just tested, and the code as currently sh

[jira] [Comment Edited] (FLINK-6276) InvalidTypesException: Unknown Error. Type is null.

2017-04-06 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960349#comment-15960349 ] Luke Hutchison edited comment on FLINK-6276 at 4/7/17 6:43 AM: -

[jira] [Updated] (FLINK-6276) InvalidTypesException: Unknown Error. Type is null.

2017-04-06 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Hutchison updated FLINK-6276: -- Description: Quite frequently when writing Flink code, I get the exception {{InvalidTypesExcept

[jira] [Commented] (FLINK-6276) InvalidTypesException: Unknown Error. Type is null.

2017-04-06 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960349#comment-15960349 ] Luke Hutchison commented on FLINK-6276: --- Looking at the flink code, the issue here i

[jira] [Updated] (FLINK-6276) InvalidTypesException: Unknown Error. Type is null.

2017-04-06 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Hutchison updated FLINK-6276: -- Description: Quite frequently when writing Flink code, I get the exception {{InvalidTypesExcept

[jira] [Created] (FLINK-6276) InvalidTypesException: Unknown Error. Type is null.

2017-04-06 Thread Luke Hutchison (JIRA)
Luke Hutchison created FLINK-6276: - Summary: InvalidTypesException: Unknown Error. Type is null. Key: FLINK-6276 URL: https://issues.apache.org/jira/browse/FLINK-6276 Project: Flink Issue Typ

[jira] [Commented] (FLINK-6115) Need more helpful error message when trying to serialize a tuple with a null field

2017-03-31 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950505#comment-15950505 ] Luke Hutchison commented on FLINK-6115: --- [~Zentol] In point (1), I wasn't referring

[jira] [Comment Edited] (FLINK-6115) Need more helpful error message when trying to serialize a tuple with a null field

2017-03-30 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950319#comment-15950319 ] Luke Hutchison edited comment on FLINK-6115 at 3/31/17 4:49 AM:

[jira] [Commented] (FLINK-6115) Need more helpful error message when trying to serialize a tuple with a null field

2017-03-30 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950319#comment-15950319 ] Luke Hutchison commented on FLINK-6115: --- [~greghogan] You're assuming data with {{nu

[jira] [Commented] (FLINK-6019) Some log4j messages do not have a loglevel field set, so they can't be suppressed

2017-03-30 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948836#comment-15948836 ] Luke Hutchison commented on FLINK-6019: --- It is definitely the Akka log printing all

[jira] [Commented] (FLINK-6115) Need more helpful error message when trying to serialize a tuple with a null field

2017-03-29 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948412#comment-15948412 ] Luke Hutchison commented on FLINK-6115: --- [~greghogan]: fang yong's comment exactly i

[jira] [Comment Edited] (FLINK-6185) Output writers and OutputFormats need to support compression

2017-03-25 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941797#comment-15941797 ] Luke Hutchison edited comment on FLINK-6185 at 3/25/17 8:23 PM:

[jira] [Comment Edited] (FLINK-6185) Output writers and OutputFormats need to support compression

2017-03-25 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941797#comment-15941797 ] Luke Hutchison edited comment on FLINK-6185 at 3/25/17 8:22 PM:

[jira] [Commented] (FLINK-6115) Need more helpful error message when trying to serialize a tuple with a null field

2017-03-25 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941882#comment-15941882 ] Luke Hutchison commented on FLINK-6115: --- [~greghogan] versioning of durable binary f

[jira] [Commented] (FLINK-6185) Output writers and OutputFormats need to support compression

2017-03-25 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941797#comment-15941797 ] Luke Hutchison commented on FLINK-6185: --- Here's my simple gzip OutputFormat though,

[jira] [Updated] (FLINK-6185) Output writers and OutputFormats need to support compression

2017-03-25 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Hutchison updated FLINK-6185: -- Summary: Output writers and OutputFormats need to support compression (was: Output writers and

[jira] [Updated] (FLINK-6185) Output writers and OutputFormats need to support gzip

2017-03-25 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Hutchison updated FLINK-6185: -- Summary: Output writers and OutputFormats need to support gzip (was: Input readers and output w

[jira] [Commented] (FLINK-6185) Input readers and output writers/formats need to support gzip

2017-03-25 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941795#comment-15941795 ] Luke Hutchison commented on FLINK-6185: --- Ah, sorry that I missed that. I may contrib

[jira] [Updated] (FLINK-6185) Input readers and output writers/formats need to support gzip

2017-03-24 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Hutchison updated FLINK-6185: -- Description: File sources (such as {{ExecutionEnvironment#readCsvFile()}}) and sinks (such as {

[jira] [Created] (FLINK-6185) Input readers and output writers/formats need to support gzip

2017-03-24 Thread Luke Hutchison (JIRA)
Luke Hutchison created FLINK-6185: - Summary: Input readers and output writers/formats need to support gzip Key: FLINK-6185 URL: https://issues.apache.org/jira/browse/FLINK-6185 Project: Flink

[jira] [Updated] (FLINK-6185) Input readers and output writers/formats need to support gzip

2017-03-24 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Hutchison updated FLINK-6185: -- Description: File sources (such as {{env#readCsvFile()}}) and sinks (such as {{FileOutputFormat

[jira] [Commented] (FLINK-6019) Some log4j messages do not have a loglevel field set, so they can't be suppressed

2017-03-24 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940106#comment-15940106 ] Luke Hutchison commented on FLINK-6019: --- As far as I can tell, Akka uses a different

[jira] [Commented] (FLINK-6115) Need more helpful error message when trying to serialize a tuple with a null field

2017-03-24 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940101#comment-15940101 ] Luke Hutchison commented on FLINK-6115: --- Hi [~fhueske]], So the wire format of indi

[jira] [Commented] (FLINK-6115) Need more helpful error message when trying to serialize a tuple with a null field

2017-03-22 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15937185#comment-15937185 ] Luke Hutchison commented on FLINK-6115: --- bq. Why do you think there is no penalty to

[jira] [Comment Edited] (FLINK-6114) Type checking fails with generics, even when concrete type of field is not needed

2017-03-21 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935589#comment-15935589 ] Luke Hutchison edited comment on FLINK-6114 at 3/22/17 1:05 AM:

[jira] [Comment Edited] (FLINK-6114) Type checking fails with generics, even when concrete type of field is not needed

2017-03-21 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935576#comment-15935576 ] Luke Hutchison edited comment on FLINK-6114 at 3/22/17 12:45 AM: ---

[jira] [Commented] (FLINK-6114) Type checking fails with generics, even when concrete type of field is not needed

2017-03-21 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935589#comment-15935589 ] Luke Hutchison commented on FLINK-6114: --- I figured maybe I was using distinct() wron

[jira] [Updated] (FLINK-6146) Incorrect function name given in exception thrown by DataSet.getType()

2017-03-21 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Hutchison updated FLINK-6146: -- Description: In the following code, this exception is thrown at the line marked {{// (1)}}: {no

[jira] [Updated] (FLINK-6146) Incorrect function name given in exception thrown by DataSet.getType()

2017-03-21 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Hutchison updated FLINK-6146: -- Description: In the following code, this exception is thrown at the line marked {{// (1)}}: {no

[jira] [Comment Edited] (FLINK-6114) Type checking fails with generics, even when concrete type of field is not needed

2017-03-21 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935576#comment-15935576 ] Luke Hutchison edited comment on FLINK-6114 at 3/22/17 12:25 AM: ---

[jira] [Commented] (FLINK-6114) Type checking fails with generics, even when concrete type of field is not needed

2017-03-21 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15935576#comment-15935576 ] Luke Hutchison commented on FLINK-6114: --- [~greghogan] I partially reconstructed exac

[jira] [Created] (FLINK-6146) Incorrect function name given in exception thrown by DataSet.getType()

2017-03-21 Thread Luke Hutchison (JIRA)
Luke Hutchison created FLINK-6146: - Summary: Incorrect function name given in exception thrown by DataSet.getType() Key: FLINK-6146 URL: https://issues.apache.org/jira/browse/FLINK-6146 Project: Flink

[jira] [Comment Edited] (FLINK-6114) Type checking fails with generics, even when concrete type of field is not needed

2017-03-20 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934109#comment-15934109 ] Luke Hutchison edited comment on FLINK-6114 at 3/21/17 5:18 AM:

[jira] [Comment Edited] (FLINK-6114) Type checking fails with generics, even when concrete type of field is not needed

2017-03-20 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934109#comment-15934109 ] Luke Hutchison edited comment on FLINK-6114 at 3/21/17 5:17 AM:

[jira] [Commented] (FLINK-6114) Type checking fails with generics, even when concrete type of field is not needed

2017-03-20 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934109#comment-15934109 ] Luke Hutchison commented on FLINK-6114: --- Hi Greg, the code that caused the exception

[jira] [Comment Edited] (FLINK-6115) Need more helpful error message when trying to serialize a tuple with a null field

2017-03-20 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934071#comment-15934071 ] Luke Hutchison edited comment on FLINK-6115 at 3/21/17 4:15 AM:

[jira] [Commented] (FLINK-6115) Need more helpful error message when trying to serialize a tuple with a null field

2017-03-20 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934071#comment-15934071 ] Luke Hutchison commented on FLINK-6115: --- It's quite easy to end up with null values

[jira] [Commented] (FLINK-6115) Need more helpful error message when trying to serialize a tuple with a null field

2017-03-20 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15932558#comment-15932558 ] Luke Hutchison commented on FLINK-6115: --- Hi Fabian, is there a fundamental reason wh

[jira] [Commented] (FLINK-6115) Need more helpful error message when trying to serialize a tuple with a null field

2017-03-19 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15932059#comment-15932059 ] Luke Hutchison commented on FLINK-6115: --- N.B. the tuple field in question was of typ

[jira] [Commented] (FLINK-6115) Need more helpful error message when trying to serialize a tuple with a null field

2017-03-18 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931600#comment-15931600 ] Luke Hutchison commented on FLINK-6115: --- More generally, why is it not possible to s

[jira] [Created] (FLINK-6115) Need more helpful error message when trying to serialize a tuple with a null field

2017-03-18 Thread Luke Hutchison (JIRA)
Luke Hutchison created FLINK-6115: - Summary: Need more helpful error message when trying to serialize a tuple with a null field Key: FLINK-6115 URL: https://issues.apache.org/jira/browse/FLINK-6115 Pr

[jira] [Created] (FLINK-6114) Type checking fails with generics, even when concrete type of field is not needed

2017-03-18 Thread Luke Hutchison (JIRA)
Luke Hutchison created FLINK-6114: - Summary: Type checking fails with generics, even when concrete type of field is not needed Key: FLINK-6114 URL: https://issues.apache.org/jira/browse/FLINK-6114 Pro

[jira] [Commented] (FLINK-6110) Flink unnecessarily repeats shared work triggered by different blocking sinks, leading to massive inefficiency

2017-03-18 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931214#comment-15931214 ] Luke Hutchison commented on FLINK-6110: --- Chesnay: Sorry, I couldn't find that dup, a

[jira] [Updated] (FLINK-6110) Flink unnecessarily repeats shared work triggered by different blocking sinks, leading to massive inefficiency

2017-03-18 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Hutchison updated FLINK-6110: -- Description: After a blocking sink (collect() or count()) is called, all already-computed inter

[jira] [Updated] (FLINK-6110) Flink unnecessarily repeats shared work triggered by different blocking sinks, leading to massive inefficiency

2017-03-18 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Hutchison updated FLINK-6110: -- Description: After a blocking sink (collect() or count()) is called, all already-computed inter

[jira] [Created] (FLINK-6110) Flink unnecessarily repeats shared work triggered by different blocking sinks, leading to massive inefficiency

2017-03-18 Thread Luke Hutchison (JIRA)
Luke Hutchison created FLINK-6110: - Summary: Flink unnecessarily repeats shared work triggered by different blocking sinks, leading to massive inefficiency Key: FLINK-6110 URL: https://issues.apache.org/jira/brows

[jira] [Created] (FLINK-6108) Add sum(fieldName) to sum based on named POJO fields

2017-03-18 Thread Luke Hutchison (JIRA)
Luke Hutchison created FLINK-6108: - Summary: Add sum(fieldName) to sum based on named POJO fields Key: FLINK-6108 URL: https://issues.apache.org/jira/browse/FLINK-6108 Project: Flink Issue Ty

[jira] [Updated] (FLINK-6108) Add sum(fieldName) to sum based on named POJO fields

2017-03-18 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Hutchison updated FLINK-6108: -- Description: Currently it is possible to do {code} dataSet.groupBy(0).sum(1) {code} but not {

[jira] [Updated] (FLINK-6070) Suggestion: add ComparableTuple types

2017-03-16 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Hutchison updated FLINK-6070: -- Description: Since Java doesn't have built-in tuple types, I find myself using Flink tuples for

[jira] [Created] (FLINK-6070) Suggestion: add ComparableTuple types

2017-03-16 Thread Luke Hutchison (JIRA)
Luke Hutchison created FLINK-6070: - Summary: Suggestion: add ComparableTuple types Key: FLINK-6070 URL: https://issues.apache.org/jira/browse/FLINK-6070 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-6026) Return type of flatMap with lambda function not correctly resolved

2017-03-15 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Hutchison closed FLINK-6026. - Resolution: Not A Bug > Return type of flatMap with lambda function not correctly resolved > -

[jira] [Commented] (FLINK-6026) Return type of flatMap with lambda function not correctly resolved

2017-03-15 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927065#comment-15927065 ] Luke Hutchison commented on FLINK-6026: --- Makes sense. I was wondering if there was s

[jira] [Closed] (FLINK-6057) Better default needed for num network buffers

2017-03-15 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Hutchison closed FLINK-6057. - Resolution: Duplicate > Better default needed for num network buffers > --

[jira] [Commented] (FLINK-6057) Better default needed for num network buffers

2017-03-15 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15926090#comment-15926090 ] Luke Hutchison commented on FLINK-6057: --- Yes, thanks, sorry for the dup. > Better

[jira] [Created] (FLINK-6057) Better default needed for num network buffers

2017-03-15 Thread Luke Hutchison (JIRA)
Luke Hutchison created FLINK-6057: - Summary: Better default needed for num network buffers Key: FLINK-6057 URL: https://issues.apache.org/jira/browse/FLINK-6057 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-6035) Sinks need optional name parameter: .collect(name), .count(name)

2017-03-14 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15923849#comment-15923849 ] Luke Hutchison edited comment on FLINK-6035 at 3/14/17 9:19 AM:

[jira] [Updated] (FLINK-6035) Sinks need optional name parameter: .collect(name), .count(name)

2017-03-14 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Hutchison updated FLINK-6035: -- Summary: Sinks need optional name parameter: .collect(name), .count(name) (was: The method name

[jira] [Commented] (FLINK-6035) The method name(String) is undefined for the type UnsortedGrouping

2017-03-14 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15923849#comment-15923849 ] Luke Hutchison commented on FLINK-6035: --- The name parameter shouldn't be required, j

[jira] [Commented] (FLINK-6035) The method name(String) is undefined for the type UnsortedGrouping

2017-03-14 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15923789#comment-15923789 ] Luke Hutchison commented on FLINK-6035: --- I see, makes sense. I was going through my

[jira] [Created] (FLINK-6035) The method name(String) is undefined for the type UnsortedGrouping

2017-03-13 Thread Luke Hutchison (JIRA)
Luke Hutchison created FLINK-6035: - Summary: The method name(String) is undefined for the type UnsortedGrouping Key: FLINK-6035 URL: https://issues.apache.org/jira/browse/FLINK-6035 Project: Flink

[jira] [Commented] (FLINK-6026) Return type of flatMap with lambda function not correctly resolved

2017-03-13 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15922732#comment-15922732 ] Luke Hutchison commented on FLINK-6026: --- Makes sense, I wondered if that may be the

[jira] [Commented] (FLINK-6024) Need more fine-grained info for "InvalidProgramException: This type (...) cannot be used as key"

2017-03-13 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15922699#comment-15922699 ] Luke Hutchison commented on FLINK-6024: --- This was for the batch API (DataSet). More

[jira] [Updated] (FLINK-6029) Strange linebreaks in web dashboard graph view make it hard to read text

2017-03-13 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Hutchison updated FLINK-6029: -- Attachment: Screenshot_2017-03-13_01-40-52.png Screenshot > Strange linebreaks in web dashboard

[jira] [Created] (FLINK-6029) Strange linebreaks in web dashboard graph view make it hard to read text

2017-03-13 Thread Luke Hutchison (JIRA)
Luke Hutchison created FLINK-6029: - Summary: Strange linebreaks in web dashboard graph view make it hard to read text Key: FLINK-6029 URL: https://issues.apache.org/jira/browse/FLINK-6029 Project: Fli

[jira] [Updated] (FLINK-6029) Strange linebreaks in web dashboard graph view make it hard to read text

2017-03-13 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Hutchison updated FLINK-6029: -- Description: Text lines inside the boxes in the Flink web dashboard have linebreaks at very odd

[jira] [Created] (FLINK-6028) Unnamed operations in main method logged as "main(null:-1)"

2017-03-13 Thread Luke Hutchison (JIRA)
Luke Hutchison created FLINK-6028: - Summary: Unnamed operations in main method logged as "main(null:-1)" Key: FLINK-6028 URL: https://issues.apache.org/jira/browse/FLINK-6028 Project: Flink

[jira] [Commented] (FLINK-6026) [Type Inference] Cannot name flatMap operations

2017-03-13 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15907003#comment-15907003 ] Luke Hutchison commented on FLINK-6026: --- This does seem to be a problem limited to f

[jira] [Updated] (FLINK-6019) Some log4j messages do not have a loglevel field set, so they can't be suppressed

2017-03-13 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Hutchison updated FLINK-6019: -- Description: Some of the log messages do not appear to have a loglevel value set, so they can't

[jira] [Updated] (FLINK-6024) Need more fine-grained info for "InvalidProgramException: This type (...) cannot be used as key"

2017-03-13 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Hutchison updated FLINK-6024: -- Description: I got this very confusing exception: {noformat} InvalidProgramException: This type

[jira] [Updated] (FLINK-6016) Newlines should be valid in quoted strings in CSV

2017-03-13 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Hutchison updated FLINK-6016: -- Description: The RFC for the CSV format specifies that newlines are valid in quoted strings in

[jira] [Updated] (FLINK-6026) [Type Inference] Cannot name flatMap operations

2017-03-13 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Hutchison updated FLINK-6026: -- Summary: [Type Inference] Cannot name flatMap operations (was: Cannot name flatMap operations)

[jira] [Updated] (FLINK-6026) Cannot name flatMap operations

2017-03-13 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Hutchison updated FLINK-6026: -- Component/s: Core > Cannot name flatMap operations > -- > >

[jira] [Updated] (FLINK-6026) Cannot name flatMap operations

2017-03-13 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Hutchison updated FLINK-6026: -- Description: I get an error if I try naming a flatMap operation: {code} DataSet> y = x.flatMap(

[jira] [Created] (FLINK-6026) Cannot name flatMap operations

2017-03-13 Thread Luke Hutchison (JIRA)
Luke Hutchison created FLINK-6026: - Summary: Cannot name flatMap operations Key: FLINK-6026 URL: https://issues.apache.org/jira/browse/FLINK-6026 Project: Flink Issue Type: Bug Affects Ve

[jira] [Updated] (FLINK-6026) Cannot name flatMap operations

2017-03-13 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Hutchison updated FLINK-6026: -- Description: I get an error if I try naming a flatMap operation: ``` DataSet> y = x.flatMap((t,

[jira] [Created] (FLINK-6024) Need more fine-grained info for "InvalidProgramException: This type (...) cannot be used as key"

2017-03-10 Thread Luke Hutchison (JIRA)
Luke Hutchison created FLINK-6024: - Summary: Need more fine-grained info for "InvalidProgramException: This type (...) cannot be used as key" Key: FLINK-6024 URL: https://issues.apache.org/jira/browse/FLINK-6024

[jira] [Comment Edited] (FLINK-4785) Flink string parser doesn't handle string fields containing two consecutive double quotes

2017-03-10 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15905779#comment-15905779 ] Luke Hutchison edited comment on FLINK-4785 at 3/10/17 11:48 PM: ---

[jira] [Commented] (FLINK-4785) Flink string parser doesn't handle string fields containing two consecutive double quotes

2017-03-10 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15905779#comment-15905779 ] Luke Hutchison commented on FLINK-4785: --- I'm pretty sure I have seen backslash escap

[jira] [Commented] (FLINK-6017) CSV reader does not support quoted double quotes

2017-03-10 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15905775#comment-15905775 ] Luke Hutchison commented on FLINK-6017: --- Thanks, sorry for the dup! > CSV reader do

[jira] [Commented] (FLINK-6019) Some log4j messages do not have a loglevel field set, so they can't be suppressed

2017-03-10 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904680#comment-15904680 ] Luke Hutchison commented on FLINK-6019: --- Also, these messages do not respond to sett

  1   2   >