[GitHub] [flink] syhily commented on pull request #20565: [BP-1.14][FLINK-27399][Connector/Pulsar] [Connector/Pulsar] Change initial consuming position setting logic for better handle the checkpoint.

2022-08-13 Thread GitBox
syhily commented on PR #20565: URL: https://github.com/apache/flink/pull/20565#issuecomment-1214293751 @PatrickRen Can you help me review this backport 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 abo

[GitHub] [flink] syhily commented on pull request #20564: [BP-1.15][FLINK-27399][Connector/Pulsar] [Connector/Pulsar] Change initial consuming position setting logic for better handle the checkpoint.

2022-08-13 Thread GitBox
syhily commented on PR #20564: URL: https://github.com/apache/flink/pull/20564#issuecomment-1214293729 @PatrickRen Can you help me review this backport 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 abo

[GitHub] [flink] syhily commented on pull request #20565: [BP-1.14][FLINK-27399][Connector/Pulsar] [Connector/Pulsar] Change initial consuming position setting logic for better handle the checkpoint.

2022-08-13 Thread GitBox
syhily commented on PR #20565: URL: https://github.com/apache/flink/pull/20565#issuecomment-1214293046 > Thanks for cherry-picking this patch. One comment is inline. > > Also, I'd like to confirm that you bring the test utils from master to 1.14 for Pulsar Connector tests. Is it right

[GitHub] [flink] syhily commented on a diff in pull request #20565: [BP-1.14][FLINK-27399][Connector/Pulsar] [Connector/Pulsar] Change initial consuming position setting logic for better handle the ch

2022-08-13 Thread GitBox
syhily commented on code in PR #20565: URL: https://github.com/apache/flink/pull/20565#discussion_r945234696 ## flink-connectors/flink-connector-pulsar/pom.xml: ## @@ -36,13 +36,15 @@ under the License. jar - 2.8.0 + 2.9.1 Review C

[GitHub] [flink] ChengkaiYang2022 commented on a diff in pull request #20510: [FLINK-28815][docs] Translate the Real Time Reporting with the Table API page into Chinese

2022-08-13 Thread GitBox
ChengkaiYang2022 commented on code in PR #20510: URL: https://github.com/apache/flink/pull/20510#discussion_r945226488 ## docs/content.zh/docs/try-flink/table_api.md: ## @@ -28,51 +28,49 @@ under the License. # 基于 Table API 实现实时报表 -Apache Flink offers a Table API as a unifi

[GitHub] [flink] ChengkaiYang2022 commented on a diff in pull request #20510: [FLINK-28815][docs] Translate the Real Time Reporting with the Table API page into Chinese

2022-08-13 Thread GitBox
ChengkaiYang2022 commented on code in PR #20510: URL: https://github.com/apache/flink/pull/20510#discussion_r945227294 ## docs/content.zh/docs/try-flink/table_api.md: ## @@ -28,51 +28,49 @@ under the License. # 基于 Table API 实现实时报表 -Apache Flink offers a Table API as a unifi

[GitHub] [flink] ChengkaiYang2022 commented on a diff in pull request #20510: [FLINK-28815][docs] Translate the Real Time Reporting with the Table API page into Chinese

2022-08-13 Thread GitBox
ChengkaiYang2022 commented on code in PR #20510: URL: https://github.com/apache/flink/pull/20510#discussion_r945225617 ## docs/content.zh/docs/try-flink/table_api.md: ## @@ -28,51 +28,49 @@ under the License. # 基于 Table API 实现实时报表 -Apache Flink offers a Table API as a unifi

[GitHub] [flink] tisonkun commented on a diff in pull request #20565: [BP-1.14][FLINK-27399][Connector/Pulsar] [Connector/Pulsar] Change initial consuming position setting logic for better handle the

2022-08-13 Thread GitBox
tisonkun commented on code in PR #20565: URL: https://github.com/apache/flink/pull/20565#discussion_r945217710 ## flink-connectors/flink-connector-pulsar/pom.xml: ## @@ -36,13 +36,15 @@ under the License. jar - 2.8.0 + 2.9.1 Review

[jira] [Updated] (FLINK-28817) NullPointerException in HybridSource when restoring from checkpoint

2022-08-13 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-28817: - Fix Version/s: 1.15.2 > NullPointerException in HybridSource when restoring from checkpoint > --

[GitHub] [flink] tweise merged pull request #20563: [FLINK-28817][connector/common] NullPointerException in HybridSource when restoring from checkpoint

2022-08-13 Thread GitBox
tweise merged PR #20563: URL: https://github.com/apache/flink/pull/20563 -- 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-unsubscr...@flink.apache

[jira] [Updated] (FLINK-22071) LookupTableSource.LookupRuntimeProvider customizes parallelism

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

[jira] [Updated] (FLINK-28910) CDC From Mysql To Hbase Bugs

2022-08-13 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28910: --- Labels: pull-request-available stale-blocker (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-25469) FlinkKafkaProducerITCase.testScaleUpAfterScalingDown fails on AZP

2022-08-13 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25469: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira Bot|https://g

[jira] [Updated] (FLINK-25164) DogStatsD Metrics Reporter

