[jira] [Updated] (FLINK-15655) Refactor equals code generation in blink

2020-04-28 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15655: --- Issue Type: Improvement (was: Bug) > Refactor equals code generation in blink >

[jira] [Updated] (FLINK-17433) [umbrella] Real time hive integration

2020-04-28 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17433: --- Issue Type: New Feature (was: Bug) > [umbrella] Real time hive integration >

[GitHub] [flink] hehuiyuan edited a comment on pull request #11870: [FLINK-17117][SQL-Blink]Remove useless cast class code for processElement method in SourceCon…

2020-04-28 Thread GitBox
hehuiyuan edited a comment on pull request #11870: URL: https://github.com/apache/flink/pull/11870#issuecomment-620353134 @KurtYoung @wuchong Hi , do you have any suggestions? This is an automated message from the Apache

[jira] [Commented] (FLINK-16097) Translate "SQL Client" page of "Table API & SQL" into Chinese

2020-04-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094986#comment-17094986 ] Jark Wu commented on FLINK-16097: - [~xbaith], did you create a pull request on GitHub? Is the title

[jira] [Commented] (FLINK-17198) DDL and DML compatibility for Hive connector

2020-04-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094983#comment-17094983 ] Jingsong Lee commented on FLINK-17198: -- Hi [~lirui] can you create all sub-jiras? > DDL and DML

[GitHub] [flink] flinkbot edited a comment on pull request #11903: [FLINK-16661] Add support for Application Mode to YARN.

2020-04-28 Thread GitBox
flinkbot edited a comment on pull request #11903: URL: https://github.com/apache/flink/pull/11903#issuecomment-619010246 ## CI report: * 7f9ea6e4f4a506644e8c79d54eea8cad98b0a6a3 UNKNOWN * 75f0fcc317aa9a1f27a44f321cf4c9428c615017 UNKNOWN *

[jira] [Assigned] (FLINK-17251) supports INSERT statement in TableEnvironment#executeSql and Table#executeInsert api

2020-04-28 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17251: -- Assignee: godfrey he > supports INSERT statement in TableEnvironment#executeSql and >

[jira] [Assigned] (FLINK-17431) Implement table DDLs for Hive dialect part 1

2020-04-28 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17431: -- Assignee: Rui Li > Implement table DDLs for Hive dialect part 1 >

[jira] [Commented] (FLINK-17436) When submitting Python job via "flink run" a IllegalAccessError will be raised due to the package's private access control

2020-04-28 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094982#comment-17094982 ] Wei Zhong commented on FLINK-17436: --- Hi [~chesnay] I have updated the description. The

[GitHub] [flink] JingsongLi commented on a change in pull request #11935: [FLINK-17431][sql-parser-hive][hive] Implement table DDLs for Hive di…

2020-04-28 Thread GitBox
JingsongLi commented on a change in pull request #11935: URL: https://github.com/apache/flink/pull/11935#discussion_r417025603 ## File path: flink-table/flink-sql-parser-hive/src/main/java/org/apache/flink/sql/parser/hive/ddl/SqlCreateHiveTable.java ## @@ -0,0 +1,467 @@ +/* +

[jira] [Updated] (FLINK-17446) Blink supports cube and window together in group by

2020-04-28 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-17446: Description:       Blink planner supports CUBE. CUBE can be used together with a field but not window. For

[jira] [Created] (FLINK-17446) Blink supports cube and window together in group by

2020-04-28 Thread Liu (Jira)
Liu created FLINK-17446: --- Summary: Blink supports cube and window together in group by Key: FLINK-17446 URL: https://issues.apache.org/jira/browse/FLINK-17446 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-17431) Implement table DDLs for Hive dialect part 1

2020-04-28 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-17431: Component/s: Table SQL / API Connectors / Hive > Implement table DDLs for Hive

[jira] [Updated] (FLINK-17436) When submitting Python job via "flink run" a IllegalAccessError will be raised due to the package's private access control

2020-04-28 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-17436: -- Description: Currently when submitting Python job via "flink run" a IllegalAccessError will be

