[jira] [Resolved] (FLINK-14321) Support to parse watermark statement in SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-14321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-14321. - Fix Version/s: 1.10.0 Resolution: Fixed 1.10.0: bccc4404ec9e73cc03e36631e6b3cf38a8c0e571 > Suppo

[GitHub] [flink] flinkbot edited a comment on issue #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL

flinkbot edited a comment on issue #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL URL: https://github.com/apache/flink/pull/9952#issuecomment-544436896 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] wuchong closed pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL

wuchong closed pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL URL: https://github.com/apache/flink/pull/9952 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#issuecomment-546219804 ## CI report: * f47a9f60dff6710ce5a7d5fe341a94d0fffb2d6d : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL

flinkbot edited a comment on issue #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL URL: https://github.com/apache/flink/pull/9952#issuecomment-544436896 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] wuchong commented on issue #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL

wuchong commented on issue #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL URL: https://github.com/apache/flink/pull/9952#issuecomment-546226951 Thanks @KurtYoung and @danny0405 for the reviewing. I will merge this then. --

[GitHub] [flink] KurtYoung commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

KurtYoung commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#discussion_r338907408 ## File path: flink-table/flink-table-planner-blink/src/main

[GitHub] [flink] KurtYoung commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

KurtYoung commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#discussion_r338906446 ## File path: flink-table/flink-table-planner-blink/src/main

[GitHub] [flink] KurtYoung commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

KurtYoung commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#discussion_r338907002 ## File path: flink-table/flink-table-planner-blink/src/main

[GitHub] [flink] KurtYoung commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

KurtYoung commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#discussion_r338907291 ## File path: flink-table/flink-table-planner-blink/src/main

[GitHub] [flink] KurtYoung commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

KurtYoung commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#discussion_r338907827 ## File path: flink-table/flink-table-planner-blink/src/main

[GitHub] [flink] KurtYoung commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

KurtYoung commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#discussion_r338906042 ## File path: flink-table/flink-table-planner-blink/src/main

[GitHub] [flink] KurtYoung commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

KurtYoung commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#discussion_r338905610 ## File path: flink-table/flink-table-planner-blink/src/main

[GitHub] [flink] KurtYoung commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

KurtYoung commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#discussion_r338907546 ## File path: flink-table/flink-table-planner-blink/src/main

[jira] [Created] (FLINK-14527) Add integeration tests for PostgreSQL and MySQL dialects in flink jdbc module

Jark Wu created FLINK-14527: --- Summary: Add integeration tests for PostgreSQL and MySQL dialects in flink jdbc module Key: FLINK-14527 URL: https://issues.apache.org/jira/browse/FLINK-14527 Project: Flink

[jira] [Resolved] (FLINK-14524) PostgreSQL JDBC sink generates invalid SQL in upsert mode

