[GitHub] [flink] flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#issuecomment-546219804 ## CI report: * f47a9f60dff6710ce5a7d5fe341a94d0fffb2d6d :

[jira] [Commented] (FLINK-14539) Unique key metadata should be ketp when using concat or concat_ws in some cases

[ https://issues.apache.org/jira/browse/FLINK-14539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962759#comment-16962759 ] Kevin Zhang commented on FLINK-14539: - [~jark] That's good, I'd like to join the discussion by then,

[GitHub] [flink] KevinZwx closed pull request #10015: [FLINK-14539][Table SQL/Planner]Unique key metadata should be ketp wh…

KevinZwx closed pull request #10015: [FLINK-14539][Table SQL/Planner]Unique key metadata should be ketp wh… URL: https://github.com/apache/flink/pull/10015 This is an automated message from the Apache Git Service. To

[jira] [Assigned] (FLINK-14546) Support map type in flink-json

[ https://issues.apache.org/jira/browse/FLINK-14546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang reassigned FLINK-14546: Assignee: Benchao Li > Support map type in flink-json > -- > >

[jira] [Commented] (FLINK-13111) FlinkKinesisConsumer fails with endpoint and region used together

[ https://issues.apache.org/jira/browse/FLINK-13111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962793#comment-16962793 ] Robert Metzger commented on FLINK-13111: [~kanfade]: Could you maybe help the community with a

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r340478205 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r340484430 ## File path:

[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 : FAILURE

[GitHub] [flink] wuchong commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

wuchong commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#discussion_r340485069 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert

flinkbot edited a comment on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert URL: https://github.com/apache/flink/pull/9796#issuecomment-536253430 ## CI report: * 3b84408bb5ee764b1a64103b1f4df3e0ceacaba7

[GitHub] [flink] flinkbot edited a comment on issue #10042: [FLINK-11466][e2e] Implement LocalStandaloneKafkaResource

flinkbot edited a comment on issue #10042: [FLINK-11466][e2e] Implement LocalStandaloneKafkaResource URL: https://github.com/apache/flink/pull/10042#issuecomment-547792578 ## CI report: * b523eace793d9168a2816e50891d6227183a7175 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte…

flinkbot edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte… URL: https://github.com/apache/flink/pull/10035#issuecomment-547440593 ## CI report: * db25eacc6c332f35ea23e583b5363717c0f599da : SUCCESS

[GitHub] [flink] kl0u commented on a change in pull request #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient

kl0u commented on a change in pull request #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient URL: https://github.com/apache/flink/pull/9972#discussion_r340517441 ## File path: flink-clients/src/main/java/org/apache/flink/client/program/ContextEnvironment.java

[GitHub] [flink] kl0u commented on a change in pull request #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient

kl0u commented on a change in pull request #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient URL: https://github.com/apache/flink/pull/9972#discussion_r340515896 ## File path:

[GitHub] [flink] yangjf2019 commented on a change in pull request #9764: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into Chinese

yangjf2019 commented on a change in pull request #9764: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into Chinese URL: https://github.com/apache/flink/pull/9764#discussion_r340525435 ## File path: docs/dev/connectors/kafka.zh.md ## @@ -26,25 +26,20 @@

[jira] [Updated] (FLINK-14439) RestartPipelinedRegionStrategy leverage tracked partition availability for better failover experience in DefaultScheduler

[ https://issues.apache.org/jira/browse/FLINK-14439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14439: Description: In current region failover when using DefaultScheduler, most of the input result partition

[jira] [Assigned] (FLINK-14439) RestartPipelinedRegionStrategy leverage tracked partition availability for better failover experience in DefaultScheduler

[ https://issues.apache.org/jira/browse/FLINK-14439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-14439: Assignee: Zhu Zhu (was: Gary Yao) > RestartPipelinedRegionStrategy leverage tracked partition

[GitHub] [flink] yangjf2019 commented on a change in pull request #9764: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into Chinese

yangjf2019 commented on a change in pull request #9764: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into Chinese URL: https://github.com/apache/flink/pull/9764#discussion_r340525877 ## File path: docs/dev/connectors/kafka.zh.md ## @@ -577,171 +474,101

[jira] [Assigned] (FLINK-14439) RestartPipelinedRegionStrategy leverage tracked partition availability for better failover experience in DefaultScheduler

[ https://issues.apache.org/jira/browse/FLINK-14439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-14439: Assignee: Gary Yao > RestartPipelinedRegionStrategy leverage tracked partition availability for

[GitHub] [flink] zentol commented on a change in pull request #9996: [FLINK-14532][coordination] Split PartitionTracker

zentol commented on a change in pull request #9996: [FLINK-14532][coordination] Split PartitionTracker URL: https://github.com/apache/flink/pull/9996#discussion_r340526135 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte…

flinkbot edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte… URL: https://github.com/apache/flink/pull/10035#issuecomment-547440593 ## CI report: * db25eacc6c332f35ea23e583b5363717c0f599da : SUCCESS

[GitHub] [flink] wuchong commented on a change in pull request #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode

wuchong commented on a change in pull request #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode URL: https://github.com/apache/flink/pull/10013#discussion_r340443213 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r340445716 ## File path:

[jira] [Commented] (FLINK-14539) Unique key metadata should be ketp when using concat or concat_ws in some cases

[ https://issues.apache.org/jira/browse/FLINK-14539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962754#comment-16962754 ] Jark Wu commented on FLINK-14539: - [~KevinZwx], Yes, this is an very important use case and is bothered

[jira] [Created] (FLINK-14566) Enable ResourceSpec to get/set whether managed memory is used

Zhu Zhu created FLINK-14566: --- Summary: Enable ResourceSpec to get/set whether managed memory is used Key: FLINK-14566 URL: https://issues.apache.org/jira/browse/FLINK-14566 Project: Flink Issue

[GitHub] [flink] docete opened a new pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte…

docete opened a new pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte… URL: https://github.com/apache/flink/pull/10035 …rnal representation of TIMESTAMP_WITHOUT_TIME_ZONE ## What is the purpose of the change Introduce Timestamp as internal

[GitHub] [flink] JingsongLi commented on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert

JingsongLi commented on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert URL: https://github.com/apache/flink/pull/9796#issuecomment-547770648 > LGTM, please resolve the conflicts. Rebased.

[GitHub] [flink] flinkbot commented on issue #10039: support referencing function with fully/partially qualified names in SQL[FLINK-14262][table]

flinkbot commented on issue #10039: support referencing function with fully/partially qualified names in SQL[FLINK-14262][table] URL: https://github.com/apache/flink/pull/10039#issuecomment-547770740 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] docete commented on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte…

docete commented on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte… URL: https://github.com/apache/flink/pull/10035#issuecomment-547770564 @JingsongLi @lirui-apache Thanks for your comments and please have another look. @wuchong Could you take a look

[GitHub] [flink] yanghua opened a new pull request #10040: [hotfix] Rename TimeReaderFunction to TimerReaderFunction

yanghua opened a new pull request #10040: [hotfix] Rename TimeReaderFunction to TimerReaderFunction URL: https://github.com/apache/flink/pull/10040 ## What is the purpose of the change *This pull request renames TimeReaderFunction to TimerReaderFunction* ## Brief change

[GitHub] [flink] docete closed pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte…

docete closed pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte… URL: https://github.com/apache/flink/pull/10035 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] JingsongLi commented on a change in pull request #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert

JingsongLi commented on a change in pull request #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert URL: https://github.com/apache/flink/pull/9796#discussion_r340467626 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

wuchong commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#discussion_r340467708 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

wuchong commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#discussion_r340467090 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r340474221 ## File path:

[jira] [Commented] (FLINK-14462) Remove JobGraph#allowQueuedScheduling flag because it is always true

[ https://issues.apache.org/jira/browse/FLINK-14462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962818#comment-16962818 ] Zili Chen commented on FLINK-14462: --- Thanks for your insights. I will start progress now. > Remove

[GitHub] [flink] flinkbot edited a comment on issue #10042: [FLINK-11466][e2e] Implement LocalStandaloneKafkaResource

flinkbot edited a comment on issue #10042: [FLINK-11466][e2e] Implement LocalStandaloneKafkaResource URL: https://github.com/apache/flink/pull/10042#issuecomment-547792578 ## CI report: * b523eace793d9168a2816e50891d6227183a7175 : FAILURE

[GitHub] [flink] zentol merged pull request #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter

zentol merged pull request #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter URL: https://github.com/apache/flink/pull/9859 This is an automated message from the Apache Git Service. To respond to the

[jira] [Updated] (FLINK-11405) Add maxExceptions query parameter

[ https://issues.apache.org/jira/browse/FLINK-11405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11405: - Summary: Add maxExceptions query parameter (was: rest api can show more exceptions by

[GitHub] [flink] flinkbot edited a comment on issue #10041: [hotfix] Fix wrong Java doc comment of BroadcastStateBootstrapFunction.Context

flinkbot edited a comment on issue #10041: [hotfix] Fix wrong Java doc comment of BroadcastStateBootstrapFunction.Context URL: https://github.com/apache/flink/pull/10041#issuecomment-547782526 ## CI report: * 34cb6034520e8d233c005c6a5f35ead6e590c31f : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10040: [hotfix] Rename TimeReaderFunction to TimerReaderFunction

flinkbot edited a comment on issue #10040: [hotfix] Rename TimeReaderFunction to TimerReaderFunction URL: https://github.com/apache/flink/pull/10040#issuecomment-547782455 ## CI report: * 02d52c4bd0528e813c682c13d8477a162d3edcc1 : SUCCESS

[GitHub] [flink] hequn8128 commented on a change in pull request #10016: [FLINK-14547][table-planner-blink] Fix UDF cannot be in the join condition in blink planner

hequn8128 commented on a change in pull request #10016: [FLINK-14547][table-planner-blink] Fix UDF cannot be in the join condition in blink planner URL: https://github.com/apache/flink/pull/10016#discussion_r340531076 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #10016: [FLINK-14547][table-planner-blink] Fix UDF cannot be in the join condition in blink planner

hequn8128 commented on a change in pull request #10016: [FLINK-14547][table-planner-blink] Fix UDF cannot be in the join condition in blink planner URL: https://github.com/apache/flink/pull/10016#discussion_r340529626 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration

flinkbot edited a comment on issue #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration URL: https://github.com/apache/flink/pull/10037#issuecomment-547497114 ## CI report: * d162b69fa12ca127b422d68e79e222415347c24d : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte…

flinkbot edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte… URL: https://github.com/apache/flink/pull/10035#issuecomment-547440593 ## CI report: * db25eacc6c332f35ea23e583b5363717c0f599da : SUCCESS

[GitHub] [flink] TisonKun commented on a change in pull request #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient

TisonKun commented on a change in pull request #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient URL: https://github.com/apache/flink/pull/9972#discussion_r340541566 ## File path:

[GitHub] [flink] kl0u commented on issue #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient

kl0u commented on issue #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient URL: https://github.com/apache/flink/pull/9972#issuecomment-547838827 By the way, now I realised that my comments about the alignment of the exceptions before and after the change seem to be the

[jira] [Updated] (FLINK-14530) Capture partition meta info on TaskExecutor

[ https://issues.apache.org/jira/browse/FLINK-14530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-14530: - Summary: Capture partition meta info on TaskExecutor (was: Capture partition meta info

[GitHub] [flink] flinkbot commented on issue #10044: [FLINK-14440][tests] Annotate BatchFineGrainedRecoveryITCase to enable scheduler NG testing for it

flinkbot commented on issue #10044: [FLINK-14440][tests] Annotate BatchFineGrainedRecoveryITCase to enable scheduler NG testing for it URL: https://github.com/apache/flink/pull/10044#issuecomment-547839037 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot.

[GitHub] [flink] azagrebin commented on a change in pull request #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment

azagrebin commented on a change in pull request #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment URL: https://github.com/apache/flink/pull/8194#discussion_r340553456 ## File path:

[GitHub] [flink] flinkbot commented on issue #10047: [FLINK-14557][python] Cleanup the py4j package

flinkbot commented on issue #10047: [FLINK-14557][python] Cleanup the py4j package URL: https://github.com/apache/flink/pull/10047#issuecomment-547856331 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request.

[GitHub] [flink] lirui-apache commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte…

lirui-apache commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340441559 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

flinkbot edited a comment on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#issuecomment-546947394 ## CI report: *

[jira] [Updated] (FLINK-13869) Hive functions can not work in blink planner stream mode

[ https://issues.apache.org/jira/browse/FLINK-13869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13869: Description: In flink, specifying the StreamTableEnvironment through the EnvironmentSetting using the

[jira] [Commented] (FLINK-13900) Add a built-in "console" sink to print results in console

[ https://issues.apache.org/jira/browse/FLINK-13900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962751#comment-16962751 ] Jark Wu commented on FLINK-13900: - Hi [~xiaodao], this is one of the approaches. However, if the query

[GitHub] [flink] zhuzhurk commented on a change in pull request #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups.

zhuzhurk commented on a change in pull request #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups. URL: https://github.com/apache/flink/pull/9910#discussion_r340451673 ## File path:

[jira] [Updated] (FLINK-14567) Aggregate query with more than two group fields can't be write into HBase sink

[ https://issues.apache.org/jira/browse/FLINK-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14567: Description: If we have a hbase table sink with rowkey of varchar (also primary key) and a column of

[jira] [Commented] (FLINK-14539) Unique key metadata should be ketp when using concat or concat_ws in some cases

[ https://issues.apache.org/jira/browse/FLINK-14539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962767#comment-16962767 ] Jark Wu commented on FLINK-14539: - [~KevinZwx], I created FLINK-14567. > Unique key metadata should be

[GitHub] [flink] KurtYoung commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

KurtYoung commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#discussion_r340463970 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

KurtYoung commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#discussion_r340461613 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r340465694 ## File path:

[GitHub] [flink] KurtYoung commented on issue #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

KurtYoung commented on issue #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#issuecomment-547776674 BTW, there are still some testing failures. This is

[GitHub] [flink] KurtYoung commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

KurtYoung commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#discussion_r340465411 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

KurtYoung commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#discussion_r340460793 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

KurtYoung commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#discussion_r340461377 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r340465554 ## File path:

[GitHub] [flink] yanghua opened a new pull request #10041: [hotfix] Fix wrong Java doc comment of BroadcastStateBootstrapFunction.Context

yanghua opened a new pull request #10041: [hotfix] Fix wrong Java doc comment of BroadcastStateBootstrapFunction.Context URL: https://github.com/apache/flink/pull/10041 ## What is the purpose of the change *This pull request fixed wrong Java doc comment of

[jira] [Commented] (FLINK-14488) Update python table API with temporary tables & views methods

[ https://issues.apache.org/jira/browse/FLINK-14488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962799#comment-16962799 ] Dawid Wysakowicz commented on FLINK-14488: -- [~sunjincheng121] I updated the title of this issue

[GitHub] [flink] flinkbot edited a comment on issue #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode

flinkbot edited a comment on issue #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode URL: https://github.com/apache/flink/pull/10013#issuecomment-546868067 ## CI report: * 8c3d1a58bd358493197697e07b9d6542bf29e59a : FAILURE

[GitHub] [flink] openinx opened a new pull request #10042: [FLINK-11466][e2e] Implement LocalStandaloneKafkaResource

openinx opened a new pull request #10042: [FLINK-11466][e2e] Implement LocalStandaloneKafkaResource URL: https://github.com/apache/flink/pull/10042 ## What is the purpose of the change Rewrite the e2e kafka related test by Java, so that we can move the FLINK-11463 forward.

[jira] [Updated] (FLINK-14488) Update python table API with temporary tables & views methods

[ https://issues.apache.org/jira/browse/FLINK-14488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-14488: - Description: Update python table API with new methods introduced in Java/Scala API

[GitHub] [flink] wuchong commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

wuchong commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#discussion_r340470864 ## File path:

[jira] [Updated] (FLINK-11466) Implement LocalStandaloneKafkaResource

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

[GitHub] [flink] xuyang1706 commented on issue #9082: [FLINK-13207][ml] Add the algorithm of Fast Fourier Transformation(FFT)

xuyang1706 commented on issue #9082: [FLINK-13207][ml] Add the algorithm of Fast Fourier Transformation(FFT) URL: https://github.com/apache/flink/pull/9082#issuecomment-547788706 > Thanks for the contribution @xuyang1706 . I left a few comments with more higher level questions. >

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r340478205 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte…

JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340507045 ## File path:

[GitHub] [flink] docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte…

docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340506966 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte…

JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340505127 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte…

JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340504515 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte…

JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340504434 ## File path:

[jira] [Updated] (FLINK-14439) RestartPipelinedRegionStrategy leverage tracked partition availability for better failover experience in DefaultScheduler

[ https://issues.apache.org/jira/browse/FLINK-14439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14439: Description: In current region failover when using DefaultScheduler, most of the input result partition

[GitHub] [flink] zentol merged pull request #10019: [hotfix][docs] REST label in SSL figure was rotated out of view

zentol merged pull request #10019: [hotfix][docs] REST label in SSL figure was rotated out of view URL: https://github.com/apache/flink/pull/10019 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] GJL commented on issue #9920: [FLINK-14389][runtime] Restore task state before restarting tasks in DefaultScheduler

GJL commented on issue #9920: [FLINK-14389][runtime] Restore task state before restarting tasks in DefaultScheduler URL: https://github.com/apache/flink/pull/9920#issuecomment-547818573 Merging. This is an automated message

[jira] [Updated] (FLINK-12147) InfluxDB throws errors if metric value is NaN/infinity

[ https://issues.apache.org/jira/browse/FLINK-12147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12147: - Release Note: The InfluxDBReporter now silently skips NaN / Inf fields. > InfluxDB

[jira] [Updated] (FLINK-14572) BlobsCleanupITCase failed in Travis stage core - scheduler_ng

[ https://issues.apache.org/jira/browse/FLINK-14572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-14572: - Description: {noformat} java.lang.AssertionError: Expected: is but: was at

[GitHub] [flink] azagrebin commented on a change in pull request #9996: [FLINK-14532][coordination] Split PartitionTracker

azagrebin commented on a change in pull request #9996: [FLINK-14532][coordination] Split PartitionTracker URL: https://github.com/apache/flink/pull/9996#discussion_r340512777 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #9996: [FLINK-14532][coordination] Split PartitionTracker

azagrebin commented on a change in pull request #9996: [FLINK-14532][coordination] Split PartitionTracker URL: https://github.com/apache/flink/pull/9996#discussion_r340513720 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #9996: [FLINK-14532][coordination] Split PartitionTracker

azagrebin commented on a change in pull request #9996: [FLINK-14532][coordination] Split PartitionTracker URL: https://github.com/apache/flink/pull/9996#discussion_r340519053 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #9996: [FLINK-14532][coordination] Split PartitionTracker

azagrebin commented on a change in pull request #9996: [FLINK-14532][coordination] Split PartitionTracker URL: https://github.com/apache/flink/pull/9996#discussion_r340507724 ## File path:

[GitHub] [flink] wsry commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

wsry commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r340531019 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9764: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into Chinese

flinkbot edited a comment on issue #9764: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into Chinese URL: https://github.com/apache/flink/pull/9764#issuecomment-534832110 ## CI report: * 936857429eb4fa0e47440e142a688ac1505d85ec : FAILURE

[jira] [Commented] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962935#comment-16962935 ] Jingsong Lee commented on FLINK-13740: -- Hi [~jark], Have we reached an agreement? Can you assign

[GitHub] [flink] flinkbot edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte…

flinkbot edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte… URL: https://github.com/apache/flink/pull/10035#issuecomment-547440593 ## CI report: * db25eacc6c332f35ea23e583b5363717c0f599da : SUCCESS

[GitHub] [flink] zentol commented on a change in pull request #9797: [FLINK-14059][core] Introduce option allVerticesInSameSlotSharingGroupByDefault in ExecutionConfig

zentol commented on a change in pull request #9797: [FLINK-14059][core] Introduce option allVerticesInSameSlotSharingGroupByDefault in ExecutionConfig URL: https://github.com/apache/flink/pull/9797#discussion_r340554804 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9969: [FLINK-14022][table-planner][table-planner-blink] Add validation check for places where Python ScalarFunction cannot be used

flinkbot edited a comment on issue #9969: [FLINK-14022][table-planner][table-planner-blink] Add validation check for places where Python ScalarFunction cannot be used URL: https://github.com/apache/flink/pull/9969#issuecomment-54497 ## CI report: *

[jira] [Commented] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962940#comment-16962940 ] Jingsong Lee commented on FLINK-13702: -- BinaryLazyFormat is designed for single threaded context.

[GitHub] [flink] flinkbot commented on issue #5866: [FLINK-8047] [http connector] Add HTTP Sink to allow sending output to HTTP server

flinkbot commented on issue #5866: [FLINK-8047] [http connector] Add HTTP Sink to allow sending output to HTTP server URL: https://github.com/apache/flink/pull/5866#issuecomment-547855236 ## CI report: * 6e7c2a3e14cb9599088413973346d550bb4dae99 : UNKNOWN Bot commands

[GitHub] [flink] WeiZhong94 commented on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

WeiZhong94 commented on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#issuecomment-547752070 @flinkbot run travis

[GitHub] [flink] flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#issuecomment-546219804 ## CI report: * f47a9f60dff6710ce5a7d5fe341a94d0fffb2d6d :

[GitHub] [flink] docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte…

docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce Timestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340457641 ## File path:

  1   2   3   4   5   6   7   >