[
https://issues.apache.org/jira/browse/FLINK-4613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15535242#comment-15535242
]
ASF GitHub Bot commented on FLINK-4613:
---
Github user mbalassi commented on the issue
Github user mbalassi commented on the issue:
https://github.com/apache/flink/pull/2542
@gaborhermann @thvasilo I would definitely like to see a test on a larger
dataset, that is actually what I was asking for when I mentioned "benchmark",
maybe I was not clear then.
---
If your proj
[
https://issues.apache.org/jira/browse/FLINK-4704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15535169#comment-15535169
]
Jark Wu commented on FLINK-4704:
+1
Table API is still in beta, so it's not too late to
[
https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15535151#comment-15535151
]
Tzu-Li (Gordon) Tai commented on FLINK-4618:
Hi [~melmoth],
I'd like to make
[
https://issues.apache.org/jira/browse/FLINK-4702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15535141#comment-15535141
]
ASF GitHub Bot commented on FLINK-4702:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15535144#comment-15535144
]
ASF GitHub Bot commented on FLINK-4702:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15535142#comment-15535142
]
ASF GitHub Bot commented on FLINK-4702:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15535143#comment-15535143
]
ASF GitHub Bot commented on FLINK-4702:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2574#discussion_r81277067
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka09FetcherTest.java
---
@@ -0,0
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2574#discussion_r81282102
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka09FetcherTest.java
---
@@ -0,0
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2574#discussion_r81275213
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java
---
@@
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2574#discussion_r81277361
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka09FetcherTest.java
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534886#comment-15534886
]
ASF GitHub Bot commented on FLINK-4068:
---
Github user wuchong commented on the issue:
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/2560
@twalthr I add some Table API tests but skip some tests doesn't supported
in Table API, such as `NULLIF`, `IN`, `EXTRACT`
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-4718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534817#comment-15534817
]
ASF GitHub Bot commented on FLINK-4718:
---
GitHub user nderraugh opened a pull request
GitHub user nderraugh opened a pull request:
https://github.com/apache/flink/pull/2575
'Id' is the key of the stream and not the id of the event.
FLINK-4718 Confusing label in Parallel Streams Diagram
Minor text change to clarify a mildly confusing label in a diagram.
You c
[
https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534809#comment-15534809
]
ASF GitHub Bot commented on FLINK-4068:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2560#discussion_r81270921
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/FlinkPlannerImpl.scala
---
@@ -60,6 +60,7 @@ class FlinkPlannerImpl(
v
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534797#comment-15534797
]
Zhijiang Wang edited comment on FLINK-4715 at 9/30/16 2:31 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534800#comment-15534800
]
ASF GitHub Bot commented on FLINK-4348:
---
Github user beyond1920 commented on the iss
Neil Derraugh created FLINK-4718:
Summary: Confusing label in Parallel Streams Diagram
Key: FLINK-4718
URL: https://issues.apache.org/jira/browse/FLINK-4718
Project: Flink
Issue Type: Bug
Github user beyond1920 commented on the issue:
https://github.com/apache/flink/pull/2571
@mxm, What would happen under following cases: taskExecutor releases a
registered slot, then taskExecutor reports its latest slotReport to
ResourceManager, ResourceManager should remove the old s
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534797#comment-15534797
]
Zhijiang Wang commented on FLINK-4715:
--
Yes, we already experienced this problem in r
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534249#comment-15534249
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user mushketyk commented on a diff i
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81246840
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,231 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534241#comment-15534241
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user mushketyk commented on a diff i
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81246465
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Edge.java ---
@@ -34,10 +34,10 @@
public Edge(){}
- pub
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534239#comment-15534239
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user mushketyk commented on the issu
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2564
Hi @greghogan,
I like your ideas about providing different API for projections. This
should be better than my approach.
@vasia What do you think about this?
---
If your project is se
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534224#comment-15534224
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user mushketyk commented on a diff i
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81245767
--- Diff:
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/TestBaseUtils.java
---
@@ -480,7 +480,8 @@ protected static Fil
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534216#comment-15534216
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user kl0u commented on the issue:
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2546
Hi @StephanEwen . If I understand correctly, your suggestion is to make the
test something like the following: 1) put the split in the reader 2) read the
split 3) when the split finishes update the time
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534014#comment-15534014
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15534015#comment-15534015
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user greghogan commented on a diff i
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81225166
--- Diff:
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/TestBaseUtils.java
---
@@ -480,7 +480,8 @@ protected static Fil
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81226805
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,231 @@
+/*
+ * Licensed to the Apache
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81217922
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,231 @@
+/*
+ * Licensed to the Apache Sof
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81218538
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Edge.java ---
@@ -34,10 +34,10 @@
public Edge(){}
- public
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81218403
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,231 @@
+/*
+ * Licensed to the Apache Sof
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81218056
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,231 @@
+/*
+ * Licensed to the Apache Sof
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2564#discussion_r81218490
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/BipartiteGraph.java
---
@@ -0,0 +1,231 @@
+/*
+ * Licensed to the Apache Sof
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533864#comment-15533864
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user vasia commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533866#comment-15533866
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user vasia commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533865#comment-15533865
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user vasia commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533863#comment-15533863
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user vasia commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533862#comment-15533862
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user vasia commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533664#comment-15533664
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533663#comment-15533663
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2546#discussion_r81204726
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileMonitoringTest.java
---
@@ -440,10 +491,50 @@ public void testFileSplitMo
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533662#comment-15533662
]
ASF GitHub Bot commented on FLINK-4329:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2546#discussion_r81204990
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileMonitoringTest.java
---
@@ -190,12 +213,30 @@ public void
testFileReadin
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2546#discussion_r81204828
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileMonitoringTest.java
---
@@ -440,10 +491,50 @@ public void testFileSplitMo
[
https://issues.apache.org/jira/browse/FLINK-4636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533563#comment-15533563
]
ASF GitHub Bot commented on FLINK-4636:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-4643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533562#comment-15533562
]
ASF GitHub Bot commented on FLINK-4643:
---
Github user StephanEwen commented on the is
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2568#discussion_r81200110
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/AbstractCEPPatternOperator.java
---
@@ -126,11 +126,12 @@ public void resto
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2528
Looks good to me. Test failure is unrelated.
From my side, feel free to merge...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub a
Github user jaxbihani commented on a diff in the pull request:
https://github.com/apache/flink/pull/2568#discussion_r81199485
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/AbstractCEPPatternOperator.java
---
@@ -126,11 +126,12 @@ public void resto
[
https://issues.apache.org/jira/browse/FLINK-4636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533555#comment-15533555
]
ASF GitHub Bot commented on FLINK-4636:
---
Github user jaxbihani commented on a diff i
Till Rohrmann created FLINK-4717:
Summary: Naive version of atomic stop signal with savepoint
Key: FLINK-4717
URL: https://issues.apache.org/jira/browse/FLINK-4717
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533528#comment-15533528
]
ASF GitHub Bot commented on FLINK-4573:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2556
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-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4650:
-
Fix Version/s: 1.2.0
> Frequent task manager disconnects from JobManager
> ---
[
https://issues.apache.org/jira/browse/FLINK-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4650:
-
Affects Version/s: 1.2.0
> Frequent task manager disconnects from JobManager
> ---
Till Rohrmann created FLINK-4716:
Summary: Add trigger full recovery button to web UI
Key: FLINK-4716
URL: https://issues.apache.org/jira/browse/FLINK-4716
Project: Flink
Issue Type: Improvem
Till Rohrmann created FLINK-4715:
Summary: TaskManager should commit suicide after cancellation
failure
Key: FLINK-4715
URL: https://issues.apache.org/jira/browse/FLINK-4715
Project: Flink
I
Till Rohrmann created FLINK-4714:
Summary: Set task state to RUNNING after state has been restored
Key: FLINK-4714
URL: https://issues.apache.org/jira/browse/FLINK-4714
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-4700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533260#comment-15533260
]
Kostas Kloudas commented on FLINK-4700:
---
[~StephanEwen]
I am thinking that the bes
[
https://issues.apache.org/jira/browse/FLINK-4702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533216#comment-15533216
]
ASF GitHub Bot commented on FLINK-4702:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533215#comment-15533215
]
ASF GitHub Bot commented on FLINK-4711:
---
Github user tillrohrmann commented on the i
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2574
@tzulitai @rmetzger We need to make sure that the Kafka 0.10 code picks up
this change and the test case.
---
If your project is set up for it, you can reply to this email and have your
reply ap
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2569
Thanks for the review @uce. If Travis gives green light, I'll merge the PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If you
[
https://issues.apache.org/jira/browse/FLINK-4702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533211#comment-15533211
]
ASF GitHub Bot commented on FLINK-4702:
---
Github user StephanEwen closed the pull req
[
https://issues.apache.org/jira/browse/FLINK-4702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533210#comment-15533210
]
ASF GitHub Bot commented on FLINK-4702:
---
Github user StephanEwen commented on the is
Github user StephanEwen closed the pull request at:
https://github.com/apache/flink/pull/2559
---
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
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2559
Closing this for #2574
---
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 wish
[
https://issues.apache.org/jira/browse/FLINK-4702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533206#comment-15533206
]
ASF GitHub Bot commented on FLINK-4702:
---
GitHub user StephanEwen opened a pull reque
[
https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533204#comment-15533204
]
ASF GitHub Bot commented on FLINK-4348:
---
Github user mxm commented on the issue:
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/2574
[FLINK-4702] [kafka connector] Commit offsets to Kafka asynchronously and
don't block on polls
This fix is quite critical!
While the KafkaConsumer is polling for new data (with a timeou
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2571
CC @beyond1920 @KurtYoung
---
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-4711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533193#comment-15533193
]
ASF GitHub Bot commented on FLINK-4711:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-4711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533194#comment-15533194
]
ASF GitHub Bot commented on FLINK-4711:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2569#discussion_r81173562
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/messages/TaskControlMessages.scala
---
@@ -92,16 +92,6 @@ object TaskMessages {
/
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2569#discussion_r81173599
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -873,8 +873,7 @@ class JobManager(
}
[
https://issues.apache.org/jira/browse/FLINK-4711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533192#comment-15533192
]
ASF GitHub Bot commented on FLINK-4711:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2569#discussion_r81173481
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/JobManagerCommunicationFactory.java
---
@@ -27,15 +26,6 @@
public interf
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/2573
Refactor StreamOperator Hierachy to make Keys Explicit
This is more of a preview PR, I'm not yet completely done with testing and
making sure that everything works.
R: @StephanEwen
You c
[
https://issues.apache.org/jira/browse/FLINK-4552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533144#comment-15533144
]
ASF GitHub Bot commented on FLINK-4552:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/2572
[FLINK-4552] Refactor WindowOperator/Trigger Tests
This builds on #2570
Before, tests for WindowOperator, WindowAssigner, Trigger and WindowFunction
were all conflated in WindowOperato
[
https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533113#comment-15533113
]
ASF GitHub Bot commented on FLINK-4348:
---
GitHub user mxm opened a pull request:
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/2571
[FLINK-4348] Simplify logic of SlotManager
This pull request is split up into two commits:
1. It removes some code from the `SlotManager` to make it simpler.
- It makes use of `handleSlot
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2569#discussion_r81164326
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/messages/TaskControlMessages.scala
---
@@ -92,16 +92,6 @@ object TaskMessages {
//
--
[
https://issues.apache.org/jira/browse/FLINK-4711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533098#comment-15533098
]
ASF GitHub Bot commented on FLINK-4711:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2569#discussion_r81162283
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/JobManagerCommunicationFactory.java
---
@@ -27,15 +26,6 @@
public interface JobMa
[
https://issues.apache.org/jira/browse/FLINK-4711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533100#comment-15533100
]
ASF GitHub Bot commented on FLINK-4711:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2569#discussion_r81164597
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -873,8 +873,7 @@ class JobManager(
}
[
https://issues.apache.org/jira/browse/FLINK-4711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533099#comment-15533099
]
ASF GitHub Bot commented on FLINK-4711:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Domokos Miklós Kelen updated FLINK-4712:
Description:
We started working on implementing ranking predictions for recommender
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/2570
[FLINK-3674] Add an interface for Time aware User Functions
This moves the event-time/processing-time trigger code from
`WindowOperator` behind a well defined interface that can be used by
o
[
https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533076#comment-15533076
]
ASF GitHub Bot commented on FLINK-4068:
---
Github user twalthr commented on a diff in
1 - 100 of 214 matches
Mail list logo
