[
https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boris Osipov updated FLINK-5092:
Summary: Add maven profile with code coverage report generation (was: Add
maven profile with code c
Boris Osipov created FLINK-5092:
---
Summary: Add maven profile with code coverage
Key: FLINK-5092
URL: https://issues.apache.org/jira/browse/FLINK-5092
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676038#comment-15676038
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676039#comment-15676039
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676035#comment-15676035
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676036#comment-15676036
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r88591860
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/datastream/StreamTableProject.scala
---
@@ -0,0 +1,67 @@
+/*
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r88592516
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/BatchTableProject.scala
---
@@ -0,0 +1,67 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676034#comment-15676034
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676037#comment-15676037
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r88609838
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/sources/ProjectableTableSource.scala
---
@@ -0,0 +1,32 @@
+/*
+ * Lic
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r88591928
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/BatchTableSourceProjectRule.scala
---
@@ -0,0 +1,81 @@
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r88591967
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/datastream/StreamTableSourceProjectRule.scala
---
@@ -0,0 +1,82 @@
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r88591760
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/BatchTableProject.scala
---
@@ -0,0 +1,67 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15675614#comment-15675614
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88594602
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/java/table/BatchTableEnvironment.scala
---
@@ -162,4 +165,24 @@ class BatchTableEnv
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88594496
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/functions/utils/TableSqlFunction.scala
---
@@ -0,0 +1,99 @@
+/*
+ * L
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15675610#comment-15675610
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88594489
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/functions/utils/TableSqlFunction.scala
---
@@ -0,0 +1,99 @@
+/*
+ * L
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15675609#comment-15675609
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88594410
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/java/table/StreamTableEnvironment.scala
---
@@ -164,4 +167,24 @@ class StreamTableE
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15675606#comment-15675606
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15675604#comment-15675604
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88594421
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/codegen/CodeGenerator.scala
---
@@ -542,11 +563,14 @@ class CodeGenerator(
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15675591#comment-15675591
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on the issue:
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/2653
Thank you @fhueske @twalthr for the review, I will update the PR in this
weekend.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If y
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15675585#comment-15675585
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88593490
--- Diff: flink-libraries/flink-table/pom.xml ---
@@ -154,6 +154,10 @@ under the License.
maven-shade-plugin
[
https://issues.apache.org/jira/browse/FLINK-5090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15675401#comment-15675401
]
Xiaogang Shi commented on FLINK-5090:
-
I suggest the metrics to be channel-wise. With
[
https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15675269#comment-15675269
]
ASF GitHub Bot commented on FLINK-3930:
---
Github user vijikarthi commented on the iss
Github user vijikarthi commented on the issue:
https://github.com/apache/flink/pull/2425
@StephanEwen, @mxm I have updated the documentation changes as suggested,
moved common code from BlobUtils to SecurityContext, added new ConfigOptions
class for security configurations lookup.
[
https://issues.apache.org/jira/browse/FLINK-4587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15675265#comment-15675265
]
Renkai Ge commented on FLINK-4587:
--
Yes,solved in the way described
Stephan Ewen (JIRA)
Github user vijikarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2425#discussion_r88576086
--- Diff: docs/internals/flink_security.md ---
@@ -84,4 +86,79 @@ Security implementation details are based on https://github.com/apache/
## Toke
[
https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15675235#comment-15675235
]
ASF GitHub Bot commented on FLINK-3930:
---
Github user vijikarthi commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15675221#comment-15675221
]
Maximilian Michels commented on FLINK-2821:
---
Thanks you for your answers, [~phil
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15675194#comment-15675194
]
Maximilian Michels commented on FLINK-2821:
---
Thanks for your feedback [~melentye
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15675182#comment-15675182
]
Maximilian Michels commented on FLINK-2821:
---
{quote}
On the other hand I can't h
[
https://issues.apache.org/jira/browse/FLINK-4491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15675084#comment-15675084
]
ASF GitHub Bot commented on FLINK-4491:
---
Github user fpompermaier commented on a dif
Github user fpompermaier commented on a diff in the pull request:
https://github.com/apache/flink/pull/2790#discussion_r88567247
--- Diff:
flink-streaming-connectors/flink-connector-elasticsearch2/src/test/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSinkITCas
[
https://issues.apache.org/jira/browse/FLINK-4491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15675070#comment-15675070
]
ASF GitHub Bot commented on FLINK-4491:
---
Github user fpompermaier commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-4491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15675068#comment-15675068
]
ASF GitHub Bot commented on FLINK-4491:
---
Github user fpompermaier commented on a dif
Github user fpompermaier commented on a diff in the pull request:
https://github.com/apache/flink/pull/2790#discussion_r88566350
--- Diff:
flink-streaming-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/helper/ElasticSearchHe
Github user fpompermaier commented on a diff in the pull request:
https://github.com/apache/flink/pull/2790#discussion_r88566247
--- Diff:
flink-streaming-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/helper/ElasticSearchHe
[
https://issues.apache.org/jira/browse/FLINK-5058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-5058.
Resolution: Fixed
Fix Version/s: 1.1.4
1.2.0
Thanks for the fix!
Fixed fo
[
https://issues.apache.org/jira/browse/FLINK-5058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15675038#comment-15675038
]
ASF GitHub Bot commented on FLINK-5058:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2799
---
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 asfgit closed the pull request at:
https://github.com/apache/flink/pull/2821
---
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-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674912#comment-15674912
]
Maximilian Michels commented on FLINK-3133:
---
Hi [~AlexanderShoshin]! I've adjust
[
https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674899#comment-15674899
]
Maximilian Michels commented on FLINK-3133:
---
I've made some improvements in the
[
https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-3133:
--
Description:
The DataSet API's methods {{collect()}}, {{count()}}, and {{print()}} shoul
[
https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-3133:
--
Summary: Introduce collect()/count()/print() methods in DataStream API
(was: Introduce
Eron Wright created FLINK-5091:
---
Summary: Formalize the AppMaster environment for docker compability
Key: FLINK-5091
URL: https://issues.apache.org/jira/browse/FLINK-5091
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674640#comment-15674640
]
ASF GitHub Bot commented on FLINK-4913:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2795
That's completely reasonable. For 1.2, should we change the way
`getRuntimeContext().getUserCodeClassLoader()` works for per-job Yarn clusters?
Should it return the system class loader there?
---
If y
[
https://issues.apache.org/jira/browse/FLINK-5081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674631#comment-15674631
]
Maximilian Michels commented on FLINK-5081:
---
Thanks for reporting! I couldn't re
[
https://issues.apache.org/jira/browse/FLINK-4898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674614#comment-15674614
]
ASF GitHub Bot commented on FLINK-4898:
---
Github user EronWright commented on the iss
Github user EronWright commented on the issue:
https://github.com/apache/flink/pull/2766
@tillrohrmann would you mind taking 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 your project does not have this feat
[
https://issues.apache.org/jira/browse/FLINK-4921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674609#comment-15674609
]
ASF GitHub Bot commented on FLINK-4921:
---
GitHub user EronWright opened a pull reques
GitHub user EronWright opened a pull request:
https://github.com/apache/flink/pull/2827
[FLINK-4921] Upgrade to Mesos 1.0.1
Updated the Mesos dependency, to unlock some new features (notably the
ability to fetch into sandbox sub-directories).
Shaded the protobuf dependen
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/2703#discussion_r88522783
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosApplicationMasterRunner.java
---
@@ -601,6 +601,54 @@ else if (re
[
https://issues.apache.org/jira/browse/FLINK-4900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674537#comment-15674537
]
ASF GitHub Bot commented on FLINK-4900:
---
Github user EronWright commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-5079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5079.
--
Resolution: Not A Problem
Not a problem... mixed up different version (1.1. client and 1.2 cluster or
v
Stephan Ewen created FLINK-5090:
---
Summary: Expose optionally detailed metrics about network queue
lengths
Key: FLINK-5090
URL: https://issues.apache.org/jira/browse/FLINK-5090
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674216#comment-15674216
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674230#comment-15674230
]
ASF GitHub Bot commented on FLINK-4469:
---
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/2653#discussion_r88488494
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/FlinkCorrelate.scala
---
@@ -0,0 +1,161 @@
+/*
+ * License
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88486729
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/FlinkCorrelate.scala
---
@@ -0,0 +1,161 @@
+/*
+ * License
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88492728
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/validate/FunctionCatalog.scala
---
@@ -47,13 +52,50 @@ class FunctionCatalog
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88458986
--- Diff: flink-libraries/flink-table/pom.xml ---
@@ -154,6 +154,10 @@ under the License.
maven-shade-plugin
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88488089
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/FlinkCorrelate.scala
---
@@ -0,0 +1,161 @@
+/*
+ * License
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88482480
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/functions/utils/TableSqlFunction.scala
---
@@ -0,0 +1,99 @@
+/*
+ * L
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674220#comment-15674220
]
ASF GitHub Bot commented on FLINK-4469:
---
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/2653#discussion_r88480160
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/functions/TableFunction.scala
---
@@ -0,0 +1,119 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674217#comment-15674217
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674212#comment-15674212
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674224#comment-15674224
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674221#comment-15674221
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674225#comment-15674225
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674231#comment-15674231
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674214#comment-15674214
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674227#comment-15674227
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674222#comment-15674222
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674208#comment-15674208
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674219#comment-15674219
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674211#comment-15674211
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674229#comment-15674229
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674218#comment-15674218
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674215#comment-15674215
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674228#comment-15674228
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674223#comment-15674223
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674210#comment-15674210
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674213#comment-15674213
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674209#comment-15674209
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674226#comment-15674226
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674232#comment-15674232
]
ASF GitHub Bot commented on FLINK-4469:
---
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/2653#discussion_r88491436
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/table.scala
---
@@ -611,6 +612,130 @@ class Table(
}
/**
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88477894
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/expressions/ExpressionParser.scala
---
@@ -451,6 +452,28 @@ object Expression
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88491682
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/table.scala
---
@@ -611,6 +612,130 @@ class Table(
}
/**
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88491270
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/schema/FlinkTableFunctionImpl.scala
---
@@ -0,0 +1,77 @@
+/*
+ *
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88472140
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/codegen/CodeGenerator.scala
---
@@ -542,11 +563,14 @@ class CodeGenerator(
1 - 100 of 202 matches
Mail list logo
