[GitHub] [flink] flinkbot edited a comment on pull request #12422: [FLINK-17901][python] Add module interface in PyFlink

2020-06-02 Thread GitBox
flinkbot edited a comment on pull request #12422: URL: https://github.com/apache/flink/pull/12422#issuecomment-636647115 ## CI report: * 3a387da20f29d9b1f6baf1e57c6d9979d27dd81f Azure:

[jira] [Created] (FLINK-18082) UnsignedTypeConversionITCase stalls in ch.vorburger.mariadb4j.DB.stop

2020-06-02 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-18082: -- Summary: UnsignedTypeConversionITCase stalls in ch.vorburger.mariadb4j.DB.stop Key: FLINK-18082 URL: https://issues.apache.org/jira/browse/FLINK-18082 Project:

[GitHub] [flink] godfreyhe commented on a change in pull request #12431: [FLINK-18055] [sql-client] Fix catalog/database does not exist in sql client

2020-06-02 Thread GitBox
godfreyhe commented on a change in pull request #12431: URL: https://github.com/apache/flink/pull/12431#discussion_r434322529 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParser.java ## @@ -132,11 +132,10 @@ private

[GitHub] [flink] godfreyhe commented on a change in pull request #12431: [FLINK-18055] [sql-client] Fix catalog/database does not exist in sql client

2020-06-02 Thread GitBox
godfreyhe commented on a change in pull request #12431: URL: https://github.com/apache/flink/pull/12431#discussion_r434321402 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParser.java ## @@ -132,11 +132,10 @@ private

[GitHub] [flink] godfreyhe commented on a change in pull request #12431: [FLINK-18055] [sql-client] Fix catalog/database does not exist in sql client

2020-06-02 Thread GitBox
godfreyhe commented on a change in pull request #12431: URL: https://github.com/apache/flink/pull/12431#discussion_r434321402 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParser.java ## @@ -132,11 +132,10 @@ private

[GitHub] [flink] godfreyhe commented on a change in pull request #12431: [FLINK-18055] [sql-client] Fix catalog/database does not exist in sql client

2020-06-02 Thread GitBox
godfreyhe commented on a change in pull request #12431: URL: https://github.com/apache/flink/pull/12431#discussion_r434321402 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParser.java ## @@ -132,11 +132,10 @@ private

[jira] [Commented] (FLINK-18081) Fix broken links in "Kerberos Authentication Setup and Configuration" doc

2020-06-02 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124627#comment-17124627 ] Yangze Guo commented on FLINK-18081: Could someone assign this to me? > Fix broken links in

[jira] [Created] (FLINK-18081) Fix broken links in "Kerberos Authentication Setup and Configuration" doc

2020-06-02 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-18081: -- Summary: Fix broken links in "Kerberos Authentication Setup and Configuration" doc Key: FLINK-18081 URL: https://issues.apache.org/jira/browse/FLINK-18081 Project: Flink

[GitHub] [flink] godfreyhe commented on a change in pull request #12431: [FLINK-18055] [sql-client] Fix catalog/database does not exist in sql client

2020-06-02 Thread GitBox
godfreyhe commented on a change in pull request #12431: URL: https://github.com/apache/flink/pull/12431#discussion_r434321402 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParser.java ## @@ -132,11 +132,10 @@ private

[GitHub] [flink] godfreyhe commented on a change in pull request #12431: [FLINK-18055] [sql-client] Fix catalog/database does not exist in sql client

2020-06-02 Thread GitBox
godfreyhe commented on a change in pull request #12431: URL: https://github.com/apache/flink/pull/12431#discussion_r434321402 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParser.java ## @@ -132,11 +132,10 @@ private

[GitHub] [flink] godfreyhe commented on a change in pull request #12431: [FLINK-18055] [sql-client] Fix catalog/database does not exist in sql client

2020-06-02 Thread GitBox
godfreyhe commented on a change in pull request #12431: URL: https://github.com/apache/flink/pull/12431#discussion_r434321402 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParser.java ## @@ -132,11 +132,10 @@ private

[GitHub] [flink] godfreyhe commented on a change in pull request #12431: [FLINK-18055] [sql-client] Fix catalog/database does not exist in sql client

