[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420158#comment-15420158
]
MaGuowei commented on FLINK-4391:
-
hi,Jamie
We have already implemented the "async operato
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420137#comment-15420137
]
Renkai Ge commented on FLINK-4282:
--
[~aljoscha]I use two mod just want to prevent someone
[
https://issues.apache.org/jira/browse/FLINK-3899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420125#comment-15420125
]
ASF GitHub Bot commented on FLINK-3899:
---
GitHub user danielblazevski opened a pull r
GitHub user danielblazevski opened a pull request:
https://github.com/apache/flink/pull/2368
[FLINK-3899] Document window processing with Reduce/FoldFunction +
WindowFunction
Added example of using Reduce/Fold + Window in docs. The examples were
tested to run -- I used the sensor
GitHub user mushketyk opened a pull request:
https://github.com/apache/flink/pull/2367
[FLINK-3703][cep] Add sequence matching semantics to discard matched events
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into co
[
https://issues.apache.org/jira/browse/FLINK-3703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420110#comment-15420110
]
ASF GitHub Bot commented on FLINK-3703:
---
GitHub user mushketyk opened a pull request
[
https://issues.apache.org/jira/browse/FLINK-4384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4384.
---
> Add a "scheduleRunAsync()" feature to the RpcEndpoint
>
[
https://issues.apache.org/jira/browse/FLINK-4384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4384.
-
Resolution: Implemented
Implemented in f74f44bb56e50d1714e935df2980a6c8213faf89
> Add a "schedule
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/2342
Ran those two tests individually they seem to pass. But the Rocks_DB
version failed due to some initialization error. Thank you @StephanEwen for
your comments.
---
If your project is set up for
[
https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420025#comment-15420025
]
ASF GitHub Bot commented on FLINK-4253:
---
Github user ramkrish86 commented on the iss
Stephan Ewen created FLINK-4392:
---
Summary: Make RPC Service Thread Safe
Key: FLINK-4392
URL: https://issues.apache.org/jira/browse/FLINK-4392
Project: Flink
Issue Type: Sub-task
Compo
[
https://issues.apache.org/jira/browse/FLINK-4236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-4236.
-
Resolution: Fixed
Fix Version/s: 1.2.0
master: 726d7c7ff25a4af681bf43abedfac452bcea
[
https://issues.apache.org/jira/browse/FLINK-4236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15419981#comment-15419981
]
ASF GitHub Bot commented on FLINK-4236:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2347
---
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-4236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15419980#comment-15419980
]
ASF GitHub Bot commented on FLINK-4236:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2347
Merging this after a Checkstyle fix.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15419978#comment-15419978
]
ASF GitHub Bot commented on FLINK-4340:
---
Github user wenlong88 commented on the issu
Github user wenlong88 commented on the issue:
https://github.com/apache/flink/pull/2345
@StephanEwen you are right. But in specific situation, we may need some
temporary compromise do make the system work well, and then remove the
compromised points latter as soon as possible .
I
[
https://issues.apache.org/jira/browse/FLINK-4383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15419965#comment-15419965
]
ASF GitHub Bot commented on FLINK-4383:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2365
This is a great feature and it looks very good overall. Minor comments
inline.
Big +1 overall
---
If your project is set up for it, you can reply to this email and have your
reply appea
[
https://issues.apache.org/jira/browse/FLINK-4383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15419964#comment-15419964
]
ASF GitHub Bot commented on FLINK-4383:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2365#discussion_r74688165
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaInvocationHandler.java
---
@@ -25,33 +25,42 @@
import org.apache.flink.r
[
https://issues.apache.org/jira/browse/FLINK-4383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15419962#comment-15419962
]
ASF GitHub Bot commented on FLINK-4383:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2365#discussion_r74688148
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/messages/RemoteRpcInvocation.java
---
@@ -0,0 +1,187 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15419961#comment-15419961
]
Aljoscha Krettek commented on FLINK-4282:
-
Hi [~RenkaiGe],
I was wondering about t
[
https://issues.apache.org/jira/browse/FLINK-4383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15419958#comment-15419958
]
ASF GitHub Bot commented on FLINK-4383:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2365#discussion_r74688005
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaInvocationHandler.java
---
@@ -25,33 +25,42 @@
import org.apache.flink.r
[
https://issues.apache.org/jira/browse/FLINK-4236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15419957#comment-15419957
]
ASF GitHub Bot commented on FLINK-4236:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2347
Actually, not merging. This fails due to checkstyle violations.
---
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 doe
[
https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15419951#comment-15419951
]
ASF GitHub Bot commented on FLINK-4253:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2342
There are some test instabilities that we are trying to address. Seems
unrelated to your changes at the first glance. We'll look at the tests again
anyways before merging,
---
If your project
[
https://issues.apache.org/jira/browse/FLINK-4236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15419949#comment-15419949
]
ASF GitHub Bot commented on FLINK-4236:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2347
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
enabled and wishes so, o
[
https://issues.apache.org/jira/browse/FLINK-4365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15419947#comment-15419947
]
ASF GitHub Bot commented on FLINK-4365:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2349
Looks good, +1 to merge 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
enabled and
[
https://issues.apache.org/jira/browse/FLINK-4368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15419945#comment-15419945
]
ASF GitHub Bot commented on FLINK-4368:
---
Github user StephanEwen commented on the is
Github user StephanEwen closed the pull request at:
https://github.com/apache/flink/pull/2351
---
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-4368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15419946#comment-15419946
]
ASF GitHub Bot commented on FLINK-4368:
---
Github user StephanEwen closed the pull req
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2351
Manually merged into `flip-6` feature branch in
https://github.com/apache/flink/commit/08af7def60d54c22126b902e6fa57101d5fbb8fa
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-4366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15419943#comment-15419943
]
ASF GitHub Bot commented on FLINK-4366:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2354
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
enabled and wishes so, o
[
https://issues.apache.org/jira/browse/FLINK-4293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15419942#comment-15419942
]
ASF GitHub Bot commented on FLINK-4293:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2364
Thanks for picking this up.
+1 to merge
---
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
[
https://issues.apache.org/jira/browse/FLINK-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15419941#comment-15419941
]
ASF GitHub Bot commented on FLINK-4322:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2366
Thanks for joining this effort. I'll try to have a look at the tests in the
next days.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as w
Jamie Grier created FLINK-4391:
--
Summary: Provide support for asynchronous operations over streams
Key: FLINK-4391
URL: https://issues.apache.org/jira/browse/FLINK-4391
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15419864#comment-15419864
]
ASF GitHub Bot commented on FLINK-4253:
---
Github user ramkrish86 commented on the iss
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/2342
github build shows two failure
>
org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase.org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase
org.apac
[
https://issues.apache.org/jira/browse/FLINK-4388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15419861#comment-15419861
]
ramkrishna.s.vasudevan commented on FLINK-4388:
---
[~StephanEwen]
I think it h
49 matches
Mail list logo
