[
https://issues.apache.org/jira/browse/FLINK-991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14126446#comment-14126446
]
Mariem Ayadi commented on FLINK-991:
Sure, it makes absolute sense.
But also feel free
[
https://issues.apache.org/jira/browse/FLINK-561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-561.
---
Resolution: Duplicate
Duplicated of FLINK-820
> Usage of multiple print()/data sinks in new Java API
>
[
https://issues.apache.org/jira/browse/FLINK-265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-265:
Priority: Minor (was: Major)
> Improve VM images
> -
>
> Key: FLINK-
[
https://issues.apache.org/jira/browse/FLINK-170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-170:
Priority: Minor (was: Major)
> Introduce manual memory configuration
> -
[
https://issues.apache.org/jira/browse/FLINK-228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-228:
Priority: Trivial (was: Major)
> Evaluate HCatalog
> -
>
> Key: FLIN
[
https://issues.apache.org/jira/browse/FLINK-296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-296:
Priority: Minor (was: Major)
> Integrate graph visualization tab for running jobs
>
[
https://issues.apache.org/jira/browse/FLINK-402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-402:
Priority: Trivial (was: Major)
> ContextChecker should give meaningful error messages
>
[
https://issues.apache.org/jira/browse/FLINK-805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-805:
Priority: Minor (was: Major)
> Early check of output write permissions
> --
[
https://issues.apache.org/jira/browse/FLINK-839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-839:
Priority: Minor (was: Major)
> Add GroupReduceFunction and CoGroupFunction with separate Key
> -
[
https://issues.apache.org/jira/browse/FLINK-766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-766:
Priority: Minor (was: Major)
> Web interface progress monitoring for DataSources and DataSinks with
[
https://issues.apache.org/jira/browse/FLINK-481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-481:
Component/s: Documentation
Priority: Minor (was: Major)
Issue Type: Task (was: Improveme
[
https://issues.apache.org/jira/browse/FLINK-515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-515.
-
Resolution: Won't Fix
FLINK has a new DataSet-based Java API.
The old record-based API will be depr
Github user rmetzger commented on the pull request:
https://github.com/apache/incubator-flink/pull/116#issuecomment-54899708
I think its not your fault that the test failed there. Our tests are using
a lot of memory and most likely the kernel of the travis worker killed the jvm
(oom k
[
https://issues.apache.org/jira/browse/FLINK-538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-538.
-
Resolution: Fixed
Java Examples have been cleaned up some time ago.
Scala examples will be cleaned
[
https://issues.apache.org/jira/browse/FLINK-573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-573:
Priority: Minor (was: Major)
> Clean-up MapOperators in optimizer
>
[
https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-703:
Priority: Trivial (was: Major)
> Use complete element as join key.
> ---
[
https://issues.apache.org/jira/browse/FLINK-650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-650:
Priority: Minor (was: Major)
> Give user functions access to TypeSerializers for their input types?
[
https://issues.apache.org/jira/browse/FLINK-714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-714:
Priority: Minor (was: Major)
Issue Type: New Feature (was: Improvement)
> Allow executing Cas
[
https://issues.apache.org/jira/browse/FLINK-1043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-1043:
-
Priority: Minor (was: Major)
> Alternative combine interface
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-937:
Priority: Minor (was: Major)
> Change the YARN Client to allocate all cluster resources, if no argum
[
https://issues.apache.org/jira/browse/FLINK-983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-983:
Priority: Minor (was: Major)
> WebClient makes names of functions unreadable
> -
[
https://issues.apache.org/jira/browse/FLINK-959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-959:
Priority: Minor (was: Major)
> Automated bare-metal deployment of FLINK on Amazon EC2 and OpenStack
[
https://issues.apache.org/jira/browse/FLINK-915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-915:
Priority: Trivial (was: Major)
> Introduce two in one progress bars
> --
Github user physikerwelt commented on the pull request:
https://github.com/apache/incubator-flink/pull/116#issuecomment-54898739
@rmetzger can you check why the second build fails?
I can not see any connection from the error message
```
/home/travis/build.sh: line 41: 1
[
https://issues.apache.org/jira/browse/FLINK-879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-879:
Priority: Minor (was: Major)
> Allow empty result in cross function call
> -
[
https://issues.apache.org/jira/browse/FLINK-855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-855:
Priority: Trivial (was: Major)
> Web interface: flow vs stack layout
> -
[
https://issues.apache.org/jira/browse/FLINK-992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-992:
Issue Type: New Feature (was: Improvement)
> Create CollectionDataSets by reading (client) local fil
[
https://issues.apache.org/jira/browse/FLINK-512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-512:
Issue Type: New Feature (was: Improvement)
> Add support for Tachyon File System to Flink
>
[
https://issues.apache.org/jira/browse/FLINK-1060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-1060:
-
Issue Type: New Feature (was: Improvement)
> Support explicit shuffling of DataSets
> ---
[
https://issues.apache.org/jira/browse/FLINK-1038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-1038:
-
Issue Type: New Feature (was: Improvement)
> Adding a collection output format
>
[
https://issues.apache.org/jira/browse/FLINK-228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-228:
Issue Type: Task (was: Improvement)
> Evaluate HCatalog
> -
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-612:
Issue Type: New Feature (was: Improvement)
> Add Java 8 Lambda support to new Java API
> ---
[
https://issues.apache.org/jira/browse/FLINK-378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-378:
Priority: Minor (was: Major)
Issue Type: New Feature (was: Improvement)
> Add Java UDF Code a
[
https://issues.apache.org/jira/browse/FLINK-758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-758:
Issue Type: New Feature (was: Improvement)
> Add count method to DataSet and implement CountOperator
[
https://issues.apache.org/jira/browse/FLINK-456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-456:
Priority: Minor (was: Major)
Issue Type: New Feature (was: Improvement)
> Optional runtime st
[
https://issues.apache.org/jira/browse/FLINK-685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-685:
Issue Type: New Feature (was: Improvement)
> Add support for semi-joins
> --
[
https://issues.apache.org/jira/browse/FLINK-671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-671:
Issue Type: New Feature (was: Improvement)
> Python interface for new API (Map/Reduce)
> ---
[
https://issues.apache.org/jira/browse/FLINK-687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-687:
Issue Type: New Feature (was: Improvement)
> Add support for outer-joins
> -
[
https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-7:
--
Issue Type: New Feature (was: Improvement)
> [GitHub] Enable Range Partitioner
> -
[
https://issues.apache.org/jira/browse/FLINK-873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-873:
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-641
> Aligned the Scala KMeans with th
Github user physikerwelt commented on the pull request:
https://github.com/apache/incubator-flink/pull/116#issuecomment-54889111
... oh I did not realize that there is a tests concerning this feature...
---
If your project is set up for it, you can reply to this email and have your
r
Github user StephanEwen commented on the pull request:
https://github.com/apache/incubator-flink/pull/116#issuecomment-54886421
That seems reasonable.
+1
---
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 pr
GitHub user physikerwelt opened a pull request:
https://github.com/apache/incubator-flink/pull/116
Remove naive verification of tuple size
This verification will not work.
Think of spaces or escaped ?
I think it's easier for users to parse the SQLException
You can merge this
[
https://issues.apache.org/jira/browse/FLINK-1062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14125928#comment-14125928
]
Stephan Ewen commented on FLINK-1062:
-
One possible variant would be to use the JDT co
[
https://issues.apache.org/jira/browse/FLINK-1062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14125833#comment-14125833
]
Stephan Ewen commented on FLINK-1062:
-
I can confirm that. Works only with the Eclipse
Github user aljoscha commented on the pull request:
https://github.com/apache/incubator-flink/pull/113#issuecomment-54850915
This approach only works when using the Eclipse Java compiler. When using
javac, which maven and intellij use, the generic type information is not
preserved.
[
https://issues.apache.org/jira/browse/FLINK-1062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14125745#comment-14125745
]
ASF GitHub Bot commented on FLINK-1062:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-796:
Component/s: Documentation
Description:
Imported from GitHub
U
[
https://issues.apache.org/jira/browse/FLINK-787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-787:
Priority: Minor (was: Major)
Issue Type: Improvement (was: Bug)
> Custom termination criterio
[
https://issues.apache.org/jira/browse/FLINK-880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-880.
-
Resolution: Fixed
The example program works with the current master.
So the issue was fixed someho
[
https://issues.apache.org/jira/browse/FLINK-1027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-1027:
-
Issue Type: Improvement (was: Bug)
> CLI "run" command does not support flags
> -
[
https://issues.apache.org/jira/browse/FLINK-894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-894.
---
Resolution: Duplicate
The Java examples have been completely reworked some time ago.
Scala examples wil
[
https://issues.apache.org/jira/browse/FLINK-931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-931.
---
Resolution: Not a Problem
Our build and test time signficantly improved. Therefore, I close this issue.
[
https://issues.apache.org/jira/browse/FLINK-37?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-37:
---
Priority: Minor (was: Major)
Issue Type: Improvement (was: Bug)
> [GitHub] Enable visualization
[
https://issues.apache.org/jira/browse/FLINK-146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-146:
Component/s: Scala API
Java API
Description:
The new Java API does not allow to
[
https://issues.apache.org/jira/browse/FLINK-705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-705:
Priority: Minor (was: Major)
Issue Type: Task (was: Bug)
> Check if TPC-H resources can be ad
[
https://issues.apache.org/jira/browse/FLINK-823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-823:
Issue Type: Improvement (was: Bug)
> Improve Semantic Annotations
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-555:
Priority: Minor (was: Major)
Issue Type: Improvement (was: Bug)
> debian: add /usr/share/stra
[
https://issues.apache.org/jira/browse/FLINK-169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-169:
Priority: Minor (was: Major)
Issue Type: Improvement (was: Bug)
> Re-design ContextChecker
>
[
https://issues.apache.org/jira/browse/FLINK-441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-441:
Priority: Minor (was: Major)
Issue Type: Improvement (was: Bug)
> Renaming in pact-compiler
>
[
https://issues.apache.org/jira/browse/FLINK-430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-430:
Priority: Minor (was: Major)
Issue Type: Improvement (was: Bug)
> Provide a simple way of par
[
https://issues.apache.org/jira/browse/FLINK-449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-449.
-
Resolution: Fixed
Has been resolved some time ago.
> Introduce System Config Parameters for File O
[
https://issues.apache.org/jira/browse/FLINK-454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-454:
Priority: Minor (was: Major)
> Add ProgramInput/OutputFormats
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-507:
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-641
> Clean up Scala Examples
> --
[
https://issues.apache.org/jira/browse/FLINK-788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-788:
Issue Type: Improvement (was: Bug)
> Enable combiner for Reduce with Broadcast Variable
> --
[
https://issues.apache.org/jira/browse/FLINK-369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-369.
-
Resolution: Fixed
Has been fixed somewhere on the way of improving the web submission client.
> Ad
[
https://issues.apache.org/jira/browse/FLINK-128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-128.
---
Resolution: Duplicate
Will be fixed with FLINK-1005
> Duplicate keys after chained reducers
>
[
https://issues.apache.org/jira/browse/FLINK-742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-742.
---
Resolution: Not a Problem
> inputsplits organization
> -
>
> K
[
https://issues.apache.org/jira/browse/FLINK-509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-509:
Priority: Minor (was: Major)
Issue Type: Improvement (was: Bug)
> Move virtual machines build
[
https://issues.apache.org/jira/browse/FLINK-138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-138.
---
Resolution: Duplicate
Duplicate of FLINK-146
> WordCount total ordering not working?
> ---
[
https://issues.apache.org/jira/browse/FLINK-168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-168.
-
Resolution: Fixed
This has been implemented for the new Java API some time ago.
For the Scala API,
[
https://issues.apache.org/jira/browse/FLINK-991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14125628#comment-14125628
]
Fabian Hueske commented on FLINK-991:
-
Thanks Mariem!
This should only be delayed unti
[
https://issues.apache.org/jira/browse/FLINK-925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-925.
-
Resolution: Fixed
Fixed by 122c9b023cc5f9fcd5cb4914bd90afde0b3c6fc0
Thanks!
> Support KeySelector
[
https://issues.apache.org/jira/browse/FLINK-67?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-67:
---
Priority: Minor (was: Major)
Issue Type: Improvement (was: Bug)
> Add HBase Tests
>
[
https://issues.apache.org/jira/browse/FLINK-925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14125523#comment-14125523
]
ASF GitHub Bot commented on FLINK-925:
--
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-flink/pull/59
---
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 feature
enabled and wishes so, or if the feature
[
https://issues.apache.org/jira/browse/FLINK-827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-827:
Priority: Minor (was: Major)
Issue Type: Improvement (was: Bug)
> Add Java example program wi
[
https://issues.apache.org/jira/browse/FLINK-1032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-1032:
-
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-908
> Extend POJO Field Selectors t
[
https://issues.apache.org/jira/browse/FLINK-991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14125517#comment-14125517
]
Mariem Ayadi commented on FLINK-991:
Hey Fabian.
I just changed the assignee setting fo
[
https://issues.apache.org/jira/browse/FLINK-991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mariem Ayadi updated FLINK-991:
---
Assignee: (was: Mariem Ayadi)
> Add documentation for POJO expression keys
> --
[
https://issues.apache.org/jira/browse/FLINK-986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14125507#comment-14125507
]
Alexander Alexandrov commented on FLINK-986:
I didn't think about recovery. I g
[
https://issues.apache.org/jira/browse/FLINK-991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-991:
Issue Type: Sub-task (was: Bug)
Parent: FLINK-908
> Add documentation for POJO expression ke
[
https://issues.apache.org/jira/browse/FLINK-908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reopened FLINK-908:
-
Assignee: Robert Metzger (was: Aljoscha Krettek)
POJO expression keys been disabled for the 0.6
[
https://issues.apache.org/jira/browse/FLINK-403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-403:
Issue Type: Sub-task (was: Bug)
Parent: FLINK-641
> Support for Hadoop Types in Java/Scala
>
[
https://issues.apache.org/jira/browse/FLINK-1055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14125468#comment-14125468
]
Jonathan Hasenburg commented on FLINK-1055:
---
Hi Robert,
what exactly do you mea
[
https://issues.apache.org/jira/browse/FLINK-1082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jonathan Hasenburg updated FLINK-1082:
--
Description:
New Issue to summarize all things that should be done regarding the webclie
[
https://issues.apache.org/jira/browse/FLINK-1062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14125439#comment-14125439
]
ASF GitHub Bot commented on FLINK-1062:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/incubator-flink/pull/113#issuecomment-54808599
An improvement here could be to unify the detection whether a UDF is a
lambda, and the type extraction. Right now, we look up the `writeReplace`
method and c
[
https://issues.apache.org/jira/browse/FLINK-1062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14125437#comment-14125437
]
ASF GitHub Bot commented on FLINK-1062:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/incubator-flink/pull/113#discussion_r17233691
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/util/FunctionUtils.java
---
@@ -84,4 +84,66 @@ public static boolean is
[
https://issues.apache.org/jira/browse/FLINK-1027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14125432#comment-14125432
]
Moritz Schubotz edited comment on FLINK-1027 at 9/8/14 11:58 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-1027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14125432#comment-14125432
]
Moritz Schubotz commented on FLINK-1027:
I think a good place to start looking at
Github user StephanEwen commented on the pull request:
https://github.com/apache/incubator-flink/pull/63#issuecomment-54807258
Bear in mind that the count will be given for free also when the
first-class handling of intermediate results is merged.
---
If your project is set up for it
[
https://issues.apache.org/jira/browse/FLINK-758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14125429#comment-14125429
]
ASF GitHub Bot commented on FLINK-758:
--
Github user StephanEwen commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14125427#comment-14125427
]
Stephan Ewen commented on FLINK-986:
I think that is beyond the scope of our immediate
[
https://issues.apache.org/jira/browse/FLINK-1091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14125424#comment-14125424
]
Stephan Ewen commented on FLINK-1091:
-
I think we should make this a part of the Delta
[
https://issues.apache.org/jira/browse/FLINK-1091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-1091:
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-1092
> Allow joins with the solution
[
https://issues.apache.org/jira/browse/FLINK-1091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-1091:
Comment: was deleted
(was: The rational behind that decision was that, in order to access a
partiti
[
https://issues.apache.org/jira/browse/FLINK-1092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14125422#comment-14125422
]
Stephan Ewen commented on FLINK-1092:
-
The rational behind that decision was that, in
Github user StephanEwen commented on the pull request:
https://github.com/apache/incubator-flink/pull/94#issuecomment-54805389
Sorry for the late answer. This is nice work!
We are also working on a deep integration of shipping results (also
temporary intermediate results) back
1 - 100 of 110 matches
Mail list logo
