[jira] [Commented] (FLINK-25318) Improvement of scheduler and execution for Flink OLAP

2021-12-14 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17459716#comment-17459716 ] Xintong Song commented on FLINK-25318: -- Thanks [~zjureel], for creating this umbrel

[jira] [Commented] (FLINK-25307) Resuming Savepoint (hashmap, async, no parallelism change) end-to-end test timeout on azure

2021-12-14 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17459715#comment-17459715 ] Dawid Wysakowicz commented on FLINK-25307: -- Looking at logs it seems that we do

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

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

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[jira] [Updated] (FLINK-25318) Improvement of scheduler and execution for Flink OLAP

2021-12-14 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-25318: - Fix Version/s: 1.15.0 > Improvement of scheduler and execution for Flink OLAP >

[jira] [Updated] (FLINK-25318) Improvement of scheduler and execution for Flink OLAP

2021-12-14 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-25318: - Labels: Umbrella (was: ) > Improvement of scheduler and execution for Flink OLAP >

[GitHub] [flink] flinkbot edited a comment on pull request #18101: [FLINK-25222][tests] Remove NetworkFailureProxy used in Kafka tests

2021-12-14 Thread GitBox
flinkbot edited a comment on pull request #18101: URL: https://github.com/apache/flink/pull/18101#issuecomment-993331950 ## CI report: * 60e9a62a2bc8a3aa67e95dec3690157bcf55bf0f Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-25307) Resuming Savepoint (hashmap, async, no parallelism change) end-to-end test timeout on azure

2021-12-14 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25307: Affects Version/s: 1.13.3 > Resuming Savepoint (hashmap, async, no parallelism change) end-to-end test >

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[GitHub] [flink] RocMarshal commented on a change in pull request #17770: [FLINK-24272][Connectors / FileSystem] FileSystem compaction should throw unsupported exception in at-least-once mode

2021-12-14 Thread GitBox
RocMarshal commented on a change in pull request #17770: URL: https://github.com/apache/flink/pull/17770#discussion_r769336188 ## File path: docs/content/docs/connectors/table/filesystem.md ## @@ -195,6 +195,7 @@ When running file compaction in production, please be aware that

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

2021-12-14 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17459710#comment-17459710 ] Yun Gao commented on FLINK-24216: - https://dev.azure.com/apache-flink/apache-flink/_buil

[GitHub] [flink] flinkbot edited a comment on pull request #18101: [FLINK-25222][tests] Remove NetworkFailureProxy used in Kafka tests

2021-12-14 Thread GitBox
flinkbot edited a comment on pull request #18101: URL: https://github.com/apache/flink/pull/18101#issuecomment-993331950 ## CI report: * 60e9a62a2bc8a3aa67e95dec3690157bcf55bf0f Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-25317) ApplicationDispatcherBootstrapITCase blocked on azure

2021-12-14 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25317: Labels: test-stability (was: ) > ApplicationDispatcherBootstrapITCase blocked on azure >

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[jira] [Updated] (FLINK-25055) Support listen and notify mechanism for PartitionRequest

2021-12-14 Thread Shammon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shammon updated FLINK-25055: Parent: FLINK-25318 Issue Type: Sub-task (was: Improvement) > Support listen and notify mechanism

[jira] [Closed] (FLINK-25279) KafkaSourceLegacyITCase.testKeyValueSupport failed on azure due to topic already exists

2021-12-14 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-25279. --- Resolution: Duplicate > KafkaSourceLegacyITCase.testKeyValueSupport failed on azure due to topic > already

[jira] [Commented] (FLINK-25279) KafkaSourceLegacyITCase.testKeyValueSupport failed on azure due to topic already exists

2021-12-14 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17459709#comment-17459709 ] Yun Gao commented on FLINK-25279: - Would close due to duplicate with https://issues.apa

[jira] [Updated] (FLINK-15455) Enable TCP connection reuse across multiple jobs.

2021-12-14 Thread Shammon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shammon updated FLINK-15455: Parent: FLINK-25318 Issue Type: Sub-task (was: Improvement) > Enable TCP connection reuse across

[jira] [Commented] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

2021-12-14 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17459708#comment-17459708 ] Yun Gao commented on FLINK-24119: - https://dev.azure.com/apache-flink/apache-flink/_buil

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[GitHub] [flink] fapaul commented on pull request #18101: [FLINK-25222][tests] Remove NetworkFailureProxy used in Kafka tests

