[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891757#comment-15891757
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user huawei-flink commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891756#comment-15891756
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user huawei-flink commented on a dif
Github user huawei-flink commented on a diff in the pull request:
https://github.com/apache/flink/pull/3443#discussion_r103866134
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/table/plan/nodes/datastream/aggs/DoubleSummaryAggregation.java
---
@@ -0,0 +1,214
Github user huawei-flink commented on a diff in the pull request:
https://github.com/apache/flink/pull/3443#discussion_r103866164
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/table/api/java/stream/sql/ProcTimeRowStreamAggregationSqlITCase.java
---
@@ -0,0 +
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891754#comment-15891754
]
Tzu-Li (Gordon) Tai commented on FLINK-4422:
Fixes for the Kafka connector mod
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891752#comment-15891752
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user huawei-flink commented on a dif
Github user huawei-flink commented on a diff in the pull request:
https://github.com/apache/flink/pull/3443#discussion_r103865652
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/table/plan/logical/rel/util/WindowAggregateUtil.java
---
@@ -0,0 +1,103 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-5134:
Description:
This is a part of fine-grained resource configuration in flip-6.
In *JobGraph* generation, eac
[
https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-5134:
Summary: Aggregate ResourceSpec for chained operators when generating job
graph (was: Aggregate ResourceSpe
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891715#comment-15891715
]
ASF GitHub Bot commented on FLINK-4422:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891714#comment-15891714
]
ASF GitHub Bot commented on FLINK-4422:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891717#comment-15891717
]
ASF GitHub Bot commented on FLINK-4422:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891716#comment-15891716
]
ASF GitHub Bot commented on FLINK-4422:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3422
---
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/3419
---
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/3421
---
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/3420
---
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-4714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei updated FLINK-4714:
---
Comment: was deleted
(was: Hi [~uce]
I saw you implement {{ZooKeeperCompletedCheckpointStore}} in FLI
[
https://issues.apache.org/jira/browse/FLINK-4815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891711#comment-15891711
]
Wei-Che Wei commented on FLINK-4815:
Hi [~uce]
I saw you implement {{ZooKeeperComplet
[
https://issues.apache.org/jira/browse/FLINK-4714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891709#comment-15891709
]
Wei-Che Wei commented on FLINK-4714:
Hi [~uce]
I saw you implement {{ZooKeeperComplet
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891706#comment-15891706
]
ASF GitHub Bot commented on FLINK-4422:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3420#discussion_r103861044
--- Diff:
flink-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KillerWatchDog.java
---
@@ -42,12
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3420
Thanks for the fix @jinmingjian. LGTM, merging the PRs now.
---
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 h
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891697#comment-15891697
]
ASF GitHub Bot commented on FLINK-4422:
---
Github user tzulitai commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-5949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-5949:
---
Priority: Blocker (was: Critical)
> Flink on YARN checks for Kerberos credentials for
[
https://issues.apache.org/jira/browse/FLINK-5949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-5949:
---
Fix Version/s: 1.2.1
> Flink on YARN checks for Kerberos credentials for non-Kerberos
[
https://issues.apache.org/jira/browse/FLINK-4789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891695#comment-15891695
]
Tzu-Li (Gordon) Tai commented on FLINK-4789:
I think this issue is partially f
[
https://issues.apache.org/jira/browse/FLINK-4789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891695#comment-15891695
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4789 at 3/2/17 6:32 AM:
[
https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891694#comment-15891694
]
ASF GitHub Bot commented on FLINK-5134:
---
GitHub user zhijiangW opened a pull request
GitHub user zhijiangW opened a pull request:
https://github.com/apache/flink/pull/3455
[FLINK-5134][runtime]Aggregate ResourceSpe for chained operators when
generating JobGraph
It is a part of fine-grained resource configuration in 'flip-6'.
In 'JobGraph' generation, each c
[
https://issues.apache.org/jira/browse/FLINK-5949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-5949:
---
Description:
Reported in ML:
http://apache-flink-user-mailing-list-archive.2336050.n4
[
https://issues.apache.org/jira/browse/FLINK-5949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-5949:
---
Component/s: YARN
> Flink on YARN checks for Kerberos credentials for non-Kerberos aut
Tzu-Li (Gordon) Tai created FLINK-5949:
--
Summary: Flink on YARN checks for Kerberos credentials for
non-Kerberos authentication methods
Key: FLINK-5949
URL: https://issues.apache.org/jira/browse/FLINK-5949
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891654#comment-15891654
]
sunjincheng commented on FLINK-5947:
[~Xiaojun Jin] Congratulations you solved this bu
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891644#comment-15891644
]
Xiaojun Jin edited comment on FLINK-5947 at 3/2/17 5:12 AM:
[~
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891644#comment-15891644
]
Xiaojun Jin commented on FLINK-5947:
[~sunjincheng] thanks for your answer. I have sol
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891602#comment-15891602
]
sunjincheng commented on FLINK-5947:
I think the reason for this problem may be for me
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891584#comment-15891584
]
Xiaojun Jin edited comment on FLINK-5947 at 3/2/17 4:00 AM:
Ye
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891584#comment-15891584
]
Xiaojun Jin commented on FLINK-5947:
Yes. I have maintained a separate version of flin
[
https://issues.apache.org/jira/browse/FLINK-5948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891579#comment-15891579
]
ASF GitHub Bot commented on FLINK-5948:
---
GitHub user GEOFBOT opened a pull request:
GitHub user GEOFBOT opened a pull request:
https://github.com/apache/flink/pull/3454
[FLINK-5948] Fix error in Python zip_with_index documentation
Fixes an issue with the documentation where the camel-cased name
`zipWithIndex` is used instead of the snake-cased name (`zip_with_index
Geoffrey Mon created FLINK-5948:
---
Summary: Error in Python zip_with_index documentation
Key: FLINK-5948
URL: https://issues.apache.org/jira/browse/FLINK-5948
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891567#comment-15891567
]
sunjincheng edited comment on FLINK-5947 at 3/2/17 3:40 AM:
[~
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891567#comment-15891567
]
sunjincheng commented on FLINK-5947:
[~Xiaojun Jin] In your exception information, the
[
https://issues.apache.org/jira/browse/FLINK-5740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891562#comment-15891562
]
sunjincheng commented on FLINK-5740:
+1 very good point， any news for this issue? [~al
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891558#comment-15891558
]
sunjincheng edited comment on FLINK-5947 at 3/2/17 3:23 AM:
Hi
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891558#comment-15891558
]
sunjincheng commented on FLINK-5947:
Hi, @Xiaojun Jin thanks for reporter this issue.
[
https://issues.apache.org/jira/browse/FLINK-4714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891545#comment-15891545
]
Wei-Che Wei commented on FLINK-4714:
Hi [~till.rohrmann]
I have some ideas about this
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3450
---
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-5794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891530#comment-15891530
]
ASF GitHub Bot commented on FLINK-5794:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-5794.
--
Resolution: Fixed
Fix Version/s: 1.3.0
fixed in bf4eed144428179a2390eb67642f8ac755896fc2
> update the do
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3423#discussion_r103839943
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -363,199 +342,112 @@ object A
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891503#comment-15891503
]
ASF GitHub Bot commented on FLINK-5768:
---
Github user shaoxuan-wang commented on a di
Xiaojun Jin created FLINK-5947:
--
Summary: NullPointerException in
ContinuousProcessingTimeTrigger.clear()
Key: FLINK-5947
URL: https://issues.apache.org/jira/browse/FLINK-5947
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891454#comment-15891454
]
ASF GitHub Bot commented on FLINK-5768:
---
Github user shaoxuan-wang commented on a di
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3423#discussion_r103835523
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -54,31 +58,31 @@ object Aggre
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891447#comment-15891447
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user hongyuhong commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891449#comment-15891449
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user hongyuhong commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891448#comment-15891448
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user hongyuhong commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891450#comment-15891450
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user hongyuhong commented on a diff
Github user hongyuhong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3443#discussion_r103835080
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/table/plan/nodes/datastream/DataStreamProcTimeRowAggregate.java
---
@@ -0,0 +1,160 @
Github user hongyuhong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3443#discussion_r103835059
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/table/plan/logical/rel/util/WindowAggregateUtil.java
---
@@ -0,0 +1,103 @@
+/*
Github user hongyuhong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3443#discussion_r103835113
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/table/api/java/stream/sql/ProcTimeRowStreamAggregationSqlITCase.java
---
@@ -0,0 +1,
Github user hongyuhong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3443#discussion_r103835088
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/table/plan/nodes/datastream/aggs/DoubleSummaryAggregation.java
---
@@ -0,0 +1,214 @@
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891441#comment-15891441
]
ASF GitHub Bot commented on FLINK-5768:
---
Github user shaoxuan-wang commented on a di
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3423#discussion_r103834968
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataSetSessionWindowAggregateReduceGroupFunction.scala
---
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/3450
Looks good to me too. I will merge it.
---
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
enab
[
https://issues.apache.org/jira/browse/FLINK-5794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891407#comment-15891407
]
ASF GitHub Bot commented on FLINK-5794:
---
Github user wuchong commented on the issue:
Scott Kidder created FLINK-5946:
---
Summary: Kinesis Producer uses KPL that orphans threads that
consume 100% CPU
Key: FLINK-5946
URL: https://issues.apache.org/jira/browse/FLINK-5946
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15822346#comment-15822346
]
Ted Yu edited comment on FLINK-5486 at 3/2/17 12:35 AM:
Lock on St
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891305#comment-15891305
]
ASF GitHub Bot commented on FLINK-5768:
---
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/3423#discussion_r103807487
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -54,31 +58,31 @@ object AggregateUt
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3423#discussion_r103818316
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -737,101 +632,121 @@ object Aggrega
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3423#discussion_r103806696
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -737,101 +632,121 @@ object Aggrega
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891306#comment-15891306
]
ASF GitHub Bot commented on FLINK-5768:
---
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/3423#discussion_r103801735
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -363,199 +342,112 @@ object Aggrega
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3423#discussion_r103806213
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -737,101 +632,121 @@ object Aggrega
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3423#discussion_r103801835
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -363,199 +342,112 @@ object Aggrega
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891309#comment-15891309
]
ASF GitHub Bot commented on FLINK-5768:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891311#comment-15891311
]
ASF GitHub Bot commented on FLINK-5768:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891310#comment-15891310
]
ASF GitHub Bot commented on FLINK-5768:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891308#comment-15891308
]
ASF GitHub Bot commented on FLINK-5768:
---
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/3423#discussion_r103818719
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateAggFunction.scala
---
@@ -0,0 +1,101 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891307#comment-15891307
]
ASF GitHub Bot commented on FLINK-5768:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891296#comment-15891296
]
ASF GitHub Bot commented on FLINK-4460:
---
Github user chenqin commented on the issue:
Github user chenqin commented on the issue:
https://github.com/apache/flink/pull/2982
@aljoscha
Nice! Let's do "Chen Qin qinnc...@gmail.com"
---
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 ha
[
https://issues.apache.org/jira/browse/FLINK-5945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891121#comment-15891121
]
ASF GitHub Bot commented on FLINK-5945:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3453
Looks good to me.
+1 to merge
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled a
[
https://issues.apache.org/jira/browse/FLINK-5945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15891034#comment-15891034
]
ASF GitHub Bot commented on FLINK-5945:
---
GitHub user greghogan opened a pull request
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/3453
[FLINK-5945] [core] Close function in
OuterJoinOperatorBase#executeOnCollections
Conclude OuterJoinOperatorBase#executeOnCollections with a call to
FunctionUtils.closeFunction(function) in order
Greg Hogan created FLINK-5945:
-
Summary: Close function in
OuterJoinOperatorBase#executeOnCollections
Key: FLINK-5945
URL: https://issues.apache.org/jira/browse/FLINK-5945
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-5944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ilya Ganelin updated FLINK-5944:
Description:
Snappy is an extremely performant compression format that's widely used
offering fast
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3450
thanks for the update.
+1 to merge
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabl
[
https://issues.apache.org/jira/browse/FLINK-5794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15890896#comment-15890896
]
ASF GitHub Bot commented on FLINK-5794:
---
Github user fhueske commented on the issue:
Ilya Ganelin created FLINK-5944:
---
Summary: Flink should support reading Snappy Files
Key: FLINK-5944
URL: https://issues.apache.org/jira/browse/FLINK-5944
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-5794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15890710#comment-15890710
]
ASF GitHub Bot commented on FLINK-5794:
---
Github user sunjincheng121 commented on the
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/3450
@fhueske Appreciate your hintï¼ÂAnd I have updated the 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 project do
[
https://issues.apache.org/jira/browse/FLINK-5794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15890683#comment-15890683
]
ASF GitHub Bot commented on FLINK-5794:
---
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/3450#discussion_r103747100
--- Diff: docs/dev/table_api.md ---
@@ -4732,23 +4732,29 @@ User-defined Functions
If a required scalar function is not contained in the built-in f
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3450#discussion_r103747440
--- Diff: docs/dev/table_api.md ---
@@ -4819,7 +4826,7 @@ object TimestampModifier extends ScalarFunction {
Similar to a user-defined scalar functi
1 - 100 of 291 matches
Mail list logo
