[
https://issues.apache.org/jira/browse/FLINK-4019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15368921#comment-15368921
]
ASF GitHub Bot commented on FLINK-4019:
---
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/2214#discussion_r70161839
--- Diff: docs/apis/streaming/connectors/kinesis.md ---
@@ -146,6 +146,50 @@ Also note that Flink can only restart the topology if
enough processing slots ar
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r70146784
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/GroupedDataSet.scala ---
@@ -282,27 +283,57 @@ class GroupedDataSet[T: ClassTag](
}
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15368557#comment-15368557
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15368461#comment-15368461
]
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_r70139954
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/GroupedDataSet.scala ---
@@ -282,27 +283,57 @@ class GroupedDataSet[T: ClassTag](
}
[
https://issues.apache.org/jira/browse/FLINK-4172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15368272#comment-15368272
]
ASF GitHub Bot commented on FLINK-4172:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-4172.
-
Resolution: Fixed
Fixed in 6c5eebb7e40439310b6949e35b67c72a3dc61c75
> Don't proxy a ProxiedObject
> -
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2213
---
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-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15368189#comment-15368189
]
ASF GitHub Bot commented on FLINK-4116:
---
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/2158#discussion_r70123498
--- Diff: docs/apis/metrics.md ---
@@ -0,0 +1,441 @@
+---
+title: "Metrics"
+# Top-level navigation
+top-nav-group: apis
+top-nav-pos: 13
[
https://issues.apache.org/jira/browse/FLINK-4154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15368130#comment-15368130
]
ASF GitHub Bot commented on FLINK-4154:
---
GitHub user greghogan opened a pull request
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2223
[FLINK-4154] [core] Correction of murmur hash breaks backwards compatibility
Revert "[FLINK-3623] [runtime] Adjust MurmurHash Algorithm"
This reverts commit 641a0d436c9b7a34ff33ceb370cf299
[
https://issues.apache.org/jira/browse/FLINK-4159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15368060#comment-15368060
]
ASF GitHub Bot commented on FLINK-4159:
---
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/2217#discussion_r70113214
--- Diff:
flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/pom.xml
---
@@ -207,15 +206,9 @@ under the License.
[
https://issues.apache.org/jira/browse/FLINK-4154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367950#comment-15367950
]
Greg Hogan commented on FLINK-4154:
---
I wanted to see how much skew this causes in case w
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2214#discussion_r70103527
--- Diff: docs/apis/streaming/connectors/kinesis.md ---
@@ -146,6 +146,50 @@ Also note that Flink can only restart the topology if
enough processing slots ar
[
https://issues.apache.org/jira/browse/FLINK-4019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367948#comment-15367948
]
ASF GitHub Bot commented on FLINK-4019:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367942#comment-15367942
]
ASF GitHub Bot commented on FLINK-4019:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2214
+1 to merge once travis is green.
---
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 a
[
https://issues.apache.org/jira/browse/FLINK-4185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367941#comment-15367941
]
ASF GitHub Bot commented on FLINK-4185:
---
GitHub user jsimsa opened a pull request:
GitHub user jsimsa opened a pull request:
https://github.com/apache/flink/pull/
[FLINK-4185] Reflecting rename from Tachyon to Alluxio.
Addresses: https://issues.apache.org/jira/browse/FLINK-4185
The updated documentation has been tested following steps testing Alluxio
[
https://issues.apache.org/jira/browse/FLINK-4185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiri Simsa updated FLINK-4185:
--
Description: The Tachyon project has been renamed to Alluxio earlier this
year. The goal of this issue i
[
https://issues.apache.org/jira/browse/FLINK-4018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367938#comment-15367938
]
ASF GitHub Bot commented on FLINK-4018:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2071
No problem :)
+1 to merge once travis is green
---
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
Jiri Simsa created FLINK-4185:
-
Summary: Reflecting rename from Tachyon to Alluxio
Key: FLINK-4185
URL: https://issues.apache.org/jira/browse/FLINK-4185
Project: Flink
Issue Type: Improvement
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2220
This PR will heavily conflict with #2219, in their current state we can't
merge one without blocking the other.
---
If your project is set up for it, you can reply to this email and have your
reply a
[
https://issues.apache.org/jira/browse/FLINK-4184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367882#comment-15367882
]
ASF GitHub Bot commented on FLINK-4184:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367876#comment-15367876
]
ASF GitHub Bot commented on FLINK-4183:
---
GitHub user twalthr opened a pull request:
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/2221
[FLINK-4183] [table] Move checking for StreamTableEnvironment into
validation layer
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list
[
https://issues.apache.org/jira/browse/FLINK-4184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367871#comment-15367871
]
ASF GitHub Bot commented on FLINK-4184:
---
Github user zentol commented on a diff in t
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2158#discussion_r70097270
--- Diff: docs/apis/metrics.md ---
@@ -0,0 +1,441 @@
+---
+title: "Metrics"
+# Top-level navigation
+top-nav-group: apis
+top-nav-pos:
[
https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367873#comment-15367873
]
ASF GitHub Bot commented on FLINK-4116:
---
Github user tillrohrmann commented on a dif
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2220#discussion_r70097230
--- Diff:
flink-core/src/main/java/org/apache/flink/metrics/reporter/AbstractReporter.java
---
@@ -84,4 +84,24 @@ public void notifyOfRemovedMetric(Metric met
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/1954
The changes look good to me. Thanks for your work @fijolekProjects :-) I
had one final remark concerning the `FixedSizeFifoQueue`. Maybe we could try to
replace it with the `ArrayDeque`.
[
https://issues.apache.org/jira/browse/FLINK-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367848#comment-15367848
]
ASF GitHub Bot commented on FLINK-3190:
---
Github user tillrohrmann commented on the i
[
https://issues.apache.org/jira/browse/FLINK-4184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367842#comment-15367842
]
ASF GitHub Bot commented on FLINK-4184:
---
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/2220#discussion_r70095846
--- Diff:
flink-core/src/main/java/org/apache/flink/metrics/reporter/AbstractReporter.java
---
@@ -84,4 +84,24 @@ public void notifyOfRemovedMetric(Metric met
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1954#discussion_r70094658
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/util/FixedSizeFifoQueue.java
---
@@ -0,0 +1,55 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367828#comment-15367828
]
ASF GitHub Bot commented on FLINK-3190:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367819#comment-15367819
]
ASF GitHub Bot commented on FLINK-3190:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1954#discussion_r70094058
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/FailureRateRestartStrategy.java
---
@@ -36,19 +36,19 @@
publi
[
https://issues.apache.org/jira/browse/FLINK-4180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367808#comment-15367808
]
Jark Wu commented on FLINK-4180:
I'll work on this.
> Create a batch SQL example
> --
[
https://issues.apache.org/jira/browse/FLINK-4181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367810#comment-15367810
]
Jark Wu commented on FLINK-4181:
I'll work on this.
> Add a basic streaming Table API exa
[
https://issues.apache.org/jira/browse/FLINK-4181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-4181:
--
Assignee: Jark Wu
> Add a basic streaming Table API example
> ---
>
[
https://issues.apache.org/jira/browse/FLINK-4180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-4180:
--
Assignee: Jark Wu
> Create a batch SQL example
> --
>
> Key: FL
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2109
1) If it is to include it, then I would suggest to just replace the
DefaultFilter with that, and probably give some initial patterns for e.g.
hidden files (start with "."). Having two implementations, b
[
https://issues.apache.org/jira/browse/FLINK-4184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367779#comment-15367779
]
ASF GitHub Bot commented on FLINK-4184:
---
GitHub user tillrohrmann opened a pull requ
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367780#comment-15367780
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user kl0u commented on the issue:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2220
[FLINK-4184] [metrics] Replace invalid characters in
ScheduledDropwizardReporter
The GraphiteReporter and GangliaReporter report metric names which can
contain invalid
characters. These ch
[
https://issues.apache.org/jira/browse/FLINK-4171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1536#comment-1536
]
ASF GitHub Bot commented on FLINK-4171:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4171.
Resolution: Fixed
Fixed via 474ec9660c528af8e19898114656fccb3e4747af
> StatsD does not accept metri
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2212
---
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 tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2212
Thanks for reviewing @zentol. Will be merging this PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not ha
[
https://issues.apache.org/jira/browse/FLINK-4171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367771#comment-15367771
]
ASF GitHub Bot commented on FLINK-4171:
---
Github user tillrohrmann commented on the i
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2217#discussion_r70085553
--- Diff:
flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/pom.xml
---
@@ -207,15 +206,9 @@ under the License.
[
https://issues.apache.org/jira/browse/FLINK-4159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367767#comment-15367767
]
ASF GitHub Bot commented on FLINK-4159:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367764#comment-15367764
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2109
1. Technically the GlobFilePathFilter is not redundant, since it fulfills
exactly the requirements of the issue; be able to filter files by specifying a
regular expression. It also offers functionalit
Till Rohrmann created FLINK-4184:
Summary: Ganglia and GraphiteReporter report metric names with
invalid characters
Key: FLINK-4184
URL: https://issues.apache.org/jira/browse/FLINK-4184
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367746#comment-15367746
]
ASF GitHub Bot commented on FLINK-4159:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-4159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367749#comment-15367749
]
ASF GitHub Bot commented on FLINK-4159:
---
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/2217#discussion_r70083585
--- Diff:
flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/pom.xml
---
@@ -207,15 +206,9 @@ under the License.
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2217#discussion_r70083520
--- Diff:
flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/pom.xml
---
@@ -207,15 +206,9 @@ under the License.
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367732#comment-15367732
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user kl0u commented on the issue:
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2109
Hi @mushketyk ,
Sorry for the late reply.
I have some general comments on the PR.
1) Given the FilePathFilter, I think that the GlobFilePathFilter is
redundant, right? It is a spec
[
https://issues.apache.org/jira/browse/FLINK-4181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-4181:
Description: Although the Table API does not offer much streaming features
yet, there should be a ru
[
https://issues.apache.org/jira/browse/FLINK-4182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-4182:
Priority: Blocker (was: Major)
> HA recovery not working properly under ApplicationMaster f
[
https://issues.apache.org/jira/browse/FLINK-4182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367727#comment-15367727
]
Aljoscha Krettek commented on FLINK-4182:
-
I think this one's a blocker for the 1.
Timo Walther created FLINK-4183:
---
Summary: Move checking for StreamTableEnvironment into validation
layer
Key: FLINK-4183
URL: https://issues.apache.org/jira/browse/FLINK-4183
Project: Flink
I
Timo Walther created FLINK-4180:
---
Summary: Create a batch SQL example
Key: FLINK-4180
URL: https://issues.apache.org/jira/browse/FLINK-4180
Project: Flink
Issue Type: New Feature
Comp
[
https://issues.apache.org/jira/browse/FLINK-4182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-4182:
--
Description:
When randomly killing TaskManager and ApplicationMaster, a job sometimes does
not
Stefan Richter created FLINK-4182:
-
Summary: HA recovery not working properly under ApplicationMaster
failures.
Key: FLINK-4182
URL: https://issues.apache.org/jira/browse/FLINK-4182
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-4180:
Labels: starter (was: )
> Create a batch SQL example
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-4181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-4181:
Labels: starter (was: )
> Add a basic streaming Table API example
> ---
[
https://issues.apache.org/jira/browse/FLINK-4172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367713#comment-15367713
]
ASF GitHub Bot commented on FLINK-4172:
---
Github user uce commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2213
+1 to merge. The previously not working `TriangleListing` example
(undirected, rmat, print) is now working with this change.
---
If your project is set up for it, you can reply to this email and have yo
Timo Walther created FLINK-4181:
---
Summary: Add a basic streaming Table API example
Key: FLINK-4181
URL: https://issues.apache.org/jira/browse/FLINK-4181
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-4179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-4179:
Labels: starter (was: )
> Update TPCHQuery3Table example
> --
>
>
Timo Walther created FLINK-4179:
---
Summary: Update TPCHQuery3Table example
Key: FLINK-4179
URL: https://issues.apache.org/jira/browse/FLINK-4179
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-3943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367695#comment-15367695
]
ASF GitHub Bot commented on FLINK-3943:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2169
@mushketyk Thanks for the PR.
I also reviewed the current status. I think it's good to compare your code
with #2159 before you rework it.
---
If your project is set up for it, you can reply to t
[
https://issues.apache.org/jira/browse/FLINK-3943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367692#comment-15367692
]
ASF GitHub Bot commented on FLINK-3943:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2169#discussion_r70075759
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetMinus.scala
---
@@ -0,0 +1,150 @@
+/*
+ * L
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2169#discussion_r70075580
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetMinus.scala
---
@@ -0,0 +1,150 @@
+/*
+ * L
[
https://issues.apache.org/jira/browse/FLINK-3943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367690#comment-15367690
]
ASF GitHub Bot commented on FLINK-3943:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2169#discussion_r70073020
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetMinus.scala
---
@@ -0,0 +1,150 @@
+/*
+ * L
[
https://issues.apache.org/jira/browse/FLINK-3943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367668#comment-15367668
]
ASF GitHub Bot commented on FLINK-3943:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367659#comment-15367659
]
ASF GitHub Bot commented on FLINK-3943:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2169#discussion_r70071856
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetMinus.scala
---
@@ -0,0 +1,150 @@
+/*
+ * L
[
https://issues.apache.org/jira/browse/FLINK-3943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367658#comment-15367658
]
ASF GitHub Bot commented on FLINK-3943:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2169#discussion_r70071730
--- 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=15367652#comment-15367652
]
ASF GitHub Bot commented on FLINK-3943:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2169#discussion_r70071069
--- Diff: flink-java/src/main/java/org/apache/flink/api/java/DataSet.java
---
@@ -18,8 +18,8 @@
package org.apache.flink.api.java;
--- End diff
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2169#discussion_r70070564
--- 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=15367645#comment-15367645
]
ASF GitHub Bot commented on FLINK-3943:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2169#discussion_r70069883
--- Diff: docs/apis/table.md ---
@@ -536,6 +536,29 @@ Table result = left.unionAll(right);
+ Minus
+
+
[
https://issues.apache.org/jira/browse/FLINK-3943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367640#comment-15367640
]
ASF GitHub Bot commented on FLINK-3943:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15367631#comment-15367631
]
Gabor Gevay commented on FLINK-4029:
You might want to reuse the FieldAccessor infrast
[
https://issues.apache.org/jira/browse/FLINK-3942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-3942.
-
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed in 815bc833f2c93227c19574119bcf1d00866030b5.
1 - 100 of 186 matches
Mail list logo
