[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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:
[
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
[
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
[
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
[
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
[
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
[
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
[
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:
-
[
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
[
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
[
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
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
[
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
[
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:
[
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
[
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
[
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
[
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:
[
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:
[
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
[
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,
[
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
[
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
[
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
[
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 {
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
[
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
[
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
[
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
[
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
[
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:
[
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:
---
[
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
[
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
[
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
[
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:
---
[
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
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
[
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:
[
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:
[
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
[
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:
[
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
[
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
[
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
[
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
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
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
[
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
[
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
[
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
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
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
[
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
{
[
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
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
[
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
> -
[
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
[
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
> --
[
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
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
[
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:
[
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
[
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
[
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
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
[
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
[
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
[
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
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
[
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
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
[
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
[
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
[
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
[
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
[
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)
[
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
> --
>
>
[
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(
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
[
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,
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
[
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:
---
[
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
[
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
[
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 - 100 of 106 matches
Mail list logo