[jira] [Assigned] (FLINK-9300) Improve error message when in-memory state is too large

2018-05-04 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9300: --- Assignee: vinoyang > Improve error message when in-memory state is too large >

[jira] [Assigned] (FLINK-9299) ProcessWindowFunction documentation Java examples have errors

2018-05-04 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9299: --- Assignee: vinoyang > ProcessWindowFunction documentation Java examples have errors >

[jira] [Commented] (FLINK-8933) Avoid calling Class#newInstance

2018-05-07 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465782#comment-16465782 ] vinoyang commented on FLINK-8933: -  [~StephanEwen] so could I split the task into multiple sub tasks for

[jira] [Assigned] (FLINK-9308) The method enableCheckpointing with low values like 10 are forming DoS on Kafka Clusters

2018-05-07 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9308: --- Assignee: vinoyang > The method enableCheckpointing with low values like 10 are forming DoS on >

[jira] [Assigned] (FLINK-9309) Recommend HA setup on Production Readiness Checklist

2018-05-07 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9309: --- Assignee: vinoyang > Recommend HA setup on Production Readiness Checklist >

[jira] [Commented] (FLINK-9292) Remove TypeInfoParser

2018-05-04 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16463534#comment-16463534 ] vinoyang commented on FLINK-9292: - [~aljoscha] based on [~StephanEwen]'s description. the TypeInfoParser

[jira] [Created] (FLINK-9352) In Standalone checkpoint recover mode many jobs with same checkpoint interval cause IO pressure

2018-05-14 Thread vinoyang (JIRA)
vinoyang created FLINK-9352: --- Summary: In Standalone checkpoint recover mode many jobs with same checkpoint interval cause IO pressure Key: FLINK-9352 URL: https://issues.apache.org/jira/browse/FLINK-9352

[jira] [Assigned] (FLINK-9356) Improve error message for when queryable state not ready / reachable

2018-05-14 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9356: --- Assignee: vinoyang > Improve error message for when queryable state not ready / reachable >

[jira] [Assigned] (FLINK-9363) Bump up the Jackson version

2018-05-14 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9363: --- Assignee: vinoyang > Bump up the Jackson version > --- > >

[jira] [Assigned] (FLINK-9321) Rename SubtasksAllAccumulatorsHandlers

2018-05-09 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9321: --- Assignee: vinoyang > Rename SubtasksAllAccumulatorsHandlers > --

[jira] [Assigned] (FLINK-9265) Upgrade Prometheus version

2018-04-27 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9265: --- Assignee: vinoyang > Upgrade Prometheus version > -- > >

[jira] [Assigned] (FLINK-9221) Add method SinkFunction[A]#contramap[B](f: B => A): SinkFunction[B]

2018-04-27 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9221: --- Assignee: vinoyang > Add method SinkFunction[A]#contramap[B](f: B => A): SinkFunction[B] >

[jira] [Commented] (FLINK-9265) Upgrade Prometheus version

2018-04-28 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16457398#comment-16457398 ] vinoyang commented on FLINK-9265: - It seems the latest release version is 0.3.0. > Upgrade Prometheus

[jira] [Assigned] (FLINK-9264) Add method Writer[A]#contramap[B](f: B => A): Writer[B]

2018-04-27 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9264: --- Assignee: vinoyang > Add method Writer[A]#contramap[B](f: B => A): Writer[B] >

[jira] [Assigned] (FLINK-9326) TaskManagerOptions.NUM_TASK_SLOTS does not work for local/embedded mode

2018-05-09 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9326: --- Assignee: vinoyang > TaskManagerOptions.NUM_TASK_SLOTS does not work for local/embedded mode >

[jira] [Commented] (FLINK-9339) Accumulators are not UI accessible running in FLIP-6 mode

2018-05-11 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472849#comment-16472849 ] vinoyang commented on FLINK-9339: - the reason because of , SubtaskCurrentAttemptDetailsHeaders used url

[jira] [Created] (FLINK-9342) conflicted url path pattern about SubtaskCurrentAttemptDetailsHeaders and AggregatedSubtaskMetricsHeaders