2021-12-14 Thread GitBox
fapaul commented on pull request #18101: URL: https://github.com/apache/flink/pull/18101#issuecomment-994423273 @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 c

[jira] [Created] (FLINK-25318) Improvement of scheduler and execution for Flink OLAP

2021-12-14 Thread Shammon (Jira)
Shammon created FLINK-25318: --- Summary: Improvement of scheduler and execution for Flink OLAP Key: FLINK-25318 URL: https://issues.apache.org/jira/browse/FLINK-25318 Project: Flink Issue Type: Impro

[jira] [Commented] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

2021-12-14 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17459707#comment-17459707 ] Yun Gao commented on FLINK-24119: - https://dev.azure.com/apache-flink/apache-flink/_buil

[GitHub] [flink] flinkbot edited a comment on pull request #18111: [FLINK-25094][Test]Correct the LatencyTrackingMapStateTest#verifyIterator

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

[GitHub] [flink] becketqin commented on a change in pull request #17991: [FLINK-25132][connector/kafka] Move record deserializing from SplitFetcher to RecordEmitter to support object-reusing deseriali

2021-12-14 Thread GitBox
becketqin commented on a change in pull request #17991: URL: https://github.com/apache/flink/pull/17991#discussion_r769321825 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[jira] [Created] (FLINK-25317) ApplicationDispatcherBootstrapITCase blocked on azure

2021-12-14 Thread Yun Gao (Jira)
Yun Gao created FLINK-25317: --- Summary: ApplicationDispatcherBootstrapITCase blocked on azure Key: FLINK-25317 URL: https://issues.apache.org/jira/browse/FLINK-25317 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-25227) Comparing the equality of the same (boxed) numeric values returns false

2021-12-14 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17459704#comment-17459704 ] Francesco Guardiani commented on FLINK-25227: - [~TsReaper] but then I sugges

[GitHub] [flink] flinkbot edited a comment on pull request #18102: [FLINK-25033][runtime] Let some scheduler components updatable

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

[GitHub] [flink] flinkbot edited a comment on pull request #18113: [FLINK-25315][tests] add new extensions and utils to help the Junit5 migration

2021-12-14 Thread GitBox
flinkbot edited a comment on pull request #18113: URL: https://github.com/apache/flink/pull/18113#issuecomment-994409071 ## CI report: * 4664b97e3029a9c17abb1cfef7d3b45a85d825ac Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

2021-12-14 Thread GitBox
flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 7660ffb0e155a244663d6ac0c93576a893a293aa Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[GitHub] [flink] flinkbot commented on pull request #18113: [FLINK-25315][tests] add new extensions and utils to help the Junit5 migration

2021-12-14 Thread GitBox
flinkbot commented on pull request #18113: URL: https://github.com/apache/flink/pull/18113#issuecomment-994409071 -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #18102: [FLINK-25033][runtime] Let some scheduler components updatable

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

[GitHub] [flink] flinkbot edited a comment on pull request #18068: [FLINK-25105][checkpoint] Enables final checkpoint by default

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

[GitHub] [flink] flinkbot edited a comment on pull request #18087: [FLINK-25268] Support task manager node-label in Yarn deployment

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

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[GitHub] [flink] flinkbot edited a comment on pull request #18042: [FLINK-25076][table-planner] Improve operator name for sql job

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

[GitHub] [flink] flinkbot edited a comment on pull request #16108: [FLINK-22821][core] Stabilize NetUtils#getAvailablePort in order to avoid wrongly allocating any used ports

2021-12-14 Thread GitBox
flinkbot edited a comment on pull request #16108: URL: https://github.com/apache/flink/pull/16108#issuecomment-856641884 ## CI report: * 03e33a13e8826f6cda49070c16679533f1223e94 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #15684: [FLINK-20899][table-planner-blink][hotfix] use cost factory in RelOptCluster to create HepPlanner.

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

[jira] [Updated] (FLINK-25315) Add some extensions and utils to help the Junit5 migration

2021-12-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25315: --- Labels: Tests pull-request-available (was: Tests) > Add some extensions and utils to help t

[GitHub] [flink] ruanhang1993 opened a new pull request #18113: [FLINK-25315][tests] add new extensions and utils to help the Junit5 migration

2021-12-14 Thread GitBox
ruanhang1993 opened a new pull request #18113: URL: https://github.com/apache/flink/pull/18113 ## What is the purpose of the change This pull request adds new extensions and utils to help the Junit5 migration. ## Brief change log - Add `ParameterizedTestExtension` and

