[
https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978177#comment-15978177
]
Fang Yong commented on FLINK-6352:
--
Hi [~tzulitai], [~rmetzger], what do you think about
[
https://issues.apache.org/jira/browse/FLINK-4562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978173#comment-15978173
]
ASF GitHub Bot commented on FLINK-4562:
---
Github user shijinkui commented on the issu
Github user shijinkui commented on the issue:
https://github.com/apache/flink/pull/2460
> Hi @shijinkui, yes that sounds good to me.
Thanks. When will we merge this?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well
[
https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fang Yong updated FLINK-6352:
-
Description:
Currently "auto.offset.reset" is used to initialize the start offset of
FlinkKafkaConsum
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r112616773
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTableSink.java
---
@@ -0,0 +1,101
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978153#comment-15978153
]
ASF GitHub Bot commented on FLINK-6225:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978152#comment-15978152
]
ASF GitHub Bot commented on FLINK-6225:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r112616241
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTableSink.java
---
@@ -0,0 +1,101
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978151#comment-15978151
]
ASF GitHub Bot commented on FLINK-6225:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r112615718
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@ -402,
Fang Yong created FLINK-6352:
Summary: FlinkKafkaConsumer should support to use timestamp to set
up start offset
Key: FLINK-6352
URL: https://issues.apache.org/jira/browse/FLINK-6352
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978120#comment-15978120
]
ASF GitHub Bot commented on FLINK-6013:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978117#comment-15978117
]
ASF GitHub Bot commented on FLINK-6013:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978122#comment-15978122
]
ASF GitHub Bot commented on FLINK-6013:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3736#discussion_r112613595
--- Diff:
flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DMetric.java
---
@@ -0,0 +1,65 @@
+/*
+ * Licensed to th
[
https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978121#comment-15978121
]
ASF GitHub Bot commented on FLINK-6013:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978119#comment-15978119
]
ASF GitHub Bot commented on FLINK-6013:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978118#comment-15978118
]
ASF GitHub Bot commented on FLINK-6013:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3736#discussion_r112613661
--- Diff:
flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpClient.java
---
@@ -0,0 +1,97 @@
+/*
+ * Lice
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3736#discussion_r112613733
--- Diff:
flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpReporter.java
---
@@ -0,0 +1,197 @@
+/*
+ * L
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3736#discussion_r112614175
--- Diff:
flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpReporter.java
---
@@ -0,0 +1,197 @@
+/*
+ * L
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3736#discussion_r112613477
--- Diff: flink-dist/src/main/assemblies/opt.xml ---
@@ -95,5 +95,12 @@
flink-metrics-statsd-${project.version}.jar
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3736#discussion_r112613622
--- Diff:
flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpClient.java
---
@@ -0,0 +1,97 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978103#comment-15978103
]
Chesnay Schepler commented on FLINK-5095:
-
It's less maintainable. By introducing
[
https://issues.apache.org/jira/browse/FLINK-6351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977998#comment-15977998
]
mingleizhang edited comment on FLINK-6351 at 4/21/17 3:10 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-6351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977998#comment-15977998
]
mingleizhang commented on FLINK-6351:
-
[~till.rohrmann] Hi, Till. Please check it out
[
https://issues.apache.org/jira/browse/FLINK-6351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-6351:
Description: The currently YarnFlinkApplicationMasterRunner inherits from
AbstractYarnFlinkApplicati
[
https://issues.apache.org/jira/browse/FLINK-6351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-6351:
Priority: Major (was: Minor)
> Refactoring YarnFlinkApplicationMasterRunner by combining
> Abstrac
mingleizhang created FLINK-6351:
---
Summary: Refactoring YarnFlinkApplicationMasterRunner by combining
AbstractYarnFlinkApplicationMasterRunner in one class
Key: FLINK-6351
URL: https://issues.apache.org/jira/browse/F
[
https://issues.apache.org/jira/browse/FLINK-6350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-6350:
Component/s: Streaming
> Flink: Windowing does not work with streams from collections and the local
> execu
Bowen Li created FLINK-6350:
---
Summary: Flink: Windowing does not work with streams from
collections and the local execution environment
Key: FLINK-6350
URL: https://issues.apache.org/jira/browse/FLINK-6350
[
https://issues.apache.org/jira/browse/FLINK-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977893#comment-15977893
]
Bowen Li edited comment on FLINK-5095 at 4/21/17 1:02 AM:
--
What's
[
https://issues.apache.org/jira/browse/FLINK-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977893#comment-15977893
]
Bowen Li commented on FLINK-5095:
-
What's the main disadvantage of having counter, meters,
[
https://issues.apache.org/jira/browse/FLINK-6309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977892#comment-15977892
]
Xu Pingyong commented on FLINK-6309:
Memory consumer weights should be considered not
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977891#comment-15977891
]
ASF GitHub Bot commented on FLINK-6225:
---
GitHub user PangZhi opened a pull request:
GitHub user PangZhi opened a pull request:
https://github.com/apache/flink/pull/3748
[FLINK-6225] [Cassandra Connector] add CassandraTableSink
This PR is to address https://issues.apache.org/jira/browse/FLINK-6225
- add Row type support for CassandraSink
- add StreamTabl
Tzu-Li (Gordon) Tai created FLINK-6349:
--
Summary: Enforce per-subtask record ordering on resharding for
FlinkKinesisConsumer
Key: FLINK-6349
URL: https://issues.apache.org/jira/browse/FLINK-6349
Tzu-Li (Gordon) Tai created FLINK-6348:
--
Summary: Migrate from Java serialization for RollingSink's state
Key: FLINK-6348
URL: https://issues.apache.org/jira/browse/FLINK-6348
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-6347:
--
Summary: Migrate from Java serialization for
MessageAcknowledgingSourceBase's state
Key: FLINK-6347
URL: https://issues.apache.org/jira/browse/FLINK-6347
Tzu-Li (Gordon) Tai created FLINK-6346:
--
Summary: Migrate from Java serialization for
GenericWriteAheadSink's state
Key: FLINK-6346
URL: https://issues.apache.org/jira/browse/FLINK-6346
Project:
Tzu-Li (Gordon) Tai created FLINK-6345:
--
Summary: Migrate from Java serialization for
ContinuousFileReaderOperator's state
Key: FLINK-6345
URL: https://issues.apache.org/jira/browse/FLINK-6345
Pr
[
https://issues.apache.org/jira/browse/FLINK-6344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6344:
---
Summary: Migrate from Java serialization for BucketingSink's state (was:
Migrate from
Tzu-Li (Gordon) Tai created FLINK-6344:
--
Summary: Migrate from Java serialization for `BucketingSink`'s
state
Key: FLINK-6344
URL: https://issues.apache.org/jira/browse/FLINK-6344
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6343:
---
Description:
With FLINK-6324, the Java serialization shortcut for operator state is no
[
https://issues.apache.org/jira/browse/FLINK-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6343:
---
Description:
With FLINK-6324, the Java serialization shortcut for operator state is no
Tzu-Li (Gordon) Tai created FLINK-6343:
--
Summary: Migrate from discouraged Java serialization for all
sources / sinks
Key: FLINK-6343
URL: https://issues.apache.org/jira/browse/FLINK-6343
Project
[
https://issues.apache.org/jira/browse/FLINK-6311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-6311.
--
Resolution: Fixed
Fix Version/s: 1.2.2
1.3.0
Resolved for mast
[
https://issues.apache.org/jira/browse/FLINK-6311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977768#comment-15977768
]
ASF GitHub Bot commented on FLINK-6311:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3738
---
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-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977755#comment-15977755
]
ASF GitHub Bot commented on FLINK-6013:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/3736
Green build! @zentol
---
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 s
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977669#comment-15977669
]
ASF GitHub Bot commented on FLINK-6228:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977648#comment-15977648
]
ASF GitHub Bot commented on FLINK-6228:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977681#comment-15977681
]
ASF GitHub Bot commented on FLINK-6228:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977653#comment-15977653
]
ASF GitHub Bot commented on FLINK-6228:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977667#comment-15977667
]
ASF GitHub Bot commented on FLINK-6228:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977678#comment-15977678
]
ASF GitHub Bot commented on FLINK-6228:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977655#comment-15977655
]
ASF GitHub Bot commented on FLINK-6228:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977661#comment-15977661
]
ASF GitHub Bot commented on FLINK-6228:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977680#comment-15977680
]
ASF GitHub Bot commented on FLINK-6228:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977662#comment-15977662
]
ASF GitHub Bot commented on FLINK-6228:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977657#comment-15977657
]
ASF GitHub Bot commented on FLINK-6228:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977675#comment-15977675
]
ASF GitHub Bot commented on FLINK-6228:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977659#comment-15977659
]
ASF GitHub Bot commented on FLINK-6228:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977674#comment-15977674
]
ASF GitHub Bot commented on FLINK-6228:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977658#comment-15977658
]
ASF GitHub Bot commented on FLINK-6228:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977679#comment-15977679
]
ASF GitHub Bot commented on FLINK-6228:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977660#comment-15977660
]
ASF GitHub Bot commented on FLINK-6228:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977671#comment-15977671
]
ASF GitHub Bot commented on FLINK-6228:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977665#comment-15977665
]
ASF GitHub Bot commented on FLINK-6228:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977654#comment-15977654
]
ASF GitHub Bot commented on FLINK-6228:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977677#comment-15977677
]
ASF GitHub Bot commented on FLINK-6228:
---
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/3743#discussion_r112461145
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/ProjectionTranslator.scala
---
@@ -216,6 +216,26 @@ object ProjectionTransl
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3743#discussion_r112469838
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/aggregations.scala
---
@@ -35,6 +37,18 @@ abstract sealed class Aggr
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3743#discussion_r112571486
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/windows.scala
---
@@ -22,6 +22,126 @@ import org.apache.flink.table.expressi
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3743#discussion_r112494372
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/call.scala
---
@@ -49,6 +57,128 @@ case class Call(functionName: Str
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3743#discussion_r112560976
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/call.scala
---
@@ -49,6 +57,128 @@ case class Call(functionName: Str
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977684#comment-15977684
]
ASF GitHub Bot commented on FLINK-6228:
---
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/3743#discussion_r112459590
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/ProjectionTranslator.scala
---
@@ -190,8 +190,8 @@ object ProjectionTransla
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977651#comment-15977651
]
ASF GitHub Bot commented on FLINK-6228:
---
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/3743#discussion_r112482490
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/windows.scala
---
@@ -22,6 +22,126 @@ import org.apache.flink.table.expressi
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977649#comment-15977649
]
ASF GitHub Bot commented on FLINK-6228:
---
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/3743#discussion_r112460885
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/ProjectionTranslator.scala
---
@@ -216,6 +216,26 @@ object ProjectionTransl
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3743#discussion_r112485134
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/call.scala
---
@@ -49,6 +57,128 @@ case class Call(functionName: Str
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3743#discussion_r112559640
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/call.scala
---
@@ -49,6 +57,128 @@ case class Call(functionName: Str
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3743#discussion_r112479103
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/expressionDsl.scala
---
@@ -586,6 +602,13 @@ trait ImplicitExpressionO
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977672#comment-15977672
]
ASF GitHub Bot commented on FLINK-6228:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977676#comment-15977676
]
ASF GitHub Bot commented on FLINK-6228:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977683#comment-15977683
]
ASF GitHub Bot commented on FLINK-6228:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977668#comment-15977668
]
ASF GitHub Bot commented on FLINK-6228:
---
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/3743#discussion_r112456485
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala
---
@@ -810,6 +810,47 @@ class Table(
new WindowedTable
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977652#comment-15977652
]
ASF GitHub Bot commented on FLINK-6228:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977673#comment-15977673
]
ASF GitHub Bot commented on FLINK-6228:
---
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/3743#discussion_r112476982
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/expressionDsl.scala
---
@@ -364,6 +365,21 @@ trait ImplicitExpressionO
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977650#comment-15977650
]
ASF GitHub Bot commented on FLINK-6228:
---
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/3743#discussion_r112471307
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/ProjectionTranslator.scala
---
@@ -216,6 +216,26 @@ object ProjectionTransl
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977663#comment-15977663
]
ASF GitHub Bot commented on FLINK-6228:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977682#comment-15977682
]
ASF GitHub Bot commented on FLINK-6228:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977670#comment-15977670
]
ASF GitHub Bot commented on FLINK-6228:
---
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/3743#discussion_r112460318
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/ProjectionTranslator.scala
---
@@ -216,6 +216,26 @@ object ProjectionTransl
1 - 100 of 295 matches
Mail list logo
