[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15203687#comment-15203687
]
ramkrishna.s.vasudevan commented on FLINK-3579:
---
[~twalthr] - This PR got closed not sure
Github user ramkrish86 commented on the pull request:
https://github.com/apache/flink/pull/1808#issuecomment-199109373
@hsaputra
I am waiting for @tillrohrmann reviews. Why did this get closed am not
sure. Any way to open it back?
---
If your project is set up for it, you can
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15203686#comment-15203686
]
ASF GitHub Bot commented on FLINK-3579:
---
Github user ramkrish86 commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15203543#comment-15203543
]
ASF GitHub Bot commented on FLINK-3109:
---
Github user wangyangjun commented on the pull request:
Github user wangyangjun commented on the pull request:
https://github.com/apache/flink/pull/1527#issuecomment-199043205
Hi StephanEwen, sorry for replying this late.
This will join two window streams as long as slide size of these two
windows are equal. It can be two
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15203529#comment-15203529
]
ASF GitHub Bot commented on FLINK-3579:
---
Github user hsaputra commented on the pull request:
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/1808#issuecomment-199026680
Anyone merged this PR as part of commit to Flink ASF Git repo?
I wonder why asfgit close this PR
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-3636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi resolved FLINK-3636.
---
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed via f09d68a.
> NoClassDefFoundError
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1808
---
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
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15203526#comment-15203526
]
ASF GitHub Bot commented on FLINK-3579:
---
Github user asfgit closed the pull request at:
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1790#issuecomment-198344319
I just tested the change on a cluster, also with larger log files, and it
seems to work very well.
The only thing I found was that clicking the "Download" button on
[
https://issues.apache.org/jira/browse/FLINK-3628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-3628:
Assignee: MaGuowei (was: Aljoscha Krettek)
> ChainingOutput and CopyingChainingOutput
[
https://issues.apache.org/jira/browse/FLINK-3609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-3609.
--
Resolution: Fixed
Fix Version/s: 1.1.0
> Revisit selection of Calcite rules
>
[
https://issues.apache.org/jira/browse/FLINK-1964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15197621#comment-15197621
]
ASF GitHub Bot commented on FLINK-1964:
---
Github user asfgit closed the pull request at:
Github user gallenvara commented on a diff in the pull request:
https://github.com/apache/flink/pull/1776#discussion_r56668261
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/distribution/TestDataDist.java
---
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-1964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1964.
---
Resolution: Fixed
Assignee: Robert Metzger (was: Carlos Curotto)
Fix
[
https://issues.apache.org/jira/browse/FLINK-3115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15200347#comment-15200347
]
ASF GitHub Bot commented on FLINK-3115:
---
Github user smarthi commented on a diff in the pull
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1800#issuecomment-197318751
+1 from ML discussion.
I guess you can close this together with #1627 when merging.
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15199663#comment-15199663
]
ASF GitHub Bot commented on FLINK-3544:
---
Github user tillrohrmann commented on a diff in the pull
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1741#discussion_r56328994
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/FlinkResourceManager.java
---
@@ -0,0 +1,801 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15201316#comment-15201316
]
ramkrishna.s.vasudevan commented on FLINK-3579:
---
[~twalthr]?
> Improve String concatenation
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1741#discussion_r56479617
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/messages/SetWorkerPoolSize.java
---
@@ -0,0 +1,63 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-3628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-3628:
---
Assignee: Aljoscha Krettek
> ChainingOutput and CopyingChainingOutput
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1790#issuecomment-198358391
We could also have passed the `BlobServer` of the `JobManager` to the
`TaskManagerLogHandler` to avoid the extra copying. But this would mean that we
would have to
[
https://issues.apache.org/jira/browse/FLINK-3115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15200344#comment-15200344
]
ASF GitHub Bot commented on FLINK-3115:
---
Github user zcox commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15199322#comment-15199322
]
Vasia Kalavri commented on FLINK-3630:
--
Great! I've assigned the issue to you. Make sure to read the
[
https://issues.apache.org/jira/browse/FLINK-3629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15199408#comment-15199408
]
Li Fanxi commented on FLINK-3629:
-
I have already submitted a full request on Github after submitting this
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/1819
Flink-3429: adds a histogram-based watermark emitter.
When processing a stream, and for the lateness to be as low as possible,
the watermark should be as close to processing time as possible.
[
https://issues.apache.org/jira/browse/FLINK-3524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-3524:
Description:
(I don't want to include this into 1.0.0)
Currently, there is no standardized
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1741#discussion_r56374445
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/messages/SetWorkerPoolSize.java
---
@@ -0,0 +1,63 @@
+/*
+ *
30 matches
Mail list logo