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

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 #12798: [FLINK-16087][docs-zh] Translate "Detecting Patterns" page of "Streaming Concepts" into Chinese

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

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

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] dawidwys opened a new pull request #12825: [FLINK-18485] Update java to 8u251 in yarn docker kerberized test

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

[ 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

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,

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

[ 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?

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

[ 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

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

[ 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.

[ 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 >

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

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

[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

[ 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] JingsongLi commented on pull request #12566: [FLINK-17761][connector/common] Add a constructor taking capacity as a parameter for `FutureCompletingBlockingQueue`

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] [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

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

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

[ 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,

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

dawidwys commented on a change in pull request #12790: URL: https://github.com/apache/flink/pull/12790#discussion_r450027166 ## File path:

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

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

[jira] [Commented] (FLINK-17177) Handle ERROR event correctly in KubernetesResourceManager#onError

[ https://issues.apache.org/jira/browse/FLINK-17177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151821#comment-17151821 ] Yang Wang commented on FLINK-17177: --- I agree that we could first make the logging of {{ERROR}} action

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

[ 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] flinkbot edited a comment on pull request #12805: [FLINK-15221][table api]support fault-tolerant semantic for kafka table api

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

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…

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

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

JingsongLi commented on pull request #12566: URL: https://github.com/apache/flink/pull/12566#issuecomment-654051068 Thanks for the contribution. Why default value is 1? Why not keep Int.Max? This is an automated message

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

[ 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

[ 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

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

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

[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

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…

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

[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

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

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] 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

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] 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

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] 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

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

[ 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

[ 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

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

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] 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

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…

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

<    1   2   3