[GitHub] [flink] flinkbot commented on pull request #18384: [FLINK-22643][network] Reuse tpc connections between taskmanagers

2022-01-17 Thread GitBox
flinkbot commented on pull request #18384: URL: https://github.com/apache/flink/pull/18384#issuecomment-1015050232 ## CI report: * 3cbd0a1b5e27a8699edb9f7bb33e44f4aa1ab72d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17814: [FLINK-24899][runtime] Enable data compression for blocking shuffle by default

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #17814: URL: https://github.com/apache/flink/pull/17814#issuecomment-971129699 ## CI report: * 5a2cf6c1387dcc0822a56dcff10ed683a1476f0a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #17503: URL: https://github.com/apache/flink/pull/17503#issuecomment-945138587 ## CI report: * 4d30cc1db8de1a547c0908f6a634c647a6f4f69a Azure:

[GitHub] [flink] 1996fanrui opened a new pull request #18384: [FLINK-22643][network] Reuse tpc connections between taskmanagers

2022-01-17 Thread GitBox
1996fanrui opened a new pull request #18384: URL: https://github.com/apache/flink/pull/18384 ## What is the purpose of the change Reuse tpc connections between taskmanagers ## Brief change log Reuse tpc connections between taskmanagers. ## Verifying this change

[GitHub] [flink] flinkbot edited a comment on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #17503: URL: https://github.com/apache/flink/pull/17503#issuecomment-945138587 ## CI report: * 4d30cc1db8de1a547c0908f6a634c647a6f4f69a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18157: URL: https://github.com/apache/flink/pull/18157#issuecomment-998436589 ## CI report: * a9175f7c992d1cb30579dc88d4406c228e06a67a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #17503: URL: https://github.com/apache/flink/pull/17503#issuecomment-945138587 ## CI report: * 4d30cc1db8de1a547c0908f6a634c647a6f4f69a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18157: URL: https://github.com/apache/flink/pull/18157#issuecomment-998436589 ## CI report: * a9175f7c992d1cb30579dc88d4406c228e06a67a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #17503: URL: https://github.com/apache/flink/pull/17503#issuecomment-945138587 ## CI report: * 4d30cc1db8de1a547c0908f6a634c647a6f4f69a Azure:

[GitHub] [flink] zuston commented on pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

2022-01-17 Thread GitBox
zuston commented on pull request #18157: URL: https://github.com/apache/flink/pull/18157#issuecomment-1015046371 @Myasuka @gaoyunhaii Thanks again. I have uploaded latest commit and please let me know what you think. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] zuston commented on a change in pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

2022-01-17 Thread GitBox
zuston commented on a change in pull request #18157: URL: https://github.com/apache/flink/pull/18157#discussion_r786396516 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointMetadataOutputStream.java ## @@ -162,4 +164,97 @@ public

[GitHub] [flink] wangyang0918 commented on a change in pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

2022-01-17 Thread GitBox
wangyang0918 commented on a change in pull request #18119: URL: https://github.com/apache/flink/pull/18119#discussion_r786396085 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterDescriptor.java ## @@ -240,20 +238,11 @@ private String

[GitHub] [flink] flinkbot edited a comment on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #17503: URL: https://github.com/apache/flink/pull/17503#issuecomment-945138587 ## CI report: * 4d30cc1db8de1a547c0908f6a634c647a6f4f69a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #17503: URL: https://github.com/apache/flink/pull/17503#issuecomment-945138587 ## CI report: * 4d30cc1db8de1a547c0908f6a634c647a6f4f69a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #17503: URL: https://github.com/apache/flink/pull/17503#issuecomment-945138587 ## CI report: * 4d30cc1db8de1a547c0908f6a634c647a6f4f69a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #17503: URL: https://github.com/apache/flink/pull/17503#issuecomment-945138587 ## CI report: * 4d30cc1db8de1a547c0908f6a634c647a6f4f69a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #17503: URL: https://github.com/apache/flink/pull/17503#issuecomment-945138587 ## CI report: * 4d30cc1db8de1a547c0908f6a634c647a6f4f69a Azure:

[jira] [Updated] (FLINK-24334) Configuration kubernetes.flink.log.dir not working