2020-06-02 Thread GitBox
godfreyhe commented on a change in pull request #12431: URL: https://github.com/apache/flink/pull/12431#discussion_r434321402 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParser.java ## @@ -132,11 +132,10 @@ private

[jira] [Commented] (FLINK-17851) FlinkKafkaProducerITCase.testResumeTransaction:108->assertRecord NoSuchElement

2020-06-02 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124623#comment-17124623 ] Robert Metzger commented on FLINK-17851:

[jira] [Commented] (FLINK-18037) The doc of StreamTaskNetworkInput.java may has a redundant 'status'

2020-06-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124620#comment-17124620 ] Jark Wu commented on FLINK-18037: - I think so. > The doc of StreamTaskNetworkInput.java may has a

[jira] [Commented] (FLINK-17260) StreamingKafkaITCase failure on Azure

2020-06-02 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124621#comment-17124621 ] Robert Metzger commented on FLINK-17260:

[jira] [Assigned] (FLINK-18037) The doc of StreamTaskNetworkInput.java may has a redundant 'status'

2020-06-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-18037: --- Assignee: ZhuShang > The doc of StreamTaskNetworkInput.java may has a redundant 'status' >

[jira] [Commented] (FLINK-17824) "Resuming Savepoint" e2e stalls indefinitely

2020-06-02 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124618#comment-17124618 ] Robert Metzger commented on FLINK-17824: Now with logs:

[GitHub] [flink] wuchong commented on a change in pull request #12436: [FLINK-17847][table sql / planner] ArrayIndexOutOfBoundsException happens in StreamExecCalc operator

2020-06-02 Thread GitBox
wuchong commented on a change in pull request #12436: URL: https://github.com/apache/flink/pull/12436#discussion_r434317766 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala ## @@ -1643,19

[jira] [Commented] (FLINK-15318) RocksDBWriteBatchPerformanceTest.benchMark fails on ppc64le

2020-06-02 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124616#comment-17124616 ] Robert Metzger commented on FLINK-15318:

[jira] [Commented] (FLINK-18071) CoordinatorEventsExactlyOnceITCase.checkListContainsSequence fails on CI

2020-06-02 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124615#comment-17124615 ] Robert Metzger commented on FLINK-18071:

[GitHub] [flink] flinkbot edited a comment on pull request #12144: [FLINK-17384][flink-dist] support read hbase conf dir from flink.conf and change HBaseConfiguration construction.

2020-06-02 Thread GitBox
flinkbot edited a comment on pull request #12144: URL: https://github.com/apache/flink/pull/12144#issuecomment-628475376 ## CI report: * d36b959fb16a91c15babda10dd884cbbdec58420 UNKNOWN * 84f420d9043272150872fe4a32c2eaad2400a750 Azure:

[jira] [Commented] (FLINK-16694) Resuming Externalized Checkpoint end-to-end test failed on travis

2020-06-02 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124613#comment-17124613 ] Robert Metzger commented on FLINK-16694: It happened again, on the Hadoop 3.1.3 profile:

[jira] [Updated] (FLINK-18075) Kafka connector does not call open method of (de)serialization schema

2020-06-02 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-18075: --- Fix Version/s: 1.11.0 > Kafka connector does not call open method of (de)serialization schema >

[jira] [Commented] (FLINK-16572) CheckPubSubEmulatorTest is flaky on Azure

2020-06-02 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124611#comment-17124611 ] Robert Metzger commented on FLINK-16572:

[GitHub] [flink] godfreyhe commented on a change in pull request #12431: [FLINK-18055] [sql-client] Fix catalog/database does not exist in sql client

2020-06-02 Thread GitBox
godfreyhe commented on a change in pull request #12431: URL: https://github.com/apache/flink/pull/12431#discussion_r434317689 ## File path: flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/CliClientTest.java ## @@ -166,6 +167,64 @@ public void

[jira] [Commented] (FLINK-18068) Job scheduling stops but not exits after throwing non-fatal exception

2020-06-02 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124610#comment-17124610 ] Jiayi Liao commented on FLINK-18068: [~azagrebin] Sorry for not checking the JM logs after the

[jira] [Updated] (FLINK-17491) Translate Training page on project website

2020-06-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17491: --- Labels: pull-request-available (was: ) > Translate Training page on project website >

