[jira] [Updated] (FLINK-17495) Add support for custom variables

[ https://issues.apache.org/jira/browse/FLINK-17495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-17495: - Description: Allow users to configure additional labels, presumably via a new config opt

[GitHub] [flink] flinkbot commented on pull request #16064: Adding SharedObjects junit rule to ease test development.

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

[jira] [Assigned] (FLINK-22861) TIMESTAMPADD + timestamp_ltz type throws CodeGenException when comparing with timestamp type

[ https://issues.apache.org/jira/browse/FLINK-22861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-22861: Assignee: Leonard Xu > TIMESTAMPADD + timestamp_ltz type throws CodeGenException when com

[jira] [Updated] (FLINK-17495) Add support for custom variables

[ https://issues.apache.org/jira/browse/FLINK-17495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-17495: - Description: Allow users to configure additional labels, presumably via a new config opt

[jira] [Updated] (FLINK-17495) Add support for custom labels

[ https://issues.apache.org/jira/browse/FLINK-17495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-17495: - Description: Allow users to configure additional labels, presumably via a new configopti

[jira] [Commented] (FLINK-22861) TIMESTAMPADD + timestamp_ltz type throws CodeGenException when comparing with timestamp type

[ https://issues.apache.org/jira/browse/FLINK-22861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356234#comment-17356234 ] Leonard Xu commented on FLINK-22861: I'll take this one > TIMESTAMPADD + timestamp_

[jira] [Updated] (FLINK-17495) Add support for custom variables

[ https://issues.apache.org/jira/browse/FLINK-17495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-17495: - Summary: Add support for custom variables (was: Add support for custom labels) > Add s

[jira] [Updated] (FLINK-17495) Add support for custom labels

[ https://issues.apache.org/jira/browse/FLINK-17495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-17495: - Description:   Original description: {quote} We need to add some custom labels on Pro

[jira] [Resolved] (FLINK-22612) Restructure the coders in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-22612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo resolved FLINK-22612. -- Resolution: Done Merged into master via 9986e6f466bbd4a34a11bc79534574148e386fa8 > Restructur

[GitHub] [flink] AHeise opened a new pull request #16064: Adding SharedObjects junit rule to ease test development.

AHeise opened a new pull request #16064: URL: https://github.com/apache/flink/pull/16064 ## What is the purpose of the change Most test rely on static variables to sync between test code and UDFs to avoid serialization issues. However, static variables are error-prone and

[GitHub] [flink] HuangXingBo closed pull request #15877: [FLINK-22612][python] Restructure the coders in PyFlink

HuangXingBo closed pull request #15877: URL: https://github.com/apache/flink/pull/15877 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, pl

[jira] [Updated] (FLINK-17495) Add support for custom labels

[ https://issues.apache.org/jira/browse/FLINK-17495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-17495: - Summary: Add support for custom labels (was: Add custom labels on PrometheusReporter li

[jira] [Updated] (FLINK-17495) Add support for custom labels

[ https://issues.apache.org/jira/browse/FLINK-17495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-17495: - Description: Original description: We need to add some custom labels on Prometheus, so

[GitHub] [flink] flinkbot edited a comment on pull request #16058: [FLINK-22776][connector-jdbc] Delete casting to byte[] in AbstractJdbcRowConverter class

flinkbot edited a comment on pull request #16058: URL: https://github.com/apache/flink/pull/16058#issuecomment-853518758 ## CI report: * 903692cf8500b5cce131e34879c8a5bf2b71956a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16053: [FLINK-22847][sql-client] Quote options when using SET;

flinkbot edited a comment on pull request #16053: URL: https://github.com/apache/flink/pull/16053#issuecomment-852832662 ## CI report: * 3178b59ff95204010b870668116d2e576a54ebd8 UNKNOWN * 99ccc7ff43872137b212b9714ab866736044ca8f Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #16023: [FLINK-22698][connectors/rabbitmq] Add deliveryTimeout parameter to RabbitMQ source

flinkbot edited a comment on pull request #16023: URL: https://github.com/apache/flink/pull/16023#issuecomment-850460112 ## CI report: * 54b08d305558c8c6f646c099aaf5d40134bc0bbc Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-22858) avro-confluent doesn't support confluent schema registry that has security enabled

[ https://issues.apache.org/jira/browse/FLINK-22858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356231#comment-17356231 ] Fabian Paul commented on FLINK-22858: - [~xiaotao183] thanks for taking this once you

[jira] [Assigned] (FLINK-22858) avro-confluent doesn't support confluent schema registry that has security enabled

[ https://issues.apache.org/jira/browse/FLINK-22858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-22858: --- Assignee: TAO XIAO > avro-confluent doesn't support confluent schema registry that has secu

[GitHub] [flink] flinkbot commented on pull request #16063: [FLINK-22862][python] Support profiling in PyFlink

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

[jira] [Commented] (FLINK-22856) Move our Azure pipelines away from Ubuntu 16.04 by September

[ https://issues.apache.org/jira/browse/FLINK-22856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356220#comment-17356220 ] Chesnay Schepler commented on FLINK-22856: -- Probably {{python}} now defaults to

[jira] [Updated] (FLINK-22862) Support profiling in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-22862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22862: --- Labels: pull-request-available (was: ) > Support profiling in PyFlink > ---

[GitHub] [flink] HuangXingBo opened a new pull request #16063: [FLINK-22862][python] Support profiling in PyFlink

HuangXingBo opened a new pull request #16063: URL: https://github.com/apache/flink/pull/16063 ## What is the purpose of the change *This pull request will support profiling in PyFlink* ## Brief change log - *Support profiling in PyFlink* ## Verifying this ch

[jira] [Assigned] (FLINK-21127) Stores finished status for fully finished operators

[ https://issues.apache.org/jira/browse/FLINK-21127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-21127: Assignee: Yun Gao > Stores finished status for fully finished operators > ---

[GitHub] [flink] flinkbot edited a comment on pull request #16062: [FLINK-22854][docs-zh] Translate 'Apache Flink Documentation' index page to Chinese.

flinkbot edited a comment on pull request #16062: URL: https://github.com/apache/flink/pull/16062#issuecomment-853573551 ## CI report: * 3ea58ff61228a768bd49dde7d91c77752475c8f6 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16061: [FLINK-22855][docs-zh] Translate the 'Overview of Python API' page into Chinese.

flinkbot edited a comment on pull request #16061: URL: https://github.com/apache/flink/pull/16061#issuecomment-853573483 ## CI report: * 4075411aeeb5c59602864c346567dd2edab8a3b9 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16053: [FLINK-22847][sql-client] Quote options when using SET;

flinkbot edited a comment on pull request #16053: URL: https://github.com/apache/flink/pull/16053#issuecomment-852832662 ## CI report: * 3178b59ff95204010b870668116d2e576a54ebd8 UNKNOWN * 99ccc7ff43872137b212b9714ab866736044ca8f Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] RocMarshal closed pull request #16060: [FLINK-22860][table sql-client] Supplement 'HELP' command prompt message for SQL-Cli.

RocMarshal closed pull request #16060: URL: https://github.com/apache/flink/pull/16060 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, ple

[GitHub] [flink] flinkbot commented on pull request #16062: [FLINK-22854][docs-zh] Translate 'Apache Flink Documentation' index page to Chinese.

flinkbot commented on pull request #16062: URL: https://github.com/apache/flink/pull/16062#issuecomment-853573551 ## CI report: * 3ea58ff61228a768bd49dde7d91c77752475c8f6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #16061: [FLINK-22855][docs-zh] Translate the 'Overview of Python API' page into Chinese.

flinkbot commented on pull request #16061: URL: https://github.com/apache/flink/pull/16061#issuecomment-853573483 ## CI report: * 4075411aeeb5c59602864c346567dd2edab8a3b9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #16060: [FLINK-22860][table sql-client] Supplement 'HELP' command prompt message for SQL-Cli.

flinkbot edited a comment on pull request #16060: URL: https://github.com/apache/flink/pull/16060#issuecomment-853560762 ## CI report: * 80c08a6689b43938507efec107981c84e854c565 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * 4a48070d3bc0af24a19e01d7b091b2b82a3cdfd8 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #16060: [FLINK-22860][table sql-client] Supplement 'HELP' command prompt message for SQL-Cli.

flinkbot commented on pull request #16060: URL: https://github.com/apache/flink/pull/16060#issuecomment-853560762 ## CI report: * 80c08a6689b43938507efec107981c84e854c565 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #16059: [BP][FLINK-22795][sql-client] Throw better exception when executing remote SQL file in SQL Client

flinkbot edited a comment on pull request #16059: URL: https://github.com/apache/flink/pull/16059#issuecomment-853553208 ## CI report: * 6f19609017657b99af0a8f8f92460cb8c9b11ea8 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * ba002f5cc7465533a9700e1e08e8d27b72ca33df Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #15420: [WIP][FLINK-21356] Implement incremental checkpointing and recovery using state changelog

flinkbot edited a comment on pull request #15420: URL: https://github.com/apache/flink/pull/15420#issuecomment-809537263 ## CI report: * d316a110709f70377fbe74784227761bdebf9b65 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15317: [FLINK-20562][SQL-Client][Table-Api] Improvements,Support ExplainDetail…

flinkbot edited a comment on pull request #15317: URL: https://github.com/apache/flink/pull/15317#issuecomment-803958506 ## CI report: * 6b34ea34bb7720d8ef2ee8c98f6be11662a79ad1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@fli

[GitHub] [flink] flinkbot commented on pull request #16062: [FLINK-22854][docs-zh] Translate 'Apache Flink Documentation' index page to Chinese.

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

[jira] [Updated] (FLINK-22854) Translate 'Apache Flink Documentation' index page to Chinese

[ https://issues.apache.org/jira/browse/FLINK-22854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22854: --- Labels: pull-request-available (was: ) > Translate 'Apache Flink Documentation' index page

[GitHub] [flink] flinkbot commented on pull request #16061: [FLINK-22855][docs-zh] Translate the 'Overview of Python API' page into Chinese.

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

[GitHub] [flink] RocMarshal opened a new pull request #16062: [FLINK-22854][docs-zh] Translate 'Apache Flink Documentation' index page to Chinese.

RocMarshal opened a new pull request #16062: URL: https://github.com/apache/flink/pull/16062 ## What is the purpose of the change *Translate 'Apache Flink Documentation' index page to Chinese.* ## Brief change log *Translate 'Apache Flink Documentation' index

[jira] [Updated] (FLINK-22855) Translate the 'Overview of Python API' page into Chinese.

[ https://issues.apache.org/jira/browse/FLINK-22855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22855: --- Labels: pull-request-available (was: ) > Translate the 'Overview of Python API' page into C

[GitHub] [flink] RocMarshal opened a new pull request #16061: [FLINK-22855][docs-zh] Translate the 'Overview of Python API' page into Chinese.

RocMarshal opened a new pull request #16061: URL: https://github.com/apache/flink/pull/16061 ## What is the purpose of the change *Translate the 'Overview of Python API' page into Chinese.* ## Brief change log *Translate the 'Overview of Python API' page into

[GitHub] [flink] flinkbot commented on pull request #16060: [FLINK-22860][table sql-client] Supplement 'HELP' command prompt message for SQL-Cli.

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

[jira] [Updated] (FLINK-22860) Supplement 'HELP' command prompt message for SQL-Cli.

[ https://issues.apache.org/jira/browse/FLINK-22860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22860: --- Labels: pull-request-available (was: ) > Supplement 'HELP' command prompt message for SQL-C

[GitHub] [flink] RocMarshal opened a new pull request #16060: [FLINK-22860][table sql-client] Supplement 'HELP' command prompt message for SQL-Cli.

RocMarshal opened a new pull request #16060: URL: https://github.com/apache/flink/pull/16060 ## What is the purpose of the change *Supplement 'HELP' command prompt message for SQL-Cli.* ## Brief change log *Supplement 'HELP' command prompt message for SQL-Cli

[GitHub] [flink] fsk119 commented on a change in pull request #16056: [FLINK-13538][formats] Figure out wrong field name when serializer/deserializer throw exceptions while doing serializing/deserial

fsk119 commented on a change in pull request #16056: URL: https://github.com/apache/flink/pull/16056#discussion_r644469383 ## File path: flink-formats/flink-json/src/test/java/org/apache/flink/formats/json/JsonRowDeserializationSchemaTest.java ## @@ -316,7 +316,8 @@ private vo

[GitHub] [flink] flinkbot commented on pull request #16059: [BP][FLINK-22795][sql-client] Throw better exception when executing remote SQL file in SQL Client

flinkbot commented on pull request #16059: URL: https://github.com/apache/flink/pull/16059#issuecomment-853553208 ## CI report: * 6f19609017657b99af0a8f8f92460cb8c9b11ea8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #16056: [FLINK-13538][formats] Figure out wrong field name when serializer/deserializer throw exceptions while doing serializing/deserializi

flinkbot edited a comment on pull request #16056: URL: https://github.com/apache/flink/pull/16056#issuecomment-853074174 ## CI report: * 9ca7f82e1c0f1b0d2d1639c94ee5f9c8758ce899 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-22826) flink sql1.13.1 causes data loss based on change log stream data join

[ https://issues.apache.org/jira/browse/FLINK-22826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356153#comment-17356153 ] 徐州州 commented on FLINK-22826: -  I set the parallelism to 1, Data is still lost， My business

[GitHub] [flink] cuspymd commented on a change in pull request #16057: [FLINK-22851][security] Add basic authentication support to job dashboard and REST

cuspymd commented on a change in pull request #16057: URL: https://github.com/apache/flink/pull/16057#discussion_r644474450 ## File path: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServer.java ## @@ -174,6 +178,18 @@ public HistoryServer

[jira] [Commented] (FLINK-19592) MiniBatchGroupAggFunction should emit messages to prevent too early state eviction of downstream operators

[ https://issues.apache.org/jira/browse/FLINK-19592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356152#comment-17356152 ] Smile commented on FLINK-19592: --- [~libenchao] Could you please help review this PR? > Min

[jira] [Updated] (FLINK-22853) Flink SQL functions max/min/sum return duplicated records

[ https://issues.apache.org/jira/browse/FLINK-22853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-22853: --- Summary: Flink SQL functions max/min/sum return duplicated records (was: FLinkSql functions max/min

[jira] [Updated] (FLINK-22853) FLinkSql functions max/min/sum returns duplicated record

[ https://issues.apache.org/jira/browse/FLINK-22853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-22853: --- Summary: FLinkSql functions max/min/sum returns duplicated record (was: FLinkSql聚合函数max/min/sum返回结果

[jira] [Updated] (FLINK-22853) FLinkSql聚合函数max/min/sum返回结果重复

[ https://issues.apache.org/jira/browse/FLINK-22853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-22853: --- Priority: Major (was: Blocker) > FLinkSql聚合函数max/min/sum返回结果重复 > - > >

[jira] [Commented] (FLINK-22826) flink sql1.13.1 causes data loss based on change log stream data join

[ https://issues.apache.org/jira/browse/FLINK-22826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356151#comment-17356151 ] Jingsong Lee commented on FLINK-22826: -- What is orders table? And what is the erro

[jira] [Reopened] (FLINK-22826) flink sql1.13.1 causes data loss based on change log stream data join

[ https://issues.apache.org/jira/browse/FLINK-22826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reopened FLINK-22826: -- > flink sql1.13.1 causes data loss based on change log stream data join >

[jira] [Commented] (FLINK-20374) Wrong result when shuffling changelog stream on non-primary-key columns

[ https://issues.apache.org/jira/browse/FLINK-20374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356148#comment-17356148 ] Jingsong Lee commented on FLINK-20374: -- [~sansejin] We should discuss this in FLINK

[GitHub] [flink] akalash commented on pull request #15885: [FLINK-22376][runtime] RecoveredChannelStateHandler recycles the buffer if it was created inside and doesn't recycle if it was passed as para

akalash commented on pull request #15885: URL: https://github.com/apache/flink/pull/15885#issuecomment-853546071 @pnowojski, I didn't ignore it, I fixed it(it was problem with test which I broke earlier) -- This is an automated message from the Apache Git Service. To respond to the messa

[jira] [Commented] (FLINK-21686) Duplicate code in hive parser file should be abstracted into functions

[ https://issues.apache.org/jira/browse/FLINK-21686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356146#comment-17356146 ] luoyuxia commented on FLINK-21686: -- [~humengyu] Thanks for your contribution. As the ci

[GitHub] [flink] flinkbot edited a comment on pull request #16056: [FLINK-13538][formats] Figure out wrong field name when serializer/deserializer throw exceptions while doing serializing/deserializi

flinkbot edited a comment on pull request #16056: URL: https://github.com/apache/flink/pull/16056#issuecomment-853074174 ## CI report: * 9ca7f82e1c0f1b0d2d1639c94ee5f9c8758ce899 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #16059: [BP][FLINK-22795][sql-client] Throw better exception when executing remote SQL file in SQL Client

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

[GitHub] [flink] wuchong opened a new pull request #16059: [FLINK-22795][sql-client] Throw better exception when executing remote SQL file in SQL Client

wuchong opened a new pull request #16059: URL: https://github.com/apache/flink/pull/16059 This is a cherry-pick back to 1.13 branch. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[jira] [Created] (FLINK-22862) Support profiling in PyFlink

Huang Xingbo created FLINK-22862: Summary: Support profiling in PyFlink Key: FLINK-22862 URL: https://issues.apache.org/jira/browse/FLINK-22862 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-22795) Throw better exception when executing remote SQL file in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-22795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22795. --- Fix Version/s: (was: 1.13.2) Resolution: Fixed Fixed in - master: b9d60216435af9e0e3c5c0b3bfaa2c

[GitHub] [flink] wuchong merged pull request #16049: [FLINK-22795] Throw better exception when executing remote SQL file in SQL Client

wuchong merged pull request #16049: URL: https://github.com/apache/flink/pull/16049 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please

[GitHub] [flink] lirui-apache commented on a change in pull request #16037: [FLINK-22812][hive] Fix HiveConf, HiveMetaStoreClient and upgrade avr…

lirui-apache commented on a change in pull request #16037: URL: https://github.com/apache/flink/pull/16037#discussion_r644463624 ## File path: flink-connectors/flink-sql-connector-hive-3.1.2/pom.xml ## @@ -69,10 +69,56 @@ under the License. antlr-runtime

[jira] [Updated] (FLINK-22786) sql-client can not create .flink-sql-history file

[ https://issues.apache.org/jira/browse/FLINK-22786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22786: Fix Version/s: 1.13.2 > sql-client can not create .flink-sql-history file > --

[jira] [Comment Edited] (FLINK-22786) sql-client can not create .flink-sql-history file

[ https://issues.apache.org/jira/browse/FLINK-22786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356139#comment-17356139 ] Jark Wu edited comment on FLINK-22786 at 6/3/21, 3:48 AM: -- Fixe

[jira] [Closed] (FLINK-22786) sql-client can not create .flink-sql-history file

[ https://issues.apache.org/jira/browse/FLINK-22786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22786. --- Fix Version/s: 1.14.0 Assignee: Zhiwen Sun Resolution: Fixed Fixed in - master: bf56611cd1

[GitHub] [flink] wuchong merged pull request #16029: [FLINK-22786][sql-client] sql-client can not create .flink-sql-history file

wuchong merged pull request #16029: URL: https://github.com/apache/flink/pull/16029 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please

[GitHub] [flink] flinkbot edited a comment on pull request #15936: [FLINK-22683][runtime] Fix the null or incorrect value of total Flink…

flinkbot edited a comment on pull request #15936: URL: https://github.com/apache/flink/pull/15936#issuecomment-842214419 ## CI report: * 74bf5ad27325d9597b7fa3310343494b85002ade Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Issue Comment Deleted] (FLINK-20374) Wrong result when shuffling changelog stream on non-primary-key columns

[ https://issues.apache.org/jira/browse/FLINK-20374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 徐州州 updated FLINK-20374: Comment: was deleted (was: {code:java} select ord.Id, ord.Code, Status concat(cast(ord.Id as String),i

[jira] [Assigned] (FLINK-22776) Delete casting to byte[] in AbstractJdbcRowConverter class

[ https://issues.apache.org/jira/browse/FLINK-22776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22776: --- Assignee: Ada Wong > Delete casting to byte[] in AbstractJdbcRowConverter class > -

[jira] [Commented] (FLINK-20374) Wrong result when shuffling changelog stream on non-primary-key columns

[ https://issues.apache.org/jira/browse/FLINK-20374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356132#comment-17356132 ] 徐州州 commented on FLINK-20374: - {code:java} select ord.Id, ord.Code, Status conca

[jira] [Commented] (FLINK-22861) TIMESTAMPADD + timestamp_ltz type throws CodeGenException when comparing with timestamp type

[ https://issues.apache.org/jira/browse/FLINK-22861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356123#comment-17356123 ] Caizhi Weng commented on FLINK-22861: - I've also tried {code} @Test def myTest2():

[jira] [Commented] (FLINK-20374) Wrong result when shuffling changelog stream on non-primary-key columns

[ https://issues.apache.org/jira/browse/FLINK-20374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356124#comment-17356124 ] 徐州州 commented on FLINK-20374: - Very sure, Do a canal-json-based association, Probably my job

[GitHub] [flink] flinkbot edited a comment on pull request #16058: [FLINK-22776][connector-jdbc] Delete casting to byte[] in AbstractJdbcRowConverter class

flinkbot edited a comment on pull request #16058: URL: https://github.com/apache/flink/pull/16058#issuecomment-853518758 ## CI report: * 903692cf8500b5cce131e34879c8a5bf2b71956a Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-22662) YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint fail

[ https://issues.apache.org/jira/browse/FLINK-22662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356120#comment-17356120 ] Xintong Song commented on FLINK-22662: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-22776) Delete casting to byte[] in AbstractJdbcRowConverter class

[ https://issues.apache.org/jira/browse/FLINK-22776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356118#comment-17356118 ] Ada Wong commented on FLINK-22776: -- cc [~jark] please assign it to me. thanks. > Delet

[jira] [Reopened] (FLINK-22853) FLinkSql聚合函数max/min/sum返回结果重复

[ https://issues.apache.org/jira/browse/FLINK-22853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raypon Wang reopened FLINK-22853: - > FLinkSql聚合函数max/min/sum返回结果重复 > - > > Key: FLINK-22853

[jira] [Updated] (FLINK-22853) FLinkSql聚合函数max/min/sum返回结果重复

[ https://issues.apache.org/jira/browse/FLINK-22853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raypon Wang updated FLINK-22853: Description: mysql data： id    offset 1      1 1      3 1      2 flinksql code：(I used flink-

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356115#comment-17356115 ] Xintong Song commented on FLINK-20329: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-22068) FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356114#comment-17356114 ] Xintong Song commented on FLINK-22068: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-22735) HiveTableSourceITCase.testStreamPartitionReadByCreateTime failed because of times out

[ https://issues.apache.org/jira/browse/FLINK-22735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356112#comment-17356112 ] Xintong Song commented on FLINK-22735: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-22861) TIMESTAMPADD + timestamp_ltz type throws CodeGenException when comparing with timestamp type

[ https://issues.apache.org/jira/browse/FLINK-22861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-22861: Description: Add the following test case to {{org.apache.flink.table.planner.runtime.batch.sql.Ca

[jira] [Created] (FLINK-22861) TIMESTAMPADD + timestamp_ltz type throws CodeGenException when comparing with timestamp type

Caizhi Weng created FLINK-22861: --- Summary: TIMESTAMPADD + timestamp_ltz type throws CodeGenException when comparing with timestamp type Key: FLINK-22861 URL: https://issues.apache.org/jira/browse/FLINK-22861

[GitHub] [flink] flinkbot edited a comment on pull request #15936: [FLINK-22683][runtime] Fix the null or incorrect value of total Flink…

flinkbot edited a comment on pull request #15936: URL: https://github.com/apache/flink/pull/15936#issuecomment-842214419 ## CI report: * 74bf5ad27325d9597b7fa3310343494b85002ade Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-22853) FLinkSql聚合函数max/min/sum返回结果重复

[ https://issues.apache.org/jira/browse/FLINK-22853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356104#comment-17356104 ] JinxinTang commented on FLINK-22853: seems can not reproduce ~ {code:java} // code p

[GitHub] [flink] flinkbot commented on pull request #16058: [FLINK-22776][connector-jdbc] Delete casting to byte[] in AbstractJdbcRowConverter class

flinkbot commented on pull request #16058: URL: https://github.com/apache/flink/pull/16058#issuecomment-853518758 ## CI report: * 903692cf8500b5cce131e34879c8a5bf2b71956a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-20374) Wrong result when shuffling changelog stream on non-primary-key columns

[ https://issues.apache.org/jira/browse/FLINK-20374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356098#comment-17356098 ] Jingsong Lee commented on FLINK-20374: -- [~sansejin] Are you sure that the operator

[jira] [Commented] (FLINK-22806) The folder /checkpoint/shared state of FLINKSQL is getting bigger and bigger

[ https://issues.apache.org/jira/browse/FLINK-22806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356093#comment-17356093 ] Yun Tang commented on FLINK-22806: -- [~jark]， http://apache-flink.147419.n8.nabble.com/

[jira] [Closed] (FLINK-22853) FLinkSql聚合函数max/min/sum返回结果重复

[ https://issues.apache.org/jira/browse/FLINK-22853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22853. --- Resolution: Invalid Please use English in JIRA. > FLinkSql聚合函数max/min/sum返回结果重复 > -

[jira] [Assigned] (FLINK-22860) Supplement 'HELP' command prompt message for SQL-Cli.

[ https://issues.apache.org/jira/browse/FLINK-22860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22860: --- Assignee: Roc Marshal > Supplement 'HELP' command prompt message for SQL-Cli. > ---

[jira] [Commented] (FLINK-19015) java.lang.RuntimeException: Could not instantiate generated class 'GroupAggsHandler$15'

[ https://issues.apache.org/jira/browse/FLINK-19015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356087#comment-17356087 ] Jingsong Lee commented on FLINK-19015: -- [~twalthr] I re-produce the bug in latest m

[GitHub] [flink] flinkbot commented on pull request #16058: [FLINK-22776][connector-jdbc] Delete casting to byte[] in AbstractJdbcRowConverter class

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

[jira] [Updated] (FLINK-19896) Improve first-n-row fetching in the rank operator

[ https://issues.apache.org/jira/browse/FLINK-19896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-19896: - Fix Version/s: 1.14.0 > Improve first-n-row fetching in the rank operator >

[jira] [Closed] (FLINK-19896) Improve first-n-row fetching in the rank operator

[ https://issues.apache.org/jira/browse/FLINK-19896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-19896. Resolution: Fixed Implemented via master (1.14): 76a08c8214b5f777f7caa0dfffeb9d2e45470af3 > Impr

[GitHub] [flink] flinkbot edited a comment on pull request #15317: [FLINK-20562][SQL-Client][Table-Api] Improvements,Support ExplainDetail…

flinkbot edited a comment on pull request #15317: URL: https://github.com/apache/flink/pull/15317#issuecomment-803958506 ## CI report: * 6b34ea34bb7720d8ef2ee8c98f6be11662a79ad1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@fli

[GitHub] [flink] JingsongLi merged pull request #13921: [FLINK-19896][table-blink] Improve first-n-row fetching in the Rank o…

JingsongLi merged pull request #13921: URL: https://github.com/apache/flink/pull/13921 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, ple

[jira] [Commented] (FLINK-22860) Supplement 'HELP' command prompt message for SQL-Cli.

[ https://issues.apache.org/jira/browse/FLINK-22860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17356085#comment-17356085 ] Roc Marshal commented on FLINK-22860: - Could someone kindly assign this Jira to me ?

  1   2   3   4   5   >