liming30 commented on pull request #13109:
URL: https://github.com/apache/flink/pull/13109#issuecomment-687535459
Hi, @pnowojski I have rebase the master and reorganized the commit.
> Could you restructure first three commits in the following way ([following
our coding
dianfu commented on a change in pull request #13314:
URL: https://github.com/apache/flink/pull/13314#discussion_r483404672
##
File path: docs/dev/python/table-api-users-guide/table_environment.md
##
@@ -0,0 +1,833 @@
+---
+title: "TableEnvironment"
+nav-parent_id:
[
https://issues.apache.org/jira/browse/FLINK-14087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190592#comment-17190592
]
Dawid Wysakowicz commented on FLINK-14087:
--
Fixed in:
* master
**
Shawn-Hx commented on pull request #13308:
URL: https://github.com/apache/flink/pull/13308#issuecomment-686955574
Add `` tags for all titles according to @klion26 's
[advice](https://github.com/apache/flink/pull/13279#discussion_r483402111).
Hi, @klion26.
Could you help to review
flinkbot edited a comment on pull request #13308:
URL: https://github.com/apache/flink/pull/13308#issuecomment-685773533
## CI report:
* 7844c7a2675e2691811a91421f65948505620522 Azure:
flinkbot edited a comment on pull request #13324:
URL: https://github.com/apache/flink/pull/13324#issuecomment-686875157
## CI report:
* 04c250f4f16667c122c12e4b793204337d204c59 Azure:
rmetzger commented on a change in pull request #375:
URL: https://github.com/apache/flink-web/pull/375#discussion_r483432310
##
File path: _posts/2020-08-31-community-update.md
##
@@ -0,0 +1,222 @@
+---
+layout: post
+title: "Flink Community Update - August'20"
+date:
flinkbot edited a comment on pull request #13325:
URL: https://github.com/apache/flink/pull/13325#issuecomment-686925091
## CI report:
* 26abf1ecf936d0232c6d49c0bdd4fe3beae6252e Azure:
flinkbot edited a comment on pull request #13323:
URL: https://github.com/apache/flink/pull/13323#issuecomment-686869045
## CI report:
* 084ec77b7f7b01dc6314797cb3fa0aa2455432f7 Azure:
dawidwys opened a new pull request #13326:
URL: https://github.com/apache/flink/pull/13326
## What is the purpose of the change
Fix the issue that custom partitioners were not opened.
## Brief change log
- Moved openning of the partitioner from initProducer to open
[
https://issues.apache.org/jira/browse/FLINK-19133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19133:
---
Labels: pull-request-available (was: )
> User provided kafka partitioners are not
flinkbot edited a comment on pull request #13225:
URL: https://github.com/apache/flink/pull/13225#issuecomment-678953566
## CI report:
* 9d5f591223a0e46a22e24bbeb084a6b59c48a445 Azure:
dianfu commented on a change in pull request #13295:
URL: https://github.com/apache/flink/pull/13295#discussion_r483425236
##
File path: docs/dev/python/faq.md
##
@@ -52,6 +52,20 @@ $ source venv/bin/activate
$ python xxx.py
{% endhighlight %}
+**Note:** When running jobs
[
https://issues.apache.org/jira/browse/FLINK-14087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-14087:
-
Fix Version/s: 1.10.3
1.11.2
1.12.0
> throws
rmetzger commented on a change in pull request #375:
URL: https://github.com/apache/flink-web/pull/375#discussion_r483434583
##
File path: _posts/2020-08-31-community-update.md
##
@@ -0,0 +1,222 @@
+---
+layout: post
+title: "Flink Community Update - August'20"
+date:
sujun1020 commented on a change in pull request #13306:
URL: https://github.com/apache/flink/pull/13306#discussion_r483439854
##
File path:
flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcFileSystemFormatFactory.java
##
@@ -83,14 +96,227 @@ private static
flinkbot edited a comment on pull request #13325:
URL: https://github.com/apache/flink/pull/13325#issuecomment-686925091
## CI report:
* 26abf1ecf936d0232c6d49c0bdd4fe3beae6252e Azure:
flinkbot edited a comment on pull request #13308:
URL: https://github.com/apache/flink/pull/13308#issuecomment-685773533
## CI report:
* 7844c7a2675e2691811a91421f65948505620522 Azure:
flinkbot edited a comment on pull request #13128:
URL: https://github.com/apache/flink/pull/13128#issuecomment-672766836
## CI report:
* 313b80f4474455d7013b0852929b5a8458f391a1 UNKNOWN
* ece578a9fdbaee4d815de501187d92a729790c9b Azure:
sujun1020 commented on a change in pull request #13306:
URL: https://github.com/apache/flink/pull/13306#discussion_r483439597
##
File path:
flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcFileSystemFormatFactory.java
##
@@ -83,14 +96,227 @@ private static
[
https://issues.apache.org/jira/browse/FLINK-19121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-19121:
Fix Version/s: 1.12.0
> Avoid accessing HDFS frequently in HiveBulkWriterFactory
>
zhuxiaoshang commented on a change in pull request #13225:
URL: https://github.com/apache/flink/pull/13225#discussion_r483414657
##
File path:
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/api/Fetch.java
##
@@ -0,0 +1,13 @@
+package
flinkbot commented on pull request #13326:
URL: https://github.com/apache/flink/pull/13326#issuecomment-686943261
## CI report:
* e8a32ce376b09df4766fd6ddd439d8f634210ad7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
WeiZhong94 commented on a change in pull request #13325:
URL: https://github.com/apache/flink/pull/13325#discussion_r483411913
##
File path: flink-python/pyflink/table/expressions.py
##
@@ -538,9 +538,44 @@ def call(f: Union[str, UserDefinedFunctionWrapper], *args)
->
flinkbot edited a comment on pull request #13326:
URL: https://github.com/apache/flink/pull/13326#issuecomment-686943261
## CI report:
* e8a32ce376b09df4766fd6ddd439d8f634210ad7 Azure:
dianfu commented on pull request #13325:
URL: https://github.com/apache/flink/pull/13325#issuecomment-686950814
@WeiZhong94 Thanks for the review. Updated the PR.
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-19126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190596#comment-17190596
]
Tang Yan commented on FLINK-19126:
--
[~fly_in_gis] Thanks for your reply. I've got succeeded after
flinkbot edited a comment on pull request #13225:
URL: https://github.com/apache/flink/pull/13225#issuecomment-678953566
## CI report:
* 9d5f591223a0e46a22e24bbeb084a6b59c48a445 Azure:
flinkbot edited a comment on pull request #13321:
URL: https://github.com/apache/flink/pull/13321#issuecomment-686567896
## CI report:
* d79f152fa91b8bc555af6fb2a00a8d62b184be5a UNKNOWN
* 7039064922aaec22752ac84e4e9d41d663e68a14 Azure:
[
https://issues.apache.org/jira/browse/FLINK-19134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuiqiang Chen updated FLINK-19134:
---
Summary: Add BasicArrayTypeInfo and coder for PrimitiveArrayTypeInfo for
Python DataStream
flinkbot commented on pull request #13327:
URL: https://github.com/apache/flink/pull/13327#issuecomment-686987024
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
[
https://issues.apache.org/jira/browse/FLINK-19133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190574#comment-17190574
]
Dawid Wysakowicz commented on FLINK-19133:
--
I have the PR prepared already, was just waiting
[
https://issues.apache.org/jira/browse/FLINK-19126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190600#comment-17190600
]
Till Rohrmann commented on FLINK-19126:
---
Why isn't it enough to export {{HADOOP_CLASSPATH}}? Where
JingsongLi commented on a change in pull request #13306:
URL: https://github.com/apache/flink/pull/13306#discussion_r483442277
##
File path:
flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcFileSystemFormatFactory.java
##
@@ -83,14 +96,227 @@ private static
JingsongLi commented on a change in pull request #13306:
URL: https://github.com/apache/flink/pull/13306#discussion_r483441711
##
File path:
flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcFileSystemFormatFactory.java
##
@@ -83,14 +96,227 @@ private static
tillrohrmann closed pull request #13227:
URL: https://github.com/apache/flink/pull/13227
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to
JingsongLi commented on a change in pull request #13306:
URL: https://github.com/apache/flink/pull/13306#discussion_r483441917
##
File path:
flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcFileSystemFormatFactory.java
##
@@ -83,14 +96,227 @@ private static
azagrebin commented on a change in pull request #13181:
URL: https://github.com/apache/flink/pull/13181#discussion_r483450043
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SchedulerImpl.java
##
@@ -98,14 +101,15 @@ public SchedulerImpl(
Mohammad Hossein Gerami created FLINK-19139:
---
Summary: flink-conf.yml read values from environment variables
Key: FLINK-19139
URL: https://issues.apache.org/jira/browse/FLINK-19139
Project:
[
https://issues.apache.org/jira/browse/FLINK-18641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190612#comment-17190612
]
Zhu Zhu edited comment on FLINK-18641 at 9/4/20, 7:59 AM:
--
Hi [~becket_qin],
tillrohrmann commented on a change in pull request #13316:
URL: https://github.com/apache/flink/pull/13316#discussion_r483452267
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java
##
@@ -271,12 +271,28 @@ public int
azagrebin commented on a change in pull request #13181:
URL: https://github.com/apache/flink/pull/13181#discussion_r481844415
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SharingPhysicalSlotRequestBulk.java
##
@@ -0,0 +1,86 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-18641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190612#comment-17190612
]
Zhu Zhu commented on FLINK-18641:
-
Hi [~becket_qin], that's the status of the pull request?
> "Failure
flinkbot edited a comment on pull request #13316:
URL: https://github.com/apache/flink/pull/13316#issuecomment-686398901
## CI report:
* e37cb771c66ed8cab48e0b7abd53132fb15dfca3 UNKNOWN
* 5ccdc55dc70a57332c50bd59c0a8e6e59a29bffd Azure:
dawidwys commented on pull request #13326:
URL: https://github.com/apache/flink/pull/13326#issuecomment-686998060
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message,
flinkbot edited a comment on pull request #13284:
URL: https://github.com/apache/flink/pull/13284#issuecomment-683683000
## CI report:
* 71281ac4921c174c214f2393e169e7140698af2d Azure:
flinkbot commented on pull request #13326:
URL: https://github.com/apache/flink/pull/13326#issuecomment-686935096
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
mbalassi commented on pull request #13128:
URL: https://github.com/apache/flink/pull/13128#issuecomment-686965680
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message,
sujun1020 commented on a change in pull request #13306:
URL: https://github.com/apache/flink/pull/13306#discussion_r483439249
##
File path:
flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcFileSystemFormatFactory.java
##
@@ -83,14 +96,227 @@ private static
[
https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-18959.
-
Resolution: Fixed
Fixed via
master: d9bddfd3c49203034141fafa0b1d522e7ea0b6e7
1.11.2:
[
https://issues.apache.org/jira/browse/FLINK-19121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-19121.
Resolution: Fixed
master: 41c3a19b235ad1351e9376d2d70101bd8090a4a8
release-1.11:
tillrohrmann closed pull request #13318:
URL: https://github.com/apache/flink/pull/13318
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to
tillrohrmann commented on pull request #13317:
URL: https://github.com/apache/flink/pull/13317#issuecomment-686973783
Manually merged via 40f81b7794bde837aee8acac8944929ec43b6ef6
This is an automated message from the Apache
shuiqiangchen edited a comment on pull request #13292:
URL: https://github.com/apache/flink/pull/13292#issuecomment-686966367
Hi @dianfu Thank you for your comments. Currently, users are not able to
get/set Configurations for a StreamExecutionEnvironment since the
JingsongLi merged pull request #13301:
URL: https://github.com/apache/flink/pull/13301
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
tillrohrmann closed pull request #13317:
URL: https://github.com/apache/flink/pull/13317
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to
tillrohrmann commented on pull request #13318:
URL: https://github.com/apache/flink/pull/13318#issuecomment-686973295
Manually merged via 7e2294c2b5ca9a17c924ff948a0dcd87d90c8327
This is an automated message from the Apache
flinkbot edited a comment on pull request #13325:
URL: https://github.com/apache/flink/pull/13325#issuecomment-686925091
## CI report:
* 26abf1ecf936d0232c6d49c0bdd4fe3beae6252e Azure:
asfgit closed pull request #13015:
URL: https://github.com/apache/flink/pull/13015
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to
[
https://issues.apache.org/jira/browse/FLINK-18536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-18536.
---
Resolution: Fixed
Fixed in master via e472abb39681adb3d0e0de02254fd92b04b451f3
morsapaes commented on a change in pull request #375:
URL: https://github.com/apache/flink-web/pull/375#discussion_r483435844
##
File path: _posts/2020-08-31-community-update.md
##
@@ -0,0 +1,222 @@
+---
+layout: post
+title: "Flink Community Update - August'20"
+date:
shuiqiangchen commented on pull request #13292:
URL: https://github.com/apache/flink/pull/13292#issuecomment-686966367
Hi @dianfu Thank you for your comments. Currently, users are not able to
get/set Configurations for a StreamExecutionEnvironment since the
rmetzger commented on a change in pull request #375:
URL: https://github.com/apache/flink-web/pull/375#discussion_r483436620
##
File path: _posts/2020-08-31-community-update.md
##
@@ -0,0 +1,222 @@
+---
+layout: post
+title: "Flink Community Update - August'20"
+date:
[
https://issues.apache.org/jira/browse/FLINK-19126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190603#comment-17190603
]
Tang Yan commented on FLINK-19126:
--
[~trohrmann] If I do export HADOOP_CLASSPATH=`hadoop classpath` in
flinkbot edited a comment on pull request #13284:
URL: https://github.com/apache/flink/pull/13284#issuecomment-683683000
## CI report:
* 71281ac4921c174c214f2393e169e7140698af2d Azure:
shuiqiangchen edited a comment on pull request #13292:
URL: https://github.com/apache/flink/pull/13292#issuecomment-686966367
Hi @dianfu Thank you for your comments. Currently, users are not able to
get/set Configurations for a StreamExecutionEnvironment since the
flinkbot edited a comment on pull request #13128:
URL: https://github.com/apache/flink/pull/13128#issuecomment-672766836
## CI report:
* 313b80f4474455d7013b0852929b5a8458f391a1 UNKNOWN
* ece578a9fdbaee4d815de501187d92a729790c9b Azure:
[
https://issues.apache.org/jira/browse/FLINK-19134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19134:
---
Labels: pull-request-available (was: )
> Fix the converter of array coder for Python
shuiqiangchen opened a new pull request #13327:
URL: https://github.com/apache/flink/pull/13327
## What is the purpose of the change
Add BasicArrayTypeInfo and coder for PrimitiveArrayTypeInfo.
## Brief change log
- Added BasicArrayTypeInfo for arrays boxed
flinkbot edited a comment on pull request #13225:
URL: https://github.com/apache/flink/pull/13225#issuecomment-678953566
## CI report:
* f6141fa38f42a92fe10ca6b707813f0253ba5f3f Azure:
flinkbot edited a comment on pull request #13327:
URL: https://github.com/apache/flink/pull/13327#issuecomment-687006937
## CI report:
* 352380e8ab8941541fbc1773bcd29820bcf646c3 Azure:
flinkbot edited a comment on pull request #13181:
URL: https://github.com/apache/flink/pull/13181#issuecomment-675091412
## CI report:
* e7553689356882de1ffe606400d1255d1d757bc4 UNKNOWN
* a96b2db52a0db507e0077266c8e9cb947413e1ba Azure:
flinkbot edited a comment on pull request #13316:
URL: https://github.com/apache/flink/pull/13316#issuecomment-686398901
## CI report:
* e37cb771c66ed8cab48e0b7abd53132fb15dfca3 UNKNOWN
* 5ccdc55dc70a57332c50bd59c0a8e6e59a29bffd Azure:
flinkbot edited a comment on pull request #13329:
URL: https://github.com/apache/flink/pull/13329#issuecomment-687023379
## CI report:
* 54964991f6b3ec7b12f2cb045d29a2a33dad1011 Azure:
flinkbot edited a comment on pull request #13274:
URL: https://github.com/apache/flink/pull/13274#issuecomment-682368291
## CI report:
* 7835ad0187076a7dae2ee7e8806337f1b3db01c1 Azure:
XComp commented on a change in pull request #13316:
URL: https://github.com/apache/flink/pull/13316#discussion_r483525366
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java
##
@@ -271,12 +271,28 @@ public int
flinkbot edited a comment on pull request #13189:
URL: https://github.com/apache/flink/pull/13189#issuecomment-675350675
## CI report:
* 7594c2debe3cfeb8d4a216b65b5bda88054f12c3 Azure:
flinkbot edited a comment on pull request #13314:
URL: https://github.com/apache/flink/pull/13314#issuecomment-686373715
## CI report:
* ab431319119d2cb4865ea961c4386da3d90394fe Azure:
[
https://issues.apache.org/jira/browse/FLINK-14406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias reassigned FLINK-14406:
Assignee: Matthias
> Add metric for managed memory
> -
>
>
dianfu merged pull request #13325:
URL: https://github.com/apache/flink/pull/13325
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to
Yunhui created FLINK-19141:
--
Summary: Flink Job Submitted on Yarn Does not Work
Key: FLINK-19141
URL: https://issues.apache.org/jira/browse/FLINK-19141
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-15974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-15974.
---
Resolution: Fixed
master: bffc61ac7dad8541bde77ee6aed2b72385f420d8
> Support to use the Python UDF
flinkbot edited a comment on pull request #13325:
URL: https://github.com/apache/flink/pull/13325#issuecomment-686925091
## CI report:
* 6f65076badbf59b1ded4e7778a0349d489138e7f Azure:
[
https://issues.apache.org/jira/browse/FLINK-19141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yunhui updated FLINK-19141:
---
Description:
I first launch a cluster on yarn.
{code:java}
$flink_path/bin/yarn-session.sh \
-qu dev \
[
https://issues.apache.org/jira/browse/FLINK-19141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yunhui updated FLINK-19141:
---
Description:
I first launch a cluster on yarn.
{code:java}
$flink_path/bin/yarn-session.sh \
-qu dev \
hequn8128 merged pull request #13203:
URL: https://github.com/apache/flink/pull/13203
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
flinkbot edited a comment on pull request #13321:
URL: https://github.com/apache/flink/pull/13321#issuecomment-686567896
## CI report:
* d79f152fa91b8bc555af6fb2a00a8d62b184be5a UNKNOWN
* 7039064922aaec22752ac84e4e9d41d663e68a14 Azure:
flinkbot edited a comment on pull request #13326:
URL: https://github.com/apache/flink/pull/13326#issuecomment-686943261
## CI report:
* e8a32ce376b09df4766fd6ddd439d8f634210ad7 Azure:
flinkbot commented on pull request #13327:
URL: https://github.com/apache/flink/pull/13327#issuecomment-687006937
## CI report:
* 352380e8ab8941541fbc1773bcd29820bcf646c3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
Benchao Li created FLINK-19140:
--
Summary: Join with Table Function (UDTF) SQL example is incorrect
Key: FLINK-19140
URL: https://issues.apache.org/jira/browse/FLINK-19140
Project: Flink
Issue
Myasuka commented on a change in pull request #13179:
URL: https://github.com/apache/flink/pull/13179#discussion_r483451813
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateBackend.java
##
@@ -75,6 +76,13 @@
*/
Stream
flinkbot edited a comment on pull request #13102:
URL: https://github.com/apache/flink/pull/13102#issuecomment-671238228
## CI report:
* aeadd967bd4bdfc0352e79b194da6e0c508cfb96 Azure:
dannycranmer commented on a change in pull request #13102:
URL: https://github.com/apache/flink/pull/13102#discussion_r483515110
##
File path:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyV2.java
##
@@
[
https://issues.apache.org/jira/browse/FLINK-19124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190670#comment-17190670
]
Aljoscha Krettek commented on FLINK-19124:
--
Perfect! I think you can start by removing the
sujun1020 commented on pull request #13306:
URL: https://github.com/apache/flink/pull/13306#issuecomment-687076363
@JingsongLi Thanks for the review. Updated the PR.
This is an automated message from the Apache Git Service.
lirui-apache opened a new pull request #13330:
URL: https://github.com/apache/flink/pull/13330
…distinct agg call in FlinkAggregateExpandDistinctAggregatesRule
## What is the purpose of the change
Fix the issue that Hive `percentile` UDAF cannot be used together with
[
https://issues.apache.org/jira/browse/FLINK-18984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng closed FLINK-18984.
---
Resolution: Resolved
> Add tutorial documentation for Python DataStream API
>
[
https://issues.apache.org/jira/browse/FLINK-18984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17190683#comment-17190683
]
Hequn Cheng commented on FLINK-18984:
-
Resolved in 1.12.0 via
flinkbot edited a comment on pull request #13102:
URL: https://github.com/apache/flink/pull/13102#issuecomment-671238228
## CI report:
* aeadd967bd4bdfc0352e79b194da6e0c508cfb96 Azure:
dianfu commented on a change in pull request #13292:
URL: https://github.com/apache/flink/pull/13292#discussion_r483563989
##
File path: flink-python/pyflink/datastream/stream_execution_environment.py
##
@@ -553,6 +553,33 @@ def set_python_executable(self, python_exec: str):
1 - 100 of 217 matches
Mail list logo