[jira] [Commented] (FLINK-11909) Provide default failure/timeout/backoff handling strategy for AsyncIO functions

2020-06-02 Thread alex zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124607#comment-17124607 ] alex zhu commented on FLINK-11909: -- I believe most flink users (such as me) are focusing on business or

[GitHub] [flink] klion26 commented on a change in pull request #12313: [FLINK-17005][docs] Translate the CREATE TABLE ... LIKE syntax documentation to Chinese

2020-06-02 Thread GitBox
klion26 commented on a change in pull request #12313: URL: https://github.com/apache/flink/pull/12313#discussion_r434312012 ## File path: docs/dev/table/sql/create.zh.md ## @@ -249,59 +257,60 @@ CREATE TABLE Orders_with_watermark ( ); {% endhighlight %} -The merging logic

[GitHub] [flink-web] liying919 opened a new pull request #345: [FLINK-17491] Translate Training page on project website

2020-06-02 Thread GitBox
liying919 opened a new pull request #345: URL: https://github.com/apache/flink-web/pull/345 Translate Training page on project website. This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink-web] klion26 commented on pull request #342: [FLINK-17926] Fix the build problem of docker image

2020-06-02 Thread GitBox
klion26 commented on pull request #342: URL: https://github.com/apache/flink-web/pull/342#issuecomment-637952600 Ahh. maybe there is someting not compatible with `ruby:2.5` docker image, I tried to execute the command `docker run --rm --volume="$PWD:/srv/flink-web" --expose=4000 -p

[GitHub] [flink] flinkbot edited a comment on pull request #12453: [FLINK-18061] [table] TableResult#collect method should return a closeable iterator to avoid resource leak

2020-06-02 Thread GitBox
flinkbot edited a comment on pull request #12453: URL: https://github.com/apache/flink/pull/12453#issuecomment-637941328 ## CI report: * c2f3319900afad80a0f9fac5a8c9aa4cfdadd4ca Azure:

[GitHub] [flink] klion26 commented on a change in pull request #12237: [FLINK-17290] [chinese-translation, Documentation / Training] Transla…

2020-06-02 Thread GitBox
klion26 commented on a change in pull request #12237: URL: https://github.com/apache/flink/pull/12237#discussion_r433926976 ## File path: docs/training/streaming_analytics.zh.md ## @@ -29,123 +29,104 @@ under the License. ## Event Time and Watermarks -### Introduction +

[jira] [Updated] (FLINK-17686) Add document to dataGen, print, blackhole connectors

2020-06-02 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17686: --- Priority: Critical (was: Major) > Add document to dataGen, print, blackhole connectors >

[jira] [Updated] (FLINK-17831) Add documentation for the new Kafka connector

2020-06-02 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17831: --- Priority: Critical (was: Major) > Add documentation for the new Kafka connector >

[jira] [Updated] (FLINK-17776) Add documentation for DDL in hive dialect

2020-06-02 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17776: --- Priority: Critical (was: Major) > Add documentation for DDL in hive dialect >

[GitHub] [flink] flinkbot commented on pull request #12453: [FLINK-18061] [table] TableResult#collect method should return a closeable iterator to avoid resource leak

2020-06-02 Thread GitBox
flinkbot commented on pull request #12453: URL: https://github.com/apache/flink/pull/12453#issuecomment-637941328 ## CI report: * c2f3319900afad80a0f9fac5a8c9aa4cfdadd4ca UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12422: [FLINK-17901][python] Add module interface in PyFlink

2020-06-02 Thread GitBox
flinkbot edited a comment on pull request #12422: URL: https://github.com/apache/flink/pull/12422#issuecomment-636647115 ## CI report: * 3a387da20f29d9b1f6baf1e57c6d9979d27dd81f Azure:

[GitHub] [flink] libenchao commented on a change in pull request #12436: [FLINK-17847][table sql / planner] ArrayIndexOutOfBoundsException happens in StreamExecCalc operator

2020-06-02 Thread GitBox
libenchao commented on a change in pull request #12436: URL: https://github.com/apache/flink/pull/12436#discussion_r434297494 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala ## @@

[jira] [Updated] (FLINK-16975) Add docs for FileSystem connector

2020-06-02 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-16975: --- Priority: Critical (was: Major) > Add docs for FileSystem connector >

