[
https://issues.apache.org/jira/browse/FLINK-3675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350970#comment-15350970
]
Stefano Baghino commented on FLINK-3675:
The `lib` folder includes important JARs,
[
https://issues.apache.org/jira/browse/FLINK-3675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350970#comment-15350970
]
Stefano Baghino edited comment on FLINK-3675 at 6/27/16 1:17 PM:
---
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2146
@tillrohrmann I've addressed your comments and rebased the PR. You should
now be able to try it out locally.
---
If your project is set up for it, you can reply to this email and have your
reply appe
[
https://issues.apache.org/jira/browse/FLINK-1550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350973#comment-15350973
]
ASF GitHub Bot commented on FLINK-1550:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350974#comment-15350974
]
Maximilian Michels commented on FLINK-3675:
---
So that would be option 2 :) Actual
[
https://issues.apache.org/jira/browse/FLINK-3675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350992#comment-15350992
]
Stefano Baghino commented on FLINK-3675:
I must have misread something, I thought
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2166
LGTM
---
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-4099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351001#comment-15351001
]
ASF GitHub Bot commented on FLINK-4099:
---
Github user mxm commented on the issue:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2109#discussion_r68578183
--- Diff:
flink-core/src/test/java/org/apache/flink/api/common/io/FileInputFormatTest.java
---
@@ -314,41 +297,101 @@ public void testIgnoredUnderscoreFiles()
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351010#comment-15351010
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user zentol commented on a diff in t
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2166
Thank you for the review.
I'll wait until travis is passing and then merge it.
---
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-3675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351013#comment-15351013
]
Maximilian Michels commented on FLINK-3675:
---
Woops. Not enough coffee today ;) Y
[
https://issues.apache.org/jira/browse/FLINK-4099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351015#comment-15351015
]
ASF GitHub Bot commented on FLINK-4099:
---
Github user rmetzger commented on the issue
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2131#discussion_r68578735
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardDiscoverer.java
---
[
https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351030#comment-15351030
]
ASF GitHub Bot commented on FLINK-3231:
---
Github user tzulitai commented on a diff in
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2083#discussion_r68579929
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -790,39 +767,95 @@ else if (result instanceof TriggerSavepointFailu
[
https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351027#comment-15351027
]
ASF GitHub Bot commented on FLINK-3231:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351039#comment-15351039
]
ASF GitHub Bot commented on FLINK-3713:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2083#discussion_r68580226
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -790,39 +767,95 @@ else if (result instanceof TriggerSavepointFailu
[
https://issues.apache.org/jira/browse/FLINK-3675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350953#comment-15350953
]
Maximilian Michels edited comment on FLINK-3675 at 6/27/16 1:41 PM:
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2131#discussion_r68579220
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java
---
[
https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351043#comment-15351043
]
ASF GitHub Bot commented on FLINK-3713:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2083#discussion_r68580451
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -790,39 +767,95 @@ else if (result instanceof TriggerSavepointFailu
[
https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351046#comment-15351046
]
ASF GitHub Bot commented on FLINK-3713:
---
Github user tillrohrmann commented on a dif
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2134
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2112
---
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-4093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351052#comment-15351052
]
ASF GitHub Bot commented on FLINK-4093:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-3951.
---
Resolution: Fixed
Implemented in ee3c7a88bb74232e4884899699aaa08ae2b6e038
> Add Histogram Met
[
https://issues.apache.org/jira/browse/FLINK-3675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351055#comment-15351055
]
Stefano Baghino commented on FLINK-3675:
Of course, thanks for clarifying this to
[
https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351053#comment-15351053
]
ASF GitHub Bot commented on FLINK-3951:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4093.
---
Resolution: Fixed
Implemented in d43bf8d9b3085d1341bfca61e05c2a77e5426226
> Expose metric int
[
https://issues.apache.org/jira/browse/FLINK-4053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351056#comment-15351056
]
ASF GitHub Bot commented on FLINK-4053:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351062#comment-15351062
]
ASF GitHub Bot commented on FLINK-3713:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2083#discussion_r68581644
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -790,39 +767,95 @@ else if (result instanceof TriggerSavepointFailu
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2128#discussion_r68580911
--- Diff:
flink-streaming-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSink.java
---
@@ -76,6 +76,9 @@
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2131#discussion_r68582164
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java
---
[
https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351069#comment-15351069
]
ASF GitHub Bot commented on FLINK-3231:
---
Github user tzulitai commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2131#discussion_r68582306
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardDiscoverer.java
---
[
https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351071#comment-15351071
]
ASF GitHub Bot commented on FLINK-3231:
---
Github user rmetzger commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2131#discussion_r68582684
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyInterface.java
---
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2131#discussion_r68582645
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardDiscoverer.java
---
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2083
Good work @uce :-)
I agree that it currently it is a bit clumsy to discard savepoints of jobs
which are no longer running. From the user perspective it should be as easy as
possible.
[
https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351075#comment-15351075
]
ASF GitHub Bot commented on FLINK-3713:
---
Github user tillrohrmann commented on the i
[
https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351077#comment-15351077
]
ASF GitHub Bot commented on FLINK-3231:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351076#comment-15351076
]
ASF GitHub Bot commented on FLINK-3231:
---
Github user tzulitai commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2131#discussion_r68583275
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java
---
[
https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351089#comment-15351089
]
ASF GitHub Bot commented on FLINK-3231:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2131
@tzulitai: I'm still not done with the review. I hope I can get it done in
the next two hours.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
[
https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351093#comment-15351093
]
ASF GitHub Bot commented on FLINK-3231:
---
Github user rmetzger commented on the issue
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2128
I tihnk this looks good.
One remark for future contributions though: I think some of your tests are
too specific.
These include `openCallDeclaresQueue`, `throwExceptionIfChannelIsNull` a
[
https://issues.apache.org/jira/browse/FLINK-4053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351104#comment-15351104
]
ASF GitHub Bot commented on FLINK-4053:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351101#comment-15351101
]
ASF GitHub Bot commented on FLINK-3231:
---
Github user tzulitai commented on the issue
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2155
Thank you very much for your contribution @thormanrd. The CEP changes look
really good :-)
The only thing which we could improve is to add a unit test for the
`OrFilterFunction`.
[
https://issues.apache.org/jira/browse/FLINK-3319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351108#comment-15351108
]
ASF GitHub Bot commented on FLINK-3319:
---
Github user tillrohrmann commented on the i
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2131
@rmetzger
No problem, thank you! I'll reply to your comments after you finish
reviewing :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHu
[
https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351157#comment-15351157
]
ASF GitHub Bot commented on FLINK-3713:
---
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/2083#discussion_r68587921
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java
---
@@ -305,6 +307,11 @@ public static void printHelpForSavepoint() {
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351158#comment-15351158
]
Greg Hogan commented on FLINK-1707:
---
>From the "A Binary Variable Model for Affinity Pro
[
https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351161#comment-15351161
]
ASF GitHub Bot commented on FLINK-3713:
---
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/2083#discussion_r68588625
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -790,39 +767,95 @@ else if (result instanceof TriggerSavepointFailure) {
[
https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351166#comment-15351166
]
ASF GitHub Bot commented on FLINK-3713:
---
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/2083#discussion_r68588080
--- Diff: docs/apis/cli.md ---
@@ -279,13 +289,27 @@ guarantees for a stop request.
Action "savepoint" triggers savepoints for a running job or disposes
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2083#discussion_r68590084
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -790,39 +767,95 @@ else if (result instanceof TriggerSavepointFailure) {
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2158#discussion_r68590134
--- Diff: docs/apis/common/index.md ---
@@ -1350,3 +1350,211 @@ You may specify program arguments before the job is
executed. The plan visualiza
the
[
https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351180#comment-15351180
]
ASF GitHub Bot commented on FLINK-3713:
---
Github user uce commented on a diff in the
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2083
Thanks for review. I will propagate the errors, make the job ID/JAR
arguments optional, and try to simplify parts of the CLI as you suggested.
Regarding including the RocksDB jar in dist, I think
[
https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351186#comment-15351186
]
ASF GitHub Bot commented on FLINK-3713:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351181#comment-15351181
]
ASF GitHub Bot commented on FLINK-4116:
---
Github user tillrohrmann commented on a dif
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/2110
---
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
[
https://issues.apache.org/jira/browse/FLINK-3974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351196#comment-15351196
]
ASF GitHub Bot commented on FLINK-3974:
---
Github user aljoscha closed the pull reques
[
https://issues.apache.org/jira/browse/FLINK-3974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-3974.
-
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed in
https://github.com/apache/flink/co
[
https://issues.apache.org/jira/browse/FLINK-3974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-3974:
---
Assignee: Aljoscha Krettek
> enableObjectReuse fails when an operator chains to multi
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2131#discussion_r68594061
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java
---
@@ -86,
[
https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351210#comment-15351210
]
ASF GitHub Bot commented on FLINK-3231:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351211#comment-15351211
]
Josep Rubió commented on FLINK-1707:
Agree, I put this same statement in the design do
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2156
@tillrohrmann just added a test for `ChainedAllReduceDriver`. I didn't see
a way to build a lightweight test for chained drivers as we do with the
unchained drivers.
---
If your project is set up
[
https://issues.apache.org/jira/browse/FLINK-4113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351395#comment-15351395
]
ASF GitHub Bot commented on FLINK-4113:
---
Github user greghogan commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-4096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4096:
--
Description:
{code}
final JarOutputStream jos = new JarOutputStream(new
FileOutputStream(this.outputFile),
[
https://issues.apache.org/jira/browse/FLINK-3297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351474#comment-15351474
]
Omar Alvarez commented on FLINK-3297:
-
Done!
> Streaming connector for ZeroMQ
>
[
https://issues.apache.org/jira/browse/FLINK-3297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351612#comment-15351612
]
Robert Metzger commented on FLINK-3297:
---
Perfect, thanks a lot!
> Streaming connect
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351651#comment-15351651
]
ASF GitHub Bot commented on FLINK-3477:
---
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/1517#discussion_r68640552
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/SameTypePairComparator.java
---
@@ -0,0 +1,44 @@
+/*
+ * Licensed to the A
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351664#comment-15351664
]
ASF GitHub Bot commented on FLINK-3477:
---
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/1517#discussion_r68641370
--- Diff:
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/ReduceNode.java ---
@@ -45,10 +46,28 @@ public ReduceNode(ReduceOperatorBase operator
[
https://issues.apache.org/jira/browse/FLINK-3319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351673#comment-15351673
]
ASF GitHub Bot commented on FLINK-3319:
---
Github user thormanrd commented on the issu
Github user thormanrd commented on the issue:
https://github.com/apache/flink/pull/2155
Thanks tillrohrmann. I put the test case in PatternTest.java as I didn't
think it warranted a separate class. See public void testPatternWithOrFilter()
in that class file.
I'll keep work
[
https://issues.apache.org/jira/browse/FLINK-4110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351675#comment-15351675
]
ASF GitHub Bot commented on FLINK-4110:
---
Github user jgrier commented on the issue:
Github user jgrier commented on the issue:
https://github.com/apache/flink/pull/2153
What I would like to see here is that the tests in the quickstart actually
test the code from the job in the quickstart. For example if the job in the
quickstart is WordCount it would be nice to show
GitHub user mushketyk opened a pull request:
https://github.com/apache/flink/pull/2169
[FLINK-3943] Add support for EXCEPT operator
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your change
[
https://issues.apache.org/jira/browse/FLINK-3943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351676#comment-15351676
]
ASF GitHub Bot commented on FLINK-3943:
---
GitHub user mushketyk opened a pull request
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2169
Renamed UnionITCase to SetOperationsITCase as suggested here:
https://github.com/apache/flink/pull/2159
---
If your project is set up for it, you can reply to this email and have your
reply appear
[
https://issues.apache.org/jira/browse/FLINK-3943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351688#comment-15351688
]
ASF GitHub Bot commented on FLINK-3943:
---
Github user mushketyk commented on the issu
GitHub user thormanrd opened a pull request:
https://github.com/apache/flink/pull/2170
Merge pull request #1 from apache/master
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your changes ta
Github user mjsax commented on the issue:
https://github.com/apache/flink/pull/1813
My two cents:
1) seems to got sorted out (thx @tzulitai for the input!)
2) I personally do not care too much about the name conflict. Reusing the
same class for sink and source sounds reasonable
[
https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351701#comment-15351701
]
ASF GitHub Bot commented on FLINK-3034:
---
Github user mjsax commented on the issue:
Github user thormanrd closed the pull request at:
https://github.com/apache/flink/pull/2170
---
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 e
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351713#comment-15351713
]
ASF GitHub Bot commented on FLINK-3477:
---
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/1517#discussion_r68646048
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/MutableHashTable.java
---
@@ -1480,28 +1480,17 @@ public static int getInitia
[
https://issues.apache.org/jira/browse/FLINK-4120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351739#comment-15351739
]
Dénes Vadász commented on FLINK-4120:
-
Whether the state is re-computed or restored fr
[
https://issues.apache.org/jira/browse/FLINK-4120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351739#comment-15351739
]
Dénes Vadász edited comment on FLINK-4120 at 6/27/16 8:23 PM:
--
201 - 300 of 360 matches
Mail list logo
