[jira] [Comment Edited] (FLINK-27962) KafkaSourceReader fails to commit consumer offsets for checkpoints

[ https://issues.apache.org/jira/browse/FLINK-27962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17632277#comment-17632277 ] Eui Heo edited comment on FLINK-27962 at 11/11/22 11:56 AM: Hi, [~renqs]. 

[jira] [Commented] (FLINK-27962) KafkaSourceReader fails to commit consumer offsets for checkpoints

[ https://issues.apache.org/jira/browse/FLINK-27962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17632277#comment-17632277 ] Eui Heo commented on FLINK-27962: - Hi, [~renqs].  I've had this problem for a long time with 1.14.4 and

[jira] [Commented] (FLINK-24404) Support to submit job with the ID user provided

[ https://issues.apache.org/jira/browse/FLINK-24404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17613463#comment-17613463 ] Eui Heo commented on FLINK-24404: - Any updates? If not, could you assign this issue to me? > Support

[jira] [Closed] (FLINK-24365) Support to make Flink job more programmatically controlled via CLI

[ https://issues.apache.org/jira/browse/FLINK-24365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eui Heo closed FLINK-24365. --- Resolution: Duplicate > Support to make Flink job more programmatically controlled via CLI >

[jira] [Created] (FLINK-24404) Support to submit job with the ID user provided

Eui Heo created FLINK-24404: --- Summary: Support to submit job with the ID user provided Key: FLINK-24404 URL: https://issues.apache.org/jira/browse/FLINK-24404 Project: Flink Issue Type: New

[jira] [Created] (FLINK-24365) Support to make Flink job more programmatically controlled via CLI

Eui Heo created FLINK-24365: --- Summary: Support to make Flink job more programmatically controlled via CLI Key: FLINK-24365 URL: https://issues.apache.org/jira/browse/FLINK-24365 Project: Flink

[jira] [Commented] (FLINK-12541) Add deploy a Python Flink job and session cluster on Kubernetes support.

[ https://issues.apache.org/jira/browse/FLINK-12541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17235951#comment-17235951 ] Eui Heo commented on FLINK-12541: - How is it going? I want to submit a python job inside application,

[jira] [Comment Edited] (FLINK-11544) Add option to manually set job ID for job submissions via REST API

[ https://issues.apache.org/jira/browse/FLINK-11544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219508#comment-17219508 ] Eui Heo edited comment on FLINK-11544 at 10/23/20, 7:12 AM: [~uce] May I ask

[jira] [Comment Edited] (FLINK-11544) Add option to manually set job ID for job submissions via REST API

[ https://issues.apache.org/jira/browse/FLINK-11544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216879#comment-17216879 ] Eui Heo edited comment on FLINK-11544 at 10/23/20, 7:12 AM: The API

[jira] [Comment Edited] (FLINK-11544) Add option to manually set job ID for job submissions via REST API

[ https://issues.apache.org/jira/browse/FLINK-11544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216879#comment-17216879 ] Eui Heo edited comment on FLINK-11544 at 10/23/20, 7:11 AM: The API

[jira] [Commented] (FLINK-11544) Add option to manually set job ID for job submissions via REST API

[ https://issues.apache.org/jira/browse/FLINK-11544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219508#comment-17219508 ] Eui Heo commented on FLINK-11544: - [~uce] May I ask you to check the my comment? > Add option to

[jira] [Comment Edited] (FLINK-11544) Add option to manually set job ID for job submissions via REST API

[ https://issues.apache.org/jira/browse/FLINK-11544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216879#comment-17216879 ] Eui Heo edited comment on FLINK-11544 at 10/19/20, 4:44 PM: The API

[jira] [Comment Edited] (FLINK-11544) Add option to manually set job ID for job submissions via REST API

[ https://issues.apache.org/jira/browse/FLINK-11544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216879#comment-17216879 ] Eui Heo edited comment on FLINK-11544 at 10/19/20, 4:43 PM: The api

[jira] [Comment Edited] (FLINK-11544) Add option to manually set job ID for job submissions via REST API

[ https://issues.apache.org/jira/browse/FLINK-11544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216879#comment-17216879 ] Eui Heo edited comment on FLINK-11544 at 10/19/20, 4:37 PM: Is this official

[jira] [Commented] (FLINK-11544) Add option to manually set job ID for job submissions via REST API

[ https://issues.apache.org/jira/browse/FLINK-11544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216879#comment-17216879 ] Eui Heo commented on FLINK-11544: - Is this official feature? I want to use this feature to track a

[jira] [Closed] (FLINK-17077) FLINK_CONF_DIR environment variable to locate flink-conf.yaml in Docker container

[ https://issues.apache.org/jira/browse/FLINK-17077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eui Heo closed FLINK-17077. --- Resolution: Won't Do > FLINK_CONF_DIR environment variable to locate flink-conf.yaml in Docker > container

[jira] [Commented] (FLINK-17077) FLINK_CONF_DIR environment variable to locate flink-conf.yaml in Docker container

[ https://issues.apache.org/jira/browse/FLINK-17077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111222#comment-17111222 ] Eui Heo commented on FLINK-17077: - As for the ports, it is correct that you have explained overall. I

[jira] [Commented] (FLINK-17077) FLINK_CONF_DIR environment variable to locate flink-conf.yaml in Docker container

[ https://issues.apache.org/jira/browse/FLINK-17077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110172#comment-17110172 ] Eui Heo commented on FLINK-17077: - I considered your suggested way also. In that case, some properties

[jira] [Commented] (FLINK-17077) FLINK_CONF_DIR environment variable to locate flink-conf.yaml in Docker container

[ https://issues.apache.org/jira/browse/FLINK-17077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110019#comment-17110019 ] Eui Heo commented on FLINK-17077: - In either case, flink-conf.yaml is mounted only with the configMap.

[jira] [Comment Edited] (FLINK-17077) FLINK_CONF_DIR environment variable to locate flink-conf.yaml in Docker container

[ https://issues.apache.org/jira/browse/FLINK-17077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109795#comment-17109795 ] Eui Heo edited comment on FLINK-17077 at 5/18/20, 3:48 AM: --- Thanks for your

[jira] [Comment Edited] (FLINK-17077) FLINK_CONF_DIR environment variable to locate flink-conf.yaml in Docker container

[ https://issues.apache.org/jira/browse/FLINK-17077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109795#comment-17109795 ] Eui Heo edited comment on FLINK-17077 at 5/18/20, 3:11 AM: --- Thanks for your

[jira] [Commented] (FLINK-17077) FLINK_CONF_DIR environment variable to locate flink-conf.yaml in Docker container

[ https://issues.apache.org/jira/browse/FLINK-17077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109795#comment-17109795 ] Eui Heo commented on FLINK-17077: - Thanks for your review. The original motivation of this issue is

[jira] [Created] (FLINK-17077) FLINK_CONF_DIR environment variable to locate flink-conf.yaml in Docker container

Eui Heo created FLINK-17077: --- Summary: FLINK_CONF_DIR environment variable to locate flink-conf.yaml in Docker container Key: FLINK-17077 URL: https://issues.apache.org/jira/browse/FLINK-17077 Project:

[jira] [Closed] (FLINK-14812) Add custom libs to Flink classpath with an environment variable.

[ https://issues.apache.org/jira/browse/FLINK-14812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eui Heo closed FLINK-14812. --- Resolution: Resolved This is resolved via

[jira] [Issue Comment Deleted] (FLINK-14812) Add custom libs to Flink classpath with an environment variable.

[ https://issues.apache.org/jira/browse/FLINK-14812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eui Heo updated FLINK-14812: Comment: was deleted (was: This is resolved via

[jira] [Commented] (FLINK-14812) Add custom libs to Flink classpath with an environment variable.

[ https://issues.apache.org/jira/browse/FLINK-14812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17033444#comment-17033444 ] Eui Heo commented on FLINK-14812: - This is resolved via

[jira] [Commented] (FLINK-14812) Add custom libs to Flink classpath with an environment variable.

[ https://issues.apache.org/jira/browse/FLINK-14812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17027423#comment-17027423 ] Eui Heo commented on FLINK-14812: - [~Jamalarm] I know your work. For now, that looks pretty good. It

[jira] [Comment Edited] (FLINK-14812) Add custom libs to Flink classpath with an environment variable.

[ https://issues.apache.org/jira/browse/FLINK-14812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016428#comment-17016428 ] Eui Heo edited comment on FLINK-14812 at 1/16/20 8:17 AM: -- In particular,

[jira] [Updated] (FLINK-14812) Add custom libs to Flink classpath with an environment variable.

[ https://issues.apache.org/jira/browse/FLINK-14812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eui Heo updated FLINK-14812: Description: To use plugin library you need to add it to the flink classpath. The documentation explains

[jira] [Updated] (FLINK-14812) Add custom libs to Flink classpath with an environment variable.

[ https://issues.apache.org/jira/browse/FLINK-14812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eui Heo updated FLINK-14812: Labels: (was: pull-request-available) > Add custom libs to Flink classpath with an environment

[jira] [Comment Edited] (FLINK-14812) Add custom libs to Flink classpath with an environment variable.

[ https://issues.apache.org/jira/browse/FLINK-14812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016428#comment-17016428 ] Eui Heo edited comment on FLINK-14812 at 1/16/20 12:45 AM: --- In particular,

[jira] [Commented] (FLINK-14812) Add custom libs to Flink classpath with an environment variable.

[ https://issues.apache.org/jira/browse/FLINK-14812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016428#comment-17016428 ] Eui Heo commented on FLINK-14812: - In particular, although /opt/flink/opt of the stock image already

[jira] [Updated] (FLINK-14812) Add custom libs to Flink classpath with an environment variable.

[ https://issues.apache.org/jira/browse/FLINK-14812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eui Heo updated FLINK-14812: Description: To use plugin library you need to add it to the flink classpath. The documentation explains

[jira] [Commented] (FLINK-14812) Add metric libs to Flink classpath with an environment variable.

[ https://issues.apache.org/jira/browse/FLINK-14812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16989259#comment-16989259 ] Eui Heo commented on FLINK-14812: - I also think it's better to give it a name that can be used for more

[jira] [Comment Edited] (FLINK-14812) Add metric libs to Flink classpath with an environment variable.

[ https://issues.apache.org/jira/browse/FLINK-14812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16977939#comment-16977939 ] Eui Heo edited comment on FLINK-14812 at 11/20/19 12:18 AM: Your approach

[jira] [Comment Edited] (FLINK-14812) Add metric libs to Flink classpath with an environment variable.

[ https://issues.apache.org/jira/browse/FLINK-14812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16977939#comment-16977939 ] Eui Heo edited comment on FLINK-14812 at 11/20/19 12:10 AM: Your approach

[jira] [Commented] (FLINK-14812) Add metric libs to Flink classpath with an environment variable.

[ https://issues.apache.org/jira/browse/FLINK-14812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16977939#comment-16977939 ] Eui Heo commented on FLINK-14812: - Your approach looks good and clear. However, to my knowledge, volume

[jira] [Updated] (FLINK-14812) Add metric libs to Flink classpath with an environment variable.

[ https://issues.apache.org/jira/browse/FLINK-14812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eui Heo updated FLINK-14812: Component/s: Deployment / Scripts > Add metric libs to Flink classpath with an environment variable. >

[jira] [Created] (FLINK-14812) Add metric libs to Flink classpath with an environment variable.

Eui Heo created FLINK-14812: --- Summary: Add metric libs to Flink classpath with an environment variable. Key: FLINK-14812 URL: https://issues.apache.org/jira/browse/FLINK-14812 Project: Flink