[jira] [Commented] (FLINK-30219) Fetch results api in sql gateway return error result.

2022-11-25 Thread Aiden Gong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638798#comment-17638798 ] Aiden Gong commented on FLINK-30219: Hi , [~Leonard] , I'm willing to fix this issue. Please assign

[jira] [Created] (FLINK-30219) Fetch results api in sql gateway return error result.

2022-11-25 Thread Aiden Gong (Jira)
Aiden Gong created FLINK-30219: -- Summary: Fetch results api in sql gateway return error result. Key: FLINK-30219 URL: https://issues.apache.org/jira/browse/FLINK-30219 Project: Flink Issue

[jira] [Commented] (FLINK-29828) Support to read data from table with given snapshot id

2022-11-25 Thread liwei li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638796#comment-17638796 ] liwei li commented on FLINK-29828: -- hi, [~zjureel] , Why not we use SQL Hints?  IMO, it seems more user

[jira] [Commented] (FLINK-30213) The edge is wrong when the vertex parallelism is changed

2022-11-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638774#comment-17638774 ] Gyula Fora commented on FLINK-30213: The same issue already existed Flink with the reactive scaling

[jira] [Updated] (FLINK-30213) The edge is wrong when the vertex parallelism is changed

2022-11-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30213: --- Attachment: image-2022-11-25-21-58-48-968.png > The edge is wrong when the vertex parallelism is

[GitHub] [flink] gaborgsomogyi commented on pull request #21392: DO_NOT_MERGE FLINK-29710 testing

2022-11-25 Thread GitBox
gaborgsomogyi commented on PR #21392: URL: https://github.com/apache/flink/pull/21392#issuecomment-1327832635 Well, seems like it's in `target/test/data/` for god knows why. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Comment Edited] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

2022-11-25 Thread Krzysztof Chmielewski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638614#comment-17638614 ] Krzysztof Chmielewski edited comment on FLINK-27246 at 11/25/22 7:21 PM:

[jira] [Comment Edited] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

2022-11-25 Thread Krzysztof Chmielewski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638614#comment-17638614 ] Krzysztof Chmielewski edited comment on FLINK-27246 at 11/25/22 7:20 PM:

[GitHub] [flink-connector-mongodb] Jiabao-Sun commented on a diff in pull request #1: [FLINK-6573][connectors/mongodb] Flink MongoDB Connector

2022-11-25 Thread GitBox
Jiabao-Sun commented on code in PR #1: URL: https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1032654791 ## flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoSourceSplitState.java: ## @@ -0,0 +1,46 @@ +/* + * Licensed

[GitHub] [flink-connector-mongodb] Jiabao-Sun commented on a diff in pull request #1: [FLINK-6573][connectors/mongodb] Flink MongoDB Connector

2022-11-25 Thread GitBox
Jiabao-Sun commented on code in PR #1: URL: https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1032653087 ## flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split/MongoSourceSplitReader.java: ## @@ -0,0 +1,33 @@ +/* + *

[GitHub] [flink-connector-mongodb] Jiabao-Sun commented on a diff in pull request #1: [FLINK-6573][connectors/mongodb] Flink MongoDB Connector

2022-11-25 Thread GitBox
Jiabao-Sun commented on code in PR #1: URL: https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1032644671 ## flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSink.java: ## @@ -0,0 +1,132 @@ +/* + * Licensed to

[GitHub] [flink-connector-mongodb] Jiabao-Sun commented on a diff in pull request #1: [FLINK-6573][connectors/mongodb] Flink MongoDB Connector

2022-11-25 Thread GitBox
Jiabao-Sun commented on code in PR #1: URL: https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1032635261 ## flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoConnectorOptions.java: ## @@ -0,0 +1,143 @@ +/* + * Licensed to

[GitHub] [flink-connector-cassandra] zentol commented on a diff in pull request #3: [FLINK-26822] Add Cassandra Source

2022-11-25 Thread GitBox
zentol commented on code in PR #3: URL: https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1032611085 ## flink-connector-cassandra/pom.xml: ## @@ -78,6 +78,12 @@ under the License. provided + +

[GitHub] [flink-connector-mongodb] Jiabao-Sun commented on a diff in pull request #1: [FLINK-6573][connectors/mongodb] Flink MongoDB Connector

2022-11-25 Thread GitBox
Jiabao-Sun commented on code in PR #1: URL: https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1032603066 ## flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableFactory.java: ## @@ -0,0 +1,202 @@ +/* + * Licensed to

[GitHub] [flink-connector-cassandra] RyanSkraba commented on pull request #3: [FLINK-26822] Add Cassandra Source

2022-11-25 Thread GitBox
RyanSkraba commented on PR #3: URL: https://github.com/apache/flink-connector-cassandra/pull/3#issuecomment-1327674570 I'm taking a look! Thanks for the ping :+1: -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Commented] (FLINK-29856) Triggering savepoint does not trigger operator notifyCheckpointComplete

2022-11-25 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638690#comment-17638690 ] Maximilian Michels commented on FLINK-29856: I think the reason why Flink doesn't call

[GitHub] [flink] 1996fanrui commented on pull request #21398: [FLINK-30214][mini_cluster] MiniCluster adapt the jobvertex-parallelism-overrides

2022-11-25 Thread GitBox
1996fanrui commented on PR #21398: URL: https://github.com/apache/flink/pull/21398#issuecomment-1327654213 @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] [Updated] (FLINK-29856) Triggering savepoint does not trigger operator notifyCheckpointComplete

2022-11-25 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-29856: --- Affects Version/s: 1.15.0 > Triggering savepoint does not trigger operator

[jira] [Updated] (FLINK-29987) PartialUpdateITCase.testForeignKeyJo is unstable

2022-11-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29987: --- Labels: pull-request-available (was: ) > PartialUpdateITCase.testForeignKeyJo is unstable

[GitHub] [flink-table-store] Gerrrr opened a new pull request, #404: [FLINK-29987] Use Awaitility in PartialUpdateITCase#testForeignKeyJoin

2022-11-25 Thread GitBox
Ge opened a new pull request, #404: URL: https://github.com/apache/flink-table-store/pull/404 This patch stabilizes `PartialUpdateITCase#testForeignKeyJoin` and introduces a new test dependency - [Awaitility](https://github.com/awaitility/awaitility) that can be conveniently used to

[jira] [Updated] (FLINK-30214) The resource is not enough

2022-11-25 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-30214: Component/s: Runtime / Configuration > The resource is not enough > -- > >

[jira] [Assigned] (FLINK-30054) Move existing Pulsar connector code from Flink repo to dedicated Pulsar repo

2022-11-25 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-30054: -- Assignee: Yufan Sheng > Move existing Pulsar connector code from Flink repo to

[jira] [Updated] (FLINK-30217) Use ListState#update() to replace clear + add mode.

2022-11-25 Thread xljtswf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xljtswf updated FLINK-30217: Component/s: API / DataStream > Use ListState#update() to replace clear + add mode. >

[jira] [Updated] (FLINK-30218) [Kafka Connector] java.lang.OutOfMemoryError: Metaspace

2022-11-25 Thread Lukas Mahl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukas Mahl updated FLINK-30218: --- Description: Hello! I'm running a Flink application on AWS EMR which consumes from a Kafka Topic

[jira] [Created] (FLINK-30218) [Kafka Connector] java.lang.OutOfMemoryError: Metaspace

2022-11-25 Thread Lukas Mahl (Jira)
Lukas Mahl created FLINK-30218: -- Summary: [Kafka Connector] java.lang.OutOfMemoryError: Metaspace Key: FLINK-30218 URL: https://issues.apache.org/jira/browse/FLINK-30218 Project: Flink Issue

[jira] [Created] (FLINK-30217) Use ListState#update() to replace clear + add mode.

2022-11-25 Thread xljtswf (Jira)
xljtswf created FLINK-30217: --- Summary: Use ListState#update() to replace clear + add mode. Key: FLINK-30217 URL: https://issues.apache.org/jira/browse/FLINK-30217 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-30202) DataGeneratorSourceITCase.testGatedRateLimiter failed

2022-11-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-30202: Assignee: Chesnay Schepler > DataGeneratorSourceITCase.testGatedRateLimiter

[jira] [Commented] (FLINK-30213) The edge is wrong when the vertex parallelism is changed

2022-11-25 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638673#comment-17638673 ] Maximilian Michels commented on FLINK-30213: Thanks for reporting this [~fanrui]! I think

[GitHub] [flink-connector-redis-streams] sazzad16 commented on pull request #5: [FLINK-15571][WIP] Add Redis Stream and String sinks

2022-11-25 Thread GitBox
sazzad16 commented on PR #5: URL: https://github.com/apache/flink-connector-redis-streams/pull/5#issuecomment-1327541752 @MartijnVisser Sure. But please understand that it would take some time as at this moment it is difficult to dedicate time. -- This is an automated message from the

[GitHub] [flink-connector-aws] dannycranmer merged pull request #29: [FLINK-29895] Further increase unit test coverage for DynamoDbSink

2022-11-25 Thread GitBox
dannycranmer merged PR #29: URL: https://github.com/apache/flink-connector-aws/pull/29 -- 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] echauchot commented on pull request #21035: [FLINK-29563] Add a timeout in the wait of metrics counter in SourceTestSuiteBase#testSourceMetrics

2022-11-25 Thread GitBox
echauchot commented on PR #21035: URL: https://github.com/apache/flink/pull/21035#issuecomment-1327525295 @zentol what do you want that we do with this PR? Having no safe guard in the test waiting loop seems dangerous to me: during the implementation of a source, it could happen that

[GitHub] [flink] pnowojski commented on a diff in pull request #20137: Just for CI

2022-11-25 Thread GitBox
pnowojski commented on code in PR #20137: URL: https://github.com/apache/flink/pull/20137#discussion_r1032479797 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImpl.java: ## @@ -51,27 +64,46 @@ class

[GitHub] [flink-connector-cassandra] echauchot commented on pull request #3: [FLINK-26822] Add Cassandra Source

2022-11-25 Thread GitBox
echauchot commented on PR #3: URL: https://github.com/apache/flink-connector-cassandra/pull/3#issuecomment-1327516095 R: @zentol R: @RyanSkraba you mentioned that you already started to review this PR (when it was in the main flink repo) car you send your review comments ? -- This

[jira] [Updated] (FLINK-30216) Address tabs/spaces in checkstyle/spotless

2022-11-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30216: --- Labels: pull-request-available (was: ) > Address tabs/spaces in checkstyle/spotless >

[GitHub] [flink-kubernetes-operator] darenwkt opened a new pull request, #453: [FLINK-30216] Improve code quality by standardising tab/spaces in pom…

2022-11-25 Thread GitBox
darenwkt opened a new pull request, #453: URL: https://github.com/apache/flink-kubernetes-operator/pull/453 … files ## What is the purpose of the change This change is to improve the code quality of the repo by standardising tab/spaces based on [flink code style

[jira] [Updated] (FLINK-30216) Address tabs/spaces in checkstyle/spotless

2022-11-25 Thread Daren Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daren Wong updated FLINK-30216: --- Description: The Flink Kubernetes Operator repo has a mix of tabs and spaces, the quality config

[GitHub] [flink] echauchot closed pull request #21073: [FLINK-26822] Add Source for Cassandra connector

2022-11-25 Thread GitBox
echauchot closed pull request #21073: [FLINK-26822] Add Source for Cassandra connector URL: https://github.com/apache/flink/pull/21073 -- 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] echauchot commented on pull request #21073: [FLINK-26822] Add Source for Cassandra connector

2022-11-25 Thread GitBox
echauchot commented on PR #21073: URL: https://github.com/apache/flink/pull/21073#issuecomment-1327500964 Closing, because this PR was moved to the new cassandra dedicated repository: https://github.com/apache/flink-connector-cassandra/pull/3 -- This is an automated message from the

[jira] [Created] (FLINK-30216) Address tabs/spaces in checkstyle/spotless

2022-11-25 Thread Daren Wong (Jira)
Daren Wong created FLINK-30216: -- Summary: Address tabs/spaces in checkstyle/spotless Key: FLINK-30216 URL: https://issues.apache.org/jira/browse/FLINK-30216 Project: Flink Issue Type:

[GitHub] [flink-connector-cassandra] echauchot opened a new pull request, #3: [FLINK-26822] Add Cassandra Source

2022-11-25 Thread GitBox
echauchot opened a new pull request, #3: URL: https://github.com/apache/flink-connector-cassandra/pull/3 This PR is the move of https://github.com/apache/flink/pull/21073 to the cassandra dedicated repo -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink-connector-hbase] zentol commented on a diff in pull request #1: [FLINK-30062][Connectors/HBase] Externalize the existing connector code as is

2022-11-25 Thread GitBox
zentol commented on code in PR #1: URL: https://github.com/apache/flink-connector-hbase/pull/1#discussion_r1032457087 ## pom.xml: ## @@ -0,0 +1,545 @@ + + +http://maven.apache.org/POM/4.0.0; +xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance; +

[jira] [Resolved] (FLINK-12675) Event time synchronization in Kafka consumer

2022-11-25 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-12675. -- Resolution: Won't Fix > Event time synchronization in Kafka consumer >

[jira] [Resolved] (FLINK-10886) Event time synchronization across sources

2022-11-25 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-10886. -- Resolution: Done > Event time synchronization across sources >

[GitHub] [flink] 1996fanrui commented on pull request #21353: [FLINK-30100][checkpointing] Remove the unused CheckpointFailureReason

2022-11-25 Thread GitBox
1996fanrui commented on PR #21353: URL: https://github.com/apache/flink/pull/21353#issuecomment-1327485152 @pnowojski Thanks for your review! -- 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] [Commented] (FLINK-12675) Event time synchronization in Kafka consumer

2022-11-25 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638662#comment-17638662 ] Thomas Weise commented on FLINK-12675: -- Partition/split level alignment is supported with the new

[GitHub] [flink-connector-hbase] zentol commented on pull request #1: [FLINK-30062][Connectors/HBase] Externalize the existing connector code as is

2022-11-25 Thread GitBox
zentol commented on PR #1: URL: https://github.com/apache/flink-connector-hbase/pull/1#issuecomment-1327476765 I'm not surprised that dependency convergence is a pain. It is one of the big reasons why we haven't done it in Flink already. -- This is an automated message from the Apache

[GitHub] [flink-connector-hbase] zentol commented on pull request #1: [FLINK-30062][Connectors/HBase] Externalize the existing connector code as is

2022-11-25 Thread GitBox
zentol commented on PR #1: URL: https://github.com/apache/flink-connector-hbase/pull/1#issuecomment-1327475343 FYI, we'd like to retain the git history. The [externalization guide](https://cwiki.apache.org/confluence/display/FLINK/Externalized+Connector+development) contains some hints to

[GitHub] [flink-connector-aws] zentol commented on a diff in pull request #26: [FLINK-25859][Connectors/DynamoDB][docs] DynamoDB sink documentation

2022-11-25 Thread GitBox
zentol commented on code in PR #26: URL: https://github.com/apache/flink-connector-aws/pull/26#discussion_r1032449534 ## docs/content.zh/docs/connectors/datastream/dynamodb.md: ## @@ -0,0 +1,171 @@ +--- +title: DynamoDB +weight: 5 +type: docs +aliases: +-

[GitHub] [flink-connector-aws] zentol commented on a diff in pull request #26: [FLINK-25859][Connectors/DynamoDB][docs] DynamoDB sink documentation

2022-11-25 Thread GitBox
zentol commented on code in PR #26: URL: https://github.com/apache/flink-connector-aws/pull/26#discussion_r1032447973 ## docs/content.zh/docs/connectors/datastream/dynamodb.md: ## @@ -0,0 +1,171 @@ +--- +title: DynamoDB +weight: 5 +type: docs +aliases: +-

[GitHub] [flink-connector-aws] zentol commented on a diff in pull request #26: [FLINK-25859][Connectors/DynamoDB][docs] DynamoDB sink documentation

2022-11-25 Thread GitBox
zentol commented on code in PR #26: URL: https://github.com/apache/flink-connector-aws/pull/26#discussion_r1032447531 ## docs/content.zh/docs/connectors/table/dynamodb.md: ## @@ -0,0 +1,306 @@ +--- +title: DynamoDB +weight: 5 +type: docs +aliases: +-

[GitHub] [flink] gaborgsomogyi commented on pull request #21391: [FLINK-30194][runtime][security] Rename DelegationTokenProvider to HadoopDelegationTokenProvider

2022-11-25 Thread GitBox
gaborgsomogyi commented on PR #21391: URL: https://github.com/apache/flink/pull/21391#issuecomment-1327467670 @mbalassi success w/ rebase. -- 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-connector-opensearch] reta commented on pull request #1: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors

2022-11-25 Thread GitBox
reta commented on PR #1: URL: https://github.com/apache/flink-connector-opensearch/pull/1#issuecomment-1327467520 @zentol thnaks a lot for the review, I think I addressed all your comments, please let me know if I missed some, thanks! -- This is an automated message from the Apache Git

[GitHub] [flink-web] fapaul merged pull request #581: Add 1.15.3 release

2022-11-25 Thread GitBox
fapaul merged PR #581: URL: https://github.com/apache/flink-web/pull/581 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Closed] (FLINK-30100) Remove the unused CheckpointFailureReason

2022-11-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-30100. -- Assignee: Rui Fan Resolution: Fixed Merged to master as 5e0e0fde630..aa0cd873709 >

[GitHub] [flink] pnowojski merged pull request #21353: [FLINK-30100][checkpointing] Remove the unused CheckpointFailureReason

2022-11-25 Thread GitBox
pnowojski merged PR #21353: URL: https://github.com/apache/flink/pull/21353 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Created] (FLINK-30215) Deprecated Cassandra explicit Scala support

2022-11-25 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-30215: Summary: Deprecated Cassandra explicit Scala support Key: FLINK-30215 URL: https://issues.apache.org/jira/browse/FLINK-30215 Project: Flink Issue

[jira] [Commented] (FLINK-28853) FLIP-217 Support watermark alignment of source splits

2022-11-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638655#comment-17638655 ] Piotr Nowojski commented on FLINK-28853: I think yes, but it looks like [the

[jira] [Updated] (FLINK-28853) FLIP-217 Support watermark alignment of source splits

2022-11-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-28853: --- Release Note: Added support for watermark alignment of source splits. Since Flink 1.17,

[GitHub] [flink-table-store] zjureel commented on pull request #402: [FLINK-29988] Using lower case fields in hive catalog

2022-11-25 Thread GitBox
zjureel commented on PR #402: URL: https://github.com/apache/flink-table-store/pull/402#issuecomment-1327448839 Hi @JingsongLi I try to fix this issue and get some problems Current I convert the database, table and fields names to lower case in `HiveCatalog`, but there will be

[jira] [Closed] (FLINK-27117) FLIP-217: Support watermark alignment of source splits

2022-11-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-27117. -- Resolution: Duplicate > FLIP-217: Support watermark alignment of source splits >

[GitHub] [flink] gaborgsomogyi commented on pull request #21392: DO_NOT_MERGE FLINK-29710 testing

2022-11-25 Thread GitBox
gaborgsomogyi commented on PR #21392: URL: https://github.com/apache/flink/pull/21392#issuecomment-1327436272 Now it's pretty clear that `/__w/1/s/flink-yarn-tests/target/flink-yarn-tests-fifo` dir is never created. Now the question, where is it then :/ -- This is an automated message

[GitHub] [flink] fapaul merged pull request #21399: Update japicmp configuration for 1.15.3

2022-11-25 Thread GitBox
fapaul merged PR #21399: URL: https://github.com/apache/flink/pull/21399 -- 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-docker] fapaul merged pull request #140: Update Dockerfiles for 1.15.3 release

2022-11-25 Thread GitBox
fapaul merged PR #140: URL: https://github.com/apache/flink-docker/pull/140 -- 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] fapaul opened a new pull request, #21399: Update japicmp configuration for 1.15.3

2022-11-25 Thread GitBox
fapaul opened a new pull request, #21399: URL: https://github.com/apache/flink/pull/21399 Update japicmp configuration for 1.15.3, as part of finalizing the release -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink-docker] fapaul opened a new pull request, #140: Update Dockerfiles for 1.15.3 release

2022-11-25 Thread GitBox
fapaul opened a new pull request, #140: URL: https://github.com/apache/flink-docker/pull/140 Updated the docker images taking https://github.com/apache/flink-docker/pull/128 as an example. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink-connector-aws] dannycranmer merged pull request #30: [hotfix][Connectors/AWS] Fix Flink configuration in CI build

2022-11-25 Thread GitBox
dannycranmer merged PR #30: URL: https://github.com/apache/flink-connector-aws/pull/30 -- 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-web] hlteoh37 commented on pull request #584: [FLINK-30156] Add blogpost for the Async sink custom RateLimitingStra…

2022-11-25 Thread GitBox
hlteoh37 commented on PR #584: URL: https://github.com/apache/flink-web/pull/584#issuecomment-1327328405 Agreed offline that additional comments are nits, so will go ahead with current MD! -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink-connector-aws] dannycranmer opened a new pull request, #30: [hotfix][Connectors/AWS] Fix Flink configuration in CI build

2022-11-25 Thread GitBox
dannycranmer opened a new pull request, #30: URL: https://github.com/apache/flink-connector-aws/pull/30 ## What is the purpose of the change - Fix Flink 1.15/1.16 CI build ## Verifying this change - Verified in personal account -- This is an automated message from the

[GitHub] [flink-connector-aws] dannycranmer commented on a diff in pull request #29: [FLINK-29895] Further increase unit test coverage for DynamoDbSink

2022-11-25 Thread GitBox
dannycranmer commented on code in PR #29: URL: https://github.com/apache/flink-connector-aws/pull/29#discussion_r1032260627 ## flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/client/DynamoDbAsyncClientProvider.java: ## @@ -0,0 +1,73 @@ +/* + *

[jira] [Comment Edited] (FLINK-30214) The resource is not enough

2022-11-25 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638616#comment-17638616 ] Rui Fan edited comment on FLINK-30214 at 11/25/22 10:29 AM: Hi [~gyfora] ,

[GitHub] [flink-connector-hbase] ferenc-csaky commented on pull request #1: [FLINK-30062][Connectors/HBase] Externalize the existing connector code as is

2022-11-25 Thread GitBox
ferenc-csaky commented on PR #1: URL: https://github.com/apache/flink-connector-hbase/pull/1#issuecomment-1327297981 Frankly, achieving dependency convergence made dependency management and exclusions quite messy at this point and the main cause of that is some Hadoop dependencies are the

[jira] [Comment Edited] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

2022-11-25 Thread Krzysztof Chmielewski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638614#comment-17638614 ] Krzysztof Chmielewski edited comment on FLINK-27246 at 11/25/22 10:23 AM:

[jira] [Comment Edited] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

2022-11-25 Thread Krzysztof Chmielewski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638614#comment-17638614 ] Krzysztof Chmielewski edited comment on FLINK-27246 at 11/25/22 10:23 AM:

[jira] [Commented] (FLINK-30214) The resource is not enough

2022-11-25 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638616#comment-17638616 ] Rui Fan commented on FLINK-30214: - Hi [~gyfora] , thanks for your quick feedback. I run a flink job in

[GitHub] [flink] flinkbot commented on pull request #21398: [FLINK-30214][mini_cluster] MiniCluster adapt the jobvertex-parallelism-overrides

2022-11-25 Thread GitBox
flinkbot commented on PR #21398: URL: https://github.com/apache/flink/pull/21398#issuecomment-1327289959 ## CI report: * e79c88a8cdbe4d96262754591ed20833b2c0e4b7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Comment Edited] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

2022-11-25 Thread Krzysztof Chmielewski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638614#comment-17638614 ] Krzysztof Chmielewski edited comment on FLINK-27246 at 11/25/22 10:14 AM:

[jira] [Updated] (FLINK-30214) The resource is not enough

2022-11-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30214: --- Labels: pull-request-available (was: ) > The resource is not enough >

[GitHub] [flink] 1996fanrui opened a new pull request, #21398: [FLINK-30214][mini_cluster] MiniCluster adapt the jobvertex-parallelism-overrides

2022-11-25 Thread GitBox
1996fanrui opened a new pull request, #21398: URL: https://github.com/apache/flink/pull/21398 ## What is the purpose of the change When turn up the parallelism, the resources isn't enough for MiniCluster. ## Brief change log MiniCluster adapt the

[jira] [Commented] (FLINK-27246) Code of method "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V" of class "HashAggregateWithKeys$9211" grows beyond 64 KB

2022-11-25 Thread Krzysztof Chmielewski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638614#comment-17638614 ] Krzysztof Chmielewski commented on FLINK-27246: --- Hi [~TsReaper] Im sory for a long delay.

[jira] [Closed] (FLINK-30056) Make polling for metadata no more than specified timeout by using new Consumer#poll(Duration)

2022-11-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-30056. Fix Version/s: 1.17.0 Resolution: Fixed master:

[GitHub] [flink] zentol merged pull request #21150: [FLINK-30056][connectors][kafka] Replace deprecated kafka-clients methods

2022-11-25 Thread GitBox
zentol merged PR #21150: URL: https://github.com/apache/flink/pull/21150 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Closed] (FLINK-30156) [FLIP-242] Blogpost about the customisable RateLimitingStrategy in the AsyncSinkBase

2022-11-25 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-30156. -- Resolution: Fixed > [FLIP-242] Blogpost about the customisable RateLimitingStrategy in the >

[GitHub] [flink] zentol commented on pull request #21394: [BP-1.15][FLINK-26037][coordination] TMRunner waits for metric registry shutdown

2022-11-25 Thread GitBox
zentol commented on PR #21394: URL: https://github.com/apache/flink/pull/21394#issuecomment-1327225053 > Otherwise, we would have seen this error already earlier. Not necessarily though; you just need 1 step of the shutdown procedure being slow enough. -- This is an automated

[GitHub] [flink-connector-redis-streams] eskabetxe commented on pull request #3: [FLINK-15571] Add Redis sink

2022-11-25 Thread GitBox
eskabetxe commented on PR #3: URL: https://github.com/apache/flink-connector-redis-streams/pull/3#issuecomment-1327224834 Hi @MartijnVisser, it's pretty much at a standstill. As it is only for streams it does not fit in our use case and it is difficult to dedicate time to it. Anyway,

[GitHub] [flink] zentol commented on a diff in pull request #21387: [FLINK-30183][metrics] Adds more descriptive error in case no default constructor is present.

2022-11-25 Thread GitBox
zentol commented on code in PR #21387: URL: https://github.com/apache/flink/pull/21387#discussion_r1032178749 ## flink-runtime/src/main/java/org/apache/flink/runtime/metrics/ReporterSetup.java: ## @@ -464,6 +466,21 @@ private static Optional loadViaReflection(

[jira] [Commented] (FLINK-30214) The resource is not enough

2022-11-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638602#comment-17638602 ] Gyula Fora commented on FLINK-30214: Hi [~fanrui], Thanks for jumping on this and testing it.

[GitHub] [flink] LadyForest commented on a diff in pull request #20652: [FLINK-22315][table] Support add/modify column/constraint/watermark for ALTER TABLE statement

2022-11-25 Thread GitBox
LadyForest commented on code in PR #20652: URL: https://github.com/apache/flink/pull/20652#discussion_r1032175300 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlToOperationConverterTest.java: ## @@ -1466,6 +1476,441 @@ public void

[jira] [Assigned] (FLINK-30213) The edge is wrong when the vertex parallelism is changed

2022-11-25 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-30213: -- Assignee: Maximilian Michels > The edge is wrong when the vertex parallelism

[GitHub] [flink-web] rmetzger merged pull request #586: Rebuild website

2022-11-25 Thread GitBox
rmetzger merged PR #586: URL: https://github.com/apache/flink-web/pull/586 -- 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-web] rmetzger commented on pull request #586: Rebuild website

2022-11-25 Thread GitBox
rmetzger commented on PR #586: URL: https://github.com/apache/flink-web/pull/586#issuecomment-1327207647 Thx for the rebuild. My arm mac book is not yet properly setup for rebuilding the website. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] MartijnVisser commented on pull request #21386: [FLINK-30190][FLINK-30191][FLINK-30192][Python] Update cython, py4j and python-dateutil

2022-11-25 Thread GitBox
MartijnVisser commented on PR #21386: URL: https://github.com/apache/flink/pull/21386#issuecomment-1327206680 @HuangXingBo I was expecting that a patch update for py4j would not break anything, but it seems like it does. If you know a quick fix for this, let me know, else I'll drop the

[jira] [Updated] (FLINK-30205) Modify compact interface for TableWrite and FileStoreWrite to support normal compaction in Table Store

2022-11-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30205: --- Labels: pull-request-available (was: ) > Modify compact interface for TableWrite and

[GitHub] [flink-table-store] tsreaper opened a new pull request, #403: [FLINK-30205] Modify compact interface for TableWrite and FileStoreWrite to support normal compaction in Table Store

2022-11-25 Thread GitBox
tsreaper opened a new pull request, #403: URL: https://github.com/apache/flink-table-store/pull/403 Currently the compact interface in `TableWrite` and `FileStoreWrite` can only trigger full compaction. However a separated compact job should not only perform full compaction, but also

[jira] [Commented] (FLINK-30214) The resource is not enough

2022-11-25 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638597#comment-17638597 ] Rui Fan commented on FLINK-30214: - Hi [~gyfora] [~mxm] , please help take a look, thanks~:) > The

[jira] [Created] (FLINK-30214) The resource is not enough

2022-11-25 Thread Rui Fan (Jira)
Rui Fan created FLINK-30214: --- Summary: The resource is not enough Key: FLINK-30214 URL: https://issues.apache.org/jira/browse/FLINK-30214 Project: Flink Issue Type: Bug Reporter: Rui

[GitHub] [flink-connector-redis-streams] MartijnVisser commented on pull request #3: [FLINK-15571] Add Redis sink

2022-11-25 Thread GitBox
MartijnVisser commented on PR #3: URL: https://github.com/apache/flink-connector-redis-streams/pull/3#issuecomment-1327197048 @eskabetxe @sazzad16 Is there any update on this process? Also check out https://cwiki.apache.org/confluence/display/FLINK/Externalized+Connector+development for

[GitHub] [flink-connector-redis-streams] MartijnVisser commented on pull request #5: [FLINK-15571][WIP] Add Redis Stream and String sinks

2022-11-25 Thread GitBox
MartijnVisser commented on PR #5: URL: https://github.com/apache/flink-connector-redis-streams/pull/5#issuecomment-1327196394 @sazzad16 Can you have a look at https://cwiki.apache.org/confluence/display/FLINK/Externalized+Connector+development and update this PR accordingly? -- This

[jira] [Commented] (FLINK-30213) The edge is wrong when the vertex parallelism is changed

2022-11-25 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638589#comment-17638589 ] Rui Fan commented on FLINK-30213: - Hi [~gyfora] [~mxm] , please help take a look, and I can fix this

[GitHub] [flink-web] hlteoh37 opened a new pull request, #586: Rebuild website

2022-11-25 Thread GitBox
hlteoh37 opened a new pull request, #586: URL: https://github.com/apache/flink-web/pull/586 Adding a blogpost for https://github.com/apache/flink-web/commit/0e4b8a20ac88202c8ff5c671014d4c464c86ec8d -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink-connector-cassandra] echauchot commented on pull request #2: [FLINK-29982] move the existing Cassandra connector to external repository

2022-11-25 Thread GitBox
echauchot commented on PR #2: URL: https://github.com/apache/flink-connector-cassandra/pull/2#issuecomment-1327188718 > Couldn't sleep so I just started fixing things myself. Squashed all your changes into a single commit. Thanks Chesnay for the review and the night merge :smile: I

  1   2   >