[jira] [Created] (FLINK-6010) Documentation: correct IntelliJ IDEA Plugins path in 'Installing the Scala plugin' section

2017-03-09 Thread Bowen Li (JIRA)
Bowen Li created FLINK-6010: --- Summary: Documentation: correct IntelliJ IDEA Plugins path in 'Installing the Scala plugin' section Key: FLINK-6010 URL: https://issues.apache.org/jira/browse/FLINK-6010 Projec

[jira] [Created] (FLINK-6013) Add Datadog HTTP metrics reporter

2017-03-09 Thread Bowen Li (JIRA)
Bowen Li created FLINK-6013: --- Summary: Add Datadog HTTP metrics reporter Key: FLINK-6013 URL: https://issues.apache.org/jira/browse/FLINK-6013 Project: Flink Issue Type: Improvement Compo

[jira] [Created] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

2017-03-14 Thread Bowen Li (JIRA)
Bowen Li created FLINK-6053: --- Summary: Gauge should only take subclasses of Number, rather than everything Key: FLINK-6053 URL: https://issues.apache.org/jira/browse/FLINK-6053 Project: Flink Issu

[jira] [Updated] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

2017-03-14 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-6053: Description: Currently, Flink's Gauge is defined as ```java /** * A Gauge is a {@link Metric} that calcul

[jira] [Updated] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

2017-03-14 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-6053: Description: Currently, Flink's Gauge is defined as ```java public interface Gauge extends Metric {

[jira] [Commented] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

2017-03-14 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925257#comment-15925257 ] Bowen Li commented on FLINK-6053: - hm I found in Flink's Gauge class is used like this

[jira] [Updated] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

2017-03-15 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-6053: Fix Version/s: (was: 1.3.0) 2.0.0 > Gauge should only take subclasses of Number, rath

[jira] [Commented] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

2017-03-15 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15926514#comment-15926514 ] Bowen Li commented on FLINK-6053: - I see. I can do a hack in FLINK-6013 to check if a Gaug

[jira] [Commented] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

2017-03-15 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15926665#comment-15926665 ] Bowen Li commented on FLINK-6053: - Cool. Adding a NumberGauge or NumericGauge was my first

[jira] [Commented] (FLINK-5095) Add explicit notifyOfAddedX methods to MetricReporter interface

2017-03-15 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15926684#comment-15926684 ] Bowen Li commented on FLINK-5095: - Agree that MetricReporter interface is not extendable a

[jira] [Commented] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

2017-03-16 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15928381#comment-15928381 ] Bowen Li commented on FLINK-6053: - Thank you! > Gauge should only take subclasses of Numb

[jira] [Assigned] (FLINK-6013) Add Datadog HTTP metrics reporter

2017-03-16 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-6013: --- Assignee: Bowen Li > Add Datadog HTTP metrics reporter > - > >

[jira] [Created] (FLINK-6121) Include TravisCI build status to README.md

2017-03-20 Thread Bowen Li (JIRA)
Bowen Li created FLINK-6121: --- Summary: Include TravisCI build status to README.md Key: FLINK-6121 URL: https://issues.apache.org/jira/browse/FLINK-6121 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-6122) Include TravisCI build status to README.md

2017-03-20 Thread Bowen Li (JIRA)
Bowen Li created FLINK-6122: --- Summary: Include TravisCI build status to README.md Key: FLINK-6122 URL: https://issues.apache.org/jira/browse/FLINK-6122 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-6122) add TravisCI build status to README.md

2017-03-20 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-6122: Summary: add TravisCI build status to README.md (was: Include TravisCI build status to README.md) > add Tr

[jira] [Assigned] (FLINK-6121) Include TravisCI build status to README.md

2017-03-20 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-6121: --- Assignee: Bowen Li > Include TravisCI build status to README.md > ---

[jira] [Created] (FLINK-6133) fix build status in README.md

2017-03-20 Thread Bowen Li (JIRA)
Bowen Li created FLINK-6133: --- Summary: fix build status in README.md Key: FLINK-6133 URL: https://issues.apache.org/jira/browse/FLINK-6133 Project: Flink Issue Type: Bug Components: Build

[jira] [Resolved] (FLINK-6133) fix build status in README.md

2017-03-23 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li resolved FLINK-6133. - Resolution: Fixed > fix build status in README.md > - > > Key:

[jira] [Commented] (FLINK-5095) Add explicit notifyOfAddedX methods to MetricReporter interface

2017-04-18 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15974103#comment-15974103 ] Bowen Li commented on FLINK-5095: - I'll spend time in the following few days to see how ot

[jira] [Commented] (FLINK-5095) Add explicit notifyOfAddedX methods to MetricReporter interface

2017-04-20 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977893#comment-15977893 ] Bowen Li commented on FLINK-5095: - What's the main disadvantage of having counter, meters,

[jira] [Comment Edited] (FLINK-5095) Add explicit notifyOfAddedX methods to MetricReporter interface

2017-04-20 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977893#comment-15977893 ] Bowen Li edited comment on FLINK-5095 at 4/21/17 1:02 AM: -- What's

[jira] [Created] (FLINK-6350) Flink: Windowing does not work with streams from collections and the local execution environment

2017-04-20 Thread Bowen Li (JIRA)
Bowen Li created FLINK-6350: --- Summary: Flink: Windowing does not work with streams from collections and the local execution environment Key: FLINK-6350 URL: https://issues.apache.org/jira/browse/FLINK-6350

[jira] [Updated] (FLINK-6350) Flink: Windowing does not work with streams from collections and the local execution environment

2017-04-20 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-6350: Component/s: Streaming > Flink: Windowing does not work with streams from collections and the local > execu

[jira] [Commented] (FLINK-6350) Flink: Windowing does not work with streams from collections and the local execution environment

2017-04-25 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15983852#comment-15983852 ] Bowen Li commented on FLINK-6350: - I'll take a look first. Thanks! > Flink: Windowing doe

[jira] [Created] (FLINK-6386) Missing bracket in 'Compiler Limitation' section

2017-04-25 Thread Bowen Li (JIRA)
Bowen Li created FLINK-6386: --- Summary: Missing bracket in 'Compiler Limitation' section Key: FLINK-6386 URL: https://issues.apache.org/jira/browse/FLINK-6386 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6405) Flink should be able to load a jar from s3

2017-04-27 Thread Bowen Li (JIRA)
Bowen Li created FLINK-6405: --- Summary: Flink should be able to load a jar from s3 Key: FLINK-6405 URL: https://issues.apache.org/jira/browse/FLINK-6405 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-6013) Add Datadog HTTP metrics reporter

2017-04-28 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15989181#comment-15989181 ] Bowen Li commented on FLINK-6013: - [~StephanEwen] [~Zentol] While testing the reporter, I

[jira] [Created] (FLINK-6002) Setup: Download and Start Flink/MacOS X in Quickstart page is not rendered correctly

2017-03-08 Thread Bowen Li (JIRA)
Bowen Li created FLINK-6002: --- Summary: Setup: Download and Start Flink/MacOS X in Quickstart page is not rendered correctly Key: FLINK-6002 URL: https://issues.apache.org/jira/browse/FLINK-6002 Project: Fli

[jira] [Updated] (FLINK-6002) "Setup: Download and Start Flink" / "MacOS X" in Quickstart page is not rendered correctly

2017-03-08 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-6002: Affects Version/s: 1.2.0 Priority: Trivial (was: Major) Fix Version/s: 1.2.1

[jira] [Updated] (FLINK-6002) "Setup: Download and Start Flink" / "MacOS X" in Quickstart page is not rendered correctly

2017-03-08 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-6002: Description: On https://ci.apache.org/projects/flink/flink-docs-release-1.2/quickstart/setup_quickstart.htm

[jira] [Updated] (FLINK-6002) "Setup: Download and Start Flink" / "MacOS X" in Quickstart page is not rendered correctly

2017-03-08 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-6002: Description: On https://ci.apache.org/projects/flink/flink-docs-release-1.2/quickstart/setup_quickstart.htm

[jira] [Updated] (FLINK-6002) "Setup: Download and Start Flink" / "MacOS X" in Quickstart page is not rendered correctly

2017-03-08 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-6002: Description: On https://ci.apache.org/projects/flink/flink-docs-release-1.2/quickstart/setup_quickstart.htm

[jira] [Updated] (FLINK-6002) Documentation: 'MacOS X' under 'Download and Start Flink' in Quickstart page is not rendered correctly

2017-03-08 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-6002: Summary: Documentation: 'MacOS X' under 'Download and Start Flink' in Quickstart page is not rendered correc

[jira] [Commented] (FLINK-6002) Documentation: 'MacOS X' under 'Download and Start Flink' in Quickstart page is not rendered correctly

2017-03-08 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15901831#comment-15901831 ] Bowen Li commented on FLINK-6002: - Hi guys, how to assign this issue to myself? > Documen

[jira] [Commented] (FLINK-7589) org.apache.http.ConnectionClosedException: Premature end of Content-Length delimited message body (expected: 159764230; received: 64638536)

2017-09-14 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166515#comment-16166515 ] Bowen Li commented on FLINK-7589: - [~aljoscha] Yes, the job restarted successfully. Just

[jira] [Commented] (FLINK-7622) Respect local KPL queue size in FlinkKinesisProducer when adding records to KPL client

2017-09-14 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166925#comment-16166925 ] Bowen Li commented on FLINK-7622: - [~tzulitai] I think FLINK-7508 indirectly solves this i

[jira] [Commented] (FLINK-7635) support sideOutput in ProcessWindowFunciton & ProcessAllWindowFunction

2017-09-17 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16169574#comment-16169574 ] Bowen Li commented on FLINK-7635: - [~foxss] Hi Chen, this one looks really interesting to

[jira] [Assigned] (FLINK-7635) support sideOutput in ProcessWindowFunciton & ProcessAllWindowFunction

2017-09-18 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-7635: --- Assignee: Bowen Li > support sideOutput in ProcessWindowFunciton & ProcessAllWindowFunction > ---

[jira] [Commented] (FLINK-7635) support sideOutput in ProcessWindowFunciton & ProcessAllWindowFunction

2017-09-18 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16171061#comment-16171061 ] Bowen Li commented on FLINK-7635: - [~foxss] Thank you very much for pointing out the direc

[jira] [Closed] (FLINK-6549) Improve error message for type mismatches with side outputs

2017-09-19 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-6549. --- Resolution: Fixed > Improve error message for type mismatches with side outputs >

[jira] [Commented] (FLINK-7643) HadoopFileSystem always reloads GlobalConfiguration

2017-09-19 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16172361#comment-16172361 ] Bowen Li commented on FLINK-7643: - Looks like it's related to FLINK-7365 > HadoopFileSyst

[jira] [Updated] (FLINK-7635) Support sideOutput in ProcessWindowFunciton

2017-09-20 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7635: Summary: Support sideOutput in ProcessWindowFunciton (was: Support sideOutput in ProcessWindowFunciton & Pr

[jira] [Created] (FLINK-7660) Support sideOutput in ProcessAllWindowFunction

2017-09-20 Thread Bowen Li (JIRA)
Bowen Li created FLINK-7660: --- Summary: Support sideOutput in ProcessAllWindowFunction Key: FLINK-7660 URL: https://issues.apache.org/jira/browse/FLINK-7660 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-7635) Support sideOutput in ProcessWindowFunciton

2017-09-20 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174288#comment-16174288 ] Bowen Li commented on FLINK-7635: - [~foxss] [~aljoscha] After taking a quick look at the

[jira] [Assigned] (FLINK-7659) Unprotected access to inProgress in JobCancellationWithSavepointHandlers#handleNewRequest

2017-09-21 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-7659: --- Assignee: Bowen Li > Unprotected access to inProgress in > JobCancellationWithSavepointHandlers#hand

[jira] [Updated] (FLINK-7659) Unprotected access to inProgress in JobCancellationWithSavepointHandlers#handleNewRequest

2017-09-21 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7659: Component/s: REST > Unprotected access to inProgress in > JobCancellationWithSavepointHandlers#handleNewReq

[jira] [Commented] (FLINK-5726) Add the RocketMQ plugin for the Apache Flink

2017-09-21 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175963#comment-16175963 ] Bowen Li commented on FLINK-5726: - [~longda] Hi Longda, I'm curious that is Alibaba's BLIN

[jira] [Commented] (FLINK-7592) How to close the output log like "Connected to JobManager at Actor" and "Job execution switched to status RUNNING."?

2017-09-21 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175977#comment-16175977 ] Bowen Li commented on FLINK-7592: - Hi, are you requesting a feature or asking this specifi

[jira] [Closed] (FLINK-7433) Lack of synchronization accessing inProgress in JobCancellationWithSavepointHandlers

2017-09-21 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-7433. --- Resolution: Duplicate > Lack of synchronization accessing inProgress in > JobCancellationWithSavepointHandler

[jira] [Commented] (FLINK-7433) Lack of synchronization accessing inProgress in JobCancellationWithSavepointHandlers

2017-09-21 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16175981#comment-16175981 ] Bowen Li commented on FLINK-7433: - [~tedyu] Hi Ted, this seems to be a dup of FLINK-7659.

[jira] [Assigned] (FLINK-7388) ProcessFunction.onTimer() sets processing time as timestamp

2017-09-21 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-7388: --- Assignee: Bowen Li > ProcessFunction.onTimer() sets processing time as timestamp > --

[jira] [Commented] (FLINK-7388) ProcessFunction.onTimer() sets processing time as timestamp

2017-09-21 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16176009#comment-16176009 ] Bowen Li commented on FLINK-7388: - Interesting one. I just got some experience on ProcessF

[jira] [Created] (FLINK-7671) JobManagerCleanupITCase failed in build

2017-09-22 Thread Bowen Li (JIRA)
Bowen Li created FLINK-7671: --- Summary: JobManagerCleanupITCase failed in build Key: FLINK-7671 URL: https://issues.apache.org/jira/browse/FLINK-7671 Project: Flink Issue Type: Bug Compone

[jira] [Updated] (FLINK-7393) Move FlinkKinesisConsumerTest

2017-09-22 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7393: Summary: Move FlinkKinesisConsumerTest (was: Refactor FlinkKinesisConsumerTest) > Move FlinkKinesisConsu

[jira] [Updated] (FLINK-7393) Move unit tests of KinesisConfigUtil from FlinkKinesisConsumerTest to KinesisConfigUtilTest

2017-09-22 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7393: Summary: Move unit tests of KinesisConfigUtil from FlinkKinesisConsumerTest to KinesisConfigUtilTest (was:

[jira] [Updated] (FLINK-7635) Support sideOutput in ProcessWindowFunciton

2017-09-23 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7635: Fix Version/s: (was: 1.3.3) > Support sideOutput in ProcessWindowFunciton >

[jira] [Resolved] (FLINK-7677) Add side outputs to ProcessWindowFunction

2017-09-23 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li resolved FLINK-7677. - Resolution: Duplicate > Add side outputs to ProcessWindowFunction > --

[jira] [Updated] (FLINK-7635) Support sideOutput in ProcessWindowFunciton

2017-09-23 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7635: Priority: Major (was: Minor) > Support sideOutput in ProcessWindowFunciton > --

[jira] [Assigned] (FLINK-7674) NullPointerException in ContinuousFileMonitoringFunction close

2017-09-23 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-7674: --- Assignee: Bowen Li > NullPointerException in ContinuousFileMonitoringFunction close > ---

[jira] [Assigned] (FLINK-7648) Port TaskManagersHandler to new REST endpoint

2017-09-25 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-7648: --- Assignee: Bowen Li > Port TaskManagersHandler to new REST endpoint >

[jira] [Commented] (FLINK-7648) Port TaskManagersHandler to new REST endpoint

2017-09-25 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16180227#comment-16180227 ] Bowen Li commented on FLINK-7648: - [~till.rohrmann] [~tzulitai] I'd like to try this and c

[jira] [Commented] (FLINK-7648) Port TaskManagersHandler to new REST endpoint

2017-09-26 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16180437#comment-16180437 ] Bowen Li commented on FLINK-7648: - [~till.rohrmann] Thanks Till. Yeah, that sounds too com

[jira] [Created] (FLINK-7694) Port JobMetricsHandler to new REST handler

2017-09-26 Thread Bowen Li (JIRA)
Bowen Li created FLINK-7694: --- Summary: Port JobMetricsHandler to new REST handler Key: FLINK-7694 URL: https://issues.apache.org/jira/browse/FLINK-7694 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-7648) Port TaskManagersHandler to new REST endpoint

2017-09-26 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16181315#comment-16181315 ] Bowen Li commented on FLINK-7648: - [~till.rohrmann] Hi Till, I built Flink from source, co

[jira] [Commented] (FLINK-7694) Port JobMetricsHandler to new REST handler

2017-09-26 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16181953#comment-16181953 ] Bowen Li commented on FLINK-7694: - [~till.rohrmann] Hi Till, I have done some research on

[jira] [Assigned] (FLINK-7718) Port JobVertixMetricsHandler to new REST endpoint

2017-09-27 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-7718: --- Assignee: Bowen Li > Port JobVertixMetricsHandler to new REST endpoint >

[jira] [Assigned] (FLINK-7716) Port JobManagerMetricsHandler to new REST endpoint

2017-09-27 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-7716: --- Assignee: Bowen Li > Port JobManagerMetricsHandler to new REST endpoint > ---

[jira] [Assigned] (FLINK-7717) Port TaskManagerMetricsHandler to new REST endpoint

2017-09-27 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-7717: --- Assignee: Bowen Li > Port TaskManagerMetricsHandler to new REST endpoint > --

[jira] [Commented] (FLINK-7720) Centralize creation of backends and state related resources

2017-09-27 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16183151#comment-16183151 ] Bowen Li commented on FLINK-7720: - +1 > Centralize creation of backends and state related

[jira] [Created] (FLINK-7724) add extra metrics to MetricStoreTest.setupStore

2017-09-27 Thread Bowen Li (JIRA)
Bowen Li created FLINK-7724: --- Summary: add extra metrics to MetricStoreTest.setupStore Key: FLINK-7724 URL: https://issues.apache.org/jira/browse/FLINK-7724 Project: Flink Issue Type: Test

[jira] [Closed] (FLINK-7635) Support sideOutput in ProcessWindowFunciton

2017-09-27 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-7635. --- Resolution: Done > Support sideOutput in ProcessWindowFunciton > --- >

[jira] [Commented] (FLINK-7648) Port TaskManagersHandler to new REST endpoint

2017-09-29 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16185433#comment-16185433 ] Bowen Li commented on FLINK-7648: - [~till.rohrmann] What do you mean by "wait on its compl

[jira] [Commented] (FLINK-7694) Port JobMetricsHandler to new REST handler

2017-09-29 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16185464#comment-16185464 ] Bowen Li commented on FLINK-7694: - Does it mean that I actually only need to ensure the js

[jira] [Commented] (FLINK-7648) Port TaskManagersHandler to new REST endpoint

2017-09-29 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16186631#comment-16186631 ] Bowen Li commented on FLINK-7648: - [~till.rohrmann] I successfully started the cluster in

[jira] [Commented] (FLINK-1743) Add multinomial logistic regression to machine learning library

2017-10-01 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16187595#comment-16187595 ] Bowen Li commented on FLINK-1743: - Any update on this feature? > Add multinomial logistic

[jira] [Updated] (FLINK-7733) test instability in Kafka end-to-end test (RetriableCommitFailedException)

2017-10-01 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7733: Summary: test instability in Kafka end-to-end test (RetriableCommitFailedException) (was: test instability

[jira] [Resolved] (FLINK-7223) Increase DEFAULT_SHARD_DISCOVERY_INTERVAL_MILLIS for Flink-kinesis-connector

2017-10-03 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li resolved FLINK-7223. - Resolution: Won't Fix > Increase DEFAULT_SHARD_DISCOVERY_INTERVAL_MILLIS for Flink-kinesis-connector > ---

[jira] [Resolved] (FLINK-6957) WordCountTable example cannot be run

2017-10-03 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li resolved FLINK-6957. - Resolution: Cannot Reproduce > WordCountTable example cannot be run >

[jira] [Commented] (FLINK-7388) ProcessFunction.onTimer() sets processing time as timestamp

2017-10-03 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16190514#comment-16190514 ] Bowen Li commented on FLINK-7388: - Hi [~fhueske] , Do you mean that: in {{KeyedProcessOpe

[jira] [Commented] (FLINK-3089) State API Should Support Data Expiration (State TTL)

2017-10-03 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16190781#comment-16190781 ] Bowen Li commented on FLINK-3089: - [~srichter] Do you mean that TTL doesn't guarantee a re

[jira] [Comment Edited] (FLINK-3089) State API Should Support Data Expiration (State TTL)

2017-10-03 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16190781#comment-16190781 ] Bowen Li edited comment on FLINK-3089 at 10/4/17 4:18 AM: -- [~sric

[jira] [Assigned] (FLINK-7648) Port TaskManagersHandler to new REST endpoint

2017-10-08 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-7648: --- Assignee: (was: Bowen Li) > Port TaskManagersHandler to new REST endpoint > -

[jira] [Updated] (FLINK-7388) ProcessFunction.onTimer() sets processing time as timestamp

2017-10-08 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7388: Fix Version/s: 1.4.0 > ProcessFunction.onTimer() sets processing time as timestamp > ---

[jira] [Commented] (FLINK-7388) ProcessFunction.onTimer() sets processing time as timestamp

2017-10-08 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196399#comment-16196399 ] Bowen Li commented on FLINK-7388: - [~xccui] [~fhueske] Thank you for pointing it out! > P

[jira] [Resolved] (FLINK-6219) Add a state backend which supports sorting

2017-10-08 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li resolved FLINK-6219. - Resolution: Won't Fix > Add a state backend which supports sorting > -

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

2017-10-08 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-7167: --- Assignee: Bowen Li > Job can't set checkpoint meta directory to cover the system setting > state.che

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

2017-10-08 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196456#comment-16196456 ] Bowen Li commented on FLINK-7167: - I've been looking forward to such an improvement too. N

[jira] [Assigned] (FLINK-6615) tmp directory not cleaned up on shutdown

2017-10-08 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-6615: --- Assignee: Bowen Li > tmp directory not cleaned up on shutdown > -

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

2017-10-08 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196523#comment-16196523 ] Bowen Li commented on FLINK-7167: - Hi [~aljoscha], I feel this is partly related to discus

[jira] [Assigned] (FLINK-6505) Proactively cleanup local FS for RocksDBKeyedStateBackend on startup

2017-10-08 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-6505: --- Assignee: Bowen Li > Proactively cleanup local FS for RocksDBKeyedStateBackend on startup > -

[jira] [Assigned] (FLINK-6684) Remove AsyncCheckpointRunnable from StreamTask

2017-10-08 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-6684: --- Assignee: Bowen Li > Remove AsyncCheckpointRunnable from StreamTask > ---

[jira] [Reopened] (FLINK-6219) Add a sorted state primitive

2017-10-09 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reopened FLINK-6219: - > Add a sorted state primitive > > > Key: FLINK-6219 >

[jira] [Commented] (FLINK-6219) Add a sorted state primitive

2017-10-09 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197188#comment-16197188 ] Bowen Li commented on FLINK-6219: - [~fhueske] I think the dependency in 'Issues Link' is s

[jira] [Comment Edited] (FLINK-6219) Add a sorted state primitive

2017-10-09 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197188#comment-16197188 ] Bowen Li edited comment on FLINK-6219 at 10/9/17 4:18 PM: -- [~fhue

[jira] [Commented] (FLINK-6951) Incompatible versions of httpcomponents jars for Flink kinesis connector

2017-10-11 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16201258#comment-16201258 ] Bowen Li commented on FLINK-6951: - [~aljoscha] I believe so as I've seen a couple email th

[jira] [Updated] (FLINK-7671) testBlobServerCleanupCancelledJob in JobManagerCleanupITCase failed in build

2017-10-11 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7671: Summary: testBlobServerCleanupCancelledJob in JobManagerCleanupITCase failed in build (was: JobManagerClean

[jira] [Updated] (FLINK-7671) testBlobServerCleanupCancelledJob in JobManagerCleanupITCase failed in build

2017-10-11 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7671: Description: {code:java} org.apache.flink.runtime.jobmanager.JobManagerCleanupITCase testBlobServerCleanupCa

[jira] [Assigned] (FLINK-7475) ListState support update

2017-10-11 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-7475: --- Assignee: Bowen Li > ListState support update > > > Key: FLI

[jira] [Created] (FLINK-7820) remove text related to FoldingState and FoldingStateDescriptor from doc

2017-10-11 Thread Bowen Li (JIRA)
Bowen Li created FLINK-7820: --- Summary: remove text related to FoldingState and FoldingStateDescriptor from doc Key: FLINK-7820 URL: https://issues.apache.org/jira/browse/FLINK-7820 Project: Flink

[jira] [Commented] (FLINK-7820) remove text related to FoldingState and FoldingStateDescriptor from doc

2017-10-12 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16202918#comment-16202918 ] Bowen Li commented on FLINK-7820: - [~aljoscha] I was thinking that keeping examples of dep

  1   2   3   4   5   6   7   8   9   10   >