[GitHub] [flink] flinkbot edited a comment on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0

flinkbot edited a comment on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0 URL: https://github.com/apache/flink/pull/9751#issuecomment-534387866 ## CI report: * 5b73b3d6319447fd2d81b48183d9f22012133a6b : FAILURE

[GitHub] [flink] TisonKun commented on a change in pull request #10235: [FLINK-14839][config] Let JobGraph#classpaths become non-null

TisonKun commented on a change in pull request #10235: [FLINK-14839][config] Let JobGraph#classpaths become non-null URL: https://github.com/apache/flink/pull/10235#discussion_r349414138 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java

[GitHub] [flink] TisonKun commented on a change in pull request #10235: [FLINK-14839][config] Let JobGraph#classpaths become non-null

TisonKun commented on a change in pull request #10235: [FLINK-14839][config] Let JobGraph#classpaths become non-null URL: https://github.com/apache/flink/pull/10235#discussion_r349414021 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java

[GitHub] [flink] godfreyhe commented on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner

godfreyhe commented on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner URL: https://github.com/apache/flink/pull/9433#issuecomment-557363664 thanks for all guys' help!

[GitHub] [flink] hequn8128 commented on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner

hequn8128 commented on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner URL: https://github.com/apache/flink/pull/9433#issuecomment-557362941 LGTM. +1 This

[GitHub] [flink] flinkbot edited a comment on issue #10232: [FLINK-14314][runtime] Allocate shared slot resources respecting the resources of all vertices in the group

flinkbot edited a comment on issue #10232: [FLINK-14314][runtime] Allocate shared slot resources respecting the resources of all vertices in the group URL: https://github.com/apache/flink/pull/10232#issuecomment-554775330 ## CI report: * b62006e7cf875fa318b3ce57afb14b0b2679bcb5

[GitHub] [flink] TisonKun commented on a change in pull request #10251: [FLINK-14851][FLINK-14850] Implement Executors and wire them to the ContextEnvironment

TisonKun commented on a change in pull request #10251: [FLINK-14851][FLINK-14850] Implement Executors and wire them to the ContextEnvironment URL: https://github.com/apache/flink/pull/10251#discussion_r349411838 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #10251: [FLINK-14851][FLINK-14850] Implement Executors and wire them to the ContextEnvironment

TisonKun commented on a change in pull request #10251: [FLINK-14851][FLINK-14850] Implement Executors and wire them to the ContextEnvironment URL: https://github.com/apache/flink/pull/10251#discussion_r349411838 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #10251: [FLINK-14851][FLINK-14850] Implement Executors and wire them to the ContextEnvironment

TisonKun commented on a change in pull request #10251: [FLINK-14851][FLINK-14850] Implement Executors and wire them to the ContextEnvironment URL: https://github.com/apache/flink/pull/10251#discussion_r349411565 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #10251: [FLINK-14851][FLINK-14850] Implement Executors and wire them to the ContextEnvironment

TisonKun commented on a change in pull request #10251: [FLINK-14851][FLINK-14850] Implement Executors and wire them to the ContextEnvironment URL: https://github.com/apache/flink/pull/10251#discussion_r349411388 ## File path:

[GitHub] [flink] zjuwangg commented on issue #10272: [FLINK-14878]Support `use catalog` through sqlUpdate() method in TableEnvironment

zjuwangg commented on issue #10272: [FLINK-14878]Support `use catalog` through sqlUpdate() method in TableEnvironment URL: https://github.com/apache/flink/pull/10272#issuecomment-557361387 > sorry for the late comment, but I happened to notice that UseCatalogOperation and UseOperation

[GitHub] [flink] flinkbot edited a comment on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

flinkbot edited a comment on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#issuecomment-553881527 ## CI report: * e3ac83fe02a7583159184772ff4b4341fa65f827 : FAILURE

[jira] [Updated] (FLINK-14677) validate all tpc-ds query result with TPC Official reference answer set