2018-05-11 Thread vinoyang (JIRA)
vinoyang created FLINK-9342: --- Summary: conflicted url path pattern about SubtaskCurrentAttemptDetailsHeaders and AggregatedSubtaskMetricsHeaders Key: FLINK-9342 URL: https://issues.apache.org/jira/browse/FLINK-9342

[jira] [Commented] (FLINK-9339) Accumulators are not UI accessible running in FLIP-6 mode

2018-05-11 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472855#comment-16472855 ] vinoyang commented on FLINK-9339: - another similar issue is FLINK-9342 > Accumulators are not UI

[jira] [Commented] (FLINK-9342) conflicted url path pattern about SubtaskCurrentAttemptDetailsHeaders and AggregatedSubtaskMetricsHeaders

2018-05-11 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16472856#comment-16472856 ] vinoyang commented on FLINK-9342: - like FLINK-9339 > conflicted url path pattern about

[jira] [Updated] (FLINK-9342) Conflicted url path pattern about SubtaskCurrentAttemptDetailsHeaders and AggregatedSubtaskMetricsHeaders

2018-05-11 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-9342: Summary: Conflicted url path pattern about SubtaskCurrentAttemptDetailsHeaders and

[jira] [Commented] (FLINK-9339) Accumulators are not UI accessible running in FLIP-6 mode

2018-05-12 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473042#comment-16473042 ] vinoyang commented on FLINK-9339: - [~Zentol] you are right, I made a wrong deduction based of the error

[jira] [Commented] (FLINK-9342) Conflicted url path pattern about SubtaskCurrentAttemptDetailsHeaders and AggregatedSubtaskMetricsHeaders

2018-05-12 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473045#comment-16473045 ] vinoyang commented on FLINK-9342: - [~Zentol] I made a wrong deduction based of the error log, closing this

[jira] [Closed] (FLINK-9342) Conflicted url path pattern about SubtaskCurrentAttemptDetailsHeaders and AggregatedSubtaskMetricsHeaders

2018-05-12 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang closed FLINK-9342. --- Resolution: Not A Problem > Conflicted url path pattern about SubtaskCurrentAttemptDetailsHeaders and >

[jira] [Comment Edited] (FLINK-9299) ProcessWindowFunction documentation Java examples have errors

2018-05-13 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473407#comment-16473407 ] vinoyang edited comment on FLINK-9299 at 5/13/18 8:33 AM: -- [~yazdanjs] I have

[jira] [Commented] (FLINK-9299) ProcessWindowFunction documentation Java examples have errors

2018-05-13 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473407#comment-16473407 ] vinoyang commented on FLINK-9299: - [~yazdanjs] I have did the completed fix. thanks for your contribution!

[jira] [Assigned] (FLINK-9347) BlobServerConnection throws misleading exception for empty files

2018-05-12 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9347: --- Assignee: vinoyang > BlobServerConnection throws misleading exception for empty files >

[jira] [Commented] (FLINK-9299) ProcessWindowFunction documentation Java examples have errors

2018-05-13 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473381#comment-16473381 ] vinoyang commented on FLINK-9299: - [~yazdanjs] follow the issue's description it seems not completed fix.

[jira] [Commented] (FLINK-9347) BlobServerConnection throws misleading exception for empty files

2018-05-13 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473400#comment-16473400 ] vinoyang commented on FLINK-9347: - [~Zentol] which solution you prefer? I found the readLength method

[jira] [Assigned] (FLINK-9339) Accumulators are not UI accessible running in FLIP-6 mode

2018-05-11 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9339: --- Assignee: vinoyang > Accumulators are not UI accessible running in FLIP-6 mode >

[jira] [Assigned] (FLINK-8511) Remove legacy code for the TableType annotation

2018-05-13 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-8511: --- Assignee: vinoyang > Remove legacy code for the TableType annotation >

[jira] [Commented] (FLINK-8933) Avoid calling Class#newInstance

2018-05-13 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16473700#comment-16473700 ] vinoyang commented on FLINK-8933: - OK, I will fix it soon~ > Avoid calling Class#newInstance >

[jira] [Created] (FLINK-9350) Parameter baseInterval has wrong check message in CheckpointCoordinator constructor

