[
https://issues.apache.org/jira/browse/FLINK-3116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jun aoki reassigned FLINK-3116:
---
Assignee: jun aoki
> Remove RecordOperator
> -
>
> Key: FLINK-311
[
https://issues.apache.org/jira/browse/FLINK-2978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15043388#comment-15043388
]
ASF GitHub Bot commented on FLINK-2978:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1338#issuecomment-162224088
Hi @rmetzger, can you test this on a cluster again?
@StephanEwen can we discuss your concerns about this? I would like to
quickly get this merged after ad
[
https://issues.apache.org/jira/browse/FLINK-2978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15043376#comment-15043376
]
ASF GitHub Bot commented on FLINK-2978:
---
Github user sachingoel0101 commented on a d
Github user sachingoel0101 commented on a diff in the pull request:
https://github.com/apache/flink/pull/1338#discussion_r46760092
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java ---
@@ -302,6 +302,15 @@
*/
public static final
[
https://issues.apache.org/jira/browse/FLINK-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15043349#comment-15043349
]
Martin Junghanns commented on FLINK-3118:
-
Unlike {{MapFunction}} or {{JoinFunctio
Sachin Goel created FLINK-3124:
--
Summary: Introduce a TaskInfo object to better represent task
name, index, attempt number etc.
Key: FLINK-3124
URL: https://issues.apache.org/jira/browse/FLINK-3124
Proje
[
https://issues.apache.org/jira/browse/FLINK-2978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15043338#comment-15043338
]
ASF GitHub Bot commented on FLINK-2978:
---
Github user sachingoel0101 commented on a d
Github user sachingoel0101 commented on a diff in the pull request:
https://github.com/apache/flink/pull/1338#discussion_r46759219
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java ---
@@ -302,6 +302,15 @@
*/
public static final
[
https://issues.apache.org/jira/browse/FLINK-2928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15043337#comment-15043337
]
ASF GitHub Bot commented on FLINK-2928:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1421#issuecomment-162207406
I'm not very sure about this. Displaying two rows doesn't look good at all.
Maybe @iampeter has a better suggestion here.
---
If your project is set up for it, y
[
https://issues.apache.org/jira/browse/FLINK-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15043304#comment-15043304
]
Chesnay Schepler edited comment on FLINK-3118 at 12/5/15 2:36 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-2954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-2954.
---
Resolution: Fixed
Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/b9639eb5
>
[
https://issues.apache.org/jira/browse/FLINK-2954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15043332#comment-15043332
]
ASF GitHub Bot commented on FLINK-2954:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1409
---
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-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15043304#comment-15043304
]
Chesnay Schepler commented on FLINK-3118:
-
that would mean skipping the input vali
[
https://issues.apache.org/jira/browse/FLINK-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15043294#comment-15043294
]
Martin Junghanns commented on FLINK-3118:
-
Sorry, didn't think this through. It wo
[
https://issues.apache.org/jira/browse/FLINK-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15043291#comment-15043291
]
Martin Junghanns commented on FLINK-3118:
-
I also tried that and let {{MessageFunc
[
https://issues.apache.org/jira/browse/FLINK-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15043279#comment-15043279
]
Chesnay Schepler commented on FLINK-3118:
-
why cant you use
{code}
@SuppressWarni
[
https://issues.apache.org/jira/browse/FLINK-3116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15043273#comment-15043273
]
Chesnay Schepler commented on FLINK-3116:
-
That's exactly what you need to do, but
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1436#issuecomment-162176217
@jaoki found a reference to this class in
https://github.com/apache/flink/blob/master/flink-core/src/main/java/org/apache/flink/api/common/Plan.java#L318-L319
-
[
https://issues.apache.org/jira/browse/FLINK-3112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15043271#comment-15043271
]
ASF GitHub Bot commented on FLINK-3112:
---
Github user zentol commented on the pull re
[
https://issues.apache.org/jira/browse/FLINK-2954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15043249#comment-15043249
]
ASF GitHub Bot commented on FLINK-2954:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1409#issuecomment-162174050
Thanks for the review. I'll merge it soon
---
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 projec
[
https://issues.apache.org/jira/browse/FLINK-3090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15042787#comment-15042787
]
Robert Metzger commented on FLINK-3090:
---
I agree. We have some users running Flink o
[
https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15042783#comment-15042783
]
ASF GitHub Bot commented on FLINK-2976:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1434#issuecomment-162168898
Awesome change! I think its a feature many users are asking for because its
crucial for production use!
I'll try to review it soon.
---
If your project is set up f
[
https://issues.apache.org/jira/browse/FLINK-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15042781#comment-15042781
]
ASF GitHub Bot commented on FLINK-3093:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1427#discussion_r46756747
--- Diff: flink-core/src/main/java/org/apache/flink/types/Pair.java ---
@@ -33,6 +34,7 @@
* @param Type of the pair's first element.
* @param Ty
[
https://issues.apache.org/jira/browse/FLINK-2344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15042780#comment-15042780
]
Robert Metzger commented on FLINK-2344:
---
Is this the {{flink-core/src/main/java/org/
Robert Metzger created FLINK-3123:
-
Summary: Allow setting custom start-offsets for the Kafka consumer
Key: FLINK-3123
URL: https://issues.apache.org/jira/browse/FLINK-3123
Project: Flink
Iss
Martin Junghanns created FLINK-3122:
---
Summary: Generalize value type in LabelPropagation
Key: FLINK-3122
URL: https://issues.apache.org/jira/browse/FLINK-3122
Project: Flink
Issue Type: Imp
32 matches
Mail list logo
