[
https://issues.apache.org/jira/browse/FLINK-6373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991998#comment-15991998
]
ASF GitHub Bot commented on FLINK-6373:
---
Github user sunjincheng121 commented on the issue:
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.
*
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
[
https://issues.apache.org/jira/browse/FLINK-6333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979076#comment-15979076
]
Ted Yu edited comment on FLINK-6333 at 5/2/17 1:57 AM:
---
I found this issue which was
[
https://issues.apache.org/jira/browse/FLINK-6359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991975#comment-15991975
]
Ted Yu commented on FLINK-6359:
---
Interesting observations, Ben.
> Utilize Hierarchical Timing Wheels for
[
https://issues.apache.org/jira/browse/FLINK-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991966#comment-15991966
]
ASF GitHub Bot commented on FLINK-6196:
---
Github user clarkyzl commented on a diff in the pull
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=15991926#comment-15991926
]
Luke Hutchison commented on FLINK-6019:
---
[~StephanEwen] No, the lines I am talking about do not
[
https://issues.apache.org/jira/browse/FLINK-6190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991566#comment-15991566
]
ASF GitHub Bot commented on FLINK-6334:
---
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/3791#discussion_r114204295
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/TableFunctionConversions.scala
---
@@ -0,0 +1,56 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991543#comment-15991543
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991539#comment-15991539
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991552#comment-15991552
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991536#comment-15991536
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991541#comment-15991541
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991544#comment-15991544
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991547#comment-15991547
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991549#comment-15991549
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991548#comment-15991548
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991540#comment-15991540
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991550#comment-15991550
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991545#comment-15991545
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991551#comment-15991551
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991537#comment-15991537
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991538#comment-15991538
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991542#comment-15991542
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991546#comment-15991546
]
ASF GitHub Bot commented on FLINK-6334:
---
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/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
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
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_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
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
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
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
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 @@
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=15991423#comment-15991423
]
ASF GitHub Bot commented on FLINK-4497:
---
Github user StephenWithPH commented on the issue:
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=15991152#comment-15991152
]
Ted Yu commented on FLINK-5488:
---
Here is another example from AbstractYarnClusterDescriptor#retrieve() :
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 @@
+/*
+ *
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
[
https://issues.apache.org/jira/browse/FLINK-6382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15990971#comment-15990971
]
ASF GitHub Bot commented on FLINK-6382:
---
Github user asfgit closed the pull request at:
[
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15990738#comment-15990738
]
Shashank Agarwal commented on FLINK-6321:
-
Hi [~kkl0u] ,
Thanks, Actually i am bit busy with
[
https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15990738#comment-15990738
]
Shashank Agarwal edited comment on FLINK-6321 at 5/1/17 11:38 AM:
--
Hi
58 matches
Mail list logo
