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-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 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
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 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 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 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 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
[
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
[
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-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=15351835#comment-15351835
]
Ivan Mushketyk commented on FLINK-4096:
---
It seems that JarOutputStream closes the Fi
[
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 edited comment on FLINK-4096 at 6/27/16 9:19 PM:
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-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
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-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
[
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
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-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
[
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-
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-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
[
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
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
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(
[
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
[
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
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=15352236#comment-15352236
]
ASF GitHub Bot commented on FLINK-3943:
---
Github user wuchong commented on a diff in
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=15352241#comment-15352241
]
ASF GitHub Bot commented on FLINK-3943:
---
Github user wuchong commented on the issue:
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-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 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
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
[
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 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:
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 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
[
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 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=15352341#comment-15352341
]
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
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-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 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-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
[
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
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(
Kostas Kloudas created FLINK-4126:
-
Summary: Unstable test
ZooKeeperLeaderElectionTest.testZooKeeperReelection
Key: FLINK-4126
URL: https://issues.apache.org/jira/browse/FLINK-4126
Project: Flink
301 - 360 of 360 matches
Mail list logo
