[jira] [Commented] (FLINK-3950) Add Meter Metric Type

[ https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420743#comment-15420743 ] Chesnay Schepler commented on FLINK-3950: - The idea behind the Meter view is to re

[jira] [Updated] (FLINK-4396) GraphiteReporter class not found at startup of jobmanager

[ https://issues.apache.org/jira/browse/FLINK-4396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4396: Component/s: Metrics > GraphiteReporter class not found at startup of jobmanager > -

[jira] [Updated] (FLINK-4396) GraphiteReporter class not found at startup of jobmanager

[ https://issues.apache.org/jira/browse/FLINK-4396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4396: Labels: (was: metrics) > GraphiteReporter class not found at startup of jobmanager > -

[jira] [Updated] (FLINK-4396) GraphiteReporter class not found at startup of jobmanager

[ https://issues.apache.org/jira/browse/FLINK-4396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4396: Issue Type: Wish (was: Bug) > GraphiteReporter class not found at startup of jobmanager > -

[jira] [Commented] (FLINK-4396) GraphiteReporter class not found at startup of jobmanager

[ https://issues.apache.org/jira/browse/FLINK-4396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421110#comment-15421110 ] Chesnay Schepler commented on FLINK-4396: - For clarification I would like to ask w

[jira] [Commented] (FLINK-4177) CassandraConnectorTest.testCassandraCommitter causing unstable builds

[ https://issues.apache.org/jira/browse/FLINK-4177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15421419#comment-15421419 ] Chesnay Schepler commented on FLINK-4177: - I wrote my comment a a little bit befor

[jira] [Commented] (FLINK-4402) Wrong metrics parameter names in documentation

[ https://issues.apache.org/jira/browse/FLINK-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15423241#comment-15423241 ] Chesnay Schepler commented on FLINK-4402: - the documentation should be adjusted.

[jira] [Created] (FLINK-4411) [py] Chained dual input children are not properly propagated

Chesnay Schepler created FLINK-4411: --- Summary: [py] Chained dual input children are not properly propagated Key: FLINK-4411 URL: https://issues.apache.org/jira/browse/FLINK-4411 Project: Flink

[jira] [Updated] (FLINK-4411) [py] Chained dual input children are not properly propagated

[ https://issues.apache.org/jira/browse/FLINK-4411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4411: Fix Version/s: (was: 1.1.1) 1.1.2 > [py] Chained dual input children

[jira] [Created] (FLINK-4412) [py] Chaining does not properly handle broadcast variables

Chesnay Schepler created FLINK-4412: --- Summary: [py] Chaining does not properly handle broadcast variables Key: FLINK-4412 URL: https://issues.apache.org/jira/browse/FLINK-4412 Project: Flink

[jira] [Closed] (FLINK-4411) [py] Chained dual input children are not properly propagated

[ https://issues.apache.org/jira/browse/FLINK-4411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4411. --- Resolution: Fixed Fixed in 1050847787b416399a6c03c0568969df93ed4822 and aa50e226c318f6f52ffdf

[jira] [Closed] (FLINK-4412) [py] Chaining does not properly handle broadcast variables

[ https://issues.apache.org/jira/browse/FLINK-4412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4412. --- Resolution: Fixed Fixed in 84d28ba00f3e63a83132c1666c8dc8deec7800ba and 445eaa986dca59b124582

[jira] [Updated] (FLINK-4302) Add JavaDocs to MetricConfig

[ https://issues.apache.org/jira/browse/FLINK-4302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4302: Fix Version/s: 1.1.2 1.2.0 > Add JavaDocs to MetricConfig > -

[jira] [Closed] (FLINK-4302) Add JavaDocs to MetricConfig

[ https://issues.apache.org/jira/browse/FLINK-4302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4302. --- Resolution: Fixed Fixed in c5a9a3eb0061014fe59086505130596e924db7f9 and cbce10d100a1924747603

[jira] [Commented] (FLINK-4396) GraphiteReporter class not found at startup of jobmanager

[ https://issues.apache.org/jira/browse/FLINK-4396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432788#comment-15432788 ] Chesnay Schepler commented on FLINK-4396: - We don't require users to track down an

[jira] [Commented] (FLINK-2944) Collect, expose and display operator-specific stats

[ https://issues.apache.org/jira/browse/FLINK-2944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15434523#comment-15434523 ] Chesnay Schepler commented on FLINK-2944: - This issue is more or less an older met

[jira] [Commented] (FLINK-4502) Cassandra connector documentation has misleading consistency guarantees

[ https://issues.apache.org/jira/browse/FLINK-4502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438754#comment-15438754 ] Chesnay Schepler commented on FLINK-4502: - Alright, so let's break this down point

[jira] [Updated] (FLINK-4498) Better Cassandra sink documentation

[ https://issues.apache.org/jira/browse/FLINK-4498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4498: Component/s: Cassandra Connector > Better Cassandra sink documentation > ---

[jira] [Updated] (FLINK-4502) Cassandra connector documentation has misleading consistency guarantees

[ https://issues.apache.org/jira/browse/FLINK-4502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4502: Component/s: Cassandra Connector > Cassandra connector documentation has misleading consiste

[jira] [Commented] (FLINK-4519) scala maxLineLength increased to 120

[ https://issues.apache.org/jira/browse/FLINK-4519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445103#comment-15445103 ] Chesnay Schepler commented on FLINK-4519: - Could you provide a reason as to why th

[jira] [Resolved] (FLINK-4531) Thread.stop() is deprecated

[ https://issues.apache.org/jira/browse/FLINK-4531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler resolved FLINK-4531. - Resolution: Won't Fix > Thread.stop() is deprecated > --- > >

[jira] [Assigned] (FLINK-4544) TaskManager metrics are vulnerable to custom JMX bean installation

[ https://issues.apache.org/jira/browse/FLINK-4544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-4544: --- Assignee: Chesnay Schepler > TaskManager metrics are vulnerable to custom JMX bean in

[jira] [Created] (FLINK-4563) [metrics] scope caching not adjusted for multiple reporters

Chesnay Schepler created FLINK-4563: --- Summary: [metrics] scope caching not adjusted for multiple reporters Key: FLINK-4563 URL: https://issues.apache.org/jira/browse/FLINK-4563 Project: Flink

[jira] [Created] (FLINK-4564) [metrics] Delimiter should be configured per reporter

Chesnay Schepler created FLINK-4564: --- Summary: [metrics] Delimiter should be configured per reporter Key: FLINK-4564 URL: https://issues.apache.org/jira/browse/FLINK-4564 Project: Flink Iss

[jira] [Closed] (FLINK-4595) Close FileOutputStream in ParameterTool

[ https://issues.apache.org/jira/browse/FLINK-4595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4595. --- Resolution: Fixed Fixed in 920cda408f61a27f0b1731325b62bf141dd4b530 > Close FileOutputStream

[jira] [Closed] (FLINK-4436) Unclosed DataOutputBuffer in Utils#setTokensFor()

[ https://issues.apache.org/jira/browse/FLINK-4436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4436. --- Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 7e07bde8c5b33e9985260416fdf75e15df102ef

[jira] [Closed] (FLINK-4389) Expose metrics to Webfrontend

[ https://issues.apache.org/jira/browse/FLINK-4389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4389. --- Resolution: Fixed Fix Version/s: 1.2.0 Implemented in 70704de0c82cbb7b143dd696221e11999

[jira] [Assigned] (FLINK-4626) Missing break in MetricStore#add()

[ https://issues.apache.org/jira/browse/FLINK-4626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-4626: --- Assignee: Chesnay Schepler > Missing break in MetricStore#add() > ---

[jira] [Updated] (FLINK-4626) Missing break in MetricStore#add()

[ https://issues.apache.org/jira/browse/FLINK-4626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4626: Component/s: Metrics > Missing break in MetricStore#add() >

[jira] [Updated] (FLINK-4626) Missing break in MetricStore#add()

[ https://issues.apache.org/jira/browse/FLINK-4626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4626: Affects Version/s: 1.2.0 > Missing break in MetricStore#add() >

[jira] [Closed] (FLINK-4626) Missing break in MetricStore#add()

[ https://issues.apache.org/jira/browse/FLINK-4626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4626. --- Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 1586fc8cfc6f41244e46b27ad25dcb6b08b7ce4

[jira] [Closed] (FLINK-4608) Use short-circuit AND in Max/Min AggregationFunction

[ https://issues.apache.org/jira/browse/FLINK-4608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4608. --- Resolution: Fixed Fixed in ceb3aa05bae3d05b9f6c5a7a55e6e43fc91a9450 > Use short-circuit AND i

[jira] [Closed] (FLINK-4612) Close FileWriter using try with resources

[ https://issues.apache.org/jira/browse/FLINK-4612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4612. --- Resolution: Fixed Fix Version/s: 1.2.0 Fixed in f06930bcf0d3c2a840cdc5a2e6e5f4b1d03f45d

[jira] [Comment Edited] (FLINK-4608) Use short-circuit AND in Max/Min AggregationFunction

[ https://issues.apache.org/jira/browse/FLINK-4608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15495983#comment-15495983 ] Chesnay Schepler edited comment on FLINK-4608 at 9/16/16 10:38 AM: -

[jira] [Closed] (FLINK-4607) Close FileInputStream in ParameterTool and other

[ https://issues.apache.org/jira/browse/FLINK-4607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4607. --- Resolution: Fixed Fixed in db90580ffdb93a55a6318b18b5d50ec3666b001b > Close FileInputStream i

[jira] [Reopened] (FLINK-4608) Use short-circuit AND in Max/Min AggregationFunction

[ https://issues.apache.org/jira/browse/FLINK-4608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-4608: - > Use short-circuit AND in Max/Min AggregationFunction > -

[jira] [Closed] (FLINK-4608) Use short-circuit AND in Max/Min AggregationFunction

[ https://issues.apache.org/jira/browse/FLINK-4608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4608. --- Resolution: Fixed > Use short-circuit AND in Max/Min AggregationFunction > ---

[jira] [Closed] (FLINK-4622) CLI help message should include 'savepoint' action

[ https://issues.apache.org/jira/browse/FLINK-4622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4622. --- Resolution: Fixed Fix Version/s: 1.2.0 Implemented in d7b59d761601baba6765bb4fc407bcd9f

[jira] [Commented] (FLINK-4533) Unprotected access to meters in StatsDReporter#report()

[ https://issues.apache.org/jira/browse/FLINK-4533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15506074#comment-15506074 ] Chesnay Schepler commented on FLINK-4533: - we intentionally don't protect the acce

[jira] [Commented] (FLINK-4533) Unprotected access to meters in StatsDReporter#report()

[ https://issues.apache.org/jira/browse/FLINK-4533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507024#comment-15507024 ] Chesnay Schepler commented on FLINK-4533: - there already is a comment within repor

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

[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925915#comment-15925915 ] Chesnay Schepler commented on FLINK-6053: - This would break a public API so we can

[jira] [Commented] (FLINK-5650) Flink-python tests executing cost too long time

[ https://issues.apache.org/jira/browse/FLINK-5650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15925943#comment-15925943 ] Chesnay Schepler commented on FLINK-5650: - This got very little to do with test de

[jira] [Commented] (FLINK-5650) Flink-python tests executing cost too long time

[ https://issues.apache.org/jira/browse/FLINK-5650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15926433#comment-15926433 ] Chesnay Schepler commented on FLINK-5650: - [~shijinkui] Could you check out this b

[jira] [Updated] (FLINK-6051) Wrong metric scope names in documentation

[ https://issues.apache.org/jira/browse/FLINK-6051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6051: Component/s: Metrics > Wrong metric scope names in documentation > -

[jira] [Updated] (FLINK-6051) Wrong metric scope names in documentation

[ https://issues.apache.org/jira/browse/FLINK-6051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6051: Affects Version/s: 1.3.0 > Wrong metric scope names in documentation > -

[jira] [Closed] (FLINK-6051) Wrong metric scope names in documentation

[ https://issues.apache.org/jira/browse/FLINK-6051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6051. --- Resolution: Fixed Fix Version/s: 1.2.1 1.3.0 1.2: 9206df666057eb32f8

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

[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15926561#comment-15926561 ] Chesnay Schepler commented on FLINK-6053: - I can see the merit and would be in fav

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

[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15926574#comment-15926574 ] Chesnay Schepler commented on FLINK-6053: - Actually we could change the AbstractRe

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

[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15926574#comment-15926574 ] Chesnay Schepler edited comment on FLINK-6053 at 3/15/17 5:02 PM: --

[jira] [Assigned] (FLINK-5978) JM WebFrontend address ConfigOption is defined in ConfigConstants

[ https://issues.apache.org/jira/browse/FLINK-5978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-5978: --- Assignee: fang yong > JM WebFrontend address ConfigOption is defined in ConfigConstan

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

[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927797#comment-15927797 ] Chesnay Schepler commented on FLINK-6053: - [~phoenixjiangnan] You now have contrib

[jira] [Commented] (FLINK-5978) JM WebFrontend address ConfigOption is defined in ConfigConstants

[ https://issues.apache.org/jira/browse/FLINK-5978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927796#comment-15927796 ] Chesnay Schepler commented on FLINK-5978: - [~zjureel] You now have contributor per

[jira] [Updated] (FLINK-5453) REST API request reference incomplete

[ https://issues.apache.org/jira/browse/FLINK-5453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5453: Description: The REST API documentation is supposed to contain a list of all available requ

[jira] [Created] (FLINK-6086) Rework PythonSender/-Streamer generics

Chesnay Schepler created FLINK-6086: --- Summary: Rework PythonSender/-Streamer generics Key: FLINK-6086 URL: https://issues.apache.org/jira/browse/FLINK-6086 Project: Flink Issue Type: Improv

[jira] [Updated] (FLINK-5650) Flink-python tests executing cost too long time

[ https://issues.apache.org/jira/browse/FLINK-5650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5650: Affects Version/s: 1.3.0 > Flink-python tests executing cost too long time > ---

[jira] [Closed] (FLINK-5650) Flink-python tests executing cost too long time

[ https://issues.apache.org/jira/browse/FLINK-5650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5650. --- Resolution: Fixed Assignee: Chesnay Schepler Fix Version/s: 1.3.0 1.2: edd1065

[jira] [Resolved] (FLINK-5331) PythonPlanBinderTest idling extremely long

[ https://issues.apache.org/jira/browse/FLINK-5331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler resolved FLINK-5331. - Resolution: Duplicate Fix Version/s: 1.2.1 1.3.0 Let's assume th

[jira] [Commented] (FLINK-6098) Cassandra sink freezes after write error

[ https://issues.apache.org/jira/browse/FLINK-6098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15929893#comment-15929893 ] Chesnay Schepler commented on FLINK-6098: - It is very odd that the job does not fa

[jira] [Created] (FLINK-6111) Remove sleep after python process generation

Chesnay Schepler created FLINK-6111: --- Summary: Remove sleep after python process generation Key: FLINK-6111 URL: https://issues.apache.org/jira/browse/FLINK-6111 Project: Flink Issue Type:

[jira] [Commented] (FLINK-6110) Flink unnecessarily repeats shared work triggered by different blocking sinks, leading to massive inefficiency

[ https://issues.apache.org/jira/browse/FLINK-6110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931202#comment-15931202 ] Chesnay Schepler commented on FLINK-6110: - This is certainly useful, nevertheless

[jira] [Closed] (FLINK-6111) Remove sleep after python process generation

[ https://issues.apache.org/jira/browse/FLINK-6111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6111. --- Resolution: Fixed 3e767b5a4a0846c8d53a8167d6236dbd9657eb2f > Remove sleep after python proces

[jira] [Assigned] (FLINK-5183) [py] Support multiple jobs per Python plan file

[ https://issues.apache.org/jira/browse/FLINK-5183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-5183: --- Assignee: Geoffrey Mon > [py] Support multiple jobs per Python plan file > --

[jira] [Closed] (FLINK-5183) [py] Support multiple jobs per Python plan file

[ https://issues.apache.org/jira/browse/FLINK-5183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5183. --- Resolution: Fixed Fix Version/s: 1.3.0 2ce080da627cbc77527b69bfb877d4904e9a0701 > [py]

[jira] [Assigned] (FLINK-6043) Display time when exceptions/root cause of failure happened

[ https://issues.apache.org/jira/browse/FLINK-6043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-6043: --- Assignee: Chesnay Schepler > Display time when exceptions/root cause of failure happe

[jira] [Commented] (FLINK-6129) MetricRegistry does not stop query actor

[ https://issues.apache.org/jira/browse/FLINK-6129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15932633#comment-15932633 ] Chesnay Schepler commented on FLINK-6129: - I thought all actors are properly shutd

[jira] [Created] (FLINK-6167) Consider removing ArchivedExecutionGraph classes

Chesnay Schepler created FLINK-6167: --- Summary: Consider removing ArchivedExecutionGraph classes Key: FLINK-6167 URL: https://issues.apache.org/jira/browse/FLINK-6167 Project: Flink Issue Ty

[jira] [Commented] (FLINK-6167) Consider removing ArchivedExecutionGraph classes

[ https://issues.apache.org/jira/browse/FLINK-6167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15936492#comment-15936492 ] Chesnay Schepler commented on FLINK-6167: - In that case we could just write the jo

[jira] [Comment Edited] (FLINK-6167) Consider removing ArchivedExecutionGraph classes

[ https://issues.apache.org/jira/browse/FLINK-6167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15936492#comment-15936492 ] Chesnay Schepler edited comment on FLINK-6167 at 3/22/17 3:02 PM: --

[jira] [Assigned] (FLINK-5886) Python API for streaming applications

[ https://issues.apache.org/jira/browse/FLINK-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-5886: --- Assignee: Zohar Mizrahi > Python API for streaming applications > ---

[jira] [Commented] (FLINK-6172) Potentially unclosed RandomAccessFile in HistoryServerStaticFileServerHandler

[ https://issues.apache.org/jira/browse/FLINK-6172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15938076#comment-15938076 ] Chesnay Schepler commented on FLINK-6172: - according to the comment directly above

[jira] [Assigned] (FLINK-6042) Display last n exceptions/causes for job restarts in Web UI

[ https://issues.apache.org/jira/browse/FLINK-6042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-6042: --- Assignee: Chesnay Schepler > Display last n exceptions/causes for job restarts in Web

[jira] [Commented] (FLINK-6177) Add support for "Distributed Cache" in streaming applications

[ https://issues.apache.org/jira/browse/FLINK-6177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15939987#comment-15939987 ] Chesnay Schepler commented on FLINK-6177: - The Distributed Cache is for transferri

[jira] [Closed] (FLINK-5992) Enable file registration at distributed cache in stream execution environment

[ https://issues.apache.org/jira/browse/FLINK-5992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5992. --- Resolution: Duplicate > Enable file registration at distributed cache in stream execution envi

[jira] [Created] (FLINK-6183) TaskMetricGroup may not be cleanup when Task.run() is never called or exits early

Chesnay Schepler created FLINK-6183: --- Summary: TaskMetricGroup may not be cleanup when Task.run() is never called or exits early Key: FLINK-6183 URL: https://issues.apache.org/jira/browse/FLINK-6183

[jira] [Created] (FLINK-6184) Buffer metrics can cause NPE

Chesnay Schepler created FLINK-6184: --- Summary: Buffer metrics can cause NPE Key: FLINK-6184 URL: https://issues.apache.org/jira/browse/FLINK-6184 Project: Flink Issue Type: Bug Co

[jira] [Updated] (FLINK-6183) TaskMetricGroup may not be cleanup when Task.run() is never called or exits early

[ https://issues.apache.org/jira/browse/FLINK-6183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6183: Component/s: Metrics > TaskMetricGroup may not be cleanup when Task.run() is never called or

[jira] [Updated] (FLINK-6184) Buffer metrics can cause NPE

[ https://issues.apache.org/jira/browse/FLINK-6184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6184: Affects Version/s: 1.2.0 > Buffer metrics can cause NPE > > >

[jira] [Updated] (FLINK-6183) TaskMetricGroup may not be cleanup when Task.run() is never called or exits early

[ https://issues.apache.org/jira/browse/FLINK-6183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6183: Affects Version/s: 1.2.0 > TaskMetricGroup may not be cleanup when Task.run() is never calle

[jira] [Assigned] (FLINK-6184) Buffer metrics can cause NPE

[ https://issues.apache.org/jira/browse/FLINK-6184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-6184: --- Assignee: Chesnay Schepler > Buffer metrics can cause NPE > -

[jira] [Assigned] (FLINK-6183) TaskMetricGroup may not be cleanup when Task.run() is never called or exits early

[ https://issues.apache.org/jira/browse/FLINK-6183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-6183: --- Assignee: Chesnay Schepler > TaskMetricGroup may not be cleanup when Task.run() is ne

[jira] [Commented] (FLINK-5892) Recover job state at the granularity of operator

[ https://issues.apache.org/jira/browse/FLINK-5892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942990#comment-15942990 ] Chesnay Schepler commented on FLINK-5892: - [~maguowei] What's your progress on thi

[jira] [Commented] (FLINK-5785) Add an Imputer for preparing data

[ https://issues.apache.org/jira/browse/FLINK-5785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15943111#comment-15943111 ] Chesnay Schepler commented on FLINK-5785: - [~beera] Could you provide a link to th

[jira] [Commented] (FLINK-5785) Add an Imputer for preparing data

[ https://issues.apache.org/jira/browse/FLINK-5785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15943184#comment-15943184 ] Chesnay Schepler commented on FLINK-5785: - [~beera] You've opened the PR against y

[jira] [Commented] (FLINK-5785) Add an Imputer for preparing data

[ https://issues.apache.org/jira/browse/FLINK-5785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15944817#comment-15944817 ] Chesnay Schepler commented on FLINK-5785: - Please remove all files that shouldn't

[jira] [Updated] (FLINK-6203) DataSet Transformations

[ https://issues.apache.org/jira/browse/FLINK-6203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6203: Description: the example of GroupReduce on sorted groups can't remove duplicate Strings in a

[jira] [Updated] (FLINK-6203) DataSet Transformations

[ https://issues.apache.org/jira/browse/FLINK-6203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6203: Description: the example of GroupReduce on sorted groups can't remove duplicate Strings in a

[jira] [Closed] (FLINK-5977) Rename MAX_ATTEMPTS_HISTORY_SIZE key

[ https://issues.apache.org/jira/browse/FLINK-5977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5977. --- Resolution: Fixed Assignee: Stephan Ewen Fixed in 81a143f6b42cf39d56a36222d14b5db0cc54ad

[jira] [Closed] (FLINK-5302) Log failure cause at Execution

[ https://issues.apache.org/jira/browse/FLINK-5302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5302. --- Resolution: Invalid We already store the failureCause for each execution. > Log failure cause

[jira] [Created] (FLINK-6223) Rework PythonPlanBinder generics

Chesnay Schepler created FLINK-6223: --- Summary: Rework PythonPlanBinder generics Key: FLINK-6223 URL: https://issues.apache.org/jira/browse/FLINK-6223 Project: Flink Issue Type: Improvement

[jira] [Assigned] (FLINK-5516) Hardcoded paths in flink-python/.../PythonPlanBinder.java

[ https://issues.apache.org/jira/browse/FLINK-5516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-5516: --- Assignee: Chesnay Schepler > Hardcoded paths in flink-python/.../PythonPlanBinder.jav

[jira] [Commented] (FLINK-6115) Need more helpful error message when trying to serialize a tuple with a null field

[ https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15950482#comment-15950482 ] Chesnay Schepler commented on FLINK-6115: - [~lukehutch] Regardind 1) I believe yo

[jira] [Created] (FLINK-6229) Rework setup&configuration of PythonPlanBinder/operators

Chesnay Schepler created FLINK-6229: --- Summary: Rework setup&configuration of PythonPlanBinder/operators Key: FLINK-6229 URL: https://issues.apache.org/jira/browse/FLINK-6229 Project: Flink

[jira] [Created] (FLINK-6230) Make mmap size configurable

Chesnay Schepler created FLINK-6230: --- Summary: Make mmap size configurable Key: FLINK-6230 URL: https://issues.apache.org/jira/browse/FLINK-6230 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-6234) HTTP/HTTPS WebServer Extension

[ https://issues.apache.org/jira/browse/FLINK-6234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15953331#comment-15953331 ] Chesnay Schepler commented on FLINK-6234: - Could you give some more details what w

[jira] [Commented] (FLINK-3427) Add watermark monitoring to JobManager web frontend

[ https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15953644#comment-15953644 ] Chesnay Schepler commented on FLINK-3427: - [~vpernin] The backpressure monitoring

[jira] [Commented] (FLINK-4840) Measure latency of record processing and expose it as a metric

[ https://issues.apache.org/jira/browse/FLINK-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15954938#comment-15954938 ] Chesnay Schepler commented on FLINK-4840: - I may have found a suitable implementat

[jira] [Closed] (FLINK-4939) GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint

[ https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4939. --- Resolution: Fixed Implemented in 381bf5912237420b8e294c1fd38006a85403fd4f > GenericWriteAhead

[jira] [Closed] (FLINK-2839) Failing test: OperatorStatsAccumulatorTest.testAccumulatorAllStatistics

[ https://issues.apache.org/jira/browse/FLINK-2839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-2839. --- Resolution: Invalid Fix Version/s: 1.2.0 The operator-stats module was removed in FLINK

[jira] [Assigned] (FLINK-4177) CassandraConnectorTest.testCassandraCommitter causing unstable builds

[ https://issues.apache.org/jira/browse/FLINK-4177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-4177: --- Assignee: Chesnay Schepler > CassandraConnectorTest.testCassandraCommitter causing un

[jira] [Reopened] (FLINK-4177) CassandraConnectorTest.testCassandraCommitter causing unstable builds

[ https://issues.apache.org/jira/browse/FLINK-4177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-4177: - > CassandraConnectorTest.testCassandraCommitter causing unstable builds >

  1   2   3   4   5   6   7   8   9   10   >