[jira] [Updated] (FLINK-26943) Add DATE_ADD supported in SQL & Table API

2022-03-30 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-26943: -- Description: Returns the date {{numDays}} after {{{}startDate{}}}. Syntax: {code:java} date_add(start

[GitHub] [flink] ZhangChaoming commented on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

2022-03-30 Thread GitBox
ZhangChaoming commented on pull request #18151: URL: https://github.com/apache/flink/pull/18151#issuecomment-1084170424 @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 sp

[jira] [Commented] (FLINK-26941) Support Pattern end with notFollowedBy with window

2022-03-30 Thread Yue Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17515111#comment-17515111 ] Yue Ma commented on FLINK-26941: [~nicholasjiang] I think this impove is valid for all

[GitHub] [flink] ZhangChaoming commented on pull request #19219: [FLINK-26835][serialization] Fix concurrent modification exception

2022-03-30 Thread GitBox
ZhangChaoming commented on pull request #19219: URL: https://github.com/apache/flink/pull/19219#issuecomment-1084169173 @pnowojski `ConcurrentHashMap` uses CAS ranther than ReentrenLock after jdk8, which has good performance in multi-thread condition as well as single condition. > What

[jira] [Updated] (FLINK-26943) Add DATE_ADD supported in SQL & Table API

2022-03-30 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-26943: -- Description: Returns the date {{numDays}} after {{{}startDate{}}}. Syntax: {code:java} date_add(start

[jira] [Resolved] (FLINK-26018) Unnecessary late events when using the new KafkaSource

2022-03-30 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-26018. --- Release Note: Fixed on master: b9593715f35640154615df0098ac7459f37911c3 release-1.15: c71582

[GitHub] [flink] flinkbot edited a comment on pull request #19290: [BACKPORT 1.15][FLINK-25440][doc][pulsar] Stop and Start cursor now all uses publish…

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #19290: URL: https://github.com/apache/flink/pull/19290#issuecomment-1084005969 ## CI report: * 9a1a6ec6de9884f9173437e63d58671f8949f9ad Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-26941) Support Pattern end with notFollowedBy with window

2022-03-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26941: --- Labels: pull-request-available (was: ) > Support Pattern end with notFollowedBy with window

[GitHub] [flink] mayuehappy opened a new pull request #19295: [FLINK-26941][cep] Support Pattern end with notFollowedBy with window

2022-03-30 Thread GitBox
mayuehappy opened a new pull request #19295: URL: https://github.com/apache/flink/pull/19295 ## 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

[jira] [Created] (FLINK-26943) Add DATE_ADD supported in SQL & Table API

2022-03-30 Thread dalongliu (Jira)
dalongliu created FLINK-26943: - Summary: Add DATE_ADD supported in SQL & Table API Key: FLINK-26943 URL: https://issues.apache.org/jira/browse/FLINK-26943 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-26941) Support Pattern end with notFollowedBy with window

2022-03-30 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17515104#comment-17515104 ] Nicholas Jiang commented on FLINK-26941: [~mayuehappy], does this improve affect

[jira] [Created] (FLINK-26942) Support SELECT clause in CREATE TABLE(CTAS)

2022-03-30 Thread tartarus (Jira)
tartarus created FLINK-26942: Summary: Support SELECT clause in CREATE TABLE(CTAS) Key: FLINK-26942 URL: https://issues.apache.org/jira/browse/FLINK-26942 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-26861) Log cannot be printed completely when use System.exit(1)

2022-03-30 Thread chenzihao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17515103#comment-17515103 ] chenzihao commented on FLINK-26861: --- Hi, [~huwh]. Thank you for reminding. I found tha

[jira] [Created] (FLINK-26941) Support Pattern end with notFollowedBy with window

2022-03-30 Thread Yue Ma (Jira)
Yue Ma created FLINK-26941: -- Summary: Support Pattern end with notFollowedBy with window Key: FLINK-26941 URL: https://issues.apache.org/jira/browse/FLINK-26941 Project: Flink Issue Type: Improvemen

[GitHub] [flink] flinkbot edited a comment on pull request #19289: [BACKPORT 1.14]: [FLINK-25440][doc][pulsar] Stop and Start cursor now all uses publish…

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #19289: URL: https://github.com/apache/flink/pull/19289#issuecomment-1083997871 ## CI report: * 31f1c8cdae6247855156336d54662e4cef7ad80e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19099: [FLINK-26182][Connector/pulsar] Create a e2e tests for Pulsar sink.

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #19099: URL: https://github.com/apache/flink/pull/19099#issuecomment-1068063059 ## CI report: * a032fb606c2bb05580a7a1a7806c7a212ff5e1d3 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-26575) Improve the info message when restoring keyed state backend

2022-03-30 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-26575: - Fix Version/s: 1.15.0 1.16.0 1.14.5 > Improve the info message whe

[jira] [Created] (FLINK-26940) Add SUBSTRING_INDEX supported in SQL & Table API

2022-03-30 Thread dalongliu (Jira)
dalongliu created FLINK-26940: - Summary: Add SUBSTRING_INDEX supported in SQL & Table API Key: FLINK-26940 URL: https://issues.apache.org/jira/browse/FLINK-26940 Project: Flink Issue Type: Sub-ta

[GitHub] [flink] flinkbot edited a comment on pull request #19289: [BACKPORT 1.14]: [FLINK-25440][doc][pulsar] Stop and Start cursor now all uses publish…

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #19289: URL: https://github.com/apache/flink/pull/19289#issuecomment-1083997871 ## CI report: * 31f1c8cdae6247855156336d54662e4cef7ad80e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19099: [FLINK-26182][Connector/pulsar] Create a e2e tests for Pulsar sink.

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #19099: URL: https://github.com/apache/flink/pull/19099#issuecomment-1068063059 ## CI report: * a032fb606c2bb05580a7a1a7806c7a212ff5e1d3 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1017085273 ## CI report: * 4ca872334dc69738bc3b7aa136c1e23e7e8e99aa Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Commented] (FLINK-17231) Deprecate possible implicit fallback from LB to NodePort When retrieving Endpoint of LB Service

2022-03-30 Thread liuzhuo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17515101#comment-17515101 ] liuzhuo commented on FLINK-17231: - [~wangyang0918] When LoadBalancer is configured but u

[GitHub] [flink] flinkbot edited a comment on pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1017085273 ## CI report: * 4ca872334dc69738bc3b7aa136c1e23e7e8e99aa Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] imaffe commented on pull request #19289: [BACKPORT 1.14]: [FLINK-25440][doc][pulsar] Stop and Start cursor now all uses publish…

2022-03-30 Thread GitBox
imaffe commented on pull request #19289: URL: https://github.com/apache/flink/pull/19289#issuecomment-1084149852 I'm working to resolve the issue -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1017085273 ## CI report: * 4ca872334dc69738bc3b7aa136c1e23e7e8e99aa Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Created] (FLINK-26939) Add TRANSLATE supported in SQL & Table API

2022-03-30 Thread dalongliu (Jira)
dalongliu created FLINK-26939: - Summary: Add TRANSLATE supported in SQL & Table API Key: FLINK-26939 URL: https://issues.apache.org/jira/browse/FLINK-26939 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot edited a comment on pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1017085273 ## CI report: * 4ca872334dc69738bc3b7aa136c1e23e7e8e99aa Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #19294: [FLINK-26798][1.14][runtime] Hardens test against unexpected heartbeat

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #19294: URL: https://github.com/apache/flink/pull/19294#issuecomment-1084136681 ## CI report: * b693417fb4641bbac4a35ee0827f55b46fd4fab3 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19293: [FLINK-26798][BP-1.15][runtime] Hardens JobManagerTest against unexpected heartbeat

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #19293: URL: https://github.com/apache/flink/pull/19293#issuecomment-1084136556 ## CI report: * 43cfadcb625626129da0743773330c6673fd1974 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18933: [FLINK-26368] [kafka] Add setProperty method to KafkaSinkBuilder

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #18933: URL: https://github.com/apache/flink/pull/18933#issuecomment-1054619568 ## CI report: * 7d1836820a694cca13bc135d696ed8cd9dc2ae95 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1017085273 ## CI report: * 4ca872334dc69738bc3b7aa136c1e23e7e8e99aa Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot commented on pull request #19294: [FLINK-26798][1.14][runtime] Hardens test against unexpected heartbeat

2022-03-30 Thread GitBox
flinkbot commented on pull request #19294: URL: https://github.com/apache/flink/pull/19294#issuecomment-1084136681 ## CI report: * b693417fb4641bbac4a35ee0827f55b46fd4fab3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18933: [FLINK-26368] [kafka] Add setProperty method to KafkaSinkBuilder

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #18933: URL: https://github.com/apache/flink/pull/18933#issuecomment-1054619568 ## CI report: * 7d1836820a694cca13bc135d696ed8cd9dc2ae95 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot commented on pull request #19293: [FLINK-26798][BP-1.15][runtime] Hardens JobManagerTest against unexpected heartbeat

2022-03-30 Thread GitBox
flinkbot commented on pull request #19293: URL: https://github.com/apache/flink/pull/19293#issuecomment-1084136556 ## CI report: * 43cfadcb625626129da0743773330c6673fd1974 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1017085273 ## CI report: * 4ca872334dc69738bc3b7aa136c1e23e7e8e99aa Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] XComp opened a new pull request #19294: [FLINK-26798][1.14][runtime] Hardens test against unexpected heartbeat

2022-03-30 Thread GitBox
XComp opened a new pull request #19294: URL: https://github.com/apache/flink/pull/19294 This is a 1.14 backport for the parent PR #19195 -- 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 spec

[GitHub] [flink] XComp opened a new pull request #19293: [FLINK-26798][BP-1.15][runtime] Hardens JobManagerTest against unexpected heartbeat

2022-03-30 Thread GitBox
XComp opened a new pull request #19293: URL: https://github.com/apache/flink/pull/19293 This is a 1.15 backport for the parent PR #19195 -- 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 spec

[GitHub] [flink] flinkbot edited a comment on pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1017085273 ## CI report: * 4ca872334dc69738bc3b7aa136c1e23e7e8e99aa Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1017085273 ## CI report: * 4ca872334dc69738bc3b7aa136c1e23e7e8e99aa Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Commented] (FLINK-26938) HybridSource recovery from savepoint fails When flink parallelism is greater than the number of Kafka partitions

2022-03-30 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17515090#comment-17515090 ] Nicholas Jiang commented on FLINK-26938: [~MartijnVisser], could you please assi

[GitHub] [flink] flinkbot edited a comment on pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1017085273 ## CI report: * 4ca872334dc69738bc3b7aa136c1e23e7e8e99aa Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1017085273 ## CI report: * 4ca872334dc69738bc3b7aa136c1e23e7e8e99aa Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1017085273 ## CI report: * 4ca872334dc69738bc3b7aa136c1e23e7e8e99aa Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1017085273 ## CI report: * 39c6e525639eea1a578f99d7dc03b44b6c36cbeb Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-26938) HybridSource recovery from savepoint fails When flink parallelism is greater than the number of Kafka partitions

2022-03-30 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-26938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 文报 updated FLINK-26938: --- Attachment: HybridSourceTest.java > HybridSource recovery from savepoint fails When flink parallelism is greater >

[jira] [Updated] (FLINK-26938) HybridSource recovery from savepoint fails When flink parallelism is greater than the number of Kafka partitions

2022-03-30 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-26938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 文报 updated FLINK-26938: --- Attachment: (was: image-2022-03-31-13-25-28-520.png) > HybridSource recovery from savepoint fails When flink par

[jira] [Updated] (FLINK-26938) HybridSource recovery from savepoint fails When flink parallelism is greater than the number of Kafka partitions

2022-03-30 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-26938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 文报 updated FLINK-26938: --- Description: HybridSource recovery from savepoint fails When flink parallelism is greater than the number of Kafka

[jira] [Updated] (FLINK-26938) HybridSource recovery from savepoint fails When flink parallelism is greater than the number of Kafka partitions

2022-03-30 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-26938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 文报 updated FLINK-26938: --- Attachment: image-2022-03-31-13-36-45-686.png > HybridSource recovery from savepoint fails When flink parallelism is

[jira] [Updated] (FLINK-26938) HybridSource recovery from savepoint fails When flink parallelism is greater than the number of Kafka partitions

2022-03-30 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-26938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 文报 updated FLINK-26938: --- Description: HybridSource recovery from savepoint fails When flink parallelism is greater than the number of Kafka

[jira] [Created] (FLINK-26938) HybridSource recovery from savepoint fails When flink parallelism is greater than the number of Kafka partitions

2022-03-30 Thread Jira
文报 created FLINK-26938: -- Summary: HybridSource recovery from savepoint fails When flink parallelism is greater than the number of Kafka partitions Key: FLINK-26938 URL: https://issues.apache.org/jira/browse/FLINK-26938

[GitHub] [flink] flinkbot edited a comment on pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1017085273 ## CI report: * 39c6e525639eea1a578f99d7dc03b44b6c36cbeb Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] imaffe commented on a change in pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

2022-03-30 Thread GitBox
imaffe commented on a change in pull request #18406: URL: https://github.com/apache/flink/pull/18406#discussion_r839183575 ## File path: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/split/PulsarPartitionSplitReaderBase.java

[GitHub] [flink] flinkbot edited a comment on pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1017085273 ## CI report: * 39c6e525639eea1a578f99d7dc03b44b6c36cbeb Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19283: [hive] init improve complex type support

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #19283: URL: https://github.com/apache/flink/pull/19283#issuecomment-1082876584 ## CI report: * 97f4e2c6ea36698b35bdac3fc59c4b29773e808d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19283: [hive] init improve complex type support

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #19283: URL: https://github.com/apache/flink/pull/19283#issuecomment-1082876584 ## CI report: * 97f4e2c6ea36698b35bdac3fc59c4b29773e808d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19283: [hive] init improve complex type support

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #19283: URL: https://github.com/apache/flink/pull/19283#issuecomment-1082876584 ## CI report: * 97f4e2c6ea36698b35bdac3fc59c4b29773e808d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #18151: URL: https://github.com/apache/flink/pull/18151#issuecomment-997659194 ## CI report: * 2ce22ff3c8ce54bc228692d7c654459878c4557b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #19292: [FLINK-11388][docs][oss]Update docs for OSS Recoverable writer

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #19292: URL: https://github.com/apache/flink/pull/19292#issuecomment-1084048061 ## CI report: * d92199e59d83f17fcd0ca71c8d1354df2a2cffaa UNKNOWN * 47486d6e503a540abab64d2a53db90c35efb51d5 Azure: [PENDING](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #19292: [FLINK-11388][docs][oss]Update docs for OSS Recoverable writer

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #19292: URL: https://github.com/apache/flink/pull/19292#issuecomment-1084048061 ## CI report: * d92199e59d83f17fcd0ca71c8d1354df2a2cffaa UNKNOWN * 47486d6e503a540abab64d2a53db90c35efb51d5 UNKNOWN Bot commands The @flinkb

[GitHub] [flink] flinkbot edited a comment on pull request #16859: [FLINK-23719] [connectors/hbase] Support switch WAL in Flink SQL DDL options for HBase sink

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #16859: URL: https://github.com/apache/flink/pull/16859#issuecomment-900154234 ## CI report: * Unknown: [CANCELED](TBD) * c4623378a759c4a42548f8a56f1051851c3e1f04 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620

[GitHub] [flink] flinkbot commented on pull request #19292: [FLINK-11388][docs][oss]Update docs for OSS Recoverable writer

2022-03-30 Thread GitBox
flinkbot commented on pull request #19292: URL: https://github.com/apache/flink/pull/19292#issuecomment-1084048061 ## CI report: * d92199e59d83f17fcd0ca71c8d1354df2a2cffaa UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #19291: [FLINK-26927][testutils] Improve FlinkContainers to better support JM restarting

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #19291: URL: https://github.com/apache/flink/pull/19291#issuecomment-1084046049 ## CI report: * cf61c79dd96c1558e2511ba9faa790ab3bf3891e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] Thesharing edited a comment on pull request #19275: [FLINK-24491] Make the job termination wait until the archiving of ExecutionGraphInfo finishes

2022-03-30 Thread GitBox
Thesharing edited a comment on pull request #19275: URL: https://github.com/apache/flink/pull/19275#issuecomment-1084046966 cc @zhuzhurk @XComp Would you mind helping me review this pull request if you had free time? This change is related to the cleanup of the resources including JobManag

[GitHub] [flink] flinkbot edited a comment on pull request #16859: [FLINK-23719] [connectors/hbase] Support switch WAL in Flink SQL DDL options for HBase sink

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #16859: URL: https://github.com/apache/flink/pull/16859#issuecomment-900154234 ## CI report: * Unknown: [CANCELED](TBD) * c4623378a759c4a42548f8a56f1051851c3e1f04 UNKNOWN Bot commands The @flinkbot bot supports the fol

[GitHub] [flink] Thesharing commented on pull request #19275: [FLINK-24491] Make the job termination wait until the archiving of ExecutionGraphInfo finishes

2022-03-30 Thread GitBox
Thesharing commented on pull request #19275: URL: https://github.com/apache/flink/pull/19275#issuecomment-1084046966 cc @zhuzhurk @XComp Would you mind helping me review this pull request if you had free time? -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] wujinhu opened a new pull request #19292: [FLINK-11388][doc][OSS]Update docs for OSS Recoverable writer

2022-03-30 Thread GitBox
wujinhu opened a new pull request #19292: URL: https://github.com/apache/flink/pull/19292 ## What is the purpose of the change Update documentation for [Add Aliyun OSS recoverable writer](https://github.com/apache/flink/pull/19072) -- This is an automated message from

[GitHub] [flink] LB-Yu commented on pull request #16859: [FLINK-23719] [connectors/hbase] Support switch WAL in Flink SQL DDL options for HBase sink

2022-03-30 Thread GitBox
LB-Yu commented on pull request #16859: URL: https://github.com/apache/flink/pull/16859#issuecomment-1084046164 @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 c

[GitHub] [flink] flinkbot commented on pull request #19291: [FLINK-26927][testutils] Improve FlinkContainers to better support JM restarting

2022-03-30 Thread GitBox
flinkbot commented on pull request #19291: URL: https://github.com/apache/flink/pull/19291#issuecomment-1084046049 ## CI report: * cf61c79dd96c1558e2511ba9faa790ab3bf3891e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-26927) Support restarting JobManager in FlinkContainers

2022-03-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26927: --- Labels: pull-request-available (was: ) > Support restarting JobManager in FlinkContainers >

[GitHub] [flink] PatrickRen opened a new pull request #19291: [FLINK-26927][testutils] Improve FlinkContainers to better support JM restarting

2022-03-30 Thread GitBox
PatrickRen opened a new pull request #19291: URL: https://github.com/apache/flink/pull/19291 ## What is the purpose of the change This pull request makes some improvement on `FlinkContainers` to better support restarting JobManager under HA mode. ## Brief change log

[GitHub] [flink] zhuzhurk commented on pull request #19266: [hotfix][doc] Modify spelling error in elastic_scaling.md

2022-03-30 Thread GitBox
zhuzhurk commented on pull request #19266: URL: https://github.com/apache/flink/pull/19266#issuecomment-1084043183 Merged into release-1.15: 341deb239c7ea974af237f41e444cf42defc7bbd -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

[GitHub] [flink] zhuzhurk commented on pull request #19266: [hotfix][doc] Modify spelling error in elastic_scaling.md

2022-03-30 Thread GitBox
zhuzhurk commented on pull request #19266: URL: https://github.com/apache/flink/pull/19266#issuecomment-1084041082 Thanks for reporting and fixing this spelling error! @Myracle And thanks for reviewing the fix and merging it into master. @MartijnVisser We absolute need this fix in re

[GitHub] [flink] flinkbot edited a comment on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * 53861a48a63041cdb9ea4fe411d58a4489a51be9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * 53861a48a63041cdb9ea4fe411d58a4489a51be9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-26683) Commit side effects if stop-with-savepoint failed while finishing

2022-03-30 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17515045#comment-17515045 ] Liu commented on FLINK-26683: - The most cases I met are that the job is stuck with NoClassDe

[jira] [Updated] (FLINK-14998) Remove FileUtils#deletePathIfEmpty

2022-03-30 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-14998: - Fix Version/s: 1.16.0 (was: 1.15.0) > Remove FileUtils#deletePathIfEmpty > --

[jira] [Assigned] (FLINK-14998) Remove FileUtils#deletePathIfEmpty

2022-03-30 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-14998: Assignee: jay li > Remove FileUtils#deletePathIfEmpty > -- > >

[jira] [Commented] (FLINK-14998) Remove FileUtils#deletePathIfEmpty

2022-03-30 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17515043#comment-17515043 ] Yun Tang commented on FLINK-14998: -- [~jay li] sure, I will assign this ticket to you.

[jira] [Created] (FLINK-26937) Introduce Leveled compression for LSM

2022-03-30 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-26937: Summary: Introduce Leveled compression for LSM Key: FLINK-26937 URL: https://issues.apache.org/jira/browse/FLINK-26937 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-26882) Unaligned checkpoint with 0s timeout would fail RescaleCheckpointManuallyITCase

2022-03-30 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17515042#comment-17515042 ] Yun Tang commented on FLINK-26882: -- [~nsemmler], the broken instance https://dev.azure

[jira] [Commented] (FLINK-26934) Add reference to operator meetup talk to docs

2022-03-30 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17515041#comment-17515041 ] Yang Wang commented on FLINK-26934: --- Nice talk. Of cause, it deserves to be added to t

[GitHub] [flink] zoltar9264 commented on pull request #19252: [FLINK-25867][docs] translate ChangelogBackend documentation to chinese

2022-03-30 Thread GitBox
zoltar9264 commented on pull request #19252: URL: https://github.com/apache/flink/pull/19252#issuecomment-1084022689 Thanks @curcur ! -- 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] [Closed] (FLINK-26575) Improve the info message when restoring keyed state backend

2022-03-30 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang closed FLINK-26575. Resolution: Fixed merged in master: d8f6279c14236de832566b1ff97053e79e1e1414 release-1.15: df3ab6c72f991e9

[GitHub] [flink] Myasuka merged pull request #19034: [FLINK-26575][checkpoint] Improve the info message when restoring keyed state backend

2022-03-30 Thread GitBox
Myasuka merged pull request #19034: URL: https://github.com/apache/flink/pull/19034 -- 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: issues-unsubsc

[GitHub] [flink] flinkbot edited a comment on pull request #19289: [BACKPORT 1.14]: [FLINK-25440][doc][pulsar] Stop and Start cursor now all uses publish…

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #19289: URL: https://github.com/apache/flink/pull/19289#issuecomment-1083997871 ## CI report: * 31f1c8cdae6247855156336d54662e4cef7ad80e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-26930) Rethink last-state upgrade implementation in flink-kubernetes-operator

2022-03-30 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-26930: -- Description: Following the discussion in FLINK-26916.   How the last-state upgrade works now? First

[jira] [Updated] (FLINK-26932) TaskManager hung in cleanupAllocationBaseDirs not exit.

2022-03-30 Thread huweihua (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huweihua updated FLINK-26932: - Attachment: 1280X1280.png > TaskManager hung in cleanupAllocationBaseDirs not exit. > --

[GitHub] [flink] syhily commented on pull request #19092: [FLINK-26645][Connector/Pulsar] Fix Pulsar source subscriber consume from all partitions when only subscribed to 1 partition

2022-03-30 Thread GitBox
syhily commented on pull request #19092: URL: https://github.com/apache/flink/pull/19092#issuecomment-1084011299 @fapaul @AHeise Can you review this hotfix? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abov

[GitHub] [flink] syhily commented on pull request #19285: [FLINK-26931] Make the producer name and consumer name unique in Pulsar

2022-03-30 Thread GitBox
syhily commented on pull request #19285: URL: https://github.com/apache/flink/pull/19285#issuecomment-1084011194 @fapaul @AHeise Can you review this hotfix? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abov

[jira] [Updated] (FLINK-26932) TaskManager hung in cleanupAllocationBaseDirs not exit.

2022-03-30 Thread huweihua (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huweihua updated FLINK-26932: - Attachment: origin_img_v2_bb063beb-2f44-40fe-b1d2-4cc8dc87585g.png > TaskManager hung in cleanupAllocati

[jira] [Updated] (FLINK-26932) TaskManager hung in cleanupAllocationBaseDirs not exit.

2022-03-30 Thread huweihua (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huweihua updated FLINK-26932: - Description: The disk TaskManager used had some fatal error. And then TaskManager hung in cleanupAlloca

[jira] [Updated] (FLINK-26932) TaskManager hung in cleanupAllocationBaseDirs not exit.

2022-03-30 Thread huweihua (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huweihua updated FLINK-26932: - Description: The disk TaskManager used had some fatal error. And then TaskManager hung in cleanupAlloca

[GitHub] [flink] flinkbot edited a comment on pull request #19290: [BACKPORT 1.15][FLINK-25440][doc][pulsar] Stop and Start cursor now all uses publish…

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #19290: URL: https://github.com/apache/flink/pull/19290#issuecomment-1084005969 ## CI report: * 9a1a6ec6de9884f9173437e63d58671f8949f9ad Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Comment Edited] (FLINK-26930) Rethink last-state upgrade implementation in flink-kubernetes-operator

2022-03-30 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17515028#comment-17515028 ] Yang Wang edited comment on FLINK-26930 at 3/31/22, 2:36 AM: -

[jira] [Commented] (FLINK-26930) Rethink last-state upgrade implementation in flink-kubernetes-operator

2022-03-30 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17515028#comment-17515028 ] Yang Wang commented on FLINK-26930: --- I hesitate to store the the last checkpoint path

[GitHub] [flink] flinkbot edited a comment on pull request #19290: [BACKPORT 1.15][FLINK-25440][doc][pulsar] Stop and Start cursor now all uses publish…

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #19290: URL: https://github.com/apache/flink/pull/19290#issuecomment-1084005969 ## CI report: * 9a1a6ec6de9884f9173437e63d58671f8949f9ad UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@fl

[jira] [Commented] (FLINK-26935) Sort records by sequence number when continuous reading

2022-03-30 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17515024#comment-17515024 ] Nicholas Jiang commented on FLINK-26935: Does this ticket depend on FLINK-26439?

[GitHub] [flink] flinkbot edited a comment on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #18151: URL: https://github.com/apache/flink/pull/18151#issuecomment-997659194 ## CI report: * 849140b4515a43a19f74a3b5a38579f0955bf8a4 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink-table-store] LadyForest commented on a change in pull request #66: [FLINK-26898] Introduce creating table document for table store

2022-03-30 Thread GitBox
LadyForest commented on a change in pull request #66: URL: https://github.com/apache/flink-table-store/pull/66#discussion_r838164316 ## File path: docs/content/docs/development/overview.md ## @@ -0,0 +1,114 @@ +--- +title: "Overview" +weight: 1 +type: docs +aliases: +- /develop

[GitHub] [flink] flinkbot commented on pull request #19290: [FLINK-25440][doc][pulsar] Stop and Start cursor now all uses publish…

2022-03-30 Thread GitBox
flinkbot commented on pull request #19290: URL: https://github.com/apache/flink/pull/19290#issuecomment-1084005969 ## CI report: * 722139ee762506b49b5db47e1df30ccc1c5d02bb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

  1   2   3   4   5   6   >