[GitHub] [flink-table-store] SteNicholas commented on pull request #290: [FLINK-29252]Support create table-store table with 'connector'='table-store'

2022-09-09 Thread GitBox
SteNicholas commented on PR #290: URL: https://github.com/apache/flink-table-store/pull/290#issuecomment-124262 @MOBIN-F, why not create table with table store catalog for users? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Assigned] (FLINK-29217) CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testConcurrentCheckpoint failed with AssertionFailedError

2022-09-09 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-29217: Assignee: Yunfeng Zhou >

[jira] [Updated] (FLINK-29217) CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testConcurrentCheckpoint failed with AssertionFailedError

2022-09-09 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-29217: - Affects Version/s: (was: 1.16.0) >

[jira] [Updated] (FLINK-29217) CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testConcurrentCheckpoint failed with AssertionFailedError

2022-09-09 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-29217: - Affects Version/s: 1.16.0 >

[jira] [Resolved] (FLINK-29217) CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testConcurrentCheckpoint failed with AssertionFailedError

2022-09-09 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved FLINK-29217. -- Resolution: Fixed >

[GitHub] [flink] godfreyhe commented on pull request #20705: [FLINK-29113][table-planner] throw exception when finding at least one invalid table name in join hints

2022-09-09 Thread GitBox
godfreyhe commented on PR #20705: URL: https://github.com/apache/flink/pull/20705#issuecomment-1242601133 @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

[jira] [Closed] (FLINK-29120) Unexpected join hint propagation into view

2022-09-09 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-29120. -- Resolution: Fixed Fixed in master: 6722c89d0df35643dde38c1b8f096aa785579884 in 1.16:

[GitHub] [flink] lindong28 merged pull request #20780: [FLINK-29217][tests] Guarantee checkpoint order in OC test

2022-09-09 Thread GitBox
lindong28 merged PR #20780: URL: https://github.com/apache/flink/pull/20780 -- 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] lindong28 commented on pull request #20780: [FLINK-29217][tests] Guarantee checkpoint order in OC test

2022-09-09 Thread GitBox
lindong28 commented on PR #20780: URL: https://github.com/apache/flink/pull/20780#issuecomment-1242599858 Thanks for the PR! LGTM. -- 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] lindong28 merged pull request #20781: [FLINK-29217][tests] Guarantee checkpoint order in OC test

2022-09-09 Thread GitBox
lindong28 merged PR #20781: URL: https://github.com/apache/flink/pull/20781 -- 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] lindong28 commented on pull request #20781: [FLINK-29217][tests] Guarantee checkpoint order in OC test

2022-09-09 Thread GitBox
lindong28 commented on PR #20781: URL: https://github.com/apache/flink/pull/20781#issuecomment-1242599797 Thanks for the PR! LGTM. -- 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] godfreyhe closed pull request #20697: [FLINK-29120][table-planner] avoid join hint propagating into view

2022-09-09 Thread GitBox
godfreyhe closed pull request #20697: [FLINK-29120][table-planner] avoid join hint propagating into view URL: https://github.com/apache/flink/pull/20697 -- 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

[GitHub] [flink] godfreyhe commented on a diff in pull request #20697: [FLINK-29120][table-planner] avoid join hint propagating into view

2022-09-09 Thread GitBox
godfreyhe commented on code in PR #20697: URL: https://github.com/apache/flink/pull/20697#discussion_r967568026 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/calcite/FlinkPlannerImpl.scala: ## @@ -193,17 +193,22 @@ class FlinkPlannerImpl(

[GitHub] [flink] chenyuzhi459 commented on pull request #20782: [FLINK-29195] Expose lastCheckpointId metric

2022-09-09 Thread GitBox
chenyuzhi459 commented on PR #20782: URL: https://github.com/apache/flink/pull/20782#issuecomment-1242585969 @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

[jira] [Comment Edited] (FLINK-28765) Create a doc for protobuf format

2022-09-09 Thread Hui Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17602592#comment-17602592 ] Hui Yang edited comment on FLINK-28765 at 9/10/22 1:04 AM: --- [~maosuhan] does

[jira] [Commented] (FLINK-28765) Create a doc for protobuf format