[ https://issues.apache.org/jira/browse/FLINK-14677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-14677: --- Parent: (was: FLINK-11491) Issue Type: Task (was: Sub-task) > validate all tpc-ds

[GitHub] [flink] TisonKun commented on a change in pull request #10251: [FLINK-14851][FLINK-14850] Implement Executors and wire them to the ContextEnvironment

TisonKun commented on a change in pull request #10251: [FLINK-14851][FLINK-14850] Implement Executors and wire them to the ContextEnvironment URL: https://github.com/apache/flink/pull/10251#discussion_r349410858 ## File path:

[jira] [Created] (FLINK-14916) Asynchronously deploy cluster in AbstractJobClusterExecutor#execute

Zili Chen created FLINK-14916: - Summary: Asynchronously deploy cluster in AbstractJobClusterExecutor#execute Key: FLINK-14916 URL: https://issues.apache.org/jira/browse/FLINK-14916 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for …

flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for … URL: https://github.com/apache/flink/pull/5521#issuecomment-547463841 ## CI report: * 498611c0cd8678dfd4f3e772826081f83260bb28 : FAILURE

[jira] [Updated] (FLINK-14426) Test and pass 103 tpcds tests

[ https://issues.apache.org/jira/browse/FLINK-14426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-14426: --- Parent: (was: FLINK-11491) Issue Type: Task (was: Sub-task) > Test and pass 103 tpcds

[jira] [Updated] (FLINK-14425) Add table statistics support for tpc-ds tests

[ https://issues.apache.org/jira/browse/FLINK-14425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-14425: --- Parent: (was: FLINK-11491) Issue Type: Task (was: Sub-task) > Add table statistics

[jira] [Updated] (FLINK-14423) Import teradat.tpcds as test data generator (refer to hive)

[ https://issues.apache.org/jira/browse/FLINK-14423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-14423: --- Parent: (was: FLINK-11491) Issue Type: Task (was: Sub-task) > Import teradat.tpcds as

[jira] [Updated] (FLINK-14424) Create tpc-ds end to end test to support all tpc-ds queries

[ https://issues.apache.org/jira/browse/FLINK-14424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-14424: --- Parent: (was: FLINK-11491) Issue Type: Task (was: Sub-task) > Create tpc-ds end to

[GitHub] [flink] flinkbot edited a comment on issue #10275: [FLINK-14733][runtime] Introduce a builder for flexible ResourceProfile building

flinkbot edited a comment on issue #10275: [FLINK-14733][runtime] Introduce a builder for flexible ResourceProfile building URL: https://github.com/apache/flink/pull/10275#issuecomment-556931854 ## CI report: * f6c984aee2adafa83829762496ad13b75e8e : SUCCESS

[jira] [Commented] (FLINK-14765) Remove STATE_UPDATER in Execution

[ https://issues.apache.org/jira/browse/FLINK-14765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979776#comment-16979776 ] vinoyang commented on FLINK-14765: -- [~azagrebin] OK, will open a PR to see if it looks good when

[GitHub] [flink] flinkbot edited a comment on issue #10232: [FLINK-14314][runtime] Allocate shared slot resources respecting the resources of all vertices in the group

flinkbot edited a comment on issue #10232: [FLINK-14314][runtime] Allocate shared slot resources respecting the resources of all vertices in the group URL: https://github.com/apache/flink/pull/10232#issuecomment-554775330 ## CI report: * b62006e7cf875fa318b3ce57afb14b0b2679bcb5

[jira] [Updated] (FLINK-14915) SchedulingStrategyFactory#createInstance might not need to know JobGraph

[ https://issues.apache.org/jira/browse/FLINK-14915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-14915: -- Description: [~zhuzh] [~GJL] I just notice that {{SchedulingStrategyFactory#createInstance}} take a

[jira] [Created] (FLINK-14915) SchedulingStrategyFactory#createInstance might not need to know JobGraph

Zili Chen created FLINK-14915: - Summary: SchedulingStrategyFactory#createInstance might not need to know JobGraph Key: FLINK-14915 URL: https://issues.apache.org/jira/browse/FLINK-14915 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

flinkbot edited a comment on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#issuecomment-553881527 ## CI report: * e3ac83fe02a7583159184772ff4b4341fa65f827 : FAILURE

[jira] [Updated] (FLINK-14892) Add documentation for checkpoint directory layout

[ https://issues.apache.org/jira/browse/FLINK-14892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-14892: -- Summary: Add documentation for checkpoint directory layout (was: Add

[GitHub] [flink] zhuzhurk commented on issue #10275: [FLINK-14733][runtime] Introduce a builder for flexible ResourceProfile building

zhuzhurk commented on issue #10275: [FLINK-14733][runtime] Introduce a builder for flexible ResourceProfile building URL: https://github.com/apache/flink/pull/10275#issuecomment-557352189 Rebased. This is an automated

[GitHub] [flink] zhuzhurk commented on issue #10232: [FLINK-14314][runtime] Allocate shared slot resources respecting the resources of all vertices in the group

zhuzhurk commented on issue #10232: [FLINK-14314][runtime] Allocate shared slot resources respecting the resources of all vertices in the group URL: https://github.com/apache/flink/pull/10232#issuecomment-557351277 Rebased.

[jira] [Closed] (FLINK-14424) Create tpc-ds end to end test to support all tpc-ds queries

[ https://issues.apache.org/jira/browse/FLINK-14424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14424. -- Resolution: Duplicate > Create tpc-ds end to end test to support all tpc-ds queries >

[jira] [Closed] (FLINK-14677) validate all tpc-ds query result with TPC Official reference answer set

[ https://issues.apache.org/jira/browse/FLINK-14677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14677. -- Resolution: Duplicate > validate all tpc-ds query result with TPC Official reference answer set >

[jira] [Closed] (FLINK-14674) some tpc-ds query hang in scheduled stage for long time

[ https://issues.apache.org/jira/browse/FLINK-14674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14674. -- Assignee: Leonard Xu Resolution: Fixed fixed by using less operator memory > some tpc-ds query

[jira] [Closed] (FLINK-14675) output directory settings of tpc-ds dataGenerator have length limitation

[ https://issues.apache.org/jira/browse/FLINK-14675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14675. -- Assignee: Leonard Xu Resolution: Fixed fixed by using relative path in e2e test > output

[jira] [Reopened] (FLINK-14886) Wrong result in scalar query using blink planner

[ https://issues.apache.org/jira/browse/FLINK-14886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reopened FLINK-14886: > Wrong result in scalar query using blink planner >

[GitHub] [flink] flinkbot edited a comment on issue #10286: [FLINK-14890] [tests] Add missing test harnesses for broadcast functions

flinkbot edited a comment on issue #10286: [FLINK-14890] [tests] Add missing test harnesses for broadcast functions URL: https://github.com/apache/flink/pull/10286#issuecomment-557307188 ## CI report: * 2a81c8933ba20c459377b0804d77d21f7f1b16d7 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for …

flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for … URL: https://github.com/apache/flink/pull/5521#issuecomment-547463841 ## CI report: * 498611c0cd8678dfd4f3e772826081f83260bb28 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10286: [FLINK-14890] [tests] Add missing test harnesses for broadcast functions

flinkbot edited a comment on issue #10286: [FLINK-14890] [tests] Add missing test harnesses for broadcast functions URL: https://github.com/apache/flink/pull/10286#issuecomment-557307188 ## CI report: * 2a81c8933ba20c459377b0804d77d21f7f1b16d7 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for …

flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for … URL: https://github.com/apache/flink/pull/5521#issuecomment-547463841 ## CI report: * 498611c0cd8678dfd4f3e772826081f83260bb28 : FAILURE

[GitHub] [flink] flinkbot commented on issue #10286: [FLINK-14890] [tests] Add missing test harnesses for broadcast functions

flinkbot commented on issue #10286: [FLINK-14890] [tests] Add missing test harnesses for broadcast functions URL: https://github.com/apache/flink/pull/10286#issuecomment-557307188 ## CI report: * 2a81c8933ba20c459377b0804d77d21f7f1b16d7 : UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for …

flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for … URL: https://github.com/apache/flink/pull/5521#issuecomment-547463841 ## CI report: * 498611c0cd8678dfd4f3e772826081f83260bb28 : FAILURE

[GitHub] [flink] flinkbot commented on issue #10286: [FLINK-14890] [tests] Add missing test harnesses for broadcast functions

flinkbot commented on issue #10286: [FLINK-14890] [tests] Add missing test harnesses for broadcast functions URL: https://github.com/apache/flink/pull/10286#issuecomment-557299007 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Updated] (FLINK-14890) TestHarness for KeyedBroadcastProcessFunction

[ https://issues.apache.org/jira/browse/FLINK-14890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14890: --- Labels: pull-request-available (was: ) > TestHarness for KeyedBroadcastProcessFunction >

[GitHub] [flink] afedulov opened a new pull request #10286: [FLINK-14890] [tests] Add missing test harnesses for broadcast functions

afedulov opened a new pull request #10286: [FLINK-14890] [tests] Add missing test harnesses for broadcast functions URL: https://github.com/apache/flink/pull/10286 ## What is the purpose of the change Adds missing test harnesses for broadcast functions ## Brief change

[GitHub] [flink] flinkbot edited a comment on issue #10285: [FLINK-14896] [flink-kinesis-connector] Set jackson and guava dependency to flink-shaded

flinkbot edited a comment on issue #10285: [FLINK-14896] [flink-kinesis-connector] Set jackson and guava dependency to flink-shaded URL: https://github.com/apache/flink/pull/10285#issuecomment-557220840 ## CI report: * 148f664308ebcf488ba1b86c4e75bab1dd1c83f8 : FAILURE

[jira] [Commented] (FLINK-14908) Distributing CacheFiles through DFS does not work

[ https://issues.apache.org/jira/browse/FLINK-14908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979572#comment-16979572 ] djordje commented on FLINK-14908: - I'm using flink 1.9.0 so this version is also affected. (Assuming

[GitHub] [flink] flinkbot edited a comment on issue #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint

flinkbot edited a comment on issue #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint URL: https://github.com/apache/flink/pull/10238#issuecomment-555064294 ## CI report: * a6c3b628841cead29b7c0e3d83bbf78c3a6b9170 : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #10222: [FLINK-14788][configuration] Add configure method to CheckpointConfig

flinkbot edited a comment on issue #10222: [FLINK-14788][configuration] Add configure method to CheckpointConfig URL: https://github.com/apache/flink/pull/10222#issuecomment-554372384 ## CI report: * a7a80b60af90a66251ef5772cc55cf15bd4df55e : SUCCESS

[jira] [Updated] (FLINK-14912) register, drop, and alter catalog functions from DDL via catalog

[ https://issues.apache.org/jira/browse/FLINK-14912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-14912: - Summary: register, drop, and alter catalog functions from DDL via catalog (was: register,drop, and

[jira] [Created] (FLINK-14914) refactor CatalogFunction interface and impls to add language field

Bowen Li created FLINK-14914: Summary: refactor CatalogFunction interface and impls to add language field Key: FLINK-14914 URL: https://issues.apache.org/jira/browse/FLINK-14914 Project: Flink

[jira] [Updated] (FLINK-14913) refactor CatalogFunction interface and impls to remove properties map

[ https://issues.apache.org/jira/browse/FLINK-14913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-14913: - Component/s: Table SQL / API > refactor CatalogFunction interface and impls to remove properties map >

[jira] [Updated] (FLINK-14913) refactor CatalogFunction interface and impls to remove properties map

[ https://issues.apache.org/jira/browse/FLINK-14913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-14913: - Summary: refactor CatalogFunction interface and impls to remove properties map (was: refactor

[jira] [Created] (FLINK-14913) refactor CatalogFunction interface and impls by removing properties map

Bowen Li created FLINK-14913: Summary: refactor CatalogFunction interface and impls by removing properties map Key: FLINK-14913 URL: https://issues.apache.org/jira/browse/FLINK-14913 Project: Flink

[jira] [Created] (FLINK-14912) register,drop, and alter catalog functions from DDL to FunctionCatalog

Bowen Li created FLINK-14912: Summary: register,drop, and alter catalog functions from DDL to FunctionCatalog Key: FLINK-14912 URL: https://issues.apache.org/jira/browse/FLINK-14912 Project: Flink

[jira] [Updated] (FLINK-14906) register,drop, and alter temp system functions from DDL to FunctionCatalog

[ https://issues.apache.org/jira/browse/FLINK-14906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-14906: - Summary: register,drop, and alter temp system functions from DDL to FunctionCatalog (was: register and

[jira] [Updated] (FLINK-14911) register, drop, and alter temp catalog functions from DDL to FunctionCatalog

[ https://issues.apache.org/jira/browse/FLINK-14911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-14911: - Summary: register, drop, and alter temp catalog functions from DDL to FunctionCatalog (was: register

[jira] [Updated] (FLINK-14906) register and drop temp system functions from DDL to FunctionCatalog

[ https://issues.apache.org/jira/browse/FLINK-14906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-14906: - Summary: register and drop temp system functions from DDL to FunctionCatalog (was: register temp

[GitHub] [flink] flinkbot edited a comment on issue #10285: [FLINK-14896] [flink-kinesis-connector] Set jackson and guava dependency to flink-shaded

flinkbot edited a comment on issue #10285: [FLINK-14896] [flink-kinesis-connector] Set jackson and guava dependency to flink-shaded URL: https://github.com/apache/flink/pull/10285#issuecomment-557220840 ## CI report: * 148f664308ebcf488ba1b86c4e75bab1dd1c83f8 : PENDING

[jira] [Created] (FLINK-14911) register temp catalog functions created by DDL to FunctionCatalog

Bowen Li created FLINK-14911: Summary: register temp catalog functions created by DDL to FunctionCatalog Key: FLINK-14911 URL: https://issues.apache.org/jira/browse/FLINK-14911 Project: Flink

[jira] [Assigned] (FLINK-14906) register temp system functions created by DDL to FunctionCatalog

[ https://issues.apache.org/jira/browse/FLINK-14906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-14906: Assignee: Zhenqiu Huang > register temp system functions created by DDL to FunctionCatalog >

[jira] [Updated] (FLINK-14906) register temp system functions created by DDL to FunctionCatalog

[ https://issues.apache.org/jira/browse/FLINK-14906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-14906: - Summary: register temp system functions created by DDL to FunctionCatalog (was: Add function related

[jira] [Updated] (FLINK-14906) register temp system functions created by DDL to FunctionCatalog

[ https://issues.apache.org/jira/browse/FLINK-14906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-14906: - Fix Version/s: 1.10.0 > register temp system functions created by DDL to FunctionCatalog >

[jira] [Updated] (FLINK-14906) register temp system functions created by DDL to FunctionCatalog

[ https://issues.apache.org/jira/browse/FLINK-14906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-14906: - Description: (was: 1) Add a temporary function hashmap to store temporary functions 2) Add create,

[GitHub] [flink] flinkbot edited a comment on issue #10114: [WIP][FLINK -14651][runtime] Enable DefaultScheduler

flinkbot edited a comment on issue #10114: [WIP][FLINK -14651][runtime] Enable DefaultScheduler URL: https://github.com/apache/flink/pull/10114#issuecomment-551014940 ## CI report: * c436371614d7db5dfc8c97e01a4594c3139715db : FAILURE

[GitHub] [flink] flinkbot commented on issue #10285: [FLINK-14896] [flink-kinesis-connector] Set jackson and guava dependency to flink-shaded

flinkbot commented on issue #10285: [FLINK-14896] [flink-kinesis-connector] Set jackson and guava dependency to flink-shaded URL: https://github.com/apache/flink/pull/10285#issuecomment-557220840 ## CI report: * 148f664308ebcf488ba1b86c4e75bab1dd1c83f8 : UNKNOWN Bot

[GitHub] [flink] flinkbot edited a comment on issue #10283: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler

flinkbot edited a comment on issue #10283: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler URL: https://github.com/apache/flink/pull/10283#issuecomment-55716 ## CI report: *

[GitHub] [flink] flinkbot commented on issue #10285: [FLINK-14896] [flink-kinesis-connector] Set jackson and guava dependency to flink-shaded

flinkbot commented on issue #10285: [FLINK-14896] [flink-kinesis-connector] Set jackson and guava dependency to flink-shaded URL: https://github.com/apache/flink/pull/10285#issuecomment-557217153 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Updated] (FLINK-14896) Kinesis connector doesn't shade jackson dependency

[ https://issues.apache.org/jira/browse/FLINK-14896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14896: --- Labels: pull-request-available (was: ) > Kinesis connector doesn't shade jackson

[GitHub] [flink] RustedBones opened a new pull request #10285: [FLINK-14896] [flink-kinesis-connector] Set jackson and guava dependency to flink-shaded

RustedBones opened a new pull request #10285: [FLINK-14896] [flink-kinesis-connector] Set jackson and guava dependency to flink-shaded URL: https://github.com/apache/flink/pull/10285 ## What is the purpose of the change - Avoid missing / conflict librabry error due to exclusion rule

[GitHub] [flink] bowenli86 edited a comment on issue #10272: [FLINK-14878]Support `use catalog` through sqlUpdate() method in TableEnvironment

bowenli86 edited a comment on issue #10272: [FLINK-14878]Support `use catalog` through sqlUpdate() method in TableEnvironment URL: https://github.com/apache/flink/pull/10272#issuecomment-557215640 sorry for the late comment, but I happened to notice that UseCatalogOperation and

[GitHub] [flink] bowenli86 edited a comment on issue #10272: [FLINK-14878]Support `use catalog` through sqlUpdate() method in TableEnvironment

bowenli86 edited a comment on issue #10272: [FLINK-14878]Support `use catalog` through sqlUpdate() method in TableEnvironment URL: https://github.com/apache/flink/pull/10272#issuecomment-557215640 sorry for the late comment, but I happened to notice that UseCatalogOperation and

[GitHub] [flink] bowenli86 commented on issue #10272: [FLINK-14878]Support `use catalog` through sqlUpdate() method in TableEnvironment

bowenli86 commented on issue #10272: [FLINK-14878]Support `use catalog` through sqlUpdate() method in TableEnvironment URL: https://github.com/apache/flink/pull/10272#issuecomment-557215640 sorry for the late comment, but I happened to notice that UseCatalogOperation resides in package

[GitHub] [flink] bowenli86 closed pull request #10273: [FLINK-14866][doc] fix a few broken doc links

bowenli86 closed pull request #10273: [FLINK-14866][doc] fix a few broken doc links URL: https://github.com/apache/flink/pull/10273 This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Closed] (FLINK-14866) A few documentation links are broken

[ https://issues.apache.org/jira/browse/FLINK-14866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-14866. Resolution: Fixed master: e14bd50fed42e89674ba9d01a231d5c5e59f490c > A few documentation links are

[jira] [Assigned] (FLINK-14688) Add table related DDLs support in SQL Parser

[ https://issues.apache.org/jira/browse/FLINK-14688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-14688: Assignee: Terry Wang > Add table related DDLs support in SQL Parser >

[jira] [Closed] (FLINK-14688) Add table related DDLs support in SQL Parser

[ https://issues.apache.org/jira/browse/FLINK-14688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-14688. Resolution: Fixed master: 05a3132cb4520b9baaaf787e48ae727e75b91062 > Add table related DDLs support in

[jira] [Updated] (FLINK-14688) Add table related DDLs support in SQL Parser

[ https://issues.apache.org/jira/browse/FLINK-14688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-14688: - Fix Version/s: 1.10.0 > Add table related DDLs support in SQL Parser >

[GitHub] [flink] bowenli86 closed pull request #10209: [FLINK-14688] Add table related DDLs support in SQL Parser

bowenli86 closed pull request #10209: [FLINK-14688] Add table related DDLs support in SQL Parser URL: https://github.com/apache/flink/pull/10209 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on issue #10284: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler

flinkbot edited a comment on issue #10284: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler URL: https://github.com/apache/flink/pull/10284#issuecomment-557162273 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10282: [FLINK-14901] Throw Error in MemoryUtils if there is problem with using system classes over reflection

flinkbot edited a comment on issue #10282: [FLINK-14901] Throw Error in MemoryUtils if there is problem with using system classes over reflection URL: https://github.com/apache/flink/pull/10282#issuecomment-557119462 ## CI report: * 3b564b3abfdf77f6385d896fffe8eacbd135756e :

[jira] [Commented] (FLINK-14910) disableAutoGeneratedUIDs fails on keyBy

[ https://issues.apache.org/jira/browse/FLINK-14910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979467#comment-16979467 ] William Cheng commented on FLINK-14910: --- dota2ruhub userID: 100814397 Data is missing for a

[jira] [Updated] (FLINK-14910) disableAutoGeneratedUIDs fails on keyBy

[ https://issues.apache.org/jira/browse/FLINK-14910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] William Cheng updated FLINK-14910: -- Description: There doesn't seem to be a way to add a UID to the Partition operator created

[jira] [Created] (FLINK-14910) disableAutoGeneratedUIDs fails on keyBy

William Cheng created FLINK-14910: - Summary: disableAutoGeneratedUIDs fails on keyBy Key: FLINK-14910 URL: https://issues.apache.org/jira/browse/FLINK-14910 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-14906) Add function related method in CatalogManager

[ https://issues.apache.org/jira/browse/FLINK-14906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-14906: -- Description: 1) Add a temporary function hashmap to store temporary functions 2) Add create,

[GitHub] [flink] flinkbot edited a comment on issue #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint

flinkbot edited a comment on issue #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint URL: https://github.com/apache/flink/pull/10238#issuecomment-555064294 ## CI report: * a6c3b628841cead29b7c0e3d83bbf78c3a6b9170 : CANCELED

[jira] [Created] (FLINK-14909) Let tasks in a batch get scheduled in topological order and subtaskIndex ascending pattern

Zhu Zhu created FLINK-14909: --- Summary: Let tasks in a batch get scheduled in topological order and subtaskIndex ascending pattern Key: FLINK-14909 URL: https://issues.apache.org/jira/browse/FLINK-14909

[GitHub] [flink] flinkbot edited a comment on issue #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint

flinkbot edited a comment on issue #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint URL: https://github.com/apache/flink/pull/10238#issuecomment-555064294 ## CI report: * a6c3b628841cead29b7c0e3d83bbf78c3a6b9170 : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #10222: [FLINK-14788][configuration] Add configure method to CheckpointConfig

flinkbot edited a comment on issue #10222: [FLINK-14788][configuration] Add configure method to CheckpointConfig URL: https://github.com/apache/flink/pull/10222#issuecomment-554372384 ## CI report: * a7a80b60af90a66251ef5772cc55cf15bd4df55e : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10284: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler

flinkbot edited a comment on issue #10284: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler URL: https://github.com/apache/flink/pull/10284#issuecomment-557162273 ## CI report: *

[jira] [Closed] (FLINK-14126) Elasticsearch Xpack Machine Learning doesn't support ARM

[ https://issues.apache.org/jira/browse/FLINK-14126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-14126. Fix Version/s: (was: 2.0.0) 1.10.0 Resolution: Fixed Merged

[GitHub] [flink] flinkbot edited a comment on issue #10283: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler

flinkbot edited a comment on issue #10283: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler URL: https://github.com/apache/flink/pull/10283#issuecomment-55716 ## CI report: *

[jira] [Updated] (FLINK-14126) Elasticsearch Xpack Machine Learning doesn't support ARM

[ https://issues.apache.org/jira/browse/FLINK-14126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14126: --- Labels: pull-request-available (was: ) > Elasticsearch Xpack Machine Learning doesn't

[jira] [Assigned] (FLINK-14126) Elasticsearch Xpack Machine Learning doesn't support ARM

[ https://issues.apache.org/jira/browse/FLINK-14126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-14126: Assignee: wangxiyuan > Elasticsearch Xpack Machine Learning doesn't support ARM

[GitHub] [flink] aljoscha merged pull request #9765: [FLINK-14126][test] Disable Xpack.ml for elasticsearch 6.0+ on ARM

aljoscha merged pull request #9765: [FLINK-14126][test] Disable Xpack.ml for elasticsearch 6.0+ on ARM URL: https://github.com/apache/flink/pull/9765 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] aljoscha merged pull request #10012: [hotfix][typo] fix typo in ContaineredTaskManagerParameters

aljoscha merged pull request #10012: [hotfix][typo] fix typo in ContaineredTaskManagerParameters URL: https://github.com/apache/flink/pull/10012 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] aljoscha merged pull request #9989: [hotfix][docs] Delete useless annotation in NonWindowLeftRightJoinWithNonEquiPredicates

aljoscha merged pull request #9989: [hotfix][docs] Delete useless annotation in NonWindowLeftRightJoinWithNonEquiPredicates URL: https://github.com/apache/flink/pull/9989 This is an automated message from the Apache Git

[jira] [Commented] (FLINK-14908) Distributing CacheFiles through DFS does not work

[ https://issues.apache.org/jira/browse/FLINK-14908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979412#comment-16979412 ] Dawid Wysakowicz commented on FLINK-14908: -- cc [~chesnay] [~trohrmann] Do you know if this is a

[jira] [Updated] (FLINK-14908) Distributing CacheFiles through DFS does not work

[ https://issues.apache.org/jira/browse/FLINK-14908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-14908: - Description: User reported that distributing cache files through DFS does not work

[jira] [Created] (FLINK-14908) Distributing CacheFiles through DFS does not work

Dawid Wysakowicz created FLINK-14908: Summary: Distributing CacheFiles through DFS does not work Key: FLINK-14908 URL: https://issues.apache.org/jira/browse/FLINK-14908 Project: Flink

[GitHub] [flink] GJL commented on a change in pull request #10235: [FLINK-14839][config] Let JobGraph#classpaths become non-null

GJL commented on a change in pull request #10235: [FLINK-14839][config] Let JobGraph#classpaths become non-null URL: https://github.com/apache/flink/pull/10235#discussion_r349192762 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java

[GitHub] [flink] GJL commented on a change in pull request #10235: [FLINK-14839][config] Let JobGraph#classpaths become non-null

GJL commented on a change in pull request #10235: [FLINK-14839][config] Let JobGraph#classpaths become non-null URL: https://github.com/apache/flink/pull/10235#discussion_r349193099 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java

<    1   2   3   4   5   6   7   >