[
https://issues.apache.org/jira/browse/FLINK-3936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15300131#comment-15300131
]
ASF GitHub Bot commented on FLINK-3936:
---
GitHub user fhueske opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15300162#comment-15300162
]
ASF GitHub Bot commented on FLINK-2044:
---
Github user vasia commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15300177#comment-15300177
]
ASF GitHub Bot commented on FLINK-2044:
---
Github user greghogan commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15300223#comment-15300223
]
ASF GitHub Bot commented on FLINK-3945:
---
Github user greghogan commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-1673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15300236#comment-15300236
]
Robert Metzger commented on FLINK-1673:
---
I can not remember any user asking for this feature. I
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15300238#comment-15300238
]
ASF GitHub Bot commented on FLINK-2044:
---
Github user gallenvara commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-3586.
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed with af0f41824a1b54b71060c9ddd4f4830d45436172
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/2035
[FLINK-3936] [tableAPI] Add MIN/MAX aggregation for Boolean.
Adds support for min/max aggregations on boolean columns.
Unit tests for new aggregation included.
- [X] General
-
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15300178#comment-15300178
]
ASF GitHub Bot commented on FLINK-2044:
---
Github user vasia commented on the pull request:
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1956#issuecomment-221603967
The failures were in the `HITSAlgorithmITCase`.
---
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
[
https://issues.apache.org/jira/browse/FLINK-3586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15300111#comment-15300111
]
ASF GitHub Bot commented on FLINK-3586:
---
Github user asfgit closed the pull request at:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1778#issuecomment-221590336
I just stumbled across this in the code.
I am a bit confused by the two different flags `PARALLELISM_DEFAULT` and
`PARALLELISM_UNKNOWN`. What is the purpose of
[
https://issues.apache.org/jira/browse/FLINK-3723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-3723:
-
Priority: Critical (was: Major)
> Aggregate Functions and scalar expressions shouldn't be mixed
[
https://issues.apache.org/jira/browse/FLINK-3723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15300157#comment-15300157
]
Fabian Hueske commented on FLINK-3723:
--
We should resolve this issue (either way) before the Flink
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/1956#issuecomment-221603165
@vasia in which module were the failures? master has been quite unstable
recently now that tests are properly failing.
---
If your project is set up for it, you can
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2021#discussion_r64594890
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/degree/annotate/directed/EdgeDegreesPair.java
---
@@ -0,0 +1,81 @@
+/*
Github user gallenvara commented on the pull request:
https://github.com/apache/flink/pull/1956#issuecomment-221616393
@vasia In the travis failure reports, the failures are relevant with
flink-yarn-tests module. I have merged the latest code from master and rebase
all my commit in
[
https://issues.apache.org/jira/browse/FLINK-3152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-3152:
-
Priority: Critical (was: Major)
> Support all comparisons for Date type
>
[
https://issues.apache.org/jira/browse/FLINK-2971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-2971:
-
Priority: Critical (was: Major)
> Add outer joins to the Table API
>
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/1778#issuecomment-221597445
`PARALLELISM_UNKNOWN` is a no-op which leaves the parallelism unchanged.
This is a useful default for batch algorithms such as `JaccardIndex` for which
parallelism
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2021#discussion_r64587577
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/degree/annotate/directed/EdgeDegreesPair.java
---
@@ -0,0 +1,81 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-3945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15300183#comment-15300183
]
ASF GitHub Bot commented on FLINK-3945:
---
Github user vasia commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-3806:
--
Fix Version/s: 1.1.0
> Revert use of DataSet.count() in Gelly
> --
Maximilian Michels created FLINK-3972:
-
Summary: Subclasses of ResourceID may not to be serializable
Key: FLINK-3972
URL: https://issues.apache.org/jira/browse/FLINK-3972
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15299899#comment-15299899
]
ZhengBowen commented on FLINK-3970:
---
[~StephanEwen] can you help me?
> How to deal with "resouce
[
https://issues.apache.org/jira/browse/FLINK-3970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ZhengBowen updated FLINK-3970:
--
Comment: was deleted
(was: [~StephanEwen] can you help me?)
> How to deal with "resouce isolation"
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2032
[FLINK-3965] [gelly] Delegating GraphAlgorithm
A DelegatingGraphAlgorithm wraps a GraphAlgorithm result with a delegating
proxy object. The delegated object can be replaced when the same
[
https://issues.apache.org/jira/browse/FLINK-3962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15300102#comment-15300102
]
Maximilian Michels commented on FLINK-3962:
---
Thanks for looking into this!
> JMXReporter
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2024
---
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-3936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-3936:
-
Priority: Critical (was: Major)
> Add MIN / MAX aggregations function for BOOLEAN types
>
[
https://issues.apache.org/jira/browse/FLINK-3589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15300154#comment-15300154
]
ASF GitHub Bot commented on FLINK-3589:
---
Github user greghogan commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-3859:
-
Priority: Critical (was: Major)
> Add BigDecimal/BigInteger support to Table API
>
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1956#issuecomment-221600182
Hey @gallenvara,
I was about to merge this, but I see test failures after rebasing on top of
master.
Can you please (1) rebase on top of the latest master and
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2021#discussion_r64589442
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/asm/degree/annotate/directed/EdgeDegreesPair.java
---
@@ -0,0 +1,81 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15300456#comment-15300456
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user ggevay commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15300453#comment-15300453
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user greghogan commented on the pull request:
Github user ggevay commented on the pull request:
https://github.com/apache/flink/pull/1517#issuecomment-221644628
We talked about this yesterday with @fhueske at the Flink meetup, and the
conclusion was that we will get it into 1.1. @fhueske has several comments that
he will write
[
https://issues.apache.org/jira/browse/FLINK-3974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
B Wyatt updated FLINK-3974:
---
Attachment: ReproFLINK3974.java
Simple repro program.
> enableObjectReuse fails when an operator chains to
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15300638#comment-15300638
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user ggevay commented on the pull request:
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/1517#issuecomment-221643813
What is the status of this PR? Can we get this in and tested for the 1.1
release?
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-3974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15300642#comment-15300642
]
B Wyatt commented on FLINK-3974:
After attempting to produce a minimal repro, I realized that there needs
[
https://issues.apache.org/jira/browse/FLINK-3974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
B Wyatt updated FLINK-3974:
---
Comment: was deleted
(was: Simple repro program.)
> enableObjectReuse fails when an operator chains to
Github user ggevay commented on the pull request:
https://github.com/apache/flink/pull/1517#issuecomment-221670393
And @th0br0 is working on CombineHint.NONE.
---
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
[
https://issues.apache.org/jira/browse/FLINK-3968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-3968.
---
Resolution: Duplicate
> Cancel button on a running job not available on smaller screens
>
[
https://issues.apache.org/jira/browse/FLINK-3806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15300691#comment-15300691
]
ASF GitHub Bot commented on FLINK-3806:
---
GitHub user greghogan opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15301050#comment-15301050
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15301042#comment-15301042
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15301046#comment-15301046
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15301069#comment-15301069
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15301070#comment-15301070
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15301073#comment-15301073
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
B Wyatt updated FLINK-3974:
---
Attachment: bwyatt-FLINK3974.1.patch
I was able to fix this for my topology and the test case by making a
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15301065#comment-15301065
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15301061#comment-15301061
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3801:
--
Description:
Currently yoda-time 2.5 is used which was very old.
We should upgrade to 2.9.3
was:
Currently
Dyana Rose created FLINK-3975:
-
Summary: docs build script isn't serving the preview on the
correct base url
Key: FLINK-3975
URL: https://issues.apache.org/jira/browse/FLINK-3975
Project: Flink
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2036
[FLINK-3806] [gelly] Revert use of DataSet.count()
This leaves the Graph API unchanged but GatherSumApplyIteration and
ScatterGatherIteration now use broadcast variables to share the
[
https://issues.apache.org/jira/browse/FLINK-3970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15300746#comment-15300746
]
Stephan Ewen commented on FLINK-3970:
-
I think the best way to completely isolate jobs against each
[
https://issues.apache.org/jira/browse/FLINK-3961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15299554#comment-15299554
]
Juho Autio commented on FLINK-3961:
---
This question is primarily about Flink Batch API.
> Possibility to
[
https://issues.apache.org/jira/browse/FLINK-2672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15299557#comment-15299557
]
Juho Autio commented on FLINK-2672:
---
I wonder what the full pattern syntax would be?
To provide full
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15301082#comment-15301082
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15301083#comment-15301083
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15301097#comment-15301097
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r64666960
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/operators/UnsortedGrouping.java
---
@@ -135,10 +136,37 @@ public UnsortedGrouping(DataSet set,
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r64668630
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/ChainedReduceCombineDriver.java
---
@@ -0,0 +1,305 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15301102#comment-15301102
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r64667048
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/operators/UnsortedGrouping.java
---
@@ -135,10 +136,37 @@ public UnsortedGrouping(DataSet set,
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r64668546
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/ChainedReduceCombineDriver.java
---
@@ -0,0 +1,305 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r64667955
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/RandomAccessInputView.java
---
@@ -45,7 +45,12 @@ public
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15301104#comment-15301104
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r64668428
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/ReduceCombineDriver.java
---
@@ -42,34 +44,38 @@
* Combine operator for
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r64668798
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/ReduceCombineDriver.java
---
@@ -114,85 +118,133 @@ public void prepare() throws
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15301108#comment-15301108
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r64668757
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/ChainedReduceCombineDriver.java
---
@@ -0,0 +1,305 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-3967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15301112#comment-15301112
]
ASF GitHub Bot commented on FLINK-3967:
---
Github user mans2singh commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15301124#comment-15301124
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15301122#comment-15301122
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15301126#comment-15301126
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1517#issuecomment-221739936
Hi @ggevay as promised yesterday, I added my comments and suggestions. Let
me know what you think.
@greghogan, would you like to take a look as well? Another
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r64670146
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReduceHashTable.java
---
@@ -0,0 +1,1048 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15301128#comment-15301128
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r64671483
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReduceHashTable.java
---
@@ -0,0 +1,1048 @@
+/*
+ * Licensed to the
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r64669166
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/MemoryHashTableTestCommon.java
---
@@ -0,0 +1,666 @@
+/*
+ * Licensed
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r64669221
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/CompactingHashTableTest.java
---
@@ -252,4 +262,81 @@ private static String
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r64671543
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReduceHashTable.java
---
@@ -0,0 +1,1048 @@
+/*
+ * Licensed to the
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r64671325
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReduceHashTable.java
---
@@ -0,0 +1,1048 @@
+/*
+ * Licensed to the
Github user mans2singh commented on the pull request:
https://github.com/apache/flink/pull/2031#issuecomment-221737718
Hey @zentol - Thanks for your feedback.
- I've renamed the sink as you had recommended.
- Currently the driver from rethinkdb supports java 8 only. There
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r64671403
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReduceHashTable.java
---
@@ -0,0 +1,1048 @@
+/*
+ * Licensed to the
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r64669861
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReduceHashTable.java
---
@@ -0,0 +1,1048 @@
+/*
+ * Licensed to the
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r64670534
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReduceHashTable.java
---
@@ -0,0 +1,1048 @@
+/*
+ * Licensed to the
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r64670218
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReduceHashTable.java
---
@@ -0,0 +1,1048 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15301148#comment-15301148
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on the pull request:
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1517#issuecomment-221740318
This PR does also fix issue FLINK-2246 (add ChainedReduceCombineDriver).
Would be nice to have that change in a separate commit before we merge.
---
If your project is
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15301143#comment-15301143
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on the pull request:
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1517#discussion_r64667132
--- 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-3976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yijie Shen updated FLINK-3976:
--
Description:
The field name collisions in physical plan node make IDE hard to get a field's
type and
[
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
[
https://issues.apache.org/jira/browse/FLINK-3941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15301332#comment-15301332
]
ASF GitHub Bot commented on FLINK-3941:
---
Github user yjshen commented on the pull request:
Github user yjshen commented on the pull request:
https://github.com/apache/flink/pull/2025#issuecomment-221762766
Hi @fhueske , I've updated the `expectedType` fix and reverted changes in
`DataSetUnion` and `DataSetUnionRule` to make the implementation clear and
simple, what do you
Yijie Shen created FLINK-3976:
-
Summary: Alias fields of physical plan node to avoid name
collision with Calcite protected fields
Key: FLINK-3976
URL: https://issues.apache.org/jira/browse/FLINK-3976
1 - 100 of 178 matches
Mail list logo
