[
https://issues.apache.org/jira/browse/FLINK-4505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15464203#comment-15464203
]
ASF GitHub Bot commented on FLINK-4505:
---
Github user wangzhijiang999 commented on th
Github user wangzhijiang999 commented on the issue:
https://github.com/apache/flink/pull/2461
@tillrohrmann , I tried to understand your idea as follows:
1. Provide specific TaskExecutorFactory class instead of abstract factory
for both standalone/yarn mode.
2. Network selectio
[
https://issues.apache.org/jira/browse/FLINK-4406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu updated FLINK-4406:
---
Assignee: Kurt Young (was: Wenlong Lyu)
> Implement job master registration at resource manager
> ---
[
https://issues.apache.org/jira/browse/FLINK-4459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4459.
---
> Introduce SlotProvider for Scheduler
>
>
> Key: FLI
[
https://issues.apache.org/jira/browse/FLINK-4459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4459.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed via 6e40f59015dcdb8529691318e8f5a33e831252b8
[
https://issues.apache.org/jira/browse/FLINK-4459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15463517#comment-15463517
]
ASF GitHub Bot commented on FLINK-4459:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2424
---
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-4361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4361:
-
Summary: Introduce Flink's own future abstraction (was: Replace Scala
Futures)
> Introduce Flink
[
https://issues.apache.org/jira/browse/FLINK-4361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-4361:
Assignee: Till Rohrmann
> Introduce Flink's own future abstraction
> --
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15463483#comment-15463483
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on the iss
Github user vijikarthi commented on the issue:
https://github.com/apache/flink/pull/2275
@mxm, I was able to reproduce this issue on some other machine. The issue
is that KRB5 config file which is mounted as a local resource is not visible
though we set the system property (java.secur
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15463394#comment-15463394
]
Ivan Mushketyk commented on FLINK-2254:
---
Hi [~vkalavri],
I've written a short desig
[
https://issues.apache.org/jira/browse/FLINK-4578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15463363#comment-15463363
]
Gabor Gevay commented on FLINK-4578:
A hacky solution might be to create some dummy {{
[
https://issues.apache.org/jira/browse/FLINK-4575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15463360#comment-15463360
]
Gabor Gevay commented on FLINK-4575:
This is a bit harder than I thought, because of a
[
https://issues.apache.org/jira/browse/FLINK-4575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-4575:
---
Assignee: (was: Gabor Gevay)
> DataSet aggregate methods should support POJOs
> --
Gabor Gevay created FLINK-4578:
--
Summary: AggregateOperator incorrectly sets ForwardedField with
nested composite types
Key: FLINK-4578
URL: https://issues.apache.org/jira/browse/FLINK-4578
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-4575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay reassigned FLINK-4575:
--
Assignee: Gabor Gevay
> DataSet aggregate methods should support POJOs
> --
[
https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-4576:
---
Description:
As per discussion in FLINK-4341 by [~aljoscha] and [~StephanEwen], we nee
[
https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-4576:
---
Description:
As per discussion in FLINK-4341 by [~aljoscha] and [~StephanEwen], we nee
[
https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-4576:
---
Description:
As per discussion in FLINK-4341 by [~aljoscha] and [~StephanEwen], we nee
[
https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-4576:
---
Priority: Blocker (was: Major)
> Low Watermark Service in JobManager for Streaming So
Tzu-Li (Gordon) Tai created FLINK-4577:
--
Summary: Re-enable transparent reshard handling in Kinesis Consumer
Key: FLINK-4577
URL: https://issues.apache.org/jira/browse/FLINK-4577
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-4576:
---
Description:
As per discussion in FLINK-4341 by [~aljoscha] and [~StephanEwen], we nee
Tzu-Li (Gordon) Tai created FLINK-4576:
--
Summary: Low Watermark Service in JobManager for Streaming Sources
Key: FLINK-4576
URL: https://issues.apache.org/jira/browse/FLINK-4576
Project: Flink
Github user ggevay commented on the issue:
https://github.com/apache/flink/pull/2094
https://issues.apache.org/jira/browse/FLINK-4575
---
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 feat
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15463156#comment-15463156
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user ggevay commented on the issue:
Gabor Gevay created FLINK-4575:
--
Summary: DataSet aggregate methods should support POJOs
Key: FLINK-4575
URL: https://issues.apache.org/jira/browse/FLINK-4575
Project: Flink
Issue Type: Improvem
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15463135#comment-15463135
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user ggevay commented on the issue:
Github user ggevay commented on the issue:
https://github.com/apache/flink/pull/2094
@rmetzger Thanks for looking at it.
> Is there a reason why the DataSet methods for "sum()" for example do not
allow to aggregate on POJOs with this change?
The reason is just that i
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15463094#comment-15463094
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2094
Thank you for your work @ggevay, and the reviews @twalthr.
Is there a reason why the DataSet methods for "sum()" for example do not
allow to aggregate on POJOs with this change?
---
If you
31 matches
Mail list logo
