[GitHub] [flink] AHeise commented on pull request #15156: [FLINK-21393] [formats] Implement ParquetAvroInputFormat

AHeise commented on pull request #15156: URL: https://github.com/apache/flink/pull/15156#issuecomment-851241530 Could you please check the compilation issue? It just looks like you need to rename/remove the test method. -- This is an automated message from the Apache Git Service. To resp

[GitHub] [flink-docker] AHeise commented on a change in pull request #83: Release 1.13.1

AHeise commented on a change in pull request #83: URL: https://github.com/apache/flink-docker/pull/83#discussion_r642251127 ## File path: testing/run_travis_tests.sh ## @@ -11,12 +11,9 @@ fi BRANCH="$TRAVIS_BRANCH" -test_docker_entrypoint - -./add-custom.sh -u "https://s3

[GitHub] [flink] AHeise commented on a change in pull request #16019: [FLINK-22686][checkpointing] Incompatible subtask mappings while resuming from unaligned checkpoints

AHeise commented on a change in pull request #16019: URL: https://github.com/apache/flink/pull/16019#discussion_r642248206 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/TaskStateAssignment.java ## @@ -166,32 +169,47 @@ public OperatorSubtaskStat

[jira] [Commented] (FLINK-22781) Incorrect result for group window aggregate when mini-batch is enabled

