[GitHub] [flink] flinkbot commented on issue #10313: [FLINK-14840] Use Executor interface in SQL cli

flinkbot commented on issue #10313: [FLINK-14840] Use Executor interface in SQL cli URL: https://github.com/apache/flink/pull/10313#issuecomment-558150080 ## CI report: * 939f98f295371d474f25cb86422f01993ba87645 : UNKNOWN Bot commands The @flinkbot bot supports

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

[ https://issues.apache.org/jira/browse/FLINK-14765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-14765: --- Assignee: vinoyang > Remove STATE_UPDATER in Execution >

[GitHub] [flink] flinkbot edited a comment on issue #10314: [FLINK-14941][hbase] The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any excep

flinkbot edited a comment on issue #10314: [FLINK-14941][hbase] The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any exception URL: https://github.com/apache/flink/pull/10314#issuecomment-558163426 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10312: [FLINK-12996][table-common] Add type validators and strategies for FLIP-65

flinkbot edited a comment on issue #10312: [FLINK-12996][table-common] Add type validators and strategies for FLIP-65 URL: https://github.com/apache/flink/pull/10312#issuecomment-558117985 ## CI report: * 6ab1e71cafd16a9fd575c78d7d0e65c6e996b657 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10313: [FLINK-14840] Use Executor interface in SQL cli

flinkbot edited a comment on issue #10313: [FLINK-14840] Use Executor interface in SQL cli URL: https://github.com/apache/flink/pull/10313#issuecomment-558150080 ## CI report: * 939f98f295371d474f25cb86422f01993ba87645 : FAILURE

[GitHub] [flink] azagrebin commented on a change in pull request #10161: [FLINK-13986][runtime] Clean up legacy code for FLIP-49.

azagrebin commented on a change in pull request #10161: [FLINK-13986][runtime] Clean up legacy code for FLIP-49. URL: https://github.com/apache/flink/pull/10161#discussion_r350231144 ## File path:

[GitHub] [flink] zjffdu commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli

zjffdu commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli URL: https://github.com/apache/flink/pull/10313#discussion_r350233830 ## File path:

[GitHub] [flink] leonardBang commented on a change in pull request #10239: [FLINK-11491][end2end] Support all TPC-DS queries

leonardBang commented on a change in pull request #10239: [FLINK-11491][end2end] Support all TPC-DS queries URL: https://github.com/apache/flink/pull/10239#discussion_r350242931 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10313: [FLINK-14840] Use Executor interface in SQL cli

flinkbot edited a comment on issue #10313: [FLINK-14840] Use Executor interface in SQL cli URL: https://github.com/apache/flink/pull/10313#issuecomment-558150080 ## CI report: * 939f98f295371d474f25cb86422f01993ba87645 : FAILURE

[GitHub] [flink] flinkbot commented on issue #10315: [FLINK-14552][table] Enable partition statistics in blink planner

flinkbot commented on issue #10315: [FLINK-14552][table] Enable partition statistics in blink planner URL: https://github.com/apache/flink/pull/10315#issuecomment-558210998 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] flinkbot edited a comment on issue #10310: [FLINK-14865][python] fix unstable tests PyFlinkBlinkStreamUserDefinedFunctionTests#test_udf_in_join_condition_2

flinkbot edited a comment on issue #10310: [FLINK-14865][python] fix unstable tests PyFlinkBlinkStreamUserDefinedFunctionTests#test_udf_in_join_condition_2 URL: https://github.com/apache/flink/pull/10310#issuecomment-558081072 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10313: [FLINK-14840] Use Executor interface in SQL cli

flinkbot edited a comment on issue #10313: [FLINK-14840] Use Executor interface in SQL cli URL: https://github.com/apache/flink/pull/10313#issuecomment-558150080 ## CI report: * 939f98f295371d474f25cb86422f01993ba87645 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10305: [FLINK-14892][docs] Add documentation for checkpoint directory layout

flinkbot edited a comment on issue #10305: [FLINK-14892][docs] Add documentation for checkpoint directory layout URL: https://github.com/apache/flink/pull/10305#issuecomment-558011526 ## CI report: * 160416cea63f157c0264c24812e2b2eef90e8c1d : SUCCESS

[GitHub] [flink] flinkbot commented on issue #10314: [FLINK-14941][hbase] The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any exception

flinkbot commented on issue #10314: [FLINK-14941][hbase] The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any exception URL: https://github.com/apache/flink/pull/10314#issuecomment-558163426 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10305: [FLINK-14892][docs] Add documentation for checkpoint directory layout

flinkbot edited a comment on issue #10305: [FLINK-14892][docs] Add documentation for checkpoint directory layout URL: https://github.com/apache/flink/pull/10305#issuecomment-558011526 ## CI report: * 160416cea63f157c0264c24812e2b2eef90e8c1d : SUCCESS

[jira] [Closed] (FLINK-14874) add local aggregate to solve data skew for ROLLUP/CUBE case

[ https://issues.apache.org/jira/browse/FLINK-14874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14874. -- Resolution: Fixed merged to master: 75427bfbf3b48a30838ecb64270294370b63257d > add local aggregate

[GitHub] [flink] wangyang0918 commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

wangyang0918 commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#discussion_r350218527 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java

[GitHub] [flink] azagrebin commented on a change in pull request #10161: [FLINK-13986][runtime] Clean up legacy code for FLIP-49.

azagrebin commented on a change in pull request #10161: [FLINK-13986][runtime] Clean up legacy code for FLIP-49. URL: https://github.com/apache/flink/pull/10161#discussion_r350253136 ## File path:

[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

[GitHub] [flink] openinx opened a new pull request #10314: [FLINK-14941][hbase] The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any except

openinx opened a new pull request #10314: [FLINK-14941][hbase] The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any exception URL: https://github.com/apache/flink/pull/10314 ## What is the purpose of the change In the

[jira] [Updated] (FLINK-14941) The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any exception

[ https://issues.apache.org/jira/browse/FLINK-14941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14941: --- Labels: pull-request-available (was: ) > The AbstractTableInputFormat#nextRecord in hbase

[GitHub] [flink] flinkbot edited a comment on issue #10270: [FLINK-14672][sql-client] Make Executor stateful in sql client

flinkbot edited a comment on issue #10270: [FLINK-14672][sql-client] Make Executor stateful in sql client URL: https://github.com/apache/flink/pull/10270#issuecomment-555974946 ## CI report: * 4b5c6f4491d27b2ac16b571e3b92ce96c02c4a9a : SUCCESS

[jira] [Commented] (FLINK-13590) flink-on-yarn sometimes could create many little files that are xxx-taskmanager-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-13590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16981563#comment-16981563 ] shuwenjun commented on FLINK-13590: --- Could you wait a little week? I can valid this bug whether was

[GitHub] [flink] flinkbot edited a comment on issue #9973: [FLINK-9955] Add Kubernetes ClusterDescriptor to support deploying session cluster.

flinkbot edited a comment on issue #9973: [FLINK-9955] Add Kubernetes ClusterDescriptor to support deploying session cluster. URL: https://github.com/apache/flink/pull/9973#issuecomment-545325448 ## CI report: * 450cd1029219372cdc4f05f4bf6bc3ff6e43dc90 : SUCCESS

[GitHub] [flink] azagrebin commented on issue #10180: [FLINK-14631] Account for netty direct allocations in direct memory limit (Netty Shuffle)

azagrebin commented on issue #10180: [FLINK-14631] Account for netty direct allocations in direct memory limit (Netty Shuffle) URL: https://github.com/apache/flink/pull/10180#issuecomment-558172118 Thanks for the reviews @xintongsong @zhijiangW merging this I also increased minimum

[GitHub] [flink] azagrebin commented on a change in pull request #10180: [FLINK-14631] Account for netty direct allocations in direct memory limit (Netty Shuffle)

azagrebin commented on a change in pull request #10180: [FLINK-14631] Account for netty direct allocations in direct memory limit (Netty Shuffle) URL: https://github.com/apache/flink/pull/10180#discussion_r350203293 ## File path: flink-docs/README.md ## @@ -1,4 +1,4 @@

[GitHub] [flink] KurtYoung merged pull request #10271: [FLINK-14874] [table-planner-blink] add local aggregate to solve data skew for ROLLUP/CUBE case

KurtYoung merged pull request #10271: [FLINK-14874] [table-planner-blink] add local aggregate to solve data skew for ROLLUP/CUBE case URL: https://github.com/apache/flink/pull/10271 This is an automated message from the

[GitHub] [flink] flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#issuecomment-552307115 ## CI report: * 25f9e4b87846e5a736aa329c834f82962e1f50c4 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10313: [FLINK-14840] Use Executor interface in SQL cli

flinkbot edited a comment on issue #10313: [FLINK-14840] Use Executor interface in SQL cli URL: https://github.com/apache/flink/pull/10313#issuecomment-558150080 ## CI report: * 939f98f295371d474f25cb86422f01993ba87645 : FAILURE

[GitHub] [flink] leonardBang commented on a change in pull request #10239: [FLINK-11491][end2end] Support all TPC-DS queries

leonardBang commented on a change in pull request #10239: [FLINK-11491][end2end] Support all TPC-DS queries URL: https://github.com/apache/flink/pull/10239#discussion_r350241436 ## File path:

[GitHub] [flink] leonardBang commented on a change in pull request #10239: [FLINK-11491][end2end] Support all TPC-DS queries

leonardBang commented on a change in pull request #10239: [FLINK-11491][end2end] Support all TPC-DS queries URL: https://github.com/apache/flink/pull/10239#discussion_r350241241 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10305: [FLINK-14892][docs] Add documentation for checkpoint directory layout

flinkbot edited a comment on issue #10305: [FLINK-14892][docs] Add documentation for checkpoint directory layout URL: https://github.com/apache/flink/pull/10305#issuecomment-558011526 ## CI report: * 160416cea63f157c0264c24812e2b2eef90e8c1d : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10180: [FLINK-14631] Account for netty direct allocations in direct memory limit (Netty Shuffle)

flinkbot edited a comment on issue #10180: [FLINK-14631] Account for netty direct allocations in direct memory limit (Netty Shuffle) URL: https://github.com/apache/flink/pull/10180#issuecomment-553548508 ## CI report: * 90edfd955f7606a7def46b3aadcdc64ed95b5b3f : FAILURE

[GitHub] [flink] JingsongLi opened a new pull request #10315: [FLINK-14552][table] Enable partition statistics in blink planner

JingsongLi opened a new pull request #10315: [FLINK-14552][table] Enable partition statistics in blink planner URL: https://github.com/apache/flink/pull/10315 ## What is the purpose of the change Now after partition pruning, we will lost stats. Actually, we have partition

[jira] [Updated] (FLINK-14552) Enable partition statistics in blink planner

[ https://issues.apache.org/jira/browse/FLINK-14552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14552: --- Labels: pull-request-available (was: ) > Enable partition statistics in blink planner >

[GitHub] [flink] flinkbot edited a comment on issue #10246: [FLINK-10937][dist] Add kubernetes-entry.sh and kubernetes-session.sh.

flinkbot edited a comment on issue #10246: [FLINK-10937][dist] Add kubernetes-entry.sh and kubernetes-session.sh. URL: https://github.com/apache/flink/pull/10246#issuecomment-555375256 ## CI report: * 9f06575f29a7cb1102357c8919b57b3471dc80fd : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10245: [FLINK-10936][kubernetes] Implement Kubernetes command line tools to support session cluster.

flinkbot edited a comment on issue #10245: [FLINK-10936][kubernetes] Implement Kubernetes command line tools to support session cluster. URL: https://github.com/apache/flink/pull/10245#issuecomment-555375223 ## CI report: * 71f8401be1cb214e56f94e486c495ef7c800cfc4 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner

flinkbot edited a comment on issue #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner URL: https://github.com/apache/flink/pull/10296#issuecomment-557762350 ## CI report: * 7c5e46d1f794cb01be5088f5f5d29aec5850bf7f :

[GitHub] [flink] flinkbot edited a comment on issue #10311: [FLINK-14762][client] Enrich JobClient API

flinkbot edited a comment on issue #10311: [FLINK-14762][client] Enrich JobClient API URL: https://github.com/apache/flink/pull/10311#issuecomment-558081118 ## CI report: * aadc1cfef92eec54d86efbf39f50d91afda6 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10310: [FLINK-14865][python] fix unstable tests PyFlinkBlinkStreamUserDefinedFunctionTests#test_udf_in_join_condition_2

flinkbot edited a comment on issue #10310: [FLINK-14865][python] fix unstable tests PyFlinkBlinkStreamUserDefinedFunctionTests#test_udf_in_join_condition_2 URL: https://github.com/apache/flink/pull/10310#issuecomment-558081072 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#issuecomment-552307115 ## CI report: * 25f9e4b87846e5a736aa329c834f82962e1f50c4 : FAILURE

[jira] [Commented] (FLINK-13943) Provide api to convert flink table to java List (e.g. Table#collect)

[ https://issues.apache.org/jira/browse/FLINK-13943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16981451#comment-16981451 ] Aljoscha Krettek commented on FLINK-13943: -- I think yes. But we can make `collect()` return an

[jira] [Updated] (FLINK-12996) Add predefined type validators, strategies, and transformations

[ https://issues.apache.org/jira/browse/FLINK-12996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12996: --- Labels: pull-request-available (was: ) > Add predefined type validators, strategies, and

[GitHub] [flink] twalthr opened a new pull request #10312: [FLINK-12996][table-common] Add type validators and strategies for FLIP-65

twalthr opened a new pull request #10312: [FLINK-12996][table-common] Add type validators and strategies for FLIP-65 URL: https://github.com/apache/flink/pull/10312 ## What is the purpose of the change This adds a set of pre-defined type validators and strategies which will be

[jira] [Reopened] (FLINK-13749) Make Flink client respect classloading policy

[ https://issues.apache.org/jira/browse/FLINK-13749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-13749: -- Reopen to add release notes. > Make Flink client respect classloading policy >

[jira] [Commented] (FLINK-13749) Make Flink client respect classloading policy

[ https://issues.apache.org/jira/browse/FLINK-13749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16981452#comment-16981452 ] Aljoscha Krettek commented on FLINK-13749: -- You're right, I'm adding that.  > Make Flink

[GitHub] [flink] dawidwys commented on a change in pull request #10308: [FLINK-14904][table] Rename ANY type to RAW type

dawidwys commented on a change in pull request #10308: [FLINK-14904][table] Rename ANY type to RAW type URL: https://github.com/apache/flink/pull/10308#discussion_r350123520 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #10308: [FLINK-14904][table] Rename ANY type to RAW type

dawidwys commented on a change in pull request #10308: [FLINK-14904][table] Rename ANY type to RAW type URL: https://github.com/apache/flink/pull/10308#discussion_r350122605 ## File path: flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/DataTypesTest.java

[GitHub] [flink] dawidwys closed pull request #8915: [FLINK-13015][table-api-java] Create validators, strategies and transformations required for porting logical expressions

dawidwys closed pull request #8915: [FLINK-13015][table-api-java] Create validators, strategies and transformations required for porting logical expressions URL: https://github.com/apache/flink/pull/8915 This is an

[jira] [Created] (FLINK-14941) The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any exception

Zheng Hu created FLINK-14941: Summary: The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any exception Key: FLINK-14941 URL:

[jira] [Comment Edited] (FLINK-14104) Bump Jackson to 2.10.1

[ https://issues.apache.org/jira/browse/FLINK-14104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979170#comment-16979170 ] Chesnay Schepler edited comment on FLINK-14104 at 11/25/19 12:27 PM: -

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

aljoscha commented on issue #10286: [FLINK-14890] [tests] Add missing test harnesses for broadcast functions URL: https://github.com/apache/flink/pull/10286#issuecomment-558149223 Thanks for your contribution! I think this mixes up to (potentially) orthogonal issues: 1. The

[GitHub] [flink] flinkbot commented on issue #10311: [FLINK-14762][client] Enrich JobClient API

flinkbot commented on issue #10311: [FLINK-14762][client] Enrich JobClient API URL: https://github.com/apache/flink/pull/10311#issuecomment-558081118 ## CI report: * aadc1cfef92eec54d86efbf39f50d91afda6 : UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] flinkbot commented on issue #10310: [FLINK-14865][python] fix unstable tests PyFlinkBlinkStreamUserDefinedFunctionTests#test_udf_in_join_condition_2

flinkbot commented on issue #10310: [FLINK-14865][python] fix unstable tests PyFlinkBlinkStreamUserDefinedFunctionTests#test_udf_in_join_condition_2 URL: https://github.com/apache/flink/pull/10310#issuecomment-558081072 ## CI report: * 801926d95f316419f0464dd8456d55b074d9db34 :

[GitHub] [flink] flinkbot edited a comment on issue #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible

flinkbot edited a comment on issue #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible URL: https://github.com/apache/flink/pull/10309#issuecomment-558068110 ## CI report: * 51e86fe9d2397879945677aee80da5983402afca : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9957: [FLINK-10932] Initialize flink-kubernetes module

flinkbot edited a comment on issue #9957: [FLINK-10932] Initialize flink-kubernetes module URL: https://github.com/apache/flink/pull/9957#issuecomment-544504781 ## CI report: * 41f3075d918578641781d15eb8c4d3cfc9bb4ada : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

flinkbot edited a comment on issue #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#issuecomment-544813931 ## CI report: * 6f90b457e56a0a8cb45d63c1b05b47d2e38030a1 : SUCCESS

[jira] [Assigned] (FLINK-14624) Support computed column as rowtime attribute

[ https://issues.apache.org/jira/browse/FLINK-14624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14624: --- Assignee: Jark Wu > Support computed column as rowtime attribute >

[GitHub] [flink] rkhachatryan commented on a change in pull request #10151: [FLINK-14231] Handle the processing-time timers before closing operator to properly support endInput

rkhachatryan commented on a change in pull request #10151: [FLINK-14231] Handle the processing-time timers before closing operator to properly support endInput URL: https://github.com/apache/flink/pull/10151#discussion_r350103943 ## File path:

[jira] [Updated] (FLINK-13191) Add a simplified UDF type extraction

[ https://issues.apache.org/jira/browse/FLINK-13191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-13191: - Parent: (was: FLINK-12251) Issue Type: New Feature (was: Sub-task) > Add a

[GitHub] [flink] flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#issuecomment-545881191 ## CI report: * 802ebf37e3d932169f9826b40df483bb5e9ac064 : SUCCESS

[GitHub] [flink] zentol merged pull request #10302: [1.8][FLINK-14104][build] Use flink-shaded-jackson 9.0

zentol merged pull request #10302: [1.8][FLINK-14104][build] Use flink-shaded-jackson 9.0 URL: https://github.com/apache/flink/pull/10302 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] yanghua commented on issue #8871: [FLINK-12976] Bump Kafka client version to 2.3.0 for universal Kafka connector

yanghua commented on issue #8871: [FLINK-12976] Bump Kafka client version to 2.3.0 for universal Kafka connector URL: https://github.com/apache/flink/pull/8871#issuecomment-558133020 @aljoscha @becketqin Kafka 2.3.1 has been released. However, we still can not bump the version to 2.3.0.

[GitHub] [flink] dawidwys commented on issue #8859: [FLINK-12905][table-planner] Enable querying CatalogViews in legacy planner

dawidwys commented on issue #8859: [FLINK-12905][table-planner] Enable querying CatalogViews in legacy planner URL: https://github.com/apache/flink/pull/8859#issuecomment-558105494 @danny0405 @lirui-apache Could you have a look?

[jira] [Closed] (FLINK-14767) Mark TaskManagerOptions#EXIT_ON_FATAL_AKKA_ERROR with @Deprecated annotation

[ https://issues.apache.org/jira/browse/FLINK-14767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-14767. Fix Version/s: 1.10.0 Resolution: Fixed Merged on master in

[GitHub] [flink] aljoscha merged pull request #10215: [FLINK-14767] Mark TaskManagerOptions#EXIT_ON_FATAL_AKKA_ERROR with @Deprecated annotation

aljoscha merged pull request #10215: [FLINK-14767] Mark TaskManagerOptions#EXIT_ON_FATAL_AKKA_ERROR with @Deprecated annotation URL: https://github.com/apache/flink/pull/10215 This is an automated message from the Apache

[GitHub] [flink] XuQianJin-Stars commented on issue #8746: [hotfix][FLINK-11120][table]fix the bug of timestampadd handles time

XuQianJin-Stars commented on issue #8746: [hotfix][FLINK-11120][table]fix the bug of timestampadd handles time URL: https://github.com/apache/flink/pull/8746#issuecomment-558121572 hi @wuchong @walterddr Can you take the time to review this PR? Thanks forward

[GitHub] [flink] flinkbot edited a comment on issue #10312: [FLINK-12996][table-common] Add type validators and strategies for FLIP-65

flinkbot edited a comment on issue #10312: [FLINK-12996][table-common] Add type validators and strategies for FLIP-65 URL: https://github.com/apache/flink/pull/10312#issuecomment-558117985 ## CI report: * 6ab1e71cafd16a9fd575c78d7d0e65c6e996b657 : PENDING

[GitHub] [flink] yanghua commented on issue #10304: [FLINK-14838] Cleanup the description about container number config option in Scala and python shell doc

yanghua commented on issue #10304: [FLINK-14838] Cleanup the description about container number config option in Scala and python shell doc URL: https://github.com/apache/flink/pull/10304#issuecomment-558132118 @aljoscha Would you please review this PR. It seems Till is very busy

[GitHub] [flink] klion26 commented on issue #10298: [FLINK-11605] Translate the "Dataflow Programming Model" page into Ch… …

klion26 commented on issue #10298: [FLINK-11605] Translate the "Dataflow Programming Model" page into Ch… … URL: https://github.com/apache/flink/pull/10298#issuecomment-558143847 @ZhangchengHu0923 thanks for your contribution, could you please follow [the

[GitHub] [flink] flinkbot edited a comment on issue #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics

flinkbot edited a comment on issue #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics URL: https://github.com/apache/flink/pull/10174#issuecomment-553372516 ## CI report: * 0877da16f10eef830aafb9d6b3328df1c1b461a0

[GitHub] [flink] xintongsong commented on a change in pull request #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

xintongsong commented on a change in pull request #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#discussion_r350107833 ## File path:

[GitHub] [flink] aljoscha commented on issue #10215: [FLINK-14767] Mark TaskManagerOptions#EXIT_ON_FATAL_AKKA_ERROR with @Deprecated annotation

aljoscha commented on issue #10215: [FLINK-14767] Mark TaskManagerOptions#EXIT_ON_FATAL_AKKA_ERROR with @Deprecated annotation URL: https://github.com/apache/flink/pull/10215#issuecomment-558107507 Ok, sorry! Then that was a miss-understanding. 

[jira] [Commented] (FLINK-12692) Support disk spilling in HeapKeyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-12692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16981443#comment-16981443 ] Simon Su commented on FLINK-12692: -- Hi Yu Li, What's the difference between this and FsStateBackend ?

[jira] [Updated] (FLINK-14854) Add executeAsync() method to execution environments

[ https://issues.apache.org/jira/browse/FLINK-14854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-14854: - Summary: Add executeAsync() method to execution environments (was: Add executeAsync()

[GitHub] [flink] sunhaibotb commented on a change in pull request #10151: [FLINK-14231] Handle the processing-time timers before closing operator to properly support endInput

sunhaibotb commented on a change in pull request #10151: [FLINK-14231] Handle the processing-time timers before closing operator to properly support endInput URL: https://github.com/apache/flink/pull/10151#discussion_r350128160 ## File path:

[GitHub] [flink] flinkbot commented on issue #10312: [FLINK-12996][table-common] Add type validators and strategies for FLIP-65

flinkbot commented on issue #10312: [FLINK-12996][table-common] Add type validators and strategies for FLIP-65 URL: https://github.com/apache/flink/pull/10312#issuecomment-558117985 ## CI report: * 6ab1e71cafd16a9fd575c78d7d0e65c6e996b657 : UNKNOWN Bot commands

[GitHub] [flink] flinkbot edited a comment on issue #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner

flinkbot edited a comment on issue #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner URL: https://github.com/apache/flink/pull/10296#issuecomment-557762350 ## CI report: * 7c5e46d1f794cb01be5088f5f5d29aec5850bf7f :

[GitHub] [flink] flinkbot commented on issue #10313: [FLINK-14840] Use Executor interface in SQL cli

flinkbot commented on issue #10313: [FLINK-14840] Use Executor interface in SQL cli URL: https://github.com/apache/flink/pull/10313#issuecomment-558142103 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Updated] (FLINK-14840) Use new Executor interface in SQL cli

[ https://issues.apache.org/jira/browse/FLINK-14840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14840: --- Labels: pull-request-available (was: ) > Use new Executor interface in SQL cli >

[GitHub] [flink] aljoscha opened a new pull request #10313: [FLINK-14840] Use Executor interface in SQL cli

aljoscha opened a new pull request #10313: [FLINK-14840] Use Executor interface in SQL cli URL: https://github.com/apache/flink/pull/10313 ## What is the purpose of the change * Change the SQL cli to use the new `Executor` interface and `JobClient` instead of manually going through

[jira] [Commented] (FLINK-13899) Add SQL DDL for Elasticsearch 5.X version

[ https://issues.apache.org/jira/browse/FLINK-13899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16981537#comment-16981537 ] Robert Metzger commented on FLINK-13899: I'm not aware of anybody in the community who's

[GitHub] [flink] lirui-apache commented on a change in pull request #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner

lirui-apache commented on a change in pull request #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner URL: https://github.com/apache/flink/pull/10296#discussion_r350160829 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner

lirui-apache commented on a change in pull request #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner URL: https://github.com/apache/flink/pull/10296#discussion_r350169231 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner

lirui-apache commented on a change in pull request #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner URL: https://github.com/apache/flink/pull/10296#discussion_r350149826 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner

lirui-apache commented on a change in pull request #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner URL: https://github.com/apache/flink/pull/10296#discussion_r350168963 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner

lirui-apache commented on a change in pull request #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner URL: https://github.com/apache/flink/pull/10296#discussion_r350159832 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner

lirui-apache commented on a change in pull request #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner URL: https://github.com/apache/flink/pull/10296#discussion_r350152318 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner

lirui-apache commented on a change in pull request #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner URL: https://github.com/apache/flink/pull/10296#discussion_r350161836 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner

lirui-apache commented on a change in pull request #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner URL: https://github.com/apache/flink/pull/10296#discussion_r350155153 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner

lirui-apache commented on a change in pull request #10296: [FLINK-14691][table]Add use/create/drop/alter database operation and support it in flink/blink planner URL: https://github.com/apache/flink/pull/10296#discussion_r350151497 ## File path:

[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

[GitHub] [flink] xintongsong commented on a change in pull request #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

xintongsong commented on a change in pull request #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#discussion_r350094273 ## File path:

[GitHub] [flink] xintongsong commented on a change in pull request #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

xintongsong commented on a change in pull request #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#discussion_r350100346 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #8859: [FLINK-12905][table-planner] Enable querying CatalogViews in legacy planner

flinkbot edited a comment on issue #8859: [FLINK-12905][table-planner] Enable querying CatalogViews in legacy planner URL: https://github.com/apache/flink/pull/8859#issuecomment-518729517 ## CI report: * c2adafa7ee87b18ba6af0b5f518251150a8da386 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#issuecomment-552307115 ## CI report: * 25f9e4b87846e5a736aa329c834f82962e1f50c4 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10103: [FLINK-14506][python][build] Improve the release script for Python API release package

flinkbot edited a comment on issue #10103: [FLINK-14506][python][build] Improve the release script for Python API release package URL: https://github.com/apache/flink/pull/10103#issuecomment-550222346 ## CI report: * 7c842be4f1d79ff3206322d72f4cb1dcebd52c7e : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10245: [FLINK-10936][kubernetes] Implement Kubernetes command line tools to support session cluster.

flinkbot edited a comment on issue #10245: [FLINK-10936][kubernetes] Implement Kubernetes command line tools to support session cluster. URL: https://github.com/apache/flink/pull/10245#issuecomment-555375223 ## CI report: * 71f8401be1cb214e56f94e486c495ef7c800cfc4 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9985: [FLINK-10968][kubernetes] Implement TaskManager Entrypoint for Kubernetes.

flinkbot edited a comment on issue #9985: [FLINK-10968][kubernetes] Implement TaskManager Entrypoint for Kubernetes. URL: https://github.com/apache/flink/pull/9985#issuecomment-545891561 ## CI report: * e74d80aaf05f631c7757483023657bee6f533e45 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9986: [FLINK-10933][kubernetes] Implement KubernetesSessionClusterEntrypoint.

flinkbot edited a comment on issue #9986: [FLINK-10933][kubernetes] Implement KubernetesSessionClusterEntrypoint. URL: https://github.com/apache/flink/pull/9986#issuecomment-545891630 ## CI report: * 593bf42620faf09c1accbd692494646194e3d574 : FAILURE

<    1   2   3   4   5   >