[jira] (FLINK-5690) protobuf is not shaded properly

Title: Message Title Robert Metzger commented on FLINK-5690

[jira] (FLINK-5690) protobuf is not shaded properly

Title: Message Title Robert Metzger commented on FLINK-5690

[jira] [Updated] (FLINK-5634) Flink should not always redirect stdout to a file.

[ https://issues.apache.org/jira/browse/FLINK-5634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5634: -- Fix Version/s: (was: 1.2.0) > Flink should not always redirect stdout to a file. > -

[jira] [Updated] (FLINK-5635) Improve Docker tooling to make it easier to build images and launch Flink via Docker tools

[ https://issues.apache.org/jira/browse/FLINK-5635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5635: -- Fix Version/s: (was: 1.2.0) > Improve Docker tooling to make it easier to build images and l

[jira] [Commented] (FLINK-5552) Make the JMX port available through RESTful API

[ https://issues.apache.org/jira/browse/FLINK-5552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15850107#comment-15850107 ] Robert Metzger commented on FLINK-5552: --- [~Zentol] any thoughts on this issue? I won

[jira] [Assigned] (FLINK-4830) Show latency statistics in web interface

[ https://issues.apache.org/jira/browse/FLINK-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-4830: - Assignee: (was: Robert Metzger) > Show latency statistics in web interface >

[jira] [Resolved] (FLINK-3766) Add a new tab for monitoring metrics in the web interface

[ https://issues.apache.org/jira/browse/FLINK-3766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3766. --- Resolution: Fixed Fix Version/s: 1.2.0 This has been merged for Flink 1.2.0 > Add a ne

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

[ https://issues.apache.org/jira/browse/FLINK-2944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-2944. --- Resolution: Fixed > Collect, expose and display operator-specific stats >

[jira] [Resolved] (FLINK-867) Webinterface JobHistory does not work offline

[ https://issues.apache.org/jira/browse/FLINK-867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-867. -- Resolution: Invalid > Webinterface JobHistory does not work offline > ---

[jira] [Commented] (FLINK-867) Webinterface JobHistory does not work offline

[ https://issues.apache.org/jira/browse/FLINK-867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15851489#comment-15851489 ] Robert Metzger commented on FLINK-867: -- I'll close the issue. This is referring to our

[jira] [Commented] (FLINK-1337) Create an Amazon EMR Bootstrap Action

[ https://issues.apache.org/jira/browse/FLINK-1337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15851490#comment-15851490 ] Robert Metzger commented on FLINK-1337: --- I'm in favor of closing this JIRA. > Creat

[jira] [Commented] (FLINK-2170) Add OrcTableSource

[ https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15851712#comment-15851712 ] Robert Metzger commented on FLINK-2170: --- [~owen.omalley] What's your status on this?

[jira] [Commented] (FLINK-5690) protobuf is not shaded properly

[ https://issues.apache.org/jira/browse/FLINK-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15853217#comment-15853217 ] Robert Metzger commented on FLINK-5690: --- Thank you for providing an example. I'll lo

[jira] [Commented] (FLINK-5731) Split up CI builds

[ https://issues.apache.org/jira/browse/FLINK-5731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855726#comment-15855726 ] Robert Metzger commented on FLINK-5731: --- I will probably work on this later this wee

[jira] [Assigned] (FLINK-5690) protobuf is not shaded properly

[ https://issues.apache.org/jira/browse/FLINK-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-5690: - Assignee: Robert Metzger > protobuf is not shaded properly >

[jira] [Commented] (FLINK-1588) Load flink configuration also from classloader

[ https://issues.apache.org/jira/browse/FLINK-1588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855790#comment-15855790 ] Robert Metzger commented on FLINK-1588: --- Thank you for looking into the issue. I wo

[jira] [Commented] (FLINK-5690) protobuf is not shaded properly

[ https://issues.apache.org/jira/browse/FLINK-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855966#comment-15855966 ] Robert Metzger commented on FLINK-5690: --- Okay, cool. I still tried to reproduce the

[jira] [Commented] (FLINK-5005) Publish Scala 2.12 artifacts

[ https://issues.apache.org/jira/browse/FLINK-5005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15856327#comment-15856327 ] Robert Metzger commented on FLINK-5005: --- I can look into releasing flakka for Scala

[jira] [Created] (FLINK-5736) Fix Javadocs / Scaladocs build (Feb 2017)

Robert Metzger created FLINK-5736: - Summary: Fix Javadocs / Scaladocs build (Feb 2017) Key: FLINK-5736 URL: https://issues.apache.org/jira/browse/FLINK-5736 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-1588) Load flink configuration also from classloader

[ https://issues.apache.org/jira/browse/FLINK-1588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15856620#comment-15856620 ] Robert Metzger commented on FLINK-1588: --- Okay, sounds good. Sorry for not warning yo

[jira] [Resolved] (FLINK-1588) Load flink configuration also from classloader

[ https://issues.apache.org/jira/browse/FLINK-1588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1588. --- Resolution: Won't Fix > Load flink configuration also from classloader > -

[jira] [Commented] (FLINK-5719) Let LatencyMarkers completely bypass operators / chains

[ https://issues.apache.org/jira/browse/FLINK-5719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15857797#comment-15857797 ] Robert Metzger commented on FLINK-5719: --- Yes, changing from PublicEvolving to Intern

[jira] [Resolved] (FLINK-5153) Allow setting custom application tags for Flink on YARN

[ https://issues.apache.org/jira/browse/FLINK-5153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-5153. --- Resolution: Fixed Fix Version/s: 1.3.0 Thanks a lot for your contribution Patrick! Cha

[jira] [Commented] (FLINK-5728) FlinkKafkaProducer should flush on checkpoint by default

[ https://issues.apache.org/jira/browse/FLINK-5728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15859440#comment-15859440 ] Robert Metzger commented on FLINK-5728: --- +1 for enabling it by default. I'm against

[jira] [Commented] (FLINK-7510) Move some connectors to Apache Bahir

[ https://issues.apache.org/jira/browse/FLINK-7510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168864#comment-16168864 ] Robert Metzger commented on FLINK-7510: --- I'm not sure if we really want to move the

[jira] [Commented] (FLINK-7510) Move some connectors to Apache Bahir

[ https://issues.apache.org/jira/browse/FLINK-7510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16169763#comment-16169763 ] Robert Metzger commented on FLINK-7510: --- [~aljoscha] [~tzulitai] what do you think a

[jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric

[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173109#comment-16173109 ] Robert Metzger commented on FLINK-7608: --- How are historgrams exported to systems lik

[jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric

[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173112#comment-16173112 ] Robert Metzger commented on FLINK-7608: --- [~yew1eb] When I first implemented this, I

[jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric

[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173193#comment-16173193 ] Robert Metzger commented on FLINK-7608: --- [~Zentol] Is there a nice way to solve this

[jira] [Commented] (FLINK-7672) Publish Kinesis connector to Maven Central?

[ https://issues.apache.org/jira/browse/FLINK-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16177622#comment-16177622 ] Robert Metzger commented on FLINK-7672: --- The last time I worked with the flink kines

[jira] [Updated] (FLINK-7673) Flink Kinesis connector - remove dependency on the ASL code

[ https://issues.apache.org/jira/browse/FLINK-7673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-7673: -- Component/s: Kinesis Connector > Flink Kinesis connector - remove dependency on the ASL code > -

[jira] [Commented] (FLINK-7673) Flink Kinesis connector - remove dependency on the ASL code

[ https://issues.apache.org/jira/browse/FLINK-7673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16177629#comment-16177629 ] Robert Metzger commented on FLINK-7673: --- Thank you for looking into this! It is inde

[jira] [Commented] (FLINK-6950) Add ability to specify single jar files to be shipped to YARN

[ https://issues.apache.org/jira/browse/FLINK-6950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16183104#comment-16183104 ] Robert Metzger commented on FLINK-6950: --- Yes, please go ahead! > Add ability to spe

[jira] [Commented] (FLINK-7525) Add config option to disable Cancel functionality on UI

[ https://issues.apache.org/jira/browse/FLINK-7525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16184275#comment-16184275 ] Robert Metzger commented on FLINK-7525: --- [~Zentol] What are the implications of this

[jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric

[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16192698#comment-16192698 ] Robert Metzger commented on FLINK-7608: --- I had an offline chat with Chesnay about th

[jira] [Updated] (FLINK-7492) Memsql Connector

[ https://issues.apache.org/jira/browse/FLINK-7492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-7492: -- Component/s: Streaming Connectors > Memsql Connector > > > Key:

[jira] [Updated] (FLINK-7743) Remove the restriction of minimum memory of JM

[ https://issues.apache.org/jira/browse/FLINK-7743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-7743: -- Component/s: YARN > Remove the restriction of minimum memory of JM > ---

[jira] [Updated] (FLINK-7493) Create Pinot Connector

[ https://issues.apache.org/jira/browse/FLINK-7493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-7493: -- Component/s: Streaming Connectors > Create Pinot Connector > -- > >

[jira] [Updated] (FLINK-7679) Upgrade maven enforcer plugin to 3.0.0-M1

[ https://issues.apache.org/jira/browse/FLINK-7679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-7679: -- Component/s: Build System > Upgrade maven enforcer plugin to 3.0.0-M1 >

[jira] [Commented] (FLINK-7492) Memsql Connector

[ https://issues.apache.org/jira/browse/FLINK-7492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16195006#comment-16195006 ] Robert Metzger commented on FLINK-7492: --- I would suggest to contribute the connector

[jira] [Updated] (FLINK-7642) Upgrade maven surefire plugin to 2.19.1

[ https://issues.apache.org/jira/browse/FLINK-7642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-7642: -- Component/s: Build System > Upgrade maven surefire plugin to 2.19.1 > --

[jira] [Commented] (FLINK-7493) Create Pinot Connector

[ https://issues.apache.org/jira/browse/FLINK-7493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16195005#comment-16195005 ] Robert Metzger commented on FLINK-7493: --- I would suggest to contribute the connector

[jira] [Updated] (FLINK-7682) Invalid state size formatting

[ https://issues.apache.org/jira/browse/FLINK-7682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-7682: -- Component/s: Webfrontend > Invalid state size formatting > - > >

[jira] [Updated] (FLINK-7740) Add parameter support in CassandraInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-7740: -- Component/s: Cassandra Connector > Add parameter support in CassandraInputFormat > -

[jira] [Updated] (FLINK-7488) TaskManagerHeapSizeCalculationJavaBashTest sometimes fails

[ https://issues.apache.org/jira/browse/FLINK-7488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-7488: -- Component/s: Tests > TaskManagerHeapSizeCalculationJavaBashTest sometimes fails > --

[jira] [Updated] (FLINK-7775) Remove unreferenced method PermanentBlobCache#getNumberOfCachedJobs

[ https://issues.apache.org/jira/browse/FLINK-7775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-7775: -- Component/s: Local Runtime > Remove unreferenced method PermanentBlobCache#getNumberOfCachedJobs

[jira] [Updated] (FLINK-7495) AbstractUdfStreamOperator#initializeState() should be called in AsyncWaitOperator#initializeState()

[ https://issues.apache.org/jira/browse/FLINK-7495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-7495: -- Component/s: State Backends, Checkpointing > AbstractUdfStreamOperator#initializeState() should

[jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric

[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209085#comment-16209085 ] Robert Metzger commented on FLINK-7608: --- +1 I agree > LatencyGauge change to histo

[jira] [Commented] (FLINK-6625) Flink removes HA job data when reaching JobStatus.FAILED

[ https://issues.apache.org/jira/browse/FLINK-6625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16646333#comment-16646333 ] Robert Metzger commented on FLINK-6625: --- Can we guarantee that checkpoints are cons

[jira] [Commented] (FLINK-6116) Watermarks don't work when unioning with same DataStream

[ https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16008536#comment-16008536 ] Robert Metzger commented on FLINK-6116: --- I'm fine with leaving this open for the 1.3

[jira] [Created] (FLINK-6580) Flink on YARN doesnt start with default parameters

Robert Metzger created FLINK-6580: - Summary: Flink on YARN doesnt start with default parameters Key: FLINK-6580 URL: https://issues.apache.org/jira/browse/FLINK-6580 Project: Flink Issue Type

[jira] [Commented] (FLINK-6580) Flink on YARN doesnt start with default parameters

[ https://issues.apache.org/jira/browse/FLINK-6580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16010203#comment-16010203 ] Robert Metzger commented on FLINK-6580: --- To fix the issue, I propose to sync with de

[jira] [Commented] (FLINK-6514) Cannot start Flink Cluster in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16010233#comment-16010233 ] Robert Metzger commented on FLINK-6514: --- Merged for 1.4 in - http://git-wip-us.apac

[jira] [Resolved] (FLINK-6514) Cannot start Flink Cluster in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-6514. --- Resolution: Fixed Fix Version/s: 1.4.0 Merged for 1.3: - http://git-wip-us.apache.org/r

[jira] [Reopened] (FLINK-5763) Make savepoints self-contained and relocatable

[ https://issues.apache.org/jira/browse/FLINK-5763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-5763: --- Assignee: (was: Ufuk Celebi) Afaik this issue is not done yet because https://issues.ap

[jira] [Resolved] (FLINK-6580) Flink on YARN doesnt start with default parameters

[ https://issues.apache.org/jira/browse/FLINK-6580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-6580. --- Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 Resolved for 1.3 in htt

[jira] [Closed] (FLINK-5661) flink-mesos should shade its httpclient dependency away

[ https://issues.apache.org/jira/browse/FLINK-5661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-5661. - Resolution: Invalid Addressed in 63bbb4f533a0f11376834d584308e90b6b8b5f10 > flink-mesos should sh

[jira] [Closed] (FLINK-2816) Memory allocation module as a separate maven artifact

[ https://issues.apache.org/jira/browse/FLINK-2816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-2816. - Resolution: Won't Fix > Memory allocation module as a separate maven artifact > --

[jira] [Closed] (FLINK-2593) Revisit Flink's shading policy

[ https://issues.apache.org/jira/browse/FLINK-2593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-2593. - Resolution: Duplicate Subsumed by FLINK-6529 > Revisit Flink's shading policy > -

[jira] [Updated] (FLINK-6593) Fix Bug in ProctimeAttribute or RowtimeAttribute with join UDTF

[ https://issues.apache.org/jira/browse/FLINK-6593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6593: -- Component/s: Table API & SQL > Fix Bug in ProctimeAttribute or RowtimeAttribute with join UDTF >

[jira] [Commented] (FLINK-6031) Add parameter for per job yarn clusters to control whether the user code jar is included into the system classloader.

[ https://issues.apache.org/jira/browse/FLINK-6031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16013762#comment-16013762 ] Robert Metzger commented on FLINK-6031: --- I responded on the BEAM issue. Back to thi

[jira] [Commented] (FLINK-6328) Savepoints must not be counted as retained checkpoints

[ https://issues.apache.org/jira/browse/FLINK-6328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16013923#comment-16013923 ] Robert Metzger commented on FLINK-6328: --- [~StephanEwen] is this a blocker for the 1.

[jira] [Commented] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16013928#comment-16013928 ] Robert Metzger commented on FLINK-6321: --- Is this a issue still a blocker? is it okay

[jira] [Commented] (FLINK-6318) NFA serialisation doesn't work with TypeSerializers that load classes

[ https://issues.apache.org/jira/browse/FLINK-6318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16013929#comment-16013929 ] Robert Metzger commented on FLINK-6318: --- What is the plan for this issue wrt to Flin

[jira] [Commented] (FLINK-5636) IO Metric for StreamTwoInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-5636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16013952#comment-16013952 ] Robert Metzger commented on FLINK-5636: --- I ran into the issue as well. [~david.wang

[jira] [Updated] (FLINK-6613) OOM during reading big messages from Kafka

[ https://issues.apache.org/jira/browse/FLINK-6613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6613: -- Component/s: Kafka Connector > OOM during reading big messages from Kafka >

[jira] [Updated] (FLINK-6116) Watermarks don't work when unioning with same DataStream

[ https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6116: -- Fix Version/s: (was: 1.3.0) > Watermarks don't work when unioning with same DataStream > ---

[jira] [Updated] (FLINK-6116) Watermarks don't work when unioning with same DataStream

[ https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6116: -- Priority: Critical (was: Blocker) > Watermarks don't work when unioning with same DataStream >

[jira] [Updated] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeyedCEP.

[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6321: -- Priority: Critical (was: Blocker) > RocksDB state backend Checkpointing is not working with Key

[jira] [Commented] (FLINK-6031) Add parameter for per job yarn clusters to control whether the user code jar is included into the system classloader.

[ https://issues.apache.org/jira/browse/FLINK-6031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16015646#comment-16015646 ] Robert Metzger commented on FLINK-6031: --- Merged for master (1.4) in http://git-wip-

[jira] [Resolved] (FLINK-6031) Add parameter for per job yarn clusters to control whether the user code jar is included into the system classloader.

[ https://issues.apache.org/jira/browse/FLINK-6031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-6031. --- Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 > Add parameter for per

[jira] [Commented] (FLINK-6627) Expose tmp directories via API

[ https://issues.apache.org/jira/browse/FLINK-6627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16016341#comment-16016341 ] Robert Metzger commented on FLINK-6627: --- Wouldn't it be easier to manually create a

[jira] [Resolved] (FLINK-6582) Project from maven archetype is not buildable by default due to ${scala.binary.version}

[ https://issues.apache.org/jira/browse/FLINK-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-6582. --- Resolution: Fixed Fix for master/1.4: http://git-wip-us.apache.org/repos/asf/flink/commit/6ae7

[jira] [Created] (FLINK-6641) HA recovery on YARN fails due to missing files in HDFS

Robert Metzger created FLINK-6641: - Summary: HA recovery on YARN fails due to missing files in HDFS Key: FLINK-6641 URL: https://issues.apache.org/jira/browse/FLINK-6641 Project: Flink Issue

[jira] [Created] (FLINK-6643) Flink restarts job in HA even if NoRestartStrategy is set

Robert Metzger created FLINK-6643: - Summary: Flink restarts job in HA even if NoRestartStrategy is set Key: FLINK-6643 URL: https://issues.apache.org/jira/browse/FLINK-6643 Project: Flink Iss

[jira] [Commented] (FLINK-6641) HA recovery on YARN fails due to missing files in HDFS

[ https://issues.apache.org/jira/browse/FLINK-6641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16017534#comment-16017534 ] Robert Metzger commented on FLINK-6641: --- Yes, I agree. This JIRA is actually two iss

[jira] [Updated] (FLINK-6641) HA recovery on YARN: ClusterClient calls HighAvailabilityServices#closeAndCleanupAll

[ https://issues.apache.org/jira/browse/FLINK-6641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6641: -- Summary: HA recovery on YARN: ClusterClient calls HighAvailabilityServices#closeAndCleanupAll (

[jira] [Updated] (FLINK-6641) HA recovery on YARN: ClusterClient calls HighAvailabilityServices#closeAndCleanupAll

[ https://issues.apache.org/jira/browse/FLINK-6641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6641: -- Description: While testing the 1.3 RC1, I was unable to recovery from a JobManager failure. The

[jira] [Created] (FLINK-6646) YARN session doesn't work with HA

Robert Metzger created FLINK-6646: - Summary: YARN session doesn't work with HA Key: FLINK-6646 URL: https://issues.apache.org/jira/browse/FLINK-6646 Project: Flink Issue Type: Bug C

[jira] [Updated] (FLINK-6643) Flink restarts job in HA even if NoRestartStrategy is set

[ https://issues.apache.org/jira/browse/FLINK-6643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6643: -- Description: While testing Flink 1.3 RC1, I found that the JobManager is trying to recover a jo

[jira] [Updated] (FLINK-6643) Flink restarts job in HA even if NoRestartStrategy is set

[ https://issues.apache.org/jira/browse/FLINK-6643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6643: -- Description: While testing Flink 1.3 RC1, I found that the JobManager is trying to recover a jo

[jira] [Commented] (FLINK-6656) Migrate CEP PriorityQueue to MapState

[ https://issues.apache.org/jira/browse/FLINK-6656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16020795#comment-16020795 ] Robert Metzger commented on FLINK-6656: --- Merged to 1.3 in http://git-wip-us.apache.o

[jira] [Commented] (FLINK-6515) KafkaConsumer checkpointing fails because of ClassLoader issues

[ https://issues.apache.org/jira/browse/FLINK-6515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16021275#comment-16021275 ] Robert Metzger commented on FLINK-6515: --- Are you sure that you've re-build your user

[jira] [Commented] (FLINK-6613) OOM during reading big messages from Kafka

[ https://issues.apache.org/jira/browse/FLINK-6613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16021747#comment-16021747 ] Robert Metzger commented on FLINK-6613: --- There are some options in the Kafka consume

[jira] [Commented] (FLINK-6690) Rescaling broken

[ https://issues.apache.org/jira/browse/FLINK-6690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16022441#comment-16022441 ] Robert Metzger commented on FLINK-6690: --- Cool! Thank you guys for identifying and fi

[jira] [Commented] (FLINK-6692) The flink-dist jar contains unshaded netty jar

[ https://issues.apache.org/jira/browse/FLINK-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16023552#comment-16023552 ] Robert Metzger commented on FLINK-6692: --- Did you check if the classes are present in

[jira] [Comment Edited] (FLINK-6692) The flink-dist jar contains unshaded netty jar

[ https://issues.apache.org/jira/browse/FLINK-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16023552#comment-16023552 ] Robert Metzger edited comment on FLINK-6692 at 5/24/17 7:53 PM:

[jira] [Commented] (FLINK-6692) The flink-dist jar contains unshaded netty jar

[ https://issues.apache.org/jira/browse/FLINK-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16025107#comment-16025107 ] Robert Metzger commented on FLINK-6692: --- Okay "good", so its not a regression due to

[jira] [Updated] (FLINK-6734) Exclude org.apache.flink.api.java.tuple from checkstyle AvoidStarImport

[ https://issues.apache.org/jira/browse/FLINK-6734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6734: -- Component/s: Build System > Exclude org.apache.flink.api.java.tuple from checkstyle AvoidStarImp

[jira] [Updated] (FLINK-6741) In yarn cluster model with high available， the HDFS file is not deleted when cluster is shot down

[ https://issues.apache.org/jira/browse/FLINK-6741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6741: -- Component/s: YARN > In yarn cluster model with high available， the HDFS file is not deleted when

[jira] [Commented] (FLINK-6772) Incorrect ordering of matched state events in Flink CEP

[ https://issues.apache.org/jira/browse/FLINK-6772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16029631#comment-16029631 ] Robert Metzger commented on FLINK-6772: --- I assume we can fix this in Flink 1.3.1 and

[jira] [Updated] (FLINK-6780) ExternalTableSource fails to add the processing time and the event time attribute in the row type

[ https://issues.apache.org/jira/browse/FLINK-6780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6780: -- Component/s: Table API & SQL > ExternalTableSource fails to add the processing time and the even

[jira] [Updated] (FLINK-6680) App & Flink migration guide: updates for the 1.3 release

[ https://issues.apache.org/jira/browse/FLINK-6680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6680: -- Fix Version/s: (was: 1.3.0) 1.4.0 > App & Flink migration guide: updates

[jira] [Updated] (FLINK-6677) API Migration guide: add Table API changes

[ https://issues.apache.org/jira/browse/FLINK-6677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6677: -- Fix Version/s: (was: 1.3.0) 1.4.0 > API Migration guide: add Table API ch

[jira] [Updated] (FLINK-6679) Document HeapStatebackend

[ https://issues.apache.org/jira/browse/FLINK-6679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6679: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Document HeapStatebackend > -

[jira] [Updated] (FLINK-5820) Extend State Backend Abstraction to support Global Cleanup Hooks

[ https://issues.apache.org/jira/browse/FLINK-5820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5820: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Extend State Backend Abstraction to s

[jira] [Updated] (FLINK-6478) Add documentation on how to upgrade serializers for managed state

[ https://issues.apache.org/jira/browse/FLINK-6478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6478: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Add documentation on how to upgrade s

[jira] [Updated] (FLINK-6599) Communicate last committed checkpoint through trigger checkpoint message

[ https://issues.apache.org/jira/browse/FLINK-6599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6599: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Communicate last committed checkpoint

[jira] [Updated] (FLINK-5847) Not able to deploy Flink 1.3-SNAPSHOT on Openshift (Platform as a Service)

[ https://issues.apache.org/jira/browse/FLINK-5847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5847: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Not able to deploy Flink 1.3-SNAPSHOT

[jira] [Updated] (FLINK-5627) Allow job specific externalized checkpoint dir

[ https://issues.apache.org/jira/browse/FLINK-5627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5627: -- Fix Version/s: (was: 1.3.0) 1.4.0 > Allow job specific externalized check

<    5   6   7   8   9   10   11   12   13   14   >