[GitHub] [flink] Myasuka commented on a change in pull request #9023: [FLINK-13154][docs] Fix broken links of web docs

Myasuka commented on a change in pull request #9023: [FLINK-13154][docs] Fix broken links of web docs URL: https://github.com/apache/flink/pull/9023#discussion_r302837692 ## File path: docs/dev/table/sqlClient.md ## @@ -456,8 +456,6 @@ catalogs: Currently Flink

[jira] [Commented] (FLINK-13083) Various improvements PubSub Connector

[ https://issues.apache.org/jira/browse/FLINK-13083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883549#comment-16883549 ] Jiangjie Qin commented on FLINK-13083: -- [~Xeli] Thanks for the quick reply. Just a reminder that

[GitHub] [flink] danny0405 closed pull request #9092: [FLINK-13211] Add drop table support for flink planner

danny0405 closed pull request #9092: [FLINK-13211] Add drop table support for flink planner URL: https://github.com/apache/flink/pull/9092 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot commented on issue #9098: [FLINK-13236][table-runtime-blink] Fix bug and improve performance in TopNBuffer

flinkbot commented on issue #9098: [FLINK-13236][table-runtime-blink] Fix bug and improve performance in TopNBuffer URL: https://github.com/apache/flink/pull/9098#issuecomment-510755324 ## CI report: * 19d462121bdf06eb9982a9890dd5ce53cc9499b4 : PENDING

[jira] [Commented] (FLINK-13224) TupleTypeInfoBase equals function can't distinguish different struct type

[ https://issues.apache.org/jira/browse/FLINK-13224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883545#comment-16883545 ] forideal commented on FLINK-13224: -- if user type equals device type,the following code will get a wrong

[GitHub] [flink] TsReaper commented on issue #9098: [FLINK-13236][table-runtime-blink] Fix bug and improve performance in TopNBuffer

TsReaper commented on issue #9098: [FLINK-13236][table-runtime-blink] Fix bug and improve performance in TopNBuffer URL: https://github.com/apache/flink/pull/9098#issuecomment-510752945 @beyond1920 @wuchong @JingsongLi please take a look if you have time.

[GitHub] [flink] flinkbot commented on issue #7262: [FLINK-10478] Kafka Producer wrongly formats % for transaction ID

flinkbot commented on issue #7262: [FLINK-10478] Kafka Producer wrongly formats % for transaction ID URL: https://github.com/apache/flink/pull/7262#issuecomment-510752916 ## CI report: * 15f05f4c5791d9d42610099324e59057d26bd3ff : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9021: [FLINK-13205][runtime] Make checkpoints injection ordered with stop-with-savepoint

flinkbot edited a comment on issue #9021: [FLINK-13205][runtime] Make checkpoints injection ordered with stop-with-savepoint URL: https://github.com/apache/flink/pull/9021#issuecomment-510405873 ## CI report: * abed4b5678a2f09b3bb729bd62b5264e56b55b9f : SUCCESS

[GitHub] [flink] flinkbot commented on issue #9098: [FLINK-13236][table-runtime-blink] Fix bug and improve performance in TopNBuffer

flinkbot commented on issue #9098: [FLINK-13236][table-runtime-blink] Fix bug and improve performance in TopNBuffer URL: https://github.com/apache/flink/pull/9098#issuecomment-510753038 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Updated] (FLINK-13236) Fix bug and improve performance in TopNBuffer

[ https://issues.apache.org/jira/browse/FLINK-13236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13236: --- Labels: pull-request-available (was: ) > Fix bug and improve performance in TopNBuffer >

[GitHub] [flink] TsReaper opened a new pull request #9098: [FLINK-13236][table-runtime-blink] Fix bug and improve performance in TopNBuffer

TsReaper opened a new pull request #9098: [FLINK-13236][table-runtime-blink] Fix bug and improve performance in TopNBuffer URL: https://github.com/apache/flink/pull/9098 ## What is the purpose of the change The value of `currentTopNum` will be incorrectly calculated in the `putAll`

[jira] [Updated] (FLINK-13220) Add create/drop table support for blink planner

[ https://issues.apache.org/jira/browse/FLINK-13220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13220: --- Summary: Add create/drop table support for blink planner (was: Add DDL support for blink planner)

[jira] [Closed] (FLINK-13220) Add create/drop table support for blink planner

[ https://issues.apache.org/jira/browse/FLINK-13220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-13220. -- Resolution: Fixed merged in 1.9.0: db488c0d19dbb96466b9b765cecc06784b844926 > Add create/drop table

[jira] [Updated] (FLINK-13220) Add DDL support for blink planner

[ https://issues.apache.org/jira/browse/FLINK-13220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13220: --- Labels: pull-request-available (was: ) > Add DDL support for blink planner >

[GitHub] [flink] becketqin commented on a change in pull request #7262: [FLINK-10478] Kafka Producer wrongly formats % for transaction ID

becketqin commented on a change in pull request #7262: [FLINK-10478] Kafka Producer wrongly formats % for transaction ID URL: https://github.com/apache/flink/pull/7262#discussion_r302832450 ## File path:

[GitHub] [flink] KurtYoung closed pull request #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner

KurtYoung closed pull request #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner URL: https://github.com/apache/flink/pull/9093 This is an

[jira] [Closed] (FLINK-13211) Add drop table support for flink planner

[ https://issues.apache.org/jira/browse/FLINK-13211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-13211. -- Resolution: Fixed merged in 1.9.0: 58280f44f5ff62d129580bb091671a52537536e3 > Add drop table support

[GitHub] [flink] flinkbot edited a comment on issue #9057: [FLINK-13121] [table-planner-blink] Set batch properties to runtime in blink batch executor

flinkbot edited a comment on issue #9057: [FLINK-13121] [table-planner-blink] Set batch properties to runtime in blink batch executor URL: https://github.com/apache/flink/pull/9057#issuecomment-510405733 ## CI report: * b616282cb875778a7a5af22a2783eaaf48104908 : FAILURE

[jira] [Commented] (FLINK-10636) ERROR org.apache.flink.shaded.curator.org.apache.curator.ConnectionState - Authentication failed

[ https://issues.apache.org/jira/browse/FLINK-10636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883533#comment-16883533 ] Jiangjie Qin commented on FLINK-10636: -- [~lsy] Is this issue on Kafka 0.8? Starting from Kafka 0.9,

[GitHub] [flink] tzulitai commented on issue #9094: [FLINK-13094][state-processor-api] Provide an easy way to read timers using the State Processor API

tzulitai commented on issue #9094: [FLINK-13094][state-processor-api] Provide an easy way to read timers using the State Processor API URL: https://github.com/apache/flink/pull/9094#issuecomment-510745686 @flinkbot approve all The changes look good to me, thanks for the quick

[GitHub] [flink] flinkbot edited a comment on issue #9064: [FLINK-13188][Runtime / State Backends][Test] Fix MockStateBackend#resolveCheckpointStorageLocation return null cause intellij assertion dete

flinkbot edited a comment on issue #9064: [FLINK-13188][Runtime / State Backends][Test] Fix MockStateBackend#resolveCheckpointStorageLocation return null cause intellij assertion detect test failed URL: https://github.com/apache/flink/pull/9064#issuecomment-510409332 ## CI report:

[GitHub] [flink] flinkbot edited a comment on issue #9090: [FLINK-13124] Don't forward exceptions when finishing SourceStreamTask

flinkbot edited a comment on issue #9090: [FLINK-13124] Don't forward exceptions when finishing SourceStreamTask URL: https://github.com/apache/flink/pull/9090#issuecomment-510496617 ## CI report: * 6c229740b17ae4e0df7c8ba9678ada086ae8bf47 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager

flinkbot edited a comment on issue #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager URL: https://github.com/apache/flink/pull/8920#issuecomment-510405859 ## CI report: * 4afedee15460ac0f1f2945ca657581c538ddfc06 : FAILURE

[jira] [Closed] (FLINK-13115) Introduce planner rule to support partition pruning for PartitionableTableSource

[ https://issues.apache.org/jira/browse/FLINK-13115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-13115. -- Resolution: Implemented Fix Version/s: 1.9.0 merged in 1.9.0: 

[GitHub] [flink] KurtYoung closed pull request #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource

KurtYoung closed pull request #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource URL: https://github.com/apache/flink/pull/9080 This is an automated

[GitHub] [flink] KurtYoung commented on issue #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource

KurtYoung commented on issue #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource URL: https://github.com/apache/flink/pull/9080#issuecomment-510742027 passed here: https://travis-ci.org/KurtYoung/flink/builds/557654396

[jira] [Created] (FLINK-13236) Fix bug and improve performance in TopNBuffer

Caizhi Weng created FLINK-13236: --- Summary: Fix bug and improve performance in TopNBuffer Key: FLINK-13236 URL: https://issues.apache.org/jira/browse/FLINK-13236 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on issue #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager

flinkbot edited a comment on issue #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager URL: https://github.com/apache/flink/pull/8920#issuecomment-510405859 ## CI report: * 4afedee15460ac0f1f2945ca657581c538ddfc06 : FAILURE

[GitHub] [flink] flinkbot commented on issue #8911: [FLINK-12995][hive] Add Hive-1.2.1 build to Travis

flinkbot commented on issue #8911: [FLINK-12995][hive] Add Hive-1.2.1 build to Travis URL: https://github.com/apache/flink/pull/8911#issuecomment-510741229 ## CI report: * e0f3d5b774c08e2154b31fdde4b2c193276723a3 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9090: [FLINK-13124] Don't forward exceptions when finishing SourceStreamTask

flinkbot edited a comment on issue #9090: [FLINK-13124] Don't forward exceptions when finishing SourceStreamTask URL: https://github.com/apache/flink/pull/9090#issuecomment-510496617 ## CI report: * 6c229740b17ae4e0df7c8ba9678ada086ae8bf47 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9064: [FLINK-13188][Runtime / State Backends][Test] Fix MockStateBackend#resolveCheckpointStorageLocation return null cause intellij assertion dete

flinkbot edited a comment on issue #9064: [FLINK-13188][Runtime / State Backends][Test] Fix MockStateBackend#resolveCheckpointStorageLocation return null cause intellij assertion detect test failed URL: https://github.com/apache/flink/pull/9064#issuecomment-510409332 ## CI report:

[jira] [Commented] (FLINK-10806) Support multiple consuming offsets when discovering a new topic

[ https://issues.apache.org/jira/browse/FLINK-10806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883520#comment-16883520 ] Jiangjie Qin commented on FLINK-10806: -- Would setting \{{auto.offset.reset}} for the KafkaConsumer

[jira] [Comment Edited] (FLINK-10806) Support multiple consuming offsets when discovering a new topic

[ https://issues.apache.org/jira/browse/FLINK-10806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883520#comment-16883520 ] Jiangjie Qin edited comment on FLINK-10806 at 7/12/19 4:31 AM: ---

[GitHub] [flink] flinkbot commented on issue #7487: [FLINK-11321] Clarify NPE on fetching nonexistent topic

flinkbot commented on issue #7487: [FLINK-11321] Clarify NPE on fetching nonexistent topic URL: https://github.com/apache/flink/pull/7487#issuecomment-510739413 ## CI report: * c746405bfc3264fec2e9a5a6551360e37aa5688f : PENDING

[GitHub] [flink] lirui-apache commented on issue #8911: [FLINK-12995][hive] Add Hive-1.2.1 build to Travis

lirui-apache commented on issue #8911: [FLINK-12995][hive] Add Hive-1.2.1 build to Travis URL: https://github.com/apache/flink/pull/8911#issuecomment-510738891 Thanks for @zentol 's suggestions. PR updated accordingly. This

[jira] [Commented] (FLINK-10876) Deadlock if closing firstly pending transactions in FlinkKafkaProducer(011).close()

[ https://issues.apache.org/jira/browse/FLINK-10876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883518#comment-16883518 ] Jiangjie Qin commented on FLINK-10876: -- Is this still an issue given FLINK-10455 is fixed? Do you

[GitHub] [flink] flinkbot edited a comment on issue #9073: [FLINK-13187] Introduce ScheduleMode#LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST

flinkbot edited a comment on issue #9073: [FLINK-13187] Introduce ScheduleMode#LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST URL: https://github.com/apache/flink/pull/9073#issuecomment-510405770 ## CI report: * f588483906ba4c4459bf18671f84924a3286 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9083: [FLINK-13116] [table-planner-blink] Supports catalog statistics in blink planner

flinkbot edited a comment on issue #9083: [FLINK-13116] [table-planner-blink] Supports catalog statistics in blink planner URL: https://github.com/apache/flink/pull/9083#issuecomment-510435070 ## CI report: * 402974d0ffb69d9244c108234c9837f2eacc8d37 : PENDING

[GitHub] [flink] becketqin commented on issue #7487: [FLINK-11321] Clarify NPE on fetching nonexistent topic

becketqin commented on issue #7487: [FLINK-11321] Clarify NPE on fetching nonexistent topic URL: https://github.com/apache/flink/pull/7487#issuecomment-510736925 @Fokko Any update on this? We should also fix the `KafkaPartitionDiscoverer` in the universal Kafka connector as well.

[jira] [Updated] (FLINK-13206) modify 'use database' syntax in SQL CLI to be consistant with standard sql

[ https://issues.apache.org/jira/browse/FLINK-13206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zjuwangg updated FLINK-13206: - Affects Version/s: 1.9.0 > modify 'use database' syntax in SQL CLI to be consistant with standard sql >

[jira] [Updated] (FLINK-13206) modify 'use database' syntax in SQL CLI to be consistant with standard sql

[ https://issues.apache.org/jira/browse/FLINK-13206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zjuwangg updated FLINK-13206: - Fix Version/s: 1.9.0 > modify 'use database' syntax in SQL CLI to be consistant with standard sql >

[GitHub] [flink] beyond1920 commented on a change in pull request #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource

beyond1920 commented on a change in pull request #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource URL: https://github.com/apache/flink/pull/9080#discussion_r302807906 ## File path:

[GitHub] [flink] beyond1920 commented on a change in pull request #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource

beyond1920 commented on a change in pull request #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource URL: https://github.com/apache/flink/pull/9080#discussion_r302806301 ## File path:

[GitHub] [flink] beyond1920 commented on a change in pull request #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource

beyond1920 commented on a change in pull request #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource URL: https://github.com/apache/flink/pull/9080#discussion_r302807941 ## File path:

[GitHub] [flink] JingsongLi commented on issue #9095: [FLINK-13232][table-planner-blink] Remove CURRENT_DATE test to avoid timezone error

JingsongLi commented on issue #9095: [FLINK-13232][table-planner-blink] Remove CURRENT_DATE test to avoid timezone error URL: https://github.com/apache/flink/pull/9095#issuecomment-510736379 travis in: https://travis-ci.org/JingsongLi/flink/builds/557625626

[GitHub] [flink] flinkbot edited a comment on issue #9083: [FLINK-13116] [table-planner-blink] Supports catalog statistics in blink planner

flinkbot edited a comment on issue #9083: [FLINK-13116] [table-planner-blink] Supports catalog statistics in blink planner URL: https://github.com/apache/flink/pull/9083#issuecomment-510435070 ## CI report: * 402974d0ffb69d9244c108234c9837f2eacc8d37 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9094: [FLINK-13094][state-processor-api] Provide an easy way to read timers using the State Processor API

flinkbot edited a comment on issue #9094: [FLINK-13094][state-processor-api] Provide an easy way to read timers using the State Processor API URL: https://github.com/apache/flink/pull/9094#issuecomment-510560219 ## CI report: * 68c63247fc6c3b60b0cf7afb483cc04ee8f558d0 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9062: [FLINK-13100][network] Fix the bug of throwing IOException while FileChannelBoundedData#nextBuffer

flinkbot edited a comment on issue #9062: [FLINK-13100][network] Fix the bug of throwing IOException while FileChannelBoundedData#nextBuffer URL: https://github.com/apache/flink/pull/9062#issuecomment-510405737 ## CI report: * 106228aa31ad7065acf116029879a00fd998662b : FAILURE

[GitHub] [flink] JingsongLi commented on issue #9091: [FLINK-13229][table-planner-blink] ExpressionReducer with udf bug in blink

JingsongLi commented on issue #9091: [FLINK-13229][table-planner-blink] ExpressionReducer with udf bug in blink URL: https://github.com/apache/flink/pull/9091#issuecomment-510735657 Test pass in: https://travis-ci.org/JingsongLi/flink/builds/557348029

[jira] [Commented] (FLINK-11654) Multiple transactional KafkaProducers writing to same cluster have clashing transaction IDs

[ https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883503#comment-16883503 ] Jiangjie Qin commented on FLINK-11654: -- [~pnowojski] [~aljoscha] [~dawidwys] [~vicTTim] Do you

[GitHub] [flink] flinkbot edited a comment on issue #9078: [FLINK-13186] Remove dispatcherRetrievalService and dispatcherLeaderRetriever from RestClusterClient

flinkbot edited a comment on issue #9078: [FLINK-13186] Remove dispatcherRetrievalService and dispatcherLeaderRetriever from RestClusterClient URL: https://github.com/apache/flink/pull/9078#issuecomment-510405833 ## CI report: * b73e7985607cee8e9a8abc5b8031e4ee149db514 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9094: [FLINK-13094][state-processor-api] Provide an easy way to read timers using the State Processor API

flinkbot edited a comment on issue #9094: [FLINK-13094][state-processor-api] Provide an easy way to read timers using the State Processor API URL: https://github.com/apache/flink/pull/9094#issuecomment-510560219 ## CI report: * 68c63247fc6c3b60b0cf7afb483cc04ee8f558d0 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9062: [FLINK-13100][network] Fix the bug of throwing IOException while FileChannelBoundedData#nextBuffer

flinkbot edited a comment on issue #9062: [FLINK-13100][network] Fix the bug of throwing IOException while FileChannelBoundedData#nextBuffer URL: https://github.com/apache/flink/pull/9062#issuecomment-510405737 ## CI report: * 106228aa31ad7065acf116029879a00fd998662b : FAILURE

[jira] [Commented] (FLINK-11736) flink kafka producer failed with NOT_LEADER_FOR_PARTITION

[ https://issues.apache.org/jira/browse/FLINK-11736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883502#comment-16883502 ] Jiangjie Qin commented on FLINK-11736: -- [~debugman] NOT_LEADER_FOR_PARTITION indicates that there

[jira] [Comment Edited] (FLINK-11736) flink kafka producer failed with NOT_LEADER_FOR_PARTITION

[ https://issues.apache.org/jira/browse/FLINK-11736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883502#comment-16883502 ] Jiangjie Qin edited comment on FLINK-11736 at 7/12/19 3:50 AM: ---

[jira] [Created] (FLINK-13235) Change the Netty default transport mode to auto

zhijiang created FLINK-13235: Summary: Change the Netty default transport mode to auto Key: FLINK-13235 URL: https://issues.apache.org/jira/browse/FLINK-13235 Project: Flink Issue Type:

[GitHub] [flink] godfreyhe commented on a change in pull request #9035: [FLINK-13168] [table] clarify isBatch/isStreaming/isBounded flag in flink planner and blink planner

godfreyhe commented on a change in pull request #9035: [FLINK-13168] [table] clarify isBatch/isStreaming/isBounded flag in flink planner and blink planner URL: https://github.com/apache/flink/pull/9035#discussion_r302818070 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #9035: [FLINK-13168] [table] clarify isBatch/isStreaming/isBounded flag in flink planner and blink planner

godfreyhe commented on a change in pull request #9035: [FLINK-13168] [table] clarify isBatch/isStreaming/isBounded flag in flink planner and blink planner URL: https://github.com/apache/flink/pull/9035#discussion_r302817944 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #9035: [FLINK-13168] [table] clarify isBatch/isStreaming/isBounded flag in flink planner and blink planner

godfreyhe commented on a change in pull request #9035: [FLINK-13168] [table] clarify isBatch/isStreaming/isBounded flag in flink planner and blink planner URL: https://github.com/apache/flink/pull/9035#discussion_r302816538 ## File path:

[jira] [Commented] (FLINK-13153) SplitAggregateITCase.testMinMaxWithRetraction failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883500#comment-16883500 ] Jark Wu commented on FLINK-13153: - I will look into this soon. >

[jira] [Assigned] (FLINK-13153) SplitAggregateITCase.testMinMaxWithRetraction failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-13153: --- Assignee: Jark Wu > SplitAggregateITCase.testMinMaxWithRetraction failed on Travis >

[GitHub] [flink] flinkbot edited a comment on issue #9078: [FLINK-13186] Remove dispatcherRetrievalService and dispatcherLeaderRetriever from RestClusterClient

flinkbot edited a comment on issue #9078: [FLINK-13186] Remove dispatcherRetrievalService and dispatcherLeaderRetriever from RestClusterClient URL: https://github.com/apache/flink/pull/9078#issuecomment-510405833 ## CI report: * b73e7985607cee8e9a8abc5b8031e4ee149db514 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #8556: [FLINK-12171][Network] Do not limit the network buffer memory by heap size on the TM side

flinkbot edited a comment on issue #8556: [FLINK-12171][Network] Do not limit the network buffer memory by heap size on the TM side URL: https://github.com/apache/flink/pull/8556#issuecomment-510513877 ## CI report: * 4e2a56f6a3a9e57b001ee013d31053222e05ab7a : PENDING

[GitHub] [flink] flinkbot commented on issue #8742: [FLINK-11879] Add validators for the uses of InputSelectable, BoundedOneInput and BoundedMultiInput

flinkbot commented on issue #8742: [FLINK-11879] Add validators for the uses of InputSelectable, BoundedOneInput and BoundedMultiInput URL: https://github.com/apache/flink/pull/8742#issuecomment-510731561 ## CI report: * 3f0c15862fc70f35cd58883ca9635bde1a5fb7ee : PENDING

[GitHub] [flink] flinkbot commented on issue #9097: [flink-11529][docs-zh]Translate the "DataStream API Tutorial" page into Chinese

flinkbot commented on issue #9097: [flink-11529][docs-zh]Translate the "DataStream API Tutorial" page into Chinese URL: https://github.com/apache/flink/pull/9097#issuecomment-510731538 ## CI report: * 9fb0b9288a0b45fe24445e6bd18b7e99c7bd88eb : PENDING

[GitHub] [flink] sunhaibotb commented on issue #8742: [FLINK-11879] Add validators for the uses of InputSelectable, BoundedOneInput and BoundedMultiInput

sunhaibotb commented on issue #8742: [FLINK-11879] Add validators for the uses of InputSelectable, BoundedOneInput and BoundedMultiInput URL: https://github.com/apache/flink/pull/8742#issuecomment-510731040 Thanks for reviewing @pnowojski @1u0 . The code has been updated. Because of

[jira] [Commented] (FLINK-11607) Translate the "DataStream API Tutorial" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883495#comment-16883495 ] LakeShen commented on FLINK-11607: -- Hi [~jark], I have translated this page, if you have free time

[GitHub] [flink] flinkbot commented on issue #9097: [flink-11529][docs-zh]Translate the "DataStream API Tutorial" page into Chinese

flinkbot commented on issue #9097: [flink-11529][docs-zh]Translate the "DataStream API Tutorial" page into Chinese URL: https://github.com/apache/flink/pull/9097#issuecomment-510729249 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] LakeShen opened a new pull request #9097: [flink-11529][docs-zh]Translate the "DataStream API Tutorial" page into Chinese

LakeShen opened a new pull request #9097: [flink-11529][docs-zh]Translate the "DataStream API Tutorial" page into Chinese URL: https://github.com/apache/flink/pull/9097 [flink-11529][docs-zh]Translate the "DataStream API Tutorial" page into Chinese ## What is the purpose of the

[jira] [Commented] (FLINK-13224) TupleTypeInfoBase equals function can't distinguish different struct type

[ https://issues.apache.org/jira/browse/FLINK-13224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883492#comment-16883492 ] forideal commented on FLINK-13224: -- [~twalthr] thank you for your reply! Yes ,this is a problem of the

[GitHub] [flink] flinkbot edited a comment on issue #8556: [FLINK-12171][Network] Do not limit the network buffer memory by heap size on the TM side

flinkbot edited a comment on issue #8556: [FLINK-12171][Network] Do not limit the network buffer memory by heap size on the TM side URL: https://github.com/apache/flink/pull/8556#issuecomment-510513877 ## CI report: * 4e2a56f6a3a9e57b001ee013d31053222e05ab7a : SUCCESS

[jira] [Commented] (FLINK-13150) defaultCatalogName and defaultDatabaseName in TableEnvImpl is not updated after they are updated in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-13150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883489#comment-16883489 ] Xuefu Zhang commented on FLINK-13150: - Hi [~zjffdu], tableEnv.registerDataSet() is meant to register

[GitHub] [flink] KurtYoung commented on a change in pull request #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner

KurtYoung commented on a change in pull request #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner URL: https://github.com/apache/flink/pull/9093#discussion_r302812604 ## File path:

[GitHub] [flink] lirui-apache commented on issue #9039: [FLINK-13170][table-planner] Planner should get table factory from ca…

lirui-apache commented on issue #9039: [FLINK-13170][table-planner] Planner should get table factory from ca… URL: https://github.com/apache/flink/pull/9039#issuecomment-510725336 Thanks @danny0405 , I've updated accordingly. @godfreyhe @bowenli86 please take another look, thanks.

[GitHub] [flink] flinkbot commented on issue #9096: [hotfix][table-planner-blink] Also set batch properties in BatchExecutor

flinkbot commented on issue #9096: [hotfix][table-planner-blink] Also set batch properties in BatchExecutor URL: https://github.com/apache/flink/pull/9096#issuecomment-510724774 ## CI report: * d75ca929b19b054d56332b13374bb3570ccdd179 : PENDING

[jira] [Commented] (FLINK-13132) Allow ClusterEntrypoints use user main method to generate job graph

[ https://issues.apache.org/jira/browse/FLINK-13132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883481#comment-16883481 ] Guowei Ma commented on FLINK-13132: --- [~suez1224] and [~ZhenqiuHuang]. Thanks for your detailed

[GitHub] [flink] danny0405 commented on a change in pull request #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner

danny0405 commented on a change in pull request #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner URL: https://github.com/apache/flink/pull/9093#discussion_r302810245 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner

danny0405 commented on a change in pull request #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner URL: https://github.com/apache/flink/pull/9093#discussion_r302810065 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource

godfreyhe commented on a change in pull request #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource URL: https://github.com/apache/flink/pull/9080#discussion_r30281 ## File path:

[jira] [Comment Edited] (FLINK-11792) Make KafkaConsumer more resilient to Kafka Broker Failures

[ https://issues.apache.org/jira/browse/FLINK-11792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883478#comment-16883478 ] Jiangjie Qin edited comment on FLINK-11792 at 7/12/19 2:38 AM: --- [~knaufk]

[GitHub] [flink] danny0405 commented on a change in pull request #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner

danny0405 commented on a change in pull request #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner URL: https://github.com/apache/flink/pull/9093#discussion_r302809445 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner

danny0405 commented on a change in pull request #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner URL: https://github.com/apache/flink/pull/9093#discussion_r302809209 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner

danny0405 commented on a change in pull request #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner URL: https://github.com/apache/flink/pull/9093#discussion_r302808998 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9043: [FLINK-13165] Complete slot requests in request order

flinkbot edited a comment on issue #9043: [FLINK-13165] Complete slot requests in request order URL: https://github.com/apache/flink/pull/9043#issuecomment-510405816 ## CI report: * a75fa20222c0e9d4bdfbb6eafdfd1831e0ff48e8 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9071: FLINK-13044 [BuildSystem / Shaded] Fix for wrong shading of AWS SDK in flink-s3-fs-hadoop

flinkbot edited a comment on issue #9071: FLINK-13044 [BuildSystem / Shaded] Fix for wrong shading of AWS SDK in flink-s3-fs-hadoop URL: https://github.com/apache/flink/pull/9071#issuecomment-510513895 ## CI report: * 9b3db8abd8b43f98158021a430b00a20fae2b26d : PENDING

[GitHub] [flink] flinkbot commented on issue #9096: [hotfix][table-planner-blink] Also set batch properties in BatchExecutor

flinkbot commented on issue #9096: [hotfix][table-planner-blink] Also set batch properties in BatchExecutor URL: https://github.com/apache/flink/pull/9096#issuecomment-510722541 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] KurtYoung edited a comment on issue #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner

KurtYoung edited a comment on issue #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner URL: https://github.com/apache/flink/pull/9093#issuecomment-510722253 The correct module name are "table-planner" and

[GitHub] [flink] XuPingyong opened a new pull request #9096: [hotfix][table-planner-blink] Also set batch properties in BatchExecutor

XuPingyong opened a new pull request #9096: [hotfix][table-planner-blink] Also set batch properties in BatchExecutor URL: https://github.com/apache/flink/pull/9096 ## What is the purpose of the change Also set batch properties in BatchExecutor ## Does this pull

[GitHub] [flink] KurtYoung commented on issue #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner

KurtYoung commented on issue #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner URL: https://github.com/apache/flink/pull/9093#issuecomment-510722253 The correct module name is "table-planner" and

[GitHub] [flink] KurtYoung commented on a change in pull request #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner

KurtYoung commented on a change in pull request #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner URL: https://github.com/apache/flink/pull/9093#discussion_r302807515 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner

KurtYoung commented on a change in pull request #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner URL: https://github.com/apache/flink/pull/9093#discussion_r302808299 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner

KurtYoung commented on a change in pull request #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner URL: https://github.com/apache/flink/pull/9093#discussion_r302806439 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner

KurtYoung commented on a change in pull request #9093: [FLINK-13220][FLINK-13211] [flink-table] Add drop table support for flink planner and add DDL support for blink planner URL: https://github.com/apache/flink/pull/9093#discussion_r302807499 ## File path:

[jira] [Comment Edited] (FLINK-11792) Make KafkaConsumer more resilient to Kafka Broker Failures

[ https://issues.apache.org/jira/browse/FLINK-11792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883478#comment-16883478 ] Jiangjie Qin edited comment on FLINK-11792 at 7/12/19 2:37 AM: --- [~knaufk]

[jira] [Commented] (FLINK-11792) Make KafkaConsumer more resilient to Kafka Broker Failures

[ https://issues.apache.org/jira/browse/FLINK-11792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883478#comment-16883478 ] Jiangjie Qin commented on FLINK-11792: -- [~knaufk] Thanks for the explanation. There might be some

[jira] [Assigned] (FLINK-13210) Hive connector test should dependent on blink planner instead of legacy planner

[ https://issues.apache.org/jira/browse/FLINK-13210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-13210: Assignee: Rui Li (was: Bowen Li) > Hive connector test should dependent on blink planner

[GitHub] [flink] godfreyhe commented on a change in pull request #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource

godfreyhe commented on a change in pull request #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource URL: https://github.com/apache/flink/pull/9080#discussion_r302807643 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource

godfreyhe commented on a change in pull request #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource URL: https://github.com/apache/flink/pull/9080#discussion_r302806940 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource

godfreyhe commented on a change in pull request #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource URL: https://github.com/apache/flink/pull/9080#discussion_r302806331 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9071: FLINK-13044 [BuildSystem / Shaded] Fix for wrong shading of AWS SDK in flink-s3-fs-hadoop

flinkbot edited a comment on issue #9071: FLINK-13044 [BuildSystem / Shaded] Fix for wrong shading of AWS SDK in flink-s3-fs-hadoop URL: https://github.com/apache/flink/pull/9071#issuecomment-510513895 ## CI report: * 9b3db8abd8b43f98158021a430b00a20fae2b26d : SUCCESS

  1   2   3   4   5   6   7   >