2022-01-17 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-24334: -- Description: After FLINK-21128, {{kubernetes.flink.log.dir}} could not take effect. (was: After

[jira] [Commented] (FLINK-21319) hadoop-mapreduce jars are not loaded into classpath when submiting flink on yarn jobs.

2022-01-17 Thread Shengnan YU (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477541#comment-17477541 ] Shengnan YU commented on FLINK-21319: - I got this problem when I use flink with hudi. I found

[GitHub] [flink] wangyang0918 commented on a change in pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

2022-01-17 Thread GitBox
wangyang0918 commented on a change in pull request #17503: URL: https://github.com/apache/flink/pull/17503#discussion_r786384894 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/parameters/KubernetesJobManagerParameters.java ## @@ -96,6

[GitHub] [flink] 1996fanrui commented on pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

2022-01-17 Thread GitBox
1996fanrui commented on pull request #18365: URL: https://github.com/apache/flink/pull/18365#issuecomment-1015030623 @pnowojski It seems the test failure isn't related with this PR. There is a table ci failure and previous ci is ok. I try to run azure again.

[GitHub] [flink] wsry closed pull request #18364: [FLINK-25654][network] Remove the redundant locks in SortMergeResultPartition

2022-01-17 Thread GitBox
wsry closed pull request #18364: URL: https://github.com/apache/flink/pull/18364 -- 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. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-25070) FLIP-195: Improve the name and structure of vertex and operator name for job

2022-01-17 Thread Wenlong Lyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477534#comment-17477534 ] Wenlong Lyu commented on FLINK-25070: - [~MartijnVisser] users cannot control operator name, but they

[GitHub] [flink] flinkbot edited a comment on pull request #17814: [FLINK-24899][runtime] Enable data compression for blocking shuffle by default

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #17814: URL: https://github.com/apache/flink/pull/17814#issuecomment-971129699 ## CI report: * 5a2cf6c1387dcc0822a56dcff10ed683a1476f0a Azure:

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

2022-01-17 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252560#comment-17252560 ] Ada Wong edited comment on FLINK-20375 at 1/18/22, 2:44 AM: My temporary fix

[GitHub] [flink] flinkbot edited a comment on pull request #17814: [FLINK-24899][runtime] Enable data compression for blocking shuffle by default

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #17814: URL: https://github.com/apache/flink/pull/17814#issuecomment-971129699 ## CI report: * 5a2cf6c1387dcc0822a56dcff10ed683a1476f0a Azure:

[GitHub] [flink] SteNicholas removed a comment on pull request #17814: [FLINK-24899][runtime] Enable data compression for blocking shuffle by default

2022-01-17 Thread GitBox
SteNicholas removed a comment on pull request #17814: URL: https://github.com/apache/flink/pull/17814#issuecomment-1015015059 @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

[jira] [Commented] (FLINK-25560) Add "sink.delete.mode" in HBase sql connector for retracting the latest version or all versions in changelog mode

2022-01-17 Thread Bruce Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477531#comment-17477531 ] Bruce Wong commented on FLINK-25560: Hi, [~MartijnVisser]  Is there anyone else who can help me to

[GitHub] [flink] flinkbot edited a comment on pull request #17814: [FLINK-24899][runtime] Enable data compression for blocking shuffle by default

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #17814: URL: https://github.com/apache/flink/pull/17814#issuecomment-971129699 ## CI report: * 5a2cf6c1387dcc0822a56dcff10ed683a1476f0a Azure:

[GitHub] [flink] spoon-lz commented on a change in pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

2022-01-17 Thread GitBox
spoon-lz commented on a change in pull request #18119: URL: https://github.com/apache/flink/pull/18119#discussion_r786375022 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterDescriptor.java ## @@ -240,20 +238,11 @@ private String

[GitHub] [flink] flinkbot edited a comment on pull request #17814: [FLINK-24899][runtime] Enable data compression for blocking shuffle by default

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #17814: URL: https://github.com/apache/flink/pull/17814#issuecomment-971129699 ## CI report: * 5a2cf6c1387dcc0822a56dcff10ed683a1476f0a Azure:

[GitHub] [flink] SteNicholas removed a comment on pull request #17814: [FLINK-24899][runtime] Enable data compression for blocking shuffle by default

2022-01-17 Thread GitBox
SteNicholas removed a comment on pull request #17814: URL: https://github.com/apache/flink/pull/17814#issuecomment-1014648635 @wsry, I have added a commit for the failure of the CI. Please help to take a look at the update. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] SteNicholas commented on pull request #17814: [FLINK-24899][runtime] Enable data compression for blocking shuffle by default

2022-01-17 Thread GitBox
SteNicholas commented on pull request #17814: URL: https://github.com/apache/flink/pull/17814#issuecomment-1015015059 @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

[jira] [Comment Edited] (FLINK-25614) Let LocalWindowAggregate be chained with upstream

2022-01-17 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477524#comment-17477524 ] Jing Zhang edited comment on FLINK-25614 at 1/18/22, 2:23 AM: --

[jira] [Comment Edited] (FLINK-25614) Let LocalWindowAggregate be chained with upstream

2022-01-17 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477524#comment-17477524 ] Jing Zhang edited comment on FLINK-25614 at 1/18/22, 2:23 AM: --

[jira] [Commented] (FLINK-25614) Let LocalWindowAggregate be chained with upstream

2022-01-17 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477524#comment-17477524 ] Jing Zhang commented on FLINK-25614: [~wenlong.lwl][~lmagics]Thanks a lot for explain. I understand.

[GitHub] [flink] flinkbot edited a comment on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * b300d723871dd5b3c1f6978d2fa16e01896fabbc Azure:

[jira] [Commented] (FLINK-25482) Hive Lookup Join with decimal type failed

2022-01-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477522#comment-17477522 ] luoyuxia commented on FLINK-25482: -- [~miaojianlong]Thanks for reporting it, feel free to open pr to us.

[GitHub] [flink] flinkbot edited a comment on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * b300d723871dd5b3c1f6978d2fa16e01896fabbc Azure:

[GitHub] [flink] zuston commented on a change in pull request #18157: [FLINK-17808] Rename checkpoint meta file to "_metadata" until it has…

2022-01-17 Thread GitBox
zuston commented on a change in pull request #18157: URL: https://github.com/apache/flink/pull/18157#discussion_r786368729 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointMetadataOutputStream.java ## @@ -162,4 +164,97 @@ public

[GitHub] [flink] 1996fanrui commented on pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

2022-01-17 Thread GitBox
1996fanrui commented on pull request #18365: URL: https://github.com/apache/flink/pull/18365#issuecomment-1015007385 @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

[jira] [Comment Edited] (FLINK-25529) java.lang.ClassNotFoundException: org.apache.orc.PhysicalWriter when write bulkly into hive-2.1.1 orc table

2022-01-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477521#comment-17477521 ] luoyuxia edited comment on FLINK-25529 at 1/18/22, 2:05 AM: [~straw] It may

[jira] [Comment Edited] (FLINK-25529) java.lang.ClassNotFoundException: org.apache.orc.PhysicalWriter when write bulkly into hive-2.1.1 orc table

2022-01-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477521#comment-17477521 ] luoyuxia edited comment on FLINK-25529 at 1/18/22, 2:04 AM: [~straw] It may

[jira] [Comment Edited] (FLINK-25529) java.lang.ClassNotFoundException: org.apache.orc.PhysicalWriter when write bulkly into hive-2.1.1 orc table

2022-01-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477521#comment-17477521 ] luoyuxia edited comment on FLINK-25529 at 1/18/22, 2:04 AM: [~straw] It may

[jira] [Commented] (FLINK-25529) java.lang.ClassNotFoundException: org.apache.orc.PhysicalWriter when write bulkly into hive-2.1.1 orc table

2022-01-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477521#comment-17477521 ] luoyuxia commented on FLINK-25529: -- [~straw]  I download the [flink-hive-connector

[GitHub] [flink] flinkbot edited a comment on pull request #18380: [FLINK-25676][python] Support set_description in DataStream API

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18380: URL: https://github.com/apache/flink/pull/18380#issuecomment-1014348700 ## CI report: * 8567524e525600f37c4bfab1100c9f95c721b194 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18380: [FLINK-25676][python] Support set_description in DataStream API

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18380: URL: https://github.com/apache/flink/pull/18380#issuecomment-1014348700 ## CI report: * 8567524e525600f37c4bfab1100c9f95c721b194 Azure:

[jira] [Commented] (FLINK-25562) hive sql connector 依赖冲突

2022-01-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477516#comment-17477516 ] luoyuxia commented on FLINK-25562: -- Seems the hive connector 1.2.2 doesn't support hive 1.1.0,  we may

[GitHub] [flink] luoyuxia edited a comment on pull request #17990: [FLINK-25142][Connectors / Hive]Fix user-defined hive udtf initialize exception in hive dialect

2022-01-17 Thread GitBox
luoyuxia edited a comment on pull request #17990: URL: https://github.com/apache/flink/pull/17990#issuecomment-1014998915 @xiangqiao123 Sorry for the late reply., LGTM. @wuchong @beyond1920 Could you please help review & merge ? -- This is an automated message from the Apache Git

[GitHub] [flink] luoyuxia commented on pull request #17990: [FLINK-25142][Connectors / Hive]Fix user-defined hive udtf initialize exception in hive dialect

2022-01-17 Thread GitBox
luoyuxia commented on pull request #17990: URL: https://github.com/apache/flink/pull/17990#issuecomment-1014998915 @xiangqiao123 Sorry for the late reply., LGTM. @wuchong @zhijiangW Could you please help review & merge ? -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #18363: [Flink-25600][table-planner] Support new statement set syntax in sql client and update docs

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18363: URL: https://github.com/apache/flink/pull/18363#issuecomment-1012985353 ## CI report: * 419db64fb0e5165af2da748de01105ecf2b569fc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18363: [Flink-25600][table-planner] Support new statement set syntax in sql client and update docs

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18363: URL: https://github.com/apache/flink/pull/18363#issuecomment-1012985353 ## CI report: * 419db64fb0e5165af2da748de01105ecf2b569fc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18382: [FLINK-25524] Fix ChangelogStateBackend.notifyCheckpointComplete

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18382: URL: https://github.com/apache/flink/pull/18382#issuecomment-1014709963 ## CI report: * 6bd06df926e13c3dc4788242316f600711ccb418 Azure:

[GitHub] [flink-docker] tweise merged pull request #97: Update dev-1.14 for 1.14.3 release

2022-01-17 Thread GitBox
tweise merged pull request #97: URL: https://github.com/apache/flink-docker/pull/97 -- 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. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot edited a comment on pull request #18348: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18348: URL: https://github.com/apache/flink/pull/18348#issuecomment-1011977937 ## CI report: * e64fc5d1a9a1ffb3e09ccc42664c8c28104a9941 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18383: [hotfix][docs] Updated orderby clause section

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18383: URL: https://github.com/apache/flink/pull/18383#issuecomment-1014874958 ## CI report: * cee027d930aaa3ac13aa572ef91d12a87ef514e5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18382: [FLINK-25524] Fix ChangelogStateBackend.notifyCheckpointComplete

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18382: URL: https://github.com/apache/flink/pull/18382#issuecomment-1014709963 ## CI report: * b811819772b2d2a5dc839ac8589c07fd9796ff1f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18382: [FLINK-25524] Fix ChangelogStateBackend.notifyCheckpointComplete

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18382: URL: https://github.com/apache/flink/pull/18382#issuecomment-1014709963 ## CI report: * b811819772b2d2a5dc839ac8589c07fd9796ff1f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18348: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18348: URL: https://github.com/apache/flink/pull/18348#issuecomment-1011977937 ## CI report: * a8d265e5f6cc1db8bf1c0869fda1d52f3445c092 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18382: [FLINK-25524] Fix ChangelogStateBackend.notifyCheckpointComplete

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18382: URL: https://github.com/apache/flink/pull/18382#issuecomment-1014709963 ## CI report: * b811819772b2d2a5dc839ac8589c07fd9796ff1f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18348: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18348: URL: https://github.com/apache/flink/pull/18348#issuecomment-1011977937 ## CI report: * 1fa421963e5fc709a4293532c959a5b50f9e4bb8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18348: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18348: URL: https://github.com/apache/flink/pull/18348#issuecomment-1011977937 ## CI report: * 1fa421963e5fc709a4293532c959a5b50f9e4bb8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18383: [hotfix][docs] Updated orderby clause section

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18383: URL: https://github.com/apache/flink/pull/18383#issuecomment-1014874958 ## CI report: * cee027d930aaa3ac13aa572ef91d12a87ef514e5 Azure:

[GitHub] [flink] flinkbot commented on pull request #18383: [hotfix][docs] Updated orderby clause section

2022-01-17 Thread GitBox
flinkbot commented on pull request #18383: URL: https://github.com/apache/flink/pull/18383#issuecomment-1014875581 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

[GitHub] [flink] flinkbot commented on pull request #18383: [hotfix][docs] Updated orderby clause section

2022-01-17 Thread GitBox
flinkbot commented on pull request #18383: URL: https://github.com/apache/flink/pull/18383#issuecomment-1014874958 ## CI report: * cee027d930aaa3ac13aa572ef91d12a87ef514e5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18382: [FLINK-25524] Fix ChangelogStateBackend.notifyCheckpointComplete

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18382: URL: https://github.com/apache/flink/pull/18382#issuecomment-1014709963 ## CI report: * b5d1edb85053fb7371c884d2a8f3a7b0b0f64f97 Azure:

[GitHub] [flink] mans2singh opened a new pull request #18383: [hotfix][docs] Updated orderby clause section

2022-01-17 Thread GitBox
mans2singh opened a new pull request #18383: URL: https://github.com/apache/flink/pull/18383 ## What is the purpose of the change * The order by section indicates `... is no this limitation in ...` ## Brief change log * Changed to `... is no such limitation in ...`

[GitHub] [flink] flinkbot edited a comment on pull request #18382: [FLINK-25524] Fix ChangelogStateBackend.notifyCheckpointComplete

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18382: URL: https://github.com/apache/flink/pull/18382#issuecomment-1014709963 ## CI report: * 88928763224da2a95afb2811ecf3311232a2c115 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #17503: URL: https://github.com/apache/flink/pull/17503#issuecomment-945138587 ## CI report: * 4d30cc1db8de1a547c0908f6a634c647a6f4f69a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18354: [FLINK-25650][docs] Added "Interplay with long-running record process…

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18354: URL: https://github.com/apache/flink/pull/18354#issuecomment-1014449494 ## CI report: * 80cc40f2dc4121c04d58da7f8c91202094625869 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18316: [hotfix][docs] Fixing multiple internal and external 404 links

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18316: URL: https://github.com/apache/flink/pull/18316#issuecomment-1008874978 ## CI report: * 40a6f16a2126db71bc34c019294f7d4f8294542c Azure:

[GitHub] [flink] zentol commented on a change in pull request #18194: [FLINK-25436] Let Dispatcher only retain recovered jobs in BlobServer

2022-01-17 Thread GitBox
zentol commented on a change in pull request #18194: URL: https://github.com/apache/flink/pull/18194#discussion_r786254780 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java ## @@ -1045,6 +1048,27 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #17503: [FLINK-24334][Deployment/Kubernetes] Configuration 'kubernetes.flink.log.dir' compatible

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #17503: URL: https://github.com/apache/flink/pull/17503#issuecomment-945138587 ## CI report: * f0d16df0222b7271dda3204336382d5007fc3b70 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18192: [FLINK-25406] Let FileSystemBlobStore sync output stream

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18192: URL: https://github.com/apache/flink/pull/18192#issuecomment-1000394190 ## CI report: * b0a3e6f76624a6afc293ef69205e91d440fee1f0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17814: [FLINK-24899][runtime] Enable data compression for blocking shuffle by default

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #17814: URL: https://github.com/apache/flink/pull/17814#issuecomment-971129699 ## CI report: * 5a2cf6c1387dcc0822a56dcff10ed683a1476f0a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18382: [FLINK-25524] Fix ChangelogStateBackend.notifyCheckpointComplete

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18382: URL: https://github.com/apache/flink/pull/18382#issuecomment-1014709963 ## CI report: * 88928763224da2a95afb2811ecf3311232a2c115 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18348: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18348: URL: https://github.com/apache/flink/pull/18348#issuecomment-1011977937 ## CI report: * 1fa421963e5fc709a4293532c959a5b50f9e4bb8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18382: [FLINK-25524] Fix ChangelogStateBackend.notifyCheckpointComplete

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18382: URL: https://github.com/apache/flink/pull/18382#issuecomment-1014709963 ## CI report: * 88928763224da2a95afb2811ecf3311232a2c115 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18351: [FLINK-25646][docs] Added "High parallelism" limitation for buffer debloating docs

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18351: URL: https://github.com/apache/flink/pull/18351#issuecomment-1012106731 ## CI report: * 6fd86437e9bc448215bf55b289b1a980cbf8b373 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18348: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18348: URL: https://github.com/apache/flink/pull/18348#issuecomment-1011977937 ## CI report: * 1fa421963e5fc709a4293532c959a5b50f9e4bb8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18348: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18348: URL: https://github.com/apache/flink/pull/18348#issuecomment-1011977937 ## CI report: * c2d29d872128e979d1c4f86b80aa6512f4b49dbe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18367: [FLINK-25657][Kinesis] Upgrade com.amazonaws:amazon-kinesis-client dependency from 1.14.1 to 1.14.7

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18367: URL: https://github.com/apache/flink/pull/18367#issuecomment-1013185960 ## CI report: * 67ba96a94d75cfdfcdae77da0abfcdce0e5a2117 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18348: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18348: URL: https://github.com/apache/flink/pull/18348#issuecomment-1011977937 ## CI report: * c2d29d872128e979d1c4f86b80aa6512f4b49dbe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18165: [FLINK-24904][docs] Updated docs to reflect new KDS Sink and deprecat…

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18165: URL: https://github.com/apache/flink/pull/18165#issuecomment-998902737 ## CI report: * 631e75a7b2e1c74ea7b53ab845cdfa9f07b597aa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18381: [hotfix][flink-annotations] Add v1.15 as the next Flink version to master

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18381: URL: https://github.com/apache/flink/pull/18381#issuecomment-1014523784 ## CI report: * fa06744edb04bbfba64b233e4755ea0fb98977f8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * b300d723871dd5b3c1f6978d2fa16e01896fabbc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18165: [FLINK-24904][docs] Updated docs to reflect new KDS Sink and deprecat…

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18165: URL: https://github.com/apache/flink/pull/18165#issuecomment-998902737 ## CI report: * 257de486f8667d77d98ed2404d2ea390074a76e1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18348: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18348: URL: https://github.com/apache/flink/pull/18348#issuecomment-1011977937 ## CI report: * c2d29d872128e979d1c4f86b80aa6512f4b49dbe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18194: [FLINK-25436] Let Dispatcher only retain recovered jobs in BlobServer

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18194: URL: https://github.com/apache/flink/pull/18194#issuecomment-1000443947 ## CI report: * 9097b39a2141b1cf6cc6524a62fcaf2d12b2f130 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18348: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18348: URL: https://github.com/apache/flink/pull/18348#issuecomment-1011977937 ## CI report: * c2d29d872128e979d1c4f86b80aa6512f4b49dbe Azure:

[jira] [Updated] (FLINK-25662) Access KeyedStateStore in WindowAssigner

2022-01-17 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-25662: - Fix Version/s: (was: 1.14.3) > Access KeyedStateStore in WindowAssigner >

[jira] [Updated] (FLINK-25633) CPUResourceTest does not work with German Locale

2022-01-17 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-25633: - Fix Version/s: (was: 1.13.6) (was: 1.14.3) > CPUResourceTest does

[GitHub] [flink] flinkbot edited a comment on pull request #18352: [FLINK-15585][table] Improve function identifier string in plan digest

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18352: URL: https://github.com/apache/flink/pull/18352#issuecomment-1012981301 ## CI report: * 9a722a403d015ecb0d161d377ee6421f1ada63b7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18348: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18348: URL: https://github.com/apache/flink/pull/18348#issuecomment-1011977937 ## CI report: * c2d29d872128e979d1c4f86b80aa6512f4b49dbe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18349: [FLINK-25609][table] Anonymous/inline tables don't require ObjectIdentifier anymore

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18349: URL: https://github.com/apache/flink/pull/18349#issuecomment-1011991081 ## CI report: * 0aa7220300adc4f5f9ef0aa59608f299b3b9ac29 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18382: [WIP][FLINK-25524][state/changelog] Fix checkpoint ID in completion notifications

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18382: URL: https://github.com/apache/flink/pull/18382#issuecomment-1014709963 ## CI report: * 88928763224da2a95afb2811ecf3311232a2c115 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18382: [WIP][FLINK-25524][state/changelog] Fix checkpoint ID in completion notifications

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18382: URL: https://github.com/apache/flink/pull/18382#issuecomment-1014709963 ## CI report: * 88928763224da2a95afb2811ecf3311232a2c115 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18343: [FLINK-25633] Set locale to en-US to avoid ambiguous decimal formattings

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18343: URL: https://github.com/apache/flink/pull/18343#issuecomment-1011258099 ## CI report: * 94936f35c707fa2d869fb92800610ee35b0a4f4f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18382: [WIP][FLINK-25524][state/changelog] Fix checkpoint ID in completion notifications

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18382: URL: https://github.com/apache/flink/pull/18382#issuecomment-1014709963 ## CI report: * 88928763224da2a95afb2811ecf3311232a2c115 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18382: [WIP][FLINK-25524][state/changelog] Fix checkpoint ID in completion notifications

2022-01-17 Thread GitBox
flinkbot edited a comment on pull request #18382: URL: https://github.com/apache/flink/pull/18382#issuecomment-1014709963 ## CI report: * 88928763224da2a95afb2811ecf3311232a2c115 Azure:

<    1   2   3   4   5   6   7   >