[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15203816#comment-15203816
]
ASF GitHub Bot commented on FLINK-3579:
---
Github user zentol commented on the pull re
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1808#issuecomment-199146677
grasping at straws here: when was the tableOnCalcite branch deleted?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHu
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15203812#comment-15203812
]
Chesnay Schepler commented on FLINK-3579:
-
we can't reopen pull requests, you will
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15203687#comment-15203687
]
ramkrishna.s.vasudevan commented on FLINK-3579:
---
[~twalthr] - This PR got cl
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 r
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15203686#comment-15203686
]
ASF GitHub Bot commented on FLINK-3579:
---
Github user ramkrish86 commented on the pul
[
https://issues.apache.org/jira/browse/FLINK-3109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15203543#comment-15203543
]
ASF GitHub Bot commented on FLINK-3109:
---
Github user wangyangjun commented on the pu
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 SlidingTi
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15203529#comment-15203529
]
ASF GitHub Bot commented on FLINK-3579:
---
Github user hsaputra commented on the pull
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 e
[
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 while
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 enab
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15203526#comment-15203526
]
ASF GitHub Bot commented on FLINK-3579:
---
Github user asfgit closed the pull request
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 setKe
[
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&focusedCommentId=15197621#comment-15197621
]
ASF GitHub Bot commented on FLINK-1964:
---
Github user asfgit closed the pull request
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 Softw
[
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 Version/s
[
https://issues.apache.org/jira/browse/FLINK-3115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15200347#comment-15200347
]
ASF GitHub Bot commented on FLINK-3115:
---
Github user smarthi commented on a diff in
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&focusedCommentId=15199663#comment-15199663
]
ASF GitHub Bot commented on FLINK-3544:
---
Github user tillrohrmann commented on a dif
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 A
[
https://issues.apache.org/jira/browse/FLINK-3579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15201316#comment-15201316
]
ramkrishna.s.vasudevan commented on FLINK-3579:
---
[~twalthr]?
> Improve Stri
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 setKeyContextEl
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&focusedCommentId=15200344#comment-15200344
]
ASF GitHub Bot commented on FLINK-3115:
---
Github user zcox commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15199322#comment-15199322
]
Vasia Kalavri commented on FLINK-3630:
--
Great! I've assigned the issue to you. Make s
[
https://issues.apache.org/jira/browse/FLINK-3629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15199408#comment-15199408
]
Li Fanxi commented on FLINK-3629:
-
I have already submitted a full request on Github after
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. Unfortuna
31 matches
Mail list logo