2022-09-09 Thread Hui Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17602592#comment-17602592 ] Hui Yang commented on FLINK-28765: -- [~maosuhan] does this change support accessing the nested object in

[jira] [Comment Edited] (FLINK-29252) Support create table-store table with 'connector'='table-store'

2022-09-09 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17602591#comment-17602591 ] Yubin Li edited comment on FLINK-29252 at 9/10/22 1:00 AM: --- According to flip

[jira] [Comment Edited] (FLINK-29252) Support create table-store table with 'connector'='table-store'

2022-09-09 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17602591#comment-17602591 ] Yubin Li edited comment on FLINK-29252 at 9/10/22 1:00 AM: --- According to flip

[jira] [Comment Edited] (FLINK-29252) Support create table-store table with 'connector'='table-store'

2022-09-09 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17602591#comment-17602591 ] Yubin Li edited comment on FLINK-29252 at 9/10/22 12:58 AM: According to

[jira] [Commented] (FLINK-29252) Support create table-store table with 'connector'='table-store'

2022-09-09 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17602591#comment-17602591 ] Yubin Li commented on FLINK-29252: -- Accounding to flip

[GitHub] [flink] snuyanzin commented on pull request #19916: [FLINK-27936][tests] Migrate flink-connector-cassandra to JUnit5

2022-09-09 Thread GitBox
snuyanzin commented on PR #19916: URL: https://github.com/apache/flink/pull/19916#issuecomment-1242399223 @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

[GitHub] [flink] snuyanzin commented on pull request #19916: [FLINK-27936][tests] Migrate flink-connector-cassandra to JUnit5

2022-09-09 Thread GitBox
snuyanzin commented on PR #19916: URL: https://github.com/apache/flink/pull/19916#issuecomment-1242399019 The [CI test failure](https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=40870=logs=ae4f8708-9994-57d3-c2d7-b892156e7812=0c940707-2659-5648-cbe6-a1ad63045f0a) is

[jira] [Updated] (FLINK-29252) Support create table-store table with 'connector'='table-store'

2022-09-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29252: --- Labels: pull-request-available (was: ) > Support create table-store table with

[jira] [Updated] (FLINK-29252) Support create table-store table with 'connector'='table-store'

2022-09-09 Thread MOBIN (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] MOBIN updated FLINK-29252: -- Description: Support create table-store table with 'connector'='table-store':  sink to table-store:

[GitHub] [flink-table-store] MOBIN-F opened a new pull request, #290: [FLINK-29252]Support create table-store table with 'connector'='table-store'

2022-09-09 Thread GitBox
MOBIN-F opened a new pull request, #290: URL: https://github.com/apache/flink-table-store/pull/290 [[FLINK-29252]](https://issues.apache.org/jira/browse/FLINK-29252)Support create table-store table with 'connector'='table-store' sink to table-store: ``` SET

[jira] [Created] (FLINK-29252) Support create table-store table with 'connector'='table-store'

2022-09-09 Thread MOBIN (Jira)
MOBIN created FLINK-29252: - Summary: Support create table-store table with 'connector'='table-store' Key: FLINK-29252 URL: https://issues.apache.org/jira/browse/FLINK-29252 Project: Flink Issue

[GitHub] [flink] flinkbot commented on pull request #20805: [FLINK-29198][test] Fail after maximum RetryOnException

2022-09-09 Thread GitBox
flinkbot commented on PR #20805: URL: https://github.com/apache/flink/pull/20805#issuecomment-1242302020 ## CI report: * 8edd9917b3e520f1fc78faa799afddd480b56bad UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-29198) RetryExtension doesn't make the test fail if the retries are exhausted

2022-09-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29198: --- Labels: pull-request-available starter (was: starter) > RetryExtension doesn't make the

[GitHub] [flink] RyanSkraba opened a new pull request, #20805: [FLINK-29198][test] Fail after maximum RetryOnException

2022-09-09 Thread GitBox
RyanSkraba opened a new pull request, #20805: URL: https://github.com/apache/flink/pull/20805 ## What is the purpose of the change This pull request causes tests annotated with `@RetryOnException` to fail after the given number of retries when used with the JUnit5

