[jira] [Commented] (FLINK-33112) Support placement constraint

[ https://issues.apache.org/jira/browse/FLINK-33112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17778513#comment-17778513 ] Junfan Zhang commented on FLINK-33112: --

[jira] [Commented] (FLINK-33112) Support placement constraint

[ https://issues.apache.org/jira/browse/FLINK-33112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773083#comment-17773083 ] Junfan Zhang commented on FLINK-33112: -- PTAL [~guoyangze]  > Support placement constraint >

[jira] [Created] (FLINK-33112) Support placement constraint

Junfan Zhang created FLINK-33112: Summary: Support placement constraint Key: FLINK-33112 URL: https://issues.apache.org/jira/browse/FLINK-33112 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-27550) Remove checking yarn queues before submitting job to Yarn

[ https://issues.apache.org/jira/browse/FLINK-27550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-27550: - Description: When invoking the method of {{checkYarnQueues}} in YarnClusterDescriptor, it will

[jira] [Updated] (FLINK-27550) Remove checking yarn queues before submitting job to Yarn

[ https://issues.apache.org/jira/browse/FLINK-27550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-27550: - Description: When invoking the method of {{checkYarnQueues}} in YarnClusterDescriptor, it will

[jira] [Updated] (FLINK-27550) Remove checking yarn queues before submitting job to Yarn

[ https://issues.apache.org/jira/browse/FLINK-27550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-27550: - Description: When invoking the method of checkYarnQueues in YarnClusterDescriptor, it will

[jira] [Created] (FLINK-27550) Remove checking yarn queues before submitting job to Yarn

Junfan Zhang created FLINK-27550: Summary: Remove checking yarn queues before submitting job to Yarn Key: FLINK-27550 URL: https://issues.apache.org/jira/browse/FLINK-27550 Project: Flink

[jira] [Created] (FLINK-26697) Detailed log with flink app name

Junfan Zhang created FLINK-26697: Summary: Detailed log with flink app name Key: FLINK-26697 URL: https://issues.apache.org/jira/browse/FLINK-26697 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-26696) Reuse the method of judgment

Junfan Zhang created FLINK-26696: Summary: Reuse the method of judgment Key: FLINK-26696 URL: https://issues.apache.org/jira/browse/FLINK-26696 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-26329) Adjust the order of var initialization in FlinkControllerConfig

Junfan Zhang created FLINK-26329: Summary: Adjust the order of var initialization in FlinkControllerConfig Key: FLINK-26329 URL: https://issues.apache.org/jira/browse/FLINK-26329 Project: Flink

[jira] [Created] (FLINK-26324) Remove duplicate condition judgment

Junfan Zhang created FLINK-26324: Summary: Remove duplicate condition judgment Key: FLINK-26324 URL: https://issues.apache.org/jira/browse/FLINK-26324 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-25495) Client support attach mode when using the deployment of application mode

[ https://issues.apache.org/jira/browse/FLINK-25495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491294#comment-17491294 ] Junfan Zhang commented on FLINK-25495: -- Thanks for your suggestions. I have drafted, if u have

[jira] [Commented] (FLINK-25495) Client support attach mode when using the deployment of application mode

[ https://issues.apache.org/jira/browse/FLINK-25495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488725#comment-17488725 ] Junfan Zhang commented on FLINK-25495: -- As discussed in mail list, the community will drop per-job

[jira] [Commented] (FLINK-25749) YARNSessionFIFOSecuredITCase.testDetachedMode fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480118#comment-17480118 ] Junfan Zhang commented on FLINK-25749: -- All failure above looks lost connection with mini-yarn,

[jira] [Commented] (FLINK-25495) Client support attach mode when using the deployment of application mode

[ https://issues.apache.org/jira/browse/FLINK-25495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17471736#comment-17471736 ] Junfan Zhang commented on FLINK-25495: -- [~wangyang0918] Thanks for your reply. {noformat} I am

[jira] [Comment Edited] (FLINK-25445) TaskExecutor always creates local file for task even when local state store is not used

[ https://issues.apache.org/jira/browse/FLINK-25445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17471347#comment-17471347 ] Junfan Zhang edited comment on FLINK-25445 at 1/10/22, 3:10 AM: Do you

[jira] [Commented] (FLINK-25445) TaskExecutor always creates local file for task even when local state store is not used

[ https://issues.apache.org/jira/browse/FLINK-25445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17471347#comment-17471347 ] Junfan Zhang commented on FLINK-25445: -- Do you mind i take over this ticket? [~zjureel] I'm learn

[jira] [Commented] (FLINK-25564) TaskManagerProcessFailureStreamingRecoveryITCase>AbstractTaskManagerProcessFailureRecoveryTest.testTaskManagerProcessFailure fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470741#comment-17470741 ] Junfan Zhang commented on FLINK-25564: -- I can't reproduce this in my local machine, and you?

[jira] [Created] (FLINK-25536) Minor Fix: Adjust the order of variable declaration and comment in StateAssignmentOperation

Junfan Zhang created FLINK-25536: Summary: Minor Fix: Adjust the order of variable declaration and comment in StateAssignmentOperation Key: FLINK-25536 URL: https://issues.apache.org/jira/browse/FLINK-25536

[jira] [Commented] (FLINK-25534) execute pre-job throws org.apache.flink.table.api.TableException: Failed to execute sql

[ https://issues.apache.org/jira/browse/FLINK-25534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469627#comment-17469627 ] Junfan Zhang commented on FLINK-25534: -- I think you could login to the appmaster container on yarn

[jira] [Commented] (FLINK-25495) Client support attach mode when using the deployment of application mode

[ https://issues.apache.org/jira/browse/FLINK-25495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468583#comment-17468583 ] Junfan Zhang commented on FLINK-25495: -- [~trohrmann]  Polling is always OK. However, when in our

[jira] [Commented] (FLINK-25495) Client support attach mode when using the deployment of application mode

[ https://issues.apache.org/jira/browse/FLINK-25495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468330#comment-17468330 ] Junfan Zhang commented on FLINK-25495: -- Thanks for your reply [~trohrmann] As I know, flink cli

[jira] [Commented] (FLINK-25496) ThreadDumpInfoTest.testComparedWithDefaultJDKImplemetation failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17467128#comment-17467128 ] Junfan Zhang commented on FLINK-25496: -- Sorry for that. I'll correct it asap. >

[jira] [Commented] (FLINK-25495) Client support attach mode when using the deployment of application mode

[ https://issues.apache.org/jira/browse/FLINK-25495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17467125#comment-17467125 ] Junfan Zhang commented on FLINK-25495: -- Could you help check this feature [~trohrmann]? If

[jira] [Updated] (FLINK-25495) Client support attach mode when using the deployment of application mode

[ https://issues.apache.org/jira/browse/FLINK-25495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-25495: - Description: h2. Why In our internal data platform, we support flink batch and streaming job

[jira] [Created] (FLINK-25495) Client support attach mode when using the deployment of application mode

Junfan Zhang created FLINK-25495: Summary: Client support attach mode when using the deployment of application mode Key: FLINK-25495 URL: https://issues.apache.org/jira/browse/FLINK-25495 Project:

[jira] [Commented] (FLINK-25410) Flink CLI should exit when app is accepted with detach mode on Yarn

[ https://issues.apache.org/jira/browse/FLINK-25410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464468#comment-17464468 ] Junfan Zhang commented on FLINK-25410: -- Sounds great! [~trohrmann]. It's elegant and general. I

[jira] [Commented] (FLINK-17808) Rename checkpoint meta file to "_metadata" until it has completed writing

[ https://issues.apache.org/jira/browse/FLINK-17808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464399#comment-17464399 ] Junfan Zhang commented on FLINK-17808: -- Gentle ping [~yunta] . Do you have any ideas? > Rename

[jira] [Commented] (FLINK-17808) Rename checkpoint meta file to "_metadata" until it has completed writing

[ https://issues.apache.org/jira/browse/FLINK-17808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463624#comment-17463624 ] Junfan Zhang commented on FLINK-17808: -- I overlooked this, and thanks [~yunta] for pointing it. I

[jira] [Comment Edited] (FLINK-25410) Flink CLI should exit when app is accepted with detach mode on Yarn

[ https://issues.apache.org/jira/browse/FLINK-25410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463588#comment-17463588 ] Junfan Zhang edited comment on FLINK-25410 at 12/22/21, 5:47 AM: - Could

[jira] [Comment Edited] (FLINK-25410) Flink CLI should exit when app is accepted with detach mode on Yarn

[ https://issues.apache.org/jira/browse/FLINK-25410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463588#comment-17463588 ] Junfan Zhang edited comment on FLINK-25410 at 12/22/21, 5:43 AM: - Could

[jira] [Commented] (FLINK-25410) Flink CLI should exit when app is accepted with detach mode on Yarn

[ https://issues.apache.org/jira/browse/FLINK-25410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463588#comment-17463588 ] Junfan Zhang commented on FLINK-25410: -- Could you help check this feature? [~guoyangze]  

[jira] [Updated] (FLINK-25410) Flink CLI should exit when app is accepted with detach mode on Yarn

[ https://issues.apache.org/jira/browse/FLINK-25410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-25410: - Description: h2. Why In our internal streaming platform, we will use flink-cli tool to submit

[jira] [Updated] (FLINK-25410) Flink CLI should exit when app is accepted with detach mode on Yarn

[ https://issues.apache.org/jira/browse/FLINK-25410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-25410: - Description: h2. Why In our internal streaming platform, we will use flink-cli tool to submit

[jira] [Created] (FLINK-25410) Flink CLI should exit when app is accepted with detach mode on Yarn

Junfan Zhang created FLINK-25410: Summary: Flink CLI should exit when app is accepted with detach mode on Yarn Key: FLINK-25410 URL: https://issues.apache.org/jira/browse/FLINK-25410 Project: Flink

[jira] [Commented] (FLINK-17808) Rename checkpoint meta file to "_metadata" until it has completed writing

[ https://issues.apache.org/jira/browse/FLINK-17808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463584#comment-17463584 ] Junfan Zhang commented on FLINK-17808: -- [~yunta]  As Stephan mentioned above, i also think the

[jira] [Commented] (FLINK-25398) Show complete stacktrace when requesting thread dump

[ https://issues.apache.org/jira/browse/FLINK-25398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463582#comment-17463582 ] Junfan Zhang commented on FLINK-25398: -- [~Thesharing] Thanks for your advice. Agree with u, i will

[jira] [Commented] (FLINK-25398) Show complete stacktrace when requesting thread dump

[ https://issues.apache.org/jira/browse/FLINK-25398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463068#comment-17463068 ] Junfan Zhang commented on FLINK-25398: -- [~xtsong]  Besides, Spark print the complete stacktrace in

[jira] [Commented] (FLINK-25398) Show complete stacktrace when requesting thread dump

[ https://issues.apache.org/jira/browse/FLINK-25398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463067#comment-17463067 ] Junfan Zhang commented on FLINK-25398: -- [~xtsong] Thanks for your quick reply >From my

[jira] [Comment Edited] (FLINK-25398) Show complete stacktrace when requesting thread dump

[ https://issues.apache.org/jira/browse/FLINK-25398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463067#comment-17463067 ] Junfan Zhang edited comment on FLINK-25398 at 12/21/21, 8:26 AM: -

[jira] [Commented] (FLINK-25398) Show complete stacktrace when requesting thread dump

[ https://issues.apache.org/jira/browse/FLINK-25398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463009#comment-17463009 ] Junfan Zhang commented on FLINK-25398: -- Could you help check this ticket? [~guoyangze]  [~yunta]  

[jira] [Updated] (FLINK-25398) Show complete stacktrace when requesting thread dump

[ https://issues.apache.org/jira/browse/FLINK-25398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-25398: - Attachment: stacktrace.png > Show complete stacktrace when requesting thread dump >

[jira] [Updated] (FLINK-25398) Show complete stacktrace when requesting thread dump

[ https://issues.apache.org/jira/browse/FLINK-25398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-25398: - Description: h2. Why Now the stacktrace is not complete when clicking the task executor's

[jira] [Created] (FLINK-25398) Show complete stacktrace when requesting thread dump

Junfan Zhang created FLINK-25398: Summary: Show complete stacktrace when requesting thread dump Key: FLINK-25398 URL: https://issues.apache.org/jira/browse/FLINK-25398 Project: Flink Issue

[jira] [Commented] (FLINK-17808) Rename checkpoint meta file to "_metadata" until it has completed writing

[ https://issues.apache.org/jira/browse/FLINK-17808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17462957#comment-17462957 ] Junfan Zhang commented on FLINK-17808: -- Could i take over this ticket? [~yunta] [~guoyangze]

[jira] [Commented] (FLINK-22485) Support client attach on application mode

[ https://issues.apache.org/jira/browse/FLINK-22485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460386#comment-17460386 ] Junfan Zhang commented on FLINK-22485: -- Rediscuss this ticket.  After reading the code about the

[jira] [Updated] (FLINK-22485) Support client attach on application mode

[ https://issues.apache.org/jira/browse/FLINK-22485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-22485: - Priority: Major (was: Not a Priority) > Support client attach on application mode >

[jira] [Updated] (FLINK-25313) Enable flink runtime web

[ https://issues.apache.org/jira/browse/FLINK-25313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-25313: - Summary: Enable flink runtime web (was: Enable flink-web-ui) > Enable flink runtime web >

[jira] [Commented] (FLINK-25313) Enable flink-web-ui

[ https://issues.apache.org/jira/browse/FLINK-25313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459847#comment-17459847 ] Junfan Zhang commented on FLINK-25313: -- Sorry for lacking the description. When i run flink

[jira] [Commented] (FLINK-25313) Enable flink-web-ui

[ https://issues.apache.org/jira/browse/FLINK-25313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459630#comment-17459630 ] Junfan Zhang commented on FLINK-25313: -- Linked PR: https://github.com/apache/flink-training/pull/45

[jira] [Created] (FLINK-25313) Enable flink-web-ui

Junfan Zhang created FLINK-25313: Summary: Enable flink-web-ui Key: FLINK-25313 URL: https://issues.apache.org/jira/browse/FLINK-25313 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-25268) Support task manager node-label in Yarn deployment

[ https://issues.apache.org/jira/browse/FLINK-25268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459604#comment-17459604 ] Junfan Zhang commented on FLINK-25268: -- Thanks [~guoyangze]  > Support task manager node-label in

[jira] [Comment Edited] (FLINK-25268) Support task manager node-label in Yarn deployment

[ https://issues.apache.org/jira/browse/FLINK-25268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458159#comment-17458159 ] Junfan Zhang edited comment on FLINK-25268 at 12/14/21, 11:28 AM: --

[jira] [Commented] (FLINK-25268) Support task manager node-label in Yarn deployment

[ https://issues.apache.org/jira/browse/FLINK-25268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458159#comment-17458159 ] Junfan Zhang commented on FLINK-25268: -- Could you help check this features? [~wangyang0918]

[jira] [Updated] (FLINK-25268) Support task manager node-label in Yarn deployment

[ https://issues.apache.org/jira/browse/FLINK-25268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-25268: - Description: Now Flink only support application level node label, it's necessary to introduce

[jira] [Created] (FLINK-25268) Support task manager node-label in Yarn deployment

Junfan Zhang created FLINK-25268: Summary: Support task manager node-label in Yarn deployment Key: FLINK-25268 URL: https://issues.apache.org/jira/browse/FLINK-25268 Project: Flink Issue

[jira] [Created] (FLINK-25153) Inappropriate variable naming

Junfan Zhang created FLINK-25153: Summary: Inappropriate variable naming Key: FLINK-25153 URL: https://issues.apache.org/jira/browse/FLINK-25153 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-25099) flink on yarn Accessing two HDFS Clusters

[ https://issues.apache.org/jira/browse/FLINK-25099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451514#comment-17451514 ] Junfan Zhang commented on FLINK-25099: -- If you could provide more detailed info like submmision cli

[jira] [Commented] (FLINK-25099) flink on yarn Accessing two HDFS Clusters

[ https://issues.apache.org/jira/browse/FLINK-25099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451479#comment-17451479 ] Junfan Zhang commented on FLINK-25099: -- Good news [~libra_816] > flink on yarn Accessing two HDFS

[jira] [Comment Edited] (FLINK-25099) flink on yarn Accessing two HDFS Clusters

[ https://issues.apache.org/jira/browse/FLINK-25099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451479#comment-17451479 ] Junfan Zhang edited comment on FLINK-25099 at 12/1/21, 2:54 AM: Glad to

[jira] [Comment Edited] (FLINK-16654) Implement Application Mode according to FLIP-85

[ https://issues.apache.org/jira/browse/FLINK-16654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451211#comment-17451211 ] Junfan Zhang edited comment on FLINK-16654 at 11/30/21, 4:03 PM: - Now

[jira] [Commented] (FLINK-16654) Implement Application Mode according to FLIP-85

[ https://issues.apache.org/jira/browse/FLINK-16654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451211#comment-17451211 ] Junfan Zhang commented on FLINK-16654: -- Now when using the ApplicationMode, the flink cli will be

[jira] [Comment Edited] (FLINK-25099) flink on yarn Accessing two HDFS Clusters

[ https://issues.apache.org/jira/browse/FLINK-25099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451160#comment-17451160 ] Junfan Zhang edited comment on FLINK-25099 at 11/30/21, 2:28 PM: - Just

[jira] [Commented] (FLINK-25099) flink on yarn Accessing two HDFS Clusters

[ https://issues.apache.org/jira/browse/FLINK-25099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451160#comment-17451160 ] Junfan Zhang commented on FLINK-25099: -- Just ignore setting the default.fs=flinkcluster. but

[jira] [Commented] (FLINK-25099) flink on yarn Accessing two HDFS Clusters

[ https://issues.apache.org/jira/browse/FLINK-25099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451123#comment-17451123 ] Junfan Zhang commented on FLINK-25099: -- I think in yours architecture, you should not reset the

[jira] [Commented] (FLINK-25099) flink on yarn Accessing two HDFS Clusters

[ https://issues.apache.org/jira/browse/FLINK-25099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451071#comment-17451071 ] Junfan Zhang commented on FLINK-25099: -- The submission cluster is {{hdfsn21n159}}. but you set the

[jira] [Commented] (FLINK-25099) flink on yarn Accessing two HDFS Clusters

[ https://issues.apache.org/jira/browse/FLINK-25099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450853#comment-17450853 ] Junfan Zhang commented on FLINK-25099: -- Could you make the log level debug and attach more logs ?

[jira] [Created] (FLINK-24963) Remove the tail separator when outputting yarn queue names

Junfan Zhang created FLINK-24963: Summary: Remove the tail separator when outputting yarn queue names Key: FLINK-24963 URL: https://issues.apache.org/jira/browse/FLINK-24963 Project: Flink

[jira] [Updated] (FLINK-24555) Incorrectly put empty list to flink configuration

[ https://issues.apache.org/jira/browse/FLINK-24555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-24555: - Description: h2. Why As I found some warn logs in our production flink jobs, like as

[jira] [Commented] (FLINK-24555) Incorrectly put empty list to flink configuration

[ https://issues.apache.org/jira/browse/FLINK-24555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429095#comment-17429095 ] Junfan Zhang commented on FLINK-24555: -- [~jark] Could you help review it? Thanks > Incorrectly put

[jira] [Updated] (FLINK-24555) Incorrectly put empty list to flink configuration

[ https://issues.apache.org/jira/browse/FLINK-24555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-24555: - Description: h2. Why As I found some warn logs in our production flink jobs, like as

[jira] [Updated] (FLINK-24555) Incorrectly put empty list to flink configuration

[ https://issues.apache.org/jira/browse/FLINK-24555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-24555: - Description: h2. Why As I found some warn logs in our production flink jobs, like as

[jira] [Updated] (FLINK-24555) Incorrectly put empty list to flink configuration

[ https://issues.apache.org/jira/browse/FLINK-24555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-24555: - Description: h2. Why As I found some warn logs in our production flink jobs, like as

[jira] [Updated] (FLINK-24555) Incorrectly put empty list to flink configuration

[ https://issues.apache.org/jira/browse/FLINK-24555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-24555: - Description: h2. Why As I found some warn logs in our production flink jobs, like as

[jira] [Updated] (FLINK-24555) Incorrectly put empty list to flink configuration

[ https://issues.apache.org/jira/browse/FLINK-24555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-24555: - Description: h2. Why As I found some warn logs in our production flink jobs, like as follows

[jira] [Created] (FLINK-24555) Incorrectly put empty list to flink configuration

Junfan Zhang created FLINK-24555: Summary: Incorrectly put empty list to flink configuration Key: FLINK-24555 URL: https://issues.apache.org/jira/browse/FLINK-24555 Project: Flink Issue

[jira] [Commented] (FLINK-23991) Specifying yarn.staging-dir fail when staging scheme is different from default fs scheme

[ https://issues.apache.org/jira/browse/FLINK-23991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407934#comment-17407934 ] Junfan Zhang commented on FLINK-23991: -- Could you help assign ticket to me? [~lirui] [~jark] >

[jira] [Updated] (FLINK-23991) Specifying yarn.staging-dir fail when staging scheme is different from default fs scheme

[ https://issues.apache.org/jira/browse/FLINK-23991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-23991: - Description: When the yarn.staging-dir path scheme is different from the default fs scheme, the

[jira] [Created] (FLINK-23991) Specifying yarn.staging-dir fail when staging scheme is different from default fs scheme

Junfan Zhang created FLINK-23991: Summary: Specifying yarn.staging-dir fail when staging scheme is different from default fs scheme Key: FLINK-23991 URL: https://issues.apache.org/jira/browse/FLINK-23991

[jira] [Created] (FLINK-23004) Fix misleading log

Junfan Zhang created FLINK-23004: Summary: Fix misleading log Key: FLINK-23004 URL: https://issues.apache.org/jira/browse/FLINK-23004 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-22919) Remove support for Hadoop1.x in HadoopInputFormatCommonBase.getCredentialsFromUGI

[ https://issues.apache.org/jira/browse/FLINK-22919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359850#comment-17359850 ] Junfan Zhang commented on FLINK-22919: -- [~lirui] Please review it. Thanks > Remove support for

[jira] [Created] (FLINK-22919) Remove support for Hadoop1.x in HadoopInputFormatCommonBase.getCredentialsFromUGI

Junfan Zhang created FLINK-22919: Summary: Remove support for Hadoop1.x in HadoopInputFormatCommonBase.getCredentialsFromUGI Key: FLINK-22919 URL: https://issues.apache.org/jira/browse/FLINK-22919

[jira] [Commented] (FLINK-22690) kerberos integration with flink，kerberos tokens will expire

[ https://issues.apache.org/jira/browse/FLINK-22690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17346635#comment-17346635 ] Junfan Zhang commented on FLINK-22690: -- Please add more details info, such as submission mode(Yarn

[jira] [Comment Edited] (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=17345857#comment-17345857 ] Junfan Zhang edited comment on FLINK-21232 at 5/17/21, 3:54 AM: Hi

[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=17345857#comment-17345857 ] Junfan Zhang commented on FLINK-21232: -- Nice improvement! Thanks for your work. [~jackwangcs] And

[jira] [Commented] (FLINK-22329) Missing credentials in jobconf causes repeated authentication in Hive datasource

[ https://issues.apache.org/jira/browse/FLINK-22329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344497#comment-17344497 ] Junfan Zhang commented on FLINK-22329: -- Update it, please review it again. Thanks [~lirui] >

[jira] [Updated] (FLINK-22329) Missing credentials in jobconf causes repeated authentication in Hive datasource

[ https://issues.apache.org/jira/browse/FLINK-22329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-22329: - Summary: Missing credentials in jobconf causes repeated authentication in Hive datasource

[jira] [Commented] (FLINK-21700) Allow to disable fetching Hadoop delegation token on Yarn

[ https://issues.apache.org/jira/browse/FLINK-21700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344323#comment-17344323 ] Junfan Zhang commented on FLINK-21700: -- [~fly_in_gis] [~lirui] Could you help set status to

[jira] [Commented] (FLINK-22534) Set delegation token's service name as credential alias

[ https://issues.apache.org/jira/browse/FLINK-22534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17343786#comment-17343786 ] Junfan Zhang commented on FLINK-22534: -- Wow, thanks for your review. [~lirui]. > Set delegation

[jira] [Commented] (FLINK-22534) Set delegation token's service name as credential alias

[ https://issues.apache.org/jira/browse/FLINK-22534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17342391#comment-17342391 ] Junfan Zhang commented on FLINK-22534: -- [~lirui] Thanks for your reply. Yes > Set delegation

[jira] [Commented] (FLINK-22534) Set delegation token's service name as credential alias

[ https://issues.apache.org/jira/browse/FLINK-22534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17342268#comment-17342268 ] Junfan Zhang commented on FLINK-22534: -- Any ideas on it? [~lirui] [~mapohl] > Set delegation

[jira] [Comment Edited] (FLINK-22534) Set delegation token's service name as credential alias

[ https://issues.apache.org/jira/browse/FLINK-22534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17340761#comment-17340761 ] Junfan Zhang edited comment on FLINK-22534 at 5/7/21, 11:55 AM:

[jira] [Commented] (FLINK-22534) Set delegation token's service name as credential alias

[ https://issues.apache.org/jira/browse/FLINK-22534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17340761#comment-17340761 ] Junfan Zhang commented on FLINK-22534: -- [~mapohl]. Sorry for the late reply. More details infos

[jira] [Updated] (FLINK-22534) Set delegation token's service name as credential alias

[ https://issues.apache.org/jira/browse/FLINK-22534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-22534: - Description: h4. What Set the Hadoop delegation token's service name as credential alias. h4.

[jira] [Updated] (FLINK-22534) Set delegation token's service name as credential alias

[ https://issues.apache.org/jira/browse/FLINK-22534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-22534: - Description: h4. What Set the Hadoop delegation token's service name as credential alias. h4.

[jira] [Updated] (FLINK-22534) Set delegation token's service name as credential alias

[ https://issues.apache.org/jira/browse/FLINK-22534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-22534: - Description: h4. What Set the Hadoop delegation token's service name as credential alias. h4.

[jira] [Updated] (FLINK-22534) Set delegation token's service name as credential alias

[ https://issues.apache.org/jira/browse/FLINK-22534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-22534: - Attachment: debug2.PNG > Set delegation token's service name as credential alias >

[jira] [Updated] (FLINK-22534) Set delegation token's service name as credential alias

[ https://issues.apache.org/jira/browse/FLINK-22534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-22534: - Description: h4. What Set the Hadoop delegation token's service name as credential alias. h4.

[jira] [Updated] (FLINK-22534) Set delegation token's service name as credential alias

[ https://issues.apache.org/jira/browse/FLINK-22534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-22534: - Description: h4. What Set the Hadoop delegation token's service name as credential alias. h4.

[jira] [Updated] (FLINK-22534) Set delegation token's service name as credential alias

[ https://issues.apache.org/jira/browse/FLINK-22534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-22534: - Description: h4. What Set the Hadoop delegation token's service name as credential alias. h4.

  1   2   >