[jira] [Comment Edited] (FLINK-25756) Dedicated Opensearch connectors

2022-12-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645247#comment-17645247 ] Chesnay Schepler edited comment on FLINK-25756 at 12/9/22 11:19 AM:

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

2022-12-09 Thread GitBox
zentol commented on PR #3: URL: https://github.com/apache/flink-connector-cassandra/pull/3#issuecomment-1344270870 > Is there anything I can do to help the review ? For better or worse, no :) Holidays are coming up so I won't review it this year (:scream:) at the very least.

[GitHub] [flink-connector-opensearch] reta commented on pull request #3: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors (documentation)

2022-12-09 Thread GitBox
reta commented on PR #3: URL: https://github.com/apache/flink-connector-opensearch/pull/3#issuecomment-1344290837 > In the original PR you mentioned this: > > ``` > any mentions and uses of mapping types have been removed: it is deprecated feature, scheduled for removal (the

[GitHub] [flink] twalthr closed pull request #21203: [FLINK-21239][Table SQL/API] Upgrade Calcite to 1.28.0

2022-12-09 Thread GitBox
twalthr closed pull request #21203: [FLINK-21239][Table SQL/API] Upgrade Calcite to 1.28.0 URL: https://github.com/apache/flink/pull/21203 -- 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] [Updated] (FLINK-30352) [Connectors][Elasticsearch] Document missing configuration properties

2022-12-09 Thread Andriy Redko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andriy Redko updated FLINK-30352: - Description: There is a number of configuration properties which are not documented: - 

[GitHub] [flink] snuyanzin commented on a diff in pull request #21478: [FLINK-28352][tests] Disable PulsarSourceUnorderedE2ECase, PulsarUnorderedPartitionSplitReaderTest and PulsarUnorderedSourceITCas

2022-12-09 Thread GitBox
snuyanzin commented on code in PR #21478: URL: https://github.com/apache/flink/pull/21478#discussion_r1044526123 ## flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/PulsarUnorderedSourceITCase.java: ## @@ -32,12 +32,14 @@ import

[jira] [Commented] (FLINK-30325) the column lost comments, also find some issue ,but that commit is not mr. i have some diff solution

2022-12-09 Thread blackpighe (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645189#comment-17645189 ] blackpighe commented on FLINK-30325: ok,i see,thank you > the column lost comments, also find some

[GitHub] [flink] 1996fanrui commented on a diff in pull request #21432: [FLINK-30250][web][flame-graph] Fix the bug that show the flame graph of old type

2022-12-09 Thread GitBox
1996fanrui commented on code in PR #21432: URL: https://github.com/apache/flink/pull/21432#discussion_r1044225732 ## flink-runtime-web/web-dashboard/src/app/pages/job/overview/flamegraph/job-overview-drawer-flamegraph.component.ts: ## @@ -50,12 +50,13 @@ import {

[GitHub] [flink] liyubin117 commented on a diff in pull request #21182: [FLINK-29679][table] Migrate to new schema framework & show column comment

2022-12-09 Thread GitBox
liyubin117 commented on code in PR #21182: URL: https://github.com/apache/flink/pull/21182#discussion_r1044056409 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/typeutils/TimeIndicatorTypeInfo.java: ## @@ -62,13 +61,10 @@ protected

[GitHub] [flink-connector-pulsar] MartijnVisser commented on a diff in pull request #4: [FLINK-30336][BP 3.0] Sync missing e2e tests

2022-12-09 Thread GitBox
MartijnVisser commented on code in PR #4: URL: https://github.com/apache/flink-connector-pulsar/pull/4#discussion_r1044377052 ## .github/workflows/ci.yml: ## @@ -32,6 +32,10 @@ on: required: true type: boolean +concurrency: + group: pr-${{ github.ref }}

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

2022-12-09 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-27246: Affects Version/s: 1.15.3 1.16.0 > Code of method >

[jira] [Commented] (FLINK-30314) Unable to read all records from compressed line-delimited JSON files using Table API

2022-12-09 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645291#comment-17645291 ] Etienne Chauchot commented on FLINK-30314: -- Yes I agree, something needs to be done here. I'll

[GitHub] [flink-connector-opensearch] reta commented on a diff in pull request #3: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors (documentation)

2022-12-09 Thread GitBox
reta commented on code in PR #3: URL: https://github.com/apache/flink-connector-opensearch/pull/3#discussion_r103885 ## docs/content/docs/connectors/datastream/opensearch.md: ## @@ -0,0 +1,328 @@ +--- +title: Opensearch +weight: 5 +type: docs +aliases: + -

[jira] [Commented] (FLINK-30314) Unable to read all records from compressed line-delimited JSON files using Table API

2022-12-09 Thread Dmitry Yaraev (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645326#comment-17645326 ] Dmitry Yaraev commented on FLINK-30314: --- ??We would need to uncompress them to a resilient

[jira] [Commented] (FLINK-23408) Wait for a checkpoint completed after finishing a task

2022-12-09 Thread qiunan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645202#comment-17645202 ] qiunan commented on FLINK-23408: [~dwysakowicz]  Ok, thanks, I'm looking at the code for release-1.14.

[jira] [Commented] (FLINK-30334) SourceCoordinator error splitRequest check cause HybridSource loss of data and hang

2022-12-09 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645220#comment-17645220 ] Zhu Zhu commented on FLINK-30334: - Thanks for volunteering to fix it. [~lemonjing] I have assigned you

[GitHub] [flink] flinkbot commented on pull request #21475: Update over-agg.md

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

[jira] [Updated] (FLINK-29835) NoClassDefFoundError in PulsarSourceUnorderedE2ECase

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

[jira] [Commented] (FLINK-30314) Unable to read all records from compressed line-delimited JSON files using Table API

2022-12-09 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-30314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645228#comment-17645228 ] Matěj Novotný commented on FLINK-30314: --- [~echauchot] But then the Flink should decline to even

[jira] [Updated] (FLINK-30349) Sync missing HBase e2e tests to external repo

2022-12-09 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-30349: --- Priority: Blocker (was: Major) > Sync missing HBase e2e tests to external repo >

[jira] [Commented] (FLINK-25920) Allow receiving updates of CommittableSummary

2022-12-09 Thread Jun Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645234#comment-17645234 ] Jun Qin commented on FLINK-25920: - [~KristoffSC]  I see the three Jiras have been fixed and released in

[jira] [Created] (FLINK-30351) Enable test cases again

2022-12-09 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-30351: - Summary: Enable test cases again Key: FLINK-30351 URL: https://issues.apache.org/jira/browse/FLINK-30351 Project: Flink Issue Type: Sub-task

[GitHub] [flink-connector-pulsar] zentol commented on a diff in pull request #4: [FLINK-30336][BP 3.0] Sync missing e2e tests

2022-12-09 Thread GitBox
zentol commented on code in PR #4: URL: https://github.com/apache/flink-connector-pulsar/pull/4#discussion_r1044400940 ## .github/workflows/push_pr.yml: ## @@ -18,6 +18,11 @@ name: Build flink-connector-pulsar on: [push, pull_request] + +concurrency: + group: ${{

[GitHub] [flink] XComp opened a new pull request, #21480: [FLINK-28352][tests] Disable PulsarSourceUnorderedE2ECase, PulsarUnorderedPartitionSplitReaderTest and PulsarUnorderedSourceITCase

2022-12-09 Thread GitBox
XComp opened a new pull request, #21480: URL: https://github.com/apache/flink/pull/21480 1.15 backport PR for parent PR https://github.com/apache/flink/pull/21478 -- 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] flinkbot commented on pull request #21478: [FLINK-28352][tests] Disable PulsarSourceUnorderedE2ECase, PulsarUnorderedPartitionSplitReaderTest and PulsarUnorderedSourceITCase

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

[GitHub] [flink] flinkbot commented on pull request #21479: [BP-1.16][FLINK-28352][tests] Disable PulsarSourceUnorderedE2ECase, PulsarUnorderedPartitionSplitReaderTest and PulsarUnorderedSourceITCase

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

[GitHub] [flink] flinkbot commented on pull request #21480: [BP-1.15][FLINK-28352][tests] Disable PulsarSourceUnorderedE2ECase, PulsarUnorderedPartitionSplitReaderTest and PulsarUnorderedSourceITCase

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

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

2022-12-09 Thread GitBox
Jiabao-Sun commented on PR #1: URL: https://github.com/apache/flink-connector-mongodb/pull/1#issuecomment-1344276831 Thanks @twalthr for the detailed review. Please help review it again when you have time. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] 1996fanrui commented on pull request #21368: [FLINK-30165][runtime][JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

2022-12-09 Thread GitBox
1996fanrui commented on PR #21368: URL: https://github.com/apache/flink/pull/21368#issuecomment-1344305894 @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] AngluarWilliam opened a new pull request, #21473: Update over-agg.md

2022-12-09 Thread GitBox
AngluarWilliam opened a new pull request, #21473: URL: https://github.com/apache/flink/pull/21473 WINDOW标题对应不对 ## What is the purpose of the change *The title of the article is not placed in the correct position, causing ambiguity* ## Brief change log

[GitHub] [flink] yuzelin commented on a diff in pull request #21141: [FLINK-29742][sql-gateway] Support completing statement in SqlGatewayService.

2022-12-09 Thread GitBox
yuzelin commented on code in PR #21141: URL: https://github.com/apache/flink/pull/21141#discussion_r1044272601 ## flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/SqlGatewayServiceITCase.java: ## @@ -554,6 +554,55 @@ public void

[GitHub] [flink] Aitozi commented on pull request #21316: [FLINK-30019] Remove the unused HiveTableFileInputFormat in hive conn…

2022-12-09 Thread GitBox
Aitozi commented on PR #21316: URL: https://github.com/apache/flink/pull/21316#issuecomment-1344127779 > @Aitozi Could you please rebase the master, and then I'll find a committer help merge. Thanks. thanks, done -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] XComp opened a new pull request, #21478: [FLINK-28352][tests] Disable PulsarSourceUnorderedE2ECase, PulsarUnorderedPartitionSplitReaderTest and PulsarUnorderedSourceITCase

2022-12-09 Thread GitBox
XComp opened a new pull request, #21478: URL: https://github.com/apache/flink/pull/21478 ## What is the purpose of the change These tests cause constant test instabilities. We decided to disable these tests for now to reduce the amount of effort for CI maintenance. FLINK-30351 was

[GitHub] [flink-connector-opensearch] reta commented on a diff in pull request #3: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors (documentation)

2022-12-09 Thread GitBox
reta commented on code in PR #3: URL: https://github.com/apache/flink-connector-opensearch/pull/3#discussion_r1044469621 ## flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchConnectorOptions.java: ## @@ -143,7 +143,7 @@ public class

[GitHub] [flink-connector-opensearch] reta commented on a diff in pull request #3: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors (documentation)

2022-12-09 Thread GitBox
reta commented on code in PR #3: URL: https://github.com/apache/flink-connector-opensearch/pull/3#discussion_r1044510624 ## docs/content/docs/connectors/table/opensearch.md: ## @@ -0,0 +1,286 @@ +--- +title: Opensearch +weight: 7 +type: docs +aliases: + -

[GitHub] [flink-connector-opensearch] reta commented on a diff in pull request #3: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors (documentation)

2022-12-09 Thread GitBox
reta commented on code in PR #3: URL: https://github.com/apache/flink-connector-opensearch/pull/3#discussion_r1044510808 ## docs/content/docs/connectors/table/opensearch.md: ## @@ -0,0 +1,286 @@ +--- +title: Opensearch +weight: 7 +type: docs +aliases: + -

[GitHub] [flink] AngluarWilliam opened a new pull request, #21474: Update over-agg.md

2022-12-09 Thread GitBox
AngluarWilliam opened a new pull request, #21474: URL: https://github.com/apache/flink/pull/21474 WINDOW标题对应不对 ## What is the purpose of the change *The title of the article is not placed in the correct position, causing ambiguity* ## Brief change log

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

2022-12-09 Thread GitBox
echauchot commented on PR #3: URL: https://github.com/apache/flink-connector-cassandra/pull/3#issuecomment-1344284613 > > Is there anything I can do to help the review ? > > For better or worse, no :) > > Holidays are coming up so I won't review it this year (scream) at the

[jira] [Commented] (FLINK-30314) Unable to read all records from compressed line-delimited JSON files using Table API

2022-12-09 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645294#comment-17645294 ] Etienne Chauchot commented on FLINK-30314: -- Actually despite the comment on uncompressed json

[GitHub] [flink] luoyuxia commented on pull request #21316: [FLINK-30019] Remove the unused HiveTableFileInputFormat in hive conn…

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

[GitHub] [flink-connector-opensearch] reta commented on a diff in pull request #3: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors (documentation)

2022-12-09 Thread GitBox
reta commented on code in PR #3: URL: https://github.com/apache/flink-connector-opensearch/pull/3#discussion_r1044469621 ## flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchConnectorOptions.java: ## @@ -143,7 +143,7 @@ public class

[jira] [Commented] (FLINK-30251) Move the IO with DFS during abort checkpoint to an asynchronous thread.

2022-12-09 Thread ming li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645200#comment-17645200 ] ming li commented on FLINK-30251: - [~gaoyunhaii] thanks for your reply. We have tried setting timeout

[jira] [Commented] (FLINK-29755) PulsarSourceUnorderedE2ECase.testSavepoint failed because of missing TaskManagers

2022-12-09 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645201#comment-17645201 ] Sergey Nuyanzin commented on FLINK-29755: - PulsarSourceUnorderedE2ECase.testSourceSingleSplit

[jira] [Assigned] (FLINK-30334) SourceCoordinator error splitRequest check cause HybridSource loss of data and hang

2022-12-09 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-30334: --- Assignee: Ran Tao > SourceCoordinator error splitRequest check cause HybridSource loss of data >

[GitHub] [flink] AngluarWilliam opened a new pull request, #21475: Update over-agg.md

2022-12-09 Thread GitBox
AngluarWilliam opened a new pull request, #21475: URL: https://github.com/apache/flink/pull/21475 WINDOW标题对应不对 ## What is the purpose of the change *The title of the article is not placed in the correct position, causing ambiguity* ## Brief change log

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

2022-12-09 Thread GitBox
Jiabao-Sun commented on code in PR #1: URL: https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1044309412 ## flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter/BsonToRowDataConverters.java: ## @@ -0,0 +1,677 @@ +/* + *

[GitHub] [flink] twalthr commented on pull request #21203: [FLINK-21239][Table SQL/API] Upgrade Calcite to 1.28.0

2022-12-09 Thread GitBox
twalthr commented on PR #21203: URL: https://github.com/apache/flink/pull/21203#issuecomment-1344130597 @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] [Closed] (FLINK-25756) Dedicated Opensearch connectors

2022-12-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-25756. Assignee: Andriy Redko Resolution: Fixed main:

[GitHub] [flink-connector-opensearch] zentol merged pull request #1: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors

2022-12-09 Thread GitBox
zentol merged PR #1: URL: https://github.com/apache/flink-connector-opensearch/pull/1 -- 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] liyubin117 commented on a diff in pull request #21182: [FLINK-29679][table] Migrate to new schema framework & show column comment

2022-12-09 Thread GitBox
liyubin117 commented on code in PR #21182: URL: https://github.com/apache/flink/pull/21182#discussion_r1044056409 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/typeutils/TimeIndicatorTypeInfo.java: ## @@ -62,13 +61,10 @@ protected

[GitHub] [flink] liyubin117 commented on a diff in pull request #21182: [FLINK-29679][table] Migrate to new schema framework & show column comment

2022-12-09 Thread GitBox
liyubin117 commented on code in PR #21182: URL: https://github.com/apache/flink/pull/21182#discussion_r1044056409 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/typeutils/TimeIndicatorTypeInfo.java: ## @@ -62,13 +61,10 @@ protected

[GitHub] [flink-connector-pulsar] zentol commented on a diff in pull request #4: [FLINK-30336][BP 3.0] Sync missing e2e tests

2022-12-09 Thread GitBox
zentol commented on code in PR #4: URL: https://github.com/apache/flink-connector-pulsar/pull/4#discussion_r1044402113 ## pom.xml: ## @@ -45,10 +45,12 @@ under the License. flink-connector-pulsar flink-sql-connector-pulsar +

[GitHub] [flink-connector-pulsar] zentol commented on a diff in pull request #4: [FLINK-30336][BP 3.0] Sync missing e2e tests

2022-12-09 Thread GitBox
zentol commented on code in PR #4: URL: https://github.com/apache/flink-connector-pulsar/pull/4#discussion_r1044401435 ## flink-connector-pulsar-e2e-tests/pom.xml: ## @@ -77,6 +73,49 @@ under the License. + + +

[jira] [Updated] (FLINK-28352) [Umbrella] Make Pulsar connector stable

2022-12-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28352: --- Labels: pull-request-available test-stability (was: test-stability) > [Umbrella] Make

[GitHub] [flink] XComp opened a new pull request, #21479: [FLINK-28352][tests] Disable PulsarSourceUnorderedE2ECase, PulsarUnorderedPartitionSplitReaderTest and PulsarUnorderedSourceITCase

2022-12-09 Thread GitBox
XComp opened a new pull request, #21479: URL: https://github.com/apache/flink/pull/21479 1.16 backport PR for parent PR #21478 -- 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] zentol commented on a diff in pull request #21477: [FLINK-30350][build] Use default location for dependency reduced pom

2022-12-09 Thread GitBox
zentol commented on code in PR #21477: URL: https://github.com/apache/flink/pull/21477#discussion_r1044418411 ## flink-dist/pom.xml: ## @@ -688,9 +688,7 @@ under the License.

[GitHub] [flink-connector-kafka] mas-chen commented on a diff in pull request #1: [FLINK-30052][Connectors/Kafka] Move existing Kafka connector code from Flink repo to dedicated Kafka repo

2022-12-09 Thread GitBox
mas-chen commented on code in PR #1: URL: https://github.com/apache/flink-connector-kafka/pull/1#discussion_r1044425679 ## flink-connector-kafka-e2e-tests/flink-end-to-end-tests-common-kafka/pom.xml: ## @@ -18,230 +18,230 @@ specific language governing permissions and

[GitHub] [flink-connector-kafka] mas-chen commented on a diff in pull request #1: [FLINK-30052][Connectors/Kafka] Move existing Kafka connector code from Flink repo to dedicated Kafka repo

2022-12-09 Thread GitBox
mas-chen commented on code in PR #1: URL: https://github.com/apache/flink-connector-kafka/pull/1#discussion_r1044426268 ## pom.xml: ## @@ -0,0 +1,506 @@ + + +http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd; +

[GitHub] [flink-connector-kafka] mas-chen commented on a diff in pull request #1: [FLINK-30052][Connectors/Kafka] Move existing Kafka connector code from Flink repo to dedicated Kafka repo

2022-12-09 Thread GitBox
mas-chen commented on code in PR #1: URL: https://github.com/apache/flink-connector-kafka/pull/1#discussion_r1044426003 ## flink-sql-connector-kafka/pom.xml: ## @@ -24,20 +24,16 @@ under the License. 4.0.0 - flink-connectors

[jira] [Updated] (FLINK-30352) [Connectors][Elasticsearch] Document missing configuration properties

2022-12-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30352: --- Labels: pull-request-available (was: ) > [Connectors][Elasticsearch] Document missing

[jira] [Commented] (FLINK-23408) Wait for a checkpoint completed after finishing a task

2022-12-09 Thread qiunan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645187#comment-17645187 ] qiunan commented on FLINK-23408: !image-2022-12-09-16-54-05-453.png! [~dwysakowicz] I see that only

[jira] [Closed] (FLINK-30333) Supports lookup a partial-update table

2022-12-09 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30333. --- Resolution: Fixed master: e33f36ff07d13e55d26da81ebbc916d1fe0c2e15 > Supports lookup a

[GitHub] [flink] rovboyko commented on pull request #21406: [FLINK-30088][runtime] Fix excessive state updates for TtlMapState and TtlListState

2022-12-09 Thread GitBox
rovboyko commented on PR #21406: URL: https://github.com/apache/flink/pull/21406#issuecomment-1344101060 @azagrebin , @Myasuka , @Jiayi-Liao , could you please help with code review? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Updated] (FLINK-30340) PulsarUnorderedSourceITCase fails with IllegalStateException

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

[jira] [Created] (FLINK-30350) Write dependency-reduced pom to default directory

2022-12-09 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-30350: Summary: Write dependency-reduced pom to default directory Key: FLINK-30350 URL: https://issues.apache.org/jira/browse/FLINK-30350 Project: Flink

[GitHub] [flink-connector-pulsar] zentol commented on a diff in pull request #4: [FLINK-30336][BP 3.0] Sync missing e2e tests

2022-12-09 Thread GitBox
zentol commented on code in PR #4: URL: https://github.com/apache/flink-connector-pulsar/pull/4#discussion_r1044335086 ## .github/workflows/ci.yml: ## @@ -32,6 +32,10 @@ on: required: true type: boolean +concurrency: + group: pr-${{ github.ref }} Review

[jira] [Updated] (FLINK-30336) Sync missing Pulsar e2e tests to external repo

2022-12-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30336: --- Labels: pull-request-available (was: ) > Sync missing Pulsar e2e tests to external repo >

[GitHub] [flink-connector-pulsar] zentol commented on a diff in pull request #4: [FLINK-30336][BP 3.0] Sync missing e2e tests

2022-12-09 Thread GitBox
zentol commented on code in PR #4: URL: https://github.com/apache/flink-connector-pulsar/pull/4#discussion_r1044335086 ## .github/workflows/ci.yml: ## @@ -32,6 +32,10 @@ on: required: true type: boolean +concurrency: + group: pr-${{ github.ref }} Review

[GitHub] [flink-connector-pulsar] zentol commented on a diff in pull request #4: [FLINK-30336][BP 3.0] Sync missing e2e tests

2022-12-09 Thread GitBox
zentol commented on code in PR #4: URL: https://github.com/apache/flink-connector-pulsar/pull/4#discussion_r1044336405 ## .github/workflows/ci.yml: ## @@ -32,6 +32,10 @@ on: required: true type: boolean +concurrency: + group: pr-${{ github.ref }} Review

[GitHub] [flink] flinkbot commented on pull request #21477: [FLINK-30350][build] Use default location for dependency reduced pom

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

[GitHub] [flink-connector-opensearch] zentol commented on pull request #1: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors

2022-12-09 Thread GitBox
zentol commented on PR #1: URL: https://github.com/apache/flink-connector-opensearch/pull/1#issuecomment-1344181659 ok -- 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-opensearch] reta commented on a diff in pull request #3: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors (documentation)

2022-12-09 Thread GitBox
reta commented on code in PR #3: URL: https://github.com/apache/flink-connector-opensearch/pull/3#discussion_r1044467982 ## docs/content/docs/connectors/table/opensearch.md: ## @@ -0,0 +1,286 @@ +--- +title: Opensearch +weight: 7 +type: docs +aliases: + -

[GitHub] [flink-connector-elasticsearch] reta opened a new pull request, #49: FLINK-30352: [Connectors/Elasticsearch] Document missing configuration properties

2022-12-09 Thread GitBox
reta opened a new pull request, #49: URL: https://github.com/apache/flink-connector-elasticsearch/pull/49 There is a number of configuration properties which are not documented: - sink.delivery-guarantee - connection.request-timeout - connection.timeout - socket.timeout  

[GitHub] [flink-connector-elasticsearch] boring-cyborg[bot] commented on pull request #49: FLINK-30352: [Connectors/Elasticsearch] Document missing configuration properties

2022-12-09 Thread GitBox
boring-cyborg[bot] commented on PR #49: URL: https://github.com/apache/flink-connector-elasticsearch/pull/49#issuecomment-1344371414 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) --

[jira] [Updated] (FLINK-29540) SubQueryAntiJoinTest started to fail after Calcite 1.27

2022-12-09 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-29540: - Parent Issue: FLINK-29932 (was: FLINK-21239) > SubQueryAntiJoinTest started to fail after

[GitHub] [flink-connector-elasticsearch] reta commented on pull request #49: [FLINK-30352] [connectors/elasticsearch] Document missing configuration properties

2022-12-09 Thread GitBox
reta commented on PR #49: URL: https://github.com/apache/flink-connector-elasticsearch/pull/49#issuecomment-1344376924 @zentol please take a look, closing the gap in Elasticsearch configuration documentation, thank you -- This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-29237) RexSimplify can not be removed after update to calcite 1.27

2022-12-09 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-29237: - Parent Issue: FLINK-29932 (was: FLINK-21239) > RexSimplify can not be removed after update to

[jira] [Comment Edited] (FLINK-23408) Wait for a checkpoint completed after finishing a task

2022-12-09 Thread qiunan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645202#comment-17645202 ] qiunan edited comment on FLINK-23408 at 12/9/22 9:15 AM: - [~dwysakowicz]  Ok,

[jira] [Comment Edited] (FLINK-23408) Wait for a checkpoint completed after finishing a task

2022-12-09 Thread qiunan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645202#comment-17645202 ] qiunan edited comment on FLINK-23408 at 12/9/22 9:14 AM: - [~dwysakowicz]  Ok,

[GitHub] [flink-table-store] tsreaper merged pull request #430: [FLINK-30333] Supports lookup a partial-update table

2022-12-09 Thread GitBox
tsreaper merged PR #430: URL: https://github.com/apache/flink-table-store/pull/430 -- 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] AngluarWilliam opened a new pull request, #21476: Update over-agg.md

2022-12-09 Thread GitBox
AngluarWilliam opened a new pull request, #21476: URL: https://github.com/apache/flink/pull/21476 WINDOW标题对应不对 ## What is the purpose of the change *The title of the article is not placed in the correct position, causing ambiguity* ## Brief change log

[jira] [Updated] (FLINK-30334) SourceCoordinator error splitRequest check cause HybridSource loss of data and hang

2022-12-09 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-30334: Fix Version/s: 1.17.0 > SourceCoordinator error splitRequest check cause HybridSource loss of data > and

[jira] [Updated] (FLINK-30334) SourceCoordinator error splitRequest check cause HybridSource loss of data and hang

2022-12-09 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-30334: Fix Version/s: 1.16.1 > SourceCoordinator error splitRequest check cause HybridSource loss of data > and

[jira] [Commented] (FLINK-30314) Unable to read all records from compressed line-delimited JSON files using Table API

2022-12-09 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645221#comment-17645221 ] Etienne Chauchot commented on FLINK-30314: -- [1.15

[jira] [Comment Edited] (FLINK-30314) Unable to read all records from compressed line-delimited JSON files using Table API

2022-12-09 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645221#comment-17645221 ] Etienne Chauchot edited comment on FLINK-30314 at 12/9/22 9:58 AM: ---

[jira] [Comment Edited] (FLINK-30314) Unable to read all records from compressed line-delimited JSON files using Table API

2022-12-09 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645221#comment-17645221 ] Etienne Chauchot edited comment on FLINK-30314 at 12/9/22 9:58 AM: ---

[GitHub] [flink] flinkbot commented on pull request #21473: Update over-agg.md

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

[GitHub] [flink] flinkbot commented on pull request #21474: Update over-agg.md

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

[jira] [Created] (FLINK-30349) Sync missing HBase e2e tests to external repo

2022-12-09 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-30349: -- Summary: Sync missing HBase e2e tests to external repo Key: FLINK-30349 URL: https://issues.apache.org/jira/browse/FLINK-30349 Project: Flink Issue

[GitHub] [flink-connector-opensearch] zentol commented on a diff in pull request #3: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors (documentation)

2022-12-09 Thread GitBox
zentol commented on code in PR #3: URL: https://github.com/apache/flink-connector-opensearch/pull/3#discussion_r1044352277 ## docs/content/docs/connectors/datastream/opensearch.md: ## @@ -0,0 +1,328 @@ +--- +title: Opensearch +weight: 5 +type: docs +aliases: + -

[jira] [Updated] (FLINK-29836) PulsarUnorderedSourceITCase#testMultipleSplits failed due to an expected job restart not happening

2022-12-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29836: -- Summary: PulsarUnorderedSourceITCase#testMultipleSplits failed due to an expected job restart

[GitHub] [flink-connector-rabbitmq] zentol commented on pull request #3: [FLINK-30279] Move existing RabbitMQ connector code from Flink repo to dedicated RabbitMQ repo

2022-12-09 Thread GitBox
zentol commented on PR #3: URL: https://github.com/apache/flink-connector-rabbitmq/pull/3#issuecomment-1344243690 Looks like this is again using the 1.17-SNAPSHOT code instead of 1.16.0. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Updated] (FLINK-30279) Move existing RabbitMQ connector code from Flink repo to dedicated RabbitMQ repo

2022-12-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30279: --- Labels: pull-request-available (was: ) > Move existing RabbitMQ connector code from Flink

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

2022-12-09 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-27246: --- Assignee: Krzysztof Chmielewski > Code of method >

[GitHub] [flink-connector-opensearch] reta commented on a diff in pull request #3: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors (documentation)

2022-12-09 Thread GitBox
reta commented on code in PR #3: URL: https://github.com/apache/flink-connector-opensearch/pull/3#discussion_r100646 ## docs/content/docs/connectors/table/opensearch.md: ## @@ -0,0 +1,286 @@ +--- +title: Opensearch +weight: 7 +type: docs +aliases: + -

[GitHub] [flink-connector-opensearch] reta commented on a diff in pull request #3: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors (documentation)

2022-12-09 Thread GitBox
reta commented on code in PR #3: URL: https://github.com/apache/flink-connector-opensearch/pull/3#discussion_r100312 ## docs/content/docs/connectors/datastream/opensearch.md: ## @@ -0,0 +1,328 @@ +--- +title: Opensearch +weight: 5 +type: docs +aliases: + -

[GitHub] [flink] zentol commented on pull request #21477: [FLINK-30350][build] Use default location for dependency reduced pom

2022-12-09 Thread GitBox
zentol commented on PR #21477: URL: https://github.com/apache/flink/pull/21477#issuecomment-1344365713 @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] [Created] (FLINK-30352) [Connectors][Elasticsearch] Document missing configuration properties

2022-12-09 Thread Andriy Redko (Jira)
Andriy Redko created FLINK-30352: Summary: [Connectors][Elasticsearch] Document missing configuration properties Key: FLINK-30352 URL: https://issues.apache.org/jira/browse/FLINK-30352 Project: Flink

[jira] [Updated] (FLINK-30352) [Connectors][Elasticsearch] Document missing configuration properties

2022-12-09 Thread Andriy Redko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andriy Redko updated FLINK-30352: - Priority: Minor (was: Major) > [Connectors][Elasticsearch] Document missing configuration

[jira] [Updated] (FLINK-30352) [Connectors][Elasticsearch] Document missing configuration properties

2022-12-09 Thread Andriy Redko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andriy Redko updated FLINK-30352: - Description: There is a number of configuration properties which are not documented: -

  1   2   >