[jira] [Commented] (FLINK-33230) Support Expanding ExecutionGraph to StreamGraph in Web UI

[ https://issues.apache.org/jira/browse/FLINK-33230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17801754#comment-17801754 ] Matt Wang commented on FLINK-33230: --- [~Yu Chen] it's a valuable function, looking forw

[jira] [Created] (FLINK-33643) Allow StreamExecutionEnvironment's executeAsync API to use default JobName

Matt Wang created FLINK-33643: - Summary: Allow StreamExecutionEnvironment's executeAsync API to use default JobName Key: FLINK-33643 URL: https://issues.apache.org/jira/browse/FLINK-33643 Project: Flink

[jira] [Created] (FLINK-33640) Support configuring FLINK_CONF_FILE through environment variables

Matt Wang created FLINK-33640: - Summary: Support configuring FLINK_CONF_FILE through environment variables Key: FLINK-33640 URL: https://issues.apache.org/jira/browse/FLINK-33640 Project: Flink

[jira] [Commented] (FLINK-18742) Some configuration args do not take effect at client

[ https://issues.apache.org/jira/browse/FLINK-18742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17776194#comment-17776194 ] Matt Wang commented on FLINK-18742: --- [~rmetzger] [~huwh] this bug haved fiex since 1.1

[jira] [Comment Edited] (FLINK-18742) Some configuration args do not take effect at client

[ https://issues.apache.org/jira/browse/FLINK-18742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17776194#comment-17776194 ] Matt Wang edited comment on FLINK-18742 at 10/17/23 12:30 PM:

[jira] [Commented] (FLINK-33051) Unify the GlobalFailureHandler and LabeledGlobalFailureHandler interface

[ https://issues.apache.org/jira/browse/FLINK-33051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767805#comment-17767805 ] Matt Wang commented on FLINK-33051: --- [~pgaref] I agree with your point of view. Curren

[jira] [Commented] (FLINK-32114) Make FailureEnricherContext more flexible and include task specific fields

[ https://issues.apache.org/jira/browse/FLINK-32114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17766634#comment-17766634 ] Matt Wang commented on FLINK-32114: --- [~pgaref] hi, If you haven't started doing this y

[jira] [Comment Edited] (FLINK-33051) GlobalFailureHandler interface should be retired in favor of LabeledGlobalFailureHandler

[ https://issues.apache.org/jira/browse/FLINK-33051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17765162#comment-17765162 ] Matt Wang edited comment on FLINK-33051 at 9/14/23 12:57 PM: -

[jira] [Updated] (FLINK-33051) Unify the GlobalFailureHandler and LabeledGlobalFailureHandler interface

[ https://issues.apache.org/jira/browse/FLINK-33051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matt Wang updated FLINK-33051: -- Summary: Unify the GlobalFailureHandler and LabeledGlobalFailureHandler interface (was: GlobalFailure

[jira] [Commented] (FLINK-33051) GlobalFailureHandler interface should be retired in favor of LabeledGlobalFailureHandler

[ https://issues.apache.org/jira/browse/FLINK-33051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17765162#comment-17765162 ] Matt Wang commented on FLINK-33051: --- [~pgaref] Let me think about it. I don't think it

[jira] [Updated] (FLINK-31508) FLIP-304: Pluggable failure handling for Apache Flink

[ https://issues.apache.org/jira/browse/FLINK-31508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matt Wang updated FLINK-31508: -- Description: This is an umbrella ticket for [FLIP-304|https://cwiki.apache.org/confluence/display/FLIN

[jira] [Commented] (FLINK-33051) GlobalFailureHandler interface should be retired in favor of LabeledGlobalFailureHandler

[ https://issues.apache.org/jira/browse/FLINK-33051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764970#comment-17764970 ] Matt Wang commented on FLINK-33051: --- [~pgaref] got it, i will take it > GlobalFailure

[jira] [Commented] (FLINK-33051) GlobalFailureHandler interface should be retired in favor of LabeledGlobalFailureHandler

[ https://issues.apache.org/jira/browse/FLINK-33051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764473#comment-17764473 ] Matt Wang commented on FLINK-33051: --- [~pgaref] Have you started this tricket? If you a

[jira] [Commented] (FLINK-31889) Add documentation for implementing/loading enrichers

[ https://issues.apache.org/jira/browse/FLINK-31889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762746#comment-17762746 ] Matt Wang commented on FLINK-31889: --- [~pgaref] if you create a ticket for chinese docu

[jira] [Commented] (FLINK-31895) End-to-end integration tests for failure labels

[ https://issues.apache.org/jira/browse/FLINK-31895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762715#comment-17762715 ] Matt Wang commented on FLINK-31895: --- [~pgaref] I would like to take this ticket if pos

[jira] [Comment Edited] (FLINK-32804) Release Testing: Verify FLIP-304: Pluggable failure handling for Apache Flink

[ https://issues.apache.org/jira/browse/FLINK-32804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762539#comment-17762539 ] Matt Wang edited comment on FLINK-32804 at 9/7/23 2:35 AM: --- [~

[jira] [Commented] (FLINK-31895) End-to-end integration tests for failure labels

[ https://issues.apache.org/jira/browse/FLINK-31895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762544#comment-17762544 ] Matt Wang commented on FLINK-31895: --- [~pgaref] Sorry, there is some ambiguity in my co

[jira] [Comment Edited] (FLINK-32804) Release Testing: Verify FLIP-304: Pluggable failure handling for Apache Flink

[ https://issues.apache.org/jira/browse/FLINK-32804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762539#comment-17762539 ] Matt Wang edited comment on FLINK-32804 at 9/7/23 2:24 AM: --- [~

[jira] [Commented] (FLINK-32804) Release Testing: Verify FLIP-304: Pluggable failure handling for Apache Flink

[ https://issues.apache.org/jira/browse/FLINK-32804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762539#comment-17762539 ] Matt Wang commented on FLINK-32804: --- [~pgaref] LGTM, we can follow up in these Jiras,

[jira] [Comment Edited] (FLINK-32804) Release Testing: Verify FLIP-304: Pluggable failure handling for Apache Flink

[ https://issues.apache.org/jira/browse/FLINK-32804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761745#comment-17761745 ] Matt Wang edited comment on FLINK-32804 at 9/4/23 9:07 AM: --- [~

[jira] [Updated] (FLINK-32804) Release Testing: Verify FLIP-304: Pluggable failure handling for Apache Flink

[ https://issues.apache.org/jira/browse/FLINK-32804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matt Wang updated FLINK-32804: -- Attachment: image-2023-09-04-17-04-21-682.png > Release Testing: Verify FLIP-304: Pluggable failure ha

[jira] [Comment Edited] (FLINK-32804) Release Testing: Verify FLIP-304: Pluggable failure handling for Apache Flink

[ https://issues.apache.org/jira/browse/FLINK-32804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761745#comment-17761745 ] Matt Wang edited comment on FLINK-32804 at 9/4/23 9:05 AM: --- [~

[jira] [Commented] (FLINK-32804) Release Testing: Verify FLIP-304: Pluggable failure handling for Apache Flink

[ https://issues.apache.org/jira/browse/FLINK-32804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761745#comment-17761745 ] Matt Wang commented on FLINK-32804: --- [~renqs] [~pgaref] hi, I have tested the function

[jira] [Updated] (FLINK-32804) Release Testing: Verify FLIP-304: Pluggable failure handling for Apache Flink

[ https://issues.apache.org/jira/browse/FLINK-32804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matt Wang updated FLINK-32804: -- Attachment: image-2023-09-04-17-03-25-452.png > Release Testing: Verify FLIP-304: Pluggable failure ha

[jira] [Updated] (FLINK-32804) Release Testing: Verify FLIP-304: Pluggable failure handling for Apache Flink

[ https://issues.apache.org/jira/browse/FLINK-32804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matt Wang updated FLINK-32804: -- Attachment: image-2023-09-04-17-02-41-760.png > Release Testing: Verify FLIP-304: Pluggable failure ha

[jira] [Updated] (FLINK-32804) Release Testing: Verify FLIP-304: Pluggable failure handling for Apache Flink

[ https://issues.apache.org/jira/browse/FLINK-32804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matt Wang updated FLINK-32804: -- Attachment: image-2023-09-04-17-00-16-413.png > Release Testing: Verify FLIP-304: Pluggable failure ha

[jira] [Updated] (FLINK-32804) Release Testing: Verify FLIP-304: Pluggable failure handling for Apache Flink

[ https://issues.apache.org/jira/browse/FLINK-32804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matt Wang updated FLINK-32804: -- Attachment: image-2023-09-04-16-58-29-329.png > Release Testing: Verify FLIP-304: Pluggable failure ha

[jira] [Commented] (FLINK-31895) End-to-end integration tests for failure labels

[ https://issues.apache.org/jira/browse/FLINK-31895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761738#comment-17761738 ] Matt Wang commented on FLINK-31895: --- [~pgaref] hi,  I have interested to take it, add

[jira] [Commented] (FLINK-33022) When FailureEnricherUtils load FailureEnricherFactory failed should throw exception or add some error logs

[ https://issues.apache.org/jira/browse/FLINK-33022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761737#comment-17761737 ] Matt Wang commented on FLINK-33022: --- [~pg1...@imperial.ac.uk] how do you think it? >

[jira] [Created] (FLINK-33022) When FailureEnricherUtils load FailureEnricherFactory failed should throw exception or add some error logs

Matt Wang created FLINK-33022: - Summary: When FailureEnricherUtils load FailureEnricherFactory failed should throw exception or add some error logs Key: FLINK-33022 URL: https://issues.apache.org/jira/browse/FLINK-330

[jira] [Commented] (FLINK-32804) Release Testing: Verify FLIP-304: Pluggable failure handling for Apache Flink

[ https://issues.apache.org/jira/browse/FLINK-32804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760933#comment-17760933 ] Matt Wang commented on FLINK-32804: --- [~renqs] I just started doing this verification t

[jira] [Commented] (FLINK-29199) Support blue-green deployment type

[ https://issues.apache.org/jira/browse/FLINK-29199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760707#comment-17760707 ] Matt Wang commented on FLINK-29199: --- [~nfraison.datadog] I think [double data output]

[jira] [Commented] (FLINK-32319) flink can't the partition of network after restart

[ https://issues.apache.org/jira/browse/FLINK-32319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760380#comment-17760380 ] Matt Wang commented on FLINK-32319: --- [~1026688210] Under what circumstances will this

[jira] [Commented] (FLINK-29643) Possible NPE in ApplicationDispatcherBootstrap with failedJob submission and no HA

[ https://issues.apache.org/jira/browse/FLINK-29643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760369#comment-17760369 ] Matt Wang commented on FLINK-29643: --- [~nkruber] hi, I can't reproduce this error here.

[jira] [Commented] (FLINK-29199) Support blue-green deployment type

[ https://issues.apache.org/jira/browse/FLINK-29199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760355#comment-17760355 ] Matt Wang commented on FLINK-29199: --- [~nfraison.datadog] I'm curious, is BlueGreen dep

[jira] [Created] (FLINK-32984) Display the host port information on the suttasks page of SubtaskExecution

Matt Wang created FLINK-32984: - Summary: Display the host port information on the suttasks page of SubtaskExecution Key: FLINK-32984 URL: https://issues.apache.org/jira/browse/FLINK-32984 Project: Flink

[jira] [Commented] (FLINK-30680) Consider using the autoscaler to detect slow taskmanagers

[ https://issues.apache.org/jira/browse/FLINK-30680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17758436#comment-17758436 ] Matt Wang commented on FLINK-30680: --- [~gyfora] Can you give me the permissions on Conf

[jira] [Commented] (FLINK-30680) Consider using the autoscaler to detect slow taskmanagers

[ https://issues.apache.org/jira/browse/FLINK-30680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17758320#comment-17758320 ] Matt Wang commented on FLINK-30680: --- [~gyfora] [~mxm] Hi, can I take this Jira? I am i

[jira] [Commented] (FLINK-32804) Release Testing: Verify FLIP-304: Pluggable failure handling for Apache Flink

[ https://issues.apache.org/jira/browse/FLINK-32804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17757795#comment-17757795 ] Matt Wang commented on FLINK-32804: --- [~renqs] can i task this, I'm interested in this

[jira] [Commented] (FLINK-32840) [JUnit5 Migration] The executiongraph package of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17753116#comment-17753116 ] Matt Wang commented on FLINK-32840: --- [~fanrui] i I am interested in this, can you assi

[jira] [Updated] (FLINK-32630) The log level of job failed info should change from INFO to WARN/ERROR if job failed

[ https://issues.apache.org/jira/browse/FLINK-32630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matt Wang updated FLINK-32630: -- Summary: The log level of job failed info should change from INFO to WARN/ERROR if job failed (was: T

[jira] [Updated] (FLINK-32630) The log level of job failed info should change from info to warn/error if job failed

[ https://issues.apache.org/jira/browse/FLINK-32630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matt Wang updated FLINK-32630: -- Summary: The log level of job failed info should change from info to warn/error if job failed (was: T

[jira] [Commented] (FLINK-32630) The log level should change from info to warn/error if job failed

[ https://issues.apache.org/jira/browse/FLINK-32630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17744584#comment-17744584 ] Matt Wang commented on FLINK-32630: --- hi, [~tison] [~Weijie Guo] I think this is a poin

[jira] [Updated] (FLINK-32630) The log level should change from info to warn/error if job failed

[ https://issues.apache.org/jira/browse/FLINK-32630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matt Wang updated FLINK-32630: -- Description: When a job fails to submit or run, the following log level should be changed to WARN or

[jira] [Created] (FLINK-32630) The log level should change from info to warn/error if job failed

Matt Wang created FLINK-32630: - Summary: The log level should change from info to warn/error if job failed Key: FLINK-32630 URL: https://issues.apache.org/jira/browse/FLINK-32630 Project: Flink

[jira] [Commented] (FLINK-32619) ConfigOptions to support fallback configuration

[ https://issues.apache.org/jira/browse/FLINK-32619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17744413#comment-17744413 ] Matt Wang commented on FLINK-32619: --- hi, i saw flink  has supported this, like this: {

[jira] [Comment Edited] (FLINK-31655) Adaptive Channel selection for partitioner

[ https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17736966#comment-17736966 ] Matt Wang edited comment on FLINK-31655 at 6/26/23 2:56 AM:

[jira] [Comment Edited] (FLINK-31655) Adaptive Channel selection for partitioner

[ https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17736966#comment-17736966 ] Matt Wang edited comment on FLINK-31655 at 6/26/23 2:56 AM:

[jira] [Commented] (FLINK-31655) Adaptive Channel selection for partitioner

[ https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17736966#comment-17736966 ] Matt Wang commented on FLINK-31655: --- [~tartarus] thanks for the hard testing too, and

[jira] [Commented] (FLINK-32038) OffsetCommitMode.Kafka_periodic with checkpointing enabled

[ https://issues.apache.org/jira/browse/FLINK-32038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720966#comment-17720966 ] Matt Wang commented on FLINK-32038: --- [~pritam.agarwala]  Do you mean you want use the

[jira] [Commented] (FLINK-30680) Consider using the autoscaler to detect slow taskmanagers

[ https://issues.apache.org/jira/browse/FLINK-30680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17678973#comment-17678973 ] Matt Wang commented on FLINK-30680: --- [~gyfora] When we designed it internally, we also

[jira] [Comment Edited] (FLINK-30680) Consider using the autoscaler to detect slow taskmanagers

[ https://issues.apache.org/jira/browse/FLINK-30680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17678650#comment-17678650 ] Matt Wang edited comment on FLINK-30680 at 1/19/23 12:00 PM: -

[jira] [Comment Edited] (FLINK-30680) Consider using the autoscaler to detect slow taskmanagers

[ https://issues.apache.org/jira/browse/FLINK-30680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17678650#comment-17678650 ] Matt Wang edited comment on FLINK-30680 at 1/19/23 11:39 AM: -

[jira] [Commented] (FLINK-30680) Consider using the autoscaler to detect slow taskmanagers

[ https://issues.apache.org/jira/browse/FLINK-30680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17678650#comment-17678650 ] Matt Wang commented on FLINK-30680: --- In our production environment, during the peak bu

[jira] [Commented] (FLINK-19013) Log start/end of state restoration

[ https://issues.apache.org/jira/browse/FLINK-19013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17184098#comment-17184098 ] Matt Wang commented on FLINK-19013: --- Agree it, it would be useful while debugging.  hi

[jira] [Comment Edited] (FLINK-18742) Some configuration args do not take effect at client

[ https://issues.apache.org/jira/browse/FLINK-18742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17183685#comment-17183685 ] Matt Wang edited comment on FLINK-18742 at 8/25/20, 2:30 AM: -

[jira] [Commented] (FLINK-18742) Some configuration args do not take effect at client

[ https://issues.apache.org/jira/browse/FLINK-18742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17183685#comment-17183685 ] Matt Wang commented on FLINK-18742: --- [~rmetzger] The `CoreOptions.CHECK_LEAKED_CLASSLO

[jira] [Commented] (FLINK-18983) Job doesn't changed to failed if close function has blocked

[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180221#comment-17180221 ] Matt Wang commented on FLINK-18983: --- You can add a test case in Description which has

[jira] [Commented] (FLINK-18783) Load AkkaRpcService through separate class loader

[ https://issues.apache.org/jira/browse/FLINK-18783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17174052#comment-17174052 ] Matt Wang commented on FLINK-18783: --- [~trohrmann] Have you started doing this? if not,

[jira] [Commented] (FLINK-18742) Some configuration args do not take effect at client

[ https://issues.apache.org/jira/browse/FLINK-18742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17174050#comment-17174050 ] Matt Wang commented on FLINK-18742: --- [~fly_in_gis] Can you help me review the PR, thx.

[jira] [Commented] (FLINK-18783) Load AkkaRpcService through separate class loader

[ https://issues.apache.org/jira/browse/FLINK-18783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17172516#comment-17172516 ] Matt Wang commented on FLINK-18783: --- [~trohrmann] Got it (y) > Load AkkaRpcService th

[jira] [Commented] (FLINK-18808) Task-level numRecordsOut metric may be underestimated

[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17172513#comment-17172513 ] Matt Wang commented on FLINK-18808: --- Agree with [~trohrmann], I also think the task-le

[jira] [Commented] (FLINK-18783) Load AkkaRpcService through separate class loader

[ https://issues.apache.org/jira/browse/FLINK-18783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17172481#comment-17172481 ] Matt Wang commented on FLINK-18783: --- The AkkaRpcService and scala dependency is  neces

[jira] [Commented] (FLINK-18742) Some configuration args do not take effect at client

[ https://issues.apache.org/jira/browse/FLINK-18742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167828#comment-17167828 ] Matt Wang commented on FLINK-18742: --- [~aljoscha] [~fly_in_gis] Can you help me review

[jira] [Commented] (FLINK-18742) Some configuration args do not take effect at client

[ https://issues.apache.org/jira/browse/FLINK-18742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166941#comment-17166941 ] Matt Wang commented on FLINK-18742: --- [~fly_in_gis] it still has this problem at `maste

[jira] [Updated] (FLINK-18742) Some configuration args do not take effect at client

[ https://issues.apache.org/jira/browse/FLINK-18742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matt Wang updated FLINK-18742: -- Summary: Some configuration args do not take effect at client (was: Configuration args do not take ef

[jira] [Updated] (FLINK-18742) Some configuration args do not take effect at client

[ https://issues.apache.org/jira/browse/FLINK-18742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matt Wang updated FLINK-18742: -- Description: Some configuration args from command line will not work at client, for example, the job

[jira] [Commented] (FLINK-18742) Configuration args do not take effect at client

[ https://issues.apache.org/jira/browse/FLINK-18742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166391#comment-17166391 ] Matt Wang commented on FLINK-18742: --- I have fixed this  in our company internal versio

[jira] [Updated] (FLINK-18742) Configuration args do not take effect at client

[ https://issues.apache.org/jira/browse/FLINK-18742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matt Wang updated FLINK-18742: -- Description: The configuration args from command line will not work at client, for example, the job s

[jira] [Created] (FLINK-18742) Configuration args do not take effect at client

Matt Wang created FLINK-18742: - Summary: Configuration args do not take effect at client Key: FLINK-18742 URL: https://issues.apache.org/jira/browse/FLINK-18742 Project: Flink Issue Type: Improve

[jira] [Commented] (FLINK-14729) Multi-topics consuming from KafkaTableSource

[ https://issues.apache.org/jira/browse/FLINK-14729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16982624#comment-16982624 ] Matt Wang commented on FLINK-14729: --- Good feature, just modify the KafkaTableSourceBas