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
Proj
[
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 un
[
https://issues.apache.org/jira/browse/FLINK-3941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15301332#comment-15301332
]
ASF GitHub Bot commented on FLINK-3941:
---
Github user yjshen commented on the pull re
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 t
[
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-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15301143#comment-15301143
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on the pull r
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](
}
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&focusedCommentId=15301148#comment-15301148
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on the pull r
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 get
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 Apa
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15301128#comment-15301128
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on a diff in
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 Apa
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 t
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 pa
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 Apa
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15301126#comment-15301126
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on a diff in
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 Apa
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 Apa
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 i
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 Apa
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 Apa
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 Apa
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15301122#comment-15301122
]
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=15301124#comment-15301124
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on a diff in
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 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-3967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15301112#comment-15301112
]
ASF GitHub Bot commented on FLINK-3967:
---
Github user mans2singh commented on the pul
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15301108#comment-15301108
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on a diff in
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 Exc
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 RandomAccessInputView(ArrayLi
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15301104#comment-15301104
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on a diff in
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 Reduce
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 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15301102#comment-15301102
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on a diff in
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, K
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 @@
+/*
+ * Licen
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, K
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15301097#comment-15301097
]
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=15301083#comment-15301083
]
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=15301082#comment-15301082
]
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=15301075#comment-15301075
]
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=15301073#comment-15301073
]
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=15301061#comment-15301061
]
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=15301070#comment-15301070
]
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=15301069#comment-15301069
]
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=15301065#comment-15301065
]
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=15301046#comment-15301046
]
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=15301050#comment-15301050
]
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=15301042#comment-15301042
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user fhueske commented on a diff in
[
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 very
[
https://issues.apache.org/jira/browse/FLINK-3970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15300746#comment-15300746
]
Stephan Ewen commented on FLINK-3970:
-
I think the best way to completely isolate jobs
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
numberOfVert
[
https://issues.apache.org/jira/browse/FLINK-3975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dyana Rose updated FLINK-3975:
--
Description:
when running the documentation build script as:
{{./build_docs.sh -p}} the docs are built u
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-3806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15300691#comment-15300691
]
ASF GitHub Bot commented on FLINK-3806:
---
GitHub user greghogan opened a pull request
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 projec
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15300638#comment-15300638
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user ggevay commented on the pull re
[
https://issues.apache.org/jira/browse/FLINK-3974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15300642#comment-15300642
]
B Wyatt commented on FLINK-3974:
After attempting to produce a minimal repro, I realized t
[
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 multip
[
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 mu
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15300456#comment-15300456
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user ggevay commented on the pull re
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 he
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15300453#comment-15300453
]
ASF GitHub Bot commented on FLINK-3477:
---
Github user greghogan commented on the pull
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
repl
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-2044.
--
Resolution: Implemented
Fix Version/s: 1.1.0
> Implementation of Gelly HITS Algorithm
> -
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15300415#comment-15300415
]
ASF GitHub Bot commented on FLINK-2044:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1956
---
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-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15300409#comment-15300409
]
ASF GitHub Bot commented on FLINK-2044:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1956#issuecomment-221637781
Thanks @gallenvara! All tests pass now. I will merge :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
B Wyatt created FLINK-3974:
--
Summary: enableObjectReuse fails when an operator chains to
multiple downstream operators
Key: FLINK-3974
URL: https://issues.apache.org/jira/browse/FLINK-3974
Project: Flink
Fabian Hueske created FLINK-3973:
Summary: Table API documentation is "hidden" in Programming Guide
menu list
Key: FLINK-3973
URL: https://issues.apache.org/jira/browse/FLINK-3973
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reassigned FLINK-3714:
-
Assignee: Kostas Kloudas
> Add Support for "Allowed Lateness"
> -
[
https://issues.apache.org/jira/browse/FLINK-1673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-1673.
---
Resolution: Won't Fix
> Colocate Flink Kafka consumer
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15300238#comment-15300238
]
ASF GitHub Bot commented on FLINK-2044:
---
Github user gallenvara commented on the pul
[
https://issues.apache.org/jira/browse/FLINK-1673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15300236#comment-15300236
]
Robert Metzger commented on FLINK-1673:
---
I can not remember any user asking for this
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 th
[
https://issues.apache.org/jira/browse/FLINK-3945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15300223#comment-15300223
]
ASF GitHub Bot commented on FLINK-3945:
---
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/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 @@
+/*
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
I
[
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
> --
>
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15300187#comment-15300187
]
ASF GitHub Bot commented on FLINK-2044:
---
Github user gallenvara commented on the pul
Github user gallenvara commented on the pull request:
https://github.com/apache/flink/pull/1956#issuecomment-221606502
@vasia wait for minutes and i will take a look.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If you
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-3945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15300183#comment-15300183
]
ASF GitHub Bot commented on FLINK-3945:
---
Github user vasia commented on a diff in th
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 pro
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15300178#comment-15300178
]
ASF GitHub Bot commented on FLINK-2044:
---
Github user vasia commented on the pull req
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15300177#comment-15300177
]
ASF GitHub Bot commented on FLINK-2044:
---
Github user greghogan commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-3723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15300157#comment-15300157
]
Fabian Hueske commented on FLINK-3723:
--
We should resolve this issue (either way) bef
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 r
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 squas
[
https://issues.apache.org/jira/browse/FLINK-3945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15300173#comment-15300173
]
ASF GitHub Bot commented on FLINK-3945:
---
Github user greghogan commented on a diff i
[
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 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 @@
+/*
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 can
Fabian Hueske created FLINK-3971:
Summary: Aggregates handle null values incorrectly.
Key: FLINK-3971
URL: https://issues.apache.org/jira/browse/FLINK-3971
Project: Flink
Issue Type: Bug
[
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&focusedCommentId=15300154#comment-15300154
]
ASF GitHub Bot commented on FLINK-3589:
---
Github user greghogan commented on the pull
[
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
> --
[
https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15300162#comment-15300162
]
ASF GitHub Bot commented on FLINK-2044:
---
Github user vasia commented on the pull req
1 - 100 of 178 matches
Mail list logo