[ https://issues.apache.org/jira/browse/FLINK-14524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-14524. - Fix Version/s: 1.9.2 1.10.0 Resolution: Fixed 1.10.0: 1cefbb8b5d0ba0e687635441

[GitHub] [flink] flinkbot edited a comment on issue #9990: [FLINK-14524] [flink-jdbc] Correct syntax for PostgreSQL dialect "upsert" statement

flinkbot edited a comment on issue #9990: [FLINK-14524] [flink-jdbc] Correct syntax for PostgreSQL dialect "upsert" statement URL: https://github.com/apache/flink/pull/9990#issuecomment-546166373 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] wuchong merged pull request #9990: [FLINK-14524] [flink-jdbc] Correct syntax for PostgreSQL dialect "upsert" statement

wuchong merged pull request #9990: [FLINK-14524] [flink-jdbc] Correct syntax for PostgreSQL dialect "upsert" statement URL: https://github.com/apache/flink/pull/9990 This is an automated message from the Apache Git Service.

[jira] [Assigned] (FLINK-14524) PostgreSQL JDBC sink generates invalid SQL in upsert mode

[ https://issues.apache.org/jira/browse/FLINK-14524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14524: --- Assignee: Fawad Halim > PostgreSQL JDBC sink generates invalid SQL in upsert mode > ---

[GitHub] [flink] flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#issuecomment-542593114 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbo

[GitHub] [flink] KurtYoung commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

KurtYoung commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#discussion_r338903410 ## File path: flink-table/flink-table-planner-blink/src/main

[GitHub] [flink] flinkbot commented on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

flinkbot commented on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#issuecomment-546219804 ## CI report: * f47a9f60dff6710ce5a7d5fe341a94d0fffb2d6d : UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#issuecomment-542593114 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbo

[GitHub] [flink] KurtYoung commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

KurtYoung commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#discussion_r338900074 ## File path: flink-table/flink-table-planner-blink/src/main

[jira] [Commented] (FLINK-10435) Client sporadically hangs after Ctrl + C

[ https://issues.apache.org/jira/browse/FLINK-10435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959459#comment-16959459 ] Yang Wang commented on FLINK-10435: --- It seems that the yarn client hangs when calling

[GitHub] [flink] flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#issuecomment-542593114 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbo

[GitHub] [flink] JingsongLi commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

JingsongLi commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#discussion_r338899223 ## File path: flink-table/flink-table-planner-blink/src/mai

[GitHub] [flink] flinkbot commented on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

flinkbot commented on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#issuecomment-546216825 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot.

[GitHub] [flink] flinkbot edited a comment on issue #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions

flinkbot edited a comment on issue #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions URL: https://github.com/apache/flink/pull/9977#issuecomment-545444286 ## CI report: * 89d33a5aeefd6934261cc185c306c2e55b6c8ad2 : FAILURE [Build](https://

[GitHub] [flink] wsry opened a new pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

wsry opened a new pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993 ## What is the purpose of the change If the LocalBufferPool can not request available buffer from Ne

[jira] [Updated] (FLINK-14498) Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool

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

[GitHub] [flink] flinkbot edited a comment on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering

flinkbot edited a comment on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering URL: https://github.com/apache/flink/pull/9853#issuecomment-539472188 ## CI report: * b10f5603fc55999adb8d5334a3d142d20322de5b : SUCCESS [Build](https://travis-ci.co

[GitHub] [flink] flinkbot edited a comment on issue #9783: [FLINK-14040][travis] Enable MiniCluster tests based on schedulerNG in Flink cron build

flinkbot edited a comment on issue #9783: [FLINK-14040][travis] Enable MiniCluster tests based on schedulerNG in Flink cron build URL: https://github.com/apache/flink/pull/9783#issuecomment-535844880 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] zhuzhurk commented on issue #9783: [FLINK-14040][travis] Enable MiniCluster tests based on schedulerNG in Flink cron build

zhuzhurk commented on issue #9783: [FLINK-14040][travis] Enable MiniCluster tests based on schedulerNG in Flink cron build URL: https://github.com/apache/flink/pull/9783#issuecomment-546212165 @zentol shall we merge this PR so that we can use it to verify the following scheduler changes?

[GitHub] [flink] flinkbot edited a comment on issue #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL

flinkbot edited a comment on issue #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL URL: https://github.com/apache/flink/pull/9952#issuecomment-544436896 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] danny0405 commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL

danny0405 commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL URL: https://github.com/apache/flink/pull/9952#discussion_r338894035 ## File path: flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser

[GitHub] [flink] flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#issuecomment-542593114 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbo

[GitHub] [flink] wuchong commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

wuchong commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#discussion_r338893966 ## File path: flink-table/flink-table-planner-blink/src/main/j

[GitHub] [flink] wuchong commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

wuchong commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#discussion_r338893966 ## File path: flink-table/flink-table-planner-blink/src/main/j

[GitHub] [flink] flinkbot edited a comment on issue #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions

flinkbot edited a comment on issue #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions URL: https://github.com/apache/flink/pull/9977#issuecomment-545444286 ## CI report: * 89d33a5aeefd6934261cc185c306c2e55b6c8ad2 : FAILURE [Build](https://

[GitHub] [flink] flinkbot edited a comment on issue #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL

flinkbot edited a comment on issue #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL URL: https://github.com/apache/flink/pull/9952#issuecomment-544436896 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] wuchong commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL

wuchong commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL URL: https://github.com/apache/flink/pull/9952#discussion_r338891673 ## File path: flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/d

[GitHub] [flink] flinkbot edited a comment on issue #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions

flinkbot edited a comment on issue #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions URL: https://github.com/apache/flink/pull/9977#issuecomment-545428245 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] flinkbot edited a comment on issue #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions

flinkbot edited a comment on issue #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions URL: https://github.com/apache/flink/pull/9977#issuecomment-545444286 ## CI report: * 89d33a5aeefd6934261cc185c306c2e55b6c8ad2 : FAILURE [Build](https://

[GitHub] [flink] flinkbot edited a comment on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering

flinkbot edited a comment on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering URL: https://github.com/apache/flink/pull/9853#issuecomment-539472188 ## CI report: * b10f5603fc55999adb8d5334a3d142d20322de5b : SUCCESS [Build](https://travis-ci.co

[GitHub] [flink] flinkbot edited a comment on issue #9992: [FLINK-14481][RunTime/Network]change Flink's port check to 0 to 65535

flinkbot edited a comment on issue #9992: [FLINK-14481][RunTime/Network]change Flink's port check to 0 to 65535 URL: https://github.com/apache/flink/pull/9992#issuecomment-546188093 ## CI report: * c63d8e2bc6d7bc16c46940a81857211d8788c1fe : SUCCESS [Build](https://travis-ci.com/

[jira] [Resolved] (FLINK-14519) Fail on invoking declineCheckpoint remotely

[ https://issues.apache.org/jira/browse/FLINK-14519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao resolved FLINK-14519. Resolution: Duplicate Sorry for not looking into FLINK-14076 carefully. This is already fixed. >

[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-545887333 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] wangyang0918 commented on a change in pull request #9986: [FLINK-10933][kubernetes] Implement KubernetesSessionClusterEntrypoint.

wangyang0918 commented on a change in pull request #9986: [FLINK-10933][kubernetes] Implement KubernetesSessionClusterEntrypoint. URL: https://github.com/apache/flink/pull/9986#discussion_r338886907 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/Kubernetes

[GitHub] [flink] flinkbot edited a comment on issue #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions

flinkbot edited a comment on issue #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions URL: https://github.com/apache/flink/pull/9977#issuecomment-545444286 ## CI report: * 89d33a5aeefd6934261cc185c306c2e55b6c8ad2 : FAILURE [Build](https://

[GitHub] [flink] flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#issuecomment-542593114 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbo

[GitHub] [flink] JingsongLi commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

JingsongLi commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#discussion_r338884634 ## File path: flink-table/flink-table-planner-blink/src/mai

[GitHub] [flink] flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#issuecomment-542617499 ## CI report: * f20e67a260971f17d77c7ecc7c55b04136e432c5 : SUCCESS [B

[GitHub] [flink] flinkbot edited a comment on issue #9894: [FLINK-14342][table][python] Remove method FunctionDefinition#getLanguage.

flinkbot edited a comment on issue #9894: [FLINK-14342][table][python] Remove method FunctionDefinition#getLanguage. URL: https://github.com/apache/flink/pull/9894#issuecomment-541559889 ## CI report: * 89595e0af27e0ae61f0fcd956ec422f203a3ab95 : CANCELED [Build](https://travis-c

[GitHub] [flink] flinkbot edited a comment on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering

flinkbot edited a comment on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering URL: https://github.com/apache/flink/pull/9853#issuecomment-539472188 ## CI report: * b10f5603fc55999adb8d5334a3d142d20322de5b : SUCCESS [Build](https://travis-ci.co

[GitHub] [flink] zhijiangW commented on a change in pull request #9854: [FLINK-14230][task] Change the endInput call of the downstream operator to after the upstream operator closes

zhijiangW commented on a change in pull request #9854: [FLINK-14230][task] Change the endInput call of the downstream operator to after the upstream operator closes URL: https://github.com/apache/flink/pull/9854#discussion_r338863841 ## File path: flink-streaming-java/src/test/jav

[jira] [Comment Edited] (FLINK-14520) Could not find a suitable table factory, but Factory is available

[ https://issues.apache.org/jira/browse/FLINK-14520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959425#comment-16959425 ] Jark Wu edited comment on FLINK-14520 at 10/25/19 4:37 AM: --- Hi

[GitHub] [flink] flinkbot edited a comment on issue #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL

flinkbot edited a comment on issue #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL URL: https://github.com/apache/flink/pull/9952#issuecomment-544436896 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] danny0405 commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL

danny0405 commented on a change in pull request #9952: [FLINK-14321][sql-parser] Support to parse watermark statement in SQL DDL URL: https://github.com/apache/flink/pull/9952#discussion_r338883419 ## File path: flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser

[jira] [Commented] (FLINK-14520) Could not find a suitable table factory, but Factory is available

[ https://issues.apache.org/jira/browse/FLINK-14520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959425#comment-16959425 ] Jark Wu commented on FLINK-14520: - Hi [~mserranom], {{CSV}} doesn't not work, {{OldCsv}}

[GitHub] [flink] flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#issuecomment-542593114 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbo

[GitHub] [flink] KurtYoung commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

KurtYoung commented on a change in pull request #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#discussion_r338883013 ## File path: flink-table/flink-table-planner-blink/src/main

[GitHub] [flink] flinkbot edited a comment on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering

flinkbot edited a comment on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering URL: https://github.com/apache/flink/pull/9853#issuecomment-539467530 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] ifndef-SleePy commented on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering

ifndef-SleePy commented on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering URL: https://github.com/apache/flink/pull/9853#issuecomment-546195770 Hi @pnowojski , thanks for reviewing! I have addressed the comments. Could you take a look? ---

[GitHub] [flink] flinkbot edited a comment on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering

flinkbot edited a comment on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering URL: https://github.com/apache/flink/pull/9853#issuecomment-539467530 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] ifndef-SleePy commented on a change in pull request #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering

ifndef-SleePy commented on a change in pull request #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering URL: https://github.com/apache/flink/pull/9853#discussion_r338881552 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/Chec

[GitHub] [flink] flinkbot edited a comment on issue #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions

flinkbot edited a comment on issue #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions URL: https://github.com/apache/flink/pull/9977#issuecomment-545444286 ## CI report: * 89d33a5aeefd6934261cc185c306c2e55b6c8ad2 : FAILURE [Build](https://

[GitHub] [flink] flinkbot edited a comment on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering

flinkbot edited a comment on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering URL: https://github.com/apache/flink/pull/9853#issuecomment-539467530 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Resolved] (FLINK-14408) In OldPlanner, UDF open method can not be invoke when SQL is optimized

[ https://issues.apache.org/jira/browse/FLINK-14408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-14408. - Resolution: Fixed 1.10.0: 12996bd8ef4f83f1c31df06a13aec6512c46999b > In OldPlanner, UDF open method can

[GitHub] [flink] ifndef-SleePy commented on a change in pull request #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering

ifndef-SleePy commented on a change in pull request #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering URL: https://github.com/apache/flink/pull/9853#discussion_r338879934 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/Chec

[GitHub] [flink] flinkbot edited a comment on issue #9916: [FLINK-14408][Table-Planner]UDF's open method is invoked to initialize when sql is optimized in oldPlanner

flinkbot edited a comment on issue #9916: [FLINK-14408][Table-Planner]UDF's open method is invoked to initialize when sql is optimized in oldPlanner URL: https://github.com/apache/flink/pull/9916#issuecomment-542755222 Thanks a lot for your contribution to the Apache Flink project. I'm the

[jira] [Updated] (FLINK-14408) In OldPlanner, UDF open method can not be invoke when SQL is optimized

[ https://issues.apache.org/jira/browse/FLINK-14408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14408: --- Labels: pull-request-available (was: ) > In OldPlanner, UDF open method can not be invoke w

[GitHub] [flink] wuchong closed pull request #9916: [FLINK-14408][Table-Planner]UDF's open method is invoked to initialize when sql is optimized in oldPlanner

wuchong closed pull request #9916: [FLINK-14408][Table-Planner]UDF's open method is invoked to initialize when sql is optimized in oldPlanner URL: https://github.com/apache/flink/pull/9916 This is an automated message from t

[jira] [Comment Edited] (FLINK-14511) Checking YARN queues should add "root" prefix

[ https://issues.apache.org/jira/browse/FLINK-14511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959404#comment-16959404 ] Zhanchun Zhang edited comment on FLINK-14511 at 10/25/19 4:09 AM:

[GitHub] [flink] flinkbot edited a comment on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering

flinkbot edited a comment on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering URL: https://github.com/apache/flink/pull/9853#issuecomment-539467530 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] flinkbot edited a comment on issue #9992: [FLINK-14481][RunTime/Network]change Flink's port check to 0 to 65535

flinkbot edited a comment on issue #9992: [FLINK-14481][RunTime/Network]change Flink's port check to 0 to 65535 URL: https://github.com/apache/flink/pull/9992#issuecomment-546188093 ## CI report: * c63d8e2bc6d7bc16c46940a81857211d8788c1fe : PENDING [Build](https://travis-ci.com/

[jira] [Commented] (FLINK-14511) Checking YARN queues should add "root" prefix

[ https://issues.apache.org/jira/browse/FLINK-14511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959404#comment-16959404 ] Zhanchun Zhang commented on FLINK-14511:  For fair scheduler, we can use `-yqu r

[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-545887333 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] thousandhu commented on a change in pull request #9986: [FLINK-10933][kubernetes] Implement KubernetesSessionClusterEntrypoint.

thousandhu commented on a change in pull request #9986: [FLINK-10933][kubernetes] Implement KubernetesSessionClusterEntrypoint. URL: https://github.com/apache/flink/pull/9986#discussion_r338878342 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesRe

[GitHub] [flink] flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#issuecomment-540450322 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] flinkbot edited a comment on issue #9894: [FLINK-14342][table][python] Remove method FunctionDefinition#getLanguage.

flinkbot edited a comment on issue #9894: [FLINK-14342][table][python] Remove method FunctionDefinition#getLanguage. URL: https://github.com/apache/flink/pull/9894#issuecomment-541555428 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] JingsongLi commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

JingsongLi commented on a change in pull request #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#discussion_r338878083 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/

[GitHub] [flink] hequn8128 commented on issue #9894: [FLINK-14342][table][python] Remove method FunctionDefinition#getLanguage.

hequn8128 commented on issue #9894: [FLINK-14342][table][python] Remove method FunctionDefinition#getLanguage. URL: https://github.com/apache/flink/pull/9894#issuecomment-546191130 Merging... Thank you all for your review and update.

[jira] [Commented] (FLINK-14519) Fail on invoking declineCheckpoint remotely

[ https://issues.apache.org/jira/browse/FLINK-14519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959402#comment-16959402 ] Jiayi Liao commented on FLINK-14519: The problem is a bit weird because {{DeclineChe

[GitHub] [flink] flinkbot edited a comment on issue #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions

flinkbot edited a comment on issue #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions URL: https://github.com/apache/flink/pull/9977#issuecomment-545428245 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] HuangXingBo commented on issue #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions

HuangXingBo commented on issue #9977: [FLINK-14497][python] Support primitive data types in Python user-defined functions URL: https://github.com/apache/flink/pull/9977#issuecomment-546190451 Thanks @hequn8128 @dianfu , I have addressed the comments at the latest push.

[GitHub] [flink] flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#issuecomment-542617499 ## CI report: * f20e67a260971f17d77c7ecc7c55b04136e432c5 : SUCCESS [B

[GitHub] [flink] flinkbot edited a comment on issue #9894: [FLINK-14342][table][python] Remove method FunctionDefinition#getLanguage.

flinkbot edited a comment on issue #9894: [FLINK-14342][table][python] Remove method FunctionDefinition#getLanguage. URL: https://github.com/apache/flink/pull/9894#issuecomment-541559889 ## CI report: * 89595e0af27e0ae61f0fcd956ec422f203a3ab95 : CANCELED [Build](https://travis-c

[jira] [Created] (FLINK-14526) Support Hive version 1.1.0 and 1.1.1

Rui Li created FLINK-14526: -- Summary: Support Hive version 1.1.0 and 1.1.1 Key: FLINK-14526 URL: https://issues.apache.org/jira/browse/FLINK-14526 Project: Flink Issue Type: Task Component

[GitHub] [flink] flinkbot edited a comment on issue #9783: [FLINK-14040][travis] Enable MiniCluster tests based on schedulerNG in Flink cron build

flinkbot edited a comment on issue #9783: [FLINK-14040][travis] Enable MiniCluster tests based on schedulerNG in Flink cron build URL: https://github.com/apache/flink/pull/9783#issuecomment-535848177 ## CI report: * 5d9e3113e10bbf0220b4f8e080ecd1cddd9c9059 : FAILURE [Build](http

[GitHub] [flink] flinkbot commented on issue #9992: [FLINK-14481][RunTime/Network]change Flink's port check to 0 to 65535

flinkbot commented on issue #9992: [FLINK-14481][RunTime/Network]change Flink's port check to 0 to 65535 URL: https://github.com/apache/flink/pull/9992#issuecomment-546188093 ## CI report: * c63d8e2bc6d7bc16c46940a81857211d8788c1fe : UNKNOWN Bot commands The @flin

[GitHub] [flink] flinkbot edited a comment on issue #9991: [FLINK-14478][python] optimize current python test cases to reduce test time.

flinkbot edited a comment on issue #9991: [FLINK-14478][python] optimize current python test cases to reduce test time. URL: https://github.com/apache/flink/pull/9991#issuecomment-546171997 ## CI report: * df840c57b1035c328f8067b821418cab151f5fe0 : SUCCESS [Build](https://travis

[GitHub] [flink] flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink

flinkbot edited a comment on issue #9909: [FLINK-14381][table] Partition field names should be got from CatalogTable instead of source/sink URL: https://github.com/apache/flink/pull/9909#issuecomment-542617499 ## CI report: * f20e67a260971f17d77c7ecc7c55b04136e432c5 : SUCCESS [B

[GitHub] [flink] flinkbot edited a comment on issue #9894: [FLINK-14342][table][python] Remove method FunctionDefinition#getLanguage.

flinkbot edited a comment on issue #9894: [FLINK-14342][table][python] Remove method FunctionDefinition#getLanguage. URL: https://github.com/apache/flink/pull/9894#issuecomment-541559889 ## CI report: * 89595e0af27e0ae61f0fcd956ec422f203a3ab95 : CANCELED [Build](https://travis-c

[GitHub] [flink] flinkbot edited a comment on issue #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter

flinkbot edited a comment on issue #9859: [FLINK-11405][rest]rest api can more exceptions by query parameter URL: https://github.com/apache/flink/pull/9859#issuecomment-539878774 ## CI report: * c8bf66050c865904c402bdc9c079a6e4de1a064c : FAILURE [Build](https://travis-ci.com/fli

[GitHub] [flink] flinkbot commented on issue #9992: [FLINK-14481][RunTime/Network]change Flink's port check to 0 to 65535

flinkbot commented on issue #9992: [FLINK-14481][RunTime/Network]change Flink's port check to 0 to 65535 URL: https://github.com/apache/flink/pull/9992#issuecomment-546183832 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revie

[GitHub] [flink] AT-Fieldless opened a new pull request #9992: change Flink's port check to 0 to 65535

AT-Fieldless opened a new pull request #9992: change Flink's port check to 0 to 65535 URL: https://github.com/apache/flink/pull/9992 ## What is the purpose of the change Current NettyConfig's port check is from 0 to 65536, and this pull request change it to 0 to 65535. ## Bri

[GitHub] [flink] flinkbot edited a comment on issue #9990: [FLINK-14524] [flink-jdbc] Correct syntax for PostgreSQL dialect "upsert" statement

flinkbot edited a comment on issue #9990: [FLINK-14524] [flink-jdbc] Correct syntax for PostgreSQL dialect "upsert" statement URL: https://github.com/apache/flink/pull/9990#issuecomment-546166887 ## CI report: * 56a7c678cf04569e01bf65807b8bb1ffbe7acdd0 : SUCCESS [Build](https://

[jira] [Commented] (FLINK-14525) buffer pool is destroyed

[ https://issues.apache.org/jira/browse/FLINK-14525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959386#comment-16959386 ] Jiayi Liao commented on FLINK-14525: I believe this is not the root cause. "Buffer p

[jira] [Created] (FLINK-14525) buffer pool is destroyed

Saqib created FLINK-14525: - Summary: buffer pool is destroyed Key: FLINK-14525 URL: https://issues.apache.org/jira/browse/FLINK-14525 Project: Flink Issue Type: Bug Components: Runtime / Ne

  1   2   3   4   5   6   7   8   >