[ https://issues.apache.org/jira/browse/FLINK-22781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354243#comment-17354243 ] Andy commented on FLINK-22781: -- [~icshuo] Thanks for your reply. WindowAggregate support re

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

flinkbot commented on pull request #16028: URL: https://github.com/apache/flink/pull/16028#issuecomment-851232873 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] flinkbot commented on pull request #16027: [FLINK-22472][filesystem] close file of partition when partition is committable

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

[GitHub] [flink] flinkbot edited a comment on pull request #16020: [FLINK-21911][table-api] Add built-in greatest/least functions support #15821

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

[jira] [Updated] (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 ] ASF GitHub Bot updated FLINK-22795: --- Labels: pull-request-available (was: ) > Throw better exception when executing remote SQL f

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

JasonLeeCoding opened a new pull request #16028: URL: https://github.com/apache/flink/pull/16028 ## What is the purpose of the change *Throw better exception when executing remote SQL file in SQL Client* ## Brief change log *add checkArgs method in SqlClient.java

[GitHub] [flink] flinkbot edited a comment on pull request #14754: [FLINK-21127][runtime][checkpoint] Stores finished status for fully finished operators in checkpoint

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

[GitHub] [flink] flinkbot commented on pull request #16027: [FLINK-22472][filesystem] close file of partition when partition is committable

flinkbot commented on pull request #16027: URL: https://github.com/apache/flink/pull/16027#issuecomment-851227315 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-22472) The real partition data produced time is behind meta(_SUCCESS) file produced

[ https://issues.apache.org/jira/browse/FLINK-22472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22472: --- Labels: pull-request-available (was: ) > The real partition data produced time is behind me

[GitHub] [flink] luoyuxia opened a new pull request #16027: [FLINK-22472][filesystem] close file of partition when partition is committable

luoyuxia opened a new pull request #16027: URL: https://github.com/apache/flink/pull/16027 ## What is the purpose of the change *This pull request is to fix the issue that although partition has committed, the file in this partition is still unready * ## Brief

[jira] [Assigned] (FLINK-22689) Table API Documentation Row-Based Operations Example Fails

[ https://issues.apache.org/jira/browse/FLINK-22689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22689: --- Assignee: Yao Zhang > Table API Documentation Row-Based Operations Example Fails >

[jira] [Updated] (FLINK-22689) Table API Documentation Row-Based Operations Example Fails

[ https://issues.apache.org/jira/browse/FLINK-22689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22689: Component/s: (was: Table SQL / Ecosystem) Table SQL / API > Table API Documentation R

[jira] [Updated] (FLINK-22788) Code of equals method grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-22788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maciej Bryński updated FLINK-22788: --- Description: I'm getting following exception when running SQL with many (more than 500) col

[jira] [Updated] (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:all-tabpanel ] YUJIANBO updated FLINK-22806: - Description: I have added the parameter ： 1、tableEnv.getConfig().setIdleStateRetention: 3600 (one h

[jira] [Updated] (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:all-tabpanel ] YUJIANBO updated FLINK-22806: - Description: I have added the parameter ： 1、tableEnv.getConfig().setIdleStateRetention: 3600 (one h

[GitHub] [flink] flinkbot edited a comment on pull request #16026: Fix flink 22472

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

[jira] [Assigned] (FLINK-22272) Some scenes can't drop table by hive catalog

[ https://issues.apache.org/jira/browse/FLINK-22272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-22272: -- Assignee: wangzeyu > Some scenes can't drop table by hive catalog > -

[jira] [Commented] (FLINK-22272) Some scenes can't drop table by hive catalog

[ https://issues.apache.org/jira/browse/FLINK-22272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354224#comment-17354224 ] Rui Li commented on FLINK-22272: [~wangzeyu] Sure, assigning this to you > Some scenes

[GitHub] [flink] flinkbot commented on pull request #16026: Fix flink 22472

flinkbot commented on pull request #16026: URL: https://github.com/apache/flink/pull/16026#issuecomment-851179728 ## CI report: * 1e3d273ad37eff4e22345727b4fd771e2e53e51a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #16025: [FLINK-22714][table-planner-blink] Simplify window TVF to a simple window assigner if successor node is WindowRank or WindowJoin.

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

[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: * 14571a942bd83fcae56460740da2b297f5f0559e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #16025: [FLINK-22714][table-planner-blink] Simplify window TVF to a simple window assigner if successor node is WindowRank or WindowJoin.

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

[GitHub] [flink] flinkbot commented on pull request #16026: Fix flink 22472

flinkbot commented on pull request #16026: URL: https://github.com/apache/flink/pull/16026#issuecomment-851162988 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] luoyuxia opened a new pull request #16026: Fix flink 22472

luoyuxia opened a new pull request #16026: URL: https://github.com/apache/flink/pull/16026 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them o

[jira] [Commented] (FLINK-21607) Twitter table source connector

[ https://issues.apache.org/jira/browse/FLINK-21607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354207#comment-17354207 ] luoyuxia commented on FLINK-21607: -- I am interested in it, I would like to have a try.

[GitHub] [flink] flinkbot commented on pull request #16025: [FLINK-22714][table-planner-blink] Simplify window TVF to a simple window assigner if successor node is WindowRank or WindowJoin.

flinkbot commented on pull request #16025: URL: https://github.com/apache/flink/pull/16025#issuecomment-851157647 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-22714) Simplify `StreamPhysicalWindowTableFunction` to a simple window assigner if successor node with `WindowAttachedWindowingStrategy` in planner

[ https://issues.apache.org/jira/browse/FLINK-22714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22714: --- Labels: pull-request-available (was: ) > Simplify `StreamPhysicalWindowTableFunction` to a

[GitHub] [flink] beyond1920 opened a new pull request #16025: [FLINK-22714][table-planner-blink] Simplify window TVF to a simple window assigner if successor node is WindowRank or WindowJoin.

beyond1920 opened a new pull request #16025: URL: https://github.com/apache/flink/pull/16025 ## What is the purpose of the change In theory, `StreamPhysicalWindowTableFunction` should works as a window assigner and emits at ends of window. However, `StreamPhysicalWindowTableFunction

[jira] [Commented] (FLINK-22805) Dynamic configuration of Flink checkpoint interval

[ https://issues.apache.org/jira/browse/FLINK-22805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354205#comment-17354205 ] Andy commented on FLINK-22805: -- [~okowr] , thanks for describe the requirement.  I paste t

[jira] [Updated] (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:all-tabpanel ] YUJIANBO updated FLINK-22806: - Summary: The folder /checkpoint/shared state of FLINKSQL is getting bigger and bigger (was: The checkp

[jira] [Updated] (FLINK-22806) The checkpoint state of FLINKSQL is getting bigger and bigger

[ https://issues.apache.org/jira/browse/FLINK-22806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-22806: - Description: I have added the parameter ： 1、tableEnv.getConfig().setIdleStateRetention: 3600 (one h

[jira] [Commented] (FLINK-22272) Some scenes can't drop table by hive catalog

[ https://issues.apache.org/jira/browse/FLINK-22272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354199#comment-17354199 ] wangzeyu commented on FLINK-22272: -- Hi [Rui Li|https://issues.apache.org/jira/secure/Vi

[jira] [Updated] (FLINK-22806) The checkpoint state of FLINKSQL is getting bigger and bigger

[ https://issues.apache.org/jira/browse/FLINK-22806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-22806: - Description: I have added the parameter ： 1、tableEnv.getConfig().setIdleStateRetention: 3600 (one hou

[jira] [Commented] (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=17354198#comment-17354198 ] Zhiwen Sun commented on FLINK-22786: OK. > sql-client can not create .flink-sql-his

[jira] [Comment Edited] (FLINK-22806) The checkpoint 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=17354196#comment-17354196 ] YUJIANBO edited comment on FLINK-22806 at 5/31/21, 3:30 AM:

[jira] [Commented] (FLINK-22806) The checkpoint 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=17354196#comment-17354196 ] YUJIANBO commented on FLINK-22806: -- Hi [~lirui] Can you give me some advice？ > The ch

[jira] [Comment Edited] (FLINK-22799) Missing documentation: No state backwards compatibility is not support for Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-22799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354194#comment-17354194 ] Yun Tang edited comment on FLINK-22799 at 5/31/21, 3:26 AM:

[jira] [Updated] (FLINK-22806) The checkpoint state of FLINKSQL is getting bigger and bigger

[ https://issues.apache.org/jira/browse/FLINK-22806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YUJIANBO updated FLINK-22806: - Description: I have added the parameter ： 1、state.idle.duration: 3600, 2、state.checkpoints.num-r

[jira] [Created] (FLINK-22806) The checkpoint state of FLINKSQL is getting bigger and bigger

YUJIANBO created FLINK-22806: Summary: The checkpoint state of FLINKSQL is getting bigger and bigger Key: FLINK-22806 URL: https://issues.apache.org/jira/browse/FLINK-22806 Project: Flink Issue

[jira] [Commented] (FLINK-22799) Missing documentation: No state backwards compatibility is not support for Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-22799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354194#comment-17354194 ] Yun Tang commented on FLINK-22799: -- +1 for this. > Missing documentation: No state bac

[jira] [Commented] (FLINK-22272) Some scenes can't drop table by hive catalog

[ https://issues.apache.org/jira/browse/FLINK-22272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354192#comment-17354192 ] Rui Li commented on FLINK-22272: Hi [~wangzeyu], could you explain what's the benefit to

[jira] [Commented] (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=17354190#comment-17354190 ] Jark Wu commented on FLINK-22786: - Please only fix SQL Client. I'm not sure if other pla

[GitHub] [flink] flinkbot edited a comment on pull request #16020: [FLINK-21911][table-api] Add built-in greatest/least functions support #15821

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

[jira] [Commented] (FLINK-22805) Dynamic configuration of Flink checkpoint interval

[ https://issues.apache.org/jira/browse/FLINK-22805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354188#comment-17354188 ] Jiayi Liao commented on FLINK-22805: This is a good point. But I think the root prob

[GitHub] [flink] flinkbot edited a comment on pull request #15877: [FLINK-22612][python] Restructure the coders in PyFlink

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

[jira] [Resolved] (FLINK-22759) Correct the applicability of RocksDB related options as per operator

[ https://issues.apache.org/jira/browse/FLINK-22759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-22759. -- Resolution: Fixed > Correct the applicability of RocksDB related options as per operator > ---

[jira] [Commented] (FLINK-22759) Correct the applicability of RocksDB related options as per operator

[ https://issues.apache.org/jira/browse/FLINK-22759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354187#comment-17354187 ] Yun Tang commented on FLINK-22759: -- Merged master: c0d216b606e9ba3d6e82a7e79abc97c8878e

[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=17354186#comment-17354186 ] Zhiwen Sun edited comment on FLINK-22786 at 5/31/21, 2:50 AM:

[jira] [Commented] (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=17354186#comment-17354186 ] Zhiwen Sun commented on FLINK-22786: Yes, I will create a PR about this bug. Simila

[jira] [Assigned] (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 reassigned FLINK-19896: Assignee: Jun Zhang > Improve first-n-row fetching in the rank operator > ---

[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: - Priority: Major (was: Minor) > Improve first-n-row fetching in the rank operator >

[GitHub] [flink] Myasuka merged pull request #15992: [FLINK-22759][docs] Correct the applicability of some RocksDB related options as per operator

Myasuka merged pull request #15992: URL: https://github.com/apache/flink/pull/15992 -- 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] Myasuka commented on pull request #15992: [FLINK-22759][docs] Correct the applicability of some RocksDB related options as per operator

Myasuka commented on pull request #15992: URL: https://github.com/apache/flink/pull/15992#issuecomment-851128675 Sure, this PR would be back ported to Flink-1.13. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

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

JingsongLi commented on a change in pull request #13921: URL: https://github.com/apache/flink/pull/13921#discussion_r642178367 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecRank.java ## @@ -207

[jira] [Commented] (FLINK-22370) ParquetColumnarRowSplitReader#reachedEnd() returns false after it returns true

[ https://issues.apache.org/jira/browse/FLINK-22370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354183#comment-17354183 ] Rui Li commented on FLINK-22370: Is this reemergence of FLINK-19470, or was that fix inc

[GitHub] [flink] SteNicholas commented on a change in pull request #16023: [FLINK-22698][connectors/rabbitmq] Add deliveryTimeout parameter to RabbitMQ source

SteNicholas commented on a change in pull request #16023: URL: https://github.com/apache/flink/pull/16023#discussion_r642176451 ## File path: flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/common/RMQConnectionConfig.java

[jira] [Created] (FLINK-22805) Dynamic configuration of Flink checkpoint interval

Fu Kai created FLINK-22805: -- Summary: Dynamic configuration of Flink checkpoint interval Key: FLINK-22805 URL: https://issues.apache.org/jira/browse/FLINK-22805 Project: Flink Issue Type: New Featur

[GitHub] [flink] SteNicholas commented on a change in pull request #16023: [FLINK-22698][connectors/rabbitmq] Add deliveryTimeout parameter to RabbitMQ source

SteNicholas commented on a change in pull request #16023: URL: https://github.com/apache/flink/pull/16023#discussion_r642175971 ## File path: flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/common/RMQConnectionConfig.java

[GitHub] [flink] SteNicholas commented on a change in pull request #16023: [FLINK-22698][connectors/rabbitmq] Add deliveryTimeout parameter to RabbitMQ source

SteNicholas commented on a change in pull request #16023: URL: https://github.com/apache/flink/pull/16023#discussion_r642175647 ## File path: flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/common/RMQConnectionConfig.java

[GitHub] [flink] flinkbot edited a comment on pull request #16020: [FLINK-21911][table-api] Add built-in greatest/least functions support #15821

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

[GitHub] [flink] flinkbot edited a comment on pull request #15877: [FLINK-22612][python] Restructure the coders in PyFlink

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

[jira] [Updated] (FLINK-21184) Support temporary table/function for hive connector

[ https://issues.apache.org/jira/browse/FLINK-21184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-21184: --- Priority: Major (was: Minor) > Support temporary table/function for hive connector > --

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17354179#comment-17354179 ] Shengkai Fang commented on FLINK-22795: --- [~JasonLee] You can just submit a code pa

[jira] [Commented] (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=17354178#comment-17354178 ] Shengkai Fang commented on FLINK-22786: --- [~pensz] Are you still willing to contrib

[jira] [Commented] (FLINK-22804) "CREATE VIEW" statement loses computed columns, metadata columns, watermark and table constraint

[ https://issues.apache.org/jira/browse/FLINK-22804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17354176#comment-17354176 ] Jark Wu commented on FLINK-22804: - Hi [~yulei0824], I'm afraid view doesn't support this

[jira] [Updated] (FLINK-20617) Kafka Consumer Deserializer Exception on application mode

[ https://issues.apache.org/jira/browse/FLINK-20617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20617: --- Labels: auto-deprioritized-critical stale-major (was: auto-deprioritized-critical) I am th

[jira] [Updated] (FLINK-20484) Improve hive temporal table exception

[ https://issues.apache.org/jira/browse/FLINK-20484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20484: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira Bot|https:/

[jira] [Updated] (FLINK-19881) Optimize temporal join with upsert-Source(upsert-kafka)

[ https://issues.apache.org/jira/browse/FLINK-19881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19881: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major) Thi

[jira] [Updated] (FLINK-20375) Support to control operator name in SQL

[ https://issues.apache.org/jira/browse/FLINK-20375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20375: --- Labels: auto-deprioritized-major stale-major (was: auto-deprioritized-major) I am the [Fli

[jira] [Updated] (FLINK-20012) Hive 3.1 integration exception

[ https://issues.apache.org/jira/browse/FLINK-20012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20012: --- Labels: auto-deprioritized-critical stale-major (was: auto-deprioritized-critical) I am th

[jira] [Updated] (FLINK-21120) Add support for ignore abnormal watermark

[ https://issues.apache.org/jira/browse/FLINK-21120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21120: --- Labels: auto-deprioritized-critical stale-major (was: auto-deprioritized-critical) I am th

[jira] [Updated] (FLINK-20215) Keep the "Access the Flink UI " document same in “Kubernetes Setup” and "Native Kubernetes Setup Beta"

[ https://issues.apache.org/jira/browse/FLINK-20215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20215: --- Labels: auto-deprioritized-critical stale-major (was: auto-deprioritized-critical) I am th

[jira] [Updated] (FLINK-20203) Could not find any document about how to build a Flink image from local build.

[ https://issues.apache.org/jira/browse/FLINK-20203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20203: --- Labels: auto-deprioritized-critical stale-major (was: auto-deprioritized-critical) I am th

[jira] [Updated] (FLINK-21637) Wrong results when filtering by timestamp type

[ https://issues.apache.org/jira/browse/FLINK-21637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21637: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira Bot|https:/

[jira] [Updated] (FLINK-19957) flink-sql-connector-hive incompatible with cdh6

[ https://issues.apache.org/jira/browse/FLINK-19957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19957: --- Labels: auto-deprioritized-critical stale-major (was: auto-deprioritized-critical) I am th

[jira] [Updated] (FLINK-21125) Sum or Sum0 overflow quietly

[ https://issues.apache.org/jira/browse/FLINK-21125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21125: --- Labels: stale-major (was: ) I am the [Flink Jira Bot|https://github.com/apache/flink-jira-b

[jira] [Updated] (FLINK-21726) Fix checkpoint stuck

[ https://issues.apache.org/jira/browse/FLINK-21726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21726: --- Labels: auto-deprioritized-critical stale-major (was: auto-deprioritized-critical) I am th

[jira] [Updated] (FLINK-20461) YARNFileReplicationITCase.testPerJobModeWithDefaultFileReplication

[ https://issues.apache.org/jira/browse/FLINK-20461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20461: --- Labels: auto-unassigned stale-major testability (was: auto-unassigned testability) I am th

[jira] [Updated] (FLINK-21278) NullpointExecption error is reported when using the evictor method to filter the data before the window calculation

[ https://issues.apache.org/jira/browse/FLINK-21278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21278: --- Labels: auto-deprioritized-critical pull-request-available stale-major (was: auto-depriorit

[jira] [Updated] (FLINK-21307) Revisit activation model of FlinkSecurityManager

[ https://issues.apache.org/jira/browse/FLINK-21307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21307: --- Labels: auto-deprioritized-critical stale-major (was: auto-deprioritized-critical) I am th

[jira] [Updated] (FLINK-22497) When using DefaultRollingPolicy in StreamingFileSink, the file will be finished delayed

[ https://issues.apache.org/jira/browse/FLINK-22497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22497: --- Labels: stale-major (was: ) I am the [Flink Jira Bot|https://github.com/apache/flink-jira-b

[jira] [Updated] (FLINK-22271) FlinkSQL Read Hive(parquet file) field does not exist

[ https://issues.apache.org/jira/browse/FLINK-22271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22271: --- Labels: stale-major (was: ) I am the [Flink Jira Bot|https://github.com/apache/flink-jira-b

[jira] [Updated] (FLINK-19168) Upgrade Kafka client version beyond 2.5.0

[ https://issues.apache.org/jira/browse/FLINK-19168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19168: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major) Thi

[jira] [Updated] (FLINK-22477) Remove DefaultSlotPoolServiceFactory and SlotPoolImpl

[ https://issues.apache.org/jira/browse/FLINK-22477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22477: --- Labels: stale-assigned (was: ) I am the [Flink Jira Bot|https://github.com/apache/flink-jir

[jira] [Updated] (FLINK-21283) Support sql extension for flink sql

[ https://issues.apache.org/jira/browse/FLINK-21283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21283: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major) Thi

[jira] [Updated] (FLINK-21350) ParquetInputFormat incorrectly interprets timestamps encoded in microseconds as timestamps encoded in milliseconds

[ https://issues.apache.org/jira/browse/FLINK-21350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21350: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major) Thi

[jira] [Updated] (FLINK-19363) Code of split method grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-19363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19363: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major) Thi

[jira] [Updated] (FLINK-19103) The PushPartitionIntoTableSourceScanRule will lead a performance problem when there are still many partitions after pruning

[ https://issues.apache.org/jira/browse/FLINK-19103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19103: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major) Thi

[jira] [Updated] (FLINK-22410) "Resuming Savepoint (rocks, scale up, heap timers)" fails with BindException

[ https://issues.apache.org/jira/browse/FLINK-22410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22410: --- Labels: auto-deprioritized-major test-stability (was: stale-major test-stability) Pri

[jira] [Updated] (FLINK-22110) KinesisTableApiITCase.testTableApiSourceAndSink fails/hangs on Azure when building FlinkContainer

[ https://issues.apache.org/jira/browse/FLINK-22110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22110: --- Labels: auto-deprioritized-major test-stability (was: stale-major test-stability) Pri

[jira] [Updated] (FLINK-22412) SplitAggregateRule support optimization of aggregate function reuse

[ https://issues.apache.org/jira/browse/FLINK-22412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22412: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major) Thi

[jira] [Closed] (FLINK-2148) Approximately calculate the number of distinct elements of a stream

[ https://issues.apache.org/jira/browse/FLINK-2148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot closed FLINK-2148. - Resolution: Auto Closed This issue was labeled "stale-minor" 7 ago and has not received any updat

[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: * 369ff23ce7d8246c35f498a4308588e48b8cfd0c Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * 369ff23ce7d8246c35f498a4308588e48b8cfd0c Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * 369ff23ce7d8246c35f498a4308588e48b8cfd0c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] cmick commented on a change in pull request #16023: [FLINK-22698][connectors/rabbitmq] Add deliveryTimeout parameter to RabbitMQ source

cmick commented on a change in pull request #16023: URL: https://github.com/apache/flink/pull/16023#discussion_r642131205 ## File path: flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java ## @@ -322,14 +323,28 @

[GitHub] [flink] cmick commented on pull request #16023: [FLINK-22698][connectors/rabbitmq] Add deliveryTimeout parameter to RabbitMQ source

cmick commented on pull request #16023: URL: https://github.com/apache/flink/pull/16023#issuecomment-851063717 @flinkbot run azure -- 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 co

  1   2   >