[jira] [Updated] (FLINK-17599) Update documents due to FLIP-84

2020-06-02 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17599: --- Priority: Critical (was: Major) > Update documents due to FLIP-84 >

[jira] [Updated] (FLINK-17832) Add documentation for the new Elasticsearch connector

2020-06-02 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17832: --- Priority: Critical (was: Major) > Add documentation for the new Elasticsearch connector >

[jira] [Updated] (FLINK-18065) Add documentation for new scalar/table functions

2020-06-02 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-18065: --- Priority: Critical (was: Major) > Add documentation for new scalar/table functions >

[jira] [Updated] (FLINK-17829) Add documentation for the new JDBC connector

2020-06-02 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17829: --- Priority: Critical (was: Major) > Add documentation for the new JDBC connector >

[jira] [Updated] (FLINK-18066) Add documentation for how to develop a new table source/sink

2020-06-02 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-18066: --- Priority: Critical (was: Major) > Add documentation for how to develop a new table source/sink >

[jira] [Updated] (FLINK-17406) Add documentation about dynamic table options

2020-06-02 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17406: --- Priority: Critical (was: Major) > Add documentation about dynamic table options >

[jira] [Updated] (FLINK-17830) Add documentation for the new HBase connector

2020-06-02 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17830: --- Priority: Critical (was: Major) > Add documentation for the new HBase connector >

[jira] [Updated] (FLINK-17931) Document fromValues clause

2020-06-02 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17931: --- Priority: Critical (was: Major) > Document fromValues clause > -- > >

[jira] [Updated] (FLINK-17834) Add document for Hive streaming source

2020-06-02 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17834: --- Priority: Critical (was: Major) > Add document for Hive streaming source >

[jira] [Updated] (FLINK-17836) Add document for Hive dim join

2020-06-02 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17836: --- Priority: Critical (was: Major) > Add document for Hive dim join > --

[jira] [Updated] (FLINK-17835) Add document for Hive streaming sink

2020-06-02 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-17835: --- Priority: Critical (was: Major) > Add document for Hive streaming sink >

[GitHub] [flink] Jiayi-Liao edited a comment on pull request #12444: [FLINK-18067]Change default value of yarnMinAllocationMB from zero to DEFAULT_RM_S…

2020-06-02 Thread GitBox
Jiayi-Liao edited a comment on pull request #12444: URL: https://github.com/apache/flink/pull/12444#issuecomment-637920335 @wangyang0918 Thanks for your review. I've addressed your comments and also update the description(the CI failure is caused by checkstyle error which is already

[GitHub] [flink] leonardBang commented on a change in pull request #12436: [FLINK-17847][table sql / planner] ArrayIndexOutOfBoundsException happens in StreamExecCalc operator

2020-06-02 Thread GitBox
leonardBang commented on a change in pull request #12436: URL: https://github.com/apache/flink/pull/12436#discussion_r434295803 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala ## @@

[jira] [Commented] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema

2020-06-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124584#comment-17124584 ] Jark Wu commented on FLINK-18049: - Thanks for the discussion and looking into this problem [~openinx].

[GitHub] [flink] dianfu commented on a change in pull request #12422: [FLINK-17901][python] Add module interface in PyFlink

2020-06-02 Thread GitBox
dianfu commented on a change in pull request #12422: URL: https://github.com/apache/flink/pull/12422#discussion_r434294304 ## File path: flink-python/pyflink/table/module.py ## @@ -0,0 +1,45 @@ +

[GitHub] [flink] flinkbot commented on pull request #12453: [FLINK-18061] [table] TableResult#collect method should return a closeable iterator to avoid resource leak

2020-06-02 Thread GitBox
flinkbot commented on pull request #12453: URL: https://github.com/apache/flink/pull/12453#issuecomment-637937506 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Commented] (FLINK-18080) Translate the "Kerberos Authentication Setup and Configuration" page into Chinese

2020-06-02 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124578#comment-17124578 ] Yangze Guo commented on FLINK-18080: Could someone kindly assign this to me? > Translate the

[jira] [Created] (FLINK-18080) Translate the "Kerberos Authentication Setup and Configuration" page into Chinese

2020-06-02 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-18080: -- Summary: Translate the "Kerberos Authentication Setup and Configuration" page into Chinese Key: FLINK-18080 URL: https://issues.apache.org/jira/browse/FLINK-18080