[jira] [Commented] (FLINK-25307) Resuming Savepoint (hashmap, async, no parallelism change) end-to-end test timeout on azure

2021-12-14 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17459698#comment-17459698 ] Yun Gao commented on FLINK-25307: - https://dev.azure.com/apache-flink/apache-flink/_buil

[GitHub] [flink] flinkbot edited a comment on pull request #18112: [FLINK-25305][checkpoint] Always wait for input channel state and result partition state get completed in AsyncRunnable

2021-12-14 Thread GitBox
flinkbot edited a comment on pull request #18112: URL: https://github.com/apache/flink/pull/18112#issuecomment-994403719 ## CI report: * 6bb8f5418b1dcd085b16a00f1370a88262d3e4a9 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18087: [FLINK-25268] Support task manager node-label in Yarn deployment

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

[GitHub] [flink] flinkbot edited a comment on pull request #18068: [FLINK-25105][checkpoint] Enables final checkpoint by default

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

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[GitHub] [flink] flinkbot edited a comment on pull request #15684: [FLINK-20899][table-planner-blink][hotfix] use cost factory in RelOptCluster to create HepPlanner.

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

[GitHub] [flink] flinkbot commented on pull request #18112: [FLINK-25305][checkpoint] Always wait for input channel state and result partition state get completed in AsyncRunnable

2021-12-14 Thread GitBox
flinkbot commented on pull request #18112: URL: https://github.com/apache/flink/pull/18112#issuecomment-994404371 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] MartijnVisser commented on pull request #17711: [FLINK-24737][runtime-web] Update outdated web dependencies

2021-12-14 Thread GitBox
MartijnVisser commented on pull request #17711: URL: https://github.com/apache/flink/pull/17711#issuecomment-994404275 > > Can you have a look at the failing build and fix it? > > @MartijnVisser Conflicts have been addressed. Thanks @yangjunhan The CI unfortunately still fails

[jira] [Commented] (FLINK-24948) Special character in column names breaks JDBC statement parsing

2021-12-14 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17459696#comment-17459696 ] Martijn Visser commented on FLINK-24948: CC [~afedulov] [~arvid] > Special char

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[GitHub] [flink] flinkbot commented on pull request #18112: [FLINK-25305][checkpoint] Always wait for input channel state and result partition state get completed in AsyncRunnable

2021-12-14 Thread GitBox
flinkbot commented on pull request #18112: URL: https://github.com/apache/flink/pull/18112#issuecomment-994403719 ## CI report: * 6bb8f5418b1dcd085b16a00f1370a88262d3e4a9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] gaoyunhaii commented on pull request #18112: [FLINK-25305][checkpoint] Always wait for input channel state and result partition state get completed in AsyncRunnable

2021-12-14 Thread GitBox
gaoyunhaii commented on pull request #18112: URL: https://github.com/apache/flink/pull/18112#issuecomment-994402749 @dawidwys @pnowojski could you help to have a look on this PR~? very thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please l

[jira] [Updated] (FLINK-25305) Always wait for input channel state and result partition state get completed in AsyncRunnable

2021-12-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25305: --- Labels: pull-request-available (was: ) > Always wait for input channel state and result par

[GitHub] [flink] gaoyunhaii opened a new pull request #18112: [FLINK-25305][checkpoint] Always wait for input channel state and result partition state get completed in AsyncRunnable

2021-12-14 Thread GitBox
gaoyunhaii opened a new pull request #18112: URL: https://github.com/apache/flink/pull/18112 ## What is the purpose of the change This PR fixes the issue that when a task finished on restore taking unaligned checkpoints, currently the asynchronous part does not wait till the alignme

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[jira] [Comment Edited] (FLINK-25316) BlobServer can get stuck during shutdown

2021-12-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17459683#comment-17459683 ] Robert Metzger edited comment on FLINK-25316 at 12/15/21, 7:02 AM: ---

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[jira] [Commented] (FLINK-25273) Some doubts about the FLINK-22848

2021-12-14 Thread Jianhui Dong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17459691#comment-17459691 ] Jianhui Dong commented on FLINK-25273: -- Thank u. I sent an email about this issue t

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: [FLINK-24557] Add Estimator and Transformer for K-nearest neighbor