[jira] [Assigned] (FLINK-17436) When submitting Python job via "flink run" a IllegalAccessError will be raised due to the package's private access control

2020-04-28 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17436: --- Assignee: Wei Zhong > When submitting Python job via "flink run" a IllegalAccessError will be >

[jira] [Updated] (FLINK-17436) When submitting Python job via "flink run" a IllegalAccessError will be raised due to the package's private access control

2020-04-28 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17436: Fix Version/s: 1.11.0 > When submitting Python job via "flink run" a IllegalAccessError will be > raised

[jira] [Updated] (FLINK-17285) Translate "Python Table API" page into Chinese

2020-04-28 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-17285: Component/s: API / Python > Translate "Python Table API" page into Chinese >

[jira] [Updated] (FLINK-15745) KafkaITCase.testKeyValueSupport failure due to assertion error.

2020-04-28 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-15745: - Issue Type: Bug (was: Improvement) > KafkaITCase.testKeyValueSupport failure due to assertion

[jira] [Updated] (FLINK-15745) KafkaITCase.testKeyValueSupport failure due to assertion error.

2020-04-28 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-15745: - Fix Version/s: 1.11.0 > KafkaITCase.testKeyValueSupport failure due to assertion error. >

[jira] [Commented] (FLINK-11072) KafkaITCase.testKeyValueSupport failure

2020-04-28 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094950#comment-17094950 ] Jiangjie Qin commented on FLINK-11072: -- FLINK-15745 has been created for the new failure cause

[jira] [Closed] (FLINK-11072) KafkaITCase.testKeyValueSupport failure

2020-04-28 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin closed FLINK-11072. Resolution: Fixed > KafkaITCase.testKeyValueSupport failure >

[jira] [Commented] (FLINK-15778) SQL Client end-to-end test for Kafka 0.10 nightly run hung on travis

2020-04-28 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094946#comment-17094946 ] Jiangjie Qin commented on FLINK-15778: -- >From the log it is hard to tell what happened. Some guess

[GitHub] [flink] flinkbot edited a comment on pull request #11903: [FLINK-16661] Add support for Application Mode to YARN.

2020-04-28 Thread GitBox
flinkbot edited a comment on pull request #11903: URL: https://github.com/apache/flink/pull/11903#issuecomment-619010246 ## CI report: * 7f9ea6e4f4a506644e8c79d54eea8cad98b0a6a3 UNKNOWN * 75f0fcc317aa9a1f27a44f321cf4c9428c615017 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #11903: [FLINK-16661] Add support for Application Mode to YARN.

2020-04-28 Thread GitBox
flinkbot edited a comment on pull request #11903: URL: https://github.com/apache/flink/pull/11903#issuecomment-619010246 ## CI report: * f12169b74a4545047cca830df5006c2c9ee877ce Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/162254032) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11903: [FLINK-16661] Add support for Application Mode to YARN.

2020-04-28 Thread GitBox
flinkbot edited a comment on pull request #11903: URL: https://github.com/apache/flink/pull/11903#issuecomment-619010246 ## CI report: * f12169b74a4545047cca830df5006c2c9ee877ce Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/162254032) Azure:

[GitHub] [flink] kl0u commented on pull request #11903: [FLINK-16661] Add support for Application Mode to YARN.

2020-04-28 Thread GitBox
kl0u commented on pull request #11903: URL: https://github.com/apache/flink/pull/11903#issuecomment-620882800 @wangyang0918 thanks a lot for the comments. I integrated them. As for `run-application` command and the `--executor`, they are not meant to be combined. The `embedded`

[GitHub] [flink] kl0u commented on a change in pull request #11903: [FLINK-16661] Add support for Application Mode to YARN.

2020-04-28 Thread GitBox
kl0u commented on a change in pull request #11903: URL: https://github.com/apache/flink/pull/11903#discussion_r416954031 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java ## @@ -691,11 +716,15 @@ private ApplicationReport startAppMaster(

[jira] [Created] (FLINK-17445) Allow OperatorTransformation to bootstrapWith a Scala DataSet

