[
https://issues.apache.org/jira/browse/FLINK-7017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066016#comment-16066016
]
ASF GitHub Bot commented on FLINK-7017:
---
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/4196#discussion_r124464897
--- Diff:
flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/WebFrontendITCase.java
---
@@ -83,16 +78,16 @@ public static void initialize()
[
https://issues.apache.org/jira/browse/FLINK-6665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fang Yong reassigned FLINK-6665:
Assignee: Fang Yong
> Pass a ScheduledExecutorService to the RestartStrategy
>
sunjincheng created FLINK-7025:
--
Summary: Using NullByteKeySelector for Unbounded ProcTime
NonPartitioned Over
Key: FLINK-7025
URL: https://issues.apache.org/jira/browse/FLINK-7025
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065960#comment-16065960
]
ASF GitHub Bot commented on FLINK-7014:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065961#comment-16065961
]
ASF GitHub Bot commented on FLINK-7014:
---
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/4200#discussion_r124457542
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/ExpressionReductionTest.scala
---
@@ -422,4 +423,50 @@ class ExpressionReduction
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4200#discussion_r124457316
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/ExpressionReductionTest.scala
---
@@ -422,4 +423,50 @@ class ExpressionReduction
[
https://issues.apache.org/jira/browse/FLINK-6925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065956#comment-16065956
]
ASF GitHub Bot commented on FLINK-6925:
---
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/4138#discussion_r124452756
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/ScalarFunctions.scala
---
@@ -0,0 +1,87 @@
+/*
+ * Lic
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4138#discussion_r123681972
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/scalarFunctions/ScalarFunctions.scala
---
@@ -0,0 +1,79 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-6925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065954#comment-16065954
]
ASF GitHub Bot commented on FLINK-6925:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065957#comment-16065957
]
ASF GitHub Bot commented on FLINK-6925:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065955#comment-16065955
]
ASF GitHub Bot commented on FLINK-6925:
---
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/4138#discussion_r124456117
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/ScalarFunctions.scala
---
@@ -0,0 +1,87 @@
+/*
+ * Lic
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4138#discussion_r124456032
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/ScalarFunctions.scala
---
@@ -0,0 +1,87 @@
+/*
+ * Lic
[
https://issues.apache.org/jira/browse/FLINK-7008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065948#comment-16065948
]
ASF GitHub Bot commented on FLINK-7008:
---
Github user dianfu commented on a diff in t
Github user dianfu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4195#discussion_r124455303
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFATest.java
---
@@ -324,6 +327,83 @@ public boolean filter(Event value) throws Ex
[
https://issues.apache.org/jira/browse/FLINK-6407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065941#comment-16065941
]
ASF GitHub Bot commented on FLINK-6407:
---
Github user zhangminglei commented on the i
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/4205
cc @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 so, or i
[
https://issues.apache.org/jira/browse/FLINK-6407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065937#comment-16065937
]
ASF GitHub Bot commented on FLINK-6407:
---
GitHub user zhangminglei opened a pull requ
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/4205
[FLINK-6407] [build] Upgrade AVRO to 1.8.2
Upgrade to the last maintenance releases of **AVRO** 1.8.2
You can merge this pull request into a Git repository by running:
$ git pull https://g
sunjincheng created FLINK-7024:
--
Summary: Add supported for selecting window proctime/rowtime on
row-based Tumble/Slide window
Key: FLINK-7024
URL: https://issues.apache.org/jira/browse/FLINK-7024
Proj
[
https://issues.apache.org/jira/browse/FLINK-6522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065924#comment-16065924
]
ASF GitHub Bot commented on FLINK-6522:
---
Github user zjureel commented on the issue:
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4204
Hi @tillrohrmann , I have created this PR for issue
[FLINK-6522.](https://issues.apache.org/jira/browse/FLINK-6522) Could you
please have a look when you're free, thanks
---
If your project is set
[
https://issues.apache.org/jira/browse/FLINK-6522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065922#comment-16065922
]
ASF GitHub Bot commented on FLINK-6522:
---
GitHub user zjureel opened a pull request:
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4204
[FLINK-6522] Add ZooKeeper cleanup logic to ZooKeeperHaServices
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
[
https://issues.apache.org/jira/browse/FLINK-6969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065911#comment-16065911
]
ASF GitHub Bot commented on FLINK-6969:
---
Github user wuchong commented on the issue:
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/4183
Hi @fhueske , I like the `firstResultTimeOffset`, a good design ! ð
Regarding to the watermark and timestamp, it makes sense to me. And a
simple approach come to my mind : assign a new
[
https://issues.apache.org/jira/browse/FLINK-7023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065883#comment-16065883
]
ASF GitHub Bot commented on FLINK-7023:
---
GitHub user greghogan opened a pull request
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/4203
[FLINK-7023] [gelly] Remaining types for Gelly ValueArrays
Add implementations of Byte/Char/Double/Float/ShortValueArray. Along with
the existing implementations of Int/Long/Null/StringValueArray
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4200#discussion_r124443977
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/datastream/DataStreamUserDefinedFunctionITCase.scala
---
@@ -230,6 +231,
[
https://issues.apache.org/jira/browse/FLINK-7014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065866#comment-16065866
]
ASF GitHub Bot commented on FLINK-7014:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065865#comment-16065865
]
ASF GitHub Bot commented on FLINK-7014:
---
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/4200#discussion_r124443845
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/AggSqlFunction.scala
---
@@ -57,6 +57,8 @@ class AggSqlFunction(
Greg Hogan created FLINK-7023:
-
Summary: Remaining types for Gelly ValueArrays
Key: FLINK-7023
URL: https://issues.apache.org/jira/browse/FLINK-7023
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-7014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065854#comment-16065854
]
ASF GitHub Bot commented on FLINK-7014:
---
Github user Xpray commented on a diff in th
Github user Xpray commented on a diff in the pull request:
https://github.com/apache/flink/pull/4200#discussion_r124442541
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/datastream/DataStreamUserDefinedFunctionITCase.scala
---
@@ -230,6 +231,26
[
https://issues.apache.org/jira/browse/FLINK-7014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065834#comment-16065834
]
ASF GitHub Bot commented on FLINK-7014:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-7014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065836#comment-16065836
]
ASF GitHub Bot commented on FLINK-7014:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-7014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065835#comment-16065835
]
ASF GitHub Bot commented on FLINK-7014:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4200#discussion_r124439791
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/datastream/DataStreamUserDefinedFunctionITCase.scala
---
@@ -230,
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4200#discussion_r124439457
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/UserDefinedFunction.scala
---
@@ -40,6 +40,12 @@ abstract class
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4200#discussion_r124440259
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/AggSqlFunction.scala
---
@@ -57,6 +57,8 @@ class AggSqlFu
Github user dianfu commented on the issue:
https://github.com/apache/flink/pull/4153
rebase the code and @dawidwys @kl0u could you help to take a look at this
PR?
---
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 p
[
https://issues.apache.org/jira/browse/FLINK-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065826#comment-16065826
]
ASF GitHub Bot commented on FLINK-6927:
---
Github user dianfu commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065817#comment-16065817
]
Xingcan Cui commented on FLINK-6936:
[~aljoscha], thanks for your attention. You are r
[
https://issues.apache.org/jira/browse/FLINK-6407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-6407:
---
Assignee: mingleizhang
> Upgrade AVRO dependency version to 1.8.x
> -
[
https://issues.apache.org/jira/browse/FLINK-7014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065798#comment-16065798
]
ASF GitHub Bot commented on FLINK-7014:
---
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/4200#discussion_r124436213
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/datastream/DataStreamUserDefinedFunctionITCase.scala
---
@@ -230,6 +231,
[
https://issues.apache.org/jira/browse/FLINK-6407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065792#comment-16065792
]
mingleizhang commented on FLINK-6407:
-
Avro has a release version of 1.8.2 now. I woul
[
https://issues.apache.org/jira/browse/FLINK-6422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065744#comment-16065744
]
ASF GitHub Bot commented on FLINK-6422:
---
Github user zhangminglei commented on the i
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/4202
Thanks @tedyu for reporting this. cc @StephanEwen @tedyu Could both you
take a look ? I checked the first version you designed.
---
If your project is set up for it, you can reply to this em
[
https://issues.apache.org/jira/browse/FLINK-6422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065741#comment-16065741
]
ASF GitHub Bot commented on FLINK-6422:
---
GitHub user zhangminglei opened a pull requ
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/4202
[FLINK-6422] [core] Unreachable code in FileInputFormat#createInputSpâ¦
Fix Unreachable code in FileInputFormat#createInputSplits.
You can merge this pull request into a Git repository by runn
[
https://issues.apache.org/jira/browse/FLINK-6843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065709#comment-16065709
]
mingleizhang commented on FLINK-6843:
-
[~aljoscha] I guess caused this because of java
Scott Kidder created FLINK-7022:
---
Summary: Flink Job Manager Scheduler & Web Frontend out of sync
when Zookeeper is unavailable on startup
Key: FLINK-7022
URL: https://issues.apache.org/jira/browse/FLINK-7022
[
https://issues.apache.org/jira/browse/FLINK-7017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065675#comment-16065675
]
ASF GitHub Bot commented on FLINK-7017:
---
Github user zhangminglei commented on a dif
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/4196#discussion_r124424384
--- Diff:
flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/WebFrontendITCase.java
---
@@ -83,16 +78,16 @@ public static void initial
Scott Kidder created FLINK-7021:
---
Summary: Flink Task Manager hangs on startup if one Zookeeper node
is unresolvable
Key: FLINK-7021
URL: https://issues.apache.org/jira/browse/FLINK-7021
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065620#comment-16065620
]
ASF GitHub Bot commented on FLINK-6998:
---
Github user zhenzhongxu commented on the is
Github user zhenzhongxu commented on the issue:
https://github.com/apache/flink/pull/4187
@tzulitai
**Regarding the metric naming:**
Any suggestions on naming conventions for these flink specific metrics? How
do you like 'kafkaconnector-commits-succeeded' (component-metri
[
https://issues.apache.org/jira/browse/FLINK-6998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065597#comment-16065597
]
ASF GitHub Bot commented on FLINK-6998:
---
Github user zhenzhongxu commented on a diff
Github user zhenzhongxu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4187#discussion_r124413737
--- Diff: docs/monitoring/metrics.md ---
@@ -867,6 +867,28 @@ Thus, in order to infer the metric identifier:
+ Connector:
[
https://issues.apache.org/jira/browse/FLINK-6998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065595#comment-16065595
]
ASF GitHub Bot commented on FLINK-6998:
---
Github user zhenzhongxu commented on a diff
Github user zhenzhongxu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4187#discussion_r124413756
--- Diff: docs/monitoring/metrics.md ---
@@ -867,6 +867,28 @@ Thus, in order to infer the metric identifier:
+ Connector:
[
https://issues.apache.org/jira/browse/FLINK-7009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065313#comment-16065313
]
ASF GitHub Bot commented on FLINK-7009:
---
Github user dbrinegar commented on a diff i
Github user dbrinegar commented on a diff in the pull request:
https://github.com/apache/flink/pull/4188#discussion_r124366697
--- Diff:
flink-metrics/flink-metrics-statsd/src/main/java/org/apache/flink/metrics/statsd/StatsDReporter.java
---
@@ -179,41 +254,130 @@ private String p
[
https://issues.apache.org/jira/browse/FLINK-7009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065293#comment-16065293
]
ASF GitHub Bot commented on FLINK-7009:
---
Github user dbrinegar commented on a diff i
Github user dbrinegar commented on a diff in the pull request:
https://github.com/apache/flink/pull/4188#discussion_r124364140
--- Diff:
flink-metrics/flink-metrics-statsd/src/main/java/org/apache/flink/metrics/statsd/StatsDReporter.java
---
@@ -90,6 +109,45 @@ public void close()
[
https://issues.apache.org/jira/browse/FLINK-7009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065289#comment-16065289
]
ASF GitHub Bot commented on FLINK-7009:
---
Github user dbrinegar commented on a diff i
Github user dbrinegar commented on a diff in the pull request:
https://github.com/apache/flink/pull/4188#discussion_r124363952
--- Diff:
flink-metrics/flink-metrics-statsd/src/main/java/org/apache/flink/metrics/statsd/StatsDReporter.java
---
@@ -90,6 +109,45 @@ public void close()
[
https://issues.apache.org/jira/browse/FLINK-7009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065283#comment-16065283
]
ASF GitHub Bot commented on FLINK-7009:
---
Github user dbrinegar commented on a diff i
Github user dbrinegar commented on a diff in the pull request:
https://github.com/apache/flink/pull/4188#discussion_r124363455
--- Diff: docs/monitoring/metrics.md ---
@@ -420,10 +420,30 @@ metrics.reporter.grph.protocol: TCP
In order to use this reporter you must copy
`/opt/f
[
https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065195#comment-16065195
]
sunjincheng commented on FLINK-6895:
Hi [~Aegeaner] thanks.
> Add STR_TO_DATE support
[
https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065187#comment-16065187
]
ASF GitHub Bot commented on FLINK-6584:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065189#comment-16065189
]
ASF GitHub Bot commented on FLINK-6584:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065190#comment-16065190
]
ASF GitHub Bot commented on FLINK-6584:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065186#comment-16065186
]
ASF GitHub Bot commented on FLINK-6584:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065188#comment-16065188
]
ASF GitHub Bot commented on FLINK-6584:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065191#comment-16065191
]
ASF GitHub Bot commented on FLINK-6584:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4199#discussion_r124329598
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/calcite/sql/fun/SqlStdOperatorTable.java
---
@@ -1900,7 +1900,7 @@ public void unparse
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4199#discussion_r124335785
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/calcite/RelTimeIndicatorConverter.scala
---
@@ -349,6 +350,14 @@ class Re
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4199#discussion_r124341520
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/WindowStartEndPropertiesRule.scala
---
@@ -54,34 +56,75
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4199#discussion_r124344855
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/WindowStartEndPropertiesRule.scala
---
@@ -54,34 +56,75
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4199#discussion_r124336278
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/LogicalWindowAggregateRule.scala
---
@@ -28,6 +28,7 @@
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4199#discussion_r124335359
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/MathFunctions.scala
---
@@ -16,7 +16,7 @@
* limit
[
https://issues.apache.org/jira/browse/FLINK-7006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065146#comment-16065146
]
ASF GitHub Bot commented on FLINK-7006:
---
GitHub user greghogan opened a pull request
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/4201
[FLINK-7006] [gelly] Base class using POJOs for Gelly algorithms
Gelly algorithms commonly have a Result class extending a Tuple type and
implementing one of the Unary/Binary/TertiaryResult interf
[
https://issues.apache.org/jira/browse/FLINK-7007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065138#comment-16065138
]
ASF GitHub Bot commented on FLINK-7007:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li reassigned FLINK-7014:
-
Assignee: Ruidong Li
> Expose isDeterministic interface to ScalarFunction and TableFunction
> ---
[
https://issues.apache.org/jira/browse/FLINK-7016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-7016:
--
Component/s: DataStream API
DataSet API
> Move inputFormat to InputFormatVertex
[
https://issues.apache.org/jira/browse/FLINK-7015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-7015:
--
Component/s: DataStream API
> Separate OperatorConfig from StreamConfig
> --
[
https://issues.apache.org/jira/browse/FLINK-7018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-7018:
--
Component/s: DataStream API
> Reconstruct streamgraph to clear interface
>
[
https://issues.apache.org/jira/browse/FLINK-6866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065091#comment-16065091
]
SmedbergM commented on FLINK-6866:
--
A Map[K,V] is already Serializable, as is java.util.M
[
https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065086#comment-16065086
]
Aegeaner commented on FLINK-6895:
-
I will try this.
> Add STR_TO_DATE supported in SQL
>
[
https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aegeaner reassigned FLINK-6895:
---
Assignee: Aegeaner
> Add STR_TO_DATE supported in SQL
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-6969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065057#comment-16065057
]
ASF GitHub Bot commented on FLINK-6969:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065056#comment-16065056
]
ASF GitHub Bot commented on FLINK-6969:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16065058#comment-16065058
]
ASF GitHub Bot commented on FLINK-6969:
---
Github user fhueske commented on a diff in
1 - 100 of 272 matches
Mail list logo
