[GitHub] [flink] Jiayi-Liao commented on pull request #17151: [FLINK-23180] Do not initialize checkpoint base locations when checkp…

Jiayi-Liao commented on pull request #17151: URL: https://github.com/apache/flink/pull/17151#issuecomment-920601219 > > > I think in the end there is no harm doing so, but a the very least the javadoc must be updated. I would even suggest renaming initializeBaseLocations to

[GitHub] [flink] Airblader commented on pull request #17186: [FLINK-16203][table] Support JSON_OBJECT()

Airblader commented on pull request #17186: URL: https://github.com/apache/flink/pull/17186#issuecomment-920601084 @JingsongLi Thanks for taking care of this PR! I squashed the fixup commits now. > This is interesting. Can we create a JIRA to track this issue? We can try to fix

[GitHub] [flink] flinkbot edited a comment on pull request #16798: [FLINK-23651][python] Support RabbitMQ in PyFlink

flinkbot edited a comment on pull request #16798: URL: https://github.com/apache/flink/pull/16798#issuecomment-897826601 ## CI report: * a2de26625d24fb8c554a1f2d286652af75cb1234 Azure:

[jira] [Commented] (FLINK-24300) MultipleInputOperator is running much more slowly in TPCDS

[ https://issues.apache.org/jira/browse/FLINK-24300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17415878#comment-17415878 ] Xintong Song commented on FLINK-24300: -- I'm upgrading this to blocker for now. We can downgrade it

[jira] [Updated] (FLINK-24300) MultipleInputOperator is running much more slowly in TPCDS

[ https://issues.apache.org/jira/browse/FLINK-24300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24300: - Fix Version/s: 1.15.0 1.14.0 > MultipleInputOperator is running much more

[jira] [Updated] (FLINK-24300) MultipleInputOperator is running much more slowly in TPCDS

[ https://issues.apache.org/jira/browse/FLINK-24300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24300: - Priority: Blocker (was: Major) > MultipleInputOperator is running much more slowly in TPCDS >

[jira] [Commented] (FLINK-24197) Streaming File Sink end-to-end test fails with : "RestClientException: [File upload failed.]"

[ https://issues.apache.org/jira/browse/FLINK-24197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17415877#comment-17415877 ] Xintong Song commented on FLINK-24197: --

[jira] [Closed] (FLINK-24218) Translate "UNLOAD Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24218. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: 647103c7111583cdb6ab626d739cdd69ec7fdd06

[GitHub] [flink] wuchong merged pull request #17222: [FLINK-24218][doc]Translate "UNLOAD Statements" page of "SQL" into Ch…

wuchong merged pull request #17222: URL: https://github.com/apache/flink/pull/17222 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot edited a comment on pull request #17293: Update hive_functions.md

flinkbot edited a comment on pull request #17293: URL: https://github.com/apache/flink/pull/17293#issuecomment-920552580 ## CI report: * 365dae20fd07c91a7c4a6d9bb713a7963ccff4fb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17233: FLINK-23949 adapt to Flink1.12

flinkbot edited a comment on pull request #17233: URL: https://github.com/apache/flink/pull/17233#issuecomment-916715178 ## CI report: * fc5f053fdd2896295254a4e18185baff3424640f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17203: [FLINK-22944][state] Optimize writing state changelog

flinkbot edited a comment on pull request #17203: URL: https://github.com/apache/flink/pull/17203#issuecomment-915404842 ## CI report: * 4bd2434f31574c63e93fea17893e4a38dce60f0b Azure:

[jira] [Commented] (FLINK-24305) BatchPandasUDAFITTests.test_over_window_aggregate_function fails on azure

[ https://issues.apache.org/jira/browse/FLINK-24305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17415875#comment-17415875 ] Xintong Song commented on FLINK-24305: -- Thanks for the info, [~dianfu]. I've labeled this as a

[jira] [Commented] (FLINK-24305) BatchPandasUDAFITTests.test_over_window_aggregate_function fails on azure

[ https://issues.apache.org/jira/browse/FLINK-24305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17415874#comment-17415874 ] Xintong Song commented on FLINK-24305: --

[jira] [Commented] (FLINK-24305) BatchPandasUDAFITTests.test_over_window_aggregate_function fails on azure

[ https://issues.apache.org/jira/browse/FLINK-24305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17415872#comment-17415872 ] Dian Fu commented on FLINK-24305: - Thanks [~xtsong], [~hxbks2ks] is currently looking into this issue.

[GitHub] [flink] RocMarshal commented on a change in pull request #17222: [FLINK-24218][doc]Translate "UNLOAD Statements" page of "SQL" into Ch…

RocMarshal commented on a change in pull request #17222: URL: https://github.com/apache/flink/pull/17222#discussion_r709784728 ## File path: docs/content/docs/dev/table/sql/unload.md ## @@ -46,7 +46,7 @@ The following examples show how to run a UNLOAD statement in

[jira] [Created] (FLINK-24306) group by index throw SqlValidatorException

zlzhang0122 created FLINK-24306: --- Summary: group by index throw SqlValidatorException Key: FLINK-24306 URL: https://issues.apache.org/jira/browse/FLINK-24306 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #17233: FLINK-23949 adapt to Flink1.12

flinkbot edited a comment on pull request #17233: URL: https://github.com/apache/flink/pull/17233#issuecomment-916715178 ## CI report: * fc5f053fdd2896295254a4e18185baff3424640f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17205: [FLINK-24168][table-planner] Update MATCH_ROWTIME function which could receive 0 argument or 1 argument

flinkbot edited a comment on pull request #17205: URL: https://github.com/apache/flink/pull/17205#issuecomment-915449441 ## CI report: * 170096fc6b1f13b86f5ceecfad89f8bf61b16181 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17293: Update hive_functions.md

flinkbot edited a comment on pull request #17293: URL: https://github.com/apache/flink/pull/17293#issuecomment-920552580 ## CI report: * 365dae20fd07c91a7c4a6d9bb713a7963ccff4fb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17205: [FLINK-24168][table-planner] Update MATCH_ROWTIME function which could receive 0 argument or 1 argument

flinkbot edited a comment on pull request #17205: URL: https://github.com/apache/flink/pull/17205#issuecomment-915449441 ## CI report: * 170096fc6b1f13b86f5ceecfad89f8bf61b16181 Azure:

[GitHub] [flink] iyupeng commented on pull request #14894: [FLINK-20895][flink-table-planner-blink] support local aggregate push down in blink planner

iyupeng commented on pull request #14894: URL: https://github.com/apache/flink/pull/14894#issuecomment-920562189 @sebastianliu Hello Sebastian, will you continue this work for `local aggregate push down`? We have an implementation of `local aggregate push down` too.

[jira] [Updated] (FLINK-24305) BatchPandasUDAFITTests.test_over_window_aggregate_function fails on azure

[ https://issues.apache.org/jira/browse/FLINK-24305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24305: - Fix Version/s: 1.13.3 1.14.0 >

[jira] [Updated] (FLINK-24305) BatchPandasUDAFITTests.test_over_window_aggregate_function fails on azure

[ https://issues.apache.org/jira/browse/FLINK-24305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24305: - Affects Version/s: 1.14.0 1.13.2 >

[jira] [Commented] (FLINK-24305) BatchPandasUDAFITTests.test_over_window_aggregate_function fails on azure

[ https://issues.apache.org/jira/browse/FLINK-24305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17415855#comment-17415855 ] Xintong Song commented on FLINK-24305: --

[jira] [Assigned] (FLINK-24305) BatchPandasUDAFITTests.test_over_window_aggregate_function fails on azure

[ https://issues.apache.org/jira/browse/FLINK-24305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-24305: Assignee: Huang Xingbo > BatchPandasUDAFITTests.test_over_window_aggregate_function

[GitHub] [flink] flinkbot commented on pull request #17293: Update hive_functions.md

flinkbot commented on pull request #17293: URL: https://github.com/apache/flink/pull/17293#issuecomment-920552580 ## CI report: * 365dae20fd07c91a7c4a6d9bb713a7963ccff4fb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17275: [FLINK-24271][docs] Add document for special char in JSON_VALUE and JSON_QUERY

flinkbot edited a comment on pull request #17275: URL: https://github.com/apache/flink/pull/17275#issuecomment-918884274 ## CI report: * c8ae662e089e841e3c0fd870ca4e01335ef4e871 UNKNOWN * e02b18793c9e4c99afd3b97c72e83d62eb6030de Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17233: FLINK-23949 adapt to Flink1.12

flinkbot edited a comment on pull request #17233: URL: https://github.com/apache/flink/pull/17233#issuecomment-916715178 ## CI report: * fc5f053fdd2896295254a4e18185baff3424640f Azure:

[jira] [Assigned] (FLINK-23827) Fix ModifiedMonotonicity inference for some node

[ https://issues.apache.org/jira/browse/FLINK-23827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-23827: -- Assignee: Shuo Cheng > Fix ModifiedMonotonicity inference for some node >

[GitHub] [flink] flinkbot commented on pull request #17293: Update hive_functions.md

flinkbot commented on pull request #17293: URL: https://github.com/apache/flink/pull/17293#issuecomment-920548477 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] whb-bigdata opened a new pull request #17293: Update hive_functions.md

whb-bigdata opened a new pull request #17293: URL: https://github.com/apache/flink/pull/17293 Should use “loadModule” ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That

[jira] [Updated] (FLINK-24159) document of entropy injection may mislead users

[ https://issues.apache.org/jira/browse/FLINK-24159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-24159: Description: FLINK-9061 incroduce entropy inject to s3 path for better scalability, but in

[GitHub] [flink] flinkbot edited a comment on pull request #17275: [FLINK-24271][docs] Add document for special char in JSON_VALUE and JSON_QUERY

flinkbot edited a comment on pull request #17275: URL: https://github.com/apache/flink/pull/17275#issuecomment-918884274 ## CI report: * c8ae662e089e841e3c0fd870ca4e01335ef4e871 UNKNOWN * e02b18793c9e4c99afd3b97c72e83d62eb6030de Azure:

[jira] [Commented] (FLINK-24274) Wrong parameter order in documentation of State Processor API

[ https://issues.apache.org/jira/browse/FLINK-24274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17415848#comment-17415848 ] Feifan Wang commented on FLINK-24274: - Hi [~sjwiesman], I've submit submitted a pr to master. Is

[GitHub] [flink] Myasuka commented on a change in pull request #17203: [FLINK-22944][state] Optimize writing state changelog

Myasuka commented on a change in pull request #17203: URL: https://github.com/apache/flink/pull/17203#discussion_r709721022 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/restore/ChangelogBackendRestoreOperation.java

[jira] [Commented] (FLINK-24086) Do not re-register SharedStateRegistry to reduce the recovery time of the job

[ https://issues.apache.org/jira/browse/FLINK-24086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17415847#comment-17415847 ] ming li commented on FLINK-24086: - Hi, [~dwysakowicz], I am sorry for not being able to update in time,

[GitHub] [flink] amazingJing commented on pull request #17233: FLINK-23949 adapt to Flink1.12

amazingJing commented on pull request #17233: URL: https://github.com/apache/flink/pull/17233#issuecomment-920540822 @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] flinkbot edited a comment on pull request #17205: [FLINK-24168][table-planner] Update MATCH_ROWTIME function which could receive 0 argument or 1 argument

flinkbot edited a comment on pull request #17205: URL: https://github.com/apache/flink/pull/17205#issuecomment-915449441 ## CI report: * 170096fc6b1f13b86f5ceecfad89f8bf61b16181 Azure:

[GitHub] [flink] Myasuka commented on a change in pull request #17203: [FLINK-22944][state] Optimize writing state changelog

Myasuka commented on a change in pull request #17203: URL: https://github.com/apache/flink/pull/17203#discussion_r709711663 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@

[jira] [Commented] (FLINK-24305) BatchPandasUDAFITTests.test_over_window_aggregate_function fails on azure

[ https://issues.apache.org/jira/browse/FLINK-24305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17415837#comment-17415837 ] Xintong Song commented on FLINK-24305: --

[jira] [Updated] (FLINK-24305) BatchPandasUDAFITTests.test_over_window_aggregate_function fails on azure

[ https://issues.apache.org/jira/browse/FLINK-24305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24305: - Affects Version/s: 1.12.5 > BatchPandasUDAFITTests.test_over_window_aggregate_function fails on

[jira] [Updated] (FLINK-24305) BatchPandasUDAFITTests.test_over_window_aggregate_function fails on azure

[ https://issues.apache.org/jira/browse/FLINK-24305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24305: - Fix Version/s: 1.12.6 > BatchPandasUDAFITTests.test_over_window_aggregate_function fails on

[jira] [Updated] (FLINK-24300) MultipleInputOperator is running much more slowly in TPCDS

[ https://issues.apache.org/jira/browse/FLINK-24300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-24300: - Description: When we are running TPCDS with release 1.14 we find that the job with

[jira] [Updated] (FLINK-24293) Tasks from the same job on a machine share user jar

[ https://issues.apache.org/jira/browse/FLINK-24293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huntercc updated FLINK-24293: - Description: In the current blob storage design, tasks executed by the same TaskExecutor will share

[jira] [Commented] (FLINK-24305) BatchPandasUDAFITTests.test_over_window_aggregate_function fails on azure

[ https://issues.apache.org/jira/browse/FLINK-24305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17415836#comment-17415836 ] Xintong Song commented on FLINK-24305: -- cc [~dian.fu] [~hxbks2ks] >

[jira] [Updated] (FLINK-24293) Tasks from the same job on a machine share user jar

[ https://issues.apache.org/jira/browse/FLINK-24293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huntercc updated FLINK-24293: - Description: In the current blob storage design, tasks executed by the same TaskExecutor will share

[jira] [Commented] (FLINK-24305) BatchPandasUDAFITTests.test_over_window_aggregate_function fails on azure

[ https://issues.apache.org/jira/browse/FLINK-24305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17415835#comment-17415835 ] Xintong Song commented on FLINK-24305: --

[GitHub] [flink] flinkbot edited a comment on pull request #17205: [FLINK-24168][table-planner] Update MATCH_ROWTIME function which could receive 0 argument or 1 argument

flinkbot edited a comment on pull request #17205: URL: https://github.com/apache/flink/pull/17205#issuecomment-915449441 ## CI report: * 170096fc6b1f13b86f5ceecfad89f8bf61b16181 Azure:

[jira] [Updated] (FLINK-24305) BatchPandasUDAFITTests.test_over_window_aggregate_function fails on azure

[ https://issues.apache.org/jira/browse/FLINK-24305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24305: - Priority: Blocker (was: Major) > BatchPandasUDAFITTests.test_over_window_aggregate_function

[jira] [Updated] (FLINK-23054) Correct upsert optimization by upsert keys

[ https://issues.apache.org/jira/browse/FLINK-23054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-23054: - Fix Version/s: 1.13.3 > Correct upsert optimization by upsert keys >

[jira] [Closed] (FLINK-23054) Correct upsert optimization by upsert keys

[ https://issues.apache.org/jira/browse/FLINK-23054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-23054. Resolution: Fixed release-1.13: 2c546e85e922e28f21b2972392622ea2ca30b5cd

[jira] [Commented] (FLINK-22899) ValuesUpsertSinkFunction needs to use global upsert

[ https://issues.apache.org/jira/browse/FLINK-22899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17415833#comment-17415833 ] Jingsong Lee commented on FLINK-22899: -- release-1.13: e17331e9636870d12599e66416b207d16e8e57cf >

[GitHub] [flink] JingsongLi merged pull request #17230: [FLINK-23054][table-blink] Correct upsert optimization by upsert keys

JingsongLi merged pull request #17230: URL: https://github.com/apache/flink/pull/17230 -- 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] cshuo commented on pull request #17230: [FLINK-23054][table-blink] Correct upsert optimization by upsert keys

cshuo commented on pull request #17230: URL: https://github.com/apache/flink/pull/17230#issuecomment-920525293 LGTM, +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

[jira] [Created] (FLINK-24305) BatchPandasUDAFITTests.test_over_window_aggregate_function fails on azure

Xintong Song created FLINK-24305: Summary: BatchPandasUDAFITTests.test_over_window_aggregate_function fails on azure Key: FLINK-24305 URL: https://issues.apache.org/jira/browse/FLINK-24305 Project:

[GitHub] [flink] JingsongLi commented on pull request #17186: [FLINK-16203][table] Support JSON_OBJECT()

JingsongLi commented on pull request #17186: URL: https://github.com/apache/flink/pull/17186#issuecomment-920524614 @Airblader Do you want to squash or keep hotfixs with last `Support JSON_OBJECT` commit? -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Created] (FLINK-24304) ProcessFailureCancelingITCase.testCancelingOnProcessFailure fails due to leader retrieval timeout

Xintong Song created FLINK-24304: Summary: ProcessFailureCancelingITCase.testCancelingOnProcessFailure fails due to leader retrieval timeout Key: FLINK-24304 URL:

[GitHub] [flink] RocMarshal commented on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

RocMarshal commented on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-920520153 Hi, @wuchong . I made some changes in the ITCase part of the PR. Could you help me to review this PR if you have free time? Thank you. -- This is an automated message

[GitHub] [flink] beyond1920 commented on pull request #17205: [FLINK-24168][table-planner] Update MATCH_ROWTIME function which could receive 0 argument or 1 argument

beyond1920 commented on pull request #17205: URL: https://github.com/apache/flink/pull/17205#issuecomment-920515148 @flinkbot run travis -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] flinkbot edited a comment on pull request #16798: [FLINK-23651][python] Support RabbitMQ in PyFlink

flinkbot edited a comment on pull request #16798: URL: https://github.com/apache/flink/pull/16798#issuecomment-897826601 ## CI report: * 79547c7995e297da35a88c28517c2463c9c930c3 Azure:

[jira] [Updated] (FLINK-21765) Remove implementation-specific MetricGroup parents

[ https://issues.apache.org/jira/browse/FLINK-21765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21765: --- Labels: auto-deprioritized-major auto-unassigned stale-assigned starter (was:

[GitHub] [flink] flinkbot edited a comment on pull request #16798: [FLINK-23651][python] Support RabbitMQ in PyFlink

flinkbot edited a comment on pull request #16798: URL: https://github.com/apache/flink/pull/16798#issuecomment-897826601 ## CI report: * 79547c7995e297da35a88c28517c2463c9c930c3 Azure:

[jira] [Updated] (FLINK-24303) SourceCoordinator exception may fail Session Cluster

[ https://issues.apache.org/jira/browse/FLINK-24303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-24303: - Component/s: Connectors / Common > SourceCoordinator exception may fail Session Cluster >

[GitHub] [flink] EelisK commented on a change in pull request #16798: [FLINK-23651][python] Support RabbitMQ in PyFlink

EelisK commented on a change in pull request #16798: URL: https://github.com/apache/flink/pull/16798#discussion_r709608571 ## File path: flink-connectors/flink-connector-rabbitmq/pom.xml ## @@ -92,4 +92,31 @@ under the License. + + +

[jira] [Updated] (FLINK-24303) SourceCoordinator exception may fail Session Cluster

[ https://issues.apache.org/jira/browse/FLINK-24303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-24303: - Description: The SourceCoordinator currently forwards all exceptions from

[GitHub] [flink] flinkbot edited a comment on pull request #17203: [FLINK-22944][state] Optimize writing state changelog

flinkbot edited a comment on pull request #17203: URL: https://github.com/apache/flink/pull/17203#issuecomment-915404842 ## CI report: * a4683e8c521180f39b7714b9884cd71520dac1c6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17238: [FLINK-24233][runtime] Create view reader always on the first PartitionRequest even if request subpartition view fails in order to si

flinkbot edited a comment on pull request #17238: URL: https://github.com/apache/flink/pull/17238#issuecomment-916817365 ## CI report: * 49ee064fd07710fbba08485c8037135f91ad110d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17203: [FLINK-22944][state] Optimize writing state changelog

flinkbot edited a comment on pull request #17203: URL: https://github.com/apache/flink/pull/17203#issuecomment-915404842 ## CI report: * a4683e8c521180f39b7714b9884cd71520dac1c6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17288: [FLINK-24292][connectors/kafka] Use KafkaSink in examples instead of …

flinkbot edited a comment on pull request #17288: URL: https://github.com/apache/flink/pull/17288#issuecomment-919945771 ## CI report: * 7b4aa92287cf00aa2a2b0e82bf5069c868c52c8a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17256: [FLINK-23385][table] Implement COALESCE function

flinkbot edited a comment on pull request #17256: URL: https://github.com/apache/flink/pull/17256#issuecomment-918040209 ## CI report: * 25fb8010703524981f7934402ebe46b266dc551e UNKNOWN * 521bf3c8656aaa4d7c9fc4b213c3e47e0ba95f03 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17204: [FLINK-22942] [sql/planner] Disable UPSERT INTO statement

flinkbot edited a comment on pull request #17204: URL: https://github.com/apache/flink/pull/17204#issuecomment-915424597 ## CI report: * 08737f676be9cb8dd784258b17eb6a92e4b1b715 UNKNOWN * 56a3348b9dd0289aec214280cb304284706b543d UNKNOWN *

[GitHub] [flink] rkhachatryan commented on pull request #17203: [FLINK-22944][state] Optimize writing state changelog

rkhachatryan commented on pull request #17203: URL: https://github.com/apache/flink/pull/17203#issuecomment-920364763 Regarding the tests, there are already in `ChangelogDelegateHashMapTest` and similar, e.g. `testKeyGroupSnapshotRestoreScaleDown`, `testKeyGroupSnapshotRestoreScaleUp`,

[jira] [Updated] (FLINK-24303) SourceCoordinator exception may fail Session Cluster

[ https://issues.apache.org/jira/browse/FLINK-24303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-24303: - Description: The SourceCoordinator currently forwards all exceptions from

[jira] [Created] (FLINK-24303) SourceCoordinator exception may fail Session Cluster

Seth Wiesman created FLINK-24303: Summary: SourceCoordinator exception may fail Session Cluster Key: FLINK-24303 URL: https://issues.apache.org/jira/browse/FLINK-24303 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #17268: [FLINK-24133][core] Network failure test replaced by comment in the code due to high expense of stabilizing such low important test

flinkbot edited a comment on pull request #17268: URL: https://github.com/apache/flink/pull/17268#issuecomment-918320586 ## CI report: * 830515768c30f19fe454fc244ae1d4ba79c50cf2 Azure:

[jira] [Comment Edited] (FLINK-24286) Flink TableEnvironment executesql on IntelliJ leads to Could not find a file system implementation for scheme 's3a'

[ https://issues.apache.org/jira/browse/FLINK-24286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17415710#comment-17415710 ] James Kim edited comment on FLINK-24286 at 9/15/21, 8:08 PM: - [~jark] I've

[jira] [Commented] (FLINK-24286) Flink TableEnvironment executesql on IntelliJ leads to Could not find a file system implementation for scheme 's3a'

[ https://issues.apache.org/jira/browse/FLINK-24286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17415710#comment-17415710 ] James Kim commented on FLINK-24286: --- [~jark] I've created a thread on the mailing list on this issue.

[GitHub] [flink] flinkbot edited a comment on pull request #17292: [FLINK-24274][docs] Wrong parameter order in documentation of State Processor API

flinkbot edited a comment on pull request #17292: URL: https://github.com/apache/flink/pull/17292#issuecomment-920217923 ## CI report: * 5cb9c76088321a3c1e367961d64980a01e031afd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17291: [BP-1.14][FLINK-24292][connectors/kafka] Use KafkaSink in examples instead of FlinkKafkaProducer

flinkbot edited a comment on pull request #17291: URL: https://github.com/apache/flink/pull/17291#issuecomment-920128782 ## CI report: * 812cd8bde4eab0c427020da31b2c0060300a0656 Azure:

[jira] [Commented] (FLINK-24286) Flink TableEnvironment executesql on IntelliJ leads to Could not find a file system implementation for scheme 's3a'

[ https://issues.apache.org/jira/browse/FLINK-24286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17415706#comment-17415706 ] James Kim commented on FLINK-24286: --- Yep, that did the trick. However, now I'm getting a different

[jira] [Commented] (FLINK-24234) [FLIP-171] Byte Based & Time Based Flushing for AsyncSinkBase

[ https://issues.apache.org/jira/browse/FLINK-24234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17415700#comment-17415700 ] Danny Cranmer commented on FLINK-24234: --- Thanks [~CrynetLogistics], I have merged this. Resolving

[jira] [Resolved] (FLINK-24234) [FLIP-171] Byte Based & Time Based Flushing for AsyncSinkBase

[ https://issues.apache.org/jira/browse/FLINK-24234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-24234. --- Resolution: Done > [FLIP-171] Byte Based & Time Based Flushing for AsyncSinkBase >

[GitHub] [flink] dannycranmer merged pull request #17244: [FLINK-24234][connectors] FLIP-171: Adding Time & Byte Size Based Flushing to Async Sink Writer

dannycranmer merged pull request #17244: URL: https://github.com/apache/flink/pull/17244 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot edited a comment on pull request #17286: [FLINK-24281][connectors/kafka] Migrate all format tests from FlinkKafkaProducer to KafkaSink

flinkbot edited a comment on pull request #17286: URL: https://github.com/apache/flink/pull/17286#issuecomment-919857208 ## CI report: * cdc812d630cb4be65fdd2e6d4a53d21abecfc632 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

flinkbot edited a comment on pull request #17229: URL: https://github.com/apache/flink/pull/17229#issuecomment-916519510 ## CI report: * 7d28a7c11daddc37548f4d25b404161bc045a0ea Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17292: [FLINK-24274][docs] Wrong parameter order in documentation of State Processor API

flinkbot edited a comment on pull request #17292: URL: https://github.com/apache/flink/pull/17292#issuecomment-920217923 ## CI report: * 5cb9c76088321a3c1e367961d64980a01e031afd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17275: [FLINK-24271][docs] Add document for special char in JSON_VALUE and JSON_QUERY

flinkbot edited a comment on pull request #17275: URL: https://github.com/apache/flink/pull/17275#issuecomment-918884274 ## CI report: * c8ae662e089e841e3c0fd870ca4e01335ef4e871 UNKNOWN * e02b18793c9e4c99afd3b97c72e83d62eb6030de Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17268: [FLINK-24133][core] Network failure test replaced by comment in the code due to high expense of stabilizing such low important test

flinkbot edited a comment on pull request #17268: URL: https://github.com/apache/flink/pull/17268#issuecomment-918320586 ## CI report: * 530f9c472c1c4861ff0c6c3b751424969a33ed84 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17238: [FLINK-24233][runtime] Create view reader always on the first PartitionRequest even if request subpartition view fails in order to si

flinkbot edited a comment on pull request #17238: URL: https://github.com/apache/flink/pull/17238#issuecomment-916817365 ## CI report: * 0b1e925a05a2eb992ab0396381234ba661ad66c6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

flinkbot edited a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-904541061 ## CI report: * 6d397f18b8f43900da233d017c88ec2c357470bf Azure:

[GitHub] [flink] syhily commented on a change in pull request #17271: [FLINK-23969][connector/pulsar] Create e2e tests for pulsar connector.

syhily commented on a change in pull request #17271: URL: https://github.com/apache/flink/pull/17271#discussion_r709410737 ## File path:

[GitHub] [flink] syhily edited a comment on pull request #17271: [FLINK-23969][connector/pulsar] Create e2e tests for pulsar connector.

syhily edited a comment on pull request #17271: URL: https://github.com/apache/flink/pull/17271#issuecomment-920228041 @fapaul @dawidwys It seems that all the E2E tests were passed on Java 8 and 11. All the review issues should be resolved. Can we merge this into Flink 1.14.0 release? The

[GitHub] [flink] syhily commented on pull request #17271: [FLINK-23969][connector/pulsar] Create e2e tests for pulsar connector.

syhily commented on pull request #17271: URL: https://github.com/apache/flink/pull/17271#issuecomment-920228041 It seems that all the E2E tests were passed on Java 8 and 11. I think that the code condition matches the review requirements. Can we merge this into Flink 1.14.0 release? The

[GitHub] [flink] syhily commented on a change in pull request #17271: [FLINK-23969][connector/pulsar] Create e2e tests for pulsar connector.

syhily commented on a change in pull request #17271: URL: https://github.com/apache/flink/pull/17271#discussion_r709410737 ## File path:

[jira] [Created] (FLINK-24302) Direct buffer memory leak on Pulsar connector with Java 11

Yufan Sheng created FLINK-24302: --- Summary: Direct buffer memory leak on Pulsar connector with Java 11 Key: FLINK-24302 URL: https://issues.apache.org/jira/browse/FLINK-24302 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #17292: [FLINK-24274][docs] Wrong parameter order in documentation of State Processor API

flinkbot commented on pull request #17292: URL: https://github.com/apache/flink/pull/17292#issuecomment-920217923 ## CI report: * 5cb9c76088321a3c1e367961d64980a01e031afd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17268: [FLINK-24133][core] Network failure test replaced by comment in the code due to high expense of stabilizing such low important test

flinkbot edited a comment on pull request #17268: URL: https://github.com/apache/flink/pull/17268#issuecomment-918320586 ## CI report: * 530f9c472c1c4861ff0c6c3b751424969a33ed84 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17256: [FLINK-23385][table] Implement COALESCE function

flinkbot edited a comment on pull request #17256: URL: https://github.com/apache/flink/pull/17256#issuecomment-918040209 ## CI report: * 25fb8010703524981f7934402ebe46b266dc551e UNKNOWN * 07e698c121920399ea16be34674219d3d8b0e5d9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17238: [FLINK-24233][runtime] Create view reader always on the first PartitionRequest even if request subpartition view fails in order to si

flinkbot edited a comment on pull request #17238: URL: https://github.com/apache/flink/pull/17238#issuecomment-916817365 ## CI report: * 0b1e925a05a2eb992ab0396381234ba661ad66c6 Azure:

  1   2   3   4   >