[GitHub] [flink] SteNicholas removed a comment on pull request #14822: [FLINK-21005][table-api] Introduce new provider for unified Sink API and implement in planner

SteNicholas removed a comment on pull request #14822: URL: https://github.com/apache/flink/pull/14822#issuecomment-780568737 @wuchong , I have followed your detailed comments about the refactoring of `CommonExecSink#createSinkTransformation`. Please help to review again.

[GitHub] [flink] zhuzhurk commented on a change in pull request #14955: [FLINK-14869][core] Discard zero-valued extended resources in ResourceSpec/ResourceProfile

zhuzhurk commented on a change in pull request #14955: URL: https://github.com/apache/flink/pull/14955#discussion_r578191731 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java ## @@ -453,10 +456,15 @@ public

[jira] [Commented] (FLINK-21389) ParquetInputFormat should not need parquet schema as user input

[ https://issues.apache.org/jira/browse/FLINK-21389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286320#comment-17286320 ] Etienne Chauchot commented on FLINK-21389: -- Thanks [~ZhenqiuHuang] for your comment. Ok I'll do

[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-781124923 Hi Roman @rkhachatryan , I updated the PR according to the offline discussion: 1. Introduce the interface for `CheckpointPlanCalculator` for future extension. 2.

[GitHub] [flink] flinkbot edited a comment on pull request #14955: [FLINK-14869][core] Discard zero-valued extended resources in ResourceSpec/ResourceProfile

flinkbot edited a comment on pull request #14955: URL: https://github.com/apache/flink/pull/14955#issuecomment-781090588 ## CI report: * d30e5867cdac76e93c1c04cc9df434f66494c107 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14954: [FLINK-17061][runtime] Unset TM total process/flink memory size for fine-grained resource management

flinkbot edited a comment on pull request #14954: URL: https://github.com/apache/flink/pull/14954#issuecomment-781063841 ## CI report: * 6746ea0922384476c2f9f4ad4fcae1273811201f 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: * c7e6b28b249f85cf52740d5201a769e0982a60aa UNKNOWN * bebd298009b12a9d5ac6518902f5534f8e00ff32 UNKNOWN *

[GitHub] [flink] xintongsong commented on pull request #14955: [FLINK-14869][core] Discard zero-valued extended resources in ResourceSpec/ResourceProfile

xintongsong commented on pull request #14955: URL: https://github.com/apache/flink/pull/14955#issuecomment-781120144 Thanks for the review, @KarmaGYZ. Comments addressed. This is an automated message from the Apache Git

[jira] [Resolved] (FLINK-20376) Error in restoring checkpoint/savepoint when Flink is upgraded from 1.9 to 1.11.2

[ https://issues.apache.org/jira/browse/FLINK-20376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Partha Pradeep Mishra resolved FLINK-20376. --- Resolution: Done > Error in restoring checkpoint/savepoint when Flink is

[jira] [Commented] (FLINK-20376) Error in restoring checkpoint/savepoint when Flink is upgraded from 1.9 to 1.11.2

[ https://issues.apache.org/jira/browse/FLINK-20376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286316#comment-17286316 ] Partha Pradeep Mishra commented on FLINK-20376: --- [~pnowojski] Upgrade from 1.9.0 to 1.11.2

[GitHub] [flink] flinkbot edited a comment on pull request #14958: [FLINK-18550][sql-client] use TableResult#collect to get select result for sql client

flinkbot edited a comment on pull request #14958: URL: https://github.com/apache/flink/pull/14958#issuecomment-781106758 ## CI report: * 23715c1def6387cab08ccf963203538fa9074228 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14954: [FLINK-17061][runtime] Unset TM total process/flink memory size for fine-grained resource management

flinkbot edited a comment on pull request #14954: URL: https://github.com/apache/flink/pull/14954#issuecomment-781063841 ## CI report: * 6746ea0922384476c2f9f4ad4fcae1273811201f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14957: [FLINK-20534] Add Flink 1.12 MigrationVersion and add Flink 1.12 snapshots for TypeSerializer upgrade tests

flinkbot edited a comment on pull request #14957: URL: https://github.com/apache/flink/pull/14957#issuecomment-781106649 ## CI report: * dc2f8d2db78483a1d21a376ac0ff36da497f977d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14956: [FLINK-20534] Add Flink 1.12 MigrationVersion and add Flink 1.12 snapshots for TypeSerializer upgrade tests

flinkbot edited a comment on pull request #14956: URL: https://github.com/apache/flink/pull/14956#issuecomment-781106539 ## CI report: * a05e0c6456256e78658fbfceb4a9dfcb72fe2728 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14891: [FLINK-21289][deployment] FIX missing load pipeline.classpaths in app…

flinkbot edited a comment on pull request #14891: URL: https://github.com/apache/flink/pull/14891#issuecomment-774628149 ## CI report: * 1976f8fa0310d74fccbd2ccf0ccb6f7b904a60a6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14897: [FLINK-21221][runtime] Deduplication for multiple ResourceCounters

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

[GitHub] [flink] rmetzger commented on a change in pull request #14950: [FLINK-21347][coordination] Extract interface from ExecutionGraph

rmetzger commented on a change in pull request #14950: URL: https://github.com/apache/flink/pull/14950#discussion_r578181797 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/MockExecutionGraphBase.java ## @@ -0,0 +1,424 @@ +/* + * Licensed to

[GitHub] [flink] KarmaGYZ commented on pull request #14954: [FLINK-17061][runtime] Unset TM total process/flink memory size for fine-grained resource management

KarmaGYZ commented on pull request #14954: URL: https://github.com/apache/flink/pull/14954#issuecomment-781113129 Thanks for addressing my comment. +1 for merging when the CI passed. This is an automated message from the

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

Myasuka commented on a change in pull request #14835: URL: https://github.com/apache/flink/pull/14835#discussion_r578180251 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnable.java ## @@ -287,10 +287,9 @@ private

[GitHub] [flink] KarmaGYZ commented on a change in pull request #14955: [FLINK-14869][core] Discard zero-valued extended resources in ResourceSpec/ResourceProfile

KarmaGYZ commented on a change in pull request #14955: URL: https://github.com/apache/flink/pull/14955#discussion_r578172700 ## File path: flink-core/src/test/java/org/apache/flink/api/common/resources/ResourceTest.java ## @@ -152,6 +152,12 @@ public void

[GitHub] [flink] xintongsong commented on pull request #14954: [FLINK-17061][runtime] Unset TM total process/flink memory size for fine-grained resource management

xintongsong commented on pull request #14954: URL: https://github.com/apache/flink/pull/14954#issuecomment-781109918 Thanks for the review, @KarmaGYZ. Comments addressed. This is an automated message from the Apache Git

[GitHub] [flink] flinkbot commented on pull request #14958: [FLINK-18550][sql-client] use TableResult#collect to get select result for sql client

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

[GitHub] [flink] flinkbot commented on pull request #14957: [FLINK-20534] Add Flink 1.12 MigrationVersion and add Flink 1.12 snapshots for TypeSerializer upgrade tests

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

[GitHub] [flink] flinkbot commented on pull request #14956: [FLINK-20534] Add Flink 1.12 MigrationVersion and add Flink 1.12 snapshots for TypeSerializer upgrade tests

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

[GitHub] [flink] flinkbot edited a comment on pull request #14955: [FLINK-14869][core] Discard zero-valued extended resources in ResourceSpec/ResourceProfile

flinkbot edited a comment on pull request #14955: URL: https://github.com/apache/flink/pull/14955#issuecomment-781090588 ## CI report: * d30e5867cdac76e93c1c04cc9df434f66494c107 Azure:

[GitHub] [flink] KarmaGYZ commented on a change in pull request #14954: [FLINK-17061][runtime] Unset TM total process/flink memory size for fine-grained resource management

KarmaGYZ commented on a change in pull request #14954: URL: https://github.com/apache/flink/pull/14954#discussion_r578169836 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/active/ActiveResourceManagerFactory.java ## @@ -56,6 +59,33 @@

[GitHub] [flink] flinkbot edited a comment on pull request #14897: [FLINK-21221][runtime] Deduplication for multiple ResourceCounters

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

[GitHub] [flink] XComp commented on pull request #14946: [FLINK-21381][docs] Add information about service account permissions to K8s HA service documentation

XComp commented on pull request #14946: URL: https://github.com/apache/flink/pull/14946#issuecomment-781098178 I see. Thanks for clarification, @tillrohrmann & @wangyang0918 This is an automated message from the Apache Git

[GitHub] [flink] flinkbot commented on pull request #14958: [FLINK-18550][sql-client] use TableResult#collect to get select result for sql client

flinkbot commented on pull request #14958: URL: https://github.com/apache/flink/pull/14958#issuecomment-781095248 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] fsk119 opened a new pull request #14958: [FLINK-18550][sql-client] use TableResult#collect to get select result for sql client

fsk119 opened a new pull request #14958: URL: https://github.com/apache/flink/pull/14958 ## What is the purpose of the change *This pr aims to use TableResult#collect to get select result instead of using user defined sink. which could reduce a lot of code.* ## Brief

[GitHub] [flink] flinkbot commented on pull request #14957: [FLINK-20534] Add Flink 1.12 MigrationVersion and add Flink 1.12 snapshots for TypeSerializer upgrade tests

flinkbot commented on pull request #14957: URL: https://github.com/apache/flink/pull/14957#issuecomment-781092445 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 commented on pull request #14955: [FLINK-14869][core] Discard zero-valued extended resources in ResourceSpec/ResourceProfile

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

[GitHub] [flink] dianfu opened a new pull request #14957: [FLINK-20534] Add Flink 1.12 MigrationVersion and add Flink 1.12 snapshots for TypeSerializer upgrade tests

dianfu opened a new pull request #14957: URL: https://github.com/apache/flink/pull/14957 ## What is the purpose of the change *This pull request add the 1.12 MigrationVersion and also adds Flink 1.12 snapshots for TypeSerializer upgrade tests* ## Brief change log -

[GitHub] [flink] flinkbot edited a comment on pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

flinkbot edited a comment on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-766281483 ## CI report: * 2e05b89cd87ce4ba54de32eff3c68985f766180f UNKNOWN * 56566c305fba167267cf427dddbf33c62b04f997 Azure:

[jira] [Updated] (FLINK-20534) Add Flink 1.12 MigrationVersion

[ https://issues.apache.org/jira/browse/FLINK-20534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20534: --- Labels: pull-request-available (was: ) > Add Flink 1.12 MigrationVersion >

[GitHub] [flink] flinkbot commented on pull request #14956: [FLINK-20534] Add Flink 1.12 MigrationVersion and add Flink 1.12 snapshots for TypeSerializer upgrade tests

flinkbot commented on pull request #14956: URL: https://github.com/apache/flink/pull/14956#issuecomment-781089476 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] dianfu opened a new pull request #14956: Add Flink 1.12 MigrationVersion and add Flink 1.12 snapshots for TypeSerializer upgrade tests

dianfu opened a new pull request #14956: URL: https://github.com/apache/flink/pull/14956 ## What is the purpose of the change *This pull request add the 1.12 MigrationVersion and also adds Flink 1.12 snapshots for TypeSerializer upgrade tests* ## Brief change log

[GitHub] [flink] KarmaGYZ commented on pull request #14897: [FLINK-21221][runtime] Deduplication for multiple ResourceCounters

KarmaGYZ commented on pull request #14897: URL: https://github.com/apache/flink/pull/14897#issuecomment-781087943 @tillrohrmann Thanks for the review! PR updated to make the `ResourceCounter` immutable. This is an automated

[GitHub] [flink] flinkbot commented on pull request #14955: [FLINK-14869][core] Discard zero-valued extended resources in ResourceSpec/ResourceProfile

flinkbot commented on pull request #14955: URL: https://github.com/apache/flink/pull/14955#issuecomment-781087254 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] xintongsong commented on pull request #14955: [FLINK-14869][core] Discard zero-valued extended resources in ResourceSpec/ResourceProfile

xintongsong commented on pull request #14955: URL: https://github.com/apache/flink/pull/14955#issuecomment-781085871 cc @zhuzhurk This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] xintongsong commented on pull request #14954: [FLINK-17061][runtime] Unset TM total process/flink memory size for fine-grained resource management

xintongsong commented on pull request #14954: URL: https://github.com/apache/flink/pull/14954#issuecomment-781085549 cc @KarmaGYZ This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Updated] (FLINK-14869) Force an extended resource to be null if it's value is 0

[ https://issues.apache.org/jira/browse/FLINK-14869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14869: --- Labels: pull-request-available (was: ) > Force an extended resource to be null if it's

[GitHub] [flink] xintongsong opened a new pull request #14955: [FLINK-14869][core] Discard zero-valued extended resources in ResourceSpec/ResourceProfile

xintongsong opened a new pull request #14955: URL: https://github.com/apache/flink/pull/14955 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] flinkbot edited a comment on pull request #14953: [FLINK-21351][checkpointing] Don't subsume last checkpoint

flinkbot edited a comment on pull request #14953: URL: https://github.com/apache/flink/pull/14953#issuecomment-780752668 ## CI report: * 941374ecdd03b5ceb9245e4d8a8370671b691a34 UNKNOWN * b495b70cd52846372f8e14cd08facd234235f984 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14891: [FLINK-21289][deployment] FIX missing load pipeline.classpaths in app…

flinkbot edited a comment on pull request #14891: URL: https://github.com/apache/flink/pull/14891#issuecomment-774628149 ## CI report: * 29ddfd1a206cb8d33e1c5a0f0ca7c1097c77d327 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14954: [FLINK-17061][runtime] Unset TM total process/flink memory size for fine-grained resource management

flinkbot edited a comment on pull request #14954: URL: https://github.com/apache/flink/pull/14954#issuecomment-781063841 ## CI report: * 6746ea0922384476c2f9f4ad4fcae1273811201f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14891: [FLINK-21289][deployment] FIX missing load pipeline.classpaths in app…

flinkbot edited a comment on pull request #14891: URL: https://github.com/apache/flink/pull/14891#issuecomment-774628149 ## CI report: * 29ddfd1a206cb8d33e1c5a0f0ca7c1097c77d327 Azure:

[jira] [Comment Edited] (FLINK-12607) Introduce a REST API that returns the maxParallelism of a job

[ https://issues.apache.org/jira/browse/FLINK-12607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286279#comment-17286279 ] John Phelan edited comment on FLINK-12607 at 2/18/21, 5:33 AM: ---  hi

[GitHub] [flink] flinkbot commented on pull request #14954: [FLINK-17061][runtime] Unset TM total process/flink memory size for fine-grained resource management

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

[jira] [Commented] (FLINK-12607) Introduce a REST API that returns the maxParallelism of a job

[ https://issues.apache.org/jira/browse/FLINK-12607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286279#comment-17286279 ] John Phelan commented on FLINK-12607: -  hi [~rmetzger] I made what I think is a first pass at the

[GitHub] [flink] flinkbot commented on pull request #14954: [FLINK-17061][runtime] Unset TM total process/flink memory size for fine-grained resource management

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

[jira] [Updated] (FLINK-17061) Unset process/flink memory size from configuration once dynamic worker resource is activated.

[ https://issues.apache.org/jira/browse/FLINK-17061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17061: --- Labels: pull-request-available (was: ) > Unset process/flink memory size from

[GitHub] [flink] xintongsong opened a new pull request #14954: [FLINK-17061][runtime] Unset TM total process/flink memory size for fine-grained resource management

xintongsong opened a new pull request #14954: URL: https://github.com/apache/flink/pull/14954 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] flinkbot edited a comment on pull request #14944: [FLINK-21297] Support 'LOAD/UNLOAD MODULE' syntax

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

[GitHub] [flink] flinkbot edited a comment on pull request #14897: [FLINK-21221][runtime] Deduplication for multiple ResourceCounters

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

[GitHub] [flink] flinkbot edited a comment on pull request #14944: [FLINK-21297] Support 'LOAD/UNLOAD MODULE' syntax

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

[GitHub] [flink] flinkbot edited a comment on pull request #14897: [FLINK-21221][runtime] Deduplication for multiple ResourceCounters

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

[jira] [Commented] (FLINK-21311) flink1.12 cep does not execute pattern but flink1.10 is ok

[ https://issues.apache.org/jira/browse/FLINK-21311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286259#comment-17286259 ] forrest_feng commented on FLINK-21311: -- I tried ,but  it's not the way to solve the problem, I want

[GitHub] [flink] PChou commented on pull request #14891: [FLINK-21289][deployment] FIX missing load pipeline.classpaths in app…

PChou commented on pull request #14891: URL: https://github.com/apache/flink/pull/14891#issuecomment-781029670 @wangyang0918 OK. I agree that, if it was designed. I'd like to fix as the style This is an automated message

[GitHub] [flink] wangyang0918 commented on pull request #14891: [FLINK-21289][deployment] FIX missing load pipeline.classpaths in app…

wangyang0918 commented on pull request #14891: URL: https://github.com/apache/flink/pull/14891#issuecomment-781025442 @PChou Sorry for the late response. I think we could introduce the `setConfiguration` for `ClassPathPackagedProgramRetriever.Builder`. If you check the implementation of

[jira] [Commented] (FLINK-21383) Docker image does not play well together with ConfigMap based flink-conf.yamls

[ https://issues.apache.org/jira/browse/FLINK-21383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286253#comment-17286253 ] Yang Wang commented on FLINK-21383: --- ConfigMap volume is always read-only. So updating the

[GitHub] [flink] PChou commented on pull request #14891: [FLINK-21289][deployment] FIX missing load pipeline.classpaths in app…

PChou commented on pull request #14891: URL: https://github.com/apache/flink/pull/14891#issuecomment-781018060 @wangyang0918 any update? This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-18496) Anchors are not generated based on ZH characters

[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286243#comment-17286243 ] Zhilong Hong commented on FLINK-18496: -- Sorry for being confused with flink-doc and flink-web by

[jira] [Comment Edited] (FLINK-18496) Anchors are not generated based on ZH characters

[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283923#comment-17283923 ] Zhilong Hong edited comment on FLINK-18496 at 2/18/21, 2:52 AM: -Since

[jira] [Updated] (FLINK-14869) Force an extended resource to be null if it's value is 0

[ https://issues.apache.org/jira/browse/FLINK-14869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14869: - Parent: FLINK-14187 Issue Type: Sub-task (was: Improvement) > Force an extended

[jira] [Commented] (FLINK-18171) Do not take client side config options to cluster

[ https://issues.apache.org/jira/browse/FLINK-18171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286232#comment-17286232 ] Yang Wang commented on FLINK-18171: --- [~trohrmann] First, it is harmless to taking some client side

[jira] [Commented] (FLINK-21382) Standalone K8s documentation does not explain usage of standby JobManagers

[ https://issues.apache.org/jira/browse/FLINK-21382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286228#comment-17286228 ] Yang Wang commented on FLINK-21382: --- I have also created a ticket FLINK-21082 for adding documentation

[GitHub] [flink] wangyang0918 commented on a change in pull request #14946: [FLINK-21381][docs] Add information about service account permissions to K8s HA service documentation

wangyang0918 commented on a change in pull request #14946: URL: https://github.com/apache/flink/pull/14946#discussion_r578067748 ## File path: docs/content.zh/docs/deployment/ha/kubernetes_ha.md ## @@ -31,6 +31,14 @@ Flink's Kubernetes HA services use

[GitHub] [flink] flinkbot edited a comment on pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

flinkbot edited a comment on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-766281483 ## CI report: * 2e05b89cd87ce4ba54de32eff3c68985f766180f UNKNOWN * 81adc9cccd9fc0247e58ad7688252e1d98382cc5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14953: [FLINK-21351][checkpointing] Don't subsume last checkpoint

flinkbot edited a comment on pull request #14953: URL: https://github.com/apache/flink/pull/14953#issuecomment-780752668 ## CI report: * 941374ecdd03b5ceb9245e4d8a8370671b691a34 UNKNOWN * 320979883494538f42909dd10c7451b398632b90 Azure:

[jira] [Created] (FLINK-21393) Implement ParquetAvroInputFormat

Dominik Wosiński created FLINK-21393: Summary: Implement ParquetAvroInputFormat Key: FLINK-21393 URL: https://issues.apache.org/jira/browse/FLINK-21393 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

flinkbot edited a comment on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-766281483 ## CI report: * 2e05b89cd87ce4ba54de32eff3c68985f766180f UNKNOWN * 81adc9cccd9fc0247e58ad7688252e1d98382cc5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14953: [FLINK-21351][checkpointing] Don't subsume last checkpoint

flinkbot edited a comment on pull request #14953: URL: https://github.com/apache/flink/pull/14953#issuecomment-780752668 ## CI report: * 941374ecdd03b5ceb9245e4d8a8370671b691a34 UNKNOWN * 320979883494538f42909dd10c7451b398632b90 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14953: [FLINK-21351][checkpointing] Don't subsume last checkpoint

flinkbot edited a comment on pull request #14953: URL: https://github.com/apache/flink/pull/14953#issuecomment-780752668 ## CI report: * 941374ecdd03b5ceb9245e4d8a8370671b691a34 UNKNOWN * 320979883494538f42909dd10c7451b398632b90 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14838: [FLINK-19503][state] Add StateChangelog API

flinkbot edited a comment on pull request #14838: URL: https://github.com/apache/flink/pull/14838#issuecomment-772060058 ## CI report: * f560722ab6bbf452340228a2c88e025ecc797274 UNKNOWN * 42dd6bd7e4e64b3ff0ecf5156cae0f860226d629 Azure:

[GitHub] [flink] LinyuYao1021 commented on a change in pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

LinyuYao1021 commented on a change in pull request #14737: URL: https://github.com/apache/flink/pull/14737#discussion_r578016466 ## File path: flink-end-to-end-tests/flink-glue-schema-registry-test/src/main/java/org/apache/flink/glue/schema/registry/test/GSRKinesisPubsubClient.java

[GitHub] [flink] LinyuYao1021 commented on a change in pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

LinyuYao1021 commented on a change in pull request #14737: URL: https://github.com/apache/flink/pull/14737#discussion_r578014029 ## File path:

[GitHub] [flink] flinkbot edited a comment on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

flinkbot edited a comment on pull request #13912: URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037 ## CI report: * be0265377b7c2c15d73a540c8b174f2dab613b1a Azure:

[GitHub] [flink] LinyuYao1021 commented on a change in pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

LinyuYao1021 commented on a change in pull request #14737: URL: https://github.com/apache/flink/pull/14737#discussion_r578009632 ## File path: flink-formats/flink-avro-glue-schema-registry/src/test/java/org/apache/flink/formats/avro/glue/schema/registry/User.java ## @@ -0,0

[GitHub] [flink] LinyuYao1021 commented on a change in pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

LinyuYao1021 commented on a change in pull request #14737: URL: https://github.com/apache/flink/pull/14737#discussion_r578008770 ## File path:

[GitHub] [flink] LinyuYao1021 commented on a change in pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

LinyuYao1021 commented on a change in pull request #14737: URL: https://github.com/apache/flink/pull/14737#discussion_r578008683 ## File path:

[GitHub] [flink] flinkbot edited a comment on pull request #14921: [FLINK-21100][coordination] Add DeclarativeScheduler

flinkbot edited a comment on pull request #14921: URL: https://github.com/apache/flink/pull/14921#issuecomment-777147472 ## CI report: * 6ce75263caba486446116acd952d5201a4bb2d39 UNKNOWN * 51a717e648de24f9fd0eb28a2cf153289d0c7c62 UNKNOWN *

[GitHub] [flink] dannycranmer commented on a change in pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

dannycranmer commented on a change in pull request #14737: URL: https://github.com/apache/flink/pull/14737#discussion_r577987171 ## File path:

[GitHub] [flink] dannycranmer commented on a change in pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

dannycranmer commented on a change in pull request #14737: URL: https://github.com/apache/flink/pull/14737#discussion_r577986479 ## File path: flink-formats/flink-avro-glue-schema-registry/pom.xml ## @@ -0,0 +1,99 @@ + + +http://maven.apache.org/POM/4.0.0; +

[GitHub] [flink] dannycranmer commented on a change in pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

dannycranmer commented on a change in pull request #14737: URL: https://github.com/apache/flink/pull/14737#discussion_r577985579 ## File path: flink-end-to-end-tests/flink-glue-schema-registry-test/pom.xml ## @@ -0,0 +1,252 @@ + + +http://maven.apache.org/POM/4.0.0; +

[jira] [Issue Comment Deleted] (FLINK-21359) CompatibilityResult issues with Flink 1.9.0

[ https://issues.apache.org/jira/browse/FLINK-21359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Siva updated FLINK-21359: - Comment: was deleted (was: I am getting the same stack trace for both flink 1.7.0 with emr 5.21.0 and flink

[jira] [Commented] (FLINK-21359) CompatibilityResult issues with Flink 1.9.0

[ https://issues.apache.org/jira/browse/FLINK-21359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286148#comment-17286148 ] Siva commented on FLINK-21359: -- I am getting the same stack trace for both flink 1.7.0 with emr 5.21.0 and

[GitHub] [flink] flinkbot edited a comment on pull request #14804: [FLINK-21188] Replaces ArchivedExecutionGraph by ExecutionGraphInfo

flinkbot edited a comment on pull request #14804: URL: https://github.com/apache/flink/pull/14804#issuecomment-769705891 ## CI report: * b23755042be13f0ab5349855955f0b12bd3907ad Azure:

[GitHub] [flink] pnowojski commented on a change in pull request #14838: [FLINK-19503][state] Add StateChangelog API

pnowojski commented on a change in pull request #14838: URL: https://github.com/apache/flink/pull/14838#discussion_r577947431 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/StateChangelogWriterFactoryLoader.java ## @@ -0,0 +1,38 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #14838: [FLINK-19503][state] Add StateChangelog API

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

[GitHub] [flink] flinkbot edited a comment on pull request #14798: [FLINK-21187] Provide exception history for root causes

flinkbot edited a comment on pull request #14798: URL: https://github.com/apache/flink/pull/14798#issuecomment-769223911 ## CI report: * af8de65a4905ae47ab704a75acfcd1b2e897d915 UNKNOWN * 772e076ed9d773e16713236c942f4e30b659d6eb UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14953: [FLINK-21351][checkpointing] Don't subsume last checkpoint

flinkbot edited a comment on pull request #14953: URL: https://github.com/apache/flink/pull/14953#issuecomment-780752668 ## CI report: * 941374ecdd03b5ceb9245e4d8a8370671b691a34 UNKNOWN * 8af71fa26a0e8e0218ad805cb0986cec8d80df96 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14838: [FLINK-19503][state] Add StateChangelog API

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

[GitHub] [flink] zentol commented on a change in pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

zentol commented on a change in pull request #14737: URL: https://github.com/apache/flink/pull/14737#discussion_r577888627 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

zentol commented on a change in pull request #14737: URL: https://github.com/apache/flink/pull/14737#discussion_r577887598 ## File path:

[GitHub] [flink] rkhachatryan commented on a change in pull request #14799: [FLINK-21354][WIP] Wrapped StateBackend to forward state changes to StateChangleLog

rkhachatryan commented on a change in pull request #14799: URL: https://github.com/apache/flink/pull/14799#discussion_r577887482 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java ## @@ -47,6 +52,13 @@ // Configuration

[GitHub] [flink] zentol commented on a change in pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

zentol commented on a change in pull request #14737: URL: https://github.com/apache/flink/pull/14737#discussion_r577886982 ## File path: flink-formats/flink-avro-glue-schema-registry/src/test/java/org/apache/flink/formats/avro/glue/schema/registry/User.java ## @@ -0,0 +1,434

[GitHub] [flink] zentol commented on a change in pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

zentol commented on a change in pull request #14737: URL: https://github.com/apache/flink/pull/14737#discussion_r577883615 ## File path: flink-end-to-end-tests/flink-glue-schema-registry-test/pom.xml ## @@ -0,0 +1,252 @@ + + +http://maven.apache.org/POM/4.0.0; +

[GitHub] [flink] zentol commented on a change in pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

zentol commented on a change in pull request #14737: URL: https://github.com/apache/flink/pull/14737#discussion_r577883615 ## File path: flink-end-to-end-tests/flink-glue-schema-registry-test/pom.xml ## @@ -0,0 +1,252 @@ + + +http://maven.apache.org/POM/4.0.0; +

[jira] [Commented] (FLINK-21389) ParquetInputFormat should not need parquet schema as user input

[ https://issues.apache.org/jira/browse/FLINK-21389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286103#comment-17286103 ] Zhenqiu Huang commented on FLINK-21389: --- [~echauchot] Thanks for reporting this. The context of

  1   2   3   >