2020-04-28 Thread Brandon Bevans (Jira)
Brandon Bevans created FLINK-17445: -- Summary: Allow OperatorTransformation to bootstrapWith a Scala DataSet Key: FLINK-17445 URL: https://issues.apache.org/jira/browse/FLINK-17445 Project: Flink

[GitHub] [flink] kl0u commented on a change in pull request #11903: [FLINK-16661] Add support for Application Mode to YARN.

2020-04-28 Thread GitBox
kl0u commented on a change in pull request #11903: URL: https://github.com/apache/flink/pull/11903#discussion_r416944774 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationDispatcherBootstrap.java ## @@ -130,12 +132,17 @@

[jira] [Updated] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

2020-04-28 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17444: --- Fix Version/s: 1.11.0 > StreamingFileSink Azure HadoopRecoverableWriter class missing. >

[jira] [Updated] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

2020-04-28 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17444: --- Priority: Critical (was: Major) > StreamingFileSink Azure HadoopRecoverableWriter class

[jira] [Updated] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

2020-04-28 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17444: --- Description: Hello, I was recently attempting to use the Streaming File Sink to store data

[jira] [Updated] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

2020-04-28 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17444: --- Description: Hello, I was recently attempting to use the Streaming File Sink to store data

[jira] [Updated] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

2020-04-28 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17444: --- Component/s: (was: API / DataStream) FileSystems > StreamingFileSink

[jira] [Updated] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

