[GitHub] [flink] flinkbot edited a comment on pull request #17645: [FLINK-24667][runtime] Fix error handling in ChannelStateCheckpointWriter

flinkbot edited a comment on pull request #17645: URL: https://github.com/apache/flink/pull/17645#issuecomment-957822962 ## CI report: * b3688cf3f05ac4ef7ae74acb0c992d3f1d60a340 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-24793) DefaultSchedulerLocalRecoveryITCase fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-24793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440264#comment-17440264 ] Till Rohrmann commented on FLINK-24793: --- Another instance: https://dev.azure.com/

[jira] [Commented] (FLINK-24738) Fail during announcing buffer size to released local channel

[ https://issues.apache.org/jira/browse/FLINK-24738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440261#comment-17440261 ] Dawid Wysakowicz commented on FLINK-24738: -- Merged in: * master ** 138e83e2bc6f

[jira] [Commented] (FLINK-24763) ParquetFileSystemITCase.testLimitableBulkFormat failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440260#comment-17440260 ] Till Rohrmann commented on FLINK-24763: --- Another instance: https://dev.azure.com/

[jira] [Updated] (FLINK-24738) Fail during announcing buffer size to released local channel

[ https://issues.apache.org/jira/browse/FLINK-24738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-24738: - Fix Version/s: 1.15.0 > Fail during announcing buffer size to released local channel > -

[jira] [Commented] (FLINK-24764) pyflink/table/tests/test_udf.py hang on Azure

[ https://issues.apache.org/jira/browse/FLINK-24764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440257#comment-17440257 ] Till Rohrmann commented on FLINK-24764: --- Another instance: https://dev.azure.com/

[jira] [Commented] (FLINK-24764) pyflink/table/tests/test_udf.py hang on Azure

[ https://issues.apache.org/jira/browse/FLINK-24764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440258#comment-17440258 ] Till Rohrmann commented on FLINK-24764: --- cc [~dianfu] can you take a look? > pyfl

[jira] [Updated] (FLINK-24764) pyflink/table/tests/test_udf.py hang on Azure

[ https://issues.apache.org/jira/browse/FLINK-24764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-24764: -- Affects Version/s: 1.15.0 > pyflink/table/tests/test_udf.py hang on Azure > --

[GitHub] [flink] flinkbot edited a comment on pull request #17700: [FLINK-24773][kafka] Fail job if unhandled exception occurs during committing

flinkbot edited a comment on pull request #17700: URL: https://github.com/apache/flink/pull/17700#issuecomment-961972204 ## CI report: * 228e5a9f2d227c5311ad12af866a16c8ba58c80b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] dawidwys merged pull request #17663: [FLINK-24738][runtime] Ignoring buffer size announcement if the channel is released already

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

[GitHub] [flink] flinkbot edited a comment on pull request #17645: [FLINK-24667][runtime] Fix error handling in ChannelStateCheckpointWriter

flinkbot edited a comment on pull request #17645: URL: https://github.com/apache/flink/pull/17645#issuecomment-957822962 ## CI report: * b3688cf3f05ac4ef7ae74acb0c992d3f1d60a340 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17653: FLINK SQL checkpoint不生效

flinkbot edited a comment on pull request #17653: URL: https://github.com/apache/flink/pull/17653#issuecomment-958686553 ## CI report: * 237fb3a04e81602238b87ffc24423fc6f4cfe0ce Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-24806) RMQSourceITCase.testStopWithSavepoint and testAckFailure failed on azure due to connection error

[ https://issues.apache.org/jira/browse/FLINK-24806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-24806: -- Fix Version/s: 1.14.1 1.13.4 > RMQSourceITCase.testStopWithSavepoint and te

[jira] [Updated] (FLINK-24806) RMQSourceITCase.testStopWithSavepoint and testAckFailure failed on azure due to connection error

[ https://issues.apache.org/jira/browse/FLINK-24806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-24806: -- Affects Version/s: 1.14.0 1.13.3 > RMQSourceITCase.testStopWithSavepoin

[jira] [Assigned] (FLINK-24806) RMQSourceITCase.testStopWithSavepoint and testAckFailure failed on azure due to connection error

[ https://issues.apache.org/jira/browse/FLINK-24806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-24806: - Assignee: Michał Ciesielczyk > RMQSourceITCase.testStopWithSavepoint and testAckFailure

[jira] [Updated] (FLINK-24806) RMQSourceITCase.testStopWithSavepoint and testAckFailure failed on azure due to connection error

[ https://issues.apache.org/jira/browse/FLINK-24806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-24806: -- Fix Version/s: 1.15.0 > RMQSourceITCase.testStopWithSavepoint and testAckFailure failed on azu

[jira] [Comment Edited] (FLINK-24806) RMQSourceITCase.testStopWithSavepoint and testAckFailure failed on azure due to connection error

[ https://issues.apache.org/jira/browse/FLINK-24806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440255#comment-17440255 ] Till Rohrmann edited comment on FLINK-24806 at 11/8/21, 7:54 AM: -

[jira] [Commented] (FLINK-24806) RMQSourceITCase.testStopWithSavepoint and testAckFailure failed on azure due to connection error

[ https://issues.apache.org/jira/browse/FLINK-24806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440255#comment-17440255 ] Till Rohrmann commented on FLINK-24806: --- [~cmick] sure, I'll assign the ticket to

[GitHub] [flink] dawidwys commented on pull request #17645: [FLINK-24667][runtime] Fix error handling in ChannelStateCheckpointWriter

dawidwys commented on pull request #17645: URL: https://github.com/apache/flink/pull/17645#issuecomment-962894828 @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] flinkbot edited a comment on pull request #17699: [FLINK-20370][table] Fix wrong results when sink primary key is not the same with query result's changelog upsert key

flinkbot edited a comment on pull request #17699: URL: https://github.com/apache/flink/pull/17699#issuecomment-961963701 ## CI report: * 8c7a80e8f57029838eb0be04ae27fa0d64001ff4 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #17700: [FLINK-24773][kafka] Fail job if unhandled exception occurs during committing

flinkbot edited a comment on pull request #17700: URL: https://github.com/apache/flink/pull/17700#issuecomment-961972204 ## CI report: * 228e5a9f2d227c5311ad12af866a16c8ba58c80b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-24806) RMQSourceITCase.testStopWithSavepoint and testAckFailure failed on azure due to connection error

[ https://issues.apache.org/jira/browse/FLINK-24806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440254#comment-17440254 ] Till Rohrmann commented on FLINK-24806: --- Another instance: https://dev.azure.com/

[GitHub] [flink] flinkbot edited a comment on pull request #17653: FLINK SQL checkpoint不生效

flinkbot edited a comment on pull request #17653: URL: https://github.com/apache/flink/pull/17653#issuecomment-958686553 ## CI report: * 237fb3a04e81602238b87ffc24423fc6f4cfe0ce Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Comment Edited] (FLINK-24401) TM cannot exit after Metaspace OOM

[ https://issues.apache.org/jira/browse/FLINK-24401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440253#comment-17440253 ] Piotr Nowojski edited comment on FLINK-24401 at 11/8/21, 7:52 AM:

[jira] [Closed] (FLINK-24401) TM cannot exit after Metaspace OOM

[ https://issues.apache.org/jira/browse/FLINK-24401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-24401. -- Fix Version/s: 1.15.0 Resolution: Fixed Merged to master/release-1.14/release-1.13 as

[GitHub] [flink] pnowojski merged pull request #17668: [FLINK-24401][runtime] Fix the bug of TM cannot exit after Metaspace OOM

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

[jira] [Commented] (FLINK-24077) HBaseConnectorITCase.testTableSink

[ https://issues.apache.org/jira/browse/FLINK-24077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440243#comment-17440243 ] Till Rohrmann commented on FLINK-24077: --- cc [~arvid], [~twalthr] > HBaseConnector

[jira] [Commented] (FLINK-24789) IllegalStateException with CheckpointCleaner being closed already

[ https://issues.apache.org/jira/browse/FLINK-24789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440241#comment-17440241 ] Till Rohrmann commented on FLINK-24789: --- What's the progress on this ticket [~dmvk

[jira] [Commented] (FLINK-24457) FileSourceTextLinesITCase.testContinuousTextFileSourceWithJobManagerFailover fails with NoSuchElement

[ https://issues.apache.org/jira/browse/FLINK-24457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440242#comment-17440242 ] Till Rohrmann commented on FLINK-24457: --- [~xmarker] can you provide a fix for the

[jira] [Commented] (FLINK-24763) ParquetFileSystemITCase.testLimitableBulkFormat failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440238#comment-17440238 ] Till Rohrmann commented on FLINK-24763: --- cc [~arvid] > ParquetFileSystemITCase.te

[jira] [Updated] (FLINK-18808) Task-level numRecordsOut metric may be underestimated

[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-18808: --- Labels: pull-request-available usability (was: auto-deprioritized-major pull-request-availa

[jira] [Commented] (FLINK-24495) Python installdeps hangs

[ https://issues.apache.org/jira/browse/FLINK-24495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440240#comment-17440240 ] Till Rohrmann commented on FLINK-24495: --- [~dianfu] can you take a look? > Python

[jira] [Commented] (FLINK-22869) SQLClientSchemaRegistryITCase timeouts on azure

[ https://issues.apache.org/jira/browse/FLINK-22869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440237#comment-17440237 ] Till Rohrmann commented on FLINK-22869: --- cc [~twalthr] this test seems to fail qui

[jira] [Updated] (FLINK-24495) Python installdeps hangs

[ https://issues.apache.org/jira/browse/FLINK-24495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-24495: -- Priority: Critical (was: Major) > Python installdeps hangs > > >

[jira] [Updated] (FLINK-18808) Task-level numRecordsOut metric may be underestimated

[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-18808: --- Priority: Not a Priority (was: Minor) > Task-level numRecordsOut metric may be underestimat

[jira] [Updated] (FLINK-22869) SQLClientSchemaRegistryITCase timeouts on azure

[ https://issues.apache.org/jira/browse/FLINK-22869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-22869: -- Component/s: Table SQL / Ecosystem > SQLClientSchemaRegistryITCase timeouts on azure > ---

[jira] [Commented] (FLINK-23848) PulsarSourceITCase is failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-23848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440236#comment-17440236 ] Till Rohrmann commented on FLINK-23848: --- cc [~arvid] > PulsarSourceITCase is fail

[jira] [Updated] (FLINK-22869) SQLClientSchemaRegistryITCase timeouts on azure

[ https://issues.apache.org/jira/browse/FLINK-22869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-22869: -- Priority: Critical (was: Major) > SQLClientSchemaRegistryITCase timeouts on azure > -

[jira] [Commented] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable

[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440235#comment-17440235 ] Till Rohrmann commented on FLINK-23944: --- cc [~arvid] > PulsarSourceITCase.testTas

[jira] [Updated] (FLINK-19052) Performance issue with PojoSerializer

[ https://issues.apache.org/jira/browse/FLINK-19052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-19052: --- Priority: Not a Priority (was: Minor) > Performance issue with PojoSerializer > ---

[GitHub] [flink-ml] guoweiM commented on pull request #22: [FLINK-24722][iteration] Fixes the issues on supporting keyed stream

guoweiM commented on pull request #22: URL: https://github.com/apache/flink-ml/pull/22#issuecomment-962886684 In general I am fine with this fix. But I have a little problem —— Do you think that we should also add a test for `partitionCustom` -- This is an automated message from the Apac

[GitHub] [flink] pnowojski commented on a change in pull request #17660: [FLINK-24657][runtime] Added metric of the total real size of input/o…

pnowojski commented on a change in pull request #17660: URL: https://github.com/apache/flink/pull/17660#discussion_r744462195 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java ## @@ -433,6 +433,24 @@ public in

[jira] [Commented] (FLINK-24757) Yarn application is not terminated after the job finishes when submitting a yarn-per-job insert job with SQL client

[ https://issues.apache.org/jira/browse/FLINK-24757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440226#comment-17440226 ] Caizhi Weng commented on FLINK-24757: - It seems that we cannot solve it by just sett

[GitHub] [flink] Airblader commented on a change in pull request #17698: [FLINK-24689][runtime-web] Add log's last modify time in log list view

Airblader commented on a change in pull request #17698: URL: https://github.com/apache/flink/pull/17698#discussion_r744457632 ## File path: flink-runtime-web/web-dashboard/src/app/pages/task-manager/log-list/task-manager-log-list.component.html ## @@ -29,14 +29,16 @@

[jira] [Commented] (FLINK-24793) DefaultSchedulerLocalRecoveryITCase fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-24793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440224#comment-17440224 ] Zhu Zhu commented on FLINK-24793: - This IT case fails when it is testing using AdaptiveS

[GitHub] [flink] flinkbot edited a comment on pull request #17710: [FLINK-24793][tests] Skip DefaultSchedulerLocalRecoveryITCase when testing AdaptiveScheduler

flinkbot edited a comment on pull request #17710: URL: https://github.com/apache/flink/pull/17710#issuecomment-962872445 ## CI report: * cf7a81b798bd54529cb4ddeecad70fe226e10e26 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #17710: [FLINK-24793][tests] Skip DefaultSchedulerLocalRecoveryITCase when testing AdaptiveScheduler

flinkbot commented on pull request #17710: URL: https://github.com/apache/flink/pull/17710#issuecomment-962872368 -- 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 unsubsc

[jira] [Comment Edited] (FLINK-24757) Yarn application is not terminated after the job finishes when submitting a yarn-per-job insert job with SQL client

[ https://issues.apache.org/jira/browse/FLINK-24757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440151#comment-17440151 ] Caizhi Weng edited comment on FLINK-24757 at 11/8/21, 7:13 AM: ---

[GitHub] [flink] zhuzhurk opened a new pull request #17710: [FLINK-24793][tests] Skip DefaultSchedulerLocalRecoveryITCase when testing AdaptiveScheduler

zhuzhurk opened a new pull request #17710: URL: https://github.com/apache/flink/pull/17710 ## What is the purpose of the change DefaultSchedulerLocalRecoveryITCase does not work with AdaptiveScheduler before FLINK-21450 is done. So we skip these tests when testing AdaptiveSchedule

[jira] [Updated] (FLINK-24793) DefaultSchedulerLocalRecoveryITCase fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-24793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24793: --- Labels: pull-request-available test-stability (was: test-stability) > DefaultSchedulerLocal

[jira] [Updated] (FLINK-24757) Yarn application is not terminated after the job finishes when submitting a yarn-per-job insert job with SQL client

[ https://issues.apache.org/jira/browse/FLINK-24757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-24757: Description: I've seen this problem for about three times in the user mailing thread (previously

[GitHub] [flink] flinkbot edited a comment on pull request #17699: [FLINK-20370][table] Fix wrong results when sink primary key is not the same with query result's changelog upsert key

flinkbot edited a comment on pull request #17699: URL: https://github.com/apache/flink/pull/17699#issuecomment-961963701 ## CI report: * bc1d328642ab4c430d4e8d0cbf977d26eb97d2e6 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #17699: [FLINK-20370][table] Fix wrong results when sink primary key is not the same with query result's changelog upsert key

flinkbot edited a comment on pull request #17699: URL: https://github.com/apache/flink/pull/17699#issuecomment-961963701 ## CI report: * bc1d328642ab4c430d4e8d0cbf977d26eb97d2e6 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #17672: [FLINK-24761][table] Fix PartitionPruner code gen compile fail

flinkbot edited a comment on pull request #17672: URL: https://github.com/apache/flink/pull/17672#issuecomment-960546911 ## CI report: * a3b173ffd738f9c5728e92a6ee2cda4e2884228d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] MartijnVisser commented on pull request #17695: [FLINK-24798][cli] Bump commons-cli to v1.5.0

MartijnVisser commented on pull request #17695: URL: https://github.com/apache/flink/pull/17695#issuecomment-962866327 `commons-cli` is bundled with `org.apache.hbase.thirdparty:hbase-shaded-miscellaneous`. Flink is getting that dependency in via `org.apache.hbase:hbase-client:jar` version

[GitHub] [flink] flinkbot edited a comment on pull request #17462: [FLINK-23170] Write metadata after materialization

flinkbot edited a comment on pull request #17462: URL: https://github.com/apache/flink/pull/17462#issuecomment-942024789 ## CI report: * de953e065ada40720bd5118aa8fb43842b27733b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] lincoln-lil commented on pull request #17699: [FLINK-20370][table] Fix wrong results when sink primary key is not the same with query result's changelog upsert key

lincoln-lil commented on pull request #17699: URL: https://github.com/apache/flink/pull/17699#issuecomment-962865148 @JingsongLi agree with you putting these logic together. I've updated the pr. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot edited a comment on pull request #17699: [FLINK-20370][table] Fix wrong results when sink primary key is not the same with query result's changelog upsert key

flinkbot edited a comment on pull request #17699: URL: https://github.com/apache/flink/pull/17699#issuecomment-961963701 ## CI report: * bc1d328642ab4c430d4e8d0cbf977d26eb97d2e6 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #17462: [FLINK-23170] Write metadata after materialization

flinkbot edited a comment on pull request #17462: URL: https://github.com/apache/flink/pull/17462#issuecomment-942024789 ## CI report: * de953e065ada40720bd5118aa8fb43842b27733b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17709: [FLINK-24806][connectors/rabbitmq] Fix container startup in RMQSourceITCase

flinkbot edited a comment on pull request #17709: URL: https://github.com/apache/flink/pull/17709#issuecomment-962748984 ## CI report: * ebf5af326bc99a65a14d479e4099616d288288f1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17637: [FLINK-24708][planner] Fix wrong results of the IN operator

flinkbot edited a comment on pull request #17637: URL: https://github.com/apache/flink/pull/17637#issuecomment-957122792 ## CI report: * 6f0727e525cb34f2a5afbe3207dac73e177ddb33 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-24815) Reduce the cpu cost of calculating stateSize during state allocation

ming li created FLINK-24815: --- Summary: Reduce the cpu cost of calculating stateSize during state allocation Key: FLINK-24815 URL: https://issues.apache.org/jira/browse/FLINK-24815 Project: Flink I

[GitHub] [flink] flinkbot edited a comment on pull request #17698: [FLINK-24689][runtime-web] Add log's last modify time in log list view

flinkbot edited a comment on pull request #17698: URL: https://github.com/apache/flink/pull/17698#issuecomment-961944542 ## CI report: * 90afa69f4588fb080119395484bf7d80d99fe174 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17698: [FLINK-24689][runtime-web] Add log's last modify time in log list view

flinkbot edited a comment on pull request #17698: URL: https://github.com/apache/flink/pull/17698#issuecomment-961944542 ## CI report: * 90afa69f4588fb080119395484bf7d80d99fe174 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17708: [FLINK-23696][connectors/rabbitmq] Fix RMQSourceTest.testRedeliveredSessionIDsAck

flinkbot edited a comment on pull request #17708: URL: https://github.com/apache/flink/pull/17708#issuecomment-962715413 ## CI report: * 1fe63c9384f63908b2f0024172d8e6753bdbb84f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] ysymi edited a comment on pull request #17698: [FLINK-24689][runtime-web] Add log's last modify time in log list view

ysymi edited a comment on pull request #17698: URL: https://github.com/apache/flink/pull/17698#issuecomment-962836982 I will rebase on latest master (commit: fc4f2556) to pass the CI check in Azure. The reason is the master I checkout from (commit: db04af41 ) always failed in `org.

[GitHub] [flink] ysymi commented on pull request #17698: [FLINK-24689][runtime-web] Add log's last modify time in log list view

ysymi commented on pull request #17698: URL: https://github.com/apache/flink/pull/17698#issuecomment-962836982 I will rebase on latest master (commit: fc4f2556) to pass the CI check in Azure. The reason is the master I checkout from (commit: db04af41 ) always failed in `org.apache.flin

[GitHub] [flink-ml] lindong28 commented on a change in pull request #10: [FLINK-24354][FLIP-174] Improve the WithParams interface

lindong28 commented on a change in pull request #10: URL: https://github.com/apache/flink-ml/pull/10#discussion_r744420186 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/param/Param.java ## @@ -0,0 +1,98 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[GitHub] [flink] JingsongLi commented on pull request #17699: [FLINK-20370][table] Fix wrong results when sink primary key is not the same with query result's changelog upsert key

JingsongLi commented on pull request #17699: URL: https://github.com/apache/flink/pull/17699#issuecomment-962830715 Thanks @lincoln-lil Note `SinkUpsertMaterializer` requires update before. We should not separate the inference of change log mode from the sink upsert materializer, whi

[GitHub] [flink] flinkbot edited a comment on pull request #17462: [FLINK-23170] Write metadata after materialization

flinkbot edited a comment on pull request #17462: URL: https://github.com/apache/flink/pull/17462#issuecomment-942024789 ## CI report: * de953e065ada40720bd5118aa8fb43842b27733b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17462: [FLINK-23170] Write metadata after materialization

flinkbot edited a comment on pull request #17462: URL: https://github.com/apache/flink/pull/17462#issuecomment-942024789 ## CI report: * de953e065ada40720bd5118aa8fb43842b27733b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17699: [FLINK-20370][table] Fix wrong results when sink primary key is not the same with query result's changelog upsert key

flinkbot edited a comment on pull request #17699: URL: https://github.com/apache/flink/pull/17699#issuecomment-961963701 ## CI report: * 4115ff9fb202b7fbb138fed2c988ab1189345bcc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17699: [FLINK-20370][table] Fix wrong results when sink primary key is not the same with query result's changelog upsert key

flinkbot edited a comment on pull request #17699: URL: https://github.com/apache/flink/pull/17699#issuecomment-961963701 ## CI report: * 4115ff9fb202b7fbb138fed2c988ab1189345bcc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-24814) Cannot update accumulators for job

mo.wu created FLINK-24814: - Summary: Cannot update accumulators for job Key: FLINK-24814 URL: https://issues.apache.org/jira/browse/FLINK-24814 Project: Flink Issue Type: Bug Components: Ta

[GitHub] [flink] cshuo commented on a change in pull request #17634: [FLINK-24691][table-common] Fix precision for sum on decimal types

cshuo commented on a change in pull request #17634: URL: https://github.com/apache/flink/pull/17634#discussion_r744380537 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java ## @@ -759,6 +760,24 @@

[jira] [Commented] (FLINK-24809) Check & possible fix decimal precision and scale for all Aggregate functions

[ https://issues.apache.org/jira/browse/FLINK-24809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440170#comment-17440170 ] Shuo Cheng commented on FLINK-24809: `SumWithRetractAggFunction` as well. > Check &

[GitHub] [flink] ysymi commented on pull request #17698: [FLINK-24689][runtime-web] Add log's last modify time in log list view

ysymi commented on pull request #17698: URL: https://github.com/apache/flink/pull/17698#issuecomment-962787085 @flinkbot re-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 specifi

[GitHub] [flink] ysymi commented on a change in pull request #17698: [FLINK-24689][runtime-web] Add log's last modify time in log list view

ysymi commented on a change in pull request #17698: URL: https://github.com/apache/flink/pull/17698#discussion_r744387331 ## File path: flink-runtime-web/web-dashboard/src/app/pages/task-manager/log-list/task-manager-log-list.component.html ## @@ -29,14 +29,16 @@

[GitHub] [flink] cshuo commented on a change in pull request #17634: [FLINK-24691][table-common] Fix precision for sum on decimal types

cshuo commented on a change in pull request #17634: URL: https://github.com/apache/flink/pull/17634#discussion_r744367549 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/ExprCodeGenerator.scala ## @@ -834,6 +834,11 @@ class E

[jira] [Commented] (FLINK-24279) Support withBroadcast with DataStream API in Flink ML Library

[ https://issues.apache.org/jira/browse/FLINK-24279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440162#comment-17440162 ] Yun Gao commented on FLINK-24279: - Fix on master via 8269bd9fdf3e5744b2d635697db5c705b9e

[jira] [Closed] (FLINK-24279) Support withBroadcast with DataStream API in Flink ML Library

[ https://issues.apache.org/jira/browse/FLINK-24279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-24279. --- Fix Version/s: 0.1.0 Assignee: Zhipeng Zhang Resolution: Fixed > Support withBroadcast with

[GitHub] [flink-ml] gaoyunhaii closed pull request #18: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

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

[jira] [Comment Edited] (FLINK-24783) Improve monitoring experience and usability of state backend

[ https://issues.apache.org/jira/browse/FLINK-24783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440160#comment-17440160 ] Yun Tang edited comment on FLINK-24783 at 11/8/21, 3:13 AM:

[jira] [Commented] (FLINK-24783) Improve monitoring experience and usability of state backend

[ https://issues.apache.org/jira/browse/FLINK-24783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440160#comment-17440160 ] Yun Tang commented on FLINK-24783: -- [~sjwiesman][~nkruber], I think it would be helpful

[GitHub] [flink] unigeorge commented on pull request #17585: [hotfix][docs] Modify wrong variable names in doc demo code

unigeorge commented on pull request #17585: URL: https://github.com/apache/flink/pull/17585#issuecomment-962769793 @dianfu Can you review it for me? -- 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

[jira] [Commented] (FLINK-20374) Wrong result when shuffling changelog stream on non-primary-key columns

[ https://issues.apache.org/jira/browse/FLINK-20374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440157#comment-17440157 ] Leonard Xu commented on FLINK-20374: [~lzljs3620320] Do you have plan to cp this fix

[jira] [Resolved] (FLINK-24475) Remove no longer used NestedMap* classes

[ https://issues.apache.org/jira/browse/FLINK-24475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-24475. -- Resolution: Fixed Merged in master: fc4f255644a64bb556b0dcefb165a9c772164c5b > Remove no longer used

[GitHub] [flink] Myasuka closed pull request #17650: [FLINK-24475] Remove no longer used NestedMap* classes

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

[jira] [Assigned] (FLINK-24813) Improve ImplicitTypeConversionITCase

[ https://issues.apache.org/jira/browse/FLINK-24813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-24813: -- Assignee: xuyang > Improve ImplicitTypeConversionITCase > ---

[jira] [Created] (FLINK-24813) Improve ImplicitTypeConversionITCase

godfrey he created FLINK-24813: -- Summary: Improve ImplicitTypeConversionITCase Key: FLINK-24813 URL: https://issues.apache.org/jira/browse/FLINK-24813 Project: Flink Issue Type: Improvement

[GitHub] [flink] godfreyhe edited a comment on pull request #17444: [FLINK-24492][table-planner]incorrect implicit type conversion between numeric and (var)char

godfreyhe edited a comment on pull request #17444: URL: https://github.com/apache/flink/pull/17444#issuecomment-962765849 ok, I will create an issue to improve the tests, FLINK-24813 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to G

[jira] [Commented] (FLINK-15352) develop MySQLCatalog to connect Flink with MySQL tables and ecosystem

[ https://issues.apache.org/jira/browse/FLINK-15352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440155#comment-17440155 ] Yuepeng Pan commented on FLINK-15352: - [~airblader] Thank you so much for the review

[GitHub] [flink] godfreyhe commented on pull request #17444: [FLINK-24492][table-planner]incorrect implicit type conversion between numeric and (var)char

godfreyhe commented on pull request #17444: URL: https://github.com/apache/flink/pull/17444#issuecomment-962765849 ok, I will create a issue to improve the tests -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] godfreyhe commented on a change in pull request #17637: [FLINK-24708][planner] Fix wrong results of the IN operator

godfreyhe commented on a change in pull request #17637: URL: https://github.com/apache/flink/pull/17637#discussion_r744369780 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/rules/logical/ConvertToNotInOrInRuleTest.scala #

[jira] [Commented] (FLINK-20370) Result is wrong when sink primary key is not the same with query

[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440153#comment-17440153 ] Wenlong Lyu commented on FLINK-20370: - [~twalthr] thanks for the explanation. Howev

[GitHub] [flink] flinkbot edited a comment on pull request #17699: [FLINK-20370][table] Fix wrong results when sink primary key is not the same with query result's changelog upsert key

flinkbot edited a comment on pull request #17699: URL: https://github.com/apache/flink/pull/17699#issuecomment-961963701 ## CI report: * 4115ff9fb202b7fbb138fed2c988ab1189345bcc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17672: [FLINK-24761][table] Fix PartitionPruner code gen compile fail

flinkbot edited a comment on pull request #17672: URL: https://github.com/apache/flink/pull/17672#issuecomment-960546911 ## CI report: * 85f69400f532e6d1732fc9cd26c03cbb5ace21ad Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17699: [FLINK-20370][table] Fix wrong results when sink primary key is not the same with query result's changelog upsert key

flinkbot edited a comment on pull request #17699: URL: https://github.com/apache/flink/pull/17699#issuecomment-961963701 ## CI report: * 4115ff9fb202b7fbb138fed2c988ab1189345bcc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17672: [FLINK-24761][table] Fix PartitionPruner code gen compile fail

flinkbot edited a comment on pull request #17672: URL: https://github.com/apache/flink/pull/17672#issuecomment-960546911 ## CI report: * 85f69400f532e6d1732fc9cd26c03cbb5ace21ad Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] Tartarus0zm commented on pull request #17672: [FLINK-24761][table] Fix PartitionPruner code gen compile fail

Tartarus0zm commented on pull request #17672: URL: https://github.com/apache/flink/pull/17672#issuecomment-962761027 @tsreaper thanks for your review. I has fix the comments, please take a look -- This is an automated message from the Apache Git Service. To respond to the message, please

  1   2   3   >