[GitHub] [flink] godfreyhe commented on a change in pull request #8288: [FLINK-12345] [table-planner-blink] Add support for generating optimized logical plan for stream window aggregate

2019-05-06 Thread GitBox
godfreyhe commented on a change in pull request #8288: [FLINK-12345] [table-planner-blink] Add support for generating optimized logical plan for stream window aggregate URL: https://github.com/apache/flink/pull/8288#discussion_r281494186 ## File path: flink-table/flink-table-plann

[GitHub] [flink] KurtYoung commented on a change in pull request #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime

2019-05-06 Thread GitBox
KurtYoung commented on a change in pull request #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime URL: https://github.com/apache/flink/pull/8302#discussion_r281494358 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apa

[GitHub] [flink] bowenli86 commented on issue #8339: [FLINK-12240][hive] Support view related operations in GenericHiveMetastoreCatalog

2019-05-06 Thread GitBox
bowenli86 commented on issue #8339: [FLINK-12240][hive] Support view related operations in GenericHiveMetastoreCatalog URL: https://github.com/apache/flink/pull/8339#issuecomment-489948651 I've addressed your comments, can you take another look? @KurtYoung

[GitHub] [flink] wuchong commented on a change in pull request #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime

2019-05-06 Thread GitBox
wuchong commented on a change in pull request #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime URL: https://github.com/apache/flink/pull/8302#discussion_r281493168 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apach

[GitHub] [flink] zhijiangW commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions

2019-05-06 Thread GitBox
zhijiangW commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions URL: https://github.com/apache/flink/pull/8290#discussion_r281493283 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/B

[GitHub] [flink] FaxianZhao commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer

2019-05-06 Thread GitBox
FaxianZhao commented on a change in pull request #7679: [FLINK-11501][Kafka Connector] Add ratelimiting to Kafka consumer URL: https://github.com/apache/flink/pull/7679#discussion_r281490411 ## File path: flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/st

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy

2019-05-06 Thread GitBox
eaglewatcherwb commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy URL: https://github.com/apache/flink/pull/8296#discussion_r281490791 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/EagerSc

[jira] [Updated] (FLINK-12423) Add Timer metric type for flink-metrics module

