[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15643392#comment-15643392
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user bjlovegithub commented on the issue:
Github user bjlovegithub commented on the issue:
https://github.com/apache/flink/pull/2629
Maybe this is a solution. We will not think about changing the type of
`checkpointLock`, which is an `Object` ans quite efficient, and not change the
order of `broadcastBarriers` and
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15642997#comment-15642997
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user bjlovegithub commented on a diff in the pull
Github user bjlovegithub commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r86709933
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
---
@@ -540,15 +540,12 @@ private boolean
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15642901#comment-15642901
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user bjlovegithub commented on the issue:
Github user bjlovegithub commented on the issue:
https://github.com/apache/flink/pull/2629
Good point ;D
Emm, I think we have to override the
`StreamOpeartor.notifyCheckpointComplete()` for `AsyncWaitOpeartor` so that
once the `TaskManager` notifies the `Task` that
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15642872#comment-15642872
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user bjlovegithub commented on a diff in the pull
Github user bjlovegithub commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r86706353
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBufferTest.java
---
@@ -0,0 +1,293 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15642868#comment-15642868
]
Xiaogang Shi edited comment on FLINK-4856 at 11/7/16 2:29 AM:
--
I have started
[
https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15642868#comment-15642868
]
Xiaogang Shi commented on FLINK-4856:
-
I have started the implementation of MapStates. But at prior to
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15642862#comment-15642862
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user bjlovegithub commented on a diff in the pull
Xiaogang Shi created FLINK-5024:
---
Summary: Add SimpleStateDescriptor to clarify the concepts
Key: FLINK-5024
URL: https://issues.apache.org/jira/browse/FLINK-5024
Project: Flink
Issue Type:
Github user bjlovegithub commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r86706002
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java
---
@@ -0,0 +1,494 @@
+/*
Xiaogang Shi created FLINK-5023:
---
Summary: Add get() method in State interface
Key: FLINK-5023
URL: https://issues.apache.org/jira/browse/FLINK-5023
Project: Flink
Issue Type: Improvement
Github user vijikarthi commented on the issue:
https://github.com/apache/flink/pull/2425
>
The cookie is added to every single message/buffer that is transferred.
That is too much - securing the integrity of the stream is responsibility of
the encryption layer. The cookie should
[
https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15642713#comment-15642713
]
ASF GitHub Bot commented on FLINK-3930:
---
Github user vijikarthi commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15642459#comment-15642459
]
ASF GitHub Bot commented on FLINK-3030:
---
Github user mushketyk commented on a diff in the pull
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2448#discussion_r86697108
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JsonGenerators.java
---
@@ -0,0 +1,86 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15642456#comment-15642456
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user mushketyk commented on the issue:
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2564
@vasia @greghogan I've updated the PR. Could you please give it another
look?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r86694144
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,272 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15642279#comment-15642279
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user mushketyk commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15642277#comment-15642277
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user mushketyk commented on a diff in the pull
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r86694124
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,272 @@
+/*
+ * Licensed to the
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2431
Hi @iampeter
Thank you for your review and sorry for the long delay.
I'll update the code in the next few days.
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-4521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15642067#comment-15642067
]
ASF GitHub Bot commented on FLINK-4521:
---
Github user mushketyk commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15641962#comment-15641962
]
ASF GitHub Bot commented on FLINK-4934:
---
Github user greghogan commented on the issue:
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2731
The RMat graph is used across many tests and the intent was to verify the
larger tests against secondary frameworks. I have no problem leaving out the
files as the command is documented in the
[
https://issues.apache.org/jira/browse/FLINK-4934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15641896#comment-15641896
]
ASF GitHub Bot commented on FLINK-4934:
---
Github user vasia commented on the issue:
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/2731
Hi @greghogan,
do we really need a 12k-line csv and a 32k-line csv to test 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
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15641702#comment-15641702
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user mbalassi commented on the issue:
Github user mbalassi commented on the issue:
https://github.com/apache/flink/pull/2094
Thanks @fhueske. I am happy to squash the commits and merge the PR given
that you are satisfied with it.
I would like to merge it by mid next week, so I could proceed with adding
the
32 matches
Mail list logo