2021-12-14 Thread GitBox
lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r769301266 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnModelData.java ## @@ -0,0 +1,120 @@ +/* + * Licensed to the Apache Soft

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[jira] [Closed] (FLINK-25272) Flink sql syntax analysis is inconsistent with the sql grammer declared now

2021-12-14 Thread Jianhui Dong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jianhui Dong closed FLINK-25272. Resolution: Invalid > Flink sql syntax analysis is inconsistent with the sql grammer declared now

[jira] [Commented] (FLINK-25272) Flink sql syntax analysis is inconsistent with the sql grammer declared now

2021-12-14 Thread Jianhui Dong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17459687#comment-17459687 ] Jianhui Dong commented on FLINK-25272: -- Thank you for your reply, I'm sorry that I

[jira] [Updated] (FLINK-24557) Support Knn in FlinkML

2021-12-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24557: --- Labels: pull-request-available (was: ) > Support Knn in FlinkML > -- >

[GitHub] [flink-ml] lindong28 commented on pull request #24: [FLINK-24557] Add Estimator and Transformer for K-nearest neighbor

2021-12-14 Thread GitBox
lindong28 commented on pull request #24: URL: https://github.com/apache/flink-ml/pull/24#issuecomment-994379627 Thanks for the update! The PR LGTM overall. I have only one question as specified in the unresolved comment. Thank you and @zhipeng93 both for all the efforts improving the

[GitHub] [flink-ml] lindong28 edited a comment on pull request #24: [FLINK-24557] Add Estimator and Transformer for K-nearest neighbor

2021-12-14 Thread GitBox
lindong28 edited a comment on pull request #24: URL: https://github.com/apache/flink-ml/pull/24#issuecomment-994379627 Thanks for the update! The PR LGTM overall. I have only one question as specified in the unresolved comment. Thank you and @zhipeng93 both for all the efforts improv

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[GitHub] [flink] xiangqiao123 commented on a change in pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

2021-12-14 Thread GitBox
xiangqiao123 commented on a change in pull request #18023: URL: https://github.com/apache/flink/pull/18023#discussion_r769297327 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java ## @@ -307,13 +323,21 @@ public JobVertexI

[jira] [Commented] (FLINK-25316) BlobServer can get stuck during shutdown

2021-12-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17459683#comment-17459683 ] Robert Metzger commented on FLINK-25316: I reverted the commit from FLINK-24156,

[jira] [Commented] (FLINK-24948) Special character in column names breaks JDBC statement parsing

2021-12-14 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17459681#comment-17459681 ] Paul Lin commented on FLINK-24948: -- [~jark] I've prepared a PR, PTAL. Thanks! > Specia

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[GitHub] [flink] flinkbot edited a comment on pull request #17991: [FLINK-25132][connector/kafka] Move record deserializing from SplitFetcher to RecordEmitter to support object-reusing deserializer

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

[GitHub] [flink] flinkbot edited a comment on pull request #17991: [FLINK-25132][connector/kafka] Move record deserializing from SplitFetcher to RecordEmitter to support object-reusing deserializer

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

[jira] [Updated] (FLINK-25316) BlobServer can get stuck during shutdown

2021-12-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-25316: --- Description: The cluster shutdown can get stuck {code} "AkkaRpcService-Supervisor-Terminatio

[jira] [Commented] (FLINK-24113) Introduce option in Application Mode to disable shutdown

2021-12-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17459674#comment-17459674 ] Robert Metzger commented on FLINK-24113: I filed a separate ticket https://issue

[jira] [Created] (FLINK-25316) BlobServer can get stuck during shutdown

2021-12-14 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-25316: -- Summary: BlobServer can get stuck during shutdown Key: FLINK-25316 URL: https://issues.apache.org/jira/browse/FLINK-25316 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #17711: [FLINK-24737][runtime-web] Update outdated web dependencies

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

[GitHub] [flink] yangjunhan commented on pull request #17711: [FLINK-24737][runtime-web] Update outdated web dependencies

2021-12-14 Thread GitBox
yangjunhan commented on pull request #17711: URL: https://github.com/apache/flink/pull/17711#issuecomment-994350770 > Can you have a look at the failing build and fix it? @MartijnVisser Conflicts have been addressed. -- This is an automated message from the Apache Git Service. To r

[GitHub] [flink] flinkbot edited a comment on pull request #17711: [FLINK-24737][runtime-web] Update outdated web dependencies

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