[jira] [Updated] (FLINK-18061) TableResult#collect should return closeable iterator to avoid resource leak

2020-06-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18061: --- Labels: pull-request-available (was: ) > TableResult#collect should return closeable

[jira] [Assigned] (FLINK-18072) HBaseLookupFunction can not work with new internal data structure RowData

2020-06-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-18072: --- Assignee: Leonard Xu > HBaseLookupFunction can not work with new internal data structure RowData >

[GitHub] [flink] godfreyhe opened a new pull request #12453: [FLINK-18061] [table] TableResult#collect method should return a closeable iterator to avoid resource leak

2020-06-02 Thread GitBox
godfreyhe opened a new pull request #12453: URL: https://github.com/apache/flink/pull/12453 ## What is the purpose of the change *as discussed in ML: http://mail-archives.apache.org/mod_mbox/flink-dev/202005.mbox/%3cd4ee47e1-0214-aa2f-f5ac-c9daf708e...@apache.org%3e, we should

[GitHub] [flink] flinkbot edited a comment on pull request #12452: [FLINK-18056][fs-connector] Removing the remaining in-progress file on initialization for hadoop path-based writer

2020-06-02 Thread GitBox
flinkbot edited a comment on pull request #12452: URL: https://github.com/apache/flink/pull/12452#issuecomment-637922636 ## CI report: * 7cb10bd1269179bbe66f5b840c0f0d2494c66a55 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12422: [FLINK-17901][python] Add module interface in PyFlink

2020-06-02 Thread GitBox
flinkbot edited a comment on pull request #12422: URL: https://github.com/apache/flink/pull/12422#issuecomment-636647115 ## CI report: * 3a387da20f29d9b1f6baf1e57c6d9979d27dd81f Azure:

[jira] [Commented] (FLINK-13866) develop testing plan for many Hive versions that we support

2020-06-02 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124577#comment-17124577 ] Rui Li commented on FLINK-13866: We already have the maven profiles to test different hive versions. I

[GitHub] [flink] jxeditor commented on a change in pull request #12431: [FLINK-18055] [sql-client] Fix catalog/database does not exist in sql client

2020-06-02 Thread GitBox
jxeditor commented on a change in pull request #12431: URL: https://github.com/apache/flink/pull/12431#discussion_r434289783 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParser.java ## @@ -132,11 +132,10 @@ private

[jira] [Updated] (FLINK-17733) Add documentation for real-time hive

2020-06-02 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17733: --- Priority: Blocker (was: Major) > Add documentation for real-time hive >

[jira] [Updated] (FLINK-18061) TableResult#collect should return closeable iterator to avoid resource leak

2020-06-02 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-18061: --- Description: as discussed in ML:

[jira] [Updated] (FLINK-15261) add dedicated documentation for blink planner

2020-06-02 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15261: --- Fix Version/s: (was: 1.10.2) (was: 1.11.0) > add dedicated documentation

[jira] [Updated] (FLINK-15242) Add doc to introduce ddls or dmls supported by sql cli

2020-06-02 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15242: --- Priority: Critical (was: Major) > Add doc to introduce ddls or dmls supported by sql cli >

[jira] [Updated] (FLINK-17908) Vague document about Kafka config in SQL-CLI

2020-06-02 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17908: --- Priority: Critical (was: Minor) > Vague document about Kafka config in SQL-CLI >

[jira] [Updated] (FLINK-14256) [Umbrella] Introduce FileSystemTableFactory with partitioned support

