[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869214#comment-15869214
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user ramkrish86 commented on the issue:
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/3149
Thanks to all @fhueske , @tonycox and @wuchong for helping in getting this
in.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5804:
---
Issue Type: New Feature (was: Sub-task)
Parent: (was: FLINK-5657)
> Add
[
https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869423#comment-15869423
]
sunjincheng commented on FLINK-5804:
Hi,guys，I made a preliminary implementation of this JIRA.
My
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101460153
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -1463,21 +1465,23 @@ class CodeGenerator(
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869422#comment-15869422
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user wuchong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869195#comment-15869195
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user wuchong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869196#comment-15869196
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user wuchong commented on a diff in the pull
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101445690
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala
---
@@ -324,4 +325,19 @@ object
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869191#comment-15869191
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user wuchong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869192#comment-15869192
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user wuchong commented on a diff in the pull
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101446217
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/datastream/DataStreamUserDefinedFunctionITCase.scala
---
@@ -0,0 +1,80
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101445424
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -1463,21 +1465,23 @@ class CodeGenerator(
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101445544
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala
---
@@ -324,4 +325,19 @@ object
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869194#comment-15869194
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user wuchong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869193#comment-15869193
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user wuchong commented on a diff in the pull
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101445785
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala
---
@@ -324,4 +325,19 @@ object
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869227#comment-15869227
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user sunjincheng121 commented on a diff in the pull
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101447054
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala
---
@@ -324,4 +325,19 @@
[
https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5804:
---
Issue Type: Sub-task (was: New Feature)
Parent: FLINK-5657
> Add [non-partitioned]
[
https://issues.apache.org/jira/browse/FLINK-5803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5803:
---
Issue Type: Sub-task (was: New Feature)
Parent: FLINK-5657
> Add [partitioned] processing
Shaoxuan Wang created FLINK-5813:
Summary: code generation for user-defined aggregate functions
Key: FLINK-5813
URL: https://issues.apache.org/jira/browse/FLINK-5813
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869413#comment-15869413
]
Fabian Hueske commented on FLINK-5792:
--
Ah, great. Thanks for pointing to the PR [~jark].
> Improve
[
https://issues.apache.org/jira/browse/FLINK-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869182#comment-15869182
]
sunjincheng commented on FLINK-5657:
Yes, agree with you. I'll do that.
> Add processing time OVER
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869216#comment-15869216
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user sunjincheng121 commented on a diff in the pull
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101447400
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/dataset/DataSetUserDefinedFunctionITCase.scala
---
@@ -0,0 +1,75
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869236#comment-15869236
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user sunjincheng121 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-5804:
-
Issue Type: New Feature (was: Sub-task)
Parent: (was: FLINK-5657)
> Add
[
https://issues.apache.org/jira/browse/FLINK-5803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-5803:
-
Issue Type: New Feature (was: Sub-task)
Parent: (was: FLINK-5657)
> Add
[
https://issues.apache.org/jira/browse/FLINK-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869418#comment-15869418
]
sunjincheng commented on FLINK-4557:
[~fhueske] Thanks for converter the "FLINK-5803" & "FLINK-5804"
[
https://issues.apache.org/jira/browse/FLINK-5803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869420#comment-15869420
]
sunjincheng commented on FLINK-5803:
Hi,guys，I made a preliminary implementation of this JIRA.
My
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869440#comment-15869440
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user sunjincheng121 commented on a diff in the pull
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101448753
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/dataset/DataSetUserDefinedFunctionITCase.scala
---
@@ -0,0 +1,75 @@
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869263#comment-15869263
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user wuchong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869275#comment-15869275
]
sunjincheng commented on FLINK-4557:
Hi,guys，I made a preliminary implementation of this JIRA.
My
[
https://issues.apache.org/jira/browse/FLINK-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869276#comment-15869276
]
sunjincheng commented on FLINK-4557:
Hi,guys，I made a preliminary implementation of this JIRA.
My
[
https://issues.apache.org/jira/browse/FLINK-5710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869355#comment-15869355
]
ASF GitHub Bot commented on FLINK-5710:
---
Github user huawei-flink commented on a diff in the pull
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101456205
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -1463,21 +1465,23 @@ class CodeGenerator(
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869376#comment-15869376
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user wuchong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869395#comment-15869395
]
Fabian Hueske commented on FLINK-5792:
--
I agree, it makes sense to ship a serialized UDF object.
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101461418
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -1463,21 +1465,23 @@ class
Github user godfreyhe commented on a diff in the pull request:
https://github.com/apache/flink/pull/3176#discussion_r101437939
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -122,6 +123,18 @@ class CodeGenerator(
Github user godfreyhe commented on a diff in the pull request:
https://github.com/apache/flink/pull/3176#discussion_r101437890
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/UDFContext.scala
---
@@ -0,0 +1,53 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869095#comment-15869095
]
ASF GitHub Bot commented on FLINK-5795:
---
GitHub user sunjincheng121 opened a pull request:
GitHub user sunjincheng121 opened a pull request:
https://github.com/apache/flink/pull/3330
[FLINK-5795][TableAPI] Improve UDTF to support constructor with pâ¦
â¦arameter.
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101446163
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/dataset/DataSetUserDefinedFunctionITCase.scala
---
@@ -0,0 +1,75 @@
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869285#comment-15869285
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user sunjincheng121 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869286#comment-15869286
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user wuchong commented on a diff in the pull
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101450383
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala
---
@@ -324,4 +325,19 @@
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101450405
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -1463,21 +1465,23 @@ class CodeGenerator(
[
https://issues.apache.org/jira/browse/FLINK-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869407#comment-15869407
]
Fabian Hueske commented on FLINK-4557:
--
Hi [~sunjincheng121], I think your last two comment should go
[
https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-5804:
-
Description:
The goal of this issue is to add support for OVER RANGE aggregations on
processing
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101458924
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -1463,21 +1465,23 @@ class
[
https://issues.apache.org/jira/browse/FLINK-5803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-5803:
-
Description:
The goal of this issue is to add support for OVER RANGE aggregations on
processing
Github user mylog00 commented on the issue:
https://github.com/apache/flink/pull/3325
TravisCI passed build.
https://travis-ci.org/mylog00/flink/builds/201929462
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869047#comment-15869047
]
ASF GitHub Bot commented on FLINK-5571:
---
Github user godfreyhe commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869049#comment-15869049
]
ASF GitHub Bot commented on FLINK-5571:
---
Github user godfreyhe commented on a diff in the pull
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101446744
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -1463,21 +1465,23 @@ class
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3176#discussion_r101447660
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/UserDefinedFunction.scala
---
@@ -24,4 +24,19 @@ package
[
https://issues.apache.org/jira/browse/FLINK-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869246#comment-15869246
]
ASF GitHub Bot commented on FLINK-5571:
---
Github user wuchong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5803:
---
Issue Type: New Feature (was: Sub-task)
Parent: (was: FLINK-5657)
> Add [partitioned]
[
https://issues.apache.org/jira/browse/FLINK-5710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869346#comment-15869346
]
ASF GitHub Bot commented on FLINK-5710:
---
Github user huawei-flink commented on a diff in the pull
Github user huawei-flink commented on a diff in the pull request:
https://github.com/apache/flink/pull/3271#discussion_r101454598
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/ProcTimeCallGen.scala
---
@@ -0,0 +1,40 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869405#comment-15869405
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user sunjincheng121 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869404#comment-15869404
]
Jark Wu commented on FLINK-5792:
Hi [~fhueske], [~sunjincheng121] has create a PR for this issue:
[
https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-5804:
-
Issue Type: Sub-task (was: New Feature)
Parent: FLINK-4557
> Add [non-partitioned]
[
https://issues.apache.org/jira/browse/FLINK-5803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-5803:
-
Issue Type: Sub-task (was: New Feature)
Parent: FLINK-4557
> Add [partitioned]
[
https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869029#comment-15869029
]
Jark Wu commented on FLINK-5792:
+1
The serialization way will be more flexible.
> Improve “UDF/UDTF" to
[
https://issues.apache.org/jira/browse/FLINK-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15869351#comment-15869351
]
ASF GitHub Bot commented on FLINK-5795:
---
Github user sunjincheng121 commented on a diff in the pull
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3330#discussion_r101455043
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -1463,21 +1465,23 @@ class
Github user huawei-flink commented on a diff in the pull request:
https://github.com/apache/flink/pull/3271#discussion_r101455204
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/table/calcite/functions/FlinkStreamFunctionCatalog.java
---
@@ -0,0 +1,39 @@
[
https://issues.apache.org/jira/browse/FLINK-5805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Anderson reassigned FLINK-5805:
-
Assignee: David Anderson
> improve docs for ProcessFunction
>
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/3305
Given our current usage where the `TypeInformation` is no longer a sole API
concept and we already keep most of the type informations in `flink-core`, I
think it is a good idea to add
[
https://issues.apache.org/jira/browse/FLINK-5790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867570#comment-15867570
]
ASF GitHub Bot commented on FLINK-5790:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867574#comment-15867574
]
Zhuoluo Yang commented on FLINK-5802:
-
Hi [~fhueske]. Thank you for your comment.
I agree with the
[
https://issues.apache.org/jira/browse/FLINK-5773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-5773:
-
Component/s: (was: DataStream API)
Distributed Coordination
> Cannot cast
[
https://issues.apache.org/jira/browse/FLINK-5773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-5773:
-
Affects Version/s: 1.3.0
> Cannot cast scala.util.Failure to
>
[
https://issues.apache.org/jira/browse/FLINK-5790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867575#comment-15867575
]
ASF GitHub Bot commented on FLINK-5790:
---
Github user shixiaogang commented on the issue:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3293
---
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-5745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867609#comment-15867609
]
ASF GitHub Bot commented on FLINK-5745:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3308
---
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-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867625#comment-15867625
]
Zhuoluo Yang commented on FLINK-5802:
-
Sure. [~fhueske]. Thank you so much. I also would like to make
David Anderson created FLINK-5805:
-
Summary: improve docs for ProcessFunction
Key: FLINK-5805
URL: https://issues.apache.org/jira/browse/FLINK-5805
Project: Flink
Issue Type: Improvement
Github user shixiaogang commented on the issue:
https://github.com/apache/flink/pull/3305
@tillrohrmann Both `org.apache.flink.api.common.typeutils.base` and
`"org.apache.flink.api.common.typeinfo` are in the module `flink-core`.
---
If your project is set up for it, you can reply
[
https://issues.apache.org/jira/browse/FLINK-5773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-5773:
-
Fix Version/s: 1.3.0
> Cannot cast scala.util.Failure to
>
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/3318
[FLINK-5070] [types] Unable to use Scala's BeanProperty with classes
This PR fixes issues with `@BeanProperty` annotation. The problem is that
`var` generates Scala-style getters/setters and the
[
https://issues.apache.org/jira/browse/FLINK-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867581#comment-15867581
]
ASF GitHub Bot commented on FLINK-5070:
---
GitHub user twalthr opened a pull request:
GitHub user alpinegizmo opened a pull request:
https://github.com/apache/flink/pull/3317
[FLINK-5805] improvements to docs for ProcessFunction
I added a paragraph to hopefully clarify why ProcessFunction is relevant to
joins. I also tried to clean up a few places where the English
[
https://issues.apache.org/jira/browse/FLINK-5805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867578#comment-15867578
]
ASF GitHub Bot commented on FLINK-5805:
---
GitHub user alpinegizmo opened a pull request:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2509
Last commit addresses consolidating the deserliazer settings for
`KafkaOffsetHandlerImpl`.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867580#comment-15867580
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user tzulitai commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-5802:
Assignee: Zhuoluo Yang
> Flink SQL calling Hive User-Defined Functions
>
[
https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867592#comment-15867592
]
Fabian Hueske commented on FLINK-5802:
--
Hi [~clarkyzl], sure. I gave you contributor permissions and
[
https://issues.apache.org/jira/browse/FLINK-5745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5745.
--
Resolution: Fixed
Fix Version/s: 1.3.0
Fixed in 9b4cd34 (release-1.2).
> Set uncaught exception
[
https://issues.apache.org/jira/browse/FLINK-5796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867612#comment-15867612
]
ASF GitHub Bot commented on FLINK-5796:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5796.
--
Resolution: Fixed
Fix Version/s: 1.2.0
1.3.0
Fixed 8368681 (release-1.2),
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3252#discussion_r101239149
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/table/api/java/stream/sql/WindowAggregateITCase.java
---
@@ -0,0 +1,135 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-5624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867642#comment-15867642
]
ASF GitHub Bot commented on FLINK-5624:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867643#comment-15867643
]
ASF GitHub Bot commented on FLINK-5624:
---
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/3252#discussion_r101248097
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/LogicalWindowAggregateRule.scala
---
@@ -0,0 +1,139 @@
1 - 100 of 312 matches
Mail list logo