2018-05-13 Thread vinoyang (JIRA)
vinoyang created FLINK-9350: --- Summary: Parameter baseInterval has wrong check message in CheckpointCoordinator constructor Key: FLINK-9350 URL: https://issues.apache.org/jira/browse/FLINK-9350 Project:

[jira] [Assigned] (FLINK-9334) Docs to have a code snippet of Kafka partition discovery

2018-05-11 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9334: --- Assignee: vinoyang > Docs to have a code snippet of Kafka partition discovery >

[jira] [Commented] (FLINK-9292) Remove TypeInfoParser

2018-05-04 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16463542#comment-16463542 ] vinoyang commented on FLINK-9292: - [~aljoscha] and [~StephanEwen] can we remove the specific method's

[jira] [Assigned] (FLINK-9398) Flink CLI list running job returns all jobs except in CREATE state

2018-05-17 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9398: --- Assignee: vinoyang > Flink CLI list running job returns all jobs except in CREATE state >

[jira] [Commented] (FLINK-9387) Several log message errors in queryable-state module

2018-05-18 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16480296#comment-16480296 ] vinoyang commented on FLINK-9387: - this change added a log variable placeholder for future.cause(), the

[jira] [Commented] (FLINK-9375) Introduce AbortCheckpoint message from JM to TMs

2018-05-17 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16480081#comment-16480081 ] vinoyang commented on FLINK-9375: - [~sihuazhou] agree with you, it's duplicate of FLINK-8871, I suggest we

[jira] [Comment Edited] (FLINK-9375) Introduce AbortCheckpoint message from JM to TMs

2018-05-17 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16480081#comment-16480081 ] vinoyang edited comment on FLINK-9375 at 5/18/18 3:18 AM: -- [~sihuazhou] agree

[jira] [Commented] (FLINK-9393) LocatableInputSplit#hashCode should take hostnames into account

2018-05-17 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16480079#comment-16480079 ] vinoyang commented on FLINK-9393: - the reason and opinion provided by [~yuzhih...@gmail.com] looks good.

[jira] [Created] (FLINK-9387) Several log message errors in queryable-state module

2018-05-17 Thread vinoyang (JIRA)
vinoyang created FLINK-9387: --- Summary: Several log message errors in queryable-state module Key: FLINK-9387 URL: https://issues.apache.org/jira/browse/FLINK-9387 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-9375) Introduce AbortCheckpoint message from JM to TMs

2018-05-16 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9375: --- Assignee: vinoyang > Introduce AbortCheckpoint message from JM to TMs >

[jira] [Assigned] (FLINK-9393) LocatableInputSplit#hashCode should take hostnames into account

2018-05-17 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9393: --- Assignee: vinoyang > LocatableInputSplit#hashCode should take hostnames into account >

[jira] [Commented] (FLINK-9352) In Standalone checkpoint recover mode many jobs with same checkpoint interval cause IO pressure

2018-05-15 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16476062#comment-16476062 ] vinoyang commented on FLINK-9352: - [~StephanEwen] [~Zentol]  what's your opinion about this? > In

[jira] [Assigned] (FLINK-9421) RunningJobsRegistry entries are not cleaned up after job termination

2018-05-23 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9421: --- Assignee: vinoyang > RunningJobsRegistry entries are not cleaned up after job termination >

[jira] [Assigned] (FLINK-9421) RunningJobsRegistry entries are not cleaned up after job termination

2018-05-23 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9421: --- Assignee: (was: vinoyang) > RunningJobsRegistry entries are not cleaned up after job termination

[jira] [Commented] (FLINK-9421) RunningJobsRegistry entries are not cleaned up after job termination

2018-05-23 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16488212#comment-16488212 ] vinoyang commented on FLINK-9421: - [~till.rohrmann] I have releases the  assignee, please go ahead thanks.

[jira] [Assigned] (FLINK-5505) Harmonize ZooKeeper configuration parameters

2018-05-25 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-5505: --- Assignee: vinoyang > Harmonize ZooKeeper configuration parameters >

[jira] [Assigned] (FLINK-8067) User code ClassLoader not set before calling ProcessingTimeCallback

2018-05-26 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-8067: --- Assignee: vinoyang > User code ClassLoader not set before calling ProcessingTimeCallback >

[jira] [Assigned] (FLINK-9445) start-scala-shell.sh fails on macOS when Java 9 & 10 are installed

2018-05-26 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9445: --- Assignee: vinoyang > start-scala-shell.sh fails on macOS when Java 9 & 10 are installed >

[jira] [Commented] (FLINK-9352) In Standalone checkpoint recover mode many jobs with same checkpoint interval cause IO pressure

2018-05-24 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16489191#comment-16489191 ] vinoyang commented on FLINK-9352: - [~StephanEwen] can you look at this? > In Standalone checkpoint

[jira] [Commented] (FLINK-9352) In Standalone checkpoint recover mode many jobs with same checkpoint interval cause IO pressure

2018-05-24 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16490187#comment-16490187 ] vinoyang commented on FLINK-9352: - [~StephanEwen] delay random is a way to handle this issue. We provide a

[jira] [Commented] (FLINK-9398) Flink CLI list running job returns all jobs except in CREATE state

2018-05-18 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16480791#comment-16480791 ] vinoyang commented on FLINK-9398: - hi [~walterddr] I have not started this issue, I have released it, you

[jira] [Assigned] (FLINK-9398) Flink CLI list running job returns all jobs except in CREATE state

2018-05-18 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9398: --- Assignee: (was: vinoyang) > Flink CLI list running job returns all jobs except in CREATE state >

[jira] [Commented] (FLINK-9352) In Standalone checkpoint recover mode many jobs with same checkpoint interval cause IO pressure

2018-05-16 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16478358#comment-16478358 ] vinoyang commented on FLINK-9352: - and [~till.rohrmann] any idea about this issue? > In Standalone

[jira] [Commented] (FLINK-9387) Several log message errors in queryable-state module

2018-05-18 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16481354#comment-16481354 ] vinoyang commented on FLINK-9387: - [~Zentol] sorry, it really did not miss a placeholder, so how it fix

[jira] [Assigned] (FLINK-9538) Make KeyedStateFunction an interface

2018-06-06 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9538: --- Assignee: vinoyang > Make KeyedStateFunction an interface > >

[jira] [Assigned] (FLINK-9568) Wrong error handling for batch input formats with invalid paths

2018-06-11 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9568: --- Assignee: vinoyang > Wrong error handling for batch input formats with invalid paths >

[jira] [Assigned] (FLINK-9558) Memory leaks during usage of bucketing-sink with disabled checkpointing

2018-06-08 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9558: --- Assignee: vinoyang > Memory leaks during usage of bucketing-sink with disabled checkpointing >

[jira] [Assigned] (FLINK-9603) Incorrect indexing of part files, when part suffix is specified (FileAlreadyExistsException)

2018-06-16 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9603: --- Assignee: vinoyang > Incorrect indexing of part files, when part suffix is specified >

[jira] [Assigned] (FLINK-9598) [Checkpoints] The config Minimum Pause Between Checkpoints doesn't work when there's a checkpoint failure

2018-06-16 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9598: --- Assignee: vinoyang > [Checkpoints] The config Minimum Pause Between Checkpoints doesn't work when

[jira] [Assigned] (FLINK-9602) Extend CommonOption section

2018-06-16 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9602: --- Assignee: vinoyang > Extend CommonOption section > --- > >

[jira] [Assigned] (FLINK-9577) Divide-by-zero in PageRank

2018-06-13 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9577: --- Assignee: vinoyang > Divide-by-zero in PageRank > -- > >

[jira] [Assigned] (FLINK-9580) Potentially unclosed ByteBufInputStream in RestClient#readRawResponse

2018-06-13 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9580: --- Assignee: vinoyang > Potentially unclosed ByteBufInputStream in RestClient#readRawResponse >

[jira] [Assigned] (FLINK-9585) Logger in ZooKeeperStateHandleStore is public and non-final

2018-06-14 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9585: --- Assignee: vinoyang > Logger in ZooKeeperStateHandleStore is public and non-final >

[jira] [Assigned] (FLINK-9603) Incorrect indexing of part files, when part suffix is specified (FileAlreadyExistsException)

2018-06-17 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9603: --- Assignee: (was: vinoyang) > Incorrect indexing of part files, when part suffix is specified >

[jira] [Assigned] (FLINK-9552) NPE in SpanningRecordSerializer during checkpoint

2018-06-07 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9552: --- Assignee: vinoyang > NPE in SpanningRecordSerializer during checkpoint >

[jira] [Assigned] (FLINK-9458) Unable to recover from job failure on YARN with NPE

2018-05-28 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9458: --- Assignee: vinoyang > Unable to recover from job failure on YARN with NPE >

[jira] [Assigned] (FLINK-9448) contribute-code.html references Hadoop 1.x support

2018-05-26 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9448: --- Assignee: vinoyang > contribute-code.html references Hadoop 1.x support >

[jira] [Assigned] (FLINK-9465) Separate timeout for savepoint and checkpoint

2018-05-29 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9465: --- Assignee: vinoyang > Separate timeout for savepoint and checkpoint >

[jira] [Assigned] (FLINK-9467) No Watermark display on Web UI

2018-05-29 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9467: --- Assignee: vinoyang > No Watermark display on Web UI > -- > >

[jira] [Assigned] (FLINK-9511) Make StateDescriptor configurable with optional TTL

2018-06-04 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9511: --- Assignee: vinoyang > Make StateDescriptor configurable with optional TTL >

[jira] [Created] (FLINK-9519) table example jar did not copy into example dir

2018-06-04 Thread vinoyang (JIRA)
vinoyang created FLINK-9519: --- Summary: table example jar did not copy into example dir Key: FLINK-9519 URL: https://issues.apache.org/jira/browse/FLINK-9519 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-9519) table example jar did not copy into example dir

2018-06-04 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-9519: Fix Version/s: 1.5.0 1.6.0 > table example jar did not copy into example dir >

[jira] [Assigned] (FLINK-9458) Unable to recover from job failure on YARN with NPE

2018-06-04 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9458: --- Assignee: (was: vinoyang) > Unable to recover from job failure on YARN with NPE >

[jira] [Assigned] (FLINK-5232) Add a Thread default uncaught exception handler on the JobManager

2018-06-04 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-5232: --- Assignee: vinoyang > Add a Thread default uncaught exception handler on the JobManager >

[jira] [Commented] (FLINK-9458) Unable to recover from job failure on YARN with NPE

2018-06-04 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16499963#comment-16499963 ] vinoyang commented on FLINK-9458: - [~till.rohrmann] OK, I have released this issue. > Unable to recover

[jira] [Assigned] (FLINK-9503) Migrate integration tests for iterative aggregators

2018-06-02 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9503: --- Assignee: vinoyang > Migrate integration tests for iterative aggregators >

[jira] [Assigned] (FLINK-9497) Job Configuration showing the password in plain text

2018-06-02 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9497: --- Assignee: vinoyang > Job Configuration showing the password in plain text >

[jira] [Assigned] (FLINK-9496) Job created time is reset after restart

2018-06-02 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9496: --- Assignee: vinoyang > Job created time is reset after restart >

[jira] [Assigned] (FLINK-9448) contribute-code.html references Hadoop 1.x support

2018-06-05 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9448: --- Assignee: (was: vinoyang) > contribute-code.html references Hadoop 1.x support >

[jira] [Closed] (FLINK-9521) Add build plugin to package table example jar

2018-06-05 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang closed FLINK-9521. --- > Add build plugin to package table example jar > - > >

[jira] [Reopened] (FLINK-9521) Add build plugin to package table example jar

2018-06-05 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reopened FLINK-9521: - > Add build plugin to package table example jar > - > >

[jira] [Updated] (FLINK-9521) Add shade plugin executions to package table example jar

2018-06-05 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-9521: Summary: Add shade plugin executions to package table example jar (was: Add build plugin to package table

[jira] [Commented] (FLINK-9521) Add shade plugin executions to package table example jar

2018-06-05 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501899#comment-16501899 ] vinoyang commented on FLINK-9521: - [~Zentol] this is a preparatory work for issue FLINK-9519, so that we

[jira] [Assigned] (FLINK-9445) start-scala-shell.sh fails on macOS when Java 9 & 10 are installed

2018-06-05 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9445: --- Assignee: (was: vinoyang) > start-scala-shell.sh fails on macOS when Java 9 & 10 are installed

[jira] [Updated] (FLINK-9521) Add shade plugin executions to package table example jar

2018-06-05 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-9521: Description: this is a preparatory work for issue FLINK-9519, so that we can get those examples' fat jar

[jira] [Closed] (FLINK-9452) Flink 1.5 document version title shows snapshot

2018-06-05 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang closed FLINK-9452. --- Resolution: Fixed > Flink 1.5 document version title shows snapshot >

[jira] [Assigned] (FLINK-9532) Flink Overview of Jobs Documentation Incorrect

2018-06-05 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9532: --- Assignee: vinoyang > Flink Overview of Jobs Documentation Incorrect >

[jira] [Commented] (FLINK-5232) Add a Thread default uncaught exception handler on the JobManager

2018-06-06 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16502895#comment-16502895 ] vinoyang commented on FLINK-5232: - [~StephanEwen] any opinion? if not, I will try to fix this. > Add a

[jira] [Assigned] (FLINK-9527) Paths initialized with URI are not normalized

2018-06-05 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9527: --- Assignee: vinoyang > Paths initialized with URI are not normalized >

[jira] [Assigned] (FLINK-9535) log4j.properties specified in env.java.options doesn't get picked.

2018-06-06 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9535: --- Assignee: vinoyang > log4j.properties specified in env.java.options doesn't get picked. >

[jira] [Assigned] (FLINK-9471) Job ending exceptions being logged at Info level

2018-06-06 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9471: --- Assignee: vinoyang > Job ending exceptions being logged at Info level >

[jira] [Assigned] (FLINK-9536) Rolling logs using log4j.properties, prevents them from showing on the UI.

2018-06-06 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9536: --- Assignee: vinoyang > Rolling logs using log4j.properties, prevents them from showing on the UI. >

[jira] [Closed] (FLINK-7917) The return of taskInformationOrBlobKey should be placed inside synchronized in ExecutionJobVertex

2018-06-06 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang closed FLINK-7917. --- Resolution: Fixed Fix Version/s: 1.6.0 > The return of taskInformationOrBlobKey should be placed

[jira] [Assigned] (FLINK-9543) Expose JobMaster IDs to metric system

2018-06-06 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9543: --- Assignee: vinoyang > Expose JobMaster IDs to metric system > -

[jira] [Created] (FLINK-9452) Flink 1.5 document version title shows snapshot

2018-05-27 Thread vinoyang (JIRA)
vinoyang created FLINK-9452: --- Summary: Flink 1.5 document version title shows snapshot Key: FLINK-9452 URL: https://issues.apache.org/jira/browse/FLINK-9452 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-9352) In Standalone checkpoint recover mode many jobs with same checkpoint interval cause IO pressure

2018-05-28 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492772#comment-16492772 ] vinoyang commented on FLINK-9352: - [~till.rohrmann] OK, I will accept your opinion. Although, I think

[jira] [Commented] (FLINK-5505) Harmonize ZooKeeper configuration parameters

2018-05-28 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492775#comment-16492775 ] vinoyang commented on FLINK-5505: - [~till.rohrmann] if you have no opinion, I will start this issue. >

[jira] [Assigned] (FLINK-9493) Forward exception when releasing a TaskManager at the SlotPool

2018-06-01 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9493: --- Assignee: vinoyang > Forward exception when releasing a TaskManager at the SlotPool >

[jira] [Created] (FLINK-9521) Add build plugin to package table example jar

2018-06-04 Thread vinoyang (JIRA)
vinoyang created FLINK-9521: --- Summary: Add build plugin to package table example jar Key: FLINK-9521 URL: https://issues.apache.org/jira/browse/FLINK-9521 Project: Flink Issue Type: Bug

  1   2   3   4   5   6   7   8   9   10   >