[GitHub] [flink] bowenli86 commented on issue #9085: [FLINK-13215][hive] Mirate ParseUtil usages to URLEncoder

bowenli86 commented on issue #9085: [FLINK-13215][hive] Mirate ParseUtil usages to URLEncoder URL: https://github.com/apache/flink/pull/9085#issuecomment-510610400 @zentol Thanks for the fix! `FlinkStandaloneHiveRunner` runs on test classes annotated with

[GitHub] [flink] flinkbot edited a comment on issue #9082: [FLINK-13207][ml] Add the algorithm of Fast Fourier Transformation(FFT)

flinkbot edited a comment on issue #9082: [FLINK-13207][ml] Add the algorithm of Fast Fourier Transformation(FFT) URL: https://github.com/apache/flink/pull/9082#issuecomment-510415691 ## CI report: * 2b6f431f4f281936034418c8ce64e2e1ba10bd5f : SUCCESS

[jira] [Commented] (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:comment-tabpanel=16883277#comment-16883277 ] Xuefu Zhang commented on FLINK-13206: - Actually no. {{Catalog}} is the parent and so an aggregation

[jira] [Comment Edited] (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:comment-tabpanel=16883277#comment-16883277 ] Xuefu Zhang edited comment on FLINK-13206 at 7/11/19 7:29 PM: -- Actually no.

[GitHub] [flink] flinkbot edited a comment on issue #9082: [FLINK-13207][ml] Add the algorithm of Fast Fourier Transformation(FFT)

flinkbot edited a comment on issue #9082: [FLINK-13207][ml] Add the algorithm of Fast Fourier Transformation(FFT) URL: https://github.com/apache/flink/pull/9082#issuecomment-510415691 ## CI report: * 2b6f431f4f281936034418c8ce64e2e1ba10bd5f : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9067: [FLINK-13069][hive] HiveTableSink should implement OverwritableTableSink

flinkbot edited a comment on issue #9067: [FLINK-13069][hive] HiveTableSink should implement OverwritableTableSink URL: https://github.com/apache/flink/pull/9067#issuecomment-510405753 ## CI report: * 0034a70157b871b401cb1f8cd5a223427cf6223a : 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 edited a comment on issue #9006: [FLINK-13107][table-planner-blink] Copy TableApi IT and UT to Blink planner

flinkbot edited a comment on issue #9006: [FLINK-13107][table-planner-blink] Copy TableApi IT and UT to Blink planner URL: https://github.com/apache/flink/pull/9006#issuecomment-510412446 ## CI report: * 9078425d6977f4a0febb11781c23e21d27dc8be5 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9081: [FLINK-13209] Following FLINK-12951: Remove TableEnvironment#sql and …

flinkbot edited a comment on issue #9081: [FLINK-13209] Following FLINK-12951: Remove TableEnvironment#sql and … URL: https://github.com/apache/flink/pull/9081#issuecomment-510415681 ## CI report: * d50585c74861ac8af2b35e0dae3ca163d4ca3d11 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9067: [FLINK-13069][hive] HiveTableSink should implement OverwritableTableSink

flinkbot edited a comment on issue #9067: [FLINK-13069][hive] HiveTableSink should implement OverwritableTableSink URL: https://github.com/apache/flink/pull/9067#issuecomment-510405753 ## CI report: * 0034a70157b871b401cb1f8cd5a223427cf6223a : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource

flinkbot edited a comment 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-510421703 ## CI report: *

[GitHub] [flink] bowenli86 commented on a change in pull request #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager

bowenli86 commented on a change in pull request #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager URL: https://github.com/apache/flink/pull/8920#discussion_r302718636 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9080: [FLINK-13115] [table-planner-blink] Introduce planner rule to support partition pruning for PartitionableTableSource

flinkbot edited a comment 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-510421703 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #9077: [FLINK-13196][table] Fix Ambiguous column name exception bug for Table API

flinkbot edited a comment on issue #9077: [FLINK-13196][table] Fix Ambiguous column name exception bug for Table API URL: https://github.com/apache/flink/pull/9077#issuecomment-510405822 ## CI report: * 11d60ab9683d4ba90a801af3996a7ab62644dba8 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9084: [FLINK-13213][table-api] Keep MinIdleStateRetentionTime/MaxIdleStateRetentionTime in TableConfig after call toAppendStream/toRetractStream wi

flinkbot edited a comment on issue #9084: [FLINK-13213][table-api] Keep MinIdleStateRetentionTime/MaxIdleStateRetentionTime in TableConfig after call toAppendStream/toRetractStream without QueryConfig parameters URL: https://github.com/apache/flink/pull/9084#issuecomment-510437882 ## CI

[GitHub] [flink] flinkbot edited a comment on issue #9077: [FLINK-13196][table] Fix Ambiguous column name exception bug for Table API

flinkbot edited a comment on issue #9077: [FLINK-13196][table] Fix Ambiguous column name exception bug for Table API URL: https://github.com/apache/flink/pull/9077#issuecomment-510405822 ## CI report: * 11d60ab9683d4ba90a801af3996a7ab62644dba8 : PENDING

[jira] [Updated] (FLINK-13232) TemporalTypesTest>ExpressionTestBase.evaluateExprs in blink planner fails on PST Timezone

[ https://issues.apache.org/jira/browse/FLINK-13232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13232: - Description: TemporalTypesTest>ExpressionTestBase.evaluateExprs in blink planner seems to have a bug

[jira] [Updated] (FLINK-13232) TemporalTypesTest>ExpressionTestBase.evaluateExprs in blink planner fails on PST Timezone

[ https://issues.apache.org/jira/browse/FLINK-13232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13232: - Summary: TemporalTypesTest>ExpressionTestBase.evaluateExprs in blink planner fails on PST Timezone

[jira] [Created] (FLINK-13232) TemporalTypesTest>ExpressionTestBase.evaluateExprs fails on PST Timezone

Bowen Li created FLINK-13232: Summary: TemporalTypesTest>ExpressionTestBase.evaluateExprs fails on PST Timezone Key: FLINK-13232 URL: https://issues.apache.org/jira/browse/FLINK-13232 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #9084: [FLINK-13213][table-api] Keep MinIdleStateRetentionTime/MaxIdleStateRetentionTime in TableConfig after call toAppendStream/toRetractStream wi

flinkbot edited a comment on issue #9084: [FLINK-13213][table-api] Keep MinIdleStateRetentionTime/MaxIdleStateRetentionTime in TableConfig after call toAppendStream/toRetractStream without QueryConfig parameters URL: https://github.com/apache/flink/pull/9084#issuecomment-510437882 ## CI

[GitHub] [flink] flinkbot edited a comment on issue #9085: [FLINK-13215][hive] Mirate ParseUtil usages to URLEncoder

flinkbot edited a comment on issue #9085: [FLINK-13215][hive] Mirate ParseUtil usages to URLEncoder URL: https://github.com/apache/flink/pull/9085#issuecomment-510445809 ## CI report: * 6d1bf89db6821cfc6d9759e5b59404f39a20812f : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9039: [FLINK-13170][table-planner] Planner should get table factory from ca…

flinkbot edited a comment on issue #9039: [FLINK-13170][table-planner] Planner should get table factory from ca… URL: https://github.com/apache/flink/pull/9039#issuecomment-510445729 ## CI report: * a14e955ab6082bbd08fcf9b28a654ab771a57fb2 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9029: [FLINK-13118][jdbc] Introduce JDBC table factory and bridge JDBC table source with streaming table source

flinkbot edited a comment on issue #9029: [FLINK-13118][jdbc] Introduce JDBC table factory and bridge JDBC table source with streaming table source URL: https://github.com/apache/flink/pull/9029#issuecomment-510473983 ## CI report: * 93aef59208dbd8a126b934c438e28ad65cff3ffd :

[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 #9088: [FLINK-13012][hive] Handle default partition name of Hive table

flinkbot edited a comment on issue #9088: [FLINK-13012][hive] Handle default partition name of Hive table URL: https://github.com/apache/flink/pull/9088#issuecomment-510484364 ## CI report: * eac5f74690ddb0b08cb41b029f5b8ac675e63565 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9085: [FLINK-13215][hive] Mirate ParseUtil usages to URLEncoder

flinkbot edited a comment on issue #9085: [FLINK-13215][hive] Mirate ParseUtil usages to URLEncoder URL: https://github.com/apache/flink/pull/9085#issuecomment-510445809 ## CI report: * 6d1bf89db6821cfc6d9759e5b59404f39a20812f : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink

flinkbot edited a comment on issue #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink URL: https://github.com/apache/flink/pull/9089#issuecomment-510488226 ## CI report: * fb34a0f4245ddac5872ea77aad07887a6ff12d11 : FAILURE

[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 #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink

flinkbot edited a comment on issue #9089: [FLINK-13225][table-planner-blink] Introduce type inference for hive functions in blink URL: https://github.com/apache/flink/pull/9089#issuecomment-510488226 ## CI report: * fb34a0f4245ddac5872ea77aad07887a6ff12d11 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9039: [FLINK-13170][table-planner] Planner should get table factory from ca…

flinkbot edited a comment on issue #9039: [FLINK-13170][table-planner] Planner should get table factory from ca… URL: https://github.com/apache/flink/pull/9039#issuecomment-510445729 ## CI report: * a14e955ab6082bbd08fcf9b28a654ab771a57fb2 : PENDING

[GitHub] [flink] XuPingyong commented on a change in pull request #9057: [FLINK-13121] [table-planner-blink] Set batch properties to runtime in blink batch executor

XuPingyong commented on a change in pull request #9057: [FLINK-13121] [table-planner-blink] Set batch properties to runtime in blink batch executor URL: https://github.com/apache/flink/pull/9057#discussion_r302376778 ## File path:

[GitHub] [flink] XuPingyong commented on a change in pull request #9057: [FLINK-13121] [table-planner-blink] Set batch properties to runtime in blink batch executor

XuPingyong commented on a change in pull request #9057: [FLINK-13121] [table-planner-blink] Set batch properties to runtime in blink batch executor URL: https://github.com/apache/flink/pull/9057#discussion_r302376863 ## File path:

[GitHub] [flink] flinkbot commented on issue #8294: [FLINK-12348][table-planner-blink]Use TableConfig in api module to replace TableConfig in blink-planner module.

flinkbot commented on issue #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#issuecomment-510345595 CI report for commit c51af3f0c5298e6a769c9ba84dfac18d2c2074aa: SUCCESS

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

flinkbot commented on issue #9073: [FLINK-13187] Introduce ScheduleMode#LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST URL: https://github.com/apache/flink/pull/9073#issuecomment-510354715 CI report for commit f588483906ba4c4459bf18671f84924a3286: FAILURE

[GitHub] [flink] pnowojski commented on a change in pull request #8925: [FLINK-12852][network] Fix the deadlock occured when requesting exclusive buffers

pnowojski commented on a change in pull request #8925: [FLINK-12852][network] Fix the deadlock occured when requesting exclusive buffers URL: https://github.com/apache/flink/pull/8925#discussion_r302387828 ## File path:

[GitHub] [flink] twalthr commented on issue #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

twalthr commented on issue #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844#issuecomment-510358524 Yes, this was also my intention in my previous comment. `sqlUpdate()` can run multiple statements (DDL and DML)

[jira] [Commented] (FLINK-12858) Potentially not properly working Flink job in case of stop-with-savepoint failure

[ https://issues.apache.org/jira/browse/FLINK-12858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882692#comment-16882692 ] yelun commented on FLINK-12858: --- Hi,[~1u0],can you give more description about this issue,such as

[GitHub] [flink] flinkbot commented on issue #8859: [FLINK-12905][table-planner] Enable querying CatalogViews in legacy planner

flinkbot commented on issue #8859: [FLINK-12905][table-planner] Enable querying CatalogViews in legacy planner URL: https://github.com/apache/flink/pull/8859#issuecomment-510358759 CI report for commit c2adafa7ee87b18ba6af0b5f518251150a8da386: FAILURE

[jira] [Commented] (FLINK-11956) Remove shading from filesystems build

[ https://issues.apache.org/jira/browse/FLINK-11956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882708#comment-16882708 ] Piotr Nowojski commented on FLINK-11956: I've discussed this with [~StephanEwen] and we decided

[jira] [Updated] (FLINK-11956) Remove shading from filesystems build

[ https://issues.apache.org/jira/browse/FLINK-11956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-11956: --- Priority: Critical (was: Blocker) > Remove shading from filesystems build >

[GitHub] [flink] carp84 commented on a change in pull request #9075: [FLINK-10245][hbase] Add an upsert table sink factory for HBase

carp84 commented on a change in pull request #9075: [FLINK-10245][hbase] Add an upsert table sink factory for HBase URL: https://github.com/apache/flink/pull/9075#discussion_r302396500 ## File path:

[GitHub] [flink] carp84 commented on a change in pull request #9075: [FLINK-10245][hbase] Add an upsert table sink factory for HBase

carp84 commented on a change in pull request #9075: [FLINK-10245][hbase] Add an upsert table sink factory for HBase URL: https://github.com/apache/flink/pull/9075#discussion_r302377044 ## File path:

[GitHub] [flink] wuchong commented on issue #9075: [FLINK-10245][hbase] Add an upsert table sink factory for HBase

wuchong commented on issue #9075: [FLINK-10245][hbase] Add an upsert table sink factory for HBase URL: https://github.com/apache/flink/pull/9075#issuecomment-510377192 @JingsongLi @carp84 comments are addressed. Sorry for commits squashed.

[GitHub] [flink] tillrohrmann commented on issue #9059: [FLINK-13141][network] Remove getBufferSize method from BufferPoolFactory

tillrohrmann commented on issue #9059: [FLINK-13141][network] Remove getBufferSize method from BufferPoolFactory URL: https://github.com/apache/flink/pull/9059#issuecomment-510376994 Before merging please make sure that Travis passes @pnowojski. We just broke the master another time due

[GitHub] [flink] KurtYoung closed pull request #9056: [FLINK-13185] [sql-parser][table-planner] Bump Calcite dependency to 1.20.0 in sql parser & flink planner

KurtYoung closed pull request #9056: [FLINK-13185] [sql-parser][table-planner] Bump Calcite dependency to 1.20.0 in sql parser & flink planner URL: https://github.com/apache/flink/pull/9056 This is an automated message from

[jira] [Closed] (FLINK-13185) Bump Calcite dependency to 1.20.0 in sql parser & flink planner

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

[jira] [Commented] (FLINK-11793) Make KafkaProducer more resilient to Kafka Broker Failures

[ https://issues.apache.org/jira/browse/FLINK-11793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882769#comment-16882769 ] Jiangjie Qin commented on FLINK-11793: -- This can probably be done by just make the retry number to

[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=16882771#comment-16882771 ] Konstantin Knauf commented on FLINK-11792: -- [~becket_qin] Thanks for having a look at this.

[jira] [Updated] (FLINK-11793) Make KafkaProducer more resilient to Kafka Broker Failures

[ https://issues.apache.org/jira/browse/FLINK-11793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-11793: - Description: Similar to FLINK-11792 we can make the FlinkKafkaProducer more resilient

[jira] [Updated] (FLINK-11793) Make KafkaProducer more resilient to Kafka Broker Failures

[ https://issues.apache.org/jira/browse/FLINK-11793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-11793: - Description: Similar to FLINK-11792 we can make the FlinkKafkaProducer more resilient

[jira] [Updated] (FLINK-13208) Update Notice file for upgrading calcite to 1.20

[ https://issues.apache.org/jira/browse/FLINK-13208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13208: --- Labels: pull-request-available (was: ) > Update Notice file for upgrading calcite to 1.20

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

flinkbot commented on issue #9039: [FLINK-13170][table-planner] Planner should get table factory from ca… URL: https://github.com/apache/flink/pull/9039#issuecomment-510400931 CI report for commit 8c24249687a431ed5aea74fdd24f2abff7d7088d: FAILURE

[GitHub] [flink] KurtYoung opened a new pull request #9079: [FLINK-13208][table-planner][table-planner-blink] Update Notice files after adding commons-codec to table package.

KurtYoung opened a new pull request #9079: [FLINK-13208][table-planner][table-planner-blink] Update Notice files after adding commons-codec to table package. URL: https://github.com/apache/flink/pull/9079 ## What is the purpose of the change Update Notice files after adding

[GitHub] [flink] danny0405 commented on issue #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

danny0405 commented on issue #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844#issuecomment-510404004 Thanks @fhueske for your nice review comments, i also think we should be caution for adding a pretty new

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

flinkbot commented 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 : PENDING

[GitHub] [flink] flinkbot commented on issue #9009: [FLINK-13133] [docs] Fix small error in PubSub documentation

flinkbot commented on issue #9009: [FLINK-13133] [docs] Fix small error in PubSub documentation URL: https://github.com/apache/flink/pull/9009#issuecomment-510405780 ## CI report: * b8beb837a68a1aec276872c79d300eadd4d0fb4a : PENDING

[GitHub] [flink] flinkbot commented on issue #9056: [FLINK-13185] [sql-parser][table-planner] Bump Calcite dependency to 1.20.0 in sql parser & flink planner

flinkbot commented on issue #9056: [FLINK-13185] [sql-parser][table-planner] Bump Calcite dependency to 1.20.0 in sql parser & flink planner URL: https://github.com/apache/flink/pull/9056#issuecomment-510405716 ## CI report: * e73503e4d0c3a07cc440bff8b0d62eefcb4834ec : PENDING

[GitHub] [flink] flinkbot commented on issue #9074: [FLINK-13198] Introduce TimeInterval in configuration package

flinkbot commented on issue #9074: [FLINK-13198] Introduce TimeInterval in configuration package URL: https://github.com/apache/flink/pull/9074#issuecomment-510405793 ## CI report: * df6685a3394eeea7a6013f2a9f6c1b6bfeac87e5 : PENDING

[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=16882783#comment-16882783 ] Jiangjie Qin commented on FLINK-13083: -- [~Xeli] Just want to check if you have started work on this

[GitHub] [flink] flinkbot commented on issue #9065: [FLINK-13102][travis] Optimize some travis stages by skipping mvn verify if possible

flinkbot commented on issue #9065: [FLINK-13102][travis] Optimize some travis stages by skipping mvn verify if possible URL: https://github.com/apache/flink/pull/9065#issuecomment-510347308 CI report for commit 2e0e53b8f336838bdcca6236913790c144251941: FAILURE

[jira] [Commented] (FLINK-13201) Unstable sql time udf test

[ https://issues.apache.org/jira/browse/FLINK-13201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882697#comment-16882697 ] Jingsong Lee commented on FLINK-13201: -- Looks like there is not output row... The sql of this case

[jira] [Updated] (FLINK-13204) The subscribedPartitionStates should be thread safe.

[ https://issues.apache.org/jira/browse/FLINK-13204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-13204: - Fix Version/s: (was: 1.9.0) > The subscribedPartitionStates should be thread safe. >

[jira] [Updated] (FLINK-13204) The subscribedPartitionStates should be thread safe.

[ https://issues.apache.org/jira/browse/FLINK-13204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-13204: - Affects Version/s: (was: 1.8.0) > The subscribedPartitionStates should be thread safe. >

[jira] [Commented] (FLINK-11768) Update TypeSerializerSnapshotMigrationITCase for Flink 1.8

[ https://issues.apache.org/jira/browse/FLINK-11768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882750#comment-16882750 ] yelun commented on FLINK-11768: --- Hi [~tzulitai],can you give me more about this issue?thanks. > Update

[GitHub] [flink] KurtYoung commented on issue #9056: [FLINK-13185] [sql-parser][table-planner] Bump Calcite dependency to 1.20.0 in sql parser & flink planner

KurtYoung commented on issue #9056: [FLINK-13185] [sql-parser][table-planner] Bump Calcite dependency to 1.20.0 in sql parser & flink planner URL: https://github.com/apache/flink/pull/9056#issuecomment-510388355 > Hi guys, I think this PR changes Flink's dependencies. Whenever we change

[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=16882759#comment-16882759 ] Jiangjie Qin commented on FLINK-11792: -- [~knaufk] This is a little surprising. By design

[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-510392806 CI report for commit be72c6a2ba0a41a1a4819917d2cba5d58b0c6dc8: FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/118705989)

[GitHub] [flink] flinkbot commented on issue #9054: [FLINK-13183][Table]Add a PrintTableSink

flinkbot commented on issue #9054: [FLINK-13183][Table]Add a PrintTableSink URL: https://github.com/apache/flink/pull/9054#issuecomment-510358821 CI report for commit 67460681c852751f60d49993567aae5d9e4f319f: FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/118704853)

[jira] [Updated] (FLINK-12852) [hotfix timeout] Deadlock occurs when requiring exclusive buffer for RemoteInputChannel

[ https://issues.apache.org/jira/browse/FLINK-12852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-12852: --- Summary: [hotfix timeout] Deadlock occurs when requiring exclusive buffer for

[jira] [Closed] (FLINK-13204) The subscribedPartitionStates should be thread safe.

[ https://issues.apache.org/jira/browse/FLINK-13204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin closed FLINK-13204. Resolution: Duplicate I was looking at an outdated code base and the issue has been fixed in

[jira] [Created] (FLINK-13205) Checkpoints/savepoints injection has loose ordering properties when a stop-with-savepoint is triggered

Alex created FLINK-13205: Summary: Checkpoints/savepoints injection has loose ordering properties when a stop-with-savepoint is triggered Key: FLINK-13205 URL: https://issues.apache.org/jira/browse/FLINK-13205

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

zjuwangg created FLINK-13206: Summary: modify 'use database' syntax in SQL CLI to be consistant with standard sql Key: FLINK-13206 URL: https://issues.apache.org/jira/browse/FLINK-13206 Project: Flink

[jira] [Commented] (FLINK-11768) Update TypeSerializerSnapshotMigrationITCase for Flink 1.8

[ https://issues.apache.org/jira/browse/FLINK-11768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882744#comment-16882744 ] vinoyang commented on FLINK-11768: -- Hi [~guanghui] this issue is hard to fix. Maybe [~tzulitai] can

[jira] [Commented] (FLINK-13186) Remove dispatcherRetrievalService and dispatcherLeaderRetriever from RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-13186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882764#comment-16882764 ] vinoyang commented on FLINK-13186: -- Thanks [~till.rohrmann] Have opened a PR. > Remove

[jira] [Updated] (FLINK-13186) Remove dispatcherRetrievalService and dispatcherLeaderRetriever from RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-13186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13186: --- Labels: pull-request-available (was: ) > Remove dispatcherRetrievalService and

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

flinkbot commented on issue #9078: [FLINK-13186] Remove dispatcherRetrievalService and dispatcherLeaderRetriever from RestClusterClient URL: https://github.com/apache/flink/pull/9078#issuecomment-510395226 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot.

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

godfreyhe opened a new 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 ## What is the purpose of the change *Introduce planner rule to

[jira] [Updated] (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 ] ASF GitHub Bot updated FLINK-13115: --- Labels: pull-request-available (was: ) > Introduce planner rule to support partition

[jira] [Commented] (FLINK-12998) Document Plugins mechanism

[ https://issues.apache.org/jira/browse/FLINK-12998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882779#comment-16882779 ] Alex commented on FLINK-12998: -- I'm trying to understand how batch job connectors relate to {{FileSystem}}

[GitHub] [flink] KurtYoung commented on a change in pull request #9036: [FLINK-13112][table-planner-blink] Support LocalZonedTimestampType in blink

KurtYoung commented on a change in pull request #9036: [FLINK-13112][table-planner-blink] Support LocalZonedTimestampType in blink URL: https://github.com/apache/flink/pull/9036#discussion_r302376027 ## File path:

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

bowenli86 edited a comment on issue #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager URL: https://github.com/apache/flink/pull/8920#issuecomment-510350722 Hi @JingsongLi , thanks for the explanation! I think solution II works better for now compared to

[GitHub] [flink] JingsongLi commented on a change in pull request #9075: [FLINK-10245][hbase] Add an upsert table sink factory for HBase

JingsongLi commented on a change in pull request #9075: [FLINK-10245][hbase] Add an upsert table sink factory for HBase URL: https://github.com/apache/flink/pull/9075#discussion_r302370020 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #9075: [FLINK-10245][hbase] Add an upsert table sink factory for HBase

JingsongLi commented on a change in pull request #9075: [FLINK-10245][hbase] Add an upsert table sink factory for HBase URL: https://github.com/apache/flink/pull/9075#discussion_r302385261 ## File path:

[jira] [Commented] (FLINK-12749) Getting Started - Docker Playgrounds - Flink Cluster Playground

[ https://issues.apache.org/jira/browse/FLINK-12749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882682#comment-16882682 ] Robert Metzger commented on FLINK-12749: I'm happy to create an Apache repo for this, but we

[GitHub] [flink] klion26 commented on a change in pull request #9064: [FLINK-13188][Runtime / State Backends][Test] Fix annotation type error in MockTtlStateTest

klion26 commented on a change in pull request #9064: [FLINK-13188][Runtime / State Backends][Test] Fix annotation type error in MockTtlStateTest URL: https://github.com/apache/flink/pull/9064#discussion_r302390170 ## File path:

[jira] [Closed] (FLINK-13141) Remove getBufferSize method from BufferPoolFactory

[ https://issues.apache.org/jira/browse/FLINK-13141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang closed FLINK-13141. Resolution: Resolved Fixed in  b6563e385263beb556ce19855ca6dfdbb7f6c853 > Remove getBufferSize method

[GitHub] [flink] wangyang0918 commented on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

wangyang0918 commented on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-510381735 Hi @HuangZhenQiu After investigation, i got the following conclusions. 1. The the default

[jira] [Updated] (FLINK-13184) Support launching task executors with multi-thread on YARN.

[ https://issues.apache.org/jira/browse/FLINK-13184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13184: -- Issue Type: Improvement (was: Bug) > Support launching task executors with multi-thread on

[jira] [Updated] (FLINK-13208) Update Notice file for upgrading calcite to 1.20

[ https://issues.apache.org/jira/browse/FLINK-13208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13208: --- Summary: Update Notice file for upgrading calcite to 1.20 (was: Add Notice file for upgrading

[jira] [Created] (FLINK-13202) Unstable StandaloneResourceManagerTest

Kurt Young created FLINK-13202: -- Summary: Unstable StandaloneResourceManagerTest Key: FLINK-13202 URL: https://issues.apache.org/jira/browse/FLINK-13202 Project: Flink Issue Type: Test

[GitHub] [flink] pnowojski merged pull request #8925: [FLINK-12852][network] Fix the deadlock occured when requesting exclusive buffers

pnowojski merged pull request #8925: [FLINK-12852][network] Fix the deadlock occured when requesting exclusive buffers URL: https://github.com/apache/flink/pull/8925 This is an automated message from the Apache Git Service.

[jira] [Commented] (FLINK-12939) Translate "Apache Kafka Connector" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-12939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882705#comment-16882705 ] yelun commented on FLINK-12939: --- Hi,[~xujiang],do you still working on this issue? > Translate "Apache

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

gaoyunhaii commented 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-510372551 Very thanks @NicoK for the review and sorry for missing the tests. I will address the

[jira] [Updated] (FLINK-13198) Introduce TimeInterval in configuration package

[ https://issues.apache.org/jira/browse/FLINK-13198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-13198: Description: Similar with MemorySize in the configuration package, we also need to introduce a

[jira] [Commented] (FLINK-11768) Update TypeSerializerSnapshotMigrationITCase for Flink 1.8

[ https://issues.apache.org/jira/browse/FLINK-11768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882735#comment-16882735 ] yelun commented on FLINK-11768: --- Hi，[~yanghua]，I wang to working this issue,can you explain this issue in

[GitHub] [flink] flinkbot commented on issue #9074: [FLINK-13198] Introduce TimeInterval in configuration package

flinkbot commented on issue #9074: [FLINK-13198] Introduce TimeInterval in configuration package URL: https://github.com/apache/flink/pull/9074#issuecomment-510387654 CI report for commit df6685a3394eeea7a6013f2a9f6c1b6bfeac87e5: FAILURE

[jira] [Commented] (FLINK-13158) Remove WebMonitor interface from webmonitor package

[ https://issues.apache.org/jira/browse/FLINK-13158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882766#comment-16882766 ] vinoyang commented on FLINK-13158: -- [~till.rohrmann] WDYT about this issue? > Remove WebMonitor

[jira] [Created] (FLINK-13209) Following FLINK-12951: Remove TableEnvironment#sql and add create table ddl support to sqlUpdate

Danny Chan created FLINK-13209: -- Summary: Following FLINK-12951: Remove TableEnvironment#sql and add create table ddl support to sqlUpdate Key: FLINK-13209 URL: https://issues.apache.org/jira/browse/FLINK-13209

[jira] [Closed] (FLINK-11778) Check and update delivery guarantees in Flink docs

[ https://issues.apache.org/jira/browse/FLINK-11778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin closed FLINK-11778. Resolution: Duplicate > Check and update delivery guarantees in Flink docs >

[GitHub] [flink] yanghua commented on issue #9013: [FLINK-13136] Fix documentation error about stopping job with restful api

yanghua commented on issue #9013: [FLINK-13136] Fix documentation error about stopping job with restful api URL: https://github.com/apache/flink/pull/9013#issuecomment-510399645 Hi @tillrohrmann WDYT about this PR? This is

  1   2   3   4   5   6   7   >