2020-04-28 Thread Marie May (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marie May updated FLINK-17444: -- Description: Hello, I was recently attempting to use the Streaming File Sink to store data to Azure

[jira] [Updated] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

2020-04-28 Thread Marie May (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marie May updated FLINK-17444: -- Summary: StreamingFileSink Azure HadoopRecoverableWriter class missing. (was: Flink

[jira] [Created] (FLINK-17444) Flink StreamingFileSink Azure HadoopRecoverableWriter is missing.

2020-04-28 Thread Marie May (Jira)
Marie May created FLINK-17444: - Summary: Flink StreamingFileSink Azure HadoopRecoverableWriter is missing. Key: FLINK-17444 URL: https://issues.apache.org/jira/browse/FLINK-17444 Project: Flink

[jira] [Commented] (FLINK-11388) Add an OSS RecoverableWriter

2020-04-28 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094854#comment-17094854 ] Kostas Kloudas commented on FLINK-11388: [~wujinhu] can I close this issue so that we can also

[jira] [Reopened] (FLINK-10114) Support Orc for StreamingFileSink

2020-04-28 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reopened FLINK-10114: > Support Orc for StreamingFileSink > - > >

[jira] [Closed] (FLINK-10114) Support Orc for StreamingFileSink

2020-04-28 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-10114. -- Resolution: Implemented Merged on master with 5d9a9b85edf4994f05518f5cbaf6cd3e2888ae43 >

[jira] [Closed] (FLINK-10114) Support Orc for StreamingFileSink

2020-04-28 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-10114. -- Resolution: Fixed Merged on master with 5d9a9b85edf4994f05518f5cbaf6cd3e2888ae43 > Support

[jira] [Updated] (FLINK-10114) Support Orc for StreamingFileSink

2020-04-28 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-10114: --- Fix Version/s: 1.11.0 > Support Orc for StreamingFileSink >

[jira] [Updated] (FLINK-10114) Support Orc for StreamingFileSink

2020-04-28 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-10114: --- Affects Version/s: 1.11.0 > Support Orc for StreamingFileSink >

[GitHub] [flink] flinkbot edited a comment on pull request #11937: [FLINK-16080]Translate "SQL Client" page of "Table API & SQL" into Chinese

2020-04-28 Thread GitBox
flinkbot edited a comment on pull request #11937: URL: https://github.com/apache/flink/pull/11937#issuecomment-620730732 ## CI report: * 17e3e18215e538e202180c9cf06af21c739a0294 Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/162509887) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11936: [FLINK-17386][Security][hotfix] fix LinkageError not captured

2020-04-28 Thread GitBox
flinkbot edited a comment on pull request #11936: URL: https://github.com/apache/flink/pull/11936#issuecomment-620683562 ## CI report: * a08eef1a61ad744aa4f735d281657d0fcba5308a Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162464560) Azure:

[jira] [Comment Edited] (FLINK-17364) Support StreamingFileSink in PrestoS3FileSystem

2020-04-28 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094843#comment-17094843 ] Kostas Kloudas edited comment on FLINK-17364 at 4/28/20, 8:05 PM: --

[jira] [Commented] (FLINK-17364) Support StreamingFileSink in PrestoS3FileSystem

2020-04-28 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094843#comment-17094843 ] Kostas Kloudas commented on FLINK-17364: [~qqibrow] sorry for the delay, I will check it in the

[GitHub] [flink] flinkbot edited a comment on pull request #11938: [FLINK-17443] [runtime] Flink's ZK in HA mode setup is unable to start up if any of the zk hosts are unreachable

2020-04-28 Thread GitBox
flinkbot edited a comment on pull request #11938: URL: https://github.com/apache/flink/pull/11938#issuecomment-620811383 ## CI report: * 2fea9756d8fb55177619e3bf14c19d53d4612148 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/162514886) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11937: [FLINK-16080]Translate "SQL Client" page of "Table API & SQL" into Chinese

2020-04-28 Thread GitBox
flinkbot edited a comment on pull request #11937: URL: https://github.com/apache/flink/pull/11937#issuecomment-620730732 ## CI report: * 17e3e18215e538e202180c9cf06af21c739a0294 Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/162509887) Azure:

[GitHub] [flink] flinkbot commented on pull request #11938: [FLINK-17443] [runtime] Flink's ZK in HA mode setup is unable to start up if any of the zk hosts are unreachable

2020-04-28 Thread GitBox
flinkbot commented on pull request #11938: URL: https://github.com/apache/flink/pull/11938#issuecomment-620811383 ## CI report: * 2fea9756d8fb55177619e3bf14c19d53d4612148 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #11937: [FLINK-16080]Translate "SQL Client" page of "Table API & SQL" into Chinese

2020-04-28 Thread GitBox
flinkbot edited a comment on pull request #11937: URL: https://github.com/apache/flink/pull/11937#issuecomment-620730732 ## CI report: * c3c2ab4754a8bdd448656e75b9c5968ef5d58e9b Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162483473) Azure:

[jira] [Assigned] (FLINK-17285) Translate "Python Table API" page into Chinese

2020-04-28 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson reassigned FLINK-17285: -- Assignee: Zixuan Rao > Translate "Python Table API" page into Chinese >

[GitHub] [flink] flinkbot commented on pull request #11938: [FLINK-17443] [runtime] Flink's ZK in HA mode setup is unable to start up if any of the zk hosts are unreachable

2020-04-28 Thread GitBox
flinkbot commented on pull request #11938: URL: https://github.com/apache/flink/pull/11938#issuecomment-620805908 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] [Updated] (FLINK-17443) Flink's ZK in HA mode setup is unable to start up if any of the zk hosts are unreachable

2020-04-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17443: --- Labels: pull-request-available (was: ) > Flink's ZK in HA mode setup is unable to start up

[GitHub] [flink] piyushnarang opened a new pull request #11938: [FLINK-17443] [runtime] Flink's ZK in HA mode setup is unable to start up if any of the zk hosts are unreachable

2020-04-28 Thread GitBox
piyushnarang opened a new pull request #11938: URL: https://github.com/apache/flink/pull/11938 ## What is the purpose of the change Flink clusters using zookeeper in HA will not startup if any of the zookeeper hosts passed in the "high-availability.zookeeper.quorum" config

[GitHub] [flink] flinkbot edited a comment on pull request #11937: [FLINK-16080]Translate "SQL Client" page of "Table API & SQL" into Chinese

2020-04-28 Thread GitBox
flinkbot edited a comment on pull request #11937: URL: https://github.com/apache/flink/pull/11937#issuecomment-620730732 ## CI report: * c3c2ab4754a8bdd448656e75b9c5968ef5d58e9b Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162483473) Azure:

[jira] [Created] (FLINK-17443) Flink's ZK in HA mode setup is unable to start up if any of the zk hosts are unreachable

2020-04-28 Thread Piyush Narang (Jira)
Piyush Narang created FLINK-17443: - Summary: Flink's ZK in HA mode setup is unable to start up if any of the zk hosts are unreachable Key: FLINK-17443 URL: https://issues.apache.org/jira/browse/FLINK-17443

[GitHub] [flink] XBaith commented on a change in pull request #11808: [FLINK-16155][docs-zh] Translate "Operator/Process Function" page into Chinese

2020-04-28 Thread GitBox
XBaith commented on a change in pull request #11808: URL: https://github.com/apache/flink/pull/11808#discussion_r416853693 ## File path: docs/dev/stream/operators/process_function.zh.md ## @@ -26,66 +26,65 @@ under the License. * This will be replaced by the TOC {:toc} -##

[GitHub] [flink] XBaith commented on a change in pull request #11808: [FLINK-16155][docs-zh] Translate "Operator/Process Function" page into Chinese

2020-04-28 Thread GitBox
XBaith commented on a change in pull request #11808: URL: https://github.com/apache/flink/pull/11808#discussion_r416852771 ## File path: docs/dev/stream/operators/process_function.zh.md ## @@ -196,7 +195,7 @@ val result: DataStream[Tuple2[String, Long]] = stream

[GitHub] [flink] XBaith commented on a change in pull request #11808: [FLINK-16155][docs-zh] Translate "Operator/Process Function" page into Chinese

2020-04-28 Thread GitBox
XBaith commented on a change in pull request #11808: URL: https://github.com/apache/flink/pull/11808#discussion_r416852450 ## File path: docs/dev/stream/operators/process_function.zh.md ## @@ -121,7 +120,7 @@ public class CountWithTimestamp { } /** - * The implementation

[GitHub] [flink] XBaith commented on a change in pull request #11808: [FLINK-16155][docs-zh] Translate "Operator/Process Function" page into Chinese

2020-04-28 Thread GitBox
XBaith commented on a change in pull request #11808: URL: https://github.com/apache/flink/pull/11808#discussion_r416852273 ## File path: docs/dev/stream/operators/process_function.zh.md ## @@ -140,23 +139,23 @@ public class CountWithTimeoutFunction Context ctx,

[GitHub] [flink] XBaith commented on a change in pull request #11808: [FLINK-16155][docs-zh] Translate "Operator/Process Function" page into Chinese

2020-04-28 Thread GitBox
XBaith commented on a change in pull request #11808: URL: https://github.com/apache/flink/pull/11808#discussion_r416851827 ## File path: docs/dev/stream/operators/process_function.zh.md ## @@ -215,18 +214,18 @@ class CountWithTimeoutFunction extends

[GitHub] [flink] XBaith commented on a change in pull request #11808: [FLINK-16155][docs-zh] Translate "Operator/Process Function" page into Chinese

2020-04-28 Thread GitBox
XBaith commented on a change in pull request #11808: URL: https://github.com/apache/flink/pull/11808#discussion_r416851121 ## File path: docs/dev/stream/operators/process_function.zh.md ## @@ -284,30 +282,31 @@ override def onTimer(timestamp: Long, ctx: OnTimerContext, out:

[GitHub] [flink] XBaith commented on a change in pull request #11808: [FLINK-16155][docs-zh] Translate "Operator/Process Function" page into Chinese

2020-04-28 Thread GitBox
XBaith commented on a change in pull request #11808: URL: https://github.com/apache/flink/pull/11808#discussion_r416851300 ## File path: docs/dev/stream/operators/process_function.zh.md ## @@ -284,30 +282,31 @@ override def onTimer(timestamp: Long, ctx: OnTimerContext, out:

[GitHub] [flink] XBaith commented on a change in pull request #11808: [FLINK-16155][docs-zh] Translate "Operator/Process Function" page into Chinese

2020-04-28 Thread GitBox
XBaith commented on a change in pull request #11808: URL: https://github.com/apache/flink/pull/11808#discussion_r416850714 ## File path: docs/dev/stream/operators/process_function.zh.md ## @@ -325,8 +324,7 @@ ctx.timerService.registerProcessingTimeTimer(coalescedTime)

[GitHub] [flink] flinkbot edited a comment on pull request #11899: [FLINK-17342] enqueue savepoint requests in UC mode

2020-04-28 Thread GitBox
flinkbot edited a comment on pull request #11899: URL: https://github.com/apache/flink/pull/11899#issuecomment-618868456 ## CI report: * abfbb54d774f261b7595ed7b877f2a46668463aa Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162488814) Azure:

[jira] [Created] (FLINK-17442) Cannot convert String or boxed-primitive arrays to DataStream using TypeInformation

2020-04-28 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-17442: -- Summary: Cannot convert String or boxed-primitive arrays to DataStream using TypeInformation Key: FLINK-17442 URL: https://issues.apache.org/jira/browse/FLINK-17442

[jira] [Closed] (FLINK-16973) Various builds failing with "Corrupted STDOUT by directly writing"

2020-04-28 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-16973. -- Resolution: Cannot Reproduce Yes, I agree. Closing ticket. > Various builds failing with

[jira] [Commented] (FLINK-17285) Translate "Python Table API" page into Chinese

2020-04-28 Thread Zixuan Rao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094776#comment-17094776 ] Zixuan Rao commented on FLINK-17285: [~alpinegizmo] May I be assigned for this task? Thanks. >

[jira] [Updated] (FLINK-17285) Translate "Python Table API" page into Chinese

2020-04-28 Thread Zixuan Rao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zixuan Rao updated FLINK-17285: --- Issue Type: Improvement (was: Task) > Translate "Python Table API" page into Chinese >

[jira] [Updated] (FLINK-17285) Translate "Python Table API" page into Chinese

2020-04-28 Thread Zixuan Rao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zixuan Rao updated FLINK-17285: --- Summary: Translate "Python Table API" page into Chinese (was: Add Chinese translation to Python

[jira] [Closed] (FLINK-17432) Rename Tutorials to Training

2020-04-28 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-17432. --- Resolution: Fixed merged to {{master}} via c955eb3 > Rename Tutorials to Training >

[jira] [Comment Edited] (FLINK-17012) Expose stage of task initialization

2020-04-28 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093561#comment-17093561 ] Piotr Nowojski edited comment on FLINK-17012 at 4/28/20, 6:33 PM: --

[GitHub] [flink] pnowojski commented on a change in pull request #11899: [FLINK-17342] enqueue savepoint requests in UC mode

2020-04-28 Thread GitBox
pnowojski commented on a change in pull request #11899: URL: https://github.com/apache/flink/pull/11899#discussion_r416655871 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointRequestDecider.java ## @@ -0,0 +1,156 @@ +/* + * Licensed to

[GitHub] [flink] pnowojski commented on a change in pull request #11899: [FLINK-17342] enqueue savepoint requests in UC mode

2020-04-28 Thread GitBox
pnowojski commented on a change in pull request #11899: URL: https://github.com/apache/flink/pull/11899#discussion_r416653169 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointRequestDecider.java ## @@ -0,0 +1,156 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot edited a comment on pull request #11937: [FLINK-16080]Translate "SQL Client" page of "Table API & SQL" into Chinese

2020-04-28 Thread GitBox
flinkbot edited a comment on pull request #11937: URL: https://github.com/apache/flink/pull/11937#issuecomment-620730732 ## CI report: * c3c2ab4754a8bdd448656e75b9c5968ef5d58e9b Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162483473) Azure:

[jira] [Created] (FLINK-17441) FlinkKinesisConsumerTest.testPeriodicWatermark: watermark count expected:<2> but was:<1>

2020-04-28 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-17441: -- Summary: FlinkKinesisConsumerTest.testPeriodicWatermark: watermark count expected:<2> but was:<1> Key: FLINK-17441 URL: https://issues.apache.org/jira/browse/FLINK-17441

[jira] [Updated] (FLINK-17441) FlinkKinesisConsumerTest.testPeriodicWatermark: watermark count expected:<2> but was:<1>

2020-04-28 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17441: --- Labels: test-stability (was: ) > FlinkKinesisConsumerTest.testPeriodicWatermark: watermark

[GitHub] [flink] flinkbot edited a comment on pull request #11899: [FLINK-17342] enqueue savepoint requests in UC mode

2020-04-28 Thread GitBox
flinkbot edited a comment on pull request #11899: URL: https://github.com/apache/flink/pull/11899#issuecomment-618868456 ## CI report: * abfbb54d774f261b7595ed7b877f2a46668463aa Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/162488814) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11935: [FLINK-17431][sql-parser-hive][hive] Implement table DDLs for Hive di…

2020-04-28 Thread GitBox
flinkbot edited a comment on pull request #11935: URL: https://github.com/apache/flink/pull/11935#issuecomment-620608086 ## CI report: * 7e431d6474f2e1ae03355a68b481d686b162c509 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162431526) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11936: [FLINK-17386][Security][hotfix] fix LinkageError not captured

2020-04-28 Thread GitBox
flinkbot edited a comment on pull request #11936: URL: https://github.com/apache/flink/pull/11936#issuecomment-620683562 ## CI report: * a08eef1a61ad744aa4f735d281657d0fcba5308a Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162464560) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11899: [FLINK-17342] enqueue savepoint requests in UC mode

2020-04-28 Thread GitBox
flinkbot edited a comment on pull request #11899: URL: https://github.com/apache/flink/pull/11899#issuecomment-618868456 ## CI report: * 3b40f3410a32673b70803a05bdb5f643f8931683 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/161799813) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11592: [FLINK-16871][runtime] Make more build time information available at runtime

2020-04-28 Thread GitBox
flinkbot edited a comment on pull request #11592: URL: https://github.com/apache/flink/pull/11592#issuecomment-607128863 ## CI report: * 347da3e6e6a4728ad972b39b58b3946675dd990b UNKNOWN * 168bea66ba7a153d2ada13622b63a5cfffaaf88a Travis:

[jira] [Commented] (FLINK-17364) Support StreamingFileSink in PrestoS3FileSystem

2020-04-28 Thread Lu Niu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094714#comment-17094714 ] Lu Niu commented on FLINK-17364: [~kkl0u] Are you OK with the approach? thanks > Support

[GitHub] [flink] flinkbot edited a comment on pull request #11899: [FLINK-17342] enqueue savepoint requests in UC mode

2020-04-28 Thread GitBox
flinkbot edited a comment on pull request #11899: URL: https://github.com/apache/flink/pull/11899#issuecomment-618868456 ## CI report: * 3b40f3410a32673b70803a05bdb5f643f8931683 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/161799813) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11934: [FLINK-17403][test] Fix invalid classpath in BashJavaUtilsITCase

2020-04-28 Thread GitBox
flinkbot edited a comment on pull request #11934: URL: https://github.com/apache/flink/pull/11934#issuecomment-620607964 ## CI report: * 33e840e3fa906f2ceea130d8b8f36750f41f8eaf Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162431494) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11937: [FLINK-16080]Translate "SQL Client" page of "Table API & SQL" into Chinese

2020-04-28 Thread GitBox
flinkbot edited a comment on pull request #11937: URL: https://github.com/apache/flink/pull/11937#issuecomment-620730732 ## CI report: * c3c2ab4754a8bdd448656e75b9c5968ef5d58e9b Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/162483473) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11592: [FLINK-16871][runtime] Make more build time information available at runtime

2020-04-28 Thread GitBox
flinkbot edited a comment on pull request #11592: URL: https://github.com/apache/flink/pull/11592#issuecomment-607128863 ## CI report: * 347da3e6e6a4728ad972b39b58b3946675dd990b UNKNOWN * 168bea66ba7a153d2ada13622b63a5cfffaaf88a Travis:

[GitHub] [flink] rkhachatryan commented on pull request #11899: [FLINK-17342] enqueue savepoint requests in UC mode

2020-04-28 Thread GitBox
rkhachatryan commented on pull request #11899: URL: https://github.com/apache/flink/pull/11899#issuecomment-620734560 Hmm.. Travis was reporting some unrelated failures via API. Thanks for looking into it. The problems were caused by mocks and the wrong `CheckpointCoordinator`

[jira] [Commented] (FLINK-16973) Various builds failing with "Corrupted STDOUT by directly writing"

2020-04-28 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094690#comment-17094690 ] Chesnay Schepler commented on FLINK-16973: -- [~rmetzger] haven't seen this in a while; I suppose

[jira] [Commented] (FLINK-10911) Enable flink-scala-shell with Scala 2.12

2020-04-28 Thread Aki Tanaka (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094689#comment-17094689 ] Aki Tanaka commented on FLINK-10911: I tried to test running a simple flink-scala-shell code with

[GitHub] [flink] flinkbot commented on pull request #11937: [FLINK-16080]Translate "SQL Client" page of "Table API & SQL" into Chinese

2020-04-28 Thread GitBox
flinkbot commented on pull request #11937: URL: https://github.com/apache/flink/pull/11937#issuecomment-620730732 ## CI report: * c3c2ab4754a8bdd448656e75b9c5968ef5d58e9b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] zentol commented on pull request #11465: [FLINK-16399]Timing the data cached by ExecutionGraphCache

2020-04-28 Thread GitBox
zentol commented on pull request #11465: URL: https://github.com/apache/flink/pull/11465#issuecomment-620724544 The issue has been resolved as part of another ticket. This is an automated message from the Apache Git Service.

[jira] [Closed] (FLINK-16399) The ExecutionGraphCache class does not periodically clear stale data, resulting in JM memory leaks

2020-04-28 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-16399. Resolution: Duplicate The issue has been resolved in another ticket. > The

[jira] [Commented] (FLINK-16097) Translate "SQL Client" page of "Table API & SQL" into Chinese

2020-04-28 Thread Bai Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094674#comment-17094674 ] Bai Xu commented on FLINK-16097: Hi [~jark], I finish this translation.Please check it out.:D >

[GitHub] [flink] flinkbot commented on pull request #11937: [FLINK-16080]Translate "Table API & SQL" pages into Chinese

2020-04-28 Thread GitBox
flinkbot commented on pull request #11937: URL: https://github.com/apache/flink/pull/11937#issuecomment-620722945 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] XBaith opened a new pull request #11937: [FLINK-16080]Translate "Table API & SQL" pages into Chinese

2020-04-28 Thread GitBox
XBaith opened a new pull request #11937: URL: https://github.com/apache/flink/pull/11937 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them on

[GitHub] [flink] flinkbot edited a comment on pull request #11934: [FLINK-17403][test] Fix invalid classpath in BashJavaUtilsITCase

2020-04-28 Thread GitBox
flinkbot edited a comment on pull request #11934: URL: https://github.com/apache/flink/pull/11934#issuecomment-620607964 ## CI report: * 33e840e3fa906f2ceea130d8b8f36750f41f8eaf Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162431494) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11936: [FLINK-17386][Security][hotfix] fix LinkageError not captured

2020-04-28 Thread GitBox
flinkbot edited a comment on pull request #11936: URL: https://github.com/apache/flink/pull/11936#issuecomment-620683562 ## CI report: * a08eef1a61ad744aa4f735d281657d0fcba5308a Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/162464560) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11931: [FLINK-17432][docs-training] Rename Tutorials to Training for better SEO

2020-04-28 Thread GitBox
flinkbot edited a comment on pull request #11931: URL: https://github.com/apache/flink/pull/11931#issuecomment-620525973 ## CI report: * 826e4af475affea37d8d079abf51a653233a1f08 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162423330) Azure:

<    1   2   3   4   5   >