[jira] [Updated] (FLINK-17471) Move LICENSE and NOTICE files to root directory of python distribution

2020-04-29 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-17471: -- Attachment: image-2020-04-30-13-57-28-072.png > Move LICENSE and NOTICE files to root directory of

[GitHub] [flink] flinkbot edited a comment on pull request #11949: [FLINK-17332][k8s] Fix restart policy not equals to Never for native task manager pods

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11949: URL: https://github.com/apache/flink/pull/11949#issuecomment-621570408 ## CI report: * 95dba088b53d2af086a56ccc04ad890c959f9a4b Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162857048) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11950: [Flink-17030] Add primary key syntax to DDL

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11950: URL: https://github.com/apache/flink/pull/11950#issuecomment-621585318 ## CI report: * c6ff889b90a10f70a7429597a2473468de2a0cce Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162862286) Azure:

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

2020-04-29 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 #9097: [FLINK-11529][docs-zh] Translate the "DataStream API Tutorial" page into Chinese

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #9097: URL: https://github.com/apache/flink/pull/9097#issuecomment-621619875 ## CI report: * a4cd0df8a0e827e7839ac00652d56193797846d5 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/162877152) Bot

[jira] [Commented] (FLINK-16850) Make flink-benchmark align with different releases of Flink

2020-04-29 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096144#comment-17096144 ] Nico Kruber commented on FLINK-16850: - The first commit needs to go into the Apache git, only after

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

2020-04-29 Thread GitBox
wangyang0918 commented on a change in pull request #11903: URL: https://github.com/apache/flink/pull/11903#discussion_r417759683 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/entrypoint/YarnDeploymentTargetNames.java ## @@ -0,0 +1,44 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot edited a comment on pull request #11590: [FLINK-16102][docs-zh] Translate docs/dev/table/hive/scala_shell_hive.zh.md into Chinese

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11590: URL: https://github.com/apache/flink/pull/11590#issuecomment-607068581 ## CI report: * d50723d3a6ed9239e26ec37cb421db586c99 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162862172) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11878: [FLINK-17125][python] Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11878: URL: https://github.com/apache/flink/pull/11878#issuecomment-618274104 ## CI report: * 5ad770fdd8fba58add55a62ed89e99ff6b9a14cf Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/162863899) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11844: [FLINK-17125][python][doc] Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11844: URL: https://github.com/apache/flink/pull/11844#issuecomment-617177959 ## CI report: * 9406a47d278c766f5f7f868d4f07226761b06690 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162858624) Bot

[GitHub] [flink] flinkbot edited a comment on pull request #11954: [FLINK-17420][table sql / api]Cannot alias Tuple and Row fields when converting DataStream to Table

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11954: URL: https://github.com/apache/flink/pull/11954#issuecomment-621615631 ## CI report: * 6a37ff126c35f1d7b35fb50ccff89f200967b2da Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/162875532) Bot

[GitHub] [flink] flinkbot commented on pull request #9097: [FLINK-11529][docs-zh] Translate the "DataStream API Tutorial" page into Chinese

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

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

2020-04-29 Thread GitBox
XBaith commented on pull request #11937: URL: https://github.com/apache/flink/pull/11937#issuecomment-621619105 Hi,@klion26.Please review this if you are free.Thank you This is an automated message from the Apache Git

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

2020-04-29 Thread GitBox
XBaith edited a comment on pull request #11937: URL: https://github.com/apache/flink/pull/11937#issuecomment-621619105 Hi, @klion26 .Please review this if you are free.Thank you This is an automated message from the Apache

[GitHub] [flink] XBaith commented on pull request #9097: [FLINK-11529][docs-zh] Translate the "DataStream API Tutorial" page into Chinese

2020-04-29 Thread GitBox
XBaith commented on pull request #9097: URL: https://github.com/apache/flink/pull/9097#issuecomment-621618293 You need update your pull request. More information, see: https://www.bilibili.com/video/BV1kK411577L?from=search=16883785088266459960

[GitHub] [flink] XBaith commented on a change in pull request #9097: [FLINK-11529][docs-zh] Translate the "DataStream API Tutorial" page into Chinese

