wangxiyuan closed pull request #23:
URL: https://github.com/apache/flink-docker/pull/23
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 commented on a change in pull request #13181:
URL: https://github.com/apache/flink/pull/13181#discussion_r481794646
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotRequestBulkCheckerImpl.java
##
@@ -0,0 +1,187 @@
+
flinkbot commented on pull request #13301:
URL: https://github.com/apache/flink/pull/13301#issuecomment-685356952
## CI report:
* a5a665a041c0a6c2c017289463e5122f2c8f6282 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
zhijiangW commented on a change in pull request #13286:
URL: https://github.com/apache/flink/pull/13286#discussion_r481793781
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java
##
@@ -366,11 +366,10 @
[
https://issues.apache.org/jira/browse/FLINK-19078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-19078:
---
Component/s: Table SQL / Runtime
> Import rowtime join temporal operator
> -
[
https://issues.apache.org/jira/browse/FLINK-19079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-19079:
---
Component/s: Table SQL / Runtime
> Support row time deduplicate operator
> -
[
https://issues.apache.org/jira/browse/FLINK-19076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-19076:
---
Component/s: Table SQL / Planner
> Import rule to deal Temporal Join condition
> ---
[
https://issues.apache.org/jira/browse/FLINK-19077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-19077:
---
Component/s: Table SQL / Runtime
> Import process time temporal join operator
>
[
https://issues.apache.org/jira/browse/FLINK-19072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-19072:
---
Component/s: Table SQL / Planner
> Import Temporal Table join rule
> ---
[
https://issues.apache.org/jira/browse/FLINK-19073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-19073:
---
Component/s: Table SQL / Planner
> Improve streamExecTemporalJoinRule
>
senegalo commented on pull request #12056:
URL: https://github.com/apache/flink/pull/12056#issuecomment-685341691
@austince @dawidwys
Hey guys,
Finally got around doing the changes you suggested.
Now we do have a reset message "that was obviously needed for some reason i
thoug
flinkbot edited a comment on pull request #12056:
URL: https://github.com/apache/flink/pull/12056#issuecomment-626167900
## CI report:
* c42ef1f62396948ece865a3b8628bea229d5ffb9 UNKNOWN
* b58ab30b48a7405840656ebc26ce55fad7473497 Azure:
[FAILURE](https://dev.azure.com/apache-fl
flinkbot commented on pull request #13301:
URL: https://github.com/apache/flink/pull/13301#issuecomment-685329829
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 pro
[
https://issues.apache.org/jira/browse/FLINK-16528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17189016#comment-17189016
]
Danny Chen commented on FLINK-16528:
What is the semantics that for an unbounded str
[
https://issues.apache.org/jira/browse/FLINK-19121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19121:
---
Labels: pull-request-available (was: )
> Avoid accessing HDFS frequently in HiveBulkWriterF
JingsongLi opened a new pull request #13301:
URL: https://github.com/apache/flink/pull/13301
## What is the purpose of the change
In HadoopPathBasedBulkWriter, getSize will invoke `FileSystem.exists` and
`FileSystem.getFileStatus`, but it is invoked per record.
There will be l
[
https://issues.apache.org/jira/browse/FLINK-19121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-19121:
-
Fix Version/s: 1.11.2
> Avoid accessing HDFS frequently in HiveBulkWriterFactory
> -
[
https://issues.apache.org/jira/browse/FLINK-19121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-19121:
Assignee: Jingsong Lee
> Avoid accessing HDFS frequently in HiveBulkWriterFactory
> -
[
https://issues.apache.org/jira/browse/FLINK-19121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-19121:
-
Summary: Avoid accessing HDFS frequently in HiveBulkWriterFactory (was:
Avoid accessing HDFS in
[
https://issues.apache.org/jira/browse/FLINK-19121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-19121:
-
Summary: Avoid accessing HDFS in HiveBulkWriterFactory (was: Avoid access
HDFS in HiveBulkWrite
[
https://issues.apache.org/jira/browse/FLINK-19115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17189012#comment-17189012
]
McClone commented on FLINK-19115:
-
CREATE TEMPORARY FUNCTION UdfPrimaryKey as
'com.gala
carp84 commented on pull request #131:
URL: https://github.com/apache/flink-statefun/pull/131#issuecomment-685325397
@klion26 it would be great if you could also give some suggestions about
translation specification here with your experience, thanks!
--
flinkbot edited a comment on pull request #13284:
URL: https://github.com/apache/flink/pull/13284#issuecomment-683683000
## CI report:
* 609881d969a4c1e6124ed51297cb82db3654 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-19112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17189006#comment-17189006
]
Jark Wu commented on FLINK-19112:
-
I think we can have a mock MetricGroup (maybe {{Unreg
[
https://issues.apache.org/jira/browse/FLINK-19121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-19121:
-
Issue Type: Bug (was: New Feature)
> Avoid access HDFS in HiveBulkWriterFactory
> -
Jingsong Lee created FLINK-19121:
Summary: Avoid access HDFS in HiveBulkWriterFactory
Key: FLINK-19121
URL: https://issues.apache.org/jira/browse/FLINK-19121
Project: Flink
Issue Type: New Fe
[
https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17189005#comment-17189005
]
Robert Metzger commented on FLINK-19064:
Why can't we open the connection in the
[
https://issues.apache.org/jira/browse/FLINK-19115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17189003#comment-17189003
]
Jark Wu commented on FLINK-19115:
-
Could you provide a program or SQL to which can repro
[
https://issues.apache.org/jira/browse/FLINK-19120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-19120.
---
Resolution: Invalid
> Failed to build Flink with HBase2.1 even using the latest Flink release
> version.
>
wuchong commented on pull request #13128:
URL: https://github.com/apache/flink/pull/13128#issuecomment-685316937
Would be great if @leonardBang can also help to review this.
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-19120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17189000#comment-17189000
]
Jark Wu commented on FLINK-19120:
-
You can't simply change the HBase version in the pom.
[
https://issues.apache.org/jira/browse/FLINK-19118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-19118:
---
Assignee: Dian Fu
> Support Expression in the operations of the Python Table API
>
[
https://issues.apache.org/jira/browse/FLINK-19115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188999#comment-17188999
]
McClone commented on FLINK-19115:
-
Why does elasticsearch connector have a large number
[
https://issues.apache.org/jira/browse/FLINK-19115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188997#comment-17188997
]
McClone commented on FLINK-19115:
-
When writing data from Kafka to elasticsearch, the ta
[
https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188996#comment-17188996
]
Nicholas Jiang commented on FLINK-19064:
Yeah, I agree with [~jark]. From my per
flinkbot edited a comment on pull request #13284:
URL: https://github.com/apache/flink/pull/13284#issuecomment-683683000
## CI report:
* 609881d969a4c1e6124ed51297cb82db3654 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
SteNicholas commented on pull request #13298:
URL: https://github.com/apache/flink/pull/13298#issuecomment-685310268
@twalthr @dawidwys Could you please review this pull request? The current
behavior of SortOperationFactory are familiar to you. Thanks.
SteNicholas removed a comment on pull request #13298:
URL: https://github.com/apache/flink/pull/13298#issuecomment-684831209
@twalthr @dawidwys Could you please review this pull request? The current
behavior of SortOperationFactory are familiar to you. Thanks.
klion26 commented on a change in pull request #13225:
URL: https://github.com/apache/flink/pull/13225#discussion_r481720837
##
File path: docs/dev/user_defined_functions.zh.md
##
@@ -147,95 +153,78 @@ data.map (new RichMapFunction[String, Int] {
-Rich functions provide, i
flinkbot edited a comment on pull request #13278:
URL: https://github.com/apache/flink/pull/13278#issuecomment-683294857
## CI report:
* ca0216692b0b058bd5cbe6a1a6b3f345feba3def UNKNOWN
* 07555378e406748f3e74624f23828f022ca8dbbe Azure:
[SUCCESS](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #13230:
URL: https://github.com/apache/flink/pull/13230#issuecomment-679164841
## CI report:
* 86c48415d9aace2a986d704154f1f26af3fe2cc1 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-19115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188981#comment-17188981
]
Fin-chan commented on FLINK-19115:
--
Do you show the example to explain the error?
> Nu
flinkbot edited a comment on pull request #13300:
URL: https://github.com/apache/flink/pull/13300#issuecomment-684957567
## CI report:
* 4f62c8cfc30654a7236e45b48a5846267897ba3a Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13232:
URL: https://github.com/apache/flink/pull/13232#issuecomment-679225070
## CI report:
* 99c5a7392b35bef45802cee74c59667e64e8f239 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13300:
URL: https://github.com/apache/flink/pull/13300#issuecomment-684957567
## CI report:
* 5364e729bdaebcd72a915b086a8a17284316c3f8 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13299:
URL: https://github.com/apache/flink/pull/13299#issuecomment-684842866
## CI report:
* 2ed16425d7018bbb39be1edd6519fcb99cb45000 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13300:
URL: https://github.com/apache/flink/pull/13300#issuecomment-684957567
## CI report:
* 5364e729bdaebcd72a915b086a8a17284316c3f8 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13299:
URL: https://github.com/apache/flink/pull/13299#issuecomment-684842866
## CI report:
* 2ed16425d7018bbb39be1edd6519fcb99cb45000 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13278:
URL: https://github.com/apache/flink/pull/13278#issuecomment-683294857
## CI report:
* ca0216692b0b058bd5cbe6a1a6b3f345feba3def UNKNOWN
* 07555378e406748f3e74624f23828f022ca8dbbe Azure:
[SUCCESS](https://dev.azure.com/apache-fl
[
https://issues.apache.org/jira/browse/FLINK-18852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-18852.
---
Fix Version/s: 1.12.0
Resolution: Fixed
Fixed in master (1.12.0): fccf7ee03b3653fc91ef49d023bc2e316f2
wuchong merged pull request #13141:
URL: https://github.com/apache/flink/pull/13141
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
wuchong commented on pull request #13141:
URL: https://github.com/apache/flink/pull/13141#issuecomment-685287870
Merging...
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-18801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-18801:
Component/s: Documentation
API / Python
> Add a "10 minutes to Table API" document under
[
https://issues.apache.org/jira/browse/FLINK-18801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-18801.
---
Fix Version/s: 1.11.2
1.12.0
Resolution: Fixed
master: 5350bca7f9c18213d2538f60146
flinkbot edited a comment on pull request #13298:
URL: https://github.com/apache/flink/pull/13298#issuecomment-684842719
## CI report:
* 473240883e0205c9b477ef761c7d18222aa579d1 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-17779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188962#comment-17188962
]
Jingsong Lee commented on FLINK-17779:
--
[~sujun1020] Assigned to you~
> Orc file f
[
https://issues.apache.org/jira/browse/FLINK-17779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-17779:
Assignee: sujun
> Orc file format support filter push down
>
leonardBang commented on pull request #13283:
URL: https://github.com/apache/flink/pull/13283#issuecomment-685278264
cc @godfreyhe could you help review this pr?
This is an automated message from the Apache Git Service.
To re
[
https://issues.apache.org/jira/browse/FLINK-17779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sujun updated FLINK-17779:
--
Attachment: (was: image-2020-09-02-11-39-27-587.png)
> Orc file format support filter push down
>
flinkbot edited a comment on pull request #13230:
URL: https://github.com/apache/flink/pull/13230#issuecomment-679164841
## CI report:
* be7e79cede81890f324a979b49651e401dcc329a Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13230:
URL: https://github.com/apache/flink/pull/13230#issuecomment-679164841
## CI report:
* be7e79cede81890f324a979b49651e401dcc329a Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
WeiZhong94 commented on a change in pull request #13278:
URL: https://github.com/apache/flink/pull/13278#discussion_r481595190
##
File path: flink-python/pyflink/table/expressions.py
##
@@ -0,0 +1,543 @@
+#
[
https://issues.apache.org/jira/browse/FLINK-17779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188955#comment-17188955
]
sujun commented on FLINK-17779:
---
hi [~lzljs3620320] , If no one is paying attention to thi
[
https://issues.apache.org/jira/browse/FLINK-17779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sujun updated FLINK-17779:
--
Attachment: image-2020-09-02-11-39-27-587.png
> Orc file format support filter push down
> ---
flinkbot edited a comment on pull request #13232:
URL: https://github.com/apache/flink/pull/13232#issuecomment-679225070
## CI report:
* dd7743539c7ed5c45d93fc8b3c12e2db8b7af65e Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-16905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-16905:
Parent: FLINK-19091
Issue Type: Sub-task (was: Bug)
> Add fromValues in Python API
>
[
https://issues.apache.org/jira/browse/FLINK-16905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-16905:
Parent: (was: FLINK-11890)
Issue Type: Bug (was: Sub-task)
> Add fromValues in Python API
> -
shuiqiangchen commented on pull request #13230:
URL: https://github.com/apache/flink/pull/13230#issuecomment-685262361
@HuangXingBo Thank you for your comments, I have updated the PR, please have
a look at it.
This is an aut
Tang Yan created FLINK-19120:
Summary: Failed to build Flink with HBase2.1 even using the latest
Flink release version.
Key: FLINK-19120
URL: https://issues.apache.org/jira/browse/FLINK-19120
Project: Fli
shuiqiangchen commented on pull request #13232:
URL: https://github.com/apache/flink/pull/13232#issuecomment-685259439
Hi @HuangXingBo , highly appreciate for your suggestions, I have updated the
PR, please have a look at it.
---
flinkbot edited a comment on pull request #13278:
URL: https://github.com/apache/flink/pull/13278#issuecomment-683294857
## CI report:
* ca0216692b0b058bd5cbe6a1a6b3f345feba3def UNKNOWN
* 07555378e406748f3e74624f23828f022ca8dbbe Azure:
[SUCCESS](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #13292:
URL: https://github.com/apache/flink/pull/13292#issuecomment-684516974
## CI report:
* 81162c9ed4c9b178e093393cf88e2d16709553de Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13245:
URL: https://github.com/apache/flink/pull/13245#issuecomment-680688340
## CI report:
* e46b2611459d09da2c220cb3fe2e8658c930a78f Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-17912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188942#comment-17188942
]
Dian Fu commented on FLINK-17912:
-
Another instance on 1.11:
[https://dev.azure.com/apa
[
https://issues.apache.org/jira/browse/FLINK-19091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-19091:
Labels: (was: pull-request-available)
> Introduce expression DSL for Python Table API
>
flinkbot edited a comment on pull request #13292:
URL: https://github.com/apache/flink/pull/13292#issuecomment-684516974
## CI report:
* 81162c9ed4c9b178e093393cf88e2d16709553de Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-15981:
-
Affects Version/s: 1.10.1
1.11.0
1.10.2
dianfu closed pull request #13273:
URL: https://github.com/apache/flink/pull/13273
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 t
dianfu commented on pull request #13278:
URL: https://github.com/apache/flink/pull/13278#issuecomment-685248357
@WeiZhong94 Thanks a lot for the review. Updated the PR. Could you take a
further look at of the PR?
This is an
[
https://issues.apache.org/jira/browse/FLINK-12884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-12884:
Assignee: Yang Wang (was: MalcolmSanders)
> Implement HighAvailabilityService based on n
[
https://issues.apache.org/jira/browse/FLINK-12884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188936#comment-17188936
]
Yang Wang commented on FLINK-12884:
---
Since [~ssy] is occupied by some other things, i
shuiqiangchen commented on pull request #13292:
URL: https://github.com/apache/flink/pull/13292#issuecomment-685244943
Hi @HuangXingBo , thanks for your comments, I have updated the PR according
to your suggestions, please have look at it.
-
Dian Fu created FLINK-19119:
---
Summary: Update the documentation to use Expression instead of
strings in the Python Table API
Key: FLINK-19119
URL: https://issues.apache.org/jira/browse/FLINK-19119
Project:
leonardBang edited a comment on pull request #13245:
URL: https://github.com/apache/flink/pull/13245#issuecomment-685239670
> LGTM. It could be worth to mention in the documentation that when
**scan.query** is present then **table-name** is ignored
Thanks @fpompermaier for the review
[
https://issues.apache.org/jira/browse/FLINK-19117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188927#comment-17188927
]
Xintong Song edited comment on FLINK-19117 at 9/2/20, 2:07 AM:
---
Dian Fu created FLINK-19118:
---
Summary: Support Expression in the operations of the Python Table
API
Key: FLINK-19118
URL: https://issues.apache.org/jira/browse/FLINK-19118
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-19117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-19117.
Resolution: Not A Problem
Sorry, mis-operation.
> FLINK-18620
> ---
>
> K
leonardBang commented on pull request #13245:
URL: https://github.com/apache/flink/pull/13245#issuecomment-685239670
> LGTM. It could be worth to mention in the documentation that when
**scan.query** is present then **table-name** is ignored
Thanks @fpompermaier for the review very m
Xintong Song created FLINK-19117:
Summary: FLINK-18620
Key: FLINK-19117
URL: https://issues.apache.org/jira/browse/FLINK-19117
Project: Flink
Issue Type: Improvement
Reporter: Xin
[
https://issues.apache.org/jira/browse/FLINK-19091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19091:
---
Labels: pull-request-available (was: )
> Introduce expression DSL for Python Table API
> --
dianfu commented on a change in pull request #13278:
URL: https://github.com/apache/flink/pull/13278#discussion_r481549748
##
File path: flink-python/pyflink/table/expressions.py
##
@@ -0,0 +1,535 @@
+#
McClone created FLINK-19115:
---
Summary: Null value fields cannot be ignored in ElasticSearch Sink
Key: FLINK-19115
URL: https://issues.apache.org/jira/browse/FLINK-19115
Project: Flink
Issue Type: B
Dian Fu created FLINK-19116:
---
Summary: Support more kinds of data for expressions.lit in the
Python Table API
Key: FLINK-19116
URL: https://issues.apache.org/jira/browse/FLINK-19116
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-15974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-15974:
Parent: FLINK-19091
Issue Type: Sub-task (was: Improvement)
> Support to use the Python UDF direc
[
https://issues.apache.org/jira/browse/FLINK-18225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-18225.
---
Resolution: Duplicate
> Add collect method in the Python TableResult
> -
[
https://issues.apache.org/jira/browse/FLINK-18225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-18225:
Fix Version/s: (was: 1.12.0)
> Add collect method in the Python TableResult
>
[
https://issues.apache.org/jira/browse/FLINK-19091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-19091:
Labels: (was: pull-request-available)
> Introduce expression DSL for Python Table API
>
[
https://issues.apache.org/jira/browse/FLINK-19114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-19114:
Labels: pull-request-available (was: )
> Introduce Expression class in the Python Table API
> ---
[
https://issues.apache.org/jira/browse/FLINK-19114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-19114:
Attachment: (was: image-2020-09-02-09-51-07-798.png)
> Introduce Expression class in the Python Table
Dian Fu created FLINK-19114:
---
Summary: Introduce Expression class in the Python Table API
Key: FLINK-19114
URL: https://issues.apache.org/jira/browse/FLINK-19114
Project: Flink
Issue Type: Sub-task
1 - 100 of 388 matches
Mail list logo
