[
https://issues.apache.org/jira/browse/FLINK-3680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jamie Grier updated FLINK-3680:
---
Attachment: Screen Shot 2016-03-29 at 8.12.17 PM.png
Screen Shot 2016-03-29 at 8.13.12
Jamie Grier created FLINK-3680:
--
Summary: Remove or improve (not set) text in the Job Plan UI
Key: FLINK-3680
URL: https://issues.apache.org/jira/browse/FLINK-3680
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-2998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15217301#comment-15217301
]
ASF GitHub Bot commented on FLINK-2998:
---
Github user gallenvara commented on the pul
Github user gallenvara commented on the pull request:
https://github.com/apache/flink/pull/1838#issuecomment-203216796
@fhueske @ChengXiangLi Can you please help with review? :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as w
[
https://issues.apache.org/jira/browse/FLINK-2998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15217300#comment-15217300
]
ASF GitHub Bot commented on FLINK-2998:
---
GitHub user gallenvara opened a pull reques
GitHub user gallenvara opened a pull request:
https://github.com/apache/flink/pull/1838
[FLINK-2998] Support range partition comparison for multi input nodes.
The PR implements range partition comparison in operation such as join and
cogroup for multi inputs, now optimizer can optim
[
https://issues.apache.org/jira/browse/FLINK-3670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15217092#comment-15217092
]
Eron Wright edited comment on FLINK-3670 at 3/29/16 11:57 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-3670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15217092#comment-15217092
]
Eron Wright commented on FLINK-3670:
-
Another possibility worth considering is to lev
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15217029#comment-15217029
]
ASF GitHub Bot commented on FLINK-3579:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1821#discussion_r57815729
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/expressions/ExpressionParser.scala
---
@@ -116,7 +118,18 @@ object Expression
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216998#comment-15216998
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1517#issuecomment-203143579
Thanks for doing these experiments! The results are quite convincing. I'm
currently on vacation and will be back in about a week.
---
If your project is set up for it,
[
https://issues.apache.org/jira/browse/FLINK-3673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216988#comment-15216988
]
Fabian Hueske commented on FLINK-3673:
--
Hi [~horvgab], can you add more detail about
Jamie Grier created FLINK-3679:
--
Summary: DeserializationSchema should handle zero or more outputs
for every input
Key: FLINK-3679
URL: https://issues.apache.org/jira/browse/FLINK-3679
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216749#comment-15216749
]
ASF GitHub Bot commented on FLINK-2157:
---
Github user thvasilo commented on the pull
Github user thvasilo commented on the pull request:
https://github.com/apache/flink/pull/871#issuecomment-203075630
@rawkintrevo AFAIK it's lack of time from a commiter to review it. If
@tillrohrmann can find some time to review this I'll refactor it to get rid of
the conflicts and h
[
https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216721#comment-15216721
]
ASF GitHub Bot commented on FLINK-2157:
---
Github user rawkintrevo commented on the pu
Github user rawkintrevo commented on the pull request:
https://github.com/apache/flink/pull/871#issuecomment-203067582
Continued from mailing list: Till already mentioned that having Rsquared
built in to MLR was just a convenience method, it's not good for a number of
reasons in prac
[
https://issues.apache.org/jira/browse/FLINK-3678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216397#comment-15216397
]
ASF GitHub Bot commented on FLINK-3678:
---
GitHub user stefanobaghino opened a pull re
GitHub user stefanobaghino opened a pull request:
https://github.com/apache/flink/pull/1837
[FLINK-3678] Make Flink logs directory configurable
* Edit config.sh
* Document the newly defined log directory configuration key
You can merge this pull request into a Git repository by
[
https://issues.apache.org/jira/browse/FLINK-3651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216361#comment-15216361
]
ASF GitHub Bot commented on FLINK-3651:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-3651.
--
Resolution: Fixed
Fix Version/s: 1.0.1
1.1.0
Fixed in 580a177 (master), 208902
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1830
---
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 is enab
[
https://issues.apache.org/jira/browse/FLINK-3651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216351#comment-15216351
]
ASF GitHub Bot commented on FLINK-3651:
---
Github user uce commented on the pull reque
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1830#issuecomment-203004909
I'm going to merge this to `master` and `release-1.0`.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If you
Stefano Baghino created FLINK-3678:
--
Summary: Make Flink logs directory configurable
Key: FLINK-3678
URL: https://issues.apache.org/jira/browse/FLINK-3678
Project: Flink
Issue Type: Improvem
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216289#comment-15216289
]
Maximilian Michels commented on FLINK-3677:
---
Linked FLINK-3655 which is related
Maximilian Michels created FLINK-3677:
-
Summary: FileInputFormat: Allow to specify include/exclude file
name patterns
Key: FLINK-3677
URL: https://issues.apache.org/jira/browse/FLINK-3677
Project:
[
https://issues.apache.org/jira/browse/FLINK-3667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216222#comment-15216222
]
Maximilian Michels commented on FLINK-3667:
---
+1 Makes sense to convert the {{Cli
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1834#issuecomment-202964440
Looks good.
Is this a Kafka-only util?
---
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
[
https://issues.apache.org/jira/browse/FLINK-3524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216193#comment-15216193
]
ASF GitHub Bot commented on FLINK-3524:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-3676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-3676.
-
Resolution: Fixed
master: 875cb448d7407687402eec15c77c24683c2d5c56
release-1.0: 875cb448d7
Maximilian Michels created FLINK-3676:
-
Summary: WebClient hasn't been removed from the docs
Key: FLINK-3676
URL: https://issues.apache.org/jira/browse/FLINK-3676
Project: Flink
Issue Typ
Stefano Baghino created FLINK-3675:
--
Summary: YARN ship folder incosistent behavior
Key: FLINK-3675
URL: https://issues.apache.org/jira/browse/FLINK-3675
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15215928#comment-15215928
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user aalexandrov commented on the pu
Github user aalexandrov commented on the pull request:
https://github.com/apache/flink/pull/1517#issuecomment-202868272
Overall it seems that the hash-based combiner works better than the
sort-based one for (a) uniform, or normal key distribution, and (b)
fixed-length records.
[
https://issues.apache.org/jira/browse/FLINK-3667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15215927#comment-15215927
]
Stephan Ewen commented on FLINK-3667:
-
Sounds good! Here are some thoughts I had when
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15215916#comment-15215916
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user aalexandrov commented on the pu
Github user aalexandrov commented on the pull request:
https://github.com/apache/flink/pull/1517#issuecomment-202864630
@fhueske We have used the Easter break to conduct the experiments. A
preliminary writeup is in the Google Doc. @ggevay will provide the results
analysis later today.
[
https://issues.apache.org/jira/browse/FLINK-3547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-3547.
--
Resolution: Implemented
Fix Version/s: 1.1.0
> Add support for streaming projection, sele
[
https://issues.apache.org/jira/browse/FLINK-3547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15215848#comment-15215848
]
ASF GitHub Bot commented on FLINK-3547:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1820
---
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 is enab
[
https://issues.apache.org/jira/browse/FLINK-3545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-3545.
-
Resolution: Implemented
Implemented in 4405235e5483d3e4ad94f4ba31627aa852580042.
> Resour
[
https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-3544.
-
Resolution: Implemented
Implemented in 92ff2b152cac3ad6a53373c0c022579306051133.
> Resour
[
https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15215832#comment-15215832
]
ASF GitHub Bot commented on FLINK-3544:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1741
---
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 is enab
Stephan Ewen created FLINK-3674:
---
Summary: Add an interface for EventTime aware User Function
Key: FLINK-3674
URL: https://issues.apache.org/jira/browse/FLINK-3674
Project: Flink
Issue Type: Ne
Gabor Horvath created FLINK-3673:
Summary: Annotations for code generation
Key: FLINK-3673
URL: https://issues.apache.org/jira/browse/FLINK-3673
Project: Flink
Issue Type: Sub-task
Gabor Horvath created FLINK-3672:
Summary: Code generation for POJO comparators
Key: FLINK-3672
URL: https://issues.apache.org/jira/browse/FLINK-3672
Project: Flink
Issue Type: Sub-task
Gabor Horvath created FLINK-3671:
Summary: Code generation for POJO serializer
Key: FLINK-3671
URL: https://issues.apache.org/jira/browse/FLINK-3671
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15215795#comment-15215795
]
ASF GitHub Bot commented on FLINK-3579:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1821#issuecomment-202819063
As far as I can tell the changes look good. I had some inline comments
where I'm not sure whether the implementation is exhaustive.
---
If your project is set up f
[
https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15215789#comment-15215789
]
ASF GitHub Bot commented on FLINK-3257:
---
Github user senorcarbone commented on the p
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15215791#comment-15215791
]
ASF GitHub Bot commented on FLINK-3579:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1821#discussion_r57699432
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/table/test/StringExpressionsITCase.java
---
@@ -121,6 +120,66 @@ public vo
Github user senorcarbone commented on the pull request:
https://github.com/apache/flink/pull/1668#issuecomment-202818056
Thanks @StephanEwen and @uce for looking into it! I really appreciate it.
How about the following:
1. I update this PR with the patch that uses ListState an
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15215786#comment-15215786
]
ASF GitHub Bot commented on FLINK-3579:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1821#discussion_r57699238
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/RexNodeTranslator.scala
---
@@ -134,7 +136,13 @@ object RexNodeTran
[
https://issues.apache.org/jira/browse/FLINK-3547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15215784#comment-15215784
]
ASF GitHub Bot commented on FLINK-3547:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1820#issuecomment-202816038
merging 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 this feature
ena
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15215781#comment-15215781
]
ASF GitHub Bot commented on FLINK-3579:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15215780#comment-15215780
]
ASF GitHub Bot commented on FLINK-3579:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1821#discussion_r57699015
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/expressions/ExpressionParser.scala
---
@@ -116,7 +118,18 @@ object Expre
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1821#discussion_r57698940
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/expressions/ExpressionParser.scala
---
@@ -116,7 +118,18 @@ object Expre
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15215779#comment-15215779
]
ASF GitHub Bot commented on FLINK-3579:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1821#discussion_r57698703
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/expressions/ExpressionParser.scala
---
@@ -59,6 +59,8 @@ object Expressi
[
https://issues.apache.org/jira/browse/FLINK-3651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15215721#comment-15215721
]
ASF GitHub Bot commented on FLINK-3651:
---
Github user uce commented on the pull reque
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1830#issuecomment-202794232
OK, depending on whether it is feasible to test this separately, I would go
ahead and merge it as is or add a test and merge then. :+1:
---
If your project is set up for it
Maximilian Michels created FLINK-3670:
-
Summary: Kerberos: Improving long-running streaming jobs
Key: FLINK-3670
URL: https://issues.apache.org/jira/browse/FLINK-3670
Project: Flink
Issue
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1704#issuecomment-202778390
Sounds great @stefanobaghino. I think you can push your work to this PR as
well since it is all related to the partial function support. Looking forward
having part
[
https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15215685#comment-15215685
]
ASF GitHub Bot commented on FLINK-1159:
---
Github user tillrohrmann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15215684#comment-15215684
]
Till Rohrmann commented on FLINK-3650:
--
Sure you can work on this [~ram_krish]. It is
72 matches
Mail list logo
