[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=17515090#comment-17515090 ] Nicholas Jiang commented on FLINK-26938: [~MartijnVisser], could you please assign this ticket

[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:

[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:

[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:

[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:

[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

[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

[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:

[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:

[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:

[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:

[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:

[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:

[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:

[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

[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:

[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:

[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

[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

[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

[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

[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

[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

[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:

[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:

[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=17515045#comment-17515045 ] Liu commented on FLINK-26683: - The most cases I met are that the job is stuck with NoClassDefFoundError for

[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=17515043#comment-17515043 ] Yun Tang commented on FLINK-14998: -- [~jay li] sure, I will assign this ticket to you. [~longwang0616]

[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=17515042#comment-17515042 ] Yun Tang commented on FLINK-26882: -- [~nsemmler], the broken instance

[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=17515041#comment-17515041 ] Yang Wang commented on FLINK-26934: --- Nice talk. Of cause, it deserves to be added to the main page to

[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

[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:

[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:

[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:

[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?

[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

[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

[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

[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

[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

[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:

[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=17515028#comment-17515028 ] Yang Wang edited comment on FLINK-26930 at 3/31/22, 2:36 AM: - I hesitate to

[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=17515028#comment-17515028 ] Yang Wang commented on FLINK-26930: --- I hesitate to store the the last checkpoint path in the HA store,

[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: -

[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=17515024#comment-17515024 ] Nicholas Jiang commented on FLINK-26935: Does this ticket depend on FLINK-26439? > Sort records

[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:

[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: +-

[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

[GitHub] [flink] flinkbot edited a comment on pull request #19289: [BACKPORT]: [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:

[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:

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

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

[GitHub] [flink] imaffe opened a new pull request #19290: [FLINK-25440][doc][pulsar] Stop and Start cursor now all uses publish…

2022-03-30 Thread GitBox
imaffe opened a new pull request #19290: URL: https://github.com/apache/flink/pull/19290 …Time instead of eventTime; doc changed to reflect this change ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob

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

2022-03-30 Thread GitBox
ZhangChaoming commented on a change in pull request #18151: URL: https://github.com/apache/flink/pull/18151#discussion_r839114370 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/table/DataGeneratorConnectorITCase.java

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

2022-03-30 Thread huweihua (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515021#comment-17515021 ] huweihua commented on FLINK-26861: -- Hi, [~chenzihao], Could you provide the log4j2 configuration? Is

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

2022-03-30 Thread GitBox
imaffe opened a new pull request #19289: URL: https://github.com/apache/flink/pull/19289 This is backporting https://github.com/apache/flink/pull/18345 to release-1.14 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[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: * 8f66a1ccecb317f8342dec401e462a31acfe8728 Azure:

[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: * 8f66a1ccecb317f8342dec401e462a31acfe8728 Azure:

[GitHub] [flink] imaffe commented on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-30 Thread GitBox
imaffe commented on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1083990503 > Thanks @imaffe - Will you also create a backport to `release-1.15` or does this only get fixed for 1.16 and onwards? Sure ~ I'll backport to both 1.15 and 1.14 --

[GitHub] [flink] deadwind4 removed a comment on pull request #18454: [hotfix][connector/pulsar] Fix typo in JavaDocs example.

2022-03-30 Thread GitBox
deadwind4 removed a comment on pull request #18454: URL: https://github.com/apache/flink/pull/18454#issuecomment-1020906388 @syhily Could you review this? Thanks a lot. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Commented] (FLINK-18229) Pending worker requests should be properly cleared

2022-03-30 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515017#comment-17515017 ] Xintong Song commented on FLINK-18229: -- Thanks for working on this, [~huwh]. I left a few comments

[jira] [Updated] (FLINK-18229) Pending worker requests should be properly cleared

2022-03-30 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18229: - Fix Version/s: 1.16.0 (was: 1.15.0) > Pending worker requests should be

[jira] [Created] (FLINK-26936) Pushdown watermark to table store source

2022-03-30 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-26936: Summary: Pushdown watermark to table store source Key: FLINK-26936 URL: https://issues.apache.org/jira/browse/FLINK-26936 Project: Flink Issue Type:

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

2022-03-30 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-26935: - Description: Some scenarios need to be strictly ordered, and we can sort the files by sequence

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

2022-03-30 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-26935: Summary: Sort records by sequence number when continuous reading Key: FLINK-26935 URL: https://issues.apache.org/jira/browse/FLINK-26935 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #19286: [FLINK-25931] Add projection pushdown support for CsvFormatFactory

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #19286: URL: https://github.com/apache/flink/pull/19286#issuecomment-1083653731 ## CI report: * ab7e810e56b04ecb49ac8c82360d56fc78aee584 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19288: [hotfix] Fix CsvRowDataDeserializationSchema constructor

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #19288: URL: https://github.com/apache/flink/pull/19288#issuecomment-1083667245 ## CI report: * 816163669c3c41032175ab29be44d4126a516683 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19287: (idea) [FLINK-xxxxx][runtime-web] Improve error message rendering

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #19287: URL: https://github.com/apache/flink/pull/19287#issuecomment-1083653857 ## CI report: * 831201952291b2f8ec10b576cbe0aa294c714ab6 Azure:

[jira] [Updated] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints)

2022-03-30 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10333: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-26052) Update chinese documentation regarding FLIP-203

2022-03-30 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26052: --- Labels: stale-assigned translation-zh (was: translation-zh) I am the [Flink Jira

[jira] [Updated] (FLINK-14098) Support multiple statements for TableEnvironment

2022-03-30 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14098: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned

[GitHub] [flink] flinkbot edited a comment 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
flinkbot edited a comment on pull request #19092: URL: https://github.com/apache/flink/pull/19092#issuecomment-1067660495 ## CI report: * 0cffb7e7049736fbe798cbf4b3c0247a6aa3b9d8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19288: [hotfix] Fix CsvRowDataDeserializationSchema constructor

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #19288: URL: https://github.com/apache/flink/pull/19288#issuecomment-1083667245 ## CI report: * 816163669c3c41032175ab29be44d4126a516683 Azure:

[GitHub] [flink] flinkbot commented on pull request #19288: [hotfix] Fix CsvRowDataDeserializationSchema constructor

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

[GitHub] [flink] afedulov commented on pull request #19255: [hotfix] Fix CsvRowDataDeserializationSchema constructor

2022-03-30 Thread GitBox
afedulov commented on pull request #19255: URL: https://github.com/apache/flink/pull/19255#issuecomment-1083660631 Thanks, @MartijnVisser . Here is the backport PR https://github.com/apache/flink/pull/19288 -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] afedulov opened a new pull request #19288: [hotfix] Fix CsvRowDataDeserializationSchema constructor

2022-03-30 Thread GitBox
afedulov opened a new pull request #19288: URL: https://github.com/apache/flink/pull/19288 The `csvSchema` field was wrongly initialized. -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #19286: [FLINK-25931] Add projection pushdown support for CsvFormatFactory

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #19286: URL: https://github.com/apache/flink/pull/19286#issuecomment-1083653731 ## CI report: * ab7e810e56b04ecb49ac8c82360d56fc78aee584 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19287: (idea) [FLINK-xxxxx][runtime-web] Improve error message rendering

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #19287: URL: https://github.com/apache/flink/pull/19287#issuecomment-1083653857 ## CI report: * 831201952291b2f8ec10b576cbe0aa294c714ab6 Azure:

[GitHub] [flink] flinkbot commented on pull request #19287: (idea) [FLINK-xxxxx][runtime-web] Improve error message rendering

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

[GitHub] [flink] flinkbot commented on pull request #19286: [FLINK-25931] Add projection pushdown support for CsvFormatFactory

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

[GitHub] [flink] rkhachatryan opened a new pull request #19287: (idea) [FLINK-xxxxx][runtime-web] Improve error message rendering

2022-03-30 Thread GitBox
rkhachatryan opened a new pull request #19287: URL: https://github.com/apache/flink/pull/19287 ``` - don't hide after a timeout (was: 4.5s) - expand the message box ``` This allows for example to clearly see what the arguments the program is missing on submission.

[jira] [Updated] (FLINK-25931) Add projection pushdown support for CsvFormatFactory

2022-03-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25931: --- Labels: pull-request-available (was: ) > Add projection pushdown support for

[GitHub] [flink] afedulov opened a new pull request #19286: [FLINK-25931] Add projection pushdown support for CsvFormatFactory

2022-03-30 Thread GitBox
afedulov opened a new pull request #19286: URL: https://github.com/apache/flink/pull/19286 ## What is the purpose of the change FLINK-24703 added support for projection pushdown in CsvFileFormatFactory. This PR adds the same functionality for non-file-based connectors that use

[GitHub] [flink] flinkbot edited a comment on pull request #18541: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors

2022-03-30 Thread GitBox
flinkbot edited a comment on pull request #18541: URL: https://github.com/apache/flink/pull/18541#issuecomment-1023343281 ## CI report: * b0ea656e1010a0b12f98488b179071aa2a8dbdfa Azure:

[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: * 8f66a1ccecb317f8342dec401e462a31acfe8728 Azure:

[GitHub] [flink] MartijnVisser merged pull request #19265: [hotfix][runtime][tests] Modify spelling error in RestServerSSLAuthITCase.java

2022-03-30 Thread GitBox
MartijnVisser merged pull request #19265: URL: https://github.com/apache/flink/pull/19265 -- 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] MartijnVisser commented on pull request #19265: [hotfix][runtime][tests] Modify spelling error in RestServerSSLAuthITCase.java

2022-03-30 Thread GitBox
MartijnVisser commented on pull request #19265: URL: https://github.com/apache/flink/pull/19265#issuecomment-1083574321 CI passed in https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=33958# - Merging this PR -- This is an automated message

[jira] [Closed] (FLINK-26923) SavepointITCase.testStopWithSavepointFailsOverToSavepoint failed on azure

2022-03-30 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-26923. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in: * master **

  1   2   3   4   5   6   >