Kostas Kloudas created FLINK-4126:
-
Summary: Unstable test
ZooKeeperLeaderElectionTest.testZooKeeperReelection
Key: FLINK-4126
URL: https://issues.apache.org/jira/browse/FLINK-4126
Project: Flink
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2169#discussion_r68704013
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/logical/operators.scala
---
@@ -236,6 +236,32 @@ case class Aggregate(
[
https://issues.apache.org/jira/browse/FLINK-3943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15352459#comment-15352459
]
ASF GitHub Bot commented on FLINK-3943:
---
Github user mushketyk commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15352370#comment-15352370
]
ASF GitHub Bot commented on FLINK-3231:
---
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/2131#discussion_r68698386
--- 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-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15352347#comment-15352347
]
ASF GitHub Bot commented on FLINK-3920:
---
Github user chiwanpark commented on a diff
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/2152#discussion_r68696822
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/BlockMatrix.scala
---
@@ -0,0 +1,287 @@
+/*
+ * Licensed to
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/2152#discussion_r68696809
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/BlockMatrix.scala
---
@@ -0,0 +1,287 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15352346#comment-15352346
]
ASF GitHub Bot commented on FLINK-3920:
---
Github user chiwanpark commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15352343#comment-15352343
]
ASF GitHub Bot commented on FLINK-3231:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15352341#comment-15352341
]
ASF GitHub Bot commented on FLINK-3920:
---
Github user chiwanpark commented on a diff
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2131#discussion_r68696712
--- 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-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15352342#comment-15352342
]
ASF GitHub Bot commented on FLINK-3920:
---
Github user chiwanpark commented on a diff
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/2152#discussion_r68696680
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/BlockMatrix.scala
---
@@ -0,0 +1,287 @@
+/*
+ * Licensed to
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/2152#discussion_r68696692
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/BlockMatrix.scala
---
@@ -0,0 +1,287 @@
+/*
+ * Licensed to
GitHub user wuchong opened a pull request:
https://github.com/apache/flink/pull/2173
[FLINK-4109] [tableAPI] Change the name of ternary condition operator
It's better to use "?" than "eval()" for ternary condition operator in
Table API since most people comming from Java/C/C++ know
[
https://issues.apache.org/jira/browse/FLINK-4109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15352339#comment-15352339
]
ASF GitHub Bot commented on FLINK-4109:
---
GitHub user wuchong opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15352337#comment-15352337
]
ASF GitHub Bot commented on FLINK-3920:
---
Github user chiwanpark commented on a diff
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/2152#discussion_r68696490
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/BlockMatrix.scala
---
@@ -0,0 +1,287 @@
+/*
+ * Licensed to
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/2152#discussion_r68696421
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/BlockMatrix.scala
---
@@ -0,0 +1,287 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15352334#comment-15352334
]
ASF GitHub Bot commented on FLINK-3920:
---
Github user chiwanpark commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15352298#comment-15352298
]
ASF GitHub Bot commented on FLINK-3231:
---
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/2131#discussion_r68694102
--- 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-3943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15352241#comment-15352241
]
ASF GitHub Bot commented on FLINK-3943:
---
Github user wuchong commented on the issue:
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/2169
Hi @mushketyk, I think we should remove duplicate records in CoGroup
instead of using `distinct`. Others looks good to me.
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-3943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15352236#comment-15352236
]
ASF GitHub Bot commented on FLINK-3943:
---
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/2169#discussion_r68689676
--- Diff: docs/apis/table.md ---
@@ -873,7 +920,7 @@ val result = tableEnv.sql(
Limitations
-The current version of streaming SQL onl
[
https://issues.apache.org/jira/browse/FLINK-3943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15352233#comment-15352233
]
ASF GitHub Bot commented on FLINK-3943:
---
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/2169#discussion_r68689427
--- Diff: docs/apis/table.md ---
@@ -695,6 +718,30 @@ val result = left.unionAll(right);
+ Minus
+
+Si
[
https://issues.apache.org/jira/browse/FLINK-3943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15352221#comment-15352221
]
ASF GitHub Bot commented on FLINK-3943:
---
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/2169#discussion_r68687942
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/logical/operators.scala
---
@@ -236,6 +236,32 @@ case class Aggregate(
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2169#discussion_r68687402
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetMinus.scala
---
@@ -0,0 +1,106 @@
+/*
+ * L
[
https://issues.apache.org/jira/browse/FLINK-3943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15352215#comment-15352215
]
ASF GitHub Bot commented on FLINK-3943:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351980#comment-15351980
]
Fabian Hueske commented on FLINK-3873:
--
The intention was to implement a StreamTableS
Chris Hogue created FLINK-4125:
--
Summary: Yarn CLI incorrectly calculates slotsPerTM when
parallelism < task manager count
Key: FLINK-4125
URL: https://issues.apache.org/jira/browse/FLINK-4125
Project: F
[
https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-2765:
--
Description:
Currently 0.98.11 is used:
{code}
0.98.11-hadoop2
{code}
Stable release for hadoop-
[
https://issues.apache.org/jira/browse/FLINK-4118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351891#comment-15351891
]
ASF GitHub Bot commented on FLINK-4118:
---
Github user iemejia closed the pull request
Github user iemejia closed the pull request at:
https://github.com/apache/flink/pull/2164
---
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 ena
[
https://issues.apache.org/jira/browse/FLINK-3873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351882#comment-15351882
]
Ivan Mushketyk commented on FLINK-3873:
---
Should this implement BatchTableSink, Strea
[
https://issues.apache.org/jira/browse/FLINK-4096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351881#comment-15351881
]
ASF GitHub Bot commented on FLINK-4096:
---
GitHub user mushketyk opened a pull request
GitHub user mushketyk opened a pull request:
https://github.com/apache/flink/pull/2172
[FLINK-4096] Ensure JarOutputStream is always closed
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If you
[
https://issues.apache.org/jira/browse/FLINK-4124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-4124:
--
Description:
Instances of the failure:
https://s3.amazonaws.com/archive.travis-ci.org/jobs/140
Kostas Kloudas created FLINK-4124:
-
Summary: Unstable test
WrapperSetupHelperTest.testCreateTopologyContext
Key: FLINK-4124
URL: https://issues.apache.org/jira/browse/FLINK-4124
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351835#comment-15351835
]
Ivan Mushketyk edited comment on FLINK-4096 at 6/27/16 9:19 PM:
[
https://issues.apache.org/jira/browse/FLINK-4096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351835#comment-15351835
]
Ivan Mushketyk edited comment on FLINK-4096 at 6/27/16 9:18 PM:
[
https://issues.apache.org/jira/browse/FLINK-4096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351835#comment-15351835
]
Ivan Mushketyk commented on FLINK-4096:
---
It seems that JarOutputStream closes the Fi
[
https://issues.apache.org/jira/browse/FLINK-4029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Mushketyk reassigned FLINK-4029:
-
Assignee: Ivan Mushketyk
> Multi-field "sum" function just like "keyBy"
> ---
[
https://issues.apache.org/jira/browse/FLINK-4029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351815#comment-15351815
]
Ivan Mushketyk commented on FLINK-4029:
---
I will work on this.
> Multi-field "sum" f
[
https://issues.apache.org/jira/browse/FLINK-4096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351801#comment-15351801
]
Ivan Mushketyk commented on FLINK-4096:
---
I'll work on this.
> Nested FileOutputStre
[
https://issues.apache.org/jira/browse/FLINK-4096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Mushketyk reassigned FLINK-4096:
-
Assignee: Ivan Mushketyk
> Nested FileOutputStream is not closed in JarFileCreator
>
[
https://issues.apache.org/jira/browse/FLINK-4053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351793#comment-15351793
]
ASF GitHub Bot commented on FLINK-4053:
---
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/2128#discussion_r68654363
--- Diff:
flink-streaming-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSink.java
---
@@ -76,6 +76,9
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2128
@zentol I see your point. Do you suggest to remove these tests?
---
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
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r68651782
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/InPlaceMutableHashTable.java
---
@@ -0,0 +1,1079 @@
+/*
+ * Licensed
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2160
---
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 thormanrd closed the pull request at:
https://github.com/apache/flink/pull/2155
---
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
Github user thormanrd commented on the issue:
https://github.com/apache/flink/pull/2155
Create PR #1271 with clean commit history
---
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
GitHub user thormanrd opened a pull request:
https://github.com/apache/flink/pull/2171
FLINK-3319 Added the or function to the CEP pattern
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15351760#comment-15351760
]
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_r68649923
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/manual/ReducePerformance.java
---
@@ -0,0 +1,237 @@
+/*
+ * Licensed to the Apache Softwa
[
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:
--
[
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
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-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 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-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 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
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
[
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 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=15351676#comment-15351676
]
ASF GitHub Bot commented on FLINK-3943:
---
GitHub user mushketyk opened a pull request
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-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
[
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
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-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
[
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-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-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-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-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
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-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
[
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
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-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
[
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
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-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
[
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:
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=15351180#comment-15351180
]
ASF GitHub Bot commented on FLINK-3713:
---
Github user uce commented on a diff in the
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
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 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
[
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
1 - 100 of 360 matches
Mail list logo
