[jira] [Created] (FLINK-8077) Can't distinguish overloaded user-defined functions that have Double and BigDecimal arguments

2017-11-15 Thread yuqi (JIRA)
yuqi created FLINK-8077: --- Summary: Can't distinguish overloaded user-defined functions that have Double and BigDecimal arguments Key: FLINK-8077 URL: https://issues.apache.org/jira/browse/FLINK-8077 Project: Fl

[jira] [Closed] (FLINK-8077) Can't distinguish overloaded user-defined functions that have Double and BigDecimal arguments

2017-11-15 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi closed FLINK-8077. --- Resolution: Not A Problem > Can't distinguish overloaded user-defined functions that have Double and > BigDecimal arg

[jira] [Created] (FLINK-7167) Job can set checkpoint meta directory to cover the system setting state.checkpoints.dir

2017-07-12 Thread yuqi (JIRA)
yuqi created FLINK-7167: --- Summary: Job can set checkpoint meta directory to cover the system setting state.checkpoints.dir Key: FLINK-7167 URL: https://issues.apache.org/jira/browse/FLINK-7167 Project: Flink

[jira] [Updated] (FLINK-7167) Job can't set checkpoint meta directory to cover the system setting state.checkpoints.dir

2017-07-13 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi updated FLINK-7167: Summary: Job can't set checkpoint meta directory to cover the system setting state.checkpoints.dir (was: Job can s

[jira] [Created] (FLINK-9492) Failed to build RexCall with SqlDatetimeSubtractionOperator

2018-06-01 Thread yuqi (JIRA)
yuqi created FLINK-9492: --- Summary: Failed to build RexCall with SqlDatetimeSubtractionOperator Key: FLINK-9492 URL: https://issues.apache.org/jira/browse/FLINK-9492 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-9492) Failed to build RexCall with SqlDatetimeSubtractionOperator