[GitHub] [flink] snuyanzin commented on a diff in pull request #19928: [FLINK-27937][tests][pubsub] Migrate flink-connectors-gcp-pubsub to JUnit 5

2022-09-09 Thread GitBox
snuyanzin commented on code in PR #19928: URL: https://github.com/apache/flink/pull/19928#discussion_r967316371 ## flink-connectors/flink-connector-gcp-pubsub/src/test/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSourceTest.java: ## @@ -66,13 +65,17 @@ public

[GitHub] [flink] snuyanzin commented on pull request #20802: [BP-1.15][FLINK-29223][coordination] Add missing output info for jobs already reached terminal state

2022-09-09 Thread GitBox
snuyanzin commented on PR #20802: URL: https://github.com/apache/flink/pull/20802#issuecomment-1242217513 rebased because it seems the PR was based on a bit old branch and it faces issue https://issues.apache.org/jira/browse/FLINK-29161 there is in logs ``` The command 'docker

[GitHub] [flink] XComp commented on pull request #20803: [BP-1.16][FLINK-29223][coordination] Add missing output info for jobs already reached terminal state

2022-09-09 Thread GitBox
XComp commented on PR #20803: URL: https://github.com/apache/flink/pull/20803#issuecomment-1242202047 @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.

[jira] [Commented] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

2022-09-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17602462#comment-17602462 ] Matthias Pohl commented on FLINK-24119: --- Here, {{KafkaITCase.testOneToOneSources}} fails with the

[GitHub] [flink] XComp commented on pull request #20803: [BP-1.16][FLINK-29223][coordination] Add missing output info for jobs already reached terminal state

2022-09-09 Thread GitBox
XComp commented on PR #20803: URL: https://github.com/apache/flink/pull/20803#issuecomment-1242201763 I reported the ci failure in FLINK-24119 -- 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] stevenzwu commented on a diff in pull request #20757: [FLINK-27919] Add FLIP-27-based source for data generation (FLIP-238)

2022-09-09 Thread GitBox
stevenzwu commented on code in PR #20757: URL: https://github.com/apache/flink/pull/20757#discussion_r967254247 ## flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/RateLimiter.java: ## @@ -22,8 +22,14 @@ import java.util.concurrent.CompletionStage;

[GitHub] [flink-connector-dynamodb] MartijnVisser commented on pull request #2: [FLINK-29246] Adding skeleton project files and checkstyle configuration

2022-09-09 Thread GitBox
MartijnVisser commented on PR #2: URL: https://github.com/apache/flink-connector-dynamodb/pull/2#issuecomment-1242194889 I would recommend to also include the CI setup from https://github.com/apache/flink-connector-elasticsearch/blob/main/.github/workflows/ci.yml to this PR -- This is

[GitHub] [flink] stevenzwu commented on a diff in pull request #20757: [FLINK-27919] Add FLIP-27-based source for data generation (FLIP-238)

2022-09-09 Thread GitBox
stevenzwu commented on code in PR #20757: URL: https://github.com/apache/flink/pull/20757#discussion_r967254247 ## flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/RateLimiter.java: ## @@ -22,8 +22,14 @@ import java.util.concurrent.CompletionStage;

[GitHub] [flink] stevenzwu commented on a diff in pull request #20757: [FLINK-27919] Add FLIP-27-based source for data generation (FLIP-238)

2022-09-09 Thread GitBox
stevenzwu commented on code in PR #20757: URL: https://github.com/apache/flink/pull/20757#discussion_r967254247 ## flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/RateLimiter.java: ## @@ -22,8 +22,14 @@ import java.util.concurrent.CompletionStage;

[GitHub] [flink] gaborgsomogyi commented on pull request #18118: [FLINK-24907] Support side out late data for interval join

2022-09-09 Thread GitBox
gaborgsomogyi commented on PR #18118: URL: https://github.com/apache/flink/pull/18118#issuecomment-1242138640 @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] afedulov commented on a diff in pull request #20757: [FLINK-27919] Add FLIP-27-based source for data generation (FLIP-238)