2022-08-13 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25164: --- Labels: auto-deprioritized-major pull-request-available stale-minor (was: auto-deprioritize

[jira] [Updated] (FLINK-27164) ResumeCheckpointManuallyITCase.testExternalizedFSCheckpointsWithLocalRecoveryZookeeper failed on azure

2022-08-13 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27164: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira Bot|https://g

[jira] [Updated] (FLINK-27626) Introduce pre-aggregated merge to table store

2022-08-13 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27626: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink Ji

[jira] [Updated] (FLINK-25211) Elasticsearch connector version compatibility

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

[jira] [Updated] (FLINK-28037) Flink SQL Upsert-Kafka can not support Flink1.14.x

2022-08-13 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28037: --- Labels: flink-connector-kafka stale-assigned upser-kafka (was: flink-connector-kafka upser-

[jira] [Commented] (FLINK-27399) Pulsar connector didn't set start consuming position correctly

2022-08-13 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17579276#comment-17579276 ] Yufan Sheng commented on FLINK-27399: - [~tison] I have backported this fix to 1.14 a

[jira] [Updated] (FLINK-27399) Pulsar connector didn't set start consuming position correctly

2022-08-13 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-27399: Description: The Pulsar connector didn't use the consuming position from the checkpoint. They jus

[jira] [Updated] (FLINK-27399) Pulsar connector didn't set start consuming position correctly

2022-08-13 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-27399: Description: The Pulsar connector didn't use the consuming position from the checkpoint. They jus

[jira] [Updated] (FLINK-27399) Pulsar connector didn't set start consuming position correctly

2022-08-13 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-27399: Description: The Pulsar connector didn't use the consuming position from the checkpoint. They jus

[jira] [Updated] (FLINK-27399) Pulsar connector didn't set start consuming position correctly

2022-08-13 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-27399: Description: The Pulsar connector didn't use the consuming position from the checkpoint. They jus

[jira] [Updated] (FLINK-27399) Pulsar connector didn't set start consuming position correctly

2022-08-13 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-27399: Fix Version/s: 1.15.2 1.14.6 > Pulsar connector didn't set start consuming posi

[jira] [Commented] (FLINK-27917) PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition failed with AssertionError

2022-08-13 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17579272#comment-17579272 ] Yufan Sheng commented on FLINK-27917: - This is the same issue caused by https://gith

[GitHub] [flink] flinkbot commented on pull request #20565: [BP-1.14][FLINK-27399][Connector/Pulsar] [Connector/Pulsar] Change initial consuming position setting logic for better handle the checkpoint

2022-08-13 Thread GitBox
flinkbot commented on PR #20565: URL: https://github.com/apache/flink/pull/20565#issuecomment-1214200811 ## CI report: * 81e73286c6d60c23fdb720acdf414398796b9c92 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] syhily opened a new pull request, #20565: [BP-1.14][FLINK-27399][Connector/Pulsar] [Connector/Pulsar] Change initial consuming position setting logic for better handle the checkpoint.

2022-08-13 Thread GitBox
syhily opened a new pull request, #20565: URL: https://github.com/apache/flink/pull/20565 This is a backport PR for https://github.com/apache/flink/pull/19972. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL ab

[jira] [Commented] (FLINK-23555) Improve common subexpression elimination by using local references

2022-08-13 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17579251#comment-17579251 ] Aitozi commented on FLINK-23555: We also encountered this problem. Currently, the CalcNo

[GitHub] [flink] liuyongvs commented on pull request #20554: [FLINK-28929][table] Add built-in datediff function.

2022-08-13 Thread GitBox
liuyongvs commented on PR #20554: URL: https://github.com/apache/flink/pull/20554#issuecomment-1214152678 @snuyanzin i don't find timestamp with timezone type to construct it ![image](https://user-images.githubusercontent.com/6316753/184495019-39665a1d-590a-47b1-95e2-f9a431527802.png)

[GitHub] [flink] xicm commented on pull request #20562: [FLINK-28950][HBase] Disable HBase2 version check in hbase-default.xml

2022-08-13 Thread GitBox
xicm commented on PR #20562: URL: https://github.com/apache/flink/pull/20562#issuecomment-1214130996 @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 comment. To

[GitHub] [flink] xicm commented on pull request #20562: [FLINK-28950][HBase] Disable HBase2 version check in hbase-default.xml

2022-08-13 Thread GitBox
xicm commented on PR #20562: URL: https://github.com/apache/flink/pull/20562#issuecomment-1214130852 The failed test seems to have nothing to do with this fix. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL ab

[jira] [Updated] (FLINK-25910) Propagate obtained delegation tokens to TaskManagers

2022-08-13 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-25910: -- Labels: pull-request-available (was: pull-request-available stale-assigned) > Propagate obtai

[GitHub] [flink] flinkbot commented on pull request #20564: [BP-1.15][FLINK-27399][Connector/Pulsar] [Connector/Pulsar] Change initial consuming position setting logic for better handle the checkpoint

2022-08-13 Thread GitBox
flinkbot commented on PR #20564: URL: https://github.com/apache/flink/pull/20564#issuecomment-1214101520 ## CI report: * 9baa6e0d3e68d625a0f233fcd207f39d5d441bc6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] syhily opened a new pull request, #20564: [BP-1.15][FLINK-27399][Connector/Pulsar] [Connector/Pulsar] Change initial consuming position setting logic for better handle the checkpoint.

2022-08-13 Thread GitBox
syhily opened a new pull request, #20564: URL: https://github.com/apache/flink/pull/20564 This is a backport PR for https://github.com/apache/flink/pull/19972. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL ab