[GitHub] [flink] flinkbot edited a comment on pull request #16108: [FLINK-22821][core] Stabilize NetUtils#getAvailablePort in order to avoid wrongly allocating any used ports

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

[GitHub] [flink] paul8263 commented on pull request #16108: [FLINK-22821][core] Stabilize NetUtils#getAvailablePort in order to avoid wrongly allocating any used ports

2021-12-14 Thread GitBox
paul8263 commented on pull request #16108: URL: https://github.com/apache/flink/pull/16108#issuecomment-994342748 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[jira] [Created] (FLINK-25315) Add some extensions and utils to help the Junit5 migration

2021-12-14 Thread Hang Ruan (Jira)
Hang Ruan created FLINK-25315: - Summary: Add some extensions and utils to help the Junit5 migration Key: FLINK-25315 URL: https://issues.apache.org/jira/browse/FLINK-25315 Project: Flink Issue Ty

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

2021-12-14 Thread GitBox
flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 5288bcedbae945ad9d8e310850865a0533a002c3 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-25231) Update PyFlink to use the new type system

2021-12-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17459666#comment-17459666 ] Dian Fu commented on FLINK-25231: - [~csq] Sure. Thanks for taking this ticket. Have assi

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

2021-12-14 Thread GitBox
flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 5288bcedbae945ad9d8e310850865a0533a002c3 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Assigned] (FLINK-25231) Update PyFlink to use the new type system

2021-12-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-25231: --- Assignee: Shuiqiang Chen > Update PyFlink to use the new type system >

[GitHub] [flink] flinkbot edited a comment on pull request #17919: [FLINK-24419][table-planner] Trim to precision when casting to BINARY/VARBINARY

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

[GitHub] [flink] flinkbot edited a comment on pull request #17919: [FLINK-24419][table-planner] Trim to precision when casting to BINARY/VARBINARY

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

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

2021-12-14 Thread GitBox
flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 5288bcedbae945ad9d8e310850865a0533a002c3 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18110: [FLINK-25310][Documentation] Fix the incorrect description for output network buffers in buffer debloat documenation

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

[GitHub] [flink] ljz2051 commented on pull request #18111: [FLINK-25094][Test]Correct the LatencyTrackingMapStateTest#verifyIterator

2021-12-14 Thread GitBox
ljz2051 commented on pull request #18111: URL: https://github.com/apache/flink/pull/18111#issuecomment-994287269 @Myasuka Could you review this change for LatencyTrackingMapStateTest when you are free? -- This is an automated message from the Apache Git Service. To respond to the message

[jira] [Comment Edited] (FLINK-25159) Streamline E2E surefire configuration setup

2021-12-14 Thread Yufei Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17459641#comment-17459641 ] Yufei Zhang edited comment on FLINK-25159 at 12/15/21, 4:40 AM: --

[GitHub] [flink] flinkbot commented on pull request #18111: [FLINK-25094][Test]Correct the LatencyTrackingMapStateTest#verifyIterator

2021-12-14 Thread GitBox
flinkbot commented on pull request #18111: URL: https://github.com/apache/flink/pull/18111#issuecomment-994286257 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] flinkbot edited a comment on pull request #18111: [FLINK-25094][Test]Correct the LatencyTrackingMapStateTest#verifyIterator

2021-12-14 Thread GitBox
flinkbot edited a comment on pull request #18111: URL: https://github.com/apache/flink/pull/18111#issuecomment-994285128 ## CI report: * 930b0c12d7dad620b6e15c23289f2e2666ce0ed0 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Comment Edited] (FLINK-25159) Streamline E2E surefire configuration setup

2021-12-14 Thread Yufei Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17459641#comment-17459641 ] Yufei Zhang edited comment on FLINK-25159 at 12/15/21, 4:37 AM: --

[GitHub] [flink] flinkbot commented on pull request #18111: [FLINK-25094][Test]Correct the LatencyTrackingMapStateTest#verifyIter…

2021-12-14 Thread GitBox
flinkbot commented on pull request #18111: URL: https://github.com/apache/flink/pull/18111#issuecomment-994285128 ## CI report: * 930b0c12d7dad620b6e15c23289f2e2666ce0ed0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Updated] (FLINK-25094) The verify code in LatencyTrackingMapStateTest#verifyIterator is not actually executed

2021-12-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25094: --- Labels: pull-request-available (was: ) > The verify code in LatencyTrackingMapStateTest#ver

  1   2   3   4   5   6   7   8   >