2019-05-06 Thread Armstrong Nova (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Armstrong Nova updated FLINK-12423: --- Description: Hi guys,      Currently, Flink only support 4 registering metrics, {{Counters}

[GitHub] [flink] wuchong commented on a change in pull request #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime

2019-05-06 Thread GitBox
wuchong commented on a change in pull request #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime URL: https://github.com/apache/flink/pull/8302#discussion_r281491514 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache

[GitHub] [flink] dianfu commented on issue #8347: [FLINK-12326][python] Add basic test framework for python api

2019-05-06 Thread GitBox
dianfu commented on issue #8347: [FLINK-12326][python] Add basic test framework for python api URL: https://github.com/apache/flink/pull/8347#issuecomment-489929559 @sunjincheng121 @WeiZhong94 Thanks a lot for your review. Updated accordingly!

[GitHub] [flink] godfreyhe commented on a change in pull request #8288: [FLINK-12345] [table-planner-blink] Add support for generating optimized logical plan for stream window aggregate

2019-05-06 Thread GitBox
godfreyhe commented on a change in pull request #8288: [FLINK-12345] [table-planner-blink] Add support for generating optimized logical plan for stream window aggregate URL: https://github.com/apache/flink/pull/8288#discussion_r281486525 ## File path: flink-table/flink-table-plann

[GitHub] [flink] KurtYoung commented on a change in pull request #8339: [FLINK-12240][hive] Support view related operations in GenericHiveMetastoreCatalog

2019-05-06 Thread GitBox
KurtYoung commented on a change in pull request #8339: [FLINK-12240][hive] Support view related operations in GenericHiveMetastoreCatalog URL: https://github.com/apache/flink/pull/8339#discussion_r281479876 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apach

[GitHub] [flink] dianfu commented on a change in pull request #8347: [FLINK-12326][python] Add basic test framework for python api

2019-05-06 Thread GitBox
dianfu commented on a change in pull request #8347: [FLINK-12326][python] Add basic test framework for python api URL: https://github.com/apache/flink/pull/8347#discussion_r281484044 ## File path: flink-python/pyflink/table/tests/test_table.py ## @@ -0,0 +1,75 @@ +# #

[GitHub] [flink] KurtYoung commented on a change in pull request #8339: [FLINK-12240][hive] Support view related operations in GenericHiveMetastoreCatalog

2019-05-06 Thread GitBox
KurtYoung commented on a change in pull request #8339: [FLINK-12240][hive] Support view related operations in GenericHiveMetastoreCatalog URL: https://github.com/apache/flink/pull/8339#discussion_r281483556 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apach

[GitHub] [flink] dianfu commented on a change in pull request #8347: [FLINK-12326][python] Add basic test framework for python api

2019-05-06 Thread GitBox
dianfu commented on a change in pull request #8347: [FLINK-12326][python] Add basic test framework for python api URL: https://github.com/apache/flink/pull/8347#discussion_r281481752 ## File path: flink-python/pyflink/table/tests/test_table.py ## @@ -0,0 +1,75 @@ +# #

[GitHub] [flink] KurtYoung commented on a change in pull request #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime

2019-05-06 Thread GitBox
KurtYoung commented on a change in pull request #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime URL: https://github.com/apache/flink/pull/8302#discussion_r281471504 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apa

[GitHub] [flink] KurtYoung commented on a change in pull request #8317: [FLINK-12371] [table-planner-blink] Add support for converting (NOT) IN/ (NOT) EXISTS to SemiJoin, and generating optimized logi

2019-05-06 Thread GitBox
KurtYoung commented on a change in pull request #8317: [FLINK-12371] [table-planner-blink] Add support for converting (NOT) IN/ (NOT) EXISTS to SemiJoin, and generating optimized logical plan URL: https://github.com/apache/flink/pull/8317#discussion_r281475435 ## File path: flink-

[GitHub] [flink] KurtYoung commented on a change in pull request #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime

2019-05-06 Thread GitBox
KurtYoung commented on a change in pull request #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime URL: https://github.com/apache/flink/pull/8302#discussion_r281474806 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/ap

[jira] [Updated] (FLINK-11987) Kafka producer occasionally throws NullpointerException

2019-05-06 Thread LIU Xiao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LIU Xiao updated FLINK-11987: - Description: We are using Flink 1.6.2 in our production environment, and kafka producer occasionally th

[GitHub] [flink] dianfu commented on a change in pull request #8347: [FLINK-12326][python] Add basic test framework for python api

2019-05-06 Thread GitBox
dianfu commented on a change in pull request #8347: [FLINK-12326][python] Add basic test framework for python api URL: https://github.com/apache/flink/pull/8347#discussion_r281473854 ## File path: flink-python/pyflink/testing/source_sink_utils.py ## @@ -0,0 +1,127 @@ +

[GitHub] [flink] dianfu commented on a change in pull request #8347: [FLINK-12326][python] Add basic test framework for python api

2019-05-06 Thread GitBox
dianfu commented on a change in pull request #8347: [FLINK-12326][python] Add basic test framework for python api URL: https://github.com/apache/flink/pull/8347#discussion_r281473572 ## File path: flink-python/pyflink/testing/source_sink_utils.py ## @@ -0,0 +1,127 @@ +

[GitHub] [flink] dianfu commented on a change in pull request #8347: [FLINK-12326][python] Add basic test framework for python api

2019-05-06 Thread GitBox
dianfu commented on a change in pull request #8347: [FLINK-12326][python] Add basic test framework for python api URL: https://github.com/apache/flink/pull/8347#discussion_r281473088 ## File path: flink-python/pyflink/testing/test_case_utils.py ## @@ -0,0 +1,64 @@ +###

[GitHub] [flink] zhuzhurk commented on a change in pull request #8316: [FLINK-12369] [coordination] Implement a region failover strategy regarding the next version FailoverStrategy interfaces

2019-05-06 Thread GitBox
zhuzhurk commented on a change in pull request #8316: [FLINK-12369] [coordination] Implement a region failover strategy regarding the next version FailoverStrategy interfaces URL: https://github.com/apache/flink/pull/8316#discussion_r281472899 ## File path: flink-runtime/src/test/

[GitHub] [flink] Zor-X-L commented on issue #8331: [FLINK-11987][flink-connector-kafka-0.11] convert NEXT_TRANSACTIONAL_ID_HINT_DESCRIPTOR to a non-static variabl…

2019-05-06 Thread GitBox
Zor-X-L commented on issue #8331: [FLINK-11987][flink-connector-kafka-0.11] convert NEXT_TRANSACTIONAL_ID_HINT_DESCRIPTOR to a non-static variabl… URL: https://github.com/apache/flink/pull/8331#issuecomment-489922433 > The Pull Request description seems a bit off. Could you add a proper de

[GitHub] [flink] bowenli86 commented on a change in pull request #8339: [FLINK-12240][hive] Support view related operations in GenericHiveMetastoreCatalog

2019-05-06 Thread GitBox
bowenli86 commented on a change in pull request #8339: [FLINK-12240][hive] Support view related operations in GenericHiveMetastoreCatalog URL: https://github.com/apache/flink/pull/8339#discussion_r281471404 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apach

[GitHub] [flink] flinkbot commented on issue #8356: [FLINK-12424] [table-planner-blink] Supports dag (multiple-sinks query) optimization

2019-05-06 Thread GitBox
flinkbot commented on issue #8356: [FLINK-12424] [table-planner-blink] Supports dag (multiple-sinks query) optimization URL: https://github.com/apache/flink/pull/8356#issuecomment-489920416 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the commun

[jira] [Updated] (FLINK-12424) Supports dag (multiple-sinks query) optimization

2019-05-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12424: --- Labels: pull-request-available (was: ) > Supports dag (multiple-sinks query) optimization >

[GitHub] [flink] godfreyhe opened a new pull request #8356: [FLINK-12424] [table-planner-blink] Supports dag (multiple-sinks query) optimization

2019-05-06 Thread GitBox
godfreyhe opened a new pull request #8356: [FLINK-12424] [table-planner-blink] Supports dag (multiple-sinks query) optimization URL: https://github.com/apache/flink/pull/8356 ## What is the purpose of the change *Supports dag (multiple-sinks query) optimization* ## Bri

[jira] [Updated] (FLINK-12424) Supports dag (multiple-sinks query) optimization

2019-05-06 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12424: --- Description: Currently, Flink planner will optimize the plan in {{writeToSink}} method. If there ar

[jira] [Updated] (FLINK-12424) Supports dag (multiple-sinks query) optimization

2019-05-06 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12424: --- Description: Currently, Flink planner will optimize the plan in {{writeToSink}} method. If there ar

[jira] [Updated] (FLINK-12424) Supports dag (multiple-sinks query) optimization

2019-05-06 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12424: --- Description: Currently, Flink planner will optimize the plan in {{writeToSink}} method. If there ar

[jira] [Created] (FLINK-12425) Implement RPCs to allow clients release result partitions in a Flink cluster.

2019-05-06 Thread Jiangjie Qin (JIRA)
Jiangjie Qin created FLINK-12425: Summary: Implement RPCs to allow clients release result partitions in a Flink cluster. Key: FLINK-12425 URL: https://issues.apache.org/jira/browse/FLINK-12425 Project

[jira] [Created] (FLINK-12424) Supports dag (multiple-sinks query) optimization

2019-05-06 Thread godfrey he (JIRA)
godfrey he created FLINK-12424: -- Summary: Supports dag (multiple-sinks query) optimization Key: FLINK-12424 URL: https://issues.apache.org/jira/browse/FLINK-12424 Project: Flink Issue Type: New

[GitHub] [flink] xuefuz commented on a change in pull request #8339: [FLINK-12240][hive] Support view related operations in GenericHiveMetastoreCatalog

2019-05-06 Thread GitBox
xuefuz commented on a change in pull request #8339: [FLINK-12240][hive] Support view related operations in GenericHiveMetastoreCatalog URL: https://github.com/apache/flink/pull/8339#discussion_r281461138 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/f

[GitHub] [flink] xuefuz commented on a change in pull request #8339: [FLINK-12240][hive] Support view related operations in GenericHiveMetastoreCatalog

2019-05-06 Thread GitBox
xuefuz commented on a change in pull request #8339: [FLINK-12240][hive] Support view related operations in GenericHiveMetastoreCatalog URL: https://github.com/apache/flink/pull/8339#discussion_r281461138 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/f

[GitHub] [flink] zhijiangW commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions

2019-05-06 Thread GitBox
zhijiangW commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions URL: https://github.com/apache/flink/pull/8290#discussion_r281460791 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/B

[GitHub] [flink] xuefuz commented on a change in pull request #8339: [FLINK-12240][hive] Support view related operations in GenericHiveMetastoreCatalog

2019-05-06 Thread GitBox
xuefuz commented on a change in pull request #8339: [FLINK-12240][hive] Support view related operations in GenericHiveMetastoreCatalog URL: https://github.com/apache/flink/pull/8339#discussion_r281460262 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/f

[GitHub] [flink] xuefuz commented on a change in pull request #8339: [FLINK-12240][hive] Support view related operations in GenericHiveMetastoreCatalog

2019-05-06 Thread GitBox
xuefuz commented on a change in pull request #8339: [FLINK-12240][hive] Support view related operations in GenericHiveMetastoreCatalog URL: https://github.com/apache/flink/pull/8339#discussion_r281459369 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/f

[GitHub] [flink] zhijiangW commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions

2019-05-06 Thread GitBox
zhijiangW commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions URL: https://github.com/apache/flink/pull/8290#discussion_r281459388 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/B

[GitHub] [flink] xuefuz commented on a change in pull request #8339: [FLINK-12240][hive] Support view related operations in GenericHiveMetastoreCatalog

2019-05-06 Thread GitBox
xuefuz commented on a change in pull request #8339: [FLINK-12240][hive] Support view related operations in GenericHiveMetastoreCatalog URL: https://github.com/apache/flink/pull/8339#discussion_r281459369 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/f

[GitHub] [flink] danny0405 commented on a change in pull request #8317: [FLINK-12371] [table-planner-blink] Add support for converting (NOT) IN/ (NOT) EXISTS to SemiJoin, and generating optimized logi

2019-05-06 Thread GitBox
danny0405 commented on a change in pull request #8317: [FLINK-12371] [table-planner-blink] Add support for converting (NOT) IN/ (NOT) EXISTS to SemiJoin, and generating optimized logical plan URL: https://github.com/apache/flink/pull/8317#discussion_r281458212 ## File path: flink-

[GitHub] [flink] zhijiangW commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions

2019-05-06 Thread GitBox
zhijiangW commented on a change in pull request #8290: [FLINK-12070] [network] Implement new bounded blocking subpartitions URL: https://github.com/apache/flink/pull/8290#discussion_r281457936 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/B

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy

2019-05-06 Thread GitBox
eaglewatcherwb commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy URL: https://github.com/apache/flink/pull/8296#discussion_r281453729 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/EagerSc

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy

2019-05-06 Thread GitBox
eaglewatcherwb commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy URL: https://github.com/apache/flink/pull/8296#discussion_r281454713 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/Executi

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy

2019-05-06 Thread GitBox
eaglewatcherwb commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy URL: https://github.com/apache/flink/pull/8296#discussion_r281455320 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/Testing

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy

2019-05-06 Thread GitBox
eaglewatcherwb commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy URL: https://github.com/apache/flink/pull/8296#discussion_r281455385 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/Testing

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy

2019-05-06 Thread GitBox
eaglewatcherwb commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy URL: https://github.com/apache/flink/pull/8296#discussion_r281453965 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/EagerSc

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy

2019-05-06 Thread GitBox
eaglewatcherwb commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy URL: https://github.com/apache/flink/pull/8296#discussion_r281455470 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/Testing

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy

2019-05-06 Thread GitBox
eaglewatcherwb commented on a change in pull request #8296: [FLINK-12228] [runtime] Implement Eager Scheduling Strategy URL: https://github.com/apache/flink/pull/8296#discussion_r281455438 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/Testing

[GitHub] [flink] zhijiangW edited a comment on issue #8242: [FLINK-6227][network] Introduce the DataConsumptionException for downstream task failure

2019-05-06 Thread GitBox
zhijiangW edited a comment on issue #8242: [FLINK-6227][network] Introduce the DataConsumptionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#issuecomment-489901309 @tillrohrmann thanks for the further suggestions! I agree with your overall ideas.

[GitHub] [flink] zhijiangW edited a comment on issue #8242: [FLINK-6227][network] Introduce the DataConsumptionException for downstream task failure

2019-05-06 Thread GitBox
zhijiangW edited a comment on issue #8242: [FLINK-6227][network] Introduce the DataConsumptionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#issuecomment-489901309 @tillrohrmann thanks for the further suggestions! I agree with your overall ideas.

[GitHub] [flink] zhijiangW edited a comment on issue #8242: [FLINK-6227][network] Introduce the DataConsumptionException for downstream task failure

2019-05-06 Thread GitBox
zhijiangW edited a comment on issue #8242: [FLINK-6227][network] Introduce the DataConsumptionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#issuecomment-489901309 @tillrohrmann thanks for the further suggestions! I agree with your overall ideas.

[GitHub] [flink] zhijiangW commented on issue #8242: [FLINK-6227][network] Introduce the DataConsumptionException for downstream task failure

2019-05-06 Thread GitBox
zhijiangW commented on issue #8242: [FLINK-6227][network] Introduce the DataConsumptionException for downstream task failure URL: https://github.com/apache/flink/pull/8242#issuecomment-489901309 @tillrohrmann thanks for the further suggestions! I agree with your overall ideas. ->Wha

[jira] [Updated] (FLINK-12330) Add integrated Tox for ensuring compatibility with the python2/3 version

2019-05-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12330: --- Labels: pull-request-available (was: ) > Add integrated Tox for ensuring compatibility with

[GitHub] [flink] sunjincheng121 opened a new pull request #8355: [FLINK-12330][python]Add integrated Tox for ensuring compatibility of multi-version of python.

2019-05-06 Thread GitBox
sunjincheng121 opened a new pull request #8355: [FLINK-12330][python]Add integrated Tox for ensuring compatibility of multi-version of python. URL: https://github.com/apache/flink/pull/8355 ## What is the purpose of the change Add integrated Tox for ensuring compatibility of multi-ve

[GitHub] [flink] flinkbot commented on issue #8355: [FLINK-12330][python]Add integrated Tox for ensuring compatibility of multi-version of python.

2019-05-06 Thread GitBox
flinkbot commented on issue #8355: [FLINK-12330][python]Add integrated Tox for ensuring compatibility of multi-version of python. URL: https://github.com/apache/flink/pull/8355#issuecomment-489901389 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] KurtYoung commented on a change in pull request #8317: [FLINK-12371] [table-planner-blink] Add support for converting (NOT) IN/ (NOT) EXISTS to SemiJoin, and generating optimized logi

2019-05-06 Thread GitBox
KurtYoung commented on a change in pull request #8317: [FLINK-12371] [table-planner-blink] Add support for converting (NOT) IN/ (NOT) EXISTS to SemiJoin, and generating optimized logical plan URL: https://github.com/apache/flink/pull/8317#discussion_r281452013 ## File path: flink-

[GitHub] [flink] KurtYoung commented on a change in pull request #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module.

2019-05-06 Thread GitBox
KurtYoung commented on a change in pull request #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module. URL: https://github.com/apache/flink/pull/8294#discussion_r281447680 ## File path: flink-table/flink-table-planner

[GitHub] [flink] KurtYoung commented on a change in pull request #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module.

2019-05-06 Thread GitBox
KurtYoung commented on a change in pull request #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module. URL: https://github.com/apache/flink/pull/8294#discussion_r281446411 ## File path: flink-table/flink-table-planner

[GitHub] [flink] KurtYoung commented on a change in pull request #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module.

2019-05-06 Thread GitBox
KurtYoung commented on a change in pull request #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module. URL: https://github.com/apache/flink/pull/8294#discussion_r281447839 ## File path: flink-table/flink-table-planner

[GitHub] [flink] KurtYoung commented on a change in pull request #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module.

2019-05-06 Thread GitBox
KurtYoung commented on a change in pull request #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module. URL: https://github.com/apache/flink/pull/8294#discussion_r281447320 ## File path: flink-table/flink-table-planner

[GitHub] [flink] KurtYoung commented on a change in pull request #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module.

2019-05-06 Thread GitBox
KurtYoung commented on a change in pull request #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module. URL: https://github.com/apache/flink/pull/8294#discussion_r281450922 ## File path: flink-table/flink-table-planner

[GitHub] [flink] KurtYoung commented on a change in pull request #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module.

2019-05-06 Thread GitBox
KurtYoung commented on a change in pull request #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module. URL: https://github.com/apache/flink/pull/8294#discussion_r281447197 ## File path: flink-table/flink-table-planner

[GitHub] [flink] KurtYoung commented on a change in pull request #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module.

2019-05-06 Thread GitBox
KurtYoung commented on a change in pull request #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module. URL: https://github.com/apache/flink/pull/8294#discussion_r281446233 ## File path: flink-table/flink-table-planner

[GitHub] [flink] wuchong commented on a change in pull request #8288: [FLINK-12345] [table-planner-blink] Add support for generating optimized logical plan for stream window aggregate

2019-05-06 Thread GitBox
wuchong commented on a change in pull request #8288: [FLINK-12345] [table-planner-blink] Add support for generating optimized logical plan for stream window aggregate URL: https://github.com/apache/flink/pull/8288#discussion_r281450454 ## File path: flink-table/flink-table-planner

[GitHub] [flink] wuchong commented on a change in pull request #8288: [FLINK-12345] [table-planner-blink] Add support for generating optimized logical plan for stream window aggregate

2019-05-06 Thread GitBox
wuchong commented on a change in pull request #8288: [FLINK-12345] [table-planner-blink] Add support for generating optimized logical plan for stream window aggregate URL: https://github.com/apache/flink/pull/8288#discussion_r281448847 ## File path: flink-table/flink-table-planner

[jira] [Closed] (FLINK-11839) Introduce FlinkLogicalWindowAggregate

2019-05-06 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-11839. -- Resolution: Duplicate > Introduce FlinkLogicalWindowAggregate > -

[jira] [Commented] (FLINK-12416) Docker build script fails on symlink creation ln -s

2019-05-06 Thread Yun Tang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16834344#comment-16834344 ] Yun Tang commented on FLINK-12416: -- [~slav4ik], would you please share the full command

[jira] [Commented] (FLINK-11561) Translate "Flink Architecture" page into Chinese

2019-05-06 Thread Tom Goong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16834343#comment-16834343 ] Tom Goong commented on FLINK-11561: --- [~jark]  Sorry, I thought that the flink-parent d

[GitHub] [flink] wuchong commented on a change in pull request #8288: [FLINK-12345] [table-planner-blink] Add support for generating optimized logical plan for stream window aggregate

2019-05-06 Thread GitBox
wuchong commented on a change in pull request #8288: [FLINK-12345] [table-planner-blink] Add support for generating optimized logical plan for stream window aggregate URL: https://github.com/apache/flink/pull/8288#discussion_r281446085 ## File path: flink-table/flink-table-planner

[GitHub] [flink] KurtYoung commented on a change in pull request #8288: [FLINK-12345] [table-planner-blink] Add support for generating optimized logical plan for stream window aggregate

2019-05-06 Thread GitBox
KurtYoung commented on a change in pull request #8288: [FLINK-12345] [table-planner-blink] Add support for generating optimized logical plan for stream window aggregate URL: https://github.com/apache/flink/pull/8288#discussion_r281444733 ## File path: flink-table/flink-table-plann

[GitHub] [flink] KurtYoung commented on a change in pull request #8288: [FLINK-12345] [table-planner-blink] Add support for generating optimized logical plan for stream window aggregate

2019-05-06 Thread GitBox
KurtYoung commented on a change in pull request #8288: [FLINK-12345] [table-planner-blink] Add support for generating optimized logical plan for stream window aggregate URL: https://github.com/apache/flink/pull/8288#discussion_r281444516 ## File path: flink-table/flink-table-plann

[jira] [Commented] (FLINK-11561) Translate "Flink Architecture" page into Chinese

2019-05-06 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16834334#comment-16834334 ] Jark Wu commented on FLINK-11561: - [~Tom Goong] Yes, it is in flink-web project. What do

[jira] [Created] (FLINK-12423) Add Timer metric type for flink-metrics module

2019-05-06 Thread Armstrong Nova (JIRA)
Armstrong Nova created FLINK-12423: -- Summary: Add Timer metric type for flink-metrics module Key: FLINK-12423 URL: https://issues.apache.org/jira/browse/FLINK-12423 Project: Flink Issue Type

[GitHub] [flink] zjffdu commented on a change in pull request #8144: [FLINK-12159]. Enable YarnMiniCluster integration test under non-secure mode

2019-05-06 Thread GitBox
zjffdu commented on a change in pull request #8144: [FLINK-12159]. Enable YarnMiniCluster integration test under non-secure mode URL: https://github.com/apache/flink/pull/8144#discussion_r281442692 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDesc

[jira] [Created] (FLINK-12422) Remove IN_TESTS for make test code and production code consistent

2019-05-06 Thread Jeff Zhang (JIRA)
Jeff Zhang created FLINK-12422: -- Summary: Remove IN_TESTS for make test code and production code consistent Key: FLINK-12422 URL: https://issues.apache.org/jira/browse/FLINK-12422 Project: Flink

[jira] [Commented] (FLINK-11561) Translate "Flink Architecture" page into Chinese

2019-05-06 Thread Tom Goong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16834331#comment-16834331 ] Tom Goong commented on FLINK-11561: --- this file is located in "flink-web" project.  Wil

[jira] [Updated] (FLINK-12421) Synchronize the latest documentation changes into Chinese documents

2019-05-06 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-12421: Issue Type: Sub-task (was: Task) Parent: FLINK-11529 > Synchronize the latest documentation chang

[jira] [Updated] (FLINK-12421) Synchronize the latest documentation changes into Chinese documents

2019-05-06 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-12421: Issue Type: Sub-task (was: Improvement) Parent: FLINK-11525 > Synchronize the latest documentatio

[jira] [Updated] (FLINK-12421) Synchronize the latest documentation changes into Chinese documents

2019-05-06 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-12421: Issue Type: Task (was: Sub-task) Parent: (was: FLINK-11525) > Synchronize the latest document

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8347: [FLINK-12326][python] Add basic test framework for python api

2019-05-06 Thread GitBox
sunjincheng121 commented on a change in pull request #8347: [FLINK-12326][python] Add basic test framework for python api URL: https://github.com/apache/flink/pull/8347#discussion_r281428840 ## File path: flink-python/pyflink/testing/test_case_utils.py ## @@ -0,0 +1,64 @@

[GitHub] [flink] flinkbot edited a comment on issue #8347: [FLINK-12326][python] Add basic test framework for python api

2019-05-06 Thread GitBox
flinkbot edited a comment on issue #8347: [FLINK-12326][python] Add basic test framework for python api URL: https://github.com/apache/flink/pull/8347#issuecomment-489486437 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8347: [FLINK-12326][python] Add basic test framework for python api

2019-05-06 Thread GitBox
sunjincheng121 commented on a change in pull request #8347: [FLINK-12326][python] Add basic test framework for python api URL: https://github.com/apache/flink/pull/8347#discussion_r281433379 ## File path: flink-python/pyflink/table/tests/test_table.py ## @@ -0,0 +1,75 @@ +

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8347: [FLINK-12326][python] Add basic test framework for python api

2019-05-06 Thread GitBox
sunjincheng121 commented on a change in pull request #8347: [FLINK-12326][python] Add basic test framework for python api URL: https://github.com/apache/flink/pull/8347#discussion_r281437149 ## File path: flink-python/pyflink/table/tests/test_table.py ## @@ -0,0 +1,75 @@ +

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8347: [FLINK-12326][python] Add basic test framework for python api

2019-05-06 Thread GitBox
sunjincheng121 commented on a change in pull request #8347: [FLINK-12326][python] Add basic test framework for python api URL: https://github.com/apache/flink/pull/8347#discussion_r281433677 ## File path: flink-python/pyflink/table/tests/test_end_to_end.py ## @@ -1,73 +0,0

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8347: [FLINK-12326][python] Add basic test framework for python api

2019-05-06 Thread GitBox
sunjincheng121 commented on a change in pull request #8347: [FLINK-12326][python] Add basic test framework for python api URL: https://github.com/apache/flink/pull/8347#discussion_r281437349 ## File path: flink-python/pyflink/testing/test_case_utils.py ## @@ -0,0 +1,64 @@

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8347: [FLINK-12326][python] Add basic test framework for python api

2019-05-06 Thread GitBox
sunjincheng121 commented on a change in pull request #8347: [FLINK-12326][python] Add basic test framework for python api URL: https://github.com/apache/flink/pull/8347#discussion_r281433195 ## File path: flink-python/pyflink/testing/source_sink_utils.py ## @@ -0,0 +1,127

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8347: [FLINK-12326][python] Add basic test framework for python api

2019-05-06 Thread GitBox
sunjincheng121 commented on a change in pull request #8347: [FLINK-12326][python] Add basic test framework for python api URL: https://github.com/apache/flink/pull/8347#discussion_r281438679 ## File path: flink-python/pyflink/find_flink_home.py ## @@ -41,5 +41,19 @@ def _f

[GitHub] [flink] wuchong opened a new pull request #8354: [FLINK-12421][docs-zh] Synchronize the latest documentation changes (commits to 7b46f604) into Chinese documents

2019-05-06 Thread GitBox
wuchong opened a new pull request #8354: [FLINK-12421][docs-zh] Synchronize the latest documentation changes (commits to 7b46f604) into Chinese documents URL: https://github.com/apache/flink/pull/8354 ## What is the purpose of the change There are several commits to documentation

[jira] [Updated] (FLINK-12421) Synchronize the latest documentation changes into Chinese documents

2019-05-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12421: --- Labels: pull-request-available (was: ) > Synchronize the latest documentation changes into

[GitHub] [flink] sunjincheng121 commented on issue #8347: [FLINK-12326][python] Add basic test framework for python api

2019-05-06 Thread GitBox
sunjincheng121 commented on issue #8347: [FLINK-12326][python] Add basic test framework for python api URL: https://github.com/apache/flink/pull/8347#issuecomment-489879981 @flinkbot approve-until architecture This is an auto

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8347: [FLINK-12326][python] Add basic test framework for python api

2019-05-06 Thread GitBox
sunjincheng121 commented on a change in pull request #8347: [FLINK-12326][python] Add basic test framework for python api URL: https://github.com/apache/flink/pull/8347#discussion_r281432761 ## File path: flink-python/pyflink/testing/source_sink_utils.py ## @@ -0,0 +1,127

[GitHub] [flink] flinkbot commented on issue #8354: [FLINK-12421][docs-zh] Synchronize the latest documentation changes (commits to 7b46f604) into Chinese documents

2019-05-06 Thread GitBox
flinkbot commented on issue #8354: [FLINK-12421][docs-zh] Synchronize the latest documentation changes (commits to 7b46f604) into Chinese documents URL: https://github.com/apache/flink/pull/8354#issuecomment-489880058 Thanks a lot for your contribution to the Apache Flink project. I'm the

[jira] [Created] (FLINK-12421) Synchronize the latest documentation changes into Chinese documents

2019-05-06 Thread Jark Wu (JIRA)
Jark Wu created FLINK-12421: --- Summary: Synchronize the latest documentation changes into Chinese documents Key: FLINK-12421 URL: https://issues.apache.org/jira/browse/FLINK-12421 Project: Flink Is

[jira] [Assigned] (FLINK-11637) Translate "Checkpoints" page into Chinese

2019-05-06 Thread Tom Goong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tom Goong reassigned FLINK-11637: - Assignee: Tom Goong > Translate "Checkpoints" page into Chinese > -

[jira] [Assigned] (FLINK-11634) Translate "State Backends" page into Chinese

2019-05-06 Thread Tom Goong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tom Goong reassigned FLINK-11634: - Assignee: Tom Goong > Translate "State Backends" page into Chinese > --

[jira] [Assigned] (FLINK-11561) Translate "Flink Architecture" page into Chinese

2019-05-06 Thread Tom Goong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tom Goong reassigned FLINK-11561: - Assignee: Tom Goong > Translate "Flink Architecture" page into Chinese > --

[jira] [Closed] (FLINK-11754) Translate the "Roadmap" page into Chinese

2019-05-06 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-11754. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in flink-web: 7f603e6b557bf14a933ec741282fc25a4c26daf5

[jira] [Updated] (FLINK-12420) Add support of cache/invalidateCache for TableAPI

2019-05-06 Thread Ruidong Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruidong Li updated FLINK-12420: --- Component/s: Table SQL / API > Add support of cache/invalidateCache for TableAPI > -

[jira] [Created] (FLINK-12420) Add support of cache/invalidateCache for TableAPI

2019-05-06 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-12420: -- Summary: Add support of cache/invalidateCache for TableAPI Key: FLINK-12420 URL: https://issues.apache.org/jira/browse/FLINK-12420 Project: Flink Issue Type: Sub

  1   2   3   4   >