[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15144128#comment-15144128
]
Dongwon Kim edited comment on FLINK-1502 at 2/12/16 6:31 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15144128#comment-15144128
]
Dongwon Kim edited comment on FLINK-1502 at 2/12/16 6:29 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15144128#comment-15144128
]
Dongwon Kim commented on FLINK-1502:
Before deciding the design, we should take into c
[
https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15144103#comment-15144103
]
ASF GitHub Bot commented on FLINK-3179:
---
Github user ramkrish86 commented on the pul
Github user ramkrish86 commented on the pull request:
https://github.com/apache/flink/pull/1553#issuecomment-183190815
@fhueske
I got the problem that I was making. My bad. I was not applying the
partition function on the Key ie. the String part returned from the flat map
and hen
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15144053#comment-15144053
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user stefanobaghino commented on the
Github user stefanobaghino commented on the pull request:
https://github.com/apache/flink/pull/1581#issuecomment-183181049
@fhueske If this is what you had in mind I can go on and apply it to the
rest of the examples.
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143862#comment-15143862
]
ASF GitHub Bot commented on FLINK-3368:
---
Github user ndimiduk commented on the pull
Github user ndimiduk commented on the pull request:
https://github.com/apache/flink/pull/1623#issuecomment-183143954
I just ran into this as well. Do you mind backporting to 0.10 branch too?
---
If your project is set up for it, you can reply to this email and have your
reply appear o
[
https://issues.apache.org/jira/browse/FLINK-3392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143734#comment-15143734
]
Ted Yu commented on FLINK-3392:
---
If you think the size() call is primitive:
http://grepcode.
[
https://issues.apache.org/jira/browse/FLINK-3392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143736#comment-15143736
]
Ted Yu commented on FLINK-3392:
---
Please read the javadoc at the beginning of the class:
http
[
https://issues.apache.org/jira/browse/FLINK-3392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143722#comment-15143722
]
Stephan Ewen commented on FLINK-3392:
-
I don't understand this issue. It is an access
Ted Yu created FLINK-3392:
-
Summary: Unprotected access to elements in
ClosableBlockingQueue#size()
Key: FLINK-3392
URL: https://issues.apache.org/jira/browse/FLINK-3392
Project: Flink
Issue Type: B
[
https://issues.apache.org/jira/browse/FLINK-3340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143566#comment-15143566
]
ASF GitHub Bot commented on FLINK-3340:
---
GitHub user greghogan opened a pull request
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/1626
[FLINK-3340] [runtime] Fix object juggling in drivers
A second attempt at object swapping in reduce drivers.
You can merge this pull request into a Git repository by running:
$ git pull https
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/1564#issuecomment-183066952
@uce I rebased, made the noted changes, and updated the pull request.
---
If your project is set up for it, you can reply to this email and have your
reply appear on G
[
https://issues.apache.org/jira/browse/FLINK-3160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143547#comment-15143547
]
ASF GitHub Bot commented on FLINK-3160:
---
Github user greghogan commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143530#comment-15143530
]
Stephan Ewen edited comment on FLINK-2609 at 2/11/16 9:26 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-2609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143530#comment-15143530
]
Stephan Ewen commented on FLINK-2609:
-
Flink internally has its own POJO serializer an
[
https://issues.apache.org/jira/browse/FLINK-3386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143520#comment-15143520
]
Stephan Ewen commented on FLINK-3386:
-
I don't get the duplicate status. This issue is
[
https://issues.apache.org/jira/browse/FLINK-3351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3351.
---
> RocksDB Backend cannot determine correct local db path
> ---
[
https://issues.apache.org/jira/browse/FLINK-3358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143504#comment-15143504
]
Stephan Ewen commented on FLINK-3358:
-
Added utility constructors and reworked initial
[
https://issues.apache.org/jira/browse/FLINK-3351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3351.
-
Resolution: Fixed
Assignee: Stephan Ewen
Fix Version/s: 1.0.0
Fixed via edae79340d
[
https://issues.apache.org/jira/browse/FLINK-3389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143502#comment-15143502
]
Stephan Ewen commented on FLINK-3389:
-
Added code for pre-defined options profiles in
[
https://issues.apache.org/jira/browse/FLINK-3271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3271.
-
Resolution: Fixed
Fix Version/s: 1.0.0
Fixed via 82c7383a67a8349d05dc98780667b3a47ab3cc54
[
https://issues.apache.org/jira/browse/FLINK-3271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3271.
---
> Using webhdfs in a flink topology throws classnotfound exception
> -
[
https://issues.apache.org/jira/browse/FLINK-3271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143497#comment-15143497
]
ASF GitHub Bot commented on FLINK-3271:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143496#comment-15143496
]
Stephan Ewen commented on FLINK-3299:
-
One thing interesting about save points is that
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1543
---
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-3374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3374.
-
Resolution: Won't Fix
Spurious I/O failure on containered CI systems
> CEPITCase testSimplePatter
[
https://issues.apache.org/jira/browse/FLINK-3374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3374.
---
> CEPITCase testSimplePatternEventTime fails
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-2445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143478#comment-15143478
]
ASF GitHub Bot commented on FLINK-2445:
---
GitHub user mliesenberg opened a pull reque
GitHub user mliesenberg opened a pull request:
https://github.com/apache/flink/pull/1625
[FLINK-2445] Add tests for HadoopOutputFormats
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mliesenberg/flink FLINK-2445-tests
Alternati
[
https://issues.apache.org/jira/browse/FLINK-3187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143386#comment-15143386
]
ASF GitHub Bot commented on FLINK-3187:
---
Github user uce commented on the pull reque
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1470#issuecomment-183037438
Thanks for addressing the comments. Changes look good!
Regarding the API breaking config key changes: is it feasible to just
deprecate the old configuration keys ins
[
https://issues.apache.org/jira/browse/FLINK-3364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-3364.
--
Resolution: Fixed
Fixed in dcea46e.
> Don't initialize SavepointStore in JobManager constructor
> -
[
https://issues.apache.org/jira/browse/FLINK-3364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143370#comment-15143370
]
ASF GitHub Bot commented on FLINK-3364:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1622
---
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-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143301#comment-15143301
]
ASF GitHub Bot commented on FLINK-3179:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1553#issuecomment-183014873
If a `Partitioner` is implemented such that is does not partition based on
the key attribute, it cannot be used for a Reduce or GroupReduce transformation
anyways. Also
[
https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143300#comment-15143300
]
ASF GitHub Bot commented on FLINK-3226:
---
GitHub user twalthr opened a pull request:
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/1624
[FLINK-3226] Translation from and to POJOs for CodeGenerator
This PR implements full POJO support as input and output type of the Table
API. It is now possible to convert from an arbitrary type to a
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1622#issuecomment-183009153
Travis gives the green light (finally). I'm going 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 we
[
https://issues.apache.org/jira/browse/FLINK-3364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143261#comment-15143261
]
ASF GitHub Bot commented on FLINK-3364:
---
Github user uce commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143203#comment-15143203
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user ggevay commented on the pull re
Github user ggevay commented on the pull request:
https://github.com/apache/flink/pull/1517#issuecomment-182993653
I think I've addressed all the comments, except documenting `CombineHint`
(I will do that tomorrow). Thanks again for reviewing the PR!
---
If your project is set up for
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143197#comment-15143197
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user ggevay commented on a diff in t
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r52643374
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/manual/ReducePerformance.java
---
@@ -0,0 +1,191 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143195#comment-15143195
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user ggevay commented on a diff in t
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r52643336
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/ReduceHashTableTest.java
---
@@ -0,0 +1,501 @@
+/*
+ * Licensed to the A
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r52643279
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/MemoryHashTableTest.java
---
@@ -100,340 +101,371 @@
@Test
publi
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143198#comment-15143198
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user ggevay commented on a diff in t
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r52643218
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReduceHashTable.java
---
@@ -0,0 +1,1014 @@
+/*
+ * Licensed to the Apac
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143194#comment-15143194
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user ggevay commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143191#comment-15143191
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user ggevay commented on a diff in t
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r52643138
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReduceHashTable.java
---
@@ -0,0 +1,1014 @@
+/*
+ * Licensed to the Apac
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143190#comment-15143190
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user ggevay commented on a diff in t
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r52642960
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReduceHashTable.java
---
@@ -0,0 +1,1014 @@
+/*
+ * Licensed to the Apac
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r52642844
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/operators/base/ReduceOperatorBase.java
---
@@ -52,6 +52,30 @@
*/
public class Reduce
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143187#comment-15143187
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user ggevay commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-3296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143176#comment-15143176
]
ASF GitHub Bot commented on FLINK-3296:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1563#issuecomment-182983683
Changes look good to me
---
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 hav
[
https://issues.apache.org/jira/browse/FLINK-3189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143151#comment-15143151
]
Robert Metzger edited comment on FLINK-3189 at 2/11/16 6:01 PM:
[
https://issues.apache.org/jira/browse/FLINK-3352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-3352:
---
Assignee: Aljoscha Krettek
> RocksDB Backend cannot determine correct hdfs path
> ---
[
https://issues.apache.org/jira/browse/FLINK-2445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143156#comment-15143156
]
ASF GitHub Bot commented on FLINK-2445:
---
Github user mliesenberg commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-3189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143151#comment-15143151
]
Robert Metzger edited comment on FLINK-3189 at 2/11/16 5:59 PM:
Github user mliesenberg commented on the pull request:
https://github.com/apache/flink/pull/1486#issuecomment-182980098
sure, though I cant close it.
Found some things that can still be improved, will add that and open a PR
tonight.
---
If your project is set up for it, you can
[
https://issues.apache.org/jira/browse/FLINK-3374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-3374:
-
Assignee: (was: Till Rohrmann)
> CEPITCase testSimplePatternEventTime fails
>
[
https://issues.apache.org/jira/browse/FLINK-3189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143151#comment-15143151
]
Robert Metzger commented on FLINK-3189:
---
Let me look into this.
> Error while parsi
[
https://issues.apache.org/jira/browse/FLINK-3189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143147#comment-15143147
]
Vijay Srinivasaraghavan edited comment on FLINK-3189 at 2/11/16 5:52 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-3189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143147#comment-15143147
]
Vijay Srinivasaraghavan commented on FLINK-3189:
What is the right way to
[
https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143135#comment-15143135
]
ASF GitHub Bot commented on FLINK-3368:
---
GitHub user rmetzger opened a pull request:
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/1623
[FLINK-3368][Kafka 0.8] Handle leader changes in Kafka Consumer.
Please see the JIRA for an explanation of the problems.
tl;dr: The Kafka 0.8 consumer now handles broker failures internally,
wi
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1553#issuecomment-182969700
Might be a stupid question, but what if the partitioner depends on the
number of elements. E.g. if you use `partitionCustom` with `Partitioner` which
counts interna
[
https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143123#comment-15143123
]
ASF GitHub Bot commented on FLINK-3179:
---
Github user tillrohrmann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143088#comment-15143088
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/1620#discussion_r52634496
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericExactlyOnceSink.java
---
@@ -0,0 +1,173 @@
+/**
+ * L
[
https://issues.apache.org/jira/browse/FLINK-3372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143062#comment-15143062
]
Nick Dimiduk commented on FLINK-3372:
-
Thanks folks.
> Setting custom YARN applicatio
[
https://issues.apache.org/jira/browse/FLINK-3372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143061#comment-15143061
]
ASF GitHub Bot commented on FLINK-3372:
---
Github user ndimiduk closed the pull reques
Github user ndimiduk closed the pull request at:
https://github.com/apache/flink/pull/1607
---
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 en
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1620#issuecomment-182959361
Good work @zentol. I had some inline comments.
My main concern is that upon recovery you'll write all elements of the
previously written checkpoint again to
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143053#comment-15143053
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user tillrohrmann commented on the p
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1567#issuecomment-182959195
Hey @ChengXiangLi,
I merged your changes together with #1600. You can close this.
---
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-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143046#comment-15143046
]
ASF GitHub Bot commented on FLINK-3226:
---
Github user vasia closed the pull request a
Github user vasia closed the pull request at:
https://github.com/apache/flink/pull/1600
---
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 enabl
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143045#comment-15143045
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1620#discussion_r52631298
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericExactlyOnceSink.java
---
@@ -0,0 +1,173 @@
+/**
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143033#comment-15143033
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-2445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143032#comment-15143032
]
ASF GitHub Bot commented on FLINK-2445:
---
Github user StephanEwen commented on the pu
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/1620#discussion_r52630950
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericExactlyOnceSink.java
---
@@ -0,0 +1,173 @@
+/**
+ * L
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1486#issuecomment-182957754
@mliesenberg Thanks for picking this up. Let's close this PR. Would be
great if you could open a new PR based on the branch you linked.
---
If your project is set u
[
https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143030#comment-15143030
]
ASF GitHub Bot commented on FLINK-3226:
---
Github user vasia commented on the pull req
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143029#comment-15143029
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1620#discussion_r52630685
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericExactlyOnceSink.java
---
@@ -0,0 +1,173 @@
+/**
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1600#issuecomment-182957377
It's all green :D Merging.
---
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 th
[
https://issues.apache.org/jira/browse/FLINK-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143006#comment-15143006
]
ASF GitHub Bot commented on FLINK-2380:
---
Github user kl0u commented on the pull requ
Github user kl0u commented on the pull request:
https://github.com/apache/flink/pull/1524#issuecomment-182951707
I have updated the PR with the new comments.
Please review the new PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on G
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142988#comment-15142988
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1620#discussion_r52627131
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericExactlyOnceSink.java
---
@@ -0,0 +1,173 @@
+/**
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142985#comment-15142985
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user tillrohrmann commented on a dif
1 - 100 of 254 matches
Mail list logo
