[jira] [Commented] (FLINK-19112) No access to metric group in ScalarFunction when optimizing

2020-09-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189006#comment-17189006 ] Jark Wu commented on FLINK-19112: - I think we can have a mock MetricGroup (maybe

[jira] [Updated] (FLINK-19121) Avoid access HDFS in HiveBulkWriterFactory

2020-09-01 Thread Jingsong Lee (Jira)
[ 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 >

[jira] [Created] (FLINK-19121) Avoid access HDFS in HiveBulkWriterFactory

2020-09-01 Thread Jingsong Lee (Jira)
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

[jira] [Commented] (FLINK-19064) HBaseRowDataInputFormat is leaking resources

2020-09-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189005#comment-17189005 ] Robert Metzger commented on FLINK-19064: Why can't we open the connection in the {{open()}}

[jira] [Commented] (FLINK-19115) Null value fields cannot be ignored in ElasticSearch Sink

2020-09-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189003#comment-17189003 ] Jark Wu commented on FLINK-19115: - Could you provide a program or SQL to which can reproduce this

[jira] [Closed] (FLINK-19120) Failed to build Flink with HBase2.1 even using the latest Flink release version.

2020-09-01 Thread Jark Wu (Jira)
[ 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. >

[GitHub] [flink] wuchong commented on pull request #13128: [FLINK-18795][hbase] Support for HBase 2

2020-09-01 Thread GitBox
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

[jira] [Commented] (FLINK-19120) Failed to build Flink with HBase2.1 even using the latest Flink release version.

2020-09-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189000#comment-17189000 ] Jark Wu commented on FLINK-19120: - You can't simply change the HBase version in the pom.xml, because

[jira] [Assigned] (FLINK-19118) Support Expression in the operations of the Python Table API

2020-09-01 Thread Dian Fu (Jira)
[ 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 >

[jira] [Commented] (FLINK-19115) Null value fields cannot be ignored in ElasticSearch Sink

2020-09-01 Thread McClone (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17188999#comment-17188999 ] McClone commented on FLINK-19115: - Why does elasticsearch connector have a large number of class with

[jira] [Commented] (FLINK-19115) Null value fields cannot be ignored in ElasticSearch Sink

2020-09-01 Thread McClone (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17188997#comment-17188997 ] McClone commented on FLINK-19115: - When writing data from Kafka to elasticsearch, the table defines four

[jira] [Commented] (FLINK-19064) HBaseRowDataInputFormat is leaking resources

2020-09-01 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17188996#comment-17188996 ] Nicholas Jiang commented on FLINK-19064: Yeah, I agree with [~jark]. From my perspective, set

[GitHub] [flink] flinkbot edited a comment on pull request #13284: [FLINK-17016][runtime] Change blink planner batch jobs to run with pipelined region scheduling

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13284: URL: https://github.com/apache/flink/pull/13284#issuecomment-683683000 ## CI report: * 609881d969a4c1e6124ed51297cb82db3654 Azure:

[GitHub] [flink] SteNicholas commented on pull request #13298: [FLINK-19038][table] It doesn't support to call Table.limit() continuously

2020-09-01 Thread GitBox
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.

[GitHub] [flink] SteNicholas removed a comment on pull request #13298: [FLINK-19038][table] It doesn't support to call Table.limit() continuously

2020-09-01 Thread GitBox
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.

[GitHub] [flink] klion26 commented on a change in pull request #13225: [FLINK-18974][docs-zh]Translate the 'User-Defined Functions' page of "Application Development's DataStream API" into Chinese

2020-09-01 Thread GitBox
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,

[GitHub] [flink] flinkbot edited a comment on pull request #13278: [FLINK-19114][python] Introduce expression DSL for Python Table API

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13278: URL: https://github.com/apache/flink/pull/13278#issuecomment-683294857 ## CI report: * ca0216692b0b058bd5cbe6a1a6b3f345feba3def UNKNOWN * 07555378e406748f3e74624f23828f022ca8dbbe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13230: [FLINK-18950][python][docs] Add documentation for Operations in Python DataStream API.

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13230: URL: https://github.com/apache/flink/pull/13230#issuecomment-679164841 ## CI report: * 86c48415d9aace2a986d704154f1f26af3fe2cc1 Azure:

[jira] [Commented] (FLINK-19115) Null value fields cannot be ignored in ElasticSearch Sink

2020-09-01 Thread Fin-chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17188981#comment-17188981 ] Fin-chan commented on FLINK-19115: -- Do you show the example to explain the error? > Null value fields

[GitHub] [flink] flinkbot edited a comment on pull request #13300: [FLINK-19077][table-runtime] Import process time temporal join operator.

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13300: URL: https://github.com/apache/flink/pull/13300#issuecomment-684957567 ## CI report: * 4f62c8cfc30654a7236e45b48a5846267897ba3a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13232: [FLINK-18951][python][docs] Add documentation for Configurations in Python DataStream API.

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13232: URL: https://github.com/apache/flink/pull/13232#issuecomment-679225070 ## CI report: * 99c5a7392b35bef45802cee74c59667e64e8f239 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13300: [FLINK-19077][table-runtime] Import process time temporal join operator.

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13300: URL: https://github.com/apache/flink/pull/13300#issuecomment-684957567 ## CI report: * 5364e729bdaebcd72a915b086a8a17284316c3f8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13299: [FLINK-19072][table-planner] Import Temporal Table join rule

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13299: URL: https://github.com/apache/flink/pull/13299#issuecomment-684842866 ## CI report: * 2ed16425d7018bbb39be1edd6519fcb99cb45000 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13300: [FLINK-19077][table-runtime] Import process time temporal join operator.

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13300: URL: https://github.com/apache/flink/pull/13300#issuecomment-684957567 ## CI report: * 5364e729bdaebcd72a915b086a8a17284316c3f8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13299: [FLINK-19072][table-planner] Import Temporal Table join rule

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13299: URL: https://github.com/apache/flink/pull/13299#issuecomment-684842866 ## CI report: * 2ed16425d7018bbb39be1edd6519fcb99cb45000 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13278: [FLINK-19114][python] Introduce expression DSL for Python Table API

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13278: URL: https://github.com/apache/flink/pull/13278#issuecomment-683294857 ## CI report: * ca0216692b0b058bd5cbe6a1a6b3f345feba3def UNKNOWN * 07555378e406748f3e74624f23828f022ca8dbbe Azure:

[jira] [Closed] (FLINK-18852) StreamScan should keep the same parallelism as the input

2020-09-01 Thread Jark Wu (Jira)
[ 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):

[GitHub] [flink] wuchong merged pull request #13141: [FLINK-18852] Fix StreamScan doesn't inherit parallelism from input in legacy planner

2020-09-01 Thread GitBox
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

[GitHub] [flink] wuchong commented on pull request #13141: [FLINK-18852] Fix StreamScan doesn't inherit parallelism from input in legacy planner

2020-09-01 Thread GitBox
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

[jira] [Updated] (FLINK-18801) Add a "10 minutes to Table API" document under the "Python API" -> "User Guide" -> "Table API" section

2020-09-01 Thread Dian Fu (Jira)
[ 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

[jira] [Closed] (FLINK-18801) Add a "10 minutes to Table API" document under the "Python API" -> "User Guide" -> "Table API" section

2020-09-01 Thread Dian Fu (Jira)
[ 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: 

[GitHub] [flink] flinkbot edited a comment on pull request #13298: [FLINK-19038][table] It doesn't support to call Table.limit() continuously

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13298: URL: https://github.com/apache/flink/pull/13298#issuecomment-684842719 ## CI report: * 473240883e0205c9b477ef761c7d18222aa579d1 Azure:

[jira] [Commented] (FLINK-17779) Orc file format support filter push down

2020-09-01 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17188962#comment-17188962 ] Jingsong Lee commented on FLINK-17779: -- [~sujun1020] Assigned to you~ > Orc file format support

[jira] [Assigned] (FLINK-17779) Orc file format support filter push down

2020-09-01 Thread Jingsong Lee (Jira)
[ 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 >

[GitHub] [flink] leonardBang commented on pull request #13283: [FLINK-18759][tests] Add readme.md for TPC-DS tools

2020-09-01 Thread GitBox
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

[jira] [Updated] (FLINK-17779) Orc file format support filter push down

2020-09-01 Thread sujun (Jira)
[ 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 >

[GitHub] [flink] flinkbot edited a comment on pull request #13230: [FLINK-18950][python][docs] Add documentation for Operations in Python DataStream API.

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13230: URL: https://github.com/apache/flink/pull/13230#issuecomment-679164841 ## CI report: * be7e79cede81890f324a979b49651e401dcc329a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13230: [FLINK-18950][python][docs] Add documentation for Operations in Python DataStream API.

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13230: URL: https://github.com/apache/flink/pull/13230#issuecomment-679164841 ## CI report: * be7e79cede81890f324a979b49651e401dcc329a Azure:

[GitHub] [flink] WeiZhong94 commented on a change in pull request #13278: [FLINK-19114][python] Introduce expression DSL for Python Table API

2020-09-01 Thread GitBox
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 @@

[jira] [Commented] (FLINK-17779) Orc file format support filter push down

2020-09-01 Thread sujun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17188955#comment-17188955 ] sujun commented on FLINK-17779: --- hi [~lzljs3620320] , If no one is paying attention to this issue, I can

[jira] [Updated] (FLINK-17779) Orc file format support filter push down

2020-09-01 Thread sujun (Jira)
[ 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 >

[GitHub] [flink] flinkbot edited a comment on pull request #13232: [FLINK-18951][python][docs] Add documentation for Configurations in Python DataStream API.

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13232: URL: https://github.com/apache/flink/pull/13232#issuecomment-679225070 ## CI report: * dd7743539c7ed5c45d93fc8b3c12e2db8b7af65e Azure:

[jira] [Updated] (FLINK-16905) Add fromValues in Python API

2020-09-01 Thread Dian Fu (Jira)
[ 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 >

[jira] [Updated] (FLINK-16905) Add fromValues in Python API

2020-09-01 Thread Dian Fu (Jira)
[ 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 >

[GitHub] [flink] shuiqiangchen commented on pull request #13230: [FLINK-18950][python][docs] Add documentation for Operations in Python DataStream API.

2020-09-01 Thread GitBox
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

[jira] [Created] (FLINK-19120) Failed to build Flink with HBase2.1 even using the latest Flink release version.

2020-09-01 Thread Tang Yan (Jira)
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:

[GitHub] [flink] shuiqiangchen commented on pull request #13232: [FLINK-18951][python][docs] Add documentation for Configurations in Python DataStream API.

2020-09-01 Thread GitBox
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.

[GitHub] [flink] flinkbot edited a comment on pull request #13278: [FLINK-19114][python] Introduce expression DSL for Python Table API

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13278: URL: https://github.com/apache/flink/pull/13278#issuecomment-683294857 ## CI report: * ca0216692b0b058bd5cbe6a1a6b3f345feba3def UNKNOWN * 07555378e406748f3e74624f23828f022ca8dbbe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13292: [FLINK-19097][python] Support add_jars() for Python StreamExecutionEnvironment.

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13292: URL: https://github.com/apache/flink/pull/13292#issuecomment-684516974 ## CI report: * 81162c9ed4c9b178e093393cf88e2d16709553de Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13245: [FLINK-17826][jdbc] Add missing custom query support on new jdbc connector

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13245: URL: https://github.com/apache/flink/pull/13245#issuecomment-680688340 ## CI report: * e46b2611459d09da2c220cb3fe2e8658c930a78f Azure:

[jira] [Commented] (FLINK-17912) KafkaShuffleITCase.testAssignedToPartitionEventTime: "Watermark should always increase"

2020-09-01 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17188942#comment-17188942 ] Dian Fu commented on FLINK-17912: - Another instance on 1.11: 

[jira] [Updated] (FLINK-19091) Introduce expression DSL for Python Table API

2020-09-01 Thread Dian Fu (Jira)
[ 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 >

[GitHub] [flink] flinkbot edited a comment on pull request #13292: [FLINK-19097][python] Support add_jars() for Python StreamExecutionEnvironment.

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13292: URL: https://github.com/apache/flink/pull/13292#issuecomment-684516974 ## CI report: * 81162c9ed4c9b178e093393cf88e2d16709553de Azure:

[jira] [Updated] (FLINK-15981) Control the direct memory in FileChannelBoundedData.FileBufferReader

2020-09-01 Thread Zhijiang (Jira)
[ 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

[GitHub] [flink] dianfu closed pull request #13273: [FLINK-18801][docs][python] Add a "10 minutes to Table API" document under the "Python API" -> "User Guide" -> "Table API" section.

2020-09-01 Thread GitBox
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

[GitHub] [flink] dianfu commented on pull request #13278: [FLINK-19091][python] Introduce expression DSL for Python Table API

2020-09-01 Thread GitBox
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

[jira] [Assigned] (FLINK-12884) Implement HighAvailabilityService based on native k8s APIs

2020-09-01 Thread Xintong Song (Jira)
[ 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

[jira] [Commented] (FLINK-12884) Implement HighAvailabilityService based on native k8s APIs

2020-09-01 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17188936#comment-17188936 ] Yang Wang commented on FLINK-12884: --- Since [~ssy] is occupied by some other things, i will take over

[GitHub] [flink] shuiqiangchen commented on pull request #13292: [FLINK-19097][python] Support add_jars() for Python StreamExecutionEnvironment.

2020-09-01 Thread GitBox
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.

[jira] [Created] (FLINK-19119) Update the documentation to use Expression instead of strings in the Python Table API

2020-09-01 Thread Dian Fu (Jira)
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:

[GitHub] [flink] leonardBang edited a comment on pull request #13245: [FLINK-17826][jdbc] Add missing custom query support on new jdbc connector

2020-09-01 Thread GitBox
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

[jira] [Comment Edited] (FLINK-19117) FLINK-18620

2020-09-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17188927#comment-17188927 ] Xintong Song edited comment on FLINK-19117 at 9/2/20, 2:07 AM: --- Sorry,

[jira] [Created] (FLINK-19118) Support Expression in the operations of the Python Table API

2020-09-01 Thread Dian Fu (Jira)
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

[jira] [Closed] (FLINK-19117) FLINK-18620

2020-09-01 Thread Xintong Song (Jira)
[ 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 > --- > >

[GitHub] [flink] leonardBang commented on pull request #13245: [FLINK-17826][jdbc] Add missing custom query support on new jdbc connector

2020-09-01 Thread GitBox
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

[jira] [Created] (FLINK-19117) FLINK-18620

2020-09-01 Thread Xintong Song (Jira)
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:

[jira] [Updated] (FLINK-19091) Introduce expression DSL for Python Table API

2020-09-01 Thread ASF GitHub Bot (Jira)
[ 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 >

[GitHub] [flink] dianfu commented on a change in pull request #13278: [FLINK-19091][python] Introduce expression DSL for Python Table API

2020-09-01 Thread GitBox
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 @@

[jira] [Created] (FLINK-19115) Null value fields cannot be ignored in ElasticSearch Sink

2020-09-01 Thread McClone (Jira)
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:

[jira] [Created] (FLINK-19116) Support more kinds of data for expressions.lit in the Python Table API

2020-09-01 Thread Dian Fu (Jira)
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

[jira] [Updated] (FLINK-15974) Support to use the Python UDF directly in the Python Table API

2020-09-01 Thread Dian Fu (Jira)
[ 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

[jira] [Closed] (FLINK-18225) Add collect method in the Python TableResult

2020-09-01 Thread Dian Fu (Jira)
[ 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 >

[jira] [Updated] (FLINK-18225) Add collect method in the Python TableResult

2020-09-01 Thread Dian Fu (Jira)
[ 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 >

[jira] [Updated] (FLINK-19091) Introduce expression DSL for Python Table API

2020-09-01 Thread Dian Fu (Jira)
[ 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 >

[jira] [Updated] (FLINK-19114) Introduce Expression class in the Python Table API

2020-09-01 Thread Dian Fu (Jira)
[ 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 >

[jira] [Updated] (FLINK-19114) Introduce Expression class in the Python Table API

2020-09-01 Thread Dian Fu (Jira)
[ 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

[jira] [Created] (FLINK-19114) Introduce Expression class in the Python Table API

2020-09-01 Thread Dian Fu (Jira)
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:

[jira] [Updated] (FLINK-19114) Introduce Expression class in the Python Table API

2020-09-01 Thread Dian Fu (Jira)
[ 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-06-754.png) > Introduce Expression class in the Python Table

[GitHub] [flink] shuiqiangchen commented on a change in pull request #13292: [FLINK-19097][python] Support add_jars() for Python StreamExecutionEnvironment.

2020-09-01 Thread GitBox
shuiqiangchen commented on a change in pull request #13292: URL: https://github.com/apache/flink/pull/13292#discussion_r481534628 ## File path: flink-python/pyflink/datastream/stream_execution_environment.py ## @@ -553,6 +553,29 @@ def set_python_executable(self, python_exec:

[GitHub] [flink] flinkbot edited a comment on pull request #13298: [FLINK-19038][table] It doesn't support to call Table.limit() continuously

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13298: URL: https://github.com/apache/flink/pull/13298#issuecomment-684842719 ## CI report: * 9d970723507b6e5dbacca3fd4f8ff9dfcae4a2b3 Azure:

[jira] [Comment Edited] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

2020-09-01 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1717#comment-1717 ] Liu edited comment on FLINK-18959 at 9/2/20, 12:36 AM: --- Hi, [~trohrmann] and

[jira] [Comment Edited] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

2020-09-01 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1717#comment-1717 ] Liu edited comment on FLINK-18959 at 9/2/20, 12:34 AM: --- Hi, [~trohrmann] and

[jira] [Commented] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

2020-09-01 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1717#comment-1717 ] Liu commented on FLINK-18959: - Hi, [~trohrmann] and [~aljoscha]. If we just revert the {{MiniDispatcher}} 

[GitHub] [flink] flinkbot edited a comment on pull request #13298: [FLINK-19038][table] It doesn't support to call Table.limit() continuously

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13298: URL: https://github.com/apache/flink/pull/13298#issuecomment-684842719 ## CI report: * 9d970723507b6e5dbacca3fd4f8ff9dfcae4a2b3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13179: [FLINK-18978][state-backends] Support full table scan of key and namespace from statebackend

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13179: URL: https://github.com/apache/flink/pull/13179#issuecomment-674957571 ## CI report: * f40dd9a3869f93be6185b98518b035548e42180e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13249: [FLINK-14087][datastream] Clone the StreamPartitioner to avoid being shared at runtime.

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13249: URL: https://github.com/apache/flink/pull/13249#issuecomment-680775587 ## CI report: * dac56bd078915f2b86835cf5e8cdba3233ee834f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13284: [FLINK-17016][runtime] Change blink planner batch jobs to run with pipelined region scheduling

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13284: URL: https://github.com/apache/flink/pull/13284#issuecomment-683683000 ## CI report: * 609881d969a4c1e6124ed51297cb82db3654 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13278: [FLINK-19091][python] Introduce expression DSL for Python Table API

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13278: URL: https://github.com/apache/flink/pull/13278#issuecomment-683294857 ## CI report: * ca0216692b0b058bd5cbe6a1a6b3f345feba3def UNKNOWN * 07555378e406748f3e74624f23828f022ca8dbbe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13179: [FLINK-18978][state-backends] Support full table scan of key and namespace from statebackend

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13179: URL: https://github.com/apache/flink/pull/13179#issuecomment-674957571 ## CI report: * 04d5121a5f791efa1ae549ced4bd21e8b36bf19b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13179: [FLINK-18978][state-backends] Support full table scan of key and namespace from statebackend

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13179: URL: https://github.com/apache/flink/pull/13179#issuecomment-674957571 ## CI report: * 04d5121a5f791efa1ae549ced4bd21e8b36bf19b Azure:

[GitHub] [flink-statefun] billyrrr commented on a change in pull request #131: [FLINK-18968] Translate README.md to Chinese

2020-09-01 Thread GitBox
billyrrr commented on a change in pull request #131: URL: https://github.com/apache/flink-statefun/pull/131#discussion_r481413440 ## File path: README.zh.md ## @@ -0,0 +1,228 @@ + + +有状态函数是一个[Apache Flink](https://flink.apache.org/)库, __可简化构建分布式有状态应用程序的过程__

[GitHub] [flink] sjwiesman commented on pull request #13179: [FLINK-18978][state-backends] Support full table scan of key and namespace from statebackend

2020-09-01 Thread GitBox
sjwiesman commented on pull request #13179: URL: https://github.com/apache/flink/pull/13179#issuecomment-685113187 fixed the license issue, sorry about that. This is an automated message from the Apache Git Service. To

[GitHub] [flink-statefun] billyrrr commented on a change in pull request #131: [FLINK-18968] Translate README.md to Chinese

2020-09-01 Thread GitBox
billyrrr commented on a change in pull request #131: URL: https://github.com/apache/flink-statefun/pull/131#discussion_r481411318 ## File path: README.zh.md ## @@ -0,0 +1,228 @@ + + +有状态函数是一个[Apache Flink](https://flink.apache.org/)库, __可简化构建分布式有状态应用程序的过程__

[GitHub] [flink-statefun] billyrrr commented on a change in pull request #131: [FLINK-18968] Translate README.md to Chinese

2020-09-01 Thread GitBox
billyrrr commented on a change in pull request #131: URL: https://github.com/apache/flink-statefun/pull/131#discussion_r481405533 ## File path: README.zh.md ## @@ -0,0 +1,228 @@ + + +有状态函数是一个[Apache Flink](https://flink.apache.org/)库, __可简化构建分布式有状态应用程序的过程__

[GitHub] [flink] flinkbot edited a comment on pull request #13299: [FLINK-19072][table-planner] Import Temporal Table join rule

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13299: URL: https://github.com/apache/flink/pull/13299#issuecomment-684842866 ## CI report: * 2ed16425d7018bbb39be1edd6519fcb99cb45000 Azure:

[GitHub] [flink-statefun] billyrrr commented on pull request #131: [FLINK-18968] Translate README.md to Chinese

2020-09-01 Thread GitBox
billyrrr commented on pull request #131: URL: https://github.com/apache/flink-statefun/pull/131#issuecomment-685099775 @tzulitai I can update the specifications first This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on pull request #13284: [FLINK-17016][runtime] Change blink planner batch jobs to run with pipelined region scheduling

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13284: URL: https://github.com/apache/flink/pull/13284#issuecomment-683683000 ## CI report: * 42b7875dce1d37427b9f85f21172208c1bd8c97b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13249: [FLINK-14087][datastream] Clone the StreamPartitioner to avoid being shared at runtime.

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13249: URL: https://github.com/apache/flink/pull/13249#issuecomment-680775587 ## CI report: * 07e11ae0c700a4172a854ae4fd108b483bde6003 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13249: [FLINK-14087][datastream] Clone the StreamPartitioner to avoid being shared at runtime.

2020-09-01 Thread GitBox
flinkbot edited a comment on pull request #13249: URL: https://github.com/apache/flink/pull/13249#issuecomment-680775587 ## CI report: * 07e11ae0c700a4172a854ae4fd108b483bde6003 Azure:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #13249: [FLINK-14087][datastream] Clone the StreamPartitioner to avoid being shared at runtime.

2020-09-01 Thread GitBox
gaoyunhaii commented on a change in pull request #13249: URL: https://github.com/apache/flink/pull/13249#discussion_r481325673 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -1180,6 +1181,14 @@ public final

  1   2   3   4   >