[GitHub] [flink] AHeise commented on pull request #14622: [FLINK-20727][connector] pulsar SourceFunction

AHeise commented on pull request #14622: URL: https://github.com/apache/flink/pull/14622#issuecomment-771496688 Sorry for coming back so late to this PR. Code-wise, it looks mostly fine. I would add a complete code review later. However, I'd like to clarify first, why we want to

[jira] [Commented] (FLINK-21232) Introduce pluggable Hadoop delegation token providers

[ https://issues.apache.org/jira/browse/FLINK-21232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276996#comment-17276996 ] Till Rohrmann commented on FLINK-21232: --- Thanks for creating this ticket [~jackwangcs]. At the

[GitHub] [flink] flinkbot edited a comment on pull request #14648: [FLINK-20978] Implement HeapSavepointRestoreOperation

flinkbot edited a comment on pull request #14648: URL: https://github.com/apache/flink/pull/14648#issuecomment-760154698 ## CI report: * c11e99641a53be119fa9aa644766612b6773ffd7 UNKNOWN * 6698ad9cd6dd1a7c2618ca6f00b2ab621ba55a91 UNKNOWN *

[jira] [Comment Edited] (FLINK-21234) testKafkaSourceSinkWithKeyAndPartialValue[legacy = false, format = csv] hang

[ https://issues.apache.org/jira/browse/FLINK-21234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277003#comment-17277003 ] Piotr Nowojski edited comment on FLINK-21234 at 2/2/21, 10:04 AM: -- This

[jira] [Commented] (FLINK-17793) Replace TableSchema with dedicated CatalogSchema

[ https://issues.apache.org/jira/browse/FLINK-17793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277012#comment-17277012 ] Timo Walther commented on FLINK-17793: -- [~ykt836] We resolve data types and expressions. Regarding

[GitHub] [flink] flinkbot edited a comment on pull request #14809: [FLINK-21206] Implement HeapKeyValueStateIterator

flinkbot edited a comment on pull request #14809: URL: https://github.com/apache/flink/pull/14809#issuecomment-769830749 ## CI report: * 4ef80f614e8ac4b5facd6f68f802746584420121 UNKNOWN * 1aa8ebbe01b58578c232d195e721256e06d601e0 Azure:

[GitHub] [flink] lovelock opened a new pull request #14833: Upgrade monaco-editor to fix scroll bug in Firefox

lovelock opened a new pull request #14833: URL: https://github.com/apache/flink/pull/14833 see this https://github.com/microsoft/monaco-editor/issues/1353 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob

[jira] [Commented] (FLINK-21103) E2e tests time out on azure

[ https://issues.apache.org/jira/browse/FLINK-21103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277055#comment-17277055 ] Dawid Wysakowicz commented on FLINK-21103: --

[GitHub] [flink] flinkbot edited a comment on pull request #14648: [FLINK-20978] Implement HeapSavepointRestoreOperation

flinkbot edited a comment on pull request #14648: URL: https://github.com/apache/flink/pull/14648#issuecomment-760154698 ## CI report: * c11e99641a53be119fa9aa644766612b6773ffd7 UNKNOWN * 6698ad9cd6dd1a7c2618ca6f00b2ab621ba55a91 UNKNOWN *

[GitHub] [flink] twalthr closed pull request #14801: [FLINK-20942][planner] Digest of FLOAT literals throws UnsupportedOpe…

twalthr closed pull request #14801: URL: https://github.com/apache/flink/pull/14801 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

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277008#comment-17277008 ] Till Rohrmann commented on FLINK-20663: --- Thanks for driving the discussion. I feel that I lack a

[jira] [Updated] (FLINK-20873) Upgrade Calcite version to 1.27

[ https://issues.apache.org/jira/browse/FLINK-20873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-20873: - Description: The following files should be removed from the Flink code base during an upgrade:

[GitHub] [flink] lovelock commented on pull request #14833: Upgrade monaco-editor to fix scroll bug in Firefox

lovelock commented on pull request #14833: URL: https://github.com/apache/flink/pull/14833#issuecomment-771549275 comment to rerun check -- Original -- From: flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14809: [FLINK-21206] Implement HeapKeyValueStateIterator

flinkbot edited a comment on pull request #14809: URL: https://github.com/apache/flink/pull/14809#issuecomment-769830749 ## CI report: * 4ef80f614e8ac4b5facd6f68f802746584420121 UNKNOWN * a22e95072ffea536662db677f36f7d8208e9976d Azure:

[jira] [Commented] (FLINK-21030) Broken job restart for job with disjoint graph

[ https://issues.apache.org/jira/browse/FLINK-21030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276965#comment-17276965 ] Yun Tang commented on FLINK-21030: -- I think returning the complete future to checkpoint coordinator to

[jira] [Commented] (FLINK-21221) Deduplication of ResourceCounter

[ https://issues.apache.org/jira/browse/FLINK-21221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276988#comment-17276988 ] Till Rohrmann commented on FLINK-21221: --- Deduplicating code sounds always like a good idea. Which

[jira] [Commented] (FLINK-7450) Bounded generic POJO field is identified as Object by TypeExtractor

[ https://issues.apache.org/jira/browse/FLINK-7450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277010#comment-17277010 ] Timo Walther commented on FLINK-7450: - I have closed the PR for now because we still don't have a

[jira] [Commented] (FLINK-21030) Broken job restart for job with disjoint graph

[ https://issues.apache.org/jira/browse/FLINK-21030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277024#comment-17277024 ] Matthias commented on FLINK-21030: -- You're right: My proposal would affect the checkpoint creation as

[GitHub] [flink] flinkbot edited a comment on pull request #14759: [FLINK-21149][table-common] Remove deprecated CatalogBaseTable.getProperties()

flinkbot edited a comment on pull request #14759: URL: https://github.com/apache/flink/pull/14759#issuecomment-767522286 ## CI report: * f29998b77b31894984c3b68d179e9c38235fc685 Azure:

[GitHub] [flink] flinkbot commented on pull request #14833: Upgrade monaco-editor to fix scroll bug in Firefox

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

[GitHub] [flink] flinkbot edited a comment on pull request #14809: [FLINK-21206] Implement HeapKeyValueStateIterator

flinkbot edited a comment on pull request #14809: URL: https://github.com/apache/flink/pull/14809#issuecomment-769830749 ## CI report: * 4ef80f614e8ac4b5facd6f68f802746584420121 UNKNOWN * 1aa8ebbe01b58578c232d195e721256e06d601e0 Azure:

[jira] [Commented] (FLINK-21221) Deduplication of ResourceCounter

[ https://issues.apache.org/jira/browse/FLINK-21221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277033#comment-17277033 ] Yangze Guo commented on FLINK-21221: The

[jira] [Assigned] (FLINK-20417) Handle "Too old resource version" exception in Kubernetes watch more gracefully

[ https://issues.apache.org/jira/browse/FLINK-20417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-20417: - Assignee: Yang Wang > Handle "Too old resource version" exception in Kubernetes watch more >

[jira] [Commented] (FLINK-20417) Handle "Too old resource version" exception in Kubernetes watch more gracefully

[ https://issues.apache.org/jira/browse/FLINK-20417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277046#comment-17277046 ] Yang Wang commented on FLINK-20417: --- Since more than one users reported this issue in the ML, I will

[GitHub] [flink] flinkbot edited a comment on pull request #14648: [FLINK-20978] Implement HeapSavepointRestoreOperation

flinkbot edited a comment on pull request #14648: URL: https://github.com/apache/flink/pull/14648#issuecomment-760154698 ## CI report: * c11e99641a53be119fa9aa644766612b6773ffd7 UNKNOWN * 6698ad9cd6dd1a7c2618ca6f00b2ab621ba55a91 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14740: [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks

flinkbot edited a comment on pull request #14740: URL: https://github.com/apache/flink/pull/14740#issuecomment-766340750 ## CI report: * e9394c62c445d5a17f802d0b6eee51bce00d9df9 Azure:

[jira] [Updated] (FLINK-21232) Introduce pluggable Hadoop delegation token providers

[ https://issues.apache.org/jira/browse/FLINK-21232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-21232: -- Component/s: Connectors / Common > Introduce pluggable Hadoop delegation token providers >

[GitHub] [flink] twalthr commented on pull request #6034: [FLINK-7450] [types] Fix type extraction of bounded generic POJO fields

twalthr commented on pull request #6034: URL: https://github.com/apache/flink/pull/6034#issuecomment-771522812 I will close it for now. Maybe we can include it in Flink 2.0 or so. This is an automated message from the Apache

[GitHub] [flink] twalthr closed pull request #6034: [FLINK-7450] [types] Fix type extraction of bounded generic POJO fields

twalthr closed pull request #6034: URL: https://github.com/apache/flink/pull/6034 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

[GitHub] [flink] flinkbot edited a comment on pull request #14759: [FLINK-21149][table-common] Remove deprecated CatalogBaseTable.getProperties()

flinkbot edited a comment on pull request #14759: URL: https://github.com/apache/flink/pull/14759#issuecomment-767522286 ## CI report: * f29998b77b31894984c3b68d179e9c38235fc685 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14833: Upgrade monaco-editor to fix scroll bug in Firefox

flinkbot edited a comment on pull request #14833: URL: https://github.com/apache/flink/pull/14833#issuecomment-771545024 ## CI report: * a068b3e8bf49fd641d0b4d288a0c670a4321dcae UNKNOWN * 548b9675a52191552a4fa8c3e597718ffe959706 UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on pull request #14648: [FLINK-20978] Implement HeapSavepointRestoreOperation

flinkbot edited a comment on pull request #14648: URL: https://github.com/apache/flink/pull/14648#issuecomment-760154698 ## CI report: * c11e99641a53be119fa9aa644766612b6773ffd7 UNKNOWN * 6698ad9cd6dd1a7c2618ca6f00b2ab621ba55a91 UNKNOWN *

[jira] [Commented] (FLINK-21030) Broken job restart for job with disjoint graph

[ https://issues.apache.org/jira/browse/FLINK-21030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277054#comment-17277054 ] Till Rohrmann commented on FLINK-21030: --- I am not entirely sure whether adjusting the checkpoint

[GitHub] [flink] gaoyunhaii edited a comment on pull request #14740: [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks

gaoyunhaii edited a comment on pull request #14740: URL: https://github.com/apache/flink/pull/14740#issuecomment-771480929 Hi @aljoscha Very thanks for the review and patches, I like the patches for they make the calculation process much more clear. I have updated the PR according to the

[jira] [Assigned] (FLINK-21210) ApplicationClusterEntryPoints should explicitly close PackagedProgram

[ https://issues.apache.org/jira/browse/FLINK-21210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-21210: - Assignee: Nicholas Jiang > ApplicationClusterEntryPoints should explicitly close

[jira] [Updated] (FLINK-20417) Handle "Too old resource version" exception in Kubernetes watch more gracefully

[ https://issues.apache.org/jira/browse/FLINK-20417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20417: -- Priority: Critical (was: Major) > Handle "Too old resource version" exception in Kubernetes

[GitHub] [flink] flinkbot edited a comment on pull request #14729: [FLINK-21092][FLINK-21093][FLINK-21094][FLINK-21096][table-planner-blink] Support ExecNode plan serialization/deserialization for `IN

flinkbot edited a comment on pull request #14729: URL: https://github.com/apache/flink/pull/14729#issuecomment-765399004 ## CI report: * b39c8c7d0f68afd25fec0cf79b7fdf9f0d8d37d7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14648: [FLINK-20978] Implement HeapSavepointRestoreOperation

flinkbot edited a comment on pull request #14648: URL: https://github.com/apache/flink/pull/14648#issuecomment-760154698 ## CI report: * c11e99641a53be119fa9aa644766612b6773ffd7 UNKNOWN * 6698ad9cd6dd1a7c2618ca6f00b2ab621ba55a91 UNKNOWN *

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277032#comment-17277032 ] Kurt Young commented on FLINK-20663: [~trohrmann] Things are becoming more interesting. If I

[GitHub] [flink] flinkbot edited a comment on pull request #14809: [FLINK-21206] Implement HeapKeyValueStateIterator

flinkbot edited a comment on pull request #14809: URL: https://github.com/apache/flink/pull/14809#issuecomment-769830749 ## CI report: * 4ef80f614e8ac4b5facd6f68f802746584420121 UNKNOWN * 4eaeb259d3b7a57db6c0c5efa36dc404a000b485 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14833: Upgrade monaco-editor to fix scroll bug in Firefox

flinkbot edited a comment on pull request #14833: URL: https://github.com/apache/flink/pull/14833#issuecomment-771545024 ## CI report: * a068b3e8bf49fd641d0b4d288a0c670a4321dcae UNKNOWN * 548b9675a52191552a4fa8c3e597718ffe959706 Azure:

[jira] [Commented] (FLINK-21200) User defined functions refuse to accept multi-set arguments without type hints

[ https://issues.apache.org/jira/browse/FLINK-21200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276941#comment-17276941 ] Timo Walther commented on FLINK-21200: -- String can handle all CHAR types because we introduce a

[GitHub] [flink] flinkbot edited a comment on pull request #14802: [FLINK-21185][table-common][table-api-java] Introduce a new interface…

flinkbot edited a comment on pull request #14802: URL: https://github.com/apache/flink/pull/14802#issuecomment-769642965 ## CI report: * 09cb5445a5a4342fddd5b7a3addaa84760ae0b53 Azure:

[jira] [Updated] (FLINK-21117) KafkaProducerExactlyOnceITCase fails with "Exceeded checkpoint tolerable failure threshold."

[ https://issues.apache.org/jira/browse/FLINK-21117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-21117: --- Component/s: (was: Runtime / Checkpointing) > KafkaProducerExactlyOnceITCase fails with

[GitHub] [flink] gaoyunhaii commented on pull request #14740: [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks

gaoyunhaii commented on pull request #14740: URL: https://github.com/apache/flink/pull/14740#issuecomment-771480929 Hi @aljoscha I like the two patches for they make the calculation process much more clear. I have updated the PR according to the comments.

[GitHub] [flink] flinkbot edited a comment on pull request #14809: [FLINK-21206] Implement HeapKeyValueStateIterator

flinkbot edited a comment on pull request #14809: URL: https://github.com/apache/flink/pull/14809#issuecomment-769830749 ## CI report: * 4ef80f614e8ac4b5facd6f68f802746584420121 UNKNOWN * 1aa8ebbe01b58578c232d195e721256e06d601e0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14802: [FLINK-21185][table-common][table-api-java] Introduce a new interface…

flinkbot edited a comment on pull request #14802: URL: https://github.com/apache/flink/pull/14802#issuecomment-769642965 ## CI report: * 09cb5445a5a4342fddd5b7a3addaa84760ae0b53 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14802: [FLINK-21185][table-common][table-api-java] Introduce a new interface…

flinkbot edited a comment on pull request #14802: URL: https://github.com/apache/flink/pull/14802#issuecomment-769642965 ## CI report: * c1b0c4d7acb0119916c2ddfe42169c600279bb77 Azure:

[GitHub] [flink] AHeise commented on pull request #14623: [FLINK-20728][connector] Pulsar SinkFunction

AHeise commented on pull request #14623: URL: https://github.com/apache/flink/pull/14623#issuecomment-771497779 Sorry for coming back so late to this PR. Code-wise, it looks mostly fine. I would add a complete code review later. However, I'd like to clarify first, why we want to

[jira] [Commented] (FLINK-21234) testKafkaSourceSinkWithKeyAndPartialValue[legacy = false, format = csv] hang

[ https://issues.apache.org/jira/browse/FLINK-21234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277003#comment-17277003 ] Piotr Nowojski commented on FLINK-21234: Those two issues might be related to one another >

[jira] [Comment Edited] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277008#comment-17277008 ] Till Rohrmann edited comment on FLINK-20663 at 2/2/21, 10:11 AM: - Thanks

[GitHub] [flink] flinkbot edited a comment on pull request #14729: [FLINK-21092][FLINK-21093][FLINK-21094][FLINK-21096][table-planner-blink] Support ExecNode plan serialization/deserialization for `IN

flinkbot edited a comment on pull request #14729: URL: https://github.com/apache/flink/pull/14729#issuecomment-765399004 ## CI report: * b39c8c7d0f68afd25fec0cf79b7fdf9f0d8d37d7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14648: [FLINK-20978] Implement HeapSavepointRestoreOperation

flinkbot edited a comment on pull request #14648: URL: https://github.com/apache/flink/pull/14648#issuecomment-760154698 ## CI report: * c11e99641a53be119fa9aa644766612b6773ffd7 UNKNOWN * 6698ad9cd6dd1a7c2618ca6f00b2ab621ba55a91 UNKNOWN *

[GitHub] [flink] lovelock closed pull request #14833: Upgrade monaco-editor to fix scroll bug in Firefox

lovelock closed pull request #14833: URL: https://github.com/apache/flink/pull/14833 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

[GitHub] [flink] flinkbot commented on pull request #14833: Upgrade monaco-editor to fix scroll bug in Firefox

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

[GitHub] [flink] flinkbot edited a comment on pull request #14648: [FLINK-20978] Implement HeapSavepointRestoreOperation

flinkbot edited a comment on pull request #14648: URL: https://github.com/apache/flink/pull/14648#issuecomment-760154698 ## CI report: * c11e99641a53be119fa9aa644766612b6773ffd7 UNKNOWN * 6698ad9cd6dd1a7c2618ca6f00b2ab621ba55a91 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14809: [FLINK-21206] Implement HeapKeyValueStateIterator

flinkbot edited a comment on pull request #14809: URL: https://github.com/apache/flink/pull/14809#issuecomment-769830749 ## CI report: * 4ef80f614e8ac4b5facd6f68f802746584420121 UNKNOWN * a22e95072ffea536662db677f36f7d8208e9976d Azure:

[jira] [Commented] (FLINK-21117) KafkaProducerExactlyOnceITCase fails with "Exceeded checkpoint tolerable failure threshold."

[ https://issues.apache.org/jira/browse/FLINK-21117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276961#comment-17276961 ] Piotr Nowojski commented on FLINK-21117: I've removed {{Runtime / Checkpointing}} tag. I've

[jira] [Assigned] (FLINK-21110) Optimize Scheduler Performance for Large-Scale Jobs

[ https://issues.apache.org/jira/browse/FLINK-21110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-21110: - Assignee: Zhilong Hong > Optimize Scheduler Performance for Large-Scale Jobs >

[GitHub] [flink] flinkbot edited a comment on pull request #14740: [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks

flinkbot edited a comment on pull request #14740: URL: https://github.com/apache/flink/pull/14740#issuecomment-766340750 ## CI report: * e9394c62c445d5a17f802d0b6eee51bce00d9df9 Azure:

[GitHub] [flink] twalthr commented on pull request #6034: [FLINK-7450] [types] Fix type extraction of bounded generic POJO fields

twalthr commented on pull request #6034: URL: https://github.com/apache/flink/pull/6034#issuecomment-771521739 @echauchot the PR is quite old. actually it is valid but would break backwards compatibility with records stored in Flink's state

[jira] [Closed] (FLINK-20942) Digest of FLOAT literals throws UnsupportedOperationException

[ https://issues.apache.org/jira/browse/FLINK-20942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-20942. Assignee: Danny Chen Resolution: Fixed Fixed in 1.13.0:

[jira] [Created] (FLINK-21239) Upgrade Calcite version to 1.28

Timo Walther created FLINK-21239: Summary: Upgrade Calcite version to 1.28 Key: FLINK-21239 URL: https://issues.apache.org/jira/browse/FLINK-21239 Project: Flink Issue Type: Improvement

[GitHub] [flink] xintongsong closed pull request #14832: [FLINK-20359][k8s] Added Owner Reference to Job Manager in native kub…

xintongsong closed pull request #14832: URL: https://github.com/apache/flink/pull/14832 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

[GitHub] [flink] xintongsong commented on pull request #14832: [FLINK-20359][k8s] Added Owner Reference to Job Manager in native kub…

xintongsong commented on pull request #14832: URL: https://github.com/apache/flink/pull/14832#issuecomment-771584887 Closed via 82a7f8ee120e2821668a21881c09b44bd1918f6e This is an automated message from the Apache Git

[jira] [Created] (FLINK-21240) incompati datetime

macdoor615 created FLINK-21240: -- Summary: incompati datetime Key: FLINK-21240 URL: https://issues.apache.org/jira/browse/FLINK-21240 Project: Flink Issue Type: Bug Reporter:

[jira] [Commented] (FLINK-21240) incompati datetime

[ https://issues.apache.org/jira/browse/FLINK-21240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277087#comment-17277087 ] Chesnay Schepler commented on FLINK-21240: -- [~macdoor615] It seems something went wrong when

[jira] [Created] (FLINK-21242) Support state access API for map operation

Wei Zhong created FLINK-21242: - Summary: Support state access API for map operation Key: FLINK-21242 URL: https://issues.apache.org/jira/browse/FLINK-21242 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-20784) .staging_xxx does not exist, when insert into hive

[ https://issues.apache.org/jira/browse/FLINK-20784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-20784: - Environment: (was: standalone cluster, batch mode,) > .staging_xxx does not exist,

[GitHub] [flink] Myasuka commented on pull request #14826: [FLINK-12358][docs] Add IT case to verify REST docs corresponding to the code

Myasuka commented on pull request #14826: URL: https://github.com/apache/flink/pull/14826#issuecomment-771607651 Previous CI failed due to FLINK-21241 @flinkbot run azure This is an automated message from the

[GitHub] [flink] flinkbot commented on pull request #14834: [FLINK-21234][build system] Adding timeout to all tasks

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

[jira] [Updated] (FLINK-20784) .staging_xxx does not exist, when insert into hive

[ https://issues.apache.org/jira/browse/FLINK-20784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-20784: - Fix Version/s: (was: 1.12.1) (was: 1.13.0) > .staging_xxx

[GitHub] [flink] flinkbot edited a comment on pull request #14809: [FLINK-21206] Implement HeapKeyValueStateIterator

flinkbot edited a comment on pull request #14809: URL: https://github.com/apache/flink/pull/14809#issuecomment-769830749 ## CI report: * 4ef80f614e8ac4b5facd6f68f802746584420121 UNKNOWN * 6995f6b05c55c8c3c162d2483e45539604520787 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14766: [FLINK-20254][hive] Make PartitionMonitor fetching partitions with same create time properly

flinkbot edited a comment on pull request #14766: URL: https://github.com/apache/flink/pull/14766#issuecomment-767662801 ## CI report: * 1275e312138642ea6a6d00f4ff8bd225723ec903 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14729: [FLINK-21092][FLINK-21093][FLINK-21094][FLINK-21096][table-planner-blink] Support ExecNode plan serialization/deserialization for `IN

flinkbot edited a comment on pull request #14729: URL: https://github.com/apache/flink/pull/14729#issuecomment-765399004 ## CI report: * 8e7fedb102a0d654ecd59f862e9b912471c2386f Azure:

[GitHub] [flink] rmetzger commented on pull request #14678: [FLINK-20833][runtime] Add pluggable failure listener in job manager

rmetzger commented on pull request #14678: URL: https://github.com/apache/flink/pull/14678#issuecomment-771681310 I noticed one issue during my manual review: When using a logger in the factory (loaded via the plugin mechanism), log4j will create a new log file. This is most likely caused

[jira] [Closed] (FLINK-20359) Support adding Owner Reference to Job Manager in native kubernetes setup

[ https://issues.apache.org/jira/browse/FLINK-20359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-20359. Resolution: Fixed Fixed compiling error and merged into release-1.12 via

[GitHub] [flink] JingsongLi commented on a change in pull request #14766: [FLINK-20254][hive] Make PartitionMonitor fetching partitions with same create time properly

JingsongLi commented on a change in pull request #14766: URL: https://github.com/apache/flink/pull/14766#discussion_r568547518 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveLookupTableSource.java ## @@ -323,5 +324,28 @@

[jira] [Updated] (FLINK-21240) incompatible datetime with MySql JDBC Driver 8.0.23

[ https://issues.apache.org/jira/browse/FLINK-21240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] macdoor615 updated FLINK-21240: --- Description: 1. upgrade mysql JDBC Driver from mysql-connector-java-8.0.22.jar to 

[GitHub] [flink] Myasuka opened a new pull request #14835: [FLINK-21213][task] Degrade log level to INFO when ignore to decline checkpoint as task not running

Myasuka opened a new pull request #14835: URL: https://github.com/apache/flink/pull/14835 ## What is the purpose of the change Degrade log level to INFO when ignore to decline checkpoint as task not running to avoid unexpected E2E test failure. ## Brief change log

[GitHub] [flink] flinkbot edited a comment on pull request #14809: [FLINK-21206] Implement HeapKeyValueStateIterator

flinkbot edited a comment on pull request #14809: URL: https://github.com/apache/flink/pull/14809#issuecomment-769830749 ## CI report: * 4ef80f614e8ac4b5facd6f68f802746584420121 UNKNOWN * 6995f6b05c55c8c3c162d2483e45539604520787 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14740: [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks

flinkbot edited a comment on pull request #14740: URL: https://github.com/apache/flink/pull/14740#issuecomment-766340750 ## CI report: * e9394c62c445d5a17f802d0b6eee51bce00d9df9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14788: [FLINK-21180][python] Move the state module from 'pyflink.common' to 'pyflink.datastream'.

flinkbot edited a comment on pull request #14788: URL: https://github.com/apache/flink/pull/14788#issuecomment-768901227 ## CI report: * d94aafa70618cb1a1f7763ee818be00abc8dcdf4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14826: [FLINK-12358][docs] Add IT case to verify REST docs corresponding to the code

flinkbot edited a comment on pull request #14826: URL: https://github.com/apache/flink/pull/14826#issuecomment-770627972 ## CI report: * ce1c42b9e4162b61553f3fadd02d30107047f91d Azure:

[jira] [Closed] (FLINK-9683) inconsistent behaviors when setting historyserver.archive.fs.dir

[ https://issues.apache.org/jira/browse/FLINK-9683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9683. --- Fix Version/s: 1.13.0 Resolution: Fixed master:

[GitHub] [flink] zentol merged pull request #14771: [FLINK-9683] Allow history server use default fs scheme

zentol merged pull request #14771: URL: https://github.com/apache/flink/pull/14771 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

[jira] [Updated] (FLINK-9683) HistoryServer should honor fs.default-scheme

[ https://issues.apache.org/jira/browse/FLINK-9683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9683: Summary: HistoryServer should honor fs.default-scheme (was: inconsistent behaviors when

[jira] [Updated] (FLINK-9683) HistoryServer should honor fs.default-scheme

[ https://issues.apache.org/jira/browse/FLINK-9683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9683: Issue Type: Improvement (was: Bug) > HistoryServer should honor fs.default-scheme >

[jira] [Created] (FLINK-21243) Add Java SDK maven module

Igal Shilman created FLINK-21243: Summary: Add Java SDK maven module Key: FLINK-21243 URL: https://issues.apache.org/jira/browse/FLINK-21243 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277194#comment-17277194 ] Kezhu Wang commented on FLINK-21132: {quote} Keep in mind that while task is spinning inside

[GitHub] [flink] flinkbot edited a comment on pull request #13551: [FLINK-19520][configuration] Add randomization of checkpoint config.

flinkbot edited a comment on pull request #13551: URL: https://github.com/apache/flink/pull/13551#issuecomment-704858051 ## CI report: * 019646dd12750ec211a543f858836637a164d845 UNKNOWN * 0e119ed52f21bc045418a0a3c2cf3cc3e1d69f83 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14809: [FLINK-21206] Implement HeapKeyValueStateIterator

flinkbot edited a comment on pull request #14809: URL: https://github.com/apache/flink/pull/14809#issuecomment-769830749 ## CI report: * 4ef80f614e8ac4b5facd6f68f802746584420121 UNKNOWN * 4eaeb259d3b7a57db6c0c5efa36dc404a000b485 Azure:

[GitHub] [flink] AHeise opened a new pull request #14834: [FLINK-21234][build system] Adding timeout to all tasks

AHeise opened a new pull request #14834: URL: https://github.com/apache/flink/pull/14834 ## What is the purpose of the change When a test gets stuck, it's usually killed after 10 min of inactivity. #13260 excluded all tests that still show log activity from this timeout to

[GitHub] [flink] flinkbot edited a comment on pull request #14648: [FLINK-20978] Implement HeapSavepointRestoreOperation

flinkbot edited a comment on pull request #14648: URL: https://github.com/apache/flink/pull/14648#issuecomment-760154698 ## CI report: * c11e99641a53be119fa9aa644766612b6773ffd7 UNKNOWN * 6698ad9cd6dd1a7c2618ca6f00b2ab621ba55a91 UNKNOWN *

[jira] [Commented] (FLINK-21208) pyarrow exception when using window with pandas udaf

[ https://issues.apache.org/jira/browse/FLINK-21208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277082#comment-17277082 ] YufeiLiu commented on FLINK-21208: -- [~hxbks2ks] I still have a question, I haven't use arrow before and

[jira] [Created] (FLINK-21241) E2E test exception check might fail if older checkpoint not completed when triggering the stop-with-savepoint

Yun Tang created FLINK-21241: Summary: E2E test exception check might fail if older checkpoint not completed when triggering the stop-with-savepoint Key: FLINK-21241 URL:

[jira] [Commented] (FLINK-21213) e2e test fail with 'As task is already not running, no longer decline checkpoint'

[ https://issues.apache.org/jira/browse/FLINK-21213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277092#comment-17277092 ] Arvid Heise commented on FLINK-21213: - On INFO, it probably still triggers e2e failure, cf.

[jira] [Commented] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277083#comment-17277083 ] Piotr Nowojski commented on FLINK-21132: I'm sharing the same concern as [~roman_khachatryan]

[GitHub] [flink] flinkbot edited a comment on pull request #14788: [FLINK-21180][python] Move the state module from 'pyflink.common' to 'pyflink.datastream'.

flinkbot edited a comment on pull request #14788: URL: https://github.com/apache/flink/pull/14788#issuecomment-768901227 ## CI report: * d94aafa70618cb1a1f7763ee818be00abc8dcdf4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14740: [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks

flinkbot edited a comment on pull request #14740: URL: https://github.com/apache/flink/pull/14740#issuecomment-766340750 ## CI report: * e9394c62c445d5a17f802d0b6eee51bce00d9df9 Azure:

  1   2   3   4   5   >