[
https://issues.apache.org/jira/browse/FLINK-6373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991998#comment-15991998
]
ASF GitHub Bot commented on FLINK-6373:
---
Github user sunjincheng121 commented on the
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/3765
Hi @haohui @fhueske I am very interested in `DISTINCT`, Let me share some
ideas about this:
First up, in standard database there are two situations can using
`DISTINCT` keyword.
* i
Github user fanzhidongyzby commented on the issue:
https://github.com/apache/flink/pull/3802
@greghogan , The compiling task runs successfully, please have a look at
the submitted code.
---
If your project is set up for it, you can reply to this email and have your
reply appear on Gi
[
https://issues.apache.org/jira/browse/FLINK-6333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979076#comment-15979076
]
Ted Yu edited comment on FLINK-6333 at 5/2/17 1:57 AM:
---
I found this
[
https://issues.apache.org/jira/browse/FLINK-6359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991975#comment-15991975
]
Ted Yu commented on FLINK-6359:
---
Interesting observations, Ben.
> Utilize Hierarchical Timi
[
https://issues.apache.org/jira/browse/FLINK-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991966#comment-15991966
]
ASF GitHub Bot commented on FLINK-6196:
---
Github user clarkyzl commented on a diff in
Github user clarkyzl commented on a diff in the pull request:
https://github.com/apache/flink/pull/3623#discussion_r114236223
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/DeferredTypeFlinkTableFunction.scala
---
@@ -0,0 +1,68 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-6019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991926#comment-15991926
]
Luke Hutchison commented on FLINK-6019:
---
[~StephanEwen] No, the lines I am talking a
[
https://issues.apache.org/jira/browse/FLINK-6190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991577#comment-15991577
]
ASF GitHub Bot commented on FLINK-6190:
---
GitHub user tzulitai opened a pull request:
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/3804
[FLINK-6190] [core] Reconfigurable TypeSerializers
Reconfigurable TypeSerializers is the first step towards allowing
serializer upgrades. The second step, activating serializer upgrades for
regist
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991566#comment-15991566
]
ASF GitHub Bot commented on FLINK-6334:
---
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/3791#discussion_r114204295
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/TableFunctionConversions.scala
---
@@ -0,0 +1,56 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991543#comment-15991543
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991539#comment-15991539
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991552#comment-15991552
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991536#comment-15991536
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991541#comment-15991541
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991544#comment-15991544
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991547#comment-15991547
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991549#comment-15991549
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991550#comment-15991550
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991548#comment-15991548
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991540#comment-15991540
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991538#comment-15991538
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991542#comment-15991542
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991546#comment-15991546
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991545#comment-15991545
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991551#comment-15991551
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991537#comment-15991537
]
ASF GitHub Bot commented on FLINK-6334:
---
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/3791#discussion_r114188108
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/UserDefinedTableFunctionTest.scala
---
@@ -50,72 +50,85 @
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3791#discussion_r114062529
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala
---
@@ -417,12 +452,33 @@ class Table(
private def
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3791#discussion_r114063055
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/logical/LogicalNode.scala
---
@@ -79,15 +79,21 @@ abstract class LogicalNod
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3791#discussion_r114199929
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/dataSet/DataSetCorrelateRule.scala
---
@@ -60,10 +60,14 @@ class Data
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3791#discussion_r114183462
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/dataSet/DataSetCorrelateRule.scala
---
@@ -60,10 +60,14 @@ class Data
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3791#discussion_r114198491
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala
---
@@ -417,12 +452,33 @@ class Table(
private def
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3791#discussion_r114190116
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/UserDefinedTableFunctionTest.scala
---
@@ -174,7 +209,8 @
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3791#discussion_r114197458
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/package.scala
---
@@ -90,4 +91,7 @@ package object scala extends
Impl
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3791#discussion_r114198865
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/package.scala
---
@@ -90,4 +91,7 @@ package object scala extends
Impl
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3791#discussion_r114063517
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/logical/operators.scala
---
@@ -56,6 +57,8 @@ case class Project(projectLis
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3791#discussion_r114062550
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala
---
@@ -417,12 +452,33 @@ class Table(
private def
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3791#discussion_r114183388
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamCorrelateRule.scala
---
@@ -59,10 +59,14 @@ clas
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3791#discussion_r114063404
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala
---
@@ -417,12 +452,33 @@ class Table(
private def
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3791#discussion_r114061983
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala
---
@@ -309,6 +308,42 @@ class Table(
}
/**
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3791#discussion_r114061878
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala
---
@@ -309,6 +308,42 @@ class Table(
}
/**
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3791#discussion_r114197865
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala
---
@@ -417,12 +452,33 @@ class Table(
private def
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3791#discussion_r114063647
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala
---
@@ -417,12 +452,33 @@ class Table(
private def
[
https://issues.apache.org/jira/browse/FLINK-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991423#comment-15991423
]
ASF GitHub Bot commented on FLINK-4497:
---
Github user StephenWithPH commented on the
Github user StephenWithPH commented on the issue:
https://github.com/apache/flink/pull/2633
@zentol & @StephanEwen ... anything I can do to get this ready to 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 your
[
https://issues.apache.org/jira/browse/FLINK-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991152#comment-15991152
]
Ted Yu commented on FLINK-5488:
---
Here is another example from AbstractYarnClusterDescriptor#
Github user fanzhidongyzby commented on a diff in the pull request:
https://github.com/apache/flink/pull/3802#discussion_r114159796
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/generator/CirculantGraph.java
---
@@ -0,0 +1,145 @@
+/*
+ * Licens
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3779
---
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-6382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15990971#comment-15990971
]
ASF GitHub Bot commented on FLINK-6382:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-6382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-6382.
-
Resolution: Implemented
Implemented in 33695781f9ce2599d18f45de6a465eaefe7d71f4
> Support additional type
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/3802#discussion_r11412
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/generator/CirculantGraph.java
---
@@ -0,0 +1,145 @@
+/*
+ * Licensed to
Github user fanzhidongyzby commented on the issue:
https://github.com/apache/flink/pull/3802
@greghogan , What should I do to process this error? All the modified code
has been pushed, how to trigger the pr to be compiled again?
---
If your project is set up for it, you can reply to
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3802
The tests sometimes fail. The build matrix splits the tests into three
groups, each run with four different configurations. As you have noted, based
on the changed code the single error can be igno
[
https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15990738#comment-15990738
]
Shashank Agarwal commented on FLINK-6321:
-
Hi [~kkl0u] ,
Thanks, Actually i am bi
[
https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15990738#comment-15990738
]
Shashank Agarwal edited comment on FLINK-6321 at 5/1/17 11:38 AM:
--
58 matches
Mail list logo