2020-06-02 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-14256: --- Summary: [Umbrella] Introduce FileSystemTableFactory with partitioned support (was: Introduce

[jira] [Updated] (FLINK-17635) Add documentation about view support

2020-06-02 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17635: --- Priority: Blocker (was: Major) > Add documentation about view support >

[jira] [Updated] (FLINK-13866) develop testing plan for many Hive versions that we support

2020-06-02 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13866: --- Fix Version/s: (was: 1.11.0) > develop testing plan for many Hive versions that we support >

[jira] [Updated] (FLINK-16448) add documentation for Hive table source and sink parallelism setting strategy

2020-06-02 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16448: --- Component/s: Documentation > add documentation for Hive table source and sink parallelism setting

[jira] [Updated] (FLINK-16448) add documentation for Hive table source and sink parallelism setting strategy

2020-06-02 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16448: --- Priority: Critical (was: Major) > add documentation for Hive table source and sink parallelism

[jira] [Updated] (FLINK-18079) KafkaShuffle Manual Tests

2020-06-02 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-18079: - Description: Manual Tests and Results to demonstrate KafkaShuffle working as expected. (was: Manual

[GitHub] [flink] flinkbot edited a comment on pull request #12452: [FLINK-18056][fs-connector] Removing the remaining in-progress file on initialization for hadoop path-based writer

2020-06-02 Thread GitBox
flinkbot edited a comment on pull request #12452: URL: https://github.com/apache/flink/pull/12452#issuecomment-637922636 ## CI report: * 7cb10bd1269179bbe66f5b840c0f0d2494c66a55 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12451: [FLINK-17857][e2e] Fix Kubernetes and docker e2e tests on Mac OS

2020-06-02 Thread GitBox
flinkbot edited a comment on pull request #12451: URL: https://github.com/apache/flink/pull/12451#issuecomment-637922585 ## CI report: * 4c93b68fa64dd913f53d69dad4eab467e78e6507 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12444: [FLINK-18067]Change default value of yarnMinAllocationMB from zero to DEFAULT_RM_S…

2020-06-02 Thread GitBox
flinkbot edited a comment on pull request #12444: URL: https://github.com/apache/flink/pull/12444#issuecomment-637596755 ## CI report: * 16ec8b694dc07564b09b60040d20b0da9c0e80c4 UNKNOWN * 59c44869c548ce9b1930d5b742a6f2c256c5a5b5 Azure:

[jira] [Created] (FLINK-18079) KafkaShuffle Manual Tests

2020-06-02 Thread Yuan Mei (Jira)
Yuan Mei created FLINK-18079: Summary: KafkaShuffle Manual Tests Key: FLINK-18079 URL: https://issues.apache.org/jira/browse/FLINK-18079 Project: Flink Issue Type: Improvement

[GitHub] [flink] danny0405 commented on a change in pull request #12386: [FLINK-17995][docs][connectors] Redesign Table & SQL Connectors page and add HBase connector documentation

2020-06-02 Thread GitBox
danny0405 commented on a change in pull request #12386: URL: https://github.com/apache/flink/pull/12386#discussion_r434281449 ## File path: docs/dev/table/connectors/index.zh.md ## @@ -0,0 +1,268 @@ +--- +title: "Table & SQL Connectors" +nav-id: sql-connectors +nav-parent_id:

[jira] [Closed] (FLINK-17940) It will throw NullPointerException when write data with Avro format using new property key in SQL-Client

2020-06-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17940. --- Fix Version/s: (was: 1.12.0) Resolution: Duplicate > It will throw NullPointerException when

[jira] [Created] (FLINK-18078) E2E tests manually for Hive streaming dim join

2020-06-02 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-18078: Summary: E2E tests manually for Hive streaming dim join Key: FLINK-18078 URL: https://issues.apache.org/jira/browse/FLINK-18078 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #12444: [FLINK-18067]Change default value of yarnMinAllocationMB from zero to DEFAULT_RM_S…

2020-06-02 Thread GitBox
flinkbot edited a comment on pull request #12444: URL: https://github.com/apache/flink/pull/12444#issuecomment-637596755 ## CI report: * 16ec8b694dc07564b09b60040d20b0da9c0e80c4 UNKNOWN * 59c44869c548ce9b1930d5b742a6f2c256c5a5b5 Azure:

[jira] [Created] (FLINK-18077) E2E tests manually for Hive streaming source

2020-06-02 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-18077: Summary: E2E tests manually for Hive streaming source Key: FLINK-18077 URL: https://issues.apache.org/jira/browse/FLINK-18077 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on pull request #12451: [FLINK-17857][e2e] Fix Kubernetes and docker e2e tests on Mac OS

2020-06-02 Thread GitBox
flinkbot commented on pull request #12451: URL: https://github.com/apache/flink/pull/12451#issuecomment-637922585 ## CI report: * 4c93b68fa64dd913f53d69dad4eab467e78e6507 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-18025) E2E tests manually for Hive streaming sink

2020-06-02 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-18025: - Description: - hive streaming sink failover - hive streaming sink job re-run - hive streaming

[GitHub] [flink] flinkbot commented on pull request #12452: [FLINK-18056][fs-connector] Removing the remaining in-progress file on initialization for hadoop path-based writer

2020-06-02 Thread GitBox
flinkbot commented on pull request #12452: URL: https://github.com/apache/flink/pull/12452#issuecomment-637922636 ## CI report: * 7cb10bd1269179bbe66f5b840c0f0d2494c66a55 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-18076) Sql client uses wrong class loader when parsing queries

2020-06-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124547#comment-17124547 ] Jark Wu commented on FLINK-18076: - >From the recently bug issues, it seems that it's urgent to add

[GitHub] [flink] flinkbot edited a comment on pull request #12144: [FLINK-17384][flink-dist] support read hbase conf dir from flink.conf and change HBaseConfiguration construction.

2020-06-02 Thread GitBox
flinkbot edited a comment on pull request #12144: URL: https://github.com/apache/flink/pull/12144#issuecomment-628475376 ## CI report: * d36b959fb16a91c15babda10dd884cbbdec58420 UNKNOWN * 3df97a6fdb130416fa447295f4ac7eb174be9cc4 Azure:

[jira] [Updated] (FLINK-18025) E2E tests manually for Hive streaming sink

2020-06-02 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-18025: - Summary: E2E tests manually for Hive streaming sink (was: E2E tests manually for Hive

[jira] [Commented] (FLINK-18056) Hive file sink throws exception when the target in-progress file exists.

2020-06-02 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124542#comment-17124542 ] Yun Gao commented on FLINK-18056: - Hi [~sjwiesman] I'm a little confusing on the scenario since when

[GitHub] [flink] Jiayi-Liao commented on pull request #12444: [FLINK-18067]Change default value of yarnMinAllocationMB from zero to DEFAULT_RM_S…

2020-06-02 Thread GitBox
Jiayi-Liao commented on pull request #12444: URL: https://github.com/apache/flink/pull/12444#issuecomment-637920335 @wangyang0918 Thanks for your review. I've addressed your comments and also update the description. Please take another look when you can spare time.

[GitHub] [flink] flinkbot commented on pull request #12452: [FLINK-18056][fs-connector] Removing the remaining in-progress file on initialization for hadoop path-based writer

2020-06-02 Thread GitBox
flinkbot commented on pull request #12452: URL: https://github.com/apache/flink/pull/12452#issuecomment-637919303 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] Jiayi-Liao commented on a change in pull request #12444: [FLINK-18067]Change default value of yarnMinAllocationMB from zero to DEFAULT_RM_S…

2020-06-02 Thread GitBox
Jiayi-Liao commented on a change in pull request #12444: URL: https://github.com/apache/flink/pull/12444#discussion_r434277415 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java ## @@ -508,7 +508,9 @@ public void killCluster(ApplicationId

[jira] [Updated] (FLINK-18056) Hive file sink throws exception when the target in-progress file exists.

2020-06-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18056: --- Labels: pull-request-available (was: ) > Hive file sink throws exception when the target

[GitHub] [flink] dianfu commented on a change in pull request #12422: [FLINK-17901][python] Add module interface in PyFlink

2020-06-02 Thread GitBox
dianfu commented on a change in pull request #12422: URL: https://github.com/apache/flink/pull/12422#discussion_r434276134 ## File path: flink-python/pyflink/table/tests/test_table_environment_api.py ## @@ -628,6 +628,15 @@ def test_table_environment_with_blink_planner(self):

[jira] [Updated] (FLINK-18021) Manually tests for 1.11 SQL features

2020-06-02 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-18021: --- Summary: Manually tests for 1.11 SQL features (was: Complement tests for 1.11 SQL) > Manually

[jira] [Updated] (FLINK-18021) Manually tests for 1.11 SQL features

2020-06-02 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-18021: --- Priority: Critical (was: Major) > Manually tests for 1.11 SQL features >

[jira] [Updated] (FLINK-18021) Manually tests for 1.11 SQL features

2020-06-02 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-18021: --- Priority: Blocker (was: Critical) > Manually tests for 1.11 SQL features >

  1   2   3   4   5   6   7   >