2022-09-09 Thread GitBox
afedulov commented on code in PR #20757: URL: https://github.com/apache/flink/pull/20757#discussion_r967214051 ## flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/RateLimiter.java: ## @@ -22,8 +22,14 @@ import java.util.concurrent.CompletionStage; /**

[jira] [Created] (FLINK-29251) Send CREATED status and Cancel event via FlinkResourceListener

2022-09-09 Thread Matyas Orhidi (Jira)
Matyas Orhidi created FLINK-29251: - Summary: Send CREATED status and Cancel event via FlinkResourceListener Key: FLINK-29251 URL: https://issues.apache.org/jira/browse/FLINK-29251 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #20804: [FLINK-29248][rpc] Remove RpcService#fenceRpcServer

2022-09-09 Thread GitBox
flinkbot commented on PR #20804: URL: https://github.com/apache/flink/pull/20804#issuecomment-1242061922 ## CI report: * 8867b28a4ecfab78e925815ff95723803e9cc6de UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-29248) Remove RpcService#fenceRpcServer

2022-09-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29248: --- Labels: pull-request-available (was: ) > Remove RpcService#fenceRpcServer >

[GitHub] [flink] zentol opened a new pull request, #20804: [FLINK-29248][rpc] Remove RpcService#fenceRpcServer

2022-09-09 Thread GitBox
zentol opened a new pull request, #20804: URL: https://github.com/apache/flink/pull/20804 Unused. -- 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] zentol commented on a diff in pull request #20757: [FLINK-27919] Add FLIP-27-based source for data generation (FLIP-238)

2022-09-09 Thread GitBox
zentol commented on code in PR #20757: URL: https://github.com/apache/flink/pull/20757#discussion_r967018774 ## flink-core/src/main/java/org/apache/flink/api/connector/source/lib/DataGeneratorSource.java: ## @@ -0,0 +1,211 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink-connector-dynamodb] mrapcooper commented on a diff in pull request #2: [FLINK-29246] Adding skeleton project files and checkstyle configuration

2022-09-09 Thread GitBox
mrapcooper commented on code in PR #2: URL: https://github.com/apache/flink-connector-dynamodb/pull/2#discussion_r967088578 ## tools/maven/checkstyle.xml: ## @@ -0,0 +1,567 @@ + + +http://www.puppycrawl.com/dtds/configuration_1_3.dtd;> + + + + + + + +

[jira] [Updated] (FLINK-29246) Setup DynamoDB Connector Project Structure

2022-09-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29246: - Component/s: Connectors / DynamoDB > Setup DynamoDB Connector Project Structure >

[jira] [Created] (FLINK-29250) Remove RpcService#getTerminationFuture

2022-09-09 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29250: Summary: Remove RpcService#getTerminationFuture Key: FLINK-29250 URL: https://issues.apache.org/jira/browse/FLINK-29250 Project: Flink Issue Type:

[jira] [Created] (FLINK-29249) Remove RpcService#execute/scheduleRunnable

2022-09-09 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29249: Summary: Remove RpcService#execute/scheduleRunnable Key: FLINK-29249 URL: https://issues.apache.org/jira/browse/FLINK-29249 Project: Flink Issue

[jira] [Updated] (FLINK-29246) Setup DynamoDB Connector Project Structure

2022-09-09 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-29246: -- Fix Version/s: dynamodb-1.0.0 > Setup DynamoDB Connector Project Structure >

[jira] [Created] (FLINK-29248) Remove RpcService#fenceRpcServer

2022-09-09 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29248: Summary: Remove RpcService#fenceRpcServer Key: FLINK-29248 URL: https://issues.apache.org/jira/browse/FLINK-29248 Project: Flink Issue Type:

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

2022-09-09 Thread GitBox
liuyongvs commented on PR #20747: URL: https://github.com/apache/flink/pull/20747#issuecomment-1241975551 hi @twalthr do you have time to review it? thanks very much! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Created] (FLINK-29247) Streamline RpcService interface

2022-09-09 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29247: Summary: Streamline RpcService interface Key: FLINK-29247 URL: https://issues.apache.org/jira/browse/FLINK-29247 Project: Flink Issue Type:

[GitHub] [flink] chenyuzhi459 commented on pull request #18118: [FLINK-24907] Support side out late data for interval join

2022-09-09 Thread GitBox
chenyuzhi459 commented on PR #18118: URL: https://github.com/apache/flink/pull/18118#issuecomment-1241975184 @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] chenyuzhi459 commented on pull request #18118: [FLINK-24907] Support side out late data for interval join

2022-09-09 Thread GitBox
chenyuzhi459 commented on PR #18118: URL: https://github.com/apache/flink/pull/18118#issuecomment-1241970987 > @MartijnVisser expected something like this. @chenyuzhi459 could you do a rebase to the latest master please? Ok, I have rebased it. -- This is an automated message from

[jira] [Updated] (FLINK-29246) Setup DynamoDB Connector Project Structure

2022-09-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29246: --- Labels: pull-request-available (was: ) > Setup DynamoDB Connector Project Structure >

[GitHub] [flink] mxm commented on pull request #20485: [FLINK-28853][connector-base] Add FLIP-217 support for watermark alignment of source splits

2022-09-09 Thread GitBox
mxm commented on PR #20485: URL: https://github.com/apache/flink/pull/20485#issuecomment-1241967274 @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-connector-dynamodb] dannycranmer opened a new pull request, #2: [FLINK-29246] Adding skeleton project files and checkstyle configuration

2022-09-09 Thread GitBox
dannycranmer opened a new pull request, #2: URL: https://github.com/apache/flink-connector-dynamodb/pull/2 ## What is the purpose of the change Adding the baseline project structure, Maven pom files and checkstyle configuration ## Brief change log * Added parent,

[GitHub] [flink] mxm commented on pull request #20485: [FLINK-28853][connector-base] Add FLIP-217 support for watermark alignment of source splits

2022-09-09 Thread GitBox
mxm commented on PR #20485: URL: https://github.com/apache/flink/pull/20485#issuecomment-1241965210 (Rebased) -- 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

[jira] [Updated] (FLINK-29067) Replace deprecated Calcite's SqlParser#configBuilder with SqlParser#config

2022-09-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29067: -- Affects Version/s: 1.17.0 > Replace deprecated Calcite's SqlParser#configBuilder with

[jira] [Resolved] (FLINK-29067) Replace deprecated Calcite's SqlParser#configBuilder with SqlParser#config

2022-09-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-29067. --- Resolution: Fixed master: 3a91ded289105684e107dfaf462159974d89456c > Replace deprecated

[GitHub] [flink] XComp merged pull request #20663: [FLINK-29067][Table SQL/API] Replace deprecated SqlParser#configBuilder with SqlParser#config

2022-09-09 Thread GitBox
XComp merged PR #20663: URL: https://github.com/apache/flink/pull/20663 -- 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 commented on pull request #20803: [BP-1.16][FLINK-29223][coordination] Add missing output info for jobs already reached terminal state

2022-09-09 Thread GitBox
flinkbot commented on PR #20803: URL: https://github.com/apache/flink/pull/20803#issuecomment-1241957567 ## CI report: * 0d0619b388a43cd92a07982c2064a627b762c302 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-29245) Remove RetryRule

2022-09-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17602326#comment-17602326 ] Matthias Pohl commented on FLINK-29245: --- [~snuyanzin]  pointed outthat I missed a few usages of

[GitHub] [flink] flinkbot commented on pull request #20802: [BP-1.15][FLINK-29223][coordination] Add missing output info for jobs already reached terminal state

2022-09-09 Thread GitBox
flinkbot commented on PR #20802: URL: https://github.com/apache/flink/pull/20802#issuecomment-1241957405 ## CI report: * 62b26914d4259408402d61e2d29c23249ef033e6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-29245) Remove RetryRule

2022-09-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29245: -- Parent: FLINK-25325 Issue Type: Sub-task (was: Bug) > Remove RetryRule >

[GitHub] [flink] gaborgsomogyi commented on pull request #18118: [FLINK-24907] Support side out late data for interval join

2022-09-09 Thread GitBox
gaborgsomogyi commented on PR #18118: URL: https://github.com/apache/flink/pull/18118#issuecomment-1241954824 @MartijnVisser expected something like this. @chenyuzhi459 could you do a rebase to the latest master please? -- This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-29245) Remove RetryRule

2022-09-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29245: -- Description: With the transition to JUnit5, using

[GitHub] [flink] snuyanzin commented on pull request #20787: [FLINK-29223][coordination] Add missing output info for jobs already reached terminal state

2022-09-09 Thread GitBox
snuyanzin commented on PR #20787: URL: https://github.com/apache/flink/pull/20787#issuecomment-1241953487 backports 1.15: https://github.com/apache/flink/pull/20802 1.16: https://github.com/apache/flink/pull/20803 -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] snuyanzin opened a new pull request, #20803: [BP-1.16][FLINK-29223][coordination] Add missing output info for jobs already reached terminal state

2022-09-09 Thread GitBox
snuyanzin opened a new pull request, #20803: URL: https://github.com/apache/flink/pull/20803 BP of https://github.com/apache/flink/pull/20787 on release-1.16 -- 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] snuyanzin opened a new pull request, #20802: [BP-1.16][FLINK-29223][coordination] Add missing output info for jobs already reached terminal state

2022-09-09 Thread GitBox
snuyanzin opened a new pull request, #20802: URL: https://github.com/apache/flink/pull/20802 BP of https://github.com/apache/flink/pull/20787 on release-1.16 -- 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] [Commented] (FLINK-27388) PulsarSourceEnumeratorTest#discoverPartitionsTriggersAssignments seems flaky

2022-09-09 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17602319#comment-17602319 ] Zili Chen commented on FLINK-27388: --- The cherry-pick PR batches changes among multiple JIRA tickets, I

[jira] [Updated] (FLINK-27388) PulsarSourceEnumeratorTest#discoverPartitionsTriggersAssignments seems flaky

2022-09-09 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-27388: -- Fix Version/s: 1.16.0 > PulsarSourceEnumeratorTest#discoverPartitionsTriggersAssignments seems flaky

[jira] [Commented] (FLINK-27388) PulsarSourceEnumeratorTest#discoverPartitionsTriggersAssignments seems flaky

2022-09-09 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17602318#comment-17602318 ] Zili Chen commented on FLINK-27388: --- master via d92ef3bc00c4c1c6ea3bb5228f2bc6bedcdcc585 >

[jira] [Assigned] (FLINK-29246) Setup DynamoDB Connector Project Structure

2022-09-09 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-29246: - Assignee: Danny Cranmer > Setup DynamoDB Connector Project Structure >

[jira] [Updated] (FLINK-29246) Setup DynamoDB Connector Project Structure

2022-09-09 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-29246: -- Description: Setup initial project structure for

[jira] [Created] (FLINK-29246) Setup DynamoDB Connector Project Structure

2022-09-09 Thread Danny Cranmer (Jira)
Danny Cranmer created FLINK-29246: - Summary: Setup DynamoDB Connector Project Structure Key: FLINK-29246 URL: https://issues.apache.org/jira/browse/FLINK-29246 Project: Flink Issue Type:

[GitHub] [flink] tisonkun commented on pull request #20792: [BK-1.16][FLINK-28934][Connector/pulsar] Fix split assignment for different Pulsar subscriptions

2022-09-09 Thread GitBox
tisonkun commented on PR #20792: URL: https://github.com/apache/flink/pull/20792#issuecomment-1241934021 @HuangXingBo I'm unsure whether this is OK to backport. Could you help with reviewing the impact? I'd checked that it's correct. @syhily and I will answer any question you're

[GitHub] [flink] MartijnVisser commented on pull request #18118: [FLINK-24907] Support side out late data for interval join

2022-09-09 Thread GitBox
MartijnVisser commented on PR #18118: URL: https://github.com/apache/flink/pull/18118#issuecomment-1241933229 @gaborgsomogyi The PR needs to be rebated since it doesn't contains the latest necessary changes to run the CI -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] tisonkun merged pull request #20725: [FLINK-28934][Connector/pulsar] Fix split assignment for different Pulsar subscriptions

2022-09-09 Thread GitBox
tisonkun merged PR #20725: URL: https://github.com/apache/flink/pull/20725 -- 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] tisonkun commented on pull request #20725: [FLINK-28934][Connector/pulsar] Fix split assignment for different Pulsar subscriptions

2022-09-09 Thread GitBox
tisonkun commented on PR #20725: URL: https://github.com/apache/flink/pull/20725#issuecomment-1241932361 Meriging... @guoweiM you're welcome to do a review after merge and leave comments. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot commented on pull request #20801: [BK-1.14][FLINK-28934][Connector/pulsar] Fix split assignment for different Pulsar subscriptions

2022-09-09 Thread GitBox
flinkbot commented on PR #20801: URL: https://github.com/apache/flink/pull/20801#issuecomment-1241928572 ## CI report: * 6f13a90f14307b1b43b80c6b6c39d083cc42dcf9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] syhily opened a new pull request, #20801: [BK-1.14][FLINK-28934][Connector/pulsar] Fix split assignment for different Pulsar subscriptions

2022-09-09 Thread GitBox
syhily opened a new pull request, #20801: URL: https://github.com/apache/flink/pull/20801 This is a backport PR for https://github.com/apache/flink/pull/20725. -- 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] zentol commented on a diff in pull request #20757: [FLINK-27919] Add FLIP-27-based source for data generation (FLIP-238)

2022-09-09 Thread GitBox
zentol commented on code in PR #20757: URL: https://github.com/apache/flink/pull/20757#discussion_r967018774 ## flink-core/src/main/java/org/apache/flink/api/connector/source/lib/DataGeneratorSource.java: ## @@ -0,0 +1,211 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink] zentol commented on a diff in pull request #20757: [FLINK-27919] Add FLIP-27-based source for data generation (FLIP-238)

2022-09-09 Thread GitBox
zentol commented on code in PR #20757: URL: https://github.com/apache/flink/pull/20757#discussion_r967017774 ## flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/RateLimiter.java: ## @@ -22,8 +22,14 @@ import java.util.concurrent.CompletionStage; /**

[GitHub] [flink] XComp commented on pull request #20663: [FLINK-29067][Table SQL/API] Replace deprecated SqlParser#configBuilder with SqlParser#config

2022-09-09 Thread GitBox
XComp commented on PR #20663: URL: https://github.com/apache/flink/pull/20663#issuecomment-1241912821 The [CI test failure](https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=40843=logs=0c940707-2659-5648-cbe6-a1ad63045f0a=075c2716-8010-5565-fe08-3c4bb45824a4) is most

[GitHub] [flink] afedulov commented on a diff in pull request #20757: [FLINK-27919] Add FLIP-27-based source for data generation (FLIP-238)

2022-09-09 Thread GitBox
afedulov commented on code in PR #20757: URL: https://github.com/apache/flink/pull/20757#discussion_r967008954 ## flink-core/src/main/java/org/apache/flink/api/connector/source/lib/DataGeneratorSource.java: ## @@ -0,0 +1,211 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink] afedulov commented on a diff in pull request #20757: [FLINK-27919] Add FLIP-27-based source for data generation (FLIP-238)

2022-09-09 Thread GitBox
afedulov commented on code in PR #20757: URL: https://github.com/apache/flink/pull/20757#discussion_r966978513 ## flink-core/src/main/java/org/apache/flink/api/connector/source/lib/DataGeneratorSource.java: ## @@ -0,0 +1,211 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink] snuyanzin commented on pull request #20663: [FLINK-29067][Table SQL/API] Replace deprecated SqlParser#configBuilder with SqlParser#config

2022-09-09 Thread GitBox
snuyanzin commented on PR #20663: URL: https://github.com/apache/flink/pull/20663#issuecomment-1241906749 @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

[GitHub] [flink] zentol commented on a diff in pull request #20757: [FLINK-27919] Add FLIP-27-based source for data generation (FLIP-238)

2022-09-09 Thread GitBox
zentol commented on code in PR #20757: URL: https://github.com/apache/flink/pull/20757#discussion_r967001455 ## flink-core/src/main/java/org/apache/flink/api/connector/source/lib/DataGeneratorSource.java: ## @@ -0,0 +1,211 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink] zentol commented on a diff in pull request #20757: [FLINK-27919] Add FLIP-27-based source for data generation (FLIP-238)

2022-09-09 Thread GitBox
zentol commented on code in PR #20757: URL: https://github.com/apache/flink/pull/20757#discussion_r967001455 ## flink-core/src/main/java/org/apache/flink/api/connector/source/lib/DataGeneratorSource.java: ## @@ -0,0 +1,211 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink] gaborgsomogyi commented on pull request #18118: [FLINK-24907] Support side out late data for interval join

2022-09-09 Thread GitBox
gaborgsomogyi commented on PR #18118: URL: https://github.com/apache/flink/pull/18118#issuecomment-1241894363 Seems like there is a permanent issue w/ jenkins: ``` E: Unsupported file ./libssl1.0.0_1.0.2n-1ubuntu5.7_amd64.deb given on commandline ``` -- This is an automated

[GitHub] [flink] chenyuzhi459 commented on pull request #20782: [FLINK-29195] Expose lastCheckpointId metric

2022-09-09 Thread GitBox
chenyuzhi459 commented on PR #20782: URL: https://github.com/apache/flink/pull/20782#issuecomment-1241883718 @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] chenyuzhi459 commented on a diff in pull request #20782: [FLINK-29195] Expose lastCheckpointId metric

2022-09-09 Thread GitBox
chenyuzhi459 commented on code in PR #20782: URL: https://github.com/apache/flink/pull/20782#discussion_r966981014 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTrackerTest.java: ## @@ -461,6 +467,7 @@ public > G gauge(String name, G gauge)

[GitHub] [flink] chenyuzhi459 commented on a diff in pull request #20782: [FLINK-29195] Expose lastCheckpointId metric

2022-09-09 Thread GitBox
chenyuzhi459 commented on code in PR #20782: URL: https://github.com/apache/flink/pull/20782#discussion_r966980348 ## docs/content/docs/ops/metrics.md: ## @@ -1292,6 +1292,11 @@ Note that for failed checkpoints, metrics are updated on a best efforts basis an The

[GitHub] [flink] afedulov commented on a diff in pull request #20757: [FLINK-27919] Add FLIP-27-based source for data generation (FLIP-238)

2022-09-09 Thread GitBox
afedulov commented on code in PR #20757: URL: https://github.com/apache/flink/pull/20757#discussion_r966978513 ## flink-core/src/main/java/org/apache/flink/api/connector/source/lib/DataGeneratorSource.java: ## @@ -0,0 +1,211 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink] afedulov commented on a diff in pull request #20757: [FLINK-27919] Add FLIP-27-based source for data generation (FLIP-238)

2022-09-09 Thread GitBox
afedulov commented on code in PR #20757: URL: https://github.com/apache/flink/pull/20757#discussion_r966971092 ## flink-core/src/main/java/org/apache/flink/api/connector/source/lib/DataGeneratorSource.java: ## @@ -0,0 +1,211 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink] afedulov commented on a diff in pull request #20757: [FLINK-27919] Add FLIP-27-based source for data generation (FLIP-238)

2022-09-09 Thread GitBox
afedulov commented on code in PR #20757: URL: https://github.com/apache/flink/pull/20757#discussion_r966971092 ## flink-core/src/main/java/org/apache/flink/api/connector/source/lib/DataGeneratorSource.java: ## @@ -0,0 +1,211 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink] afedulov commented on a diff in pull request #20757: [FLINK-27919] Add FLIP-27-based source for data generation (FLIP-238)

2022-09-09 Thread GitBox
afedulov commented on code in PR #20757: URL: https://github.com/apache/flink/pull/20757#discussion_r966967561 ## flink-core/src/main/java/org/apache/flink/api/connector/source/lib/DataGeneratorSource.java: ## @@ -0,0 +1,211 @@ +/* + * Licensed to the Apache Software Foundation

[jira] [Closed] (FLINK-29218) ADD JAR syntax could not work with Hive catalog in SQL client

2022-09-09 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu closed FLINK-29218. - Resolution: Won't Fix > ADD JAR syntax could not work with Hive catalog in SQL client >

  1   2   >