[GitHub] [flink] TJX2014 commented on a change in pull request #12819: [FLINK-18440][table-planner-blink] Allow ROW/RANGE with RANK, DENSE_RANK or ROW_NUMBER functions on window stream

2020-07-06 Thread GitBox
TJX2014 commented on a change in pull request #12819: URL: https://github.com/apache/flink/pull/12819#discussion_r450002947 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/calcite/sql/SqlRankFunction.java ## @@ -0,0 +1,50 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-18493) Make target home directory used to store yarn files configurable

2020-07-06 Thread Congxian Qiu(klion26) (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151770#comment-17151770 ] Congxian Qiu(klion26) commented on FLINK-18493: --- +1 for this feature. > Make target home

[jira] [Updated] (FLINK-18493) Make target home directory used to store yarn files configurable

2020-07-06 Thread Kevin Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Zhang updated FLINK-18493: Description: When submitting applications to yarn, the file system's default home directory, like

[GitHub] [flink] TJX2014 commented on a change in pull request #12819: [FLINK-18440][table-planner-blink] Allow ROW/RANGE with RANK, DENSE_RANK or ROW_NUMBER functions on window stream

2020-07-06 Thread GitBox
TJX2014 commented on a change in pull request #12819: URL: https://github.com/apache/flink/pull/12819#discussion_r450003842 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/TableScanTest.scala ## @@ -357,4

[GitHub] [flink] flinkbot edited a comment on pull request #12819: [FLINK-18440][table-planner-blink] Allow ROW/RANGE with RANK, DENSE_RANK or ROW_NUMBER functions on window stream

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12819: URL: https://github.com/apache/flink/pull/12819#issuecomment-653477506 ## CI report: * 9d62744ad9b4c2796aa02b96096b5340dd6163b8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12756: [FLINK-18296][json] add support for TIMESTAMP_WITH_LOCAL_ZONE and fix…

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12756: URL: https://github.com/apache/flink/pull/12756#issuecomment-648131818 ## CI report: * 39748e268b2b2d7f832549bb0a9241db7191d55a Azure:

[jira] [Created] (FLINK-18493) Make target home directory used to store yarn files configurable

2020-07-06 Thread Kevin Zhang (Jira)
Kevin Zhang created FLINK-18493: --- Summary: Make target home directory used to store yarn files configurable Key: FLINK-18493 URL: https://issues.apache.org/jira/browse/FLINK-18493 Project: Flink

[GitHub] [flink] TJX2014 commented on a change in pull request #12819: [FLINK-18440][table-planner-blink] Allow ROW/RANGE with RANK, DENSE_RANK or ROW_NUMBER functions on window stream

2020-07-06 Thread GitBox
TJX2014 commented on a change in pull request #12819: URL: https://github.com/apache/flink/pull/12819#discussion_r450004284 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/calcite/sql/SqlRankFunction.java ## @@ -0,0 +1,50 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot edited a comment on pull request #12805: [FLINK-15221][table api]support fault-tolerant semantic for kafka table api

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12805: URL: https://github.com/apache/flink/pull/12805#issuecomment-652943981 ## CI report: * 73c191e3077bba3681cf47fd29d14245e38082b5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12756: [FLINK-18296][json] add support for TIMESTAMP_WITH_LOCAL_ZONE and fix…

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12756: URL: https://github.com/apache/flink/pull/12756#issuecomment-648131818 ## CI report: * 39748e268b2b2d7f832549bb0a9241db7191d55a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12819: [FLINK-18440][table-planner-blink] Allow ROW/RANGE with RANK, DENSE_RANK or ROW_NUMBER functions on window stream

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12819: URL: https://github.com/apache/flink/pull/12819#issuecomment-653477506 ## CI report: * c4da26a262bc3b5e61ad7ca058c319a7e5fb17bd Azure:

[GitHub] [flink] pyscala commented on pull request #12566: [FLINK-17761][connector/common] Add a constructor taking capacity as a parameter for `FutureCompletingBlockingQueue`

2020-07-06 Thread GitBox
pyscala commented on pull request #12566: URL: https://github.com/apache/flink/pull/12566#issuecomment-654058889 > Thanks for the contribution. Why default value is 1? Why not keep Int.Max? @JingsongLi Thanks for your reply , The details link

[GitHub] [flink] JingsongLi merged pull request #12566: [FLINK-17761][connector/common] Add a constructor taking capacity as a parameter for `FutureCompletingBlockingQueue`

2020-07-06 Thread GitBox
JingsongLi merged pull request #12566: URL: https://github.com/apache/flink/pull/12566 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

[GitHub] [flink] flinkbot edited a comment on pull request #12824: [FLINK-18488][python] Added additional params to CsvTableSource constructor

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12824: URL: https://github.com/apache/flink/pull/12824#issuecomment-653937012 ## CI report: * a112ae76f326f1abfa2f921dcdb0acd5f63ebf25 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12798: [FLINK-16087][docs-zh] Translate "Detecting Patterns" page of "Streaming Concepts" into Chinese

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12798: URL: https://github.com/apache/flink/pull/12798#issuecomment-652303680 ## CI report: * ad5d5dcac846080e2e40255505dd35896a6c7a94 UNKNOWN * 712b7a57cea8f3b0ddac3f778f87079844198eae Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12819: [FLINK-18440][table-planner-blink] Allow ROW/RANGE with RANK, DENSE_RANK or ROW_NUMBER functions on window stream

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12819: URL: https://github.com/apache/flink/pull/12819#issuecomment-653477506 ## CI report: * 3abfccb9772dc89d051cdc9924af785e25488563 Azure:

[jira] [Commented] (FLINK-18163) Should be volatile: network.api.writer.RecordWriter.flusherException

2020-07-06 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151896#comment-17151896 ] Roman Khachatryan commented on FLINK-18163: --- [~NicoK] , I see you were involved in a

[jira] [Updated] (FLINK-18163) Should be volatile: network.api.writer.RecordWriter.flusherException

2020-07-06 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-18163: -- Priority: Minor (was: Major) (downgraded priority of the issue to minor) > Should

[jira] [Created] (FLINK-18496) Anchors are not generated based on ZH characters

2020-07-06 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-18496: --- Summary: Anchors are not generated based on ZH characters Key: FLINK-18496 URL: https://issues.apache.org/jira/browse/FLINK-18496 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-18493) Make target home directory used to store yarn files configurable

2020-07-06 Thread Kevin Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151927#comment-17151927 ] Kevin Zhang commented on FLINK-18493: - [~fly_in_gis] Yes I'd like to work on this if one of the

[GitHub] [flink-web] gaoyunhaii commented on a change in pull request #352: Add 1.11 Release announcement.

2020-07-06 Thread GitBox
gaoyunhaii commented on a change in pull request #352: URL: https://github.com/apache/flink-web/pull/352#discussion_r450125531 ## File path: _posts/2020-07-06-release-1.11.0.md ## @@ -0,0 +1,309 @@ +--- +layout: post +title: "Apache Flink 1.11.0 Release Announcement" +date:

[GitHub] [flink] TJX2014 commented on a change in pull request #12819: [FLINK-18440][table-planner-blink] Allow ROW/RANGE with RANK, DENSE_RANK or ROW_NUMBER functions on window stream

2020-07-06 Thread GitBox
TJX2014 commented on a change in pull request #12819: URL: https://github.com/apache/flink/pull/12819#discussion_r450006339 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/calcite/sql/SqlRankFunction.java ## @@ -0,0 +1,48 @@ +/* + * Licensed to

[GitHub] [flink] TJX2014 commented on a change in pull request #12819: [FLINK-18440][table-planner-blink] Allow ROW/RANGE with RANK, DENSE_RANK or ROW_NUMBER functions on window stream

2020-07-06 Thread GitBox
TJX2014 commented on a change in pull request #12819: URL: https://github.com/apache/flink/pull/12819#discussion_r450005475 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/calcite/sql/SqlRankFunction.java ## @@ -0,0 +1,50 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot edited a comment on pull request #12819: [FLINK-18440][table-planner-blink] Allow ROW/RANGE with RANK, DENSE_RANK or ROW_NUMBER functions on window stream

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12819: URL: https://github.com/apache/flink/pull/12819#issuecomment-653477506 ## CI report: * c4da26a262bc3b5e61ad7ca058c319a7e5fb17bd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12756: [FLINK-18296][json] add support for TIMESTAMP_WITH_LOCAL_ZONE and fix…

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12756: URL: https://github.com/apache/flink/pull/12756#issuecomment-648131818 ## CI report: * 39748e268b2b2d7f832549bb0a9241db7191d55a Azure:

[GitHub] [flink] dawidwys commented on a change in pull request #12790: Es hotfix

2020-07-06 Thread GitBox
dawidwys commented on a change in pull request #12790: URL: https://github.com/apache/flink/pull/12790#discussion_r450027166 ## File path:

[jira] [Commented] (FLINK-18493) Make target home directory used to store yarn files configurable

2020-07-06 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151824#comment-17151824 ] Yang Wang commented on FLINK-18493: --- Do you mean to make the staging directory configurable? If it is,

[jira] [Commented] (FLINK-18495) flink filterpushdown can not take effect in blink planner

2020-07-06 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151868#comment-17151868 ] Jingsong Lee commented on FLINK-18495: -- Yes, actually, parquet and orc not support filter push down

[jira] [Updated] (FLINK-18163) Should be volatile: network.api.writer.RecordWriter.flusherException

2020-07-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18163: --- Labels: pull-request-available (was: ) > Should be volatile:

[GitHub] [flink] BryceCicada edited a comment on pull request #12824: [FLINK-18488][python] Added additional params to CsvTableSource constructor

2020-07-06 Thread GitBox
BryceCicada edited a comment on pull request #12824: URL: https://github.com/apache/flink/pull/12824#issuecomment-654121466 @dianfu Thanks. > Should we also support emptyColumnAsNull? Yeah... from the Java side, I think some small mismatch between the CsvTableSource

[GitHub] [flink-web] morsapaes commented on a change in pull request #352: Add 1.11 Release announcement.

2020-07-06 Thread GitBox
morsapaes commented on a change in pull request #352: URL: https://github.com/apache/flink-web/pull/352#discussion_r450135871 ## File path: _posts/2020-07-06-release-1.11.0.md ## @@ -0,0 +1,309 @@ +--- +layout: post +title: "Apache Flink 1.11.0 Release Announcement" +date:

[jira] [Created] (FLINK-18494) The job was migrated from flink1.9.0 to 1.10.1, and there were incompatibilities: No enum constant org.apache.flink.table.types.logical.LogicalTypeRoot.ANY

2020-07-06 Thread wuleiflink (Jira)
wuleiflink created FLINK-18494: -- Summary: The job was migrated from flink1.9.0 to 1.10.1, and there were incompatibilities: No enum constant org.apache.flink.table.types.logical.LogicalTypeRoot.ANY Key: FLINK-18494

[GitHub] [flink] JingsongLi commented on pull request #12566: [FLINK-17761][connector/common] Add a constructor taking capacity as a parameter for `FutureCompletingBlockingQueue`

2020-07-06 Thread GitBox
JingsongLi commented on pull request #12566: URL: https://github.com/apache/flink/pull/12566#issuecomment-654060300 Thanks for the explanation. Looks good to me. This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-18397) Translate "Table & SQL Connectors Overview" page into Chinese

2020-07-06 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151841#comment-17151841 ] Benchao Li commented on FLINK-18397: [~LeoGq] Seems your question has nothing to do with this issue?

[GitHub] [flink] dawidwys opened a new pull request #12825: [FLINK-18485] Update java to 8u251 in yarn docker kerberized test

2020-07-06 Thread GitBox
dawidwys opened a new pull request #12825: URL: https://github.com/apache/flink/pull/12825 ## What is the purpose of the change Fix the kerberized Yarn docker test, which fails on downloading jce_policy. ## Brief change log * Update java to u251 from u131 * Instead

[jira] [Updated] (FLINK-18485) Kerberized YARN per-job on Docker test failed during unzip jce_policy-8.zip

2020-07-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18485: --- Labels: pull-request-available test-stability (was: test-stability) > Kerberized YARN

[GitHub] [flink] dawidwys commented on pull request #12825: [FLINK-18485] Update java to 8u251 in yarn docker kerberized test

2020-07-06 Thread GitBox
dawidwys commented on pull request #12825: URL: https://github.com/apache/flink/pull/12825#issuecomment-654069963 cc @aljoscha @dianfu This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] liuyongvs commented on pull request #12790: Es hotfix

2020-07-06 Thread GitBox
liuyongvs commented on pull request #12790: URL: https://github.com/apache/flink/pull/12790#issuecomment-654077215 > Wait until the build pass. Hi @wuchong. I found this PR hasn't fire the azure from the first time i commited the PR

[GitHub] [flink] flinkbot commented on pull request #12827: [FLINK-18163][task] Add RecordWriter.volatileFlusherException

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

[jira] [Commented] (FLINK-18495) flink filterpushdown can not take effect in blink planner

2020-07-06 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151906#comment-17151906 ] Jingsong Lee commented on FLINK-18495: -- Very glad you can take it. Which format you want to start?

[GitHub] [flink] flinkbot edited a comment on pull request #12805: [FLINK-15221][table api]support fault-tolerant semantic for kafka table api

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12805: URL: https://github.com/apache/flink/pull/12805#issuecomment-652943981 ## CI report: * b2adffed86531ab0eda2bc6ca89b346228829e42 Azure:

[GitHub] [flink] flinkbot commented on pull request #12827: [FLINK-18163][task] Add RecordWriter.volatileFlusherException

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

[jira] [Updated] (FLINK-18496) Anchors are not generated based on ZH characters

2020-07-06 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18496: Description: In ZH version pages of flink-web, the anchors are not generated based on ZH characters. The

[jira] [Updated] (FLINK-18496) Anchors are not generated based on ZH characters

2020-07-06 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18496: Description: In ZH version pages of flink-web, the anchors are not generated based on ZH characters. The

[jira] [Updated] (FLINK-18496) Anchors are not generated based on ZH characters

2020-07-06 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18496: Description: In ZH version pages of flink-web, the anchors are not generated based on ZH characters. The

[jira] [Updated] (FLINK-18496) Anchors are not generated based on ZH characters

2020-07-06 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18496: Description: In ZH version pages of flink-web, the anchors are not generated based on ZH characters. The

[jira] [Updated] (FLINK-18496) Anchors are not generated based on ZH characters

2020-07-06 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18496: Description: In ZH version pages of flink-web, the anchors are not generated based on ZH characters. The

[GitHub] [flink-web] morsapaes commented on a change in pull request #352: Add 1.11 Release announcement.

2020-07-06 Thread GitBox
morsapaes commented on a change in pull request #352: URL: https://github.com/apache/flink-web/pull/352#discussion_r450135871 ## File path: _posts/2020-07-06-release-1.11.0.md ## @@ -0,0 +1,309 @@ +--- +layout: post +title: "Apache Flink 1.11.0 Release Announcement" +date:

[GitHub] [flink] pyscala commented on pull request #12566: [FLINK-17761][connector/common] Add a constructor taking capacity as a parameter for `FutureCompletingBlockingQueue`

2020-07-06 Thread GitBox
pyscala commented on pull request #12566: URL: https://github.com/apache/flink/pull/12566#issuecomment-654045783 @JingsongLi @wuchong Can you review this PR for me? thanks. This is an automated message from the Apache Git

[jira] [Updated] (FLINK-18494) The job was migrated from flink1.9.0 to 1.10.1, and there were incompatibilities: No enum constant org.apache.flink.table.types.logical.LogicalTypeRoot.ANY

2020-07-06 Thread wuleiflink (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wuleiflink updated FLINK-18494: --- Description: The job was migrated from *flink1.9.0 to 1.10.1*, and there were incompatibilities:

[GitHub] [flink] flinkbot commented on pull request #12825: [FLINK-18485] Update java to 8u251 in yarn docker kerberized test

2020-07-06 Thread GitBox
flinkbot commented on pull request #12825: URL: https://github.com/apache/flink/pull/12825#issuecomment-654070939 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] flinkbot edited a comment on pull request #12798: [FLINK-16087][docs-zh] Translate "Detecting Patterns" page of "Streaming Concepts" into Chinese

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12798: URL: https://github.com/apache/flink/pull/12798#issuecomment-652303680 ## CI report: * ad5d5dcac846080e2e40255505dd35896a6c7a94 UNKNOWN * 63895a2f0147d6a673d32b011e6fb9cbe57f7eac Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12805: [FLINK-15221][table api]support fault-tolerant semantic for kafka table api

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12805: URL: https://github.com/apache/flink/pull/12805#issuecomment-652943981 ## CI report: * 73c191e3077bba3681cf47fd29d14245e38082b5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12819: [FLINK-18440][table-planner-blink] Allow ROW/RANGE with RANK, DENSE_RANK or ROW_NUMBER functions on window stream

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12819: URL: https://github.com/apache/flink/pull/12819#issuecomment-653477506 ## CI report: * 39695e399f55065af72ea98906892448c3d5b315 Azure:

[GitHub] [flink] liuyongvs commented on pull request #12788: [FLINK-16713] [connector] support es bounded source and lookupsource

2020-07-06 Thread GitBox
liuyongvs commented on pull request #12788: URL: https://github.com/apache/flink/pull/12788#issuecomment-654079936 Hi @wuchong @dawidwys , could you please have some time to review this, Thanks! This is an automated message

[jira] [Created] (FLINK-18495) flink filterpushdown can not take effect in blink planner

2020-07-06 Thread jackylau (Jira)
jackylau created FLINK-18495: Summary: flink filterpushdown can not take effect in blink planner Key: FLINK-18495 URL: https://issues.apache.org/jira/browse/FLINK-18495 Project: Flink Issue

[GitHub] [flink] dawidwys closed pull request #11181: [FLINK-16230][tests]Use LinkedHashSet instead of HashSet

2020-07-06 Thread GitBox
dawidwys closed pull request #11181: URL: https://github.com/apache/flink/pull/11181 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

[GitHub] [flink] flinkbot edited a comment on pull request #12805: [FLINK-15221][table api]support fault-tolerant semantic for kafka table api

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12805: URL: https://github.com/apache/flink/pull/12805#issuecomment-652943981 ## CI report: * b2adffed86531ab0eda2bc6ca89b346228829e42 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12825: [FLINK-18485] Update java to 8u251 in yarn docker kerberized test

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12825: URL: https://github.com/apache/flink/pull/12825#issuecomment-654081444 ## CI report: * 28c657e68202e164bd4c33888b4cde0517ac3b89 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12826: [FLINK-18419] Create catalog in TableEnvironment using user classloader

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12826: URL: https://github.com/apache/flink/pull/12826#issuecomment-654081532 ## CI report: * 0691185bcfe408b32b0f61a2bb2313c04c69b0e2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12824: [FLINK-18488][python] Added additional params to CsvTableSource constructor

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12824: URL: https://github.com/apache/flink/pull/12824#issuecomment-653937012 ## CI report: * a112ae76f326f1abfa2f921dcdb0acd5f63ebf25 Azure:

[GitHub] [flink] BryceCicada commented on a change in pull request #12824: [FLINK-18488][python] Added additional params to CsvTableSource constructor

2020-07-06 Thread GitBox
BryceCicada commented on a change in pull request #12824: URL: https://github.com/apache/flink/pull/12824#discussion_r450066743 ## File path: flink-python/pyflink/table/sources.py ## @@ -38,16 +38,62 @@ class CsvTableSource(TableSource): (logically) unlimited number of

[GitHub] [flink] BryceCicada commented on a change in pull request #12824: [FLINK-18488][python] Added additional params to CsvTableSource constructor

2020-07-06 Thread GitBox
BryceCicada commented on a change in pull request #12824: URL: https://github.com/apache/flink/pull/12824#discussion_r450083027 ## File path: flink-python/pyflink/table/sources.py ## @@ -38,16 +38,62 @@ class CsvTableSource(TableSource): (logically) unlimited number of

[jira] [Commented] (FLINK-18495) flink filterpushdown can not take effect in blink planner

2020-07-06 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151903#comment-17151903 ] jackylau commented on FLINK-18495: -- Hi [~lzljs3620320]. i find the flink 1.12 snpashot  flink planner

[GitHub] [flink] flinkbot edited a comment on pull request #12824: [FLINK-18488][python] Added additional params to CsvTableSource constructor

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12824: URL: https://github.com/apache/flink/pull/12824#issuecomment-653937012 ## CI report: * 6f8b0d3951c82e96839ef2c02e36165793c5a098 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12805: [FLINK-15221][table api]support fault-tolerant semantic for kafka table api

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12805: URL: https://github.com/apache/flink/pull/12805#issuecomment-652943981 ## CI report: * b2adffed86531ab0eda2bc6ca89b346228829e42 Azure:

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

2020-07-06 Thread Georg Heiler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151921#comment-17151921 ] Georg Heiler edited comment on FLINK-12501 at 7/6/20, 10:03 AM: I am

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

2020-07-06 Thread Georg Heiler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151921#comment-17151921 ] Georg Heiler commented on FLINK-12501: -- I am very new to Flink so if you already know what needs to

[jira] [Commented] (FLINK-18485) Kerberized YARN per-job on Docker test failed during unzip jce_policy-8.zip

2020-07-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151820#comment-17151820 ] Dian Fu commented on FLINK-18485: - Thanks [~dwysakowicz].  > Kerberized YARN per-job on Docker test

[GitHub] [flink-web] pnowojski opened a new pull request #355: Update website for Flink 1.11.0

2020-07-06 Thread GitBox
pnowojski opened a new pull request #355: URL: https://github.com/apache/flink-web/pull/355 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

[GitHub] [flink] BryceCicada commented on a change in pull request #12824: [FLINK-18488][python] Added additional params to CsvTableSource constructor

2020-07-06 Thread GitBox
BryceCicada commented on a change in pull request #12824: URL: https://github.com/apache/flink/pull/12824#discussion_r450066743 ## File path: flink-python/pyflink/table/sources.py ## @@ -38,16 +38,62 @@ class CsvTableSource(TableSource): (logically) unlimited number of

[GitHub] [flink] dianfu commented on pull request #12824: [FLINK-18488][python] Added additional params to CsvTableSource constructor

2020-07-06 Thread GitBox
dianfu commented on pull request #12824: URL: https://github.com/apache/flink/pull/12824#issuecomment-654112165 > @BryceCicada Good catch! Thanks a lot for the contribution. Just left a few minor comments. Should we also support emptyColumnAsNull? Besides, there are checkstyle issues

[jira] [Assigned] (FLINK-18485) Kerberized YARN per-job on Docker test failed during unzip jce_policy-8.zip

2020-07-06 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-18485: Assignee: Dawid Wysakowicz > Kerberized YARN per-job on Docker test failed

[jira] [Commented] (FLINK-18485) Kerberized YARN per-job on Docker test failed during unzip jce_policy-8.zip

2020-07-06 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151797#comment-17151797 ] Dawid Wysakowicz commented on FLINK-18485: -- It fails all the builds consistently. We should

[jira] [Updated] (FLINK-17761) FutureCompletingBlockingQueue should have a capacity limit.

2020-07-06 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17761: - Fix Version/s: 1.12.0 > FutureCompletingBlockingQueue should have a capacity limit. >

[jira] [Closed] (FLINK-17761) FutureCompletingBlockingQueue should have a capacity limit.

2020-07-06 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-17761. Resolution: Fixed master: 245632f79f9d8df10b8ebb03e1ffdb6d400292fa >

[jira] [Commented] (FLINK-17085) Remove FlinkKubeClient#handleException since it does not do anything

2020-07-06 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151840#comment-17151840 ] Yang Wang commented on FLINK-17085: --- Yeah, i will start to work on this soon. > Remove

[GitHub] [flink] dawidwys opened a new pull request #12826: [FLINK-18419] Create catalog in TableEnvironment using user classloader

2020-07-06 Thread GitBox
dawidwys opened a new pull request #12826: URL: https://github.com/apache/flink/pull/12826 ## What is the purpose of the change Fix creating a catalog with DDL when the catalog implementation comes from a user jar. ## Brief change log * Make user classloader available

[jira] [Commented] (FLINK-15843) Gracefully shutdown TaskManagers on Kubernetes

2020-07-06 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151847#comment-17151847 ] Yang Wang commented on FLINK-15843: --- Thanks for the kindly reminding. I have verified in a K8s cluster

[jira] [Updated] (FLINK-18419) Can not create a catalog

2020-07-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18419: --- Labels: pull-request-available (was: ) > Can not create a catalog >

[GitHub] [flink] flinkbot edited a comment on pull request #12756: [FLINK-18296][json] add support for TIMESTAMP_WITH_LOCAL_ZONE and fix…

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12756: URL: https://github.com/apache/flink/pull/12756#issuecomment-648131818 ## CI report: * fae8255890b34c44be279037024288cffe6fb52e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12798: [FLINK-16087][docs-zh] Translate "Detecting Patterns" page of "Streaming Concepts" into Chinese

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12798: URL: https://github.com/apache/flink/pull/12798#issuecomment-652303680 ## CI report: * ad5d5dcac846080e2e40255505dd35896a6c7a94 UNKNOWN * 63895a2f0147d6a673d32b011e6fb9cbe57f7eac Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12819: [FLINK-18440][table-planner-blink] Allow ROW/RANGE with RANK, DENSE_RANK or ROW_NUMBER functions on window stream

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12819: URL: https://github.com/apache/flink/pull/12819#issuecomment-653477506 ## CI report: * 39695e399f55065af72ea98906892448c3d5b315 Azure:

[GitHub] [flink] flinkbot commented on pull request #12825: [FLINK-18485] Update java to 8u251 in yarn docker kerberized test

2020-07-06 Thread GitBox
flinkbot commented on pull request #12825: URL: https://github.com/apache/flink/pull/12825#issuecomment-654081444 ## CI report: * 28c657e68202e164bd4c33888b4cde0517ac3b89 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-18493) Make target home directory used to store yarn files configurable

2020-07-06 Thread Kevin Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151860#comment-17151860 ] Kevin Zhang commented on FLINK-18493: - [~fly_in_gis] yes I mean the staging directory, so what's

[jira] [Commented] (FLINK-17073) Slow checkpoint cleanup causing OOMs

2020-07-06 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151881#comment-17151881 ] Etienne Chauchot commented on FLINK-17073: -- [~pnowojski] no problem. Sorry for bothering you

[GitHub] [flink] dianfu commented on a change in pull request #12824: [FLINK-18488][python] Added additional params to CsvTableSource constructor

2020-07-06 Thread GitBox
dianfu commented on a change in pull request #12824: URL: https://github.com/apache/flink/pull/12824#discussion_r450078253 ## File path: flink-python/pyflink/table/sources.py ## @@ -38,16 +38,62 @@ class CsvTableSource(TableSource): (logically) unlimited number of fields.

[GitHub] [flink] rkhachatryan opened a new pull request #12827: [FLINK-18163][task] Add RecordWriter.volatileFlusherException

2020-07-06 Thread GitBox
rkhachatryan opened a new pull request #12827: URL: https://github.com/apache/flink/pull/12827 ## What is the purpose of the change `RecordWriter.flusherException` is updated by one thread and checked by another. The field is deliberately non-volatile for performance reasons.

[jira] [Commented] (FLINK-18493) Make target home directory used to store yarn files configurable

2020-07-06 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151887#comment-17151887 ] Yang Wang commented on FLINK-18493: --- [~KevinZwx] If you want to work on this, i could close 

[jira] [Assigned] (FLINK-18483) [EFO] Test coverage improvements for FlinkKinesisConsumer

2020-07-06 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-18483: --- Assignee: Danny Cranmer > [EFO] Test coverage improvements for

[GitHub] [flink] fsk119 commented on a change in pull request #12805: [FLINK-15221][table api]support fault-tolerant semantic for kafka table api

2020-07-06 Thread GitBox
fsk119 commented on a change in pull request #12805: URL: https://github.com/apache/flink/pull/12805#discussion_r450119872 ## File path: flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka011DynamicSink.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #12805: [FLINK-15221][table api]support fault-tolerant semantic for kafka table api

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12805: URL: https://github.com/apache/flink/pull/12805#issuecomment-652943981 ## CI report: * 5fa00643457589cc011c3308ac33efbaa86bd48c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12827: [FLINK-18163][task] Add RecordWriter.volatileFlusherException

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12827: URL: https://github.com/apache/flink/pull/12827#issuecomment-654120002 ## CI report: * a47aa124dba8c4badae4567bb78cbc92d4ef072f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12824: [FLINK-18488][python] Added additional params to CsvTableSource constructor

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12824: URL: https://github.com/apache/flink/pull/12824#issuecomment-653937012 ## CI report: * e969d039e6d563986f609dedd1f93b7485242649 Azure:

[GitHub] [flink] flinkbot commented on pull request #12826: [FLINK-18419] Create catalog in TableEnvironment using user classloader

2020-07-06 Thread GitBox
flinkbot commented on pull request #12826: URL: https://github.com/apache/flink/pull/12826#issuecomment-654075595 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] flinkbot commented on pull request #12826: [FLINK-18419] Create catalog in TableEnvironment using user classloader

2020-07-06 Thread GitBox
flinkbot commented on pull request #12826: URL: https://github.com/apache/flink/pull/12826#issuecomment-654081532 ## CI report: * 0691185bcfe408b32b0f61a2bb2313c04c69b0e2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] BryceCicada commented on a change in pull request #12824: [FLINK-18488][python] Added additional params to CsvTableSource constructor

2020-07-06 Thread GitBox
BryceCicada commented on a change in pull request #12824: URL: https://github.com/apache/flink/pull/12824#discussion_r450083499 ## File path: flink-python/pyflink/table/sources.py ## @@ -38,16 +38,62 @@ class CsvTableSource(TableSource): (logically) unlimited number of

[GitHub] [flink-web] zhuzhurk commented on pull request #353: [FLINK-18454] Add a code contribution section about how to look for what to contribute

2020-07-06 Thread GitBox
zhuzhurk commented on pull request #353: URL: https://github.com/apache/flink-web/pull/353#issuecomment-654125186 I just found a problem of flink-web that the anchors of ZH docs are not properly generated. See FLINK-18496. This blocks us from reference a section with an anchor because

[GitHub] [flink] flinkbot edited a comment on pull request #12826: [FLINK-18419] Create catalog in TableEnvironment using user classloader

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12826: URL: https://github.com/apache/flink/pull/12826#issuecomment-654081532 ## CI report: * 0691185bcfe408b32b0f61a2bb2313c04c69b0e2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12805: [FLINK-15221][table api]support fault-tolerant semantic for kafka table api

2020-07-06 Thread GitBox
flinkbot edited a comment on pull request #12805: URL: https://github.com/apache/flink/pull/12805#issuecomment-652943981 ## CI report: * b2adffed86531ab0eda2bc6ca89b346228829e42 Azure:

  1   2   3   >