[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891757#comment-15891757
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user huawei-flink commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891756#comment-15891756
]
ASF GitHub Bot commented on FLINK-5653:
---
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/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=15891754#comment-15891754
]
Tzu-Li (Gordon) Tai commented on FLINK-4422:
Fixes for the Kafka connector modules have been
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891752#comment-15891752
]
ASF GitHub Bot commented on FLINK-5653:
---
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/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,
[
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
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891715#comment-15891715
]
ASF GitHub Bot commented on FLINK-4422:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891714#comment-15891714
]
ASF GitHub Bot commented on FLINK-4422:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891717#comment-15891717
]
ASF GitHub Bot commented on FLINK-4422:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891716#comment-15891716
]
ASF GitHub Bot commented on FLINK-4422:
---
Github user asfgit closed the pull request at:
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
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
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
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-4815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891711#comment-15891711
]
Wei-Che Wei commented on FLINK-4815:
Hi [~uce]
I saw you implement
[
https://issues.apache.org/jira/browse/FLINK-4714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891709#comment-15891709
]
Wei-Che Wei commented on FLINK-4714:
Hi [~uce]
I saw you implement
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891706#comment-15891706
]
ASF GitHub Bot commented on FLINK-4422:
---
Github user tzulitai commented on a diff in the pull
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
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
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=15891695#comment-15891695
]
Tzu-Li (Gordon) Tai commented on FLINK-4789:
I think this issue is partially fixed already.
[
https://issues.apache.org/jira/browse/FLINK-4789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891695#comment-15891695
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4789 at 3/2/17 6:32 AM:
I
[
https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
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:
[
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
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=15891654#comment-15891654
]
sunjincheng commented on FLINK-5947:
[~Xiaojun Jin] Congratulations you solved this bug,cheers !!!
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891644#comment-15891644
]
Xiaojun Jin edited comment on FLINK-5947 at 3/2/17 5:12 AM:
[~sunjincheng121]
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891644#comment-15891644
]
Xiaojun Jin commented on FLINK-5947:
[~sunjincheng] thanks for your answer. I have solved this bug.
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891602#comment-15891602
]
sunjincheng commented on FLINK-5947:
I think the reason for this problem may be for merge state.when
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891584#comment-15891584
]
Xiaojun Jin edited comment on FLINK-5947 at 3/2/17 4:00 AM:
Yes
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891584#comment-15891584
]
Xiaojun Jin commented on FLINK-5947:
Yes. I have maintained a separate version of flink in my company
[
https://issues.apache.org/jira/browse/FLINK-5948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
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=15891567#comment-15891567
]
sunjincheng edited comment on FLINK-5947 at 3/2/17 3:40 AM:
[~Xiaojun Jin] In
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891567#comment-15891567
]
sunjincheng commented on FLINK-5947:
[~Xiaojun Jin] In your exception information, the error line
[
https://issues.apache.org/jira/browse/FLINK-5740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891562#comment-15891562
]
sunjincheng commented on FLINK-5740:
+1 very good point， any news for this issue? [~aljoscha]
> Make
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891558#comment-15891558
]
sunjincheng edited comment on FLINK-5947 at 3/2/17 3:23 AM:
Hi, @Xiaojun Jin
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891558#comment-15891558
]
sunjincheng commented on FLINK-5947:
Hi, @Xiaojun Jin thanks for reporter this issue. Can you describe
[
https://issues.apache.org/jira/browse/FLINK-4714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891545#comment-15891545
]
Wei-Che Wei commented on FLINK-4714:
Hi [~till.rohrmann]
I have some ideas about this issue and I
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
[
https://issues.apache.org/jira/browse/FLINK-5794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891530#comment-15891530
]
ASF GitHub Bot commented on FLINK-5794:
---
Github user asfgit closed the pull request at:
[
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
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
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891503#comment-15891503
]
ASF GitHub Bot commented on FLINK-5768:
---
Github user shaoxuan-wang commented on a diff in the pull
Xiaojun Jin created FLINK-5947:
--
Summary: NullPointerException in
ContinuousProcessingTimeTrigger.clear()
Key: FLINK-5947
URL: https://issues.apache.org/jira/browse/FLINK-5947
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891454#comment-15891454
]
ASF GitHub Bot commented on FLINK-5768:
---
Github user shaoxuan-wang commented on a diff in the pull
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
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891447#comment-15891447
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user hongyuhong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891449#comment-15891449
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user hongyuhong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891448#comment-15891448
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user hongyuhong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891450#comment-15891450
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user hongyuhong commented on a diff in the pull
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_r103835088
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/table/plan/nodes/datastream/aggs/DoubleSummaryAggregation.java
---
@@ -0,0 +1,214
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
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891441#comment-15891441
]
ASF GitHub Bot commented on FLINK-5768:
---
Github user shaoxuan-wang commented on a diff in the pull
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
[
https://issues.apache.org/jira/browse/FLINK-5794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=15822346#comment-15822346
]
Ted Yu edited comment on FLINK-5486 at 3/2/17 12:35 AM:
Lock on State.bucketStates
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891305#comment-15891305
]
ASF GitHub Bot commented on FLINK-5768:
---
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/3423#discussion_r103807487
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -54,31 +58,31 @@ object
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
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
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891306#comment-15891306
]
ASF GitHub Bot commented on FLINK-5768:
---
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/3423#discussion_r103801735
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -363,199 +342,112 @@ object
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
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891311#comment-15891311
]
ASF GitHub Bot commented on FLINK-5768:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891310#comment-15891310
]
ASF GitHub Bot commented on FLINK-5768:
---
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/3423#discussion_r103801835
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -363,199 +342,112 @@ object
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891309#comment-15891309
]
ASF GitHub Bot commented on FLINK-5768:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891307#comment-15891307
]
ASF GitHub Bot commented on FLINK-5768:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891308#comment-15891308
]
ASF GitHub Bot commented on FLINK-5768:
---
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/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-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
https://issues.apache.org/jira/browse/FLINK-5945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
https://issues.apache.org/jira/browse/FLINK-5945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
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
[
https://issues.apache.org/jira/browse/FLINK-5794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890896#comment-15890896
]
ASF GitHub Bot commented on FLINK-5794:
---
Github user fhueske commented on the issue:
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
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
[
https://issues.apache.org/jira/browse/FLINK-5794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890710#comment-15890710
]
ASF GitHub Bot commented on FLINK-5794:
---
Github user sunjincheng121 commented on the issue:
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 does
[
https://issues.apache.org/jira/browse/FLINK-5794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890683#comment-15890683
]
ASF GitHub Bot commented on FLINK-5794:
---
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/3450#discussion_r103747171
--- Diff: docs/dev/table_api.md ---
@@ -4819,7 +4826,7 @@ object TimestampModifier extends ScalarFunction {
Similar to a user-defined scalar
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
1 - 100 of 290 matches
Mail list logo