2020-04-29 Thread GitBox
XBaith commented on a change in pull request #9097: URL: https://github.com/apache/flink/pull/9097#discussion_r417755148 ## File path: docs/getting-started/tutorials/datastream_api.zh.md ## @@ -203,26 +178,20 @@ DataStream> result = keyedEdits }); {% endhighlight %}

[GitHub] [flink] flinkbot edited a comment on pull request #11953: [FLINK-16975][doc] Add docs for FileSystem connector

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11953: URL: https://github.com/apache/flink/pull/11953#issuecomment-621608702 ## CI report: * c50145cf1802b4265bde068a812c9abce18be5e1 Azure:

[GitHub] [flink] flinkbot commented on pull request #11954: [FLINK-17420][table sql / api]Cannot alias Tuple and Row fields when converting DataStream to Table

2020-04-29 Thread GitBox
flinkbot commented on pull request #11954: URL: https://github.com/apache/flink/pull/11954#issuecomment-621615631 ## CI report: * 6a37ff126c35f1d7b35fb50ccff89f200967b2da UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #11878: [FLINK-17125][python] Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11878: URL: https://github.com/apache/flink/pull/11878#issuecomment-618274104 ## CI report: * 06e24237fde5862fa1c667eea53800920db37147 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161590556) Azure:

[jira] [Commented] (FLINK-17471) Move LICENSE and NOTICE files to root directory of python distribution

2020-04-29 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096135#comment-17096135 ] Yu Li commented on FLINK-17471: --- Thanks for the quick response [~dian.fu]! > Move LICENSE and NOTICE

[jira] [Commented] (FLINK-17471) Move LICENSE and NOTICE files to root directory of python distribution

2020-04-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096133#comment-17096133 ] Dian Fu commented on FLINK-17471: - [~liyu] Thanks for filing this ticket. I will take a look ASAP. >

[GitHub] [flink] flinkbot edited a comment on pull request #9782: [FLINK-14241][test] Add aarch64 support for container e2e test

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #9782: URL: https://github.com/apache/flink/pull/9782#issuecomment-535826739 ## CI report: * 0f20a7952d54037d7505d5517556c25fd7ba7e32 Azure:

[jira] [Updated] (FLINK-17359) Entropy key is not resolved if flink-s3-fs-hadoop is added as a plugin

2020-04-29 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-17359: -- Fix Version/s: (was: 1.10.2) 1.10.1 Change the fix version to 1.10.1 since we will

[jira] [Comment Edited] (FLINK-17308) ExecutionGraphCache cachedExecutionGraphs not cleanup cause OOM Bug

2020-04-29 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096132#comment-17096132 ] Yu Li edited comment on FLINK-17308 at 4/30/20, 5:03 AM: - Thanks for the

[jira] [Updated] (FLINK-17308) ExecutionGraphCache cachedExecutionGraphs not cleanup cause OOM Bug

2020-04-29 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-17308: -- Fix Version/s: (was: 1.10.2) 1.10.1 Change the fix version back to 1.10.1 since we

[jira] [Commented] (FLINK-17471) Move LICENSE and NOTICE files to root directory of python distribution

2020-04-29 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096131#comment-17096131 ] Yu Li commented on FLINK-17471: --- [~jincheng] [~hequn8128] [~dianfu] could you take a look here? Thanks. >

[jira] [Created] (FLINK-17471) Move LICENSE and NOTICE files to root directory of python distribution

2020-04-29 Thread Yu Li (Jira)
Yu Li created FLINK-17471: - Summary: Move LICENSE and NOTICE files to root directory of python distribution Key: FLINK-17471 URL: https://issues.apache.org/jira/browse/FLINK-17471 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #11954: [FLINK-17420][table sql / api]Cannot alias Tuple and Row fields when converting DataStream to Table

2020-04-29 Thread GitBox
flinkbot commented on pull request #11954: URL: https://github.com/apache/flink/pull/11954#issuecomment-621611564 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] leonardBang opened a new pull request #11954: [FLINK-17420][table sql / api]Cannot alias Tuple and Row fields when converting DataStream to Table

2020-04-29 Thread GitBox
leonardBang opened a new pull request #11954: URL: https://github.com/apache/flink/pull/11954 ## What is the purpose of the change *This pull request fix `byPosition` mode judgement in FieldInfoUtils to support reorder and reorder field properly.* ## Brief change

[GitHub] [flink] flinkbot edited a comment on pull request #11949: [FLINK-17332][k8s] Fix restart policy not equals to Never for native task manager pods

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11949: URL: https://github.com/apache/flink/pull/11949#issuecomment-621570408 ## CI report: * 95dba088b53d2af086a56ccc04ad890c959f9a4b Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162857048) Azure:

[GitHub] [flink] flinkbot commented on pull request #11953: [FLINK-16975][doc] Add docs for FileSystem connector

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

[GitHub] [flink] HuangXingBo commented on pull request #11878: [FLINK-17125][python] Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

2020-04-29 Thread GitBox
HuangXingBo commented on pull request #11878: URL: https://github.com/apache/flink/pull/11878#issuecomment-621607982 Thanks a lot for @sjwiesman review. Before you help review, I made relatively large changes to the content of this document, I put these in the fix commit. Then based on

[jira] [Commented] (FLINK-17086) Flink sql client not able to read parquet hive table because `HiveMapredSplitReader` not supports name mapping reading for parquet format.

2020-04-29 Thread Lei Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096121#comment-17096121 ] Lei Wang commented on FLINK-17086: -- Hi [~lirui], I build package from the latest code from flink github

[jira] [Commented] (FLINK-17459) JDBCAppendTableSink not support flush by flushIntervalMills

2020-04-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096120#comment-17096120 ] Jark Wu commented on FLINK-17459: - {code:java} sink.setIsAppendOnly(true); sink.setKeyFields(new

[GitHub] [flink] flinkbot commented on pull request #11953: [FLINK-16975][doc] Add docs for FileSystem connector

2020-04-29 Thread GitBox
flinkbot commented on pull request #11953: URL: https://github.com/apache/flink/pull/11953#issuecomment-621605543 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] HuangXingBo commented on a change in pull request #11878: [FLINK-17125][python] Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

2020-04-29 Thread GitBox
HuangXingBo commented on a change in pull request #11878: URL: https://github.com/apache/flink/pull/11878#discussion_r417746331 ## File path: docs/dev/table/python/usage_notes.md ## @@ -0,0 +1,120 @@ +--- +title: "Usage Notes" +nav-parent_id: python_tableapi +nav-pos: 140 +---

[jira] [Closed] (FLINK-15591) make up for feature parity by supporting CREATE TEMPORARY TABLE/VIEW in DDL

2020-04-29 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15591. -- Resolution: Fixed master: dca4a774ff75cb6d79d0c825311a56e151357027 > make up for feature parity by

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

2020-04-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16975: --- Labels: pull-request-available (was: ) > Add docs for FileSystem connector >

[GitHub] [flink] HuangXingBo commented on a change in pull request #11878: [FLINK-17125][python] Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

2020-04-29 Thread GitBox
HuangXingBo commented on a change in pull request #11878: URL: https://github.com/apache/flink/pull/11878#discussion_r417746202 ## File path: docs/dev/table/python/usage_notes.md ## @@ -0,0 +1,120 @@ +--- +title: "Usage Notes" Review comment: Yes. Make sense.

[GitHub] [flink] JingsongLi opened a new pull request #11953: [FLINK-16975][doc] Add docs for FileSystem connector

2020-04-29 Thread GitBox
JingsongLi opened a new pull request #11953: URL: https://github.com/apache/flink/pull/11953 ## What is the purpose of the change Add docs for the new file system connector ## Brief change log - Add docs for the new file system connector - Remove old filesystem

[GitHub] [flink] KurtYoung commented on pull request #11917: [FLINK-15591][table] Support create/drop temporary table in Flink SQL

2020-04-29 Thread GitBox
KurtYoung commented on pull request #11917: URL: https://github.com/apache/flink/pull/11917#issuecomment-621603904 run mvn verify locally and passed This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #11952: [FLINK-16638][runtime][checkpointing] Flink checkStateMappingCompleteness doesn't include UserDefinedOperatorIDs

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11952: URL: https://github.com/apache/flink/pull/11952#issuecomment-621589853 ## CI report: * e2f1b05a35fa8d43aa04cafbecc0333680b09a37 Azure:

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

2020-04-29 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-16975: - Summary: Add docs for FileSystem connector (was: Add docs for FileSystem connector and hive

[jira] [Assigned] (FLINK-16975) Add docs for FileSystem connector and hive connector

2020-04-29 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-16975: Assignee: Jingsong Lee > Add docs for FileSystem connector and hive connector >

[GitHub] [flink] flinkbot edited a comment on pull request #11932: [FLINK-17423][python] Support Python UDTF in blink planner under batch mode

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11932: URL: https://github.com/apache/flink/pull/11932#issuecomment-620543031 ## CI report: * a90b4df7b90946f2bd365ab8dc867958b2779047 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162636684) Azure:

[jira] [Commented] (FLINK-17447) Flink CEPOperator StateException

2020-04-29 Thread chun111111 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096108#comment-17096108 ] chun11 commented on FLINK-17447: [~aljoscha] I think the static code  for create Pattern works

[GitHub] [flink] flinkbot edited a comment on pull request #9782: [FLINK-14241][test] Add aarch64 support for container e2e test

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #9782: URL: https://github.com/apache/flink/pull/9782#issuecomment-535826739 ## CI report: * fda598e2a49de6d1d89ce6e3d9ec5ff2a1d2da7c Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/160824816) Azure:

[jira] [Commented] (FLINK-17447) Flink CEPOperator StateException

2020-04-29 Thread chun111111 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096093#comment-17096093 ] chun11 commented on FLINK-17447: in the job, one datastream math with five CEP Pattern. and the

[GitHub] [flink] flinkbot edited a comment on pull request #11878: [FLINK-17125][python] Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11878: URL: https://github.com/apache/flink/pull/11878#issuecomment-618274104 ## CI report: * 06e24237fde5862fa1c667eea53800920db37147 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161590556) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11952: [FLINK-16638][runtime][checkpointing] Flink checkStateMappingCompleteness doesn't include UserDefinedOperatorIDs

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11952: URL: https://github.com/apache/flink/pull/11952#issuecomment-621589853 ## CI report: * e2f1b05a35fa8d43aa04cafbecc0333680b09a37 Azure:

[jira] [Commented] (FLINK-17447) Flink CEPOperator StateException

2020-04-29 Thread chun111111 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096085#comment-17096085 ] chun11 commented on FLINK-17447:   import java.util.ArrayList; import java.util.HashMap; import

[jira] [Commented] (FLINK-17447) Flink CEPOperator StateException

2020-04-29 Thread chun111111 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096087#comment-17096087 ] chun11 commented on FLINK-17447: TwoStagePatternedRule is a enum :   public enum

[GitHub] [flink] flinkbot edited a comment on pull request #9782: [FLINK-14241][test] Add aarch64 support for container e2e test

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #9782: URL: https://github.com/apache/flink/pull/9782#issuecomment-535826739 ## CI report: * fda598e2a49de6d1d89ce6e3d9ec5ff2a1d2da7c Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/160824816) Azure:

[jira] [Updated] (FLINK-17447) Flink CEPOperator StateException

2020-04-29 Thread chun111111 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chun11 updated FLINK-17447: --- Attachment: image-2020-04-30-11-37-20-411.png > Flink CEPOperator StateException >

[jira] [Commented] (FLINK-16850) Make flink-benchmark align with different releases of Flink

2020-04-29 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096083#comment-17096083 ] Yun Tang commented on FLINK-16850: -- [~pnowojski], I found I cannot fork or create PR to an empty repo:

[GitHub] [flink] flinkbot edited a comment on pull request #11878: [FLINK-17125][python] Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11878: URL: https://github.com/apache/flink/pull/11878#issuecomment-618274104 ## CI report: * 06e24237fde5862fa1c667eea53800920db37147 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161590556) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11951: [FLINK-17420][table sql / api]Cannot alias Tuple and Row fields when converting DataStream to Table

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11951: URL: https://github.com/apache/flink/pull/11951#issuecomment-621585351 ## CI report: * 38b17d3e6bb0dff3d2a383ed066f23bc3c2dce4f Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/162862304) Azure:

[GitHub] [flink] flinkbot commented on pull request #11952: [FLINK-16638][runtime][checkpointing] Flink checkStateMappingCompleteness doesn't include UserDefinedOperatorIDs

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

[GitHub] [flink] flinkbot edited a comment on pull request #11950: [Flink-17030] Add primary key syntax to DDL

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11950: URL: https://github.com/apache/flink/pull/11950#issuecomment-621585318 ## CI report: * c6ff889b90a10f70a7429597a2473468de2a0cce Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/162862286) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11590: [FLINK-16102][docs-zh] Translate docs/dev/table/hive/scala_shell_hive.zh.md into Chinese

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11590: URL: https://github.com/apache/flink/pull/11590#issuecomment-607068581 ## CI report: * 8d4774382b57353f1de2f37c23144f4f2321b443 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/157422842) Azure:

[GitHub] [flink] edu05 opened a new pull request #11952: [FLINK-16638][runtime][checkpointing] Flink checkStateMappingCompleteness doesn't include UserDefinedOperatorIDs

2020-04-29 Thread GitBox
edu05 opened a new pull request #11952: URL: https://github.com/apache/flink/pull/11952 ## What is the purpose of the change *Fix a bug where an exception was being thrown when a savepoint couldn't be mapped to an ExecutionJobVertex due to the user having specified the

[GitHub] [flink] flinkbot commented on pull request #11952: [FLINK-16638][runtime][checkpointing] Flink checkStateMappingCompleteness doesn't include UserDefinedOperatorIDs

2020-04-29 Thread GitBox
flinkbot commented on pull request #11952: URL: https://github.com/apache/flink/pull/11952#issuecomment-621587868 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-16638) Flink checkStateMappingCompleteness doesn't include UserDefinedOperatorIDs

2020-04-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16638: --- Labels: pull-request-available (was: ) > Flink checkStateMappingCompleteness doesn't

[GitHub] [flink] flinkbot commented on pull request #11950: [Flink-17030] Add primary key syntax to DDL

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

[GitHub] [flink] flinkbot commented on pull request #11951: [FLINK-17420][table sql / api]Cannot alias Tuple and Row fields when converting DataStream to Table

2020-04-29 Thread GitBox
flinkbot commented on pull request #11951: URL: https://github.com/apache/flink/pull/11951#issuecomment-621585351 ## CI report: * 38b17d3e6bb0dff3d2a383ed066f23bc3c2dce4f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #11844: [FLINK-17125][python][doc] Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11844: URL: https://github.com/apache/flink/pull/11844#issuecomment-617177959 ## CI report: * e8420fe3abb672c1e15cb6440d838c02d9fd86b7 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/161590420) *

[GitHub] [flink] flinkbot edited a comment on pull request #11942: [FLINK-17325][orc] Integrate orc to file system connector

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11942: URL: https://github.com/apache/flink/pull/11942#issuecomment-621092297 ## CI report: * 2e41f637638178e4ebd8efbdc6a1a20764658eca Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162709907) Azure:

[jira] [Commented] (FLINK-17465) Update Chinese user documentation for job manager memory model

2020-04-29 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096053#comment-17096053 ] Xintong Song commented on FLINK-17465: -- [~azagrebin] I can work on this ticket. Please assign it to

[GitHub] [flink] flinkbot edited a comment on pull request #11590: [FLINK-16102][docs-zh] Translate docs/dev/table/hive/scala_shell_hive.zh.md into Chinese

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11590: URL: https://github.com/apache/flink/pull/11590#issuecomment-607068581 ## CI report: * 8d4774382b57353f1de2f37c23144f4f2321b443 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/157422842) Azure:

[jira] [Comment Edited] (FLINK-17459) JDBCAppendTableSink not support flush by flushIntervalMills

2020-04-29 Thread ranqiqiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096029#comment-17096029 ] ranqiqiang edited comment on FLINK-17459 at 4/30/20, 2:53 AM: --

[GitHub] [flink] danny0405 commented on pull request #11950: [Flink-17030] Add primary key syntax to DDL

2020-04-29 Thread GitBox
danny0405 commented on pull request #11950: URL: https://github.com/apache/flink/pull/11950#issuecomment-621581006 cc @dawidwys , can you review this for me if you have time, thanks ~ This is an automated message from the

[jira] [Comment Edited] (FLINK-17459) JDBCAppendTableSink not support flush by flushIntervalMills

2020-04-29 Thread ranqiqiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096029#comment-17096029 ] ranqiqiang edited comment on FLINK-17459 at 4/30/20, 2:42 AM: --

[GitHub] [flink] flinkbot commented on pull request #11951: [FLINK-17420][table sql / api]Cannot alias Tuple and Row fields when converting DataStream to Table

2020-04-29 Thread GitBox
flinkbot commented on pull request #11951: URL: https://github.com/apache/flink/pull/11951#issuecomment-621577344 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-17420) Cannot alias Tuple and Row fields when converting DataStream to Table

2020-04-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17420: --- Labels: pull-request-available (was: ) > Cannot alias Tuple and Row fields when converting

[GitHub] [flink] leonardBang opened a new pull request #11951: [FLINK-17420][table sql / api]Cannot alias Tuple and Row fields when converting DataStream to Table

2020-04-29 Thread GitBox
leonardBang opened a new pull request #11951: URL: https://github.com/apache/flink/pull/11951 ## What is the purpose of the change *This pull request fix `byPosition` mode judgement in FieldInfoUtils to support reorder and reorder field properly.* ## Brief

[jira] [Commented] (FLINK-17459) JDBCAppendTableSink not support flush by flushIntervalMills

2020-04-29 Thread ranqiqiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096029#comment-17096029 ] ranqiqiang commented on FLINK-17459: 1.JDBCAppendTableSink will be abandoned ?

[GitHub] [flink] flinkbot commented on pull request #11950: [Flink-17030] Add primary key syntax to DDL

2020-04-29 Thread GitBox
flinkbot commented on pull request #11950: URL: https://github.com/apache/flink/pull/11950#issuecomment-621575772 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] zhule0601 commented on a change in pull request #11590: [FLINK-16102][docs-zh] Translate docs/dev/table/hive/scala_shell_hive.zh.md into Chinese

2020-04-29 Thread GitBox
zhule0601 commented on a change in pull request #11590: URL: https://github.com/apache/flink/pull/11590#discussion_r417719961 ## File path: docs/dev/table/hive/scala_shell_hive.zh.md ## @@ -22,18 +22,18 @@ specific language governing permissions and limitations under the

[GitHub] [flink] flinkbot edited a comment on pull request #11932: [FLINK-17423][python] Support Python UDTF in blink planner under batch mode

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11932: URL: https://github.com/apache/flink/pull/11932#issuecomment-620543031 ## CI report: * a90b4df7b90946f2bd365ab8dc867958b2779047 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/162636684) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11949: [FLINK-17332][k8s] Fix restart policy not equals to Never for native task manager pods

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11949: URL: https://github.com/apache/flink/pull/11949#issuecomment-621570408 ## CI report: * 95dba088b53d2af086a56ccc04ad890c959f9a4b Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/162857048) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11844: [FLINK-17125][python][doc] Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11844: URL: https://github.com/apache/flink/pull/11844#issuecomment-617177959 ## CI report: * e8420fe3abb672c1e15cb6440d838c02d9fd86b7 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/161590420) *

[GitHub] [flink] danny0405 opened a new pull request #11950: [Flink-17030] Add primary key syntax to DDL

2020-04-29 Thread GitBox
danny0405 opened a new pull request #11950: URL: https://github.com/apache/flink/pull/11950 ## What is the purpose of the change Supports primary key and unique key syntax to sql-parser and blink-planner. ## Brief change log - Add primary key and unique syntax to sql

[jira] [Commented] (FLINK-17453) KyroSerializer throws IndexOutOfBoundsException type java.util.PriorityQueue

2020-04-29 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096014#comment-17096014 ] Jiayi Liao commented on FLINK-17453: [~aljoscha] It's Map.Entry. BTW I've updated the description

[jira] [Updated] (FLINK-17453) KyroSerializer throws IndexOutOfBoundsException type java.util.PriorityQueue

2020-04-29 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-17453: --- Description: We're using SQL UDAF with a {{PriorityQueue}} as {{Accumulator}}, and when recovering

[jira] [Updated] (FLINK-17453) KyroSerializer throws IndexOutOfBoundsException type java.util.PriorityQueue

2020-04-29 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-17453: --- Description: We're using SQL UDAF with a {{PriorityQueue}} as {{Accumulator}}, and when recovering

[GitHub] [flink] flinkbot edited a comment on pull request #11932: [FLINK-17423][python] Support Python UDTF in blink planner under batch mode

2020-04-29 Thread GitBox
flinkbot edited a comment on pull request #11932: URL: https://github.com/apache/flink/pull/11932#issuecomment-620543031 ## CI report: * a90b4df7b90946f2bd365ab8dc867958b2779047 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/162636684) Azure:

[GitHub] [flink] flinkbot commented on pull request #11949: [FLINK-17332][k8s] Fix restart policy not equals to Never for native task manager pods

2020-04-29 Thread GitBox
flinkbot commented on pull request #11949: URL: https://github.com/apache/flink/pull/11949#issuecomment-621570408 ## CI report: * 95dba088b53d2af086a56ccc04ad890c959f9a4b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] hequn8128 commented on pull request #11932: [FLINK-17423][python] Support Python UDTF in blink planner under batch mode

2020-04-29 Thread GitBox
hequn8128 commented on pull request #11932: URL: https://github.com/apache/flink/pull/11932#issuecomment-621569598 @flinkbot run travis This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-17148) Support converting pandas dataframe to flink table

2020-04-29 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096012#comment-17096012 ] Hequn Cheng commented on FLINK-17148: - Resolved in 1.11.0 via

[jira] [Closed] (FLINK-17148) Support converting pandas dataframe to flink table

2020-04-29 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-17148. --- Resolution: Resolved > Support converting pandas dataframe to flink table >

[GitHub] [flink] hequn8128 commented on pull request #11832: [FLINK-17148][python] Support converting pandas DataFrame to Flink Table

2020-04-29 Thread GitBox
hequn8128 commented on pull request #11832: URL: https://github.com/apache/flink/pull/11832#issuecomment-621568683 @dianfu Thanks. Merging... This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] dianfu commented on pull request #11832: [FLINK-17148][python] Support converting pandas DataFrame to Flink Table

2020-04-29 Thread GitBox
dianfu commented on pull request #11832: URL: https://github.com/apache/flink/pull/11832#issuecomment-621568192 Not sure why the CI of Azure wasn't triggered. It has succeed in my private azure pipeline: https://dev.azure.com/dianfu/Flink/_build/results?buildId=50=results

[GitHub] [flink] hequn8128 commented on pull request #11932: [FLINK-17423][python] Support Python UDTF in blink planner under batch mode

2020-04-29 Thread GitBox
hequn8128 commented on pull request #11932: URL: https://github.com/apache/flink/pull/11932#issuecomment-621566446 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] KurtYoung commented on a change in pull request #11944: [FLINK-17461][formats][json] Support JSON serialization and deseriazation schema for RowData type

2020-04-29 Thread GitBox
KurtYoung commented on a change in pull request #11944: URL: https://github.com/apache/flink/pull/11944#discussion_r417711841 ## File path: flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java ## @@ -0,0 +1,322 @@ +/* + *

[GitHub] [flink] flinkbot commented on pull request #11949: [FLINK-17332][k8s] Fix restart policy not equals to Never for native task manager pods

2020-04-29 Thread GitBox
flinkbot commented on pull request #11949: URL: https://github.com/apache/flink/pull/11949#issuecomment-621565971 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-17332) Fix restart policy not equals to Never for native task manager pods

2020-04-29 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17332: - Priority: Minor (was: Major) > Fix restart policy not equals to Never for native task manager

[jira] [Updated] (FLINK-17332) Fix restart policy not equals to Never for native task manager pods

2020-04-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17332: --- Labels: pull-request-available (was: ) > Fix restart policy not equals to Never for native

[GitHub] [flink] zhengcanbin opened a new pull request #11949: [FLINK-17332][k8s] Fix restart policy not equals to Never for native task manager pods

2020-04-29 Thread GitBox
zhengcanbin opened a new pull request #11949: URL: https://github.com/apache/flink/pull/11949 ## What is the purpose of the change Currently, we do not explicitly set the `RestartPolicy` for the task manager pods in the native K8s setups so that it is `Always` by default. From the

[jira] [Closed] (FLINK-17254) Improve the PyFlink documentation and examples to use SQL DDL for source/sink definition

2020-04-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17254. --- Fix Version/s: 1.9.4 1.10.1 Resolution: Resolved Merged to - master via

[jira] [Assigned] (FLINK-17254) Improve the PyFlink documentation and examples to use SQL DDL for source/sink definition

2020-04-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17254: --- Assignee: shuiqiangchen > Improve the PyFlink documentation and examples to use SQL DDL for

  1   2   3   4   >