[GitHub] [flink] xintongsong commented on pull request #17403: [FLINK-24417] Update MigrationVersion with 1.14

2021-10-10 Thread GitBox
xintongsong commented on pull request #17403: URL: https://github.com/apache/flink/pull/17403#issuecomment-939739016 I wonder if we can make the `MigrationVersion` updates easier, and reduce the chance of making mistakes. 1. Instead of manually going through all places where `Migrati

[GitHub] [flink] xintongsong commented on pull request #17403: [FLINK-24417] Update MigrationVersion with 1.14

2021-10-10 Thread GitBox
xintongsong commented on pull request #17403: URL: https://github.com/apache/flink/pull/17403#issuecomment-939730322 The new version is missing from `o.a.f.hdfstests.ContinuousFileProcessingMigrationTest`. -- This is an automated message from the Apache Git Service. To respond to the mes

[jira] [Commented] (FLINK-24489) The size of entryCache in the SharedBuffer should be defined with a threshold

2021-10-10 Thread Roc Marshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426967#comment-17426967 ] Roc Marshal commented on FLINK-24489: - IMO, There need a size threshold to avoid OOM

[jira] [Created] (FLINK-24498) KafkaShuffleITCase fails with "The topic metadata failed to propagate to Kafka broker"

2021-10-10 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-24498: Summary: KafkaShuffleITCase fails with "The topic metadata failed to propagate to Kafka broker" Key: FLINK-24498 URL: https://issues.apache.org/jira/browse/FLINK-24498

[jira] [Commented] (FLINK-23696) RMQSourceTest.testRedeliveredSessionIDsAck fails on azure

2021-10-10 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426964#comment-17426964 ] Dawid Wysakowicz commented on FLINK-23696: -- https://dev.azure.com/apache-flink/

[jira] [Created] (FLINK-24497) Kafka metrics fetching throws IllegalStateException

2021-10-10 Thread Juha (Jira)
Juha created FLINK-24497: Summary: Kafka metrics fetching throws IllegalStateException Key: FLINK-24497 URL: https://issues.apache.org/jira/browse/FLINK-24497 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-24496) Querying job details in the REST API fails

2021-10-10 Thread Juha (Jira)
Juha created FLINK-24496: Summary: Querying job details in the REST API fails Key: FLINK-24496 URL: https://issues.apache.org/jira/browse/FLINK-24496 Project: Flink Issue Type: Bug Compon

[jira] [Updated] (FLINK-24459) Performance improvement of file sink on Nexmark

2021-10-10 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-24459: --- Fix Version/s: 1.15.0 > Performance improvement of file sink on Nexmark > --

[jira] [Closed] (FLINK-24459) Performance improvement of file sink on Nexmark

2021-10-10 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-24459. -- Resolution: Fixed merged: 624372376a09df53e23bb615e5293a6caa296c47 > Performance improvement of file

[jira] [Updated] (FLINK-24459) Performance improvement of file sink on Nexmark

2021-10-10 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-24459: --- Affects Version/s: 1.14.0 > Performance improvement of file sink on Nexmark > --

[GitHub] [flink] KurtYoung merged pull request #17416: [FLINK-24459] Performance improvement of file sink

2021-10-10 Thread GitBox
KurtYoung merged pull request #17416: URL: https://github.com/apache/flink/pull/17416 -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17445: [FLINK-24390][python] Limit the grpcio version <= 1.40.0 for Python 3.5 in dev/requirements.txt

2021-10-10 Thread GitBox
flinkbot edited a comment on pull request #17445: URL: https://github.com/apache/flink/pull/17445#issuecomment-939657269 ## CI report: * 25f032ae36184c85bf6d67da7535d74f744226e9 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-24459) Performance improvement of file sink on Nexmark

2021-10-10 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426946#comment-17426946 ] Kurt Young commented on FLINK-24459: Very nice improvement! [~trushev] > Performanc

[GitHub] [flink] flinkbot commented on pull request #17445: [FLINK-24390][python] Limit the grpcio version <= 1.40.0 for Python 3.5 in dev/requirements.txt

2021-10-10 Thread GitBox
flinkbot commented on pull request #17445: URL: https://github.com/apache/flink/pull/17445#issuecomment-939657269 ## CI report: * 25f032ae36184c85bf6d67da7535d74f744226e9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #17445: [FLINK-24390][python] Limit the grpcio version <= 1.40.0 for Python 3.5 in dev/requirements.txt

2021-10-10 Thread GitBox
flinkbot commented on pull request #17445: URL: https://github.com/apache/flink/pull/17445#issuecomment-939656132 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 pro

[GitHub] [flink] dianfu opened a new pull request #17445: [FLINK-24390][python] Limit the grpcio version <= 1.40.0 for Python 3.5 in dev/requirements.txt

2021-10-10 Thread GitBox
dianfu opened a new pull request #17445: URL: https://github.com/apache/flink/pull/17445 ## What is the purpose of the change *This pull request provides a quick fix to also updates the grpcio version <= 1.40.0 for Python 3.5 in dev/requirements.txt* ## Verifying this

[jira] [Commented] (FLINK-24460) Rocksdb Iterator Error Handling Improvement

2021-10-10 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426944#comment-17426944 ] Yun Tang commented on FLINK-24460: -- This fix should be useful, [~victorunique] already

[jira] [Assigned] (FLINK-24460) Rocksdb Iterator Error Handling Improvement

2021-10-10 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-24460: Assignee: Victor Xu > Rocksdb Iterator Error Handling Improvement > -

[jira] [Commented] (FLINK-24390) Python 'build_wheels mac' fails on azure

2021-10-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426942#comment-17426942 ] Xintong Song commented on FLINK-24390: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] hililiwei commented on a change in pull request #17416: [FLINK-24459] Performance improvement of file sink

2021-10-10 Thread GitBox
hililiwei commented on a change in pull request #17416: URL: https://github.com/apache/flink/pull/17416#discussion_r725765842 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/PartitionPathUtils.java ## @@ -113,19 +113,36 @@ private static

[jira] [Commented] (FLINK-24480) EqualiserCodeGeneratorTest fails on azure

2021-10-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426940#comment-17426940 ] Xintong Song commented on FLINK-24480: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Assigned] (FLINK-23559) Enable periodic materialisation in tests

2021-10-10 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei reassigned FLINK-23559: Assignee: Yuan Mei > Enable periodic materialisation in tests > -

[jira] [Reopened] (FLINK-21706) FlinkKafkaProducerITCase.testMigrateFromAtExactlyOnceToAtLeastOnce fails with "SchemaException: Error reading field 'api_keys': Error reading field 'api_key': java.nio.

2021-10-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reopened FLINK-21706: -- New instance: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=24931&view=lo

[jira] [Commented] (FLINK-23493) python tests hang on Azure

2021-10-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426937#comment-17426937 ] Xintong Song commented on FLINK-23493: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-20928) KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:270 » Timeout

2021-10-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426936#comment-17426936 ] Xintong Song commented on FLINK-20928: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-24216) org.apache.flink.test.scheduling.AdaptiveSchedulerITCase#testStopWithSavepointFailOnFirstSavepointSucceedOnSecond blocked on azure

2021-10-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426935#comment-17426935 ] Xintong Song commented on FLINK-24216: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-24480) EqualiserCodeGeneratorTest fails on azure

2021-10-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426934#comment-17426934 ] Xintong Song commented on FLINK-24480: -- https://dev.azure.com/apache-flink/apache-f

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

2021-10-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22869: - Fix Version/s: 1.13.3 1.12.6 > SQLClientSchemaRegistryITCase timeouts on azur

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

2021-10-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426933#comment-17426933 ] Xintong Song commented on FLINK-22869: -- https://dev.azure.com/apache-flink/apache-f

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

2021-10-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426932#comment-17426932 ] Xintong Song commented on FLINK-24495: -- cc [~dianfu] [~hxbks2ks] > Python installd

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

2021-10-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426931#comment-17426931 ] Xintong Song commented on FLINK-24495: -- https://dev.azure.com/apache-flink/apache-f

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

2021-10-10 Thread Xintong Song (Jira)
Xintong Song created FLINK-24495: Summary: Python installdeps hangs Key: FLINK-24495 URL: https://issues.apache.org/jira/browse/FLINK-24495 Project: Flink Issue Type: Bug Components

[jira] [Commented] (FLINK-24390) Python 'build_wheels mac' fails on azure

2021-10-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426930#comment-17426930 ] Xintong Song commented on FLINK-24390: -- [~dianfu] New instance, on the exactly same

[jira] [Reopened] (FLINK-24390) Python 'build_wheels mac' fails on azure

2021-10-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reopened FLINK-24390: -- > Python 'build_wheels mac' fails on azure > > >

[jira] [Commented] (FLINK-24480) EqualiserCodeGeneratorTest fails on azure

2021-10-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426927#comment-17426927 ] Xintong Song commented on FLINK-24480: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] loyili closed pull request #16078: [hotfix] Fix typo

2021-10-10 Thread GitBox
loyili closed pull request #16078: URL: https://github.com/apache/flink/pull/16078 -- 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-unsubscr

[jira] [Closed] (FLINK-23358) Refactor CoreOptions parent-first patterns to List options

2021-10-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-23358. Resolution: Fixed Merged via: - master (1.15): 4d648db50d80be380a690c9ea90fc84961a13e1f > Refacto

[jira] [Assigned] (FLINK-23358) Refactor CoreOptions parent-first patterns to List options

2021-10-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-23358: Assignee: Horace Lee > Refactor CoreOptions parent-first patterns to List options > -

[jira] [Updated] (FLINK-23358) Refactor CoreOptions parent-first patterns to List options

2021-10-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23358: - Issue Type: Technical Debt (was: Improvement) > Refactor CoreOptions parent-first patterns to L

[GitHub] [flink] xintongsong closed pull request #16821: [FLINK-23358][core] Refactor CoreOptions parent first patterns to List options

2021-10-10 Thread GitBox
xintongsong closed pull request #16821: URL: https://github.com/apache/flink/pull/16821 -- 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-uns

[jira] [Updated] (FLINK-24494) Avro conluent Resigry SQL not fails to write to the topic with schema with default value for int

2021-10-10 Thread Mahendran Ponnusamy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mahendran Ponnusamy updated FLINK-24494: Description:   Given a schema registered to a topic with default value as '0' for

[jira] [Created] (FLINK-24494) Avro conluent Resigry SQL not fails to write to the topic with schema with default value for int

2021-10-10 Thread Mahendran Ponnusamy (Jira)
Mahendran Ponnusamy created FLINK-24494: --- Summary: Avro conluent Resigry SQL not fails to write to the topic with schema with default value for int Key: FLINK-24494 URL: https://issues.apache.org/jira/browse

[jira] [Commented] (FLINK-21986) taskmanager native memory not release timely after restart

2021-10-10 Thread Yaroslav Tkachenko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426853#comment-17426853 ] Yaroslav Tkachenko commented on FLINK-21986: We had a very similar problem i

[GitHub] [flink] flinkbot edited a comment on pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

2021-10-10 Thread GitBox
flinkbot edited a comment on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748 ## CI report: * a6d214f6bf7933f1e0a89178ef44d87401505270 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-23919) PullUpWindowTableFunctionIntoWindowAggregateRule generates invalid Calc for Window TVF

2021-10-10 Thread Yuval Itzchakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426829#comment-17426829 ] Yuval Itzchakov commented on FLINK-23919: - [~jark] [~jinyu.zj] Did one of you gu

[GitHub] [flink] flinkbot edited a comment on pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

2021-10-10 Thread GitBox
flinkbot edited a comment on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748 ## CI report: * b78388d1ba483c09c28f18c22f8930f6e1484779 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Assigned] (FLINK-23170) Write metadata after materialization

2021-10-10 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei reassigned FLINK-23170: Assignee: Yuan Mei > Write metadata after materialization >

[jira] [Comment Edited] (FLINK-24215) Timeout exception in submitting a job by RemoteStreamEnvironment/RemoteEnvironment

2021-10-10 Thread Roc Marshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420528#comment-17420528 ] Roc Marshal edited comment on FLINK-24215 at 10/10/21, 2:18 PM: --

[GitHub] [flink] flinkbot edited a comment on pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

2021-10-10 Thread GitBox
flinkbot edited a comment on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748 ## CI report: * b78388d1ba483c09c28f18c22f8930f6e1484779 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16821: [FLINK-23358][core] Refactor CoreOptions parent first patterns to List options

2021-10-10 Thread GitBox
flinkbot edited a comment on pull request #16821: URL: https://github.com/apache/flink/pull/16821#issuecomment-898859870 ## CI report: * c7941dda940e9593b6c9c68baac3ede726485d3e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16821: [FLINK-23358][core] Refactor CoreOptions parent first patterns to List options

2021-10-10 Thread GitBox
flinkbot edited a comment on pull request #16821: URL: https://github.com/apache/flink/pull/16821#issuecomment-898859870 ## CI report: * 860f7acaf90b23fbff802792749ef1bd0479a414 UNKNOWN * c7941dda940e9593b6c9c68baac3ede726485d3e Azure: [SUCCESS](https://dev.azure.com/apache-fl