[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15420158#comment-15420158
]
MaGuowei commented on FLINK-4391:
-
hi,Jamie
We have already implemented the "async operator" in Blink
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15420137#comment-15420137
]
Renkai Ge commented on FLINK-4282:
--
[~aljoscha]I use two mod just want to prevent someone may abuse this
[
https://issues.apache.org/jira/browse/FLINK-3899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15420125#comment-15420125
]
ASF GitHub Bot commented on FLINK-3899:
---
GitHub user danielblazevski opened a pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-3703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
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=15420025#comment-15420025
]
ASF GitHub Bot commented on FLINK-4253:
---
Github user ramkrish86 commented on the issue:
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
[
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:
[
https://issues.apache.org/jira/browse/FLINK-4236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15419981#comment-15419981
]
ASF GitHub Bot commented on FLINK-4236:
---
Github user asfgit closed the pull request at:
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
[
https://issues.apache.org/jira/browse/FLINK-4236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
https://issues.apache.org/jira/browse/FLINK-4340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15419978#comment-15419978
]
ASF GitHub Bot commented on FLINK-4340:
---
Github user wenlong88 commented on the issue:
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 .
[
https://issues.apache.org/jira/browse/FLINK-4383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15419965#comment-15419965
]
ASF GitHub Bot commented on FLINK-4383:
---
Github user StephanEwen commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-4383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15419964#comment-15419964
]
ASF GitHub Bot commented on FLINK-4383:
---
Github user StephanEwen commented on a diff in the pull
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
[
https://issues.apache.org/jira/browse/FLINK-4383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15419962#comment-15419962
]
ASF GitHub Bot commented on FLINK-4383:
---
Github user StephanEwen commented on a diff in the pull
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=15419961#comment-15419961
]
Aljoscha Krettek commented on FLINK-4282:
-
Hi [~RenkaiGe],
I was wondering about that as well but
[
https://issues.apache.org/jira/browse/FLINK-4383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15419958#comment-15419958
]
ASF GitHub Bot commented on FLINK-4383:
---
Github user StephanEwen commented on a diff in the pull
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
[
https://issues.apache.org/jira/browse/FLINK-4236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15419957#comment-15419957
]
ASF GitHub Bot commented on FLINK-4236:
---
Github user StephanEwen commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15419951#comment-15419951
]
ASF GitHub Bot commented on FLINK-4253:
---
Github user StephanEwen commented on the issue:
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=15419949#comment-15419949
]
ASF GitHub Bot commented on FLINK-4236:
---
Github user StephanEwen commented on the issue:
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,
[
https://issues.apache.org/jira/browse/FLINK-4365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15419947#comment-15419947
]
ASF GitHub Bot commented on FLINK-4365:
---
Github user StephanEwen commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-4368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15419945#comment-15419945
]
ASF GitHub Bot commented on FLINK-4368:
---
Github user StephanEwen commented on the issue:
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
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
[
https://issues.apache.org/jira/browse/FLINK-4368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15419946#comment-15419946
]
ASF GitHub Bot commented on FLINK-4368:
---
Github user StephanEwen closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15419943#comment-15419943
]
ASF GitHub Bot commented on FLINK-4366:
---
Github user StephanEwen commented on the issue:
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,
[
https://issues.apache.org/jira/browse/FLINK-4293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15419942#comment-15419942
]
ASF GitHub Bot commented on FLINK-4293:
---
Github user StephanEwen commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15419941#comment-15419941
]
ASF GitHub Bot commented on FLINK-4322:
---
Github user StephanEwen commented on the issue:
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
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
[
https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15419864#comment-15419864
]
ASF GitHub Bot commented on FLINK-4253:
---
Github user ramkrish86 commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-4388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15419861#comment-15419861
]
ramkrishna.s.vasudevan commented on FLINK-4388:
---
[~StephanEwen]
I think it happened because
49 matches
Mail list logo
