[jira] [Updated] (FLINK-17454) test_configuration.py ConfigurationTests::test_add_all failed on travis

[ https://issues.apache.org/jira/browse/FLINK-17454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17454: --- Labels: test-stability (was: ) > test_configuration.py ConfigurationTests::test_add_all

[jira] [Created] (FLINK-17454) test_configuration.py ConfigurationTests::test_add_all failed on travis

Piotr Nowojski created FLINK-17454: -- Summary: test_configuration.py ConfigurationTests::test_add_all failed on travis Key: FLINK-17454 URL: https://issues.apache.org/jira/browse/FLINK-17454 Project:

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

wangyang0918 commented on a change in pull request #11903: URL: https://github.com/apache/flink/pull/11903#discussion_r417072162 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java ## @@ -691,11 +716,15 @@ private ApplicationReport

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

wangyang0918 commented on a change in pull request #11903: URL: https://github.com/apache/flink/pull/11903#discussion_r417066142 ## File path: flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java ## @@ -165,6 +168,41 @@ public Options

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

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095078#comment-17095078 ] Sivaprasanna Sethuraman commented on FLINK-10114: - Thank you so much, [~kkl0u],

[jira] [Commented] (FLINK-17438) Flink StreamingFileSink chinese garbled

[ https://issues.apache.org/jira/browse/FLINK-17438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095076#comment-17095076 ] Sivaprasanna Sethuraman commented on FLINK-17438: - [~why198852] I agree with

[GitHub] [flink] flinkbot edited a comment on pull request #11905: [FLINK-17267] [table] legacy planner supports explain insert operation and introduce TableEnvironment#explainSql/Introduce TableEnvir

flinkbot edited a comment on pull request #11905: URL: https://github.com/apache/flink/pull/11905#issuecomment-619089324 ## CI report: * 7050007f458f91cbf3e0e8be286e62361001f2b0 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162593361) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11917: [FLINK-15591][table] Support create/drop temporary table in Flink SQL

flinkbot edited a comment on pull request #11917: URL: https://github.com/apache/flink/pull/11917#issuecomment-619827493 ## CI report: * 91669c729482b8d2b9476f0216ed88b3612f8637 Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/162601736) Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095071#comment-17095071 ] Sivaprasanna Sethuraman edited comment on FLINK-17444 at 4/29/20, 5:08 AM:

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

[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095071#comment-17095071 ] Sivaprasanna Sethuraman commented on FLINK-17444: - Yes, exclusion of the

[jira] [Comment Edited] (FLINK-17438) Flink StreamingFileSink chinese garbled

[ https://issues.apache.org/jira/browse/FLINK-17438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095066#comment-17095066 ] Jingsong Lee edited comment on FLINK-17438 at 4/29/20, 4:57 AM:

[jira] [Commented] (FLINK-17438) Flink StreamingFileSink chinese garbled

[ https://issues.apache.org/jira/browse/FLINK-17438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095066#comment-17095066 ] Jingsong Lee commented on FLINK-17438: -- [~why198852] Have you checked your hive charset? Is that

[GitHub] [flink] flinkbot edited a comment on pull request #11917: [FLINK-15591][table] Support create/drop temporary table in Flink SQL

flinkbot edited a comment on pull request #11917: URL: https://github.com/apache/flink/pull/11917#issuecomment-619827493 ## CI report: * 012133641bb130c7c5f79c5d1f4bfede326a3961 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162221841) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11939: [FLINK-17334][hive] Flink does not support HIVE UDFs with primitive return types

flinkbot edited a comment on pull request #11939: URL: https://github.com/apache/flink/pull/11939#issuecomment-620965820 ## CI report: * 5aca5feda9c1c1bcc258a682160eb66b24b4531c Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162591466) Bot

[jira] [Commented] (FLINK-17438) Flink StreamingFileSink chinese garbled

[ https://issues.apache.org/jira/browse/FLINK-17438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095065#comment-17095065 ] 颖 commented on FLINK-17438: --- [~zenfenan] I wonder if you have any solution? > Flink StreamingFileSink chinese

[jira] [Commented] (FLINK-17325) Integrate orc to file system connector

[ https://issues.apache.org/jira/browse/FLINK-17325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095063#comment-17095063 ] Jingsong Lee commented on FLINK-17325: -- [~zenfenan] Updated FYI. > Integrate orc to file system

[jira] [Updated] (FLINK-17325) Integrate orc to file system connector

[ https://issues.apache.org/jira/browse/FLINK-17325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17325: - Description: Integrate orc to file system connector, so in the sql world, users can create

[jira] [Updated] (FLINK-17325) Integrate orc to file system connector

[ https://issues.apache.org/jira/browse/FLINK-17325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17325: - Description: Integrate orc to file system connector, so in the sql world, users can create

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

[ https://issues.apache.org/jira/browse/FLINK-17254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shuiqiangchen updated FLINK-17254: -- Description: Currently there are two ways to register a table sink/source in PyFlink table

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

[ https://issues.apache.org/jira/browse/FLINK-17254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shuiqiangchen updated FLINK-17254: -- Description: Currently there are two ways to register a table sink/source in PyFlink table

[jira] [Commented] (FLINK-17325) Integrate orc to file system connector

[ https://issues.apache.org/jira/browse/FLINK-17325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095060#comment-17095060 ] Sivaprasanna Sethuraman commented on FLINK-17325: - [~lzljs3620320] If you can add some

[GitHub] [flink] wuchong commented on pull request #11925: [FLINK-16996][table] Refactor planner and connectors to use new data structures

wuchong commented on pull request #11925: URL: https://github.com/apache/flink/pull/11925#issuecomment-620983842 @JingsongLi , as far as I know, the community doesn't have a rule to make sure independent commits can pass build, but there is a rule to separate commits if it is a big

[GitHub] [flink] flinkbot edited a comment on pull request #11917: [FLINK-15591][table] Support create/drop temporary table in Flink SQL

flinkbot edited a comment on pull request #11917: URL: https://github.com/apache/flink/pull/11917#issuecomment-619827493 ## CI report: * 012133641bb130c7c5f79c5d1f4bfede326a3961 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162221841) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11815: [FLINK-17253] Support viewfs for hadoop version < 2.7

flinkbot edited a comment on pull request #11815: URL: https://github.com/apache/flink/pull/11815#issuecomment-616355624 ## CI report: * 82b7e411419bbd8a1011bdc78e2a916dbc1256a7 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160984484) Azure:

[GitHub] [flink] JingsongLi commented on pull request #11925: [FLINK-16996][table] Refactor planner and connectors to use new data structures

JingsongLi commented on pull request #11925: URL: https://github.com/apache/flink/pull/11925#issuecomment-620982610 > Hi @JingsongLi , I want to keep the splitted commits. From my point of view, squashing such a large PR into one commit is not good. So the answer is we can push

[GitHub] [flink] wuchong commented on pull request #11925: [FLINK-16996][table] Refactor planner and connectors to use new data structures

wuchong commented on pull request #11925: URL: https://github.com/apache/flink/pull/11925#issuecomment-620981796 Hi @JingsongLi , I want to keep the splitted commits. From my point of view, squashing such a large PR into one commit is not good.

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

docete commented on a change in pull request #11917: URL: https://github.com/apache/flink/pull/11917#discussion_r417059442 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java ## @@ -649,16 +649,32 @@

[GitHub] [flink] flinkbot edited a comment on pull request #11940: [FLINK-17440][network] Resolve potential buffer leak in output unspilling for unaligned checkpoints

flinkbot edited a comment on pull request #11940: URL: https://github.com/apache/flink/pull/11940#issuecomment-620976302 ## CI report: * 35a1cb9c61c3bd360705b2df2bde08c5b3718c9d Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/162597644) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11927: [FLINK-17414][python][doc] Change the steps of building PyFlink in doc

flinkbot edited a comment on pull request #11927: URL: https://github.com/apache/flink/pull/11927#issuecomment-620352224 ## CI report: * dca256f92f29144cd3fbd9580275eb5fffc5efbc Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162343842) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11815: [FLINK-17253] Support viewfs for hadoop version < 2.7

flinkbot edited a comment on pull request #11815: URL: https://github.com/apache/flink/pull/11815#issuecomment-616355624 ## CI report: * 82b7e411419bbd8a1011bdc78e2a916dbc1256a7 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160984484) Azure:

[GitHub] [flink] JingsongLi commented on pull request #11925: [FLINK-16996][table] Refactor planner and connectors to use new data structures

JingsongLi commented on pull request #11925: URL: https://github.com/apache/flink/pull/11925#issuecomment-620979505 Hi @wuchong , do you want to squash or not? Here is my question: Does it need to be able to compile for each commit to the master?

[jira] [Assigned] (FLINK-17428) Support SupportsProjectionPushDown in planner

[ https://issues.apache.org/jira/browse/FLINK-17428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17428: --- Assignee: godfrey he > Support SupportsProjectionPushDown in planner >

[GitHub] [flink] flinkbot edited a comment on pull request #11925: [FLINK-16996][table] Refactor planner and connectors to use new data structures

flinkbot edited a comment on pull request #11925: URL: https://github.com/apache/flink/pull/11925#issuecomment-620094263 ## CI report: * 80e121535f21ed3b4fc214e4902778fc804fe0b5 UNKNOWN * 65b255c54b2a1300e81415ae7f5047684fa3537f Travis:

[GitHub] [flink] flinkbot edited a comment on pull request #11927: [FLINK-17414][python][doc] Change the steps of building PyFlink in doc

flinkbot edited a comment on pull request #11927: URL: https://github.com/apache/flink/pull/11927#issuecomment-620352224 ## CI report: * dca256f92f29144cd3fbd9580275eb5fffc5efbc Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162343842) Azure:

[GitHub] [flink] flinkbot commented on pull request #11940: [FLINK-17440][network] Resolve potential buffer leak in output unspilling for unaligned checkpoints

flinkbot commented on pull request #11940: URL: https://github.com/apache/flink/pull/11940#issuecomment-620976302 ## CI report: * 35a1cb9c61c3bd360705b2df2bde08c5b3718c9d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

[ 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-29-11-55-12-995.png > Flink CEPOperator StateException >

[GitHub] [flink] flinkbot edited a comment on pull request #11905: [FLINK-17267] [table] legacy planner supports explain insert operation and introduce TableEnvironment#explainSql/Introduce TableEnvir

flinkbot edited a comment on pull request #11905: URL: https://github.com/apache/flink/pull/11905#issuecomment-619089324 ## CI report: * 0774d4cd257f4c5ab87e9106f16150d42c329ad0 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162027428) Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chun11 updated FLINK-17447: --- Description: !image-2020-04-29-11-55-12-995.png!!image-2020-04-29-10-21-10-717.png!  

[jira] [Updated] (FLINK-10934) Support application mode in kubernetes

[ https://issues.apache.org/jira/browse/FLINK-10934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-10934: -- Description: The Kubernetes do not have a default distributed storage and provide public api to ship

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

[ https://issues.apache.org/jira/browse/FLINK-16097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095037#comment-17095037 ] Bai Xu edited comment on FLINK-16097 at 4/29/20, 3:53 AM: -- Hi, [~jark],fix

[jira] [Updated] (FLINK-10934) Support application mode in kubernetes

[ https://issues.apache.org/jira/browse/FLINK-10934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-10934: -- Summary: Support application mode in kubernetes (was: Support per-job mode in kubernetes) > Support

[GitHub] [flink] spurthicriteo commented on pull request #11815: [FLINK-17253] Support viewfs for hadoop version < 2.7

spurthicriteo commented on pull request #11815: URL: https://github.com/apache/flink/pull/11815#issuecomment-620975706 @StephanEwen I tried setting up a viewfs mini cluster, but that seemed like an overkill. I added a simple testcase that mocks a filesystem with viewfs scheme.

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

[ https://issues.apache.org/jira/browse/FLINK-16097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095037#comment-17095037 ] Bai Xu edited comment on FLINK-16097 at 4/29/20, 3:52 AM: -- Hi, [~jark],fix

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

[ https://issues.apache.org/jira/browse/FLINK-16097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095037#comment-17095037 ] Bai Xu commented on FLINK-16097: Hi, [~jark],fix 16080 to 16097.Sorry about that. Is it correct now?Do I

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

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

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

lirui-apache commented on a change in pull request #11935: URL: https://github.com/apache/flink/pull/11935#discussion_r417050369 ## 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] [Commented] (FLINK-17334) Flink does not support HIVE UDFs with primitive return types

[ https://issues.apache.org/jira/browse/FLINK-17334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095031#comment-17095031 ] xin.ruan commented on FLINK-17334: -- ok > Flink does not support HIVE UDFs with primitive return types

[GitHub] [flink] flinkbot commented on pull request #11940: [FLINK-17440][network] Resolve potential buffer leak in output unspilling for unaligned checkpoints

flinkbot commented on pull request #11940: URL: https://github.com/apache/flink/pull/11940#issuecomment-620971451 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] wuchong commented on pull request #11925: [FLINK-16996][table] Refactor planner and connectors to use new data structures

wuchong commented on pull request #11925: URL: https://github.com/apache/flink/pull/11925#issuecomment-620970942 Thanks all for the reviewing. I have rebased the commits. Will merge this once builds passed. This is an

[GitHub] [flink] zhijiangW opened a new pull request #11940: [FLINK-17440][network] Resolve potential buffer leak in output unspilling for unaligned checkpoints

zhijiangW opened a new pull request #11940: URL: https://github.com/apache/flink/pull/11940 ## What is the purpose of the change If there are any exceptions thrown while interacting with `ChannelStateReader#readOutputData`, we should close the respective `BufferConsumer` to avoid

[jira] [Updated] (FLINK-17440) Potential Buffer leak in output unspilling for unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17440: --- Labels: pull-request-available (was: ) > Potential Buffer leak in output unspilling for

[jira] [Commented] (FLINK-17438) Flink StreamingFileSink chinese garbled

[ https://issues.apache.org/jira/browse/FLINK-17438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095027#comment-17095027 ] 颖 commented on FLINK-17438: --- [~lzljs3620320] yes，I used this to specify the encoding utf-8, but it didn't

[GitHub] [flink] flinkbot edited a comment on pull request #11905: [FLINK-17267] [table] legacy planner supports explain insert operation and introduce TableEnvironment#explainSql/Introduce TableEnvir

flinkbot edited a comment on pull request #11905: URL: https://github.com/apache/flink/pull/11905#issuecomment-619089324 ## CI report: * 0774d4cd257f4c5ab87e9106f16150d42c329ad0 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162027428) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11939: [FLINK-17334][hive] Flink does not support HIVE UDFs with primitive return types

flinkbot edited a comment on pull request #11939: URL: https://github.com/apache/flink/pull/11939#issuecomment-620965820 ## CI report: * 5aca5feda9c1c1bcc258a682160eb66b24b4531c Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/162591466) Bot

[GitHub] [flink] flinkbot edited a comment on pull request #11822: [FLINK-16788][Connector]ElasticSearch Connector SQL DDL add optional config (eg: username/password)

flinkbot edited a comment on pull request #11822: URL: https://github.com/apache/flink/pull/11822#issuecomment-616522760 ## CI report: * 16f89f88e2750769804c9c5e965721ea5d74c54a UNKNOWN * 806d40c34b4c6bc8cc56bd8ff8a62057f76fc751 Travis:

[jira] [Commented] (FLINK-17334) Flink does not support HIVE UDFs with primitive return types

[ https://issues.apache.org/jira/browse/FLINK-17334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095024#comment-17095024 ] Jingsong Lee commented on FLINK-17334: -- [~royruan] before closing, we should wait for 

[jira] [Reopened] (FLINK-17334) Flink does not support HIVE UDFs with primitive return types

[ https://issues.apache.org/jira/browse/FLINK-17334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reopened FLINK-17334: -- > Flink does not support HIVE UDFs with primitive return types >

[jira] [Updated] (FLINK-17334) Flink does not support HIVE UDFs with primitive return types

[ https://issues.apache.org/jira/browse/FLINK-17334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xin.ruan updated FLINK-17334: - Description: We are currently migrating Hive UDF to Flink. While testing compatibility, we found that

[jira] [Updated] (FLINK-17334) Flink does not support HIVE UDFs with primitive return types

[ https://issues.apache.org/jira/browse/FLINK-17334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xin.ruan updated FLINK-17334: - Attachment: (was: screenshot-1.png) > Flink does not support HIVE UDFs with primitive return types

[jira] [Resolved] (FLINK-17334) Flink does not support HIVE UDFs with primitive return types

[ https://issues.apache.org/jira/browse/FLINK-17334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xin.ruan resolved FLINK-17334. -- Resolution: Fixed > Flink does not support HIVE UDFs with primitive return types >

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

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

[GitHub] [flink] flinkbot commented on pull request #11939: [FLINK-17334][hive] Flink does not support HIVE UDFs with primitive return types

flinkbot commented on pull request #11939: URL: https://github.com/apache/flink/pull/11939#issuecomment-620965820 ## CI report: * 5aca5feda9c1c1bcc258a682160eb66b24b4531c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

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

[GitHub] [flink] godfreyhe commented on pull request #11905: [FLINK-17267] [table] legacy planner supports explain insert operation and introduce TableEnvironment#explainSql/Introduce TableEnvironment

godfreyhe commented on pull request #11905: URL: https://github.com/apache/flink/pull/11905#issuecomment-620965447 cc @danny0405 This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot edited a comment on pull request #11822: [FLINK-16788][Connector]ElasticSearch Connector SQL DDL add optional config (eg: username/password)

flinkbot edited a comment on pull request #11822: URL: https://github.com/apache/flink/pull/11822#issuecomment-616522760 ## CI report: * 16f89f88e2750769804c9c5e965721ea5d74c54a UNKNOWN * 794c7febb351309b3a41817031a748cd38f2e362 Travis:

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

JingsongLi edited a comment on pull request #11935: URL: https://github.com/apache/flink/pull/11935#issuecomment-620964950 > a separate PR to do the migration Looks good to me, but it is better to POC to verify. > create hive table from flink DDL out of the scope But

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

JingsongLi commented on pull request #11935: URL: https://github.com/apache/flink/pull/11935#issuecomment-620964950 > a separate PR to do the migration Looks good to me, but it is better to POC to verify. > create hive table from flink DDL out of the scope But we have

[GitHub] [flink] flinkbot commented on pull request #11939: [FLINK-17334][hive] Flink does not support HIVE UDFs with primitive return types

flinkbot commented on pull request #11939: URL: https://github.com/apache/flink/pull/11939#issuecomment-620964227 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] lirui-apache commented on pull request #11935: [FLINK-17431][sql-parser-hive][hive] Implement table DDLs for Hive di…

lirui-apache commented on pull request #11935: URL: https://github.com/apache/flink/pull/11935#issuecomment-620963790 Hey @JingsongLi > Migrate DDL by hive client to DDL by flink tEnv in tests. I have plans for this but the parser doesn't support DML yet. If we migrate now,

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

dianfu commented on a change in pull request #11832: URL: https://github.com/apache/flink/pull/11832#discussion_r417039454 ## File path: flink-python/pyflink/table/tests/test_pandas_conversion.py ## @@ -0,0 +1,147 @@

[jira] [Commented] (FLINK-17334) Flink does not support HIVE UDFs with primitive return types

[ https://issues.apache.org/jira/browse/FLINK-17334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095015#comment-17095015 ] Jingsong Lee commented on FLINK-17334: -- master: e8503986132f0ffaeec91caf5da6ece2d0eb70d3 > Flink

[GitHub] [flink] JingsongLi commented on pull request #11939: [FLINK-17334] HIVE UDF BUGFIX

JingsongLi commented on pull request #11939: URL: https://github.com/apache/flink/pull/11939#issuecomment-620962969 Thanks @Ruan-Xin , can you modify title to `[FLINK-17334][hive] Flink does not support HIVE UDFs with primitive return types`

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11822: [FLINK-16788][Connector]ElasticSearch Connector SQL DDL add optional config (eg: username/password)

KarmaGYZ commented on a change in pull request #11822: URL: https://github.com/apache/flink/pull/11822#discussion_r417039344 ## File path: flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/table/descriptors/ElasticsearchValidator.java ## @@

[GitHub] [flink] Ruan-Xin opened a new pull request #11939: [FLINK-17334] HIVE UDF BUGFIX

Ruan-Xin opened a new pull request #11939: URL: https://github.com/apache/flink/pull/11939 For more information, please check: https://github.com/apache/flink/pull/11876 This is an automated message from the Apache Git

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

[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095013#comment-17095013 ] Yang Wang commented on FLINK-17444: --- I think it just because we exclude

[GitHub] [flink] zhisheng17 commented on pull request #11822: [FLINK-16788][Connector]ElasticSearch Connector SQL DDL add optional config (eg: username/password)

zhisheng17 commented on pull request #11822: URL: https://github.com/apache/flink/pull/11822#issuecomment-620962166 @KarmaGYZ Thanks help me review the code, I had fixed, I will add an integration test or end-to-end test When free

[jira] [Updated] (FLINK-17416) Flink-kubernetes doesn't work on java 8 8u252

[ https://issues.apache.org/jira/browse/FLINK-17416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangxiyuan updated FLINK-17416: --- Description: When using java-8-8u252 version, the flink container end-to-end failed. The test 

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

dianfu commented on a change in pull request #11832: URL: https://github.com/apache/flink/pull/11832#discussion_r417037819 ## File path: flink-python/pyflink/table/tests/test_pandas_conversion.py ## @@ -0,0 +1,147 @@

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

[ https://issues.apache.org/jira/browse/FLINK-17453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095008#comment-17095008 ] Jiayi Liao commented on FLINK-17453: I'm still not sure about the root cause. Does anyone has any

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

hequn8128 commented on pull request #11832: URL: https://github.com/apache/flink/pull/11832#issuecomment-620961520 BTW. Would be great if you can rebase to the master. The interface in BaseRow has been changed, i.e., `getHeader()` has been replaced with `getRowKind()`.

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

Jiayi Liao created FLINK-17453: -- Summary: KyroSerializer throws IndexOutOfBoundsException type java.util.PriorityQueue Key: FLINK-17453 URL: https://issues.apache.org/jira/browse/FLINK-17453 Project:

[GitHub] [flink] zhisheng17 commented on a change in pull request #11822: [FLINK-16788][Connector]ElasticSearch Connector SQL DDL add optional config (eg: username/password)

zhisheng17 commented on a change in pull request #11822: URL: https://github.com/apache/flink/pull/11822#discussion_r417035037 ## File path: flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/table/descriptors/ElasticsearchValidator.java ## @@

[jira] [Created] (FLINK-17452) Support creating Hive tables with constraints

Rui Li created FLINK-17452: -- Summary: Support creating Hive tables with constraints Key: FLINK-17452 URL: https://issues.apache.org/jira/browse/FLINK-17452 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17450) Implement function DDLs for Hive dialect

Rui Li created FLINK-17450: -- Summary: Implement function DDLs for Hive dialect Key: FLINK-17450 URL: https://issues.apache.org/jira/browse/FLINK-17450 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17451) Implement view DDLs for Hive dialect

Rui Li created FLINK-17451: -- Summary: Implement view DDLs for Hive dialect Key: FLINK-17451 URL: https://issues.apache.org/jira/browse/FLINK-17451 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17449) Implement ADD/DROP partitions

Rui Li created FLINK-17449: -- Summary: Implement ADD/DROP partitions Key: FLINK-17449 URL: https://issues.apache.org/jira/browse/FLINK-17449 Project: Flink Issue Type: Sub-task Components:

[jira] [Assigned] (FLINK-17440) Potential Buffer leak in output unspilling for unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17440: Assignee: Zhijiang > Potential Buffer leak in output unspilling for unaligned checkpoints >

[jira] [Created] (FLINK-17448) Implement table DDLs for Hive dialect part2

Rui Li created FLINK-17448: -- Summary: Implement table DDLs for Hive dialect part2 Key: FLINK-17448 URL: https://issues.apache.org/jira/browse/FLINK-17448 Project: Flink Issue Type: Sub-task

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

[ https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094998#comment-17094998 ] chun11 commented on FLINK-17447: dataStream with multi cep patterns ， Flink job CepOperator >

[jira] [Comment Edited] (FLINK-17447) Flink CEPOperator StateException

[ https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094998#comment-17094998 ] chun11 edited comment on FLINK-17447 at 4/29/20, 2:25 AM: -- dataStream

[GitHub] [flink] zhisheng17 commented on a change in pull request #11822: [FLINK-16788][Connector]ElasticSearch Connector SQL DDL add optional config (eg: username/password)

zhisheng17 commented on a change in pull request #11822: URL: https://github.com/apache/flink/pull/11822#discussion_r417032637 ## File path:

[jira] [Commented] (FLINK-17186) set eventtime from source with timestampsFromField funcation at flink 1.10 error

[ https://issues.apache.org/jira/browse/FLINK-17186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094997#comment-17094997 ] gkgkgk commented on FLINK-17186: And, I think this issue is the same reason as：

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

[ 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-29-10-23-14-306.png > Flink CEPOperator StateException >

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

[ https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chun11 updated FLINK-17447: --- Description: !image-2020-04-29-10-21-10-717.png!   !image-2020-04-29-10-23-14-306.png!  

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

[ 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-29-10-22-20-645.png > Flink CEPOperator StateException >

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

[ https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chun11 updated FLINK-17447: --- Description: !image-2020-04-29-10-21-10-717.png! > Flink CEPOperator StateException >

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

[ 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-29-10-21-10-717.png > Flink CEPOperator StateException >

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

chun11 created FLINK-17447: -- Summary: Flink CEPOperator StateException Key: FLINK-17447 URL: https://issues.apache.org/jira/browse/FLINK-17447 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-17186) set eventtime from source with timestampsFromField funcation at flink 1.10 error

[ https://issues.apache.org/jira/browse/FLINK-17186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094992#comment-17094992 ] gkgkgk commented on FLINK-17186: [~zjfplayer] ,[~jark] ,[~tonychan] Because the types of rowtiem and

[jira] [Updated] (FLINK-15678) Optimize producing primary key without row number in special Top 1

[ https://issues.apache.org/jira/browse/FLINK-15678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15678: --- Issue Type: Improvement (was: Bug) > Optimize producing primary key without row number in special

  1   2   3   4   5   >