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

flinkbot 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-536253430 ## CI report: * 3b84408bb5ee764b1a64103b1f4df3e0ceacaba7 :

[GitHub] [flink] hequn8128 commented on a change in pull request #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

hequn8128 commented on a change in pull request #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work URL: https://github.com/apache/flink/pull/9766#discussion_r329333978 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

hequn8128 commented on a change in pull request #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work URL: https://github.com/apache/flink/pull/9766#discussion_r329334111 ## File path:

[jira] [Commented] (FLINK-14179) Wrong description of SqlCommand.SHOW_FUNCTIONS

[ https://issues.apache.org/jira/browse/FLINK-14179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940248#comment-16940248 ] Canbin Zheng commented on FLINK-14179: -- [~Tison] [~jark] It's a quite minor change, could any take

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

flinkbot 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-536252529 Thanks a lot for your contribution to the Apache Flink project. I'm the

[jira] [Updated] (FLINK-14253) Add hash distribution and sort grouping only when dynamic partition insert

[ https://issues.apache.org/jira/browse/FLINK-14253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14253: --- Labels: pull-request-available (was: ) > Add hash distribution and sort grouping only when

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

JingsongLi opened a new 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 ## What is the purpose of the change Now in BatchExecSinkRule, we don't have

[GitHub] [flink] flinkbot edited a comment on issue #9762: !IGNORE! ZK 3.5.5 shaded migration

flinkbot edited a comment on issue #9762: !IGNORE! ZK 3.5.5 shaded migration URL: https://github.com/apache/flink/pull/9762#issuecomment-534689957 ## CI report: * cefac57542dbd85a6693f6a1b7c8c90d91e85d30 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/128980426)

[GitHub] [flink] flinkbot edited a comment on issue #9762: !IGNORE! ZK 3.5.5 shaded migration

flinkbot edited a comment on issue #9762: !IGNORE! ZK 3.5.5 shaded migration URL: https://github.com/apache/flink/pull/9762#issuecomment-534689957 ## CI report: * cefac57542dbd85a6693f6a1b7c8c90d91e85d30 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/128980426)

[jira] [Updated] (FLINK-14268) YARN AM endless restarts when using wrong checkpoint path or wrong checkpoint

[ https://issues.apache.org/jira/browse/FLINK-14268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lsw_aka_laplace updated FLINK-14268: Description: I tried to start a  streaming task and restore from checkpoint which it was

[jira] [Updated] (FLINK-14268) YARN AM endless restarts when using wrong checkpoint path or wrong checkpoint

[ https://issues.apache.org/jira/browse/FLINK-14268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lsw_aka_laplace updated FLINK-14268: Description: I tried to start a  streaming task and restore from checkpoint which it was

[jira] [Created] (FLINK-14268) YARN AM endless restarts when using wrong checkpoint path or wrong checkpoint

Lsw_aka_laplace created FLINK-14268: --- Summary: YARN AM endless restarts when using wrong checkpoint path or wrong checkpoint Key: FLINK-14268 URL: https://issues.apache.org/jira/browse/FLINK-14268

[GitHub] [flink] flinkbot edited a comment on issue #9762: !IGNORE! ZK 3.5.5 shaded migration

flinkbot edited a comment on issue #9762: !IGNORE! ZK 3.5.5 shaded migration URL: https://github.com/apache/flink/pull/9762#issuecomment-534689957 ## CI report: * cefac57542dbd85a6693f6a1b7c8c90d91e85d30 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/128980426)

[GitHub] [flink] flinkbot edited a comment on issue #9762: !IGNORE! ZK 3.5.5 shaded migration

flinkbot edited a comment on issue #9762: !IGNORE! ZK 3.5.5 shaded migration URL: https://github.com/apache/flink/pull/9762#issuecomment-534689957 ## CI report: * cefac57542dbd85a6693f6a1b7c8c90d91e85d30 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/128980426)

[jira] [Commented] (FLINK-14117) Translate changes on documentation index page to Chinese

[ https://issues.apache.org/jira/browse/FLINK-14117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940236#comment-16940236 ] Ricco Chen commented on FLINK-14117: Hi, [~fhueske], i want to contribute to Flink. Would u assign

[jira] [Commented] (FLINK-13360) Add documentation for HBase connector for Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-13360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940231#comment-16940231 ] Jark Wu commented on FLINK-13360: - Hi [~lzljs3620320], do you still have time to do this? There are many

[jira] [Commented] (FLINK-13361) Add documentation for JDBC connector for Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-13361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940232#comment-16940232 ] Jark Wu commented on FLINK-13361: - Hi [~lzljs3620320], do you still have time to do this? There are many

[jira] [Commented] (FLINK-14266) Introduce RowCsvInputFormat to new CSV module

[ https://issues.apache.org/jira/browse/FLINK-14266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940230#comment-16940230 ] Jark Wu commented on FLINK-14266: - Can we leverage the existing {{CsvRowDeserializationSchema}} for

[GitHub] [flink] flinkbot edited a comment on issue #9781: [FLINK-14098] Support multiple statements for TableEnvironment.

flinkbot edited a comment on issue #9781: [FLINK-14098] Support multiple statements for TableEnvironment. URL: https://github.com/apache/flink/pull/9781#issuecomment-535813967 ## CI report: * ed0e04d1cd481b096d68d0c9bf36a997dcca2550 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese

flinkbot edited a comment on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese URL: https://github.com/apache/flink/pull/9749#issuecomment-534149758 ## CI report: * 141eb6db531af4b12a9506489f280f180c02a408 : FAILURE

[GitHub] [flink] dianfu commented on a change in pull request #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

dianfu commented on a change in pull request #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work URL: https://github.com/apache/flink/pull/9766#discussion_r329335830 ## File path:

[jira] [Updated] (FLINK-14145) getLatestCheckpoint(true) returns wrong checkpoint

[ https://issues.apache.org/jira/browse/FLINK-14145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14145: Fix Version/s: 1.9.1 1.10.0 > getLatestCheckpoint(true) returns wrong checkpoint >

[jira] [Commented] (FLINK-14145) getLatestCheckpoint(true) returns wrong checkpoint

[ https://issues.apache.org/jira/browse/FLINK-14145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940229#comment-16940229 ] Jark Wu commented on FLINK-14145: - 1.10.0: de92c698bbba464d15de9b70546f1b1ceee5b48b 1.9.1:

[jira] [Commented] (FLINK-14235) Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940228#comment-16940228 ] gaofeilong commented on FLINK-14235: Another instance 

[jira] [Updated] (FLINK-13942) Add Overview page for Getting Started section

[ https://issues.apache.org/jira/browse/FLINK-13942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13942: Fix Version/s: 1.9.1 1.10.0 > Add Overview page for Getting Started section >

[jira] [Commented] (FLINK-10672) Task stuck while writing output to flink

[ https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940226#comment-16940226 ] Yun Gao commented on FLINK-10672: - Hi [~mxm], very thanks for the explanation. Besides, is it possible

[jira] [Commented] (FLINK-13230) Retry acknowledgement calls

[ https://issues.apache.org/jira/browse/FLINK-13230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940225#comment-16940225 ] Jark Wu commented on FLINK-13230: - I moved this issue to 1.9.2 to unblock 1.9.1 as this is not a

[jira] [Commented] (FLINK-14206) Let fullRestart metric count fine grained restarts as well

[ https://issues.apache.org/jira/browse/FLINK-14206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940224#comment-16940224 ] Jark Wu commented on FLINK-14206: - I moved this issue to 1.9.2 to unblock 1.9.1 as this is not a

[jira] [Updated] (FLINK-13230) Retry acknowledgement calls

[ https://issues.apache.org/jira/browse/FLINK-13230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13230: Fix Version/s: (was: 1.9.1) 1.9.2 > Retry acknowledgement calls >

[jira] [Updated] (FLINK-13809) The log directory of Flink Python API is unwritable if it is installed via "sudo"

[ https://issues.apache.org/jira/browse/FLINK-13809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13809: Fix Version/s: (was: 1.9.1) 1.9.2 > The log directory of Flink Python API is

[jira] [Updated] (FLINK-14206) Let fullRestart metric count fine grained restarts as well

[ https://issues.apache.org/jira/browse/FLINK-14206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14206: Fix Version/s: (was: 1.9.1) 1.9.2 > Let fullRestart metric count fine grained

[jira] [Updated] (FLINK-13358) Add documentation for InputFormatTableSource and OutputFormatTableSink

[ https://issues.apache.org/jira/browse/FLINK-13358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13358: Fix Version/s: (was: 1.9.1) 1.9.2 > Add documentation for InputFormatTableSource

[jira] [Updated] (FLINK-14200) Temporal Table Function Joins do not work on Tables (only TableSources) on the query side

[ https://issues.apache.org/jira/browse/FLINK-14200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14200: Fix Version/s: (was: 1.9.1) 1.9.2 > Temporal Table Function Joins do not work on

[jira] [Updated] (FLINK-13520) Add documentation for the different behavior of row count sliding window in blink planner

[ https://issues.apache.org/jira/browse/FLINK-13520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13520: Fix Version/s: (was: 1.9.1) 1.9.2 > Add documentation for the different behavior

[jira] [Updated] (FLINK-13357) Add documentation for PartitionableTableSource and PartitionableTableSink

[ https://issues.apache.org/jira/browse/FLINK-13357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13357: Fix Version/s: (was: 1.9.1) 1.9.2 > Add documentation for PartitionableTableSource

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

[ https://issues.apache.org/jira/browse/FLINK-13083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13083: Fix Version/s: (was: 1.9.1) 1.9.2 > Various improvements PubSub Connector >

[jira] [Updated] (FLINK-14177) Bump Curator From 2.12.0 to 4.2.0

[ https://issues.apache.org/jira/browse/FLINK-14177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14177: Fix Version/s: (was: 1.9.1) 1.9.2 > Bump Curator From 2.12.0 to 4.2.0 >

[jira] [Updated] (FLINK-14030) IS_NULL is optimized to incorrect results

[ https://issues.apache.org/jira/browse/FLINK-14030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14030: Summary: IS_NULL is optimized to incorrect results (was: Nonequivalent conversion happens in Table

[GitHub] [flink] flinkbot edited a comment on issue #9781: [FLINK-14098] Support multiple statements for TableEnvironment.

flinkbot edited a comment on issue #9781: [FLINK-14098] Support multiple statements for TableEnvironment. URL: https://github.com/apache/flink/pull/9781#issuecomment-535813967 ## CI report: * ed0e04d1cd481b096d68d0c9bf36a997dcca2550 : FAILURE

[jira] [Updated] (FLINK-14030) Nonequivalent conversion happens in Table planner

[ https://issues.apache.org/jira/browse/FLINK-14030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14030: Fix Version/s: (was: 1.9.1) > Nonequivalent conversion happens in Table planner >

[jira] [Updated] (FLINK-13827) shell variable should be escaped in start-scala-shell.sh

[ https://issues.apache.org/jira/browse/FLINK-13827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13827: Fix Version/s: (was: 1.9.1) 1.9.2 > shell variable should be escaped in

[jira] [Updated] (FLINK-13692) Make CompletedCheckpointStore backwards compatible?

[ https://issues.apache.org/jira/browse/FLINK-13692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13692: Fix Version/s: (was: 1.9.1) 1.9.2 > Make CompletedCheckpointStore backwards

[jira] [Updated] (FLINK-13940) S3RecoverableWriter causes job to get stuck in recovery

[ https://issues.apache.org/jira/browse/FLINK-13940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13940: Fix Version/s: (was: 1.9.1) 1.9.2 > S3RecoverableWriter causes job to get stuck in

[jira] [Updated] (FLINK-13925) ClassLoader in BlobLibraryCacheManager is not using context class loader

[ https://issues.apache.org/jira/browse/FLINK-13925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13925: Fix Version/s: (was: 1.9.1) 1.9.2 > ClassLoader in BlobLibraryCacheManager is not

[jira] [Updated] (FLINK-13503) Add contract in `LookupableTableSource` to specify the behavior when lookupKeys contains null

[ https://issues.apache.org/jira/browse/FLINK-13503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13503: Fix Version/s: (was: 1.9.1) 1.9.2 > Add contract in `LookupableTableSource` to

[jira] [Updated] (FLINK-13361) Add documentation for JDBC connector for Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-13361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13361: Fix Version/s: (was: 1.9.1) 1.9.2 > Add documentation for JDBC connector for Table

[jira] [Updated] (FLINK-13360) Add documentation for HBase connector for Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-13360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13360: Fix Version/s: (was: 1.9.1) 1.9.2 > Add documentation for HBase connector for

[jira] [Updated] (FLINK-13298) write Chinese documentation and quickstart for Flink-Hive compatibility

[ https://issues.apache.org/jira/browse/FLINK-13298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13298: Fix Version/s: (was: 1.9.1) 1.9.2 > write Chinese documentation and quickstart for

[jira] [Commented] (FLINK-13278) add Chinese documentation for Hive source/sink

[ https://issues.apache.org/jira/browse/FLINK-13278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940223#comment-16940223 ] Jark Wu commented on FLINK-13278: - FLINK-13277 has been merged. So I think we can start the translation.

[jira] [Updated] (FLINK-13278) add Chinese documentation for Hive source/sink

[ https://issues.apache.org/jira/browse/FLINK-13278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13278: Fix Version/s: (was: 1.9.1) 1.9.2 > add Chinese documentation for Hive source/sink

[jira] [Assigned] (FLINK-13278) add Chinese documentation for Hive source/sink

[ https://issues.apache.org/jira/browse/FLINK-13278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-13278: --- Assignee: Zijie Lu > add Chinese documentation for Hive source/sink >

[jira] [Updated] (FLINK-13271) Add documentation for all the new features of blink planner

[ https://issues.apache.org/jira/browse/FLINK-13271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13271: Fix Version/s: (was: 1.9.1) 1.9.2 > Add documentation for all the new features of

[jira] [Updated] (FLINK-13086) add Chinese documentation for catalogs

[ https://issues.apache.org/jira/browse/FLINK-13086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13086: Fix Version/s: (was: 1.9.1) 1.9.2 > add Chinese documentation for catalogs >

[jira] [Updated] (FLINK-14118) Reduce the unnecessary flushing when there is no data available for flush

[ https://issues.apache.org/jira/browse/FLINK-14118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14118: Fix Version/s: (was: 1.8.3) (was: 1.9.1) > Reduce the unnecessary flushing

[jira] [Updated] (FLINK-12894) add Chinese documentation of how to configure and use catalogs in SQL CLI

[ https://issues.apache.org/jira/browse/FLINK-12894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-12894: Fix Version/s: (was: 1.9.1) 1.9.2 > add Chinese documentation of how to configure

[jira] [Commented] (FLINK-14118) Reduce the unnecessary flushing when there is no data available for flush

[ https://issues.apache.org/jira/browse/FLINK-14118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940221#comment-16940221 ] Jark Wu commented on FLINK-14118: - Thanks [~kevin.cyj] and [~pnowojski], as discussed in the issue, I

[jira] [Resolved] (FLINK-14049) Update error message for failed partition updates to include task name

[ https://issues.apache.org/jira/browse/FLINK-14049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-14049. - Fix Version/s: (was: 1.8.3) Resolution: Fixed 1.10.0:

[jira] [Updated] (FLINK-13910) Many serializable classes have no explicit 'serialVersionUID'

[ https://issues.apache.org/jira/browse/FLINK-13910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13910: Fix Version/s: (was: 1.9.1) 1.9.2 > Many serializable classes have no explicit

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

[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13740: Fix Version/s: (was: 1.9.1) 1.9.2 > TableAggregateITCase.testNonkeyedFlatAggregate

[jira] [Updated] (FLINK-13733) FlinkKafkaInternalProducerITCase.testHappyPath fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13733: Fix Version/s: (was: 1.9.1) 1.9.2 > FlinkKafkaInternalProducerITCase.testHappyPath

[jira] [Updated] (FLINK-13708) transformations should be cleared because a table environment could execute multiple job

[ https://issues.apache.org/jira/browse/FLINK-13708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13708: Fix Version/s: (was: 1.9.1) 1.9.2 > transformations should be cleared because a

[GitHub] [flink] flinkbot edited a comment on issue #9781: [FLINK-14098] Support multiple statements for TableEnvironment.

flinkbot edited a comment on issue #9781: [FLINK-14098] Support multiple statements for TableEnvironment. URL: https://github.com/apache/flink/pull/9781#issuecomment-535813967 ## CI report: * ed0e04d1cd481b096d68d0c9bf36a997dcca2550 : FAILURE

[jira] [Commented] (FLINK-13862) Remove or rewrite Execution Plan docs

[ https://issues.apache.org/jira/browse/FLINK-13862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940215#comment-16940215 ] Jark Wu commented on FLINK-13862: - As this is a documentation issue, I would like to not block 1.9.1. So

[jira] [Updated] (FLINK-13862) Remove or rewrite Execution Plan docs

[ https://issues.apache.org/jira/browse/FLINK-13862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13862: Fix Version/s: (was: 1.9.1) 1.9.2 > Remove or rewrite Execution Plan docs >

[GitHub] [flink] flinkbot edited a comment on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese

flinkbot edited a comment on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese URL: https://github.com/apache/flink/pull/9749#issuecomment-534149758 ## CI report: * 141eb6db531af4b12a9506489f280f180c02a408 : FAILURE

[jira] [Commented] (FLINK-14059) Introduce option allSourcesInSamePipelinedRegion in ExecutionConfig

[ https://issues.apache.org/jira/browse/FLINK-14059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940214#comment-16940214 ] Zhu Zhu commented on FLINK-14059: - Thanks [~xintongsong] for the response! Will change

[GitHub] [flink] Mrart edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb …

Mrart edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb … URL: https://github.com/apache/flink/pull/9542#issuecomment-536240909 @zentol , I add a config option like "state.backend.rocksdb.column-family-as-variable" for control the

[GitHub] [flink] Mrart edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb …

Mrart edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb … URL: https://github.com/apache/flink/pull/9542#issuecomment-536240909 @zentol , I have add a config option like "state.backend.rocksdb.column-family-as-variable" for control the

[jira] [Resolved] (FLINK-13277) add documentation of Hive source/sink

[ https://issues.apache.org/jira/browse/FLINK-13277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-13277. - Resolution: Fixed 1.10.0: 3d3e6c11ba2a303dc9a19059406a597cf9348f3f 1.9.1:

[GitHub] [flink] gaofeilong198810 commented on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese

gaofeilong198810 commented on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese URL: https://github.com/apache/flink/pull/9749#issuecomment-536240774 @flinkbot run travis This is an

[GitHub] [flink] hequn8128 commented on a change in pull request #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

hequn8128 commented on a change in pull request #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work URL: https://github.com/apache/flink/pull/9766#discussion_r329309345 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

hequn8128 commented on a change in pull request #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work URL: https://github.com/apache/flink/pull/9766#discussion_r329310180 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

hequn8128 commented on a change in pull request #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work URL: https://github.com/apache/flink/pull/9766#discussion_r329304847 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

hequn8128 commented on a change in pull request #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work URL: https://github.com/apache/flink/pull/9766#discussion_r329310696 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

hequn8128 commented on a change in pull request #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work URL: https://github.com/apache/flink/pull/9766#discussion_r329295245 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9715: [FLINK-13993][runtime] Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

zhuzhurk commented on a change in pull request #9715: [FLINK-13993][runtime] Using FlinkUserCodeClassLoaders to load the user class in the perjob mode URL: https://github.com/apache/flink/pull/9715#discussion_r329319129 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9715: [FLINK-13993][runtime] Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

zhuzhurk commented on a change in pull request #9715: [FLINK-13993][runtime] Using FlinkUserCodeClassLoaders to load the user class in the perjob mode URL: https://github.com/apache/flink/pull/9715#discussion_r329321484 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9715: [FLINK-13993][runtime] Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

zhuzhurk commented on a change in pull request #9715: [FLINK-13993][runtime] Using FlinkUserCodeClassLoaders to load the user class in the perjob mode URL: https://github.com/apache/flink/pull/9715#discussion_r329320115 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9795: [hotfix] [variable name] Typo in Table Planner RuleSets: JOIN_REORDER_PERPARE_RULES

flinkbot edited a comment on issue #9795: [hotfix] [variable name] Typo in Table Planner RuleSets: JOIN_REORDER_PERPARE_RULES URL: https://github.com/apache/flink/pull/9795#issuecomment-536208693 ## CI report: * 1055410a5888dcada8045f57f5100dc09f095db9 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9795: [hotfix] [variable name] Typo in Table Planner RuleSets: JOIN_REORDER_PERPARE_RULES

flinkbot edited a comment on issue #9795: [hotfix] [variable name] Typo in Table Planner RuleSets: JOIN_REORDER_PERPARE_RULES URL: https://github.com/apache/flink/pull/9795#issuecomment-536208693 ## CI report: * 1055410a5888dcada8045f57f5100dc09f095db9 : PENDING

[GitHub] [flink] zhuzhurk commented on a change in pull request #9715: [FLINK-13993][runtime] Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

zhuzhurk commented on a change in pull request #9715: [FLINK-13993][runtime] Using FlinkUserCodeClassLoaders to load the user class in the perjob mode URL: https://github.com/apache/flink/pull/9715#discussion_r329318669 ## File path:

[GitHub] [flink] flinkbot commented on issue #9795: [hotfix] [variable name] Typo in Table Planner RuleSets: JOIN_REORDER_PERPARE_RULES

flinkbot commented on issue #9795: [hotfix] [variable name] Typo in Table Planner RuleSets: JOIN_REORDER_PERPARE_RULES URL: https://github.com/apache/flink/pull/9795#issuecomment-536208693 ## CI report: * 1055410a5888dcada8045f57f5100dc09f095db9 : UNKNOWN

[GitHub] [flink] flinkbot commented on issue #9795: [hotfix] [variable name] Typo in Table Planner RuleSets: JOIN_REORDER_PERPARE_RULES

flinkbot commented on issue #9795: [hotfix] [variable name] Typo in Table Planner RuleSets: JOIN_REORDER_PERPARE_RULES URL: https://github.com/apache/flink/pull/9795#issuecomment-536207542 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] benoitparis opened a new pull request #9795: [hotfix] [variable name] Typo in Table Planner RuleSets: JOIN_REORDER_PERPARE_RULES

benoitparis opened a new pull request #9795: [hotfix] [variable name] Typo in Table Planner RuleSets: JOIN_REORDER_PERPARE_RULES URL: https://github.com/apache/flink/pull/9795 ## What is the purpose of the change Fix a typo

[GitHub] [flink] zhuzhurk commented on a change in pull request #9715: [FLINK-13993][runtime] Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

zhuzhurk commented on a change in pull request #9715: [FLINK-13993][runtime] Using FlinkUserCodeClassLoaders to load the user class in the perjob mode URL: https://github.com/apache/flink/pull/9715#discussion_r329314051 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9715: [FLINK-13993][runtime] Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

zhuzhurk commented on a change in pull request #9715: [FLINK-13993][runtime] Using FlinkUserCodeClassLoaders to load the user class in the perjob mode URL: https://github.com/apache/flink/pull/9715#discussion_r329317178 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9715: [FLINK-13993][runtime] Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

zhuzhurk commented on a change in pull request #9715: [FLINK-13993][runtime] Using FlinkUserCodeClassLoaders to load the user class in the perjob mode URL: https://github.com/apache/flink/pull/9715#discussion_r329317918 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9715: [FLINK-13993][runtime] Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

zhuzhurk commented on a change in pull request #9715: [FLINK-13993][runtime] Using FlinkUserCodeClassLoaders to load the user class in the perjob mode URL: https://github.com/apache/flink/pull/9715#discussion_r329313956 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #9788: [FLINK-14259] Introduce JobManagerRunner interface

TisonKun commented on a change in pull request #9788: [FLINK-14259] Introduce JobManagerRunner interface URL: https://github.com/apache/flink/pull/9788#discussion_r329314554 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerRunnerImpl.java

[GitHub] [flink] TisonKun commented on a change in pull request #9788: [FLINK-14259] Introduce JobManagerRunner interface

TisonKun commented on a change in pull request #9788: [FLINK-14259] Introduce JobManagerRunner interface URL: https://github.com/apache/flink/pull/9788#discussion_r329315033 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java

[GitHub] [flink] TisonKun commented on a change in pull request #9788: [FLINK-14259] Introduce JobManagerRunner interface

TisonKun commented on a change in pull request #9788: [FLINK-14259] Introduce JobManagerRunner interface URL: https://github.com/apache/flink/pull/9788#discussion_r329314925 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerRunnerImpl.java

[GitHub] [flink] TisonKun commented on a change in pull request #9788: [FLINK-14259] Introduce JobManagerRunner interface

TisonKun commented on a change in pull request #9788: [FLINK-14259] Introduce JobManagerRunner interface URL: https://github.com/apache/flink/pull/9788#discussion_r329314681 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerRunnerImpl.java

[jira] [Reopened] (FLINK-14179) Wrong description of SqlCommand.SHOW_FUNCTIONS

[ https://issues.apache.org/jira/browse/FLINK-14179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng reopened FLINK-14179: -- Not merged yet. > Wrong description of SqlCommand.SHOW_FUNCTIONS >

[GitHub] [flink] zhuzhurk commented on a change in pull request #9788: [FLINK-14259] Introduce JobManagerRunner interface

zhuzhurk commented on a change in pull request #9788: [FLINK-14259] Introduce JobManagerRunner interface URL: https://github.com/apache/flink/pull/9788#discussion_r329311666 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobManagerRunnerTest.java

[GitHub] [flink] zhuzhurk commented on a change in pull request #9788: [FLINK-14259] Introduce JobManagerRunner interface

zhuzhurk commented on a change in pull request #9788: [FLINK-14259] Introduce JobManagerRunner interface URL: https://github.com/apache/flink/pull/9788#discussion_r329311362 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9788: [FLINK-14259] Introduce JobManagerRunner interface

zhuzhurk commented on a change in pull request #9788: [FLINK-14259] Introduce JobManagerRunner interface URL: https://github.com/apache/flink/pull/9788#discussion_r329311153 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/JobManagerRunnerFactory.java

[GitHub] [flink] zhuzhurk commented on a change in pull request #9788: [FLINK-14259] Introduce JobManagerRunner interface

zhuzhurk commented on a change in pull request #9788: [FLINK-14259] Introduce JobManagerRunner interface URL: https://github.com/apache/flink/pull/9788#discussion_r329311204 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java

[GitHub] [flink] zhuzhurk commented on a change in pull request #9788: [FLINK-14259] Introduce JobManagerRunner interface

zhuzhurk commented on a change in pull request #9788: [FLINK-14259] Introduce JobManagerRunner interface URL: https://github.com/apache/flink/pull/9788#discussion_r329311666 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobManagerRunnerTest.java

[GitHub] [flink] zhuzhurk commented on a change in pull request #9788: [FLINK-14259] Introduce JobManagerRunner interface

zhuzhurk commented on a change in pull request #9788: [FLINK-14259] Introduce JobManagerRunner interface URL: https://github.com/apache/flink/pull/9788#discussion_r329311362 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9788: [FLINK-14259] Introduce JobManagerRunner interface

zhuzhurk commented on a change in pull request #9788: [FLINK-14259] Introduce JobManagerRunner interface URL: https://github.com/apache/flink/pull/9788#discussion_r329311040 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java ##

  1   2   >