[GitHub] [flink] flinkbot commented on pull request #12865: [FLINK-18264][doc] Translate External Resources page to Chinese

2020-07-09 Thread GitBox
flinkbot commented on pull request #12865: URL: https://github.com/apache/flink/pull/12865#issuecomment-656517840 ## CI report: * 1d004f6c97f03f46c8f29fbc348dac9036bdf493 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Created] (FLINK-18551) Don't need to download flink-conf.yaml when launching taskmanager on Yarn mode

2020-07-09 Thread Yumeng Zhang (Jira)
Yumeng Zhang created FLINK-18551: Summary: Don't need to download flink-conf.yaml when launching taskmanager on Yarn mode Key: FLINK-18551 URL: https://issues.apache.org/jira/browse/FLINK-18551 Projec

[GitHub] [flink] flinkbot commented on pull request #12865: [FLINK-18264][doc] Translate External Resources page to Chinese

2020-07-09 Thread GitBox
flinkbot commented on pull request #12865: URL: https://github.com/apache/flink/pull/12865#issuecomment-656512406 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 pro

[jira] [Updated] (FLINK-18264) Translate the "External Resource Framework" page into Chinese

2020-07-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18264: --- Labels: pull-request-available (was: ) > Translate the "External Resource Framework" page i

[GitHub] [flink] KarmaGYZ opened a new pull request #12865: [FLINK-18264][doc] Translate External Resources page to Chinese

2020-07-09 Thread GitBox
KarmaGYZ opened a new pull request #12865: URL: https://github.com/apache/flink/pull/12865 ## What is the purpose of the change Translate External Resources page to Chinese ## Verifying this change This change is a trivial rework / code cleanup without any test cover

[GitHub] [flink] flinkbot edited a comment on pull request #12864: [FLINK-18487][table] Datagen and Blackhole factory omits unrecognized properties silently

2020-07-09 Thread GitBox
flinkbot edited a comment on pull request #12864: URL: https://github.com/apache/flink/pull/12864#issuecomment-656503840 ## CI report: * 499f80cfa226fe3cf8dbc1edc707e76b01fe1182 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #12864: [FLINK-18487][table] Datagen and Blackhole factory omits unrecognized properties silently

2020-07-09 Thread GitBox
flinkbot commented on pull request #12864: URL: https://github.com/apache/flink/pull/12864#issuecomment-656503840 ## CI report: * 499f80cfa226fe3cf8dbc1edc707e76b01fe1182 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #8366: [FLINK-12415][doc-zh]Translate HistoryServer page into Chinese

2020-07-09 Thread GitBox
flinkbot edited a comment on pull request #8366: URL: https://github.com/apache/flink/pull/8366#issuecomment-656497430 ## CI report: * 29a26bdf91b8eeffe0d24925f1bf187c1692bc53 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/175095735) Bot commands

[GitHub] [flink] flinkbot commented on pull request #12864: [FLINK-18487][table] Datagen and Blackhole factory omits unrecognized properties silently

2020-07-09 Thread GitBox
flinkbot commented on pull request #12864: URL: https://github.com/apache/flink/pull/12864#issuecomment-656500646 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 pro

[GitHub] [flink] JingsongLi opened a new pull request #12864: [FLINK-18487][table] Datagen and Blackhole factory omits unrecognized properties silently

2020-07-09 Thread GitBox
JingsongLi opened a new pull request #12864: URL: https://github.com/apache/flink/pull/12864 ## What is the purpose of the change For the following DDL, we just omits the unrecognized property 'records-per-second'. ``` CREATE TABLE MyDataGen ( int_field int, doubl

[jira] [Updated] (FLINK-18487) New table source factory omits unrecognized properties silently

2020-07-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18487: --- Labels: pull-request-available (was: ) > New table source factory omits unrecognized proper

[jira] [Commented] (FLINK-18549) flink 1.11 can not commit partition automatically

2020-07-09 Thread Jun Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155165#comment-17155165 ] Jun Zhang commented on FLINK-18549: --- To add, if I use a bounded source, such as ‘bsEnv

[GitHub] [flink] flinkbot commented on pull request #8366: [FLINK-12415][doc-zh]Translate HistoryServer page into Chinese

2020-07-09 Thread GitBox
flinkbot commented on pull request #8366: URL: https://github.com/apache/flink/pull/8366#issuecomment-656497430 ## CI report: * 29a26bdf91b8eeffe0d24925f1bf187c1692bc53 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run

[jira] [Commented] (FLINK-18549) flink 1.11 can not commit partition automatically

2020-07-09 Thread Jun Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155161#comment-17155161 ] Jun Zhang commented on FLINK-18549: --- hi ,[~jark]: In my test, the partition result fi

[jira] [Commented] (FLINK-18545) Sql api cannot special flink job name

2020-07-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155160#comment-17155160 ] Jark Wu commented on FLINK-18545: - I'm fine to add {{StatementSet#execute(jobName)}}. Bu

[GitHub] [flink] klion26 commented on a change in pull request #8366: [FLINK-12415][doc-zh]Translate HistoryServer page into Chinese

2020-07-09 Thread GitBox
klion26 commented on a change in pull request #8366: URL: https://github.com/apache/flink/pull/8366#discussion_r452632484 ## File path: docs/monitoring/historyserver.zh.md ## @@ -22,62 +22,62 @@ specific language governing permissions and limitations under the License. -->

[GitHub] [flink] flinkbot edited a comment on pull request #12863: [FLINK-18539][datastream] Fix StreamExecutionEnvironment#addSource(SourceFunction, TypeInformation) doesn't use the user defined type

2020-07-09 Thread GitBox
flinkbot edited a comment on pull request #12863: URL: https://github.com/apache/flink/pull/12863#issuecomment-656486652 ## CI report: * 152bf0198f7cba67ea84df2b5c8e59bf82eb0378 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Comment Edited] (FLINK-18478) AvroDeserializationSchema does not work with types generated by avrohugger

2020-07-09 Thread Georg Heiler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155125#comment-17155125 ] Georg Heiler edited comment on FLINK-18478 at 7/10/20, 5:18 AM: --

[jira] [Comment Edited] (FLINK-18478) AvroDeserializationSchema does not work with types generated by avrohugger

2020-07-09 Thread Georg Heiler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155125#comment-17155125 ] Georg Heiler edited comment on FLINK-18478 at 7/10/20, 5:14 AM: --

[GitHub] [flink] klion26 commented on pull request #9716: [FLINK-14116][docs] Translate changes on Getting Started Overview to …

2020-07-09 Thread GitBox
klion26 commented on pull request #9716: URL: https://github.com/apache/flink/pull/9716#issuecomment-656486844 @rongzhg Do you still work on this PR, could you please rebase the master to resolve the conflict? This is an aut

[GitHub] [flink] flinkbot commented on pull request #12863: [FLINK-18539][datastream] Fix StreamExecutionEnvironment#addSource(SourceFunction, TypeInformation) doesn't use the user defined type inform

2020-07-09 Thread GitBox
flinkbot commented on pull request #12863: URL: https://github.com/apache/flink/pull/12863#issuecomment-656486652 ## CI report: * 152bf0198f7cba67ea84df2b5c8e59bf82eb0378 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] freezhan edited a comment on pull request #12157: [FLINK-17691][Connectors/Kafka] fix the bug FlinkKafkaProducer011 transactional.id too long when use Semantic.EXACTLY_ONCE mode

2020-07-09 Thread GitBox
freezhan edited a comment on pull request #12157: URL: https://github.com/apache/flink/pull/12157#issuecomment-656483534 In addition, our internal temporary repair method is ```java this.prefix = prefix.substring(0, Math.min(prefix.length(), 200)) + "-" + EncodingUtils.hex(Encodin

[jira] [Commented] (FLINK-18478) AvroDeserializationSchema does not work with types generated by avrohugger

2020-07-09 Thread Georg Heiler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155125#comment-17155125 ] Georg Heiler commented on FLINK-18478: -- I have created a fresh local build of flink

[GitHub] [flink] freezhan commented on pull request #12157: [FLINK-17691][Connectors/Kafka] fix the bug FlinkKafkaProducer011 transactional.id too long when use Semantic.EXACTLY_ONCE mode

2020-07-09 Thread GitBox
freezhan commented on pull request #12157: URL: https://github.com/apache/flink/pull/12157#issuecomment-656483534 In addition, our internal temporary repair method is ```java this.prefix = prefix.substring(0, Math.min(prefix.length(), 200)) + "-" + EncodingUtils.hex(E

[jira] [Commented] (FLINK-18545) Sql api cannot special flink job name

2020-07-09 Thread venn wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155123#comment-17155123 ] venn wu commented on FLINK-18545: - [~godfreyhe]  it's good for me, but i still think, It

[GitHub] [flink] freezhan commented on pull request #12157: [FLINK-17691][Connectors/Kafka] fix the bug FlinkKafkaProducer011 transactional.id too long when use Semantic.EXACTLY_ONCE mode

2020-07-09 Thread GitBox
freezhan commented on pull request #12157: URL: https://github.com/apache/flink/pull/12157#issuecomment-656480710 @aljoscha How about letting the user pass this prefix parameter, then then also add a check inside the generator to verify that we really obey the length cap. Transacti

[GitHub] [flink] flinkbot commented on pull request #12863: [FLINK-18539][datastream] Fix StreamExecutionEnvironment#addSource(SourceFunction, TypeInformation) doesn't use the user defined type inform

2020-07-09 Thread GitBox
flinkbot commented on pull request #12863: URL: https://github.com/apache/flink/pull/12863#issuecomment-656479906 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 pro

[jira] [Updated] (FLINK-18539) StreamExecutionEnvironment#addSource(SourceFunction, TypeInformation) doesn't use the user defined type information

2020-07-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18539: --- Labels: pull-request-available (was: ) > StreamExecutionEnvironment#addSource(SourceFunctio

[GitHub] [flink] wuchong commented on pull request #12863: [FLINK-18539][datastream] Fix StreamExecutionEnvironment#addSource(SourceFunction, TypeInformation) doesn't use the user defined type informa

2020-07-09 Thread GitBox
wuchong commented on pull request #12863: URL: https://github.com/apache/flink/pull/12863#issuecomment-656479495 Could you help to review this? @aljoscha @becketqin This is an automated message from the Apache Git Service. T

[GitHub] [flink] wuchong opened a new pull request #12863: [FLINK-18539][datastream] Fix StreamExecutionEnvironment#addSource(SourceFunction, TypeInformation) doesn't use the user defined type informa

2020-07-09 Thread GitBox
wuchong opened a new pull request #12863: URL: https://github.com/apache/flink/pull/12863 ## What is the purpose of the change Fix `StreamExecutionEnvironment#addSource(SourceFunction, TypeInformation)` doesn't use the user defined `TypeInformation` as the output type

[GitHub] [flink-web] klion26 commented on pull request #345: [FLINK-17491] Translate Training page on project website

2020-07-09 Thread GitBox
klion26 commented on pull request #345: URL: https://github.com/apache/flink-web/pull/345#issuecomment-656479351 hi @liying919, what's the status of current PR? This is an automated message from the Apache Git Service. To re

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

2020-07-09 Thread GitBox
klion26 commented on pull request #9097: URL: https://github.com/apache/flink/pull/9097#issuecomment-656478631 @LakeShen seems this pr related to FLINK-11607, could you please correct the title of the current pr This is an a

[GitHub] [flink] flinkbot edited a comment on pull request #12715: [FLINK-18361] Support username and password options for new Elasticse…

2020-07-09 Thread GitBox
flinkbot edited a comment on pull request #12715: URL: https://github.com/apache/flink/pull/12715#issuecomment-646501745 ## CI report: * a4c399810f91fb65b6a343ba9ee49e224205c68c UNKNOWN * 53207becc1f51cca448d4cd624f26b92d114a531 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-18002) Support forcing varchar type in Json format

2020-07-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18002: Priority: Major (was: Minor) > Support forcing varchar type in Json format >

[jira] [Updated] (FLINK-18002) Support forcing varchar type in Json format

2020-07-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18002: Fix Version/s: 1.12.0 > Support forcing varchar type in Json format >

[jira] [Commented] (FLINK-18549) flink 1.11 can not commit partition automatically

2020-07-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155088#comment-17155088 ] Jark Wu commented on FLINK-18549: - Do you mean there is no partition files on HDFS? I t

[jira] [Issue Comment Deleted] (FLINK-18545) Sql api cannot special flink job name

2020-07-09 Thread venn wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] venn wu updated FLINK-18545: Comment: was deleted (was: it's good for me, may you assign this issue to me, thanks) > Sql api cannot sp

[jira] [Commented] (FLINK-18545) Sql api cannot special flink job name

2020-07-09 Thread venn wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155087#comment-17155087 ] venn wu commented on FLINK-18545: - it's good for me, may you assign this issue to me, th

[jira] [Assigned] (FLINK-18550) use TableResult#collect to get select result for sql client

2020-07-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-18550: --- Assignee: godfrey he > use TableResult#collect to get select result for sql client > --

[GitHub] [flink] flinkbot edited a comment on pull request #12715: [FLINK-18361] Support username and password options for new Elasticse…

2020-07-09 Thread GitBox
flinkbot edited a comment on pull request #12715: URL: https://github.com/apache/flink/pull/12715#issuecomment-646501745 ## CI report: * a4c399810f91fb65b6a343ba9ee49e224205c68c UNKNOWN * 53207becc1f51cca448d4cd624f26b92d114a531 Azure: [FAILURE](https://dev.azure.com/apache-fl

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

2020-07-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155081#comment-17155081 ] Jark Wu commented on FLINK-18071: - Hi [~sewen] [~gaoyunhaii], what's the status of this

[jira] [Commented] (FLINK-18477) ChangelogSocketExample does not work

2020-07-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155077#comment-17155077 ] Jark Wu commented on FLINK-18477: - Hi [~twalthr], do you have time to fix this? I think

[jira] [Assigned] (FLINK-18539) StreamExecutionEnvironment#addSource(SourceFunction, TypeInformation) doesn't use the user defined type information

2020-07-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-18539: --- Assignee: Jark Wu > StreamExecutionEnvironment#addSource(SourceFunction, TypeInformation) doesn't

[jira] [Updated] (FLINK-15221) Support exactly once sink delivery semantic for Kafka in Table API

2020-07-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15221: Summary: Support exactly once sink delivery semantic for Kafka in Table API (was: supporting Exactly-once

[jira] [Closed] (FLINK-15221) supporting Exactly-once for kafka table APi

2020-07-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-15221. --- Resolution: Fixed Implemented in master (1.12.0): fce502cbc481e97b951259ac9350d0e401c68774 > supporting Exa

[GitHub] [flink] wuchong closed pull request #12805: [FLINK-15221][table api]support fault-tolerant semantic for kafka table api

2020-07-09 Thread GitBox
wuchong closed pull request #12805: URL: https://github.com/apache/flink/pull/12805 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Assigned] (FLINK-16835) Replace TableConfig with Configuration

2020-07-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-16835: --- Assignee: Shengkai Fang > Replace TableConfig with Configuration >

[jira] [Commented] (FLINK-18550) use TableResult#collect to get select result for sql client

2020-07-09 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155069#comment-17155069 ] godfrey he commented on FLINK-18550: I would like to take this ticket > use TableRe

[jira] [Created] (FLINK-18550) use TableResult#collect to get select result for sql client

2020-07-09 Thread godfrey he (Jira)
godfrey he created FLINK-18550: -- Summary: use TableResult#collect to get select result for sql client Key: FLINK-18550 URL: https://issues.apache.org/jira/browse/FLINK-18550 Project: Flink Issu

[GitHub] [flink] liuyongvs commented on a change in pull request #12851: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-09 Thread GitBox
liuyongvs commented on a change in pull request #12851: URL: https://github.com/apache/flink/pull/12851#discussion_r452604505 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/factories/TestValuesTableFactory.java ## @@ -449,6 +48

[GitHub] [flink] liuyongvs commented on a change in pull request #12851: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-09 Thread GitBox
liuyongvs commented on a change in pull request #12851: URL: https://github.com/apache/flink/pull/12851#discussion_r452604095 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushFilterIntoTableSourceScanRule.java

[GitHub] [flink] liuyongvs commented on a change in pull request #12851: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-09 Thread GitBox
liuyongvs commented on a change in pull request #12851: URL: https://github.com/apache/flink/pull/12851#discussion_r452603891 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushFilterIntoTableSourceScanRule.java

[GitHub] [flink] liuyongvs commented on a change in pull request #12851: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-09 Thread GitBox
liuyongvs commented on a change in pull request #12851: URL: https://github.com/apache/flink/pull/12851#discussion_r452585081 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushFilterIntoTableSourceScanRule.java

[GitHub] [flink] liuyongvs commented on a change in pull request #12851: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-09 Thread GitBox
liuyongvs commented on a change in pull request #12851: URL: https://github.com/apache/flink/pull/12851#discussion_r452603535 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushFilterIntoTableSourceScanRule.java

[jira] [Assigned] (FLINK-18487) New table source factory omits unrecognized properties silently

2020-07-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-18487: Assignee: Jingsong Lee > New table source factory omits unrecognized properties silently

[jira] [Commented] (FLINK-18547) the filesystem sql connector can't work well

2020-07-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155067#comment-17155067 ] Jingsong Lee commented on FLINK-18547: -- Discussed offline, not a problem. > the fi

[jira] [Closed] (FLINK-18547) the filesystem sql connector can't work well

2020-07-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-18547. Resolution: Not A Problem > the filesystem sql connector can't work well > ---

[jira] [Commented] (FLINK-9395) Outer Joins with array types on the outer join input fail

2020-07-09 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155066#comment-17155066 ] Caizhi Weng commented on FLINK-9395: As this issue only affects legacy planner, I'll

[jira] [Updated] (FLINK-18549) flink 1.11 can not commit partition automatically

2020-07-09 Thread Jun Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Zhang updated FLINK-18549: -- Description: I use the sql of flink 1.11, read from kafka and writing to hdfs, I found that the parti

[jira] [Created] (FLINK-18549) flink 1.11 can not commit partition automatically

2020-07-09 Thread Jun Zhang (Jira)
Jun Zhang created FLINK-18549: - Summary: flink 1.11 can not commit partition automatically Key: FLINK-18549 URL: https://issues.apache.org/jira/browse/FLINK-18549 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-9395) Outer Joins with array types on the outer join input fail

2020-07-09 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-9395: --- Component/s: (was: Table SQL / Planner) Table SQL / Legacy Planner > Outer Joins

[jira] [Updated] (FLINK-9395) Outer Joins with array types on the outer join input fail

2020-07-09 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-9395: --- Priority: Minor (was: Major) > Outer Joins with array types on the outer join input fail > -

[jira] [Commented] (FLINK-17144) Input type generalization does not work correctly for ARRAY and MAP in sql

2020-07-09 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155065#comment-17155065 ] Caizhi Weng commented on FLINK-17144: - To fully solve this issue we need implicit ty

[jira] [Commented] (FLINK-18545) Sql api cannot special flink job name

2020-07-09 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155062#comment-17155062 ] godfrey he commented on FLINK-18545: [~wxchunj...@163.com], this is by design. becau

[jira] [Updated] (FLINK-17144) Input type generalization does not work correctly for ARRAY and MAP in sql

2020-07-09 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-17144: Affects Version/s: 1.10.0 1.11.0 > Input type generalization does not work

[GitHub] [flink] liuyongvs commented on a change in pull request #12851: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-09 Thread GitBox
liuyongvs commented on a change in pull request #12851: URL: https://github.com/apache/flink/pull/12851#discussion_r452597228 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushFilterIntoTableSourceScanRule.java

[jira] [Commented] (FLINK-18145) Segment optimization does not work in blink ?

2020-07-09 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155058#comment-17155058 ] godfrey he commented on FLINK-18145: [~hehuiyuan] from 1.11 both {{StreamTableEnvrio

[jira] [Comment Edited] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-07-09 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155006#comment-17155006 ] Julius Michaelis edited comment on FLINK-18150 at 7/10/20, 2:55 AM: --

[jira] [Comment Edited] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-07-09 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155006#comment-17155006 ] Julius Michaelis edited comment on FLINK-18150 at 7/10/20, 2:54 AM: --

[GitHub] [flink] liuyongvs commented on a change in pull request #12851: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-09 Thread GitBox
liuyongvs commented on a change in pull request #12851: URL: https://github.com/apache/flink/pull/12851#discussion_r452594080 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/factories/TestValuesTableFactory.java ## @@ -460,34 +6

[jira] [Commented] (FLINK-18503) bug occurs when `HeapReducingState#add` method handles null

2020-07-09 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155055#comment-17155055 ] Yun Tang commented on FLINK-18503: -- I think this issue is duplicate with FLINK-15424 >

[jira] [Commented] (FLINK-18438) TaskManager start failed

2020-07-09 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155053#comment-17155053 ] Xintong Song commented on FLINK-18438: -- Could you double check that 1.8.0_101 is th

[jira] [Comment Edited] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-07-09 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155006#comment-17155006 ] Julius Michaelis edited comment on FLINK-18150 at 7/10/20, 2:42 AM: --

[GitHub] [flink] liuyongvs commented on a change in pull request #12851: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-09 Thread GitBox
liuyongvs commented on a change in pull request #12851: URL: https://github.com/apache/flink/pull/12851#discussion_r452591843 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/factories/TestValuesTableFactory.java ## @@ -449,6 +48

[jira] [Created] (FLINK-18548) Improve FlinkCalcMergeRule to merge calc nodes better

2020-07-09 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-18548: -- Summary: Improve FlinkCalcMergeRule to merge calc nodes better Key: FLINK-18548 URL: https://issues.apache.org/jira/browse/FLINK-18548 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-07-09 Thread Julius Michaelis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155006#comment-17155006 ] Julius Michaelis edited comment on FLINK-18150 at 7/10/20, 2:34 AM: --

[jira] [Comment Edited] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

2020-07-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155048#comment-17155048 ] Dian Fu edited comment on FLINK-17274 at 7/10/20, 2:32 AM: --- ma

[jira] [Assigned] (FLINK-14620) Rewrite the elasticsearch related end-to-end tests by using the newly introduce e2e java framework

2020-07-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14620: --- Assignee: Yangze Guo > Rewrite the elasticsearch related end-to-end tests by using the newly > int

[jira] [Comment Edited] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

2020-07-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155048#comment-17155048 ] Dian Fu edited comment on FLINK-17274 at 7/10/20, 2:31 AM: --- ht

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

2020-07-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155048#comment-17155048 ] Dian Fu commented on FLINK-17274: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-14620) Rewrite the elasticsearch related end-to-end tests by using the newly introduce e2e java framework

2020-07-09 Thread Zheng Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155046#comment-17155046 ] Zheng Hu commented on FLINK-14620: -- [~karmagyz] Please go ahead ,Mind to assign thi

[jira] [Closed] (FLINK-18453) Stack overflow of AggregateITCase#testAggregationCodeSplit on Azure

2020-07-09 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li closed FLINK-18453. -- Resolution: Fixed > Stack overflow of AggregateITCase#testAggregationCodeSplit on Azure > ---

[jira] [Commented] (FLINK-18542) GPUDiscoveryScriptTest fails for permission denied

2020-07-09 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155044#comment-17155044 ] Yangze Guo commented on FLINK-18542: [~Paul Lin] Could you share the entire commands

[jira] [Commented] (FLINK-18453) Stack overflow of AggregateITCase#testAggregationCodeSplit on Azure

2020-07-09 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155045#comment-17155045 ] Benchao Li commented on FLINK-18453: Fixed via e162bd7e9064032c0fd5f2035e1a23249f3ca

[GitHub] [flink] libenchao closed pull request #12861: [FLINK-18453][tests] Fix overflow of AggregateITCase#testAggregationC…

2020-07-09 Thread GitBox
libenchao closed pull request #12861: URL: https://github.com/apache/flink/pull/12861 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go t

[jira] [Updated] (FLINK-18547) the filesystem sql connector can't work well

2020-07-09 Thread tinny cat (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tinny cat updated FLINK-18547: -- Description: The options ‘partition.time-extractor.kind’,‘partition.time-extractor.class’,‘partition.

[jira] [Updated] (FLINK-18547) the filesystem sql connector can't work well

2020-07-09 Thread tinny cat (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tinny cat updated FLINK-18547: -- Description: The options ‘partition.time-extractor.kind’,‘partition.time-extractor.class’,‘partition.

[jira] [Created] (FLINK-18547) the filesystem sql connector can't work well

2020-07-09 Thread tinny cat (Jira)
tinny cat created FLINK-18547: - Summary: the filesystem sql connector can't work well Key: FLINK-18547 URL: https://issues.apache.org/jira/browse/FLINK-18547 Project: Flink Issue Type: Bug

[GitHub] [flink] liuyongvs commented on a change in pull request #12851: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-09 Thread GitBox
liuyongvs commented on a change in pull request #12851: URL: https://github.com/apache/flink/pull/12851#discussion_r452586065 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/rules/logical/PushFilterIntoTableSourceScanRuleTest.java

[jira] [Commented] (FLINK-18535) Elasticsearch connector hangs for threads deadlocked

2020-07-09 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155042#comment-17155042 ] Yangze Guo commented on FLINK-18535: Thanks for the pointer. I think this issue has

[GitHub] [flink] liuyongvs commented on a change in pull request #12851: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-09 Thread GitBox
liuyongvs commented on a change in pull request #12851: URL: https://github.com/apache/flink/pull/12851#discussion_r452585081 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushFilterIntoTableSourceScanRule.java

[GitHub] [flink] godfreyhe commented on a change in pull request #12851: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-09 Thread GitBox
godfreyhe commented on a change in pull request #12851: URL: https://github.com/apache/flink/pull/12851#discussion_r452219045 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/factories/TestValuesTableFactory.java ## @@ -449,6 +48

[GitHub] [flink] godfreyhe commented on a change in pull request #12851: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-09 Thread GitBox
godfreyhe commented on a change in pull request #12851: URL: https://github.com/apache/flink/pull/12851#discussion_r452584302 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushFilterIntoTableSourceScanRule.java

[GitHub] [flink] KarmaGYZ commented on pull request #12715: [FLINK-18361] Support username and password options for new Elasticse…

2020-07-09 Thread GitBox
KarmaGYZ commented on pull request #12715: URL: https://github.com/apache/flink/pull/12715#issuecomment-656438990 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] KarmaGYZ commented on pull request #12715: [FLINK-18361] Support username and password options for new Elasticse…

2020-07-09 Thread GitBox
KarmaGYZ commented on pull request #12715: URL: https://github.com/apache/flink/pull/12715#issuecomment-656438783 @wuchong It seems that the failure is caused by network error during downloading the elasticsearch. This is an

[GitHub] [flink] liuyongvs commented on a change in pull request #12851: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-09 Thread GitBox
liuyongvs commented on a change in pull request #12851: URL: https://github.com/apache/flink/pull/12851#discussion_r452582266 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/factories/TestValuesTableFactory.java ## @@ -449,6 +48

[GitHub] [flink] liuyongvs commented on a change in pull request #12851: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-09 Thread GitBox
liuyongvs commented on a change in pull request #12851: URL: https://github.com/apache/flink/pull/12851#discussion_r452582119 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushFilterIntoTableSourceScanRule.java

[GitHub] [flink] liuyongvs commented on a change in pull request #12851: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-09 Thread GitBox
liuyongvs commented on a change in pull request #12851: URL: https://github.com/apache/flink/pull/12851#discussion_r452581704 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushFilterIntoTableSourceScanRule.java

[GitHub] [flink] liuyongvs commented on a change in pull request #12851: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-09 Thread GitBox
liuyongvs commented on a change in pull request #12851: URL: https://github.com/apache/flink/pull/12851#discussion_r452580883 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/factories/TestValuesTableFactory.java ## @@ -240,6 +26

[GitHub] [flink] liuyongvs commented on a change in pull request #12851: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

2020-07-09 Thread GitBox
liuyongvs commented on a change in pull request #12851: URL: https://github.com/apache/flink/pull/12851#discussion_r452580785 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/rules/logical/PushFilterIntoTableSourceScanRuleTest.java

  1   2   3   4   >