[
https://issues.apache.org/jira/browse/FLINK-1987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537695#comment-14537695
]
ASF GitHub Bot commented on FLINK-1987:
---
Github user mxm commented on the pull
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/662#issuecomment-100805034
+1 links work again
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
[
https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537696#comment-14537696
]
ASF GitHub Bot commented on FLINK-1525:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/664#issuecomment-100805130
In Hadoop, the `UserConfig` would probably be a `Configuration` object with
key/value pairs.
In Flink, we are trying to get rid of these untyped maps.
Instead, I
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537797#comment-14537797
]
PJ Van Aeken edited comment on FLINK-1962 at 5/11/15 10:33 AM:
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537797#comment-14537797
]
PJ Van Aeken commented on FLINK-1962:
-
The combination of both pull requests did the
[
https://issues.apache.org/jira/browse/FLINK-1636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-1636:
---
Priority: Major (was: Minor)
Improve error handling when partitions not found
[
https://issues.apache.org/jira/browse/FLINK-1999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537822#comment-14537822
]
Ronny Bräunlich commented on FLINK-1999:
Are you sure that the input type should
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537797#comment-14537797
]
PJ Van Aeken edited comment on FLINK-1962 at 5/11/15 11:30 AM:
Github user thvasilo commented on the pull request:
https://github.com/apache/flink/pull/656#issuecomment-100884364
Thank you Johaness. The optimization code has been merged to the master
now, so could you rebase your branch to the latest master so we can look at the
changes in an
[
https://issues.apache.org/jira/browse/FLINK-1959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Alexandrov updated FLINK-1959:
Affects Version/s: (was: 0.8.1)
master
Fix
[
https://issues.apache.org/jira/browse/FLINK-1537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1537:
--
Component/s: Machine Learning Library
GSoC project: Machine learning with Apache Flink
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/664#issuecomment-100882340
I agree, however it should be optional. I don't like these tools where you
spend a lot of time registering / specifying arguments.
People want to analyze their data,
[
https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537880#comment-14537880
]
ASF GitHub Bot commented on FLINK-1525:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537888#comment-14537888
]
Felix Neutatz commented on FLINK-1999:
--
When I understand it correctly, it is like
[
https://issues.apache.org/jira/browse/FLINK-1103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537896#comment-14537896
]
Robert Metzger commented on FLINK-1103:
---
The data has been replaced by something we
[
https://issues.apache.org/jira/browse/FLINK-1999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537853#comment-14537853
]
Alexander Alexandrov commented on FLINK-1999:
-
What does a Seq[String]
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/664#issuecomment-100880185
I like it. But I think it needs some functionality for verifying
parameters. To let the user specify some parameters that always need to be
there and a description of
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/664#issuecomment-100891653
Thank you.
I didn't reuse the parser there because there is an ongoing JIRA to unify
all the command line parsers inside Flink. It seems that we are using at least
[
https://issues.apache.org/jira/browse/FLINK-1874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1874:
--
Component/s: Streaming
Break up streaming connectors into submodules
[
https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537842#comment-14537842
]
ASF GitHub Bot commented on FLINK-1525:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537845#comment-14537845
]
Alexander Alexandrov commented on FLINK-1959:
-
I think that some communication
[
https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537847#comment-14537847
]
ASF GitHub Bot commented on FLINK-1525:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537855#comment-14537855
]
ASF GitHub Bot commented on FLINK-1979:
---
Github user thvasilo commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537878#comment-14537878
]
ASF GitHub Bot commented on FLINK-1525:
---
Github user mxm commented on the pull
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/664#issuecomment-100891261
Very helpful utility. I think it's worth adapting all the examples if we
merge this. Removes a lot of unnecessary code and makes the examples more
readable.
May I
[
https://issues.apache.org/jira/browse/FLINK-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537886#comment-14537886
]
Theodore Vasiloudis commented on FLINK-1807:
[~till.rohrmann] You think we can
[
https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537909#comment-14537909
]
ASF GitHub Bot commented on FLINK-1525:
---
Github user mxm commented on the pull
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/664#issuecomment-100897320
Thanks for clarifying. I agree that the parser in Apache Commons is not the
nicest...
---
If your project is set up for it, you can reply to this email and have your
reply
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537938#comment-14537938
]
Aljoscha Krettek commented on FLINK-1962:
-
Yes, this is correct, because the Java
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/664#issuecomment-100917520
If this tool also supported positional arguments ...
I also though about adding those, but decided against it, because args[n]
is already a way of accessing
[
https://issues.apache.org/jira/browse/FLINK-1964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537922#comment-14537922
]
ASF GitHub Bot commented on FLINK-1964:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/666#issuecomment-100902145
Hey,
thank you for working on this opening a pull request.
I'll address your comments inline:
put the default value for queueSize attribute in a
[
https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537958#comment-14537958
]
ASF GitHub Bot commented on FLINK-1525:
---
Github user rmetzger commented on the pull
GitHub user chhao01 opened a pull request:
https://github.com/apache/flink/pull/667
[FLINK-1990] [staging table] Support upper case of `as` for expression
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/chhao01/flink as
[
https://issues.apache.org/jira/browse/FLINK-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538015#comment-14538015
]
ASF GitHub Bot commented on FLINK-1990:
---
GitHub user chhao01 opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538018#comment-14538018
]
Aljoscha Krettek commented on FLINK-1962:
-
Yes, because the Scala type analysis
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/667#issuecomment-100940455
Thanks for your contribution!
Could you maybe enhance it along these lines:
http://stackoverflow.com/questions/6080437/case-insensitive-scala-parser-combinator
[
https://issues.apache.org/jira/browse/FLINK-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538026#comment-14538026
]
ASF GitHub Bot commented on FLINK-1990:
---
Github user aljoscha commented on the pull
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/664#issuecomment-100941805
Thanks for clarifying, Robert.
I think convention to expect *Util classes to just contain static methods
instead of being created as an instance.
Maybe we
[
https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538035#comment-14538035
]
ASF GitHub Bot commented on FLINK-1525:
---
Github user hsaputra commented on the pull
Github user chhao01 commented on the pull request:
https://github.com/apache/flink/pull/667#issuecomment-100943527
Thanks for the quick response, I was not sure which is suppose to be. Since
it's case-insensitive, I will update the code with unit test soon.
Yes, I am
[
https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537984#comment-14537984
]
ASF GitHub Bot commented on FLINK-1525:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537997#comment-14537997
]
Cheng Hao commented on FLINK-1990:
--
What if the aggregate functions? e.g. sum / SUM ?
[
https://issues.apache.org/jira/browse/FLINK-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537997#comment-14537997
]
Cheng Hao edited comment on FLINK-1990 at 5/11/15 2:50 PM:
---
What
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537998#comment-14537998
]
Vasia Kalavri commented on FLINK-1962:
--
We chose Tuples for performance and
Github user hsaputra commented on a diff in the pull request:
https://github.com/apache/flink/pull/664#discussion_r30046159
--- Diff:
flink-examples/flink-java-examples/src/main/java/org/apache/flink/examples/java/wordcount/PojoExample.java
---
@@ -26,6 +26,7 @@
import
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/664#issuecomment-100923321
@aljoscha:
Is this the API you were thinking of?
```java
RequiredParameters required = new RequiredParameters();
Option input =
[
https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14537975#comment-14537975
]
ASF GitHub Bot commented on FLINK-1525:
---
Github user rmetzger commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/664#issuecomment-100926127
Yes, something like this.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
[
https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538004#comment-14538004
]
ASF GitHub Bot commented on FLINK-1525:
---
Github user hsaputra commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538041#comment-14538041
]
ASF GitHub Bot commented on FLINK-1990:
---
Github user chhao01 commented on the pull
Aljoscha Krettek created FLINK-2000:
---
Summary: Add SQL-style aggregations for Table API
Key: FLINK-2000
URL: https://issues.apache.org/jira/browse/FLINK-2000
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538069#comment-14538069
]
ASF GitHub Bot commented on FLINK-1990:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/667#issuecomment-100950435
I created this issue for the aggregations:
https://issues.apache.org/jira/browse/FLINK-2000. I think I can only assign you
if you have a Jira account. Do you have one?
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/659#issuecomment-100953248
I think I addressed all the (reasonable) comments you made? The user facing
API does not change in any way from this and I tried to pick consistent names
for the
[
https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538077#comment-14538077
]
ASF GitHub Bot commented on FLINK-1977:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538366#comment-14538366
]
ASF GitHub Bot commented on FLINK-1676:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-1989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538407#comment-14538407
]
Aljoscha Krettek commented on FLINK-1989:
-
I could rework the code generation to
[
https://issues.apache.org/jira/browse/FLINK-1996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538490#comment-14538490
]
Aljoscha Krettek commented on FLINK-1996:
-
I would say so, yes.
Add output
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/658#issuecomment-101024456
Looks good. One comment, though:
- The position tracking in the stream wrapper is a nice idea, but since
the `skip()` method is anyways only a hint (it may skip
[
https://issues.apache.org/jira/browse/FLINK-1996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-1996:
Assignee: (was: Aljoscha Krettek)
Add output methods to Table API
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/660#issuecomment-101000540
Does the Scala API not treat Java classes the same way as its own classes?
That sounds absolutely like the right thing to do. Why not do as much
compile time
[
https://issues.apache.org/jira/browse/FLINK-1980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538747#comment-14538747
]
ASF GitHub Bot commented on FLINK-1980:
---
Github user sekruse commented on the pull
Github user sekruse commented on the pull request:
https://github.com/apache/flink/pull/658#issuecomment-101064479
I wanted to integrate the gz support with the decorateStream method,
therefore I was waiting for this PR to be merged.
I can of course skip the seek, but I thought
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/473#issuecomment-101010857
I maintain one comment, but I am not blocking this. Feel free to merge...
---
If your project is set up for it, you can reply to this email and have your
reply
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/473#discussion_r30067549
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/typeutils/PojoTypeInfo.java
---
@@ -313,6 +319,15 @@ public int getFieldIndex(String
[
https://issues.apache.org/jira/browse/FLINK-1676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538370#comment-14538370
]
ASF GitHub Bot commented on FLINK-1676:
---
Github user StephanEwen commented on the
[
https://issues.apache.org/jira/browse/FLINK-1996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538457#comment-14538457
]
Stephan Ewen commented on FLINK-1996:
-
Does this make a good starter issue?
Add
[
https://issues.apache.org/jira/browse/FLINK-1996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538456#comment-14538456
]
Stephan Ewen commented on FLINK-1996:
-
I think it may actually be worth adding those
[
https://issues.apache.org/jira/browse/FLINK-1980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538486#comment-14538486
]
ASF GitHub Bot commented on FLINK-1980:
---
Github user StephanEwen commented on the
[
https://issues.apache.org/jira/browse/FLINK-1980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538497#comment-14538497
]
ASF GitHub Bot commented on FLINK-1980:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/658#issuecomment-101026234
I think Sebastian has already filed a JIRA for adding gz read support.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-1968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1968.
-
Resolution: Fixed
Fixed via 1c8d866a83065e3d1bc9707dab81117f24c9f678
Make Distributed Cache
[
https://issues.apache.org/jira/browse/FLINK-1968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-1968.
---
Make Distributed Cache more robust
--
Key: FLINK-1968
[
https://issues.apache.org/jira/browse/FLINK-1874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538556#comment-14538556
]
Stephan Ewen commented on FLINK-1874:
-
I think we are about to merge the biggest
[
https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538574#comment-14538574
]
ASF GitHub Bot commented on FLINK-1525:
---
Github user StephanEwen commented on the
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/664#issuecomment-101035060
Nice idea. Do we need the special `UserConfig` interface, or can we use a
`Properties` object, or a directly a `MapString, String`?
---
If your project is set up
[
https://issues.apache.org/jira/browse/FLINK-1672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1672.
-
Resolution: Fixed
Fix Version/s: 0.9
Assignee: Stephan Ewen
Implemented in
[
https://issues.apache.org/jira/browse/FLINK-1969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1969.
-
Resolution: Done
Done in fbea2da26d01c470687a5ad217a5fd6ad1de89e4
Remove old profile code
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538622#comment-14538622
]
Vasia Kalavri commented on FLINK-1962:
--
It would be great if we could somehow
[
https://issues.apache.org/jira/browse/FLINK-1959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538540#comment-14538540
]
Stephan Ewen commented on FLINK-1959:
-
I will try and look into this very soon...
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538571#comment-14538571
]
Stephan Ewen commented on FLINK-1962:
-
This seems like a flaw in the Scala Type
[
https://issues.apache.org/jira/browse/FLINK-1969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-1969.
---
Remove old profile code
---
Key: FLINK-1969
URL:
[
https://issues.apache.org/jira/browse/FLINK-1672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-1672.
---
Refactor task registration/unregistration
-
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/537#issuecomment-101048928
Hey @andralungu ,
I built on your changes and implemented what I described above. I have
pushed in [this
[
https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538662#comment-14538662
]
ASF GitHub Bot commented on FLINK-1523:
---
Github user vasia commented on the pull
Chiwan Park created FLINK-2001:
--
Summary: DistanceMetric cannot be serialized
Key: FLINK-2001
URL: https://issues.apache.org/jira/browse/FLINK-2001
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-1986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538328#comment-14538328
]
Stephan Ewen commented on FLINK-1986:
-
[~gyfora] and [~senorcarbone] Are you using
[
https://issues.apache.org/jira/browse/FLINK-1989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538348#comment-14538348
]
Stephan Ewen commented on FLINK-1989:
-
Storing the type information breaks with the
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/570#issuecomment-100996059
I had a look at the pull request and I like very much what it tries to do.
The problem right now is that I can hardly say without investing a lot of
time
[
https://issues.apache.org/jira/browse/FLINK-1983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538180#comment-14538180
]
Stephan Ewen commented on FLINK-1983:
-
This seems doable without implications.
[
https://issues.apache.org/jira/browse/FLINK-1982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538253#comment-14538253
]
Henry Saputra commented on FLINK-1982:
--
Thanks [~StephanEwen] !
As for terasort
[
https://issues.apache.org/jira/browse/FLINK-1982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538156#comment-14538156
]
Stephan Ewen commented on FLINK-1982:
-
I think the runtime and optimizer
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/660#issuecomment-100999172
Seems to contain a second fix, to skip static fields in data types.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14538269#comment-14538269
]
ASF GitHub Bot commented on FLINK-951:
--
Github user StephanEwen commented on the pull
96 matches
Mail list logo