2018-06-01 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi updated FLINK-9492: Environment: (was: {code:java} public static void main(String[] args) { try {

[jira] [Updated] (FLINK-9492) Failed to build RexCall with SqlDatetimeSubtractionOperator

2018-06-01 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi updated FLINK-9492: Description: When use RexBuilder to build RexCall with SqlDatetimeSubtractionOperator, it will throw exception.

[jira] [Closed] (FLINK-9492) Failed to build RexCall with SqlDatetimeSubtractionOperator

2018-06-01 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi closed FLINK-9492. --- Resolution: Not A Bug > Failed to build RexCall with SqlDatetimeSubtractionOperator > ---

[jira] [Assigned] (FLINK-9237) Some description about The FsStateBackend in the Docs。

2018-04-23 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi reassigned FLINK-9237: --- Assignee: yuqi > Some description about The FsStateBackend in the Docs。 > ---

[jira] [Commented] (FLINK-9237) Some description about The FsStateBackend in the Docs。

2018-04-23 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447913#comment-16447913 ] yuqi commented on FLINK-9237: - Yes, according to the code, `false` means enable asynchronous c

[jira] [Comment Edited] (FLINK-9237) Some description about The FsStateBackend in the Docs。

2018-04-23 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447913#comment-16447913 ] yuqi edited comment on FLINK-9237 at 4/23/18 3:36 PM: -- Yes, according

[jira] [Commented] (FLINK-9259) The implementation of the SourceFunction is not serializable.

2018-04-25 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16453402#comment-16453402 ] yuqi commented on FLINK-9259: - More detail are needed, you can paste more about your code [~bo

[jira] [Updated] (FLINK-9196) YARN: Flink binaries are not deleted from HDFS after cluster shutdown

2018-04-26 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi updated FLINK-9196: Attachment: 0001-xxx.patch > YARN: Flink binaries are not deleted from HDFS after cluster shutdown > ---

[jira] [Commented] (FLINK-9196) YARN: Flink binaries are not deleted from HDFS after cluster shutdown

2018-04-26 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16454295#comment-16454295 ] yuqi commented on FLINK-9196: - As far as i see, The problem may due to the fact that Clifront

[jira] [Commented] (FLINK-9196) YARN: Flink binaries are not deleted from HDFS after cluster shutdown

2018-05-01 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16459665#comment-16459665 ] yuqi commented on FLINK-9196: - [~gjy] I see, thanks for your suggestion. > YARN: Flink binari

[jira] [Comment Edited] (FLINK-9283) Update cluster execution docs

2018-05-02 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460740#comment-16460740 ] yuqi edited comment on FLINK-9283 at 5/2/18 8:55 AM: - Could not unders

[jira] [Commented] (FLINK-9283) Update cluster execution docs

2018-05-02 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460740#comment-16460740 ] yuqi commented on FLINK-9283: - Could not understand why change port 6124 to 8081 ? > The [Rem

[jira] [Comment Edited] (FLINK-9283) Update cluster execution docs

2018-05-02 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460740#comment-16460740 ] yuqi edited comment on FLINK-9283 at 5/2/18 9:04 AM: - Could not unders

[jira] [Assigned] (FLINK-9283) Update cluster execution docs

2018-05-02 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi reassigned FLINK-9283: --- Assignee: yuqi > Update cluster execution docs > - > > Key: FLINK

[jira] [Assigned] (FLINK-9284) Update CLI page

2018-05-02 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi reassigned FLINK-9284: --- Assignee: yuqi > Update CLI page > --- > > Key: FLINK-9284 > URL:

[jira] [Assigned] (FLINK-9284) Update CLI page

2018-05-03 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi reassigned FLINK-9284: --- Assignee: (was: yuqi) > Update CLI page > --- > > Key: FLINK-9284 >

[jira] [Commented] (FLINK-9329) hasRowtimeAttribute will throw NPE if user use setProctimeAttribute for table source

2018-05-10 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16470152#comment-16470152 ] yuqi commented on FLINK-9329: - More description are wanted [~yuemeng] > hasRowtimeAttribute w

[jira] [Commented] (FLINK-9340) ScheduleOrUpdateConsumersTest may fail with Address already in use

2018-05-14 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16474186#comment-16474186 ] yuqi commented on FLINK-9340: - Hard to reproduce it, Can you show more specific environment th

[jira] [Commented] (FLINK-9340) ScheduleOrUpdateConsumersTest may fail with Address already in use

2018-05-15 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16475544#comment-16475544 ] yuqi commented on FLINK-9340: - This is what have done, But No problem exists. Local environme

[jira] [Commented] (FLINK-8918) Introduce Runtime Filter Join

2018-05-16 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16477359#comment-16477359 ] yuqi commented on FLINK-8918: - # Indeed as the streaming applications runs, bloom filter will

[jira] [Commented] (FLINK-9424) BlobClientSslTest does not work in all environments

2018-05-24 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16489002#comment-16489002 ] yuqi commented on FLINK-9424: - I have met this problem before. Plan to report it in the commun

[jira] [Comment Edited] (FLINK-9424) BlobClientSslTest does not work in all environments

2018-05-24 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16489002#comment-16489002 ] yuqi edited comment on FLINK-9424 at 5/24/18 1:43 PM: -- [~twalthr] I h

[jira] [Commented] (FLINK-9340) ScheduleOrUpdateConsumersTest may fail with Address already in use

2018-05-24 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16489031#comment-16489031 ] yuqi commented on FLINK-9340: - [~yuzhih...@gmail.com] Reproduce it with new environment as i h

[jira] [Assigned] (FLINK-9446) Compatibility table not up-to-date

2018-05-26 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi reassigned FLINK-9446: --- Assignee: yuqi > Compatibility table not up-to-date > -- > >

[jira] [Commented] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored

2018-05-26 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16491687#comment-16491687 ] yuqi commented on FLINK-9143: - [~dawidwys] Thanks for your reviews. ``` Did I understand this

[jira] [Assigned] (FLINK-9453) Flink 1.5 incorrectly shows statistics in web UI

2018-05-28 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi reassigned FLINK-9453: --- Assignee: yuqi > Flink 1.5 incorrectly shows statistics in web UI >

[jira] [Assigned] (FLINK-9056) Job submission fails with AskTimeoutException if not enough slots are available

2018-03-23 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi reassigned FLINK-9056: --- Assignee: yuqi > Job submission fails with AskTimeoutException if not enough slots are > available > ---

[jira] [Commented] (FLINK-9056) Job submission fails with AskTimeoutException if not enough slots are available

2018-03-26 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16413474#comment-16413474 ] yuqi commented on FLINK-9056: - [~fhueske], Hello, I have test this problem with master branch

[jira] [Commented] (FLINK-9072) Host name with "_" causes cluster exception

2018-03-26 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16413607#comment-16413607 ] yuqi commented on FLINK-9072: - [~clevermose] I can also repreduce this problem > Host name wi

[jira] [Comment Edited] (FLINK-9072) Host name with "_" causes cluster exception

2018-03-26 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16413607#comment-16413607 ] yuqi edited comment on FLINK-9072 at 3/26/18 10:02 AM: --- [~clevermose

[jira] [Commented] (FLINK-9056) Job submission fails with AskTimeoutException if not enough slots are available

2018-04-01 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16421887#comment-16421887 ] yuqi commented on FLINK-9056: - [~mingleizhang] You are right, Problem described by can't repro

[jira] [Commented] (FLINK-9056) Job submission fails with AskTimeoutException if not enough slots are available

2018-04-04 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16425271#comment-16425271 ] yuqi commented on FLINK-9056: - Hi, [~mingleizhang], The following are detailed log {code:java}

[jira] [Commented] (FLINK-9056) Job submission fails with AskTimeoutException if not enough slots are available

2018-04-05 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16426548#comment-16426548 ] yuqi commented on FLINK-9056: - [~fhueske] Thank you for your reply, I will first reproduce it

[jira] [Commented] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored

2018-04-07 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16429282#comment-16429282 ] yuqi commented on FLINK-9143: - As far as i know, if you set  {code:java} env.enableCheckpointi

[jira] [Assigned] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored

2018-04-07 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi reassigned FLINK-9143: --- Assignee: yuqi > Restart strategy defined in flink-conf.yaml is ignored > ---

[jira] [Commented] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored

2018-04-07 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16429590#comment-16429590 ] yuqi commented on FLINK-9143: - En, Agree with you on this point [~Zentol], I also wonder why f

[jira] [Comment Edited] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored

2018-04-07 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16429590#comment-16429590 ] yuqi edited comment on FLINK-9143 at 4/8/18 2:51 AM: - En, Agree with y

[jira] [Commented] (FLINK-9158) Set default FixedRestartDelayStrategy delay to 0s

2018-04-12 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1643#comment-1643 ] yuqi commented on FLINK-9158: - +1, the reason of this issue ? > Set default FixedRestartDelay

[jira] [Assigned] (FLINK-9194) Finished jobs are not archived to HistoryServer

2018-04-17 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi reassigned FLINK-9194: --- Assignee: yuqi > Finished jobs are not archived to HistoryServer > --

[jira] [Commented] (FLINK-9194) Finished jobs are not archived to HistoryServer

2018-04-17 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16441846#comment-16441846 ] yuqi commented on FLINK-9194: - [~gjy] Could not reproduce this problem with the environment yo

[jira] [Commented] (FLINK-11619) Make ScheduleMode configurable via user code or configuration file

2019-04-11 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815938#comment-16815938 ] yuqi commented on FLINK-11619: -- [~tianchen92] Right, in some scenario, Resource are very pr

[jira] [Commented] (FLINK-8748) Cancel slot requests for alternatively completed slots in SlotPool

2018-02-23 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16374251#comment-16374251 ] yuqi commented on FLINK-8748: - According to your MR, I do think you should change the title of

[jira] [Commented] (FLINK-13120) [Feature Request] RocketMQ-flink-connector

2019-07-05 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16879204#comment-16879204 ] yuqi commented on FLINK-13120: -- I would like to join this issue if possible [~duheng] > [F

[jira] [Created] (FLINK-11619) Make ScheduleMode configurable via user code or configuration file

2019-02-14 Thread yuqi (JIRA)
yuqi created FLINK-11619: Summary: Make ScheduleMode configurable via user code or configuration file Key: FLINK-11619 URL: https://issues.apache.org/jira/browse/FLINK-11619 Project: Flink Issue Ty

[jira] [Created] (FLINK-11643) Remove useless code of externalizedCheckpointsDir

2019-02-17 Thread yuqi (JIRA)
yuqi created FLINK-11643: Summary: Remove useless code of externalizedCheckpointsDir Key: FLINK-11643 URL: https://issues.apache.org/jira/browse/FLINK-11643 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-11314) Reuse RocksDBWriteBatchWrapper in the flush method of RocksDBMapState

2019-01-14 Thread yuqi (JIRA)
yuqi created FLINK-11314: Summary: Reuse RocksDBWriteBatchWrapper in the flush method of RocksDBMapState Key: FLINK-11314 URL: https://issues.apache.org/jira/browse/FLINK-11314 Project: Flink Issue

[jira] [Assigned] (FLINK-11314) Reuse RocksDBWriteBatchWrapper in the flush method of RocksDBMapState

2019-01-14 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi reassigned FLINK-11314: Assignee: yuqi > Reuse RocksDBWriteBatchWrapper in the flush method of RocksDBMapState >

[jira] [Assigned] (FLINK-11315) Make magic number in KvStateSerializer as a constant to make more readable

2019-01-14 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi reassigned FLINK-11315: Assignee: yuqi > Make magic number in KvStateSerializer as a constant to make more readable > ---

[jira] [Created] (FLINK-11315) Make magic number in KvStateSerializer as a constant to make more readable

2019-01-14 Thread yuqi (JIRA)
yuqi created FLINK-11315: Summary: Make magic number in KvStateSerializer as a constant to make more readable Key: FLINK-11315 URL: https://issues.apache.org/jira/browse/FLINK-11315 Project: Flink I

[jira] [Updated] (FLINK-11315) Make magic number in KvStateSerializer as a constant value to make more readable

2019-01-14 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi updated FLINK-11315: - Summary: Make magic number in KvStateSerializer as a constant value to make more readable (was: Make magic numb

[jira] [Updated] (FLINK-11389) Incorrectly use job information when call getSerializedTaskInformation in class TaskDeploymentDescriptor

2019-01-18 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi updated FLINK-11389: - Description: See TaskDeploymentDescriptor {code:java} @Nullable public SerializedValue getSerializedTa

[jira] [Assigned] (FLINK-11389) Incorrectly use job information when call getSerializedTaskInformation in class TaskDeploymentDescriptor

2019-01-18 Thread yuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi reassigned FLINK-11389: Assignee: yuqi > Incorrectly use job information when call getSerializedTaskInformation in > class TaskD

[jira] [Created] (FLINK-11389) Incorrectly use job information when call getSerializedTaskInformation in class TaskDeploymentDescriptor

2019-01-18 Thread yuqi (JIRA)
yuqi created FLINK-11389: Summary: Incorrectly use job information when call getSerializedTaskInformation in class TaskDeploymentDescriptor Key: FLINK-11389 URL: https://issues.apache.org/jira/browse/FLINK-11389