[jira] [Commented] (FLINK-5017) Introduce WatermarkStatus stream element to allow for temporarily idle streaming sources

2016-12-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15714833#comment-15714833 ] Robert Metzger commented on FLINK-5017: --- I'm wondering whether this is really a bloc

[jira] [Updated] (FLINK-5011) TraversableSerializer does not perform a deep copy of the elements it is traversing

2016-12-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5011: -- Component/s: Scala API > TraversableSerializer does not perform a deep copy of the elements it i

[jira] [Commented] (FLINK-5011) TraversableSerializer does not perform a deep copy of the elements it is traversing

2016-12-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15714847#comment-15714847 ] Robert Metzger commented on FLINK-5011: --- Thank you for reporting the issue. We'll lo

[jira] [Commented] (FLINK-4859) Clearly Separate Responsibilities of StreamOperator and StreamTask

2016-12-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15714853#comment-15714853 ] Robert Metzger commented on FLINK-4859: --- I see the value of refactoring this, but I

[jira] [Updated] (FLINK-4632) when yarn nodemanager lost, flink hung

2016-12-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4632: -- Priority: Major (was: Blocker) > when yarn nodemanager lost, flink hung >

[jira] [Commented] (FLINK-4632) when yarn nodemanager lost, flink hung

2016-12-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15714931#comment-15714931 ] Robert Metzger commented on FLINK-4632: --- If its okay for everybody, I'm setting the

[jira] [Commented] (FLINK-4492) Cleanup files from canceled snapshots

2016-12-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715217#comment-15715217 ] Robert Metzger commented on FLINK-4492: --- [~srichter] do you know the status of the i

[jira] [Created] (FLINK-5233) Upgrade Jackson version because of class loader leak

2016-12-02 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5233: - Summary: Upgrade Jackson version because of class loader leak Key: FLINK-5233 URL: https://issues.apache.org/jira/browse/FLINK-5233 Project: Flink Issue Ty

[jira] [Commented] (FLINK-5039) Avro GenericRecord support is broken

2016-12-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721865#comment-15721865 ] Robert Metzger commented on FLINK-5039: --- Thanks a lot for looking into the issue. I

[jira] [Commented] (FLINK-5035) Don't Write TypeSerializer to Heap State Snapshot

2016-12-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15726517#comment-15726517 ] Robert Metzger commented on FLINK-5035: --- What's the status here? > Don't Write Type

[jira] [Commented] (FLINK-5233) Upgrade Jackson version because of class loader leak

2016-12-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15726521#comment-15726521 ] Robert Metzger commented on FLINK-5233: --- I'll put more effort into reproducing it at

[jira] [Commented] (FLINK-5039) Avro GenericRecord support is broken

2016-12-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15726541#comment-15726541 ] Robert Metzger commented on FLINK-5039: --- Just using the Avro serializer doesn't solv

[jira] [Created] (FLINK-5286) Build instability: WordCountSubclassPOJOITCase fails with IOException: Stream Closed

2016-12-08 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5286: - Summary: Build instability: WordCountSubclassPOJOITCase fails with IOException: Stream Closed Key: FLINK-5286 URL: https://issues.apache.org/jira/browse/FLINK-5286

[jira] [Commented] (FLINK-5049) Instability in QueryableStateITCase.testQueryableStateWithTaskManagerFailure

2016-12-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15731886#comment-15731886 ] Robert Metzger commented on FLINK-5049: --- Again: https://api.travis-ci.org/jobs/18200

[jira] [Created] (FLINK-5287) Test randomly fails with wrong result: testWithAtomic2[Execution mode = CLUSTER](org.apache.flink.api.scala.operators.JoinITCase)

2016-12-08 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5287: - Summary: Test randomly fails with wrong result: testWithAtomic2[Execution mode = CLUSTER](org.apache.flink.api.scala.operators.JoinITCase) Key: FLINK-5287 URL: https://issues.a

[jira] [Commented] (FLINK-5147) StreamingOperatorsITCase.testGroupedFoldOperation failed on Travis

2016-12-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15731899#comment-15731899 ] Robert Metzger commented on FLINK-5147: --- This seems a frequent issue ;) https://api

[jira] [Updated] (FLINK-5206) Flakey PythonPlanBinderTest

2016-12-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5206: -- Component/s: Python API > Flakey PythonPlanBinderTest > --- > >

[jira] [Updated] (FLINK-5206) Flakey PythonPlanBinderTest

2016-12-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5206: -- Affects Version/s: 1.2.0 > Flakey PythonPlanBinderTest > --- > >

[jira] [Commented] (FLINK-5206) Flakey PythonPlanBinderTest

2016-12-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15731901#comment-15731901 ] Robert Metzger commented on FLINK-5206: --- I got the same again: https://api.travis-c

[jira] [Updated] (FLINK-5206) Flakey PythonPlanBinderTest

2016-12-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5206: -- Labels: test-stability (was: ) > Flakey PythonPlanBinderTest > --- > >

[jira] [Commented] (FLINK-5297) Relocate Flink's Hadoop dependency and its transitive dependencies

2016-12-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15734938#comment-15734938 ] Robert Metzger commented on FLINK-5297: --- I'm wondering if it would be sufficient for

[jira] [Created] (FLINK-5306) Display checkpointing configuration details in web UI "Configuration" tab

2016-12-09 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5306: - Summary: Display checkpointing configuration details in web UI "Configuration" tab Key: FLINK-5306 URL: https://issues.apache.org/jira/browse/FLINK-5306 Project: Fl

[jira] [Commented] (FLINK-5306) Display checkpointing configuration details in web UI "Configuration" tab

2016-12-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15735078#comment-15735078 ] Robert Metzger commented on FLINK-5306: --- Perfect :) Is this a duplicate then? > Dis

[jira] [Commented] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

2016-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15741452#comment-15741452 ] Robert Metzger commented on FLINK-3398: --- [~aljoscha] You've changed the priority of

[jira] [Resolved] (FLINK-5035) Don't Write TypeSerializer to Heap State Snapshot

2016-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-5035. --- Resolution: Won't Fix Closed issue. Thank you for your responses! > Don't Write TypeSerialize

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

2016-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15741478#comment-15741478 ] Robert Metzger commented on FLINK-5041: --- What's the relationship of this JIRA and FL

[jira] [Commented] (FLINK-4858) Remove Legacy Checkpointing Interfaces

2016-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15742521#comment-15742521 ] Robert Metzger commented on FLINK-4858: --- Are we going to remove the Checkpointing in

[jira] [Updated] (FLINK-4858) Remove Legacy Checkpointing Interfaces

2016-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4858: -- Fix Version/s: (was: 1.2.0) > Remove Legacy Checkpointing Interfaces > -

[jira] [Comment Edited] (FLINK-4858) Remove Legacy Checkpointing Interfaces

2016-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15742647#comment-15742647 ] Robert Metzger edited comment on FLINK-4858 at 12/12/16 6:11 PM: ---

[jira] [Updated] (FLINK-4858) Remove Legacy Checkpointing Interfaces

2016-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4858: -- Component/s: State Backends, Checkpointing > Remove Legacy Checkpointing Interfaces > --

[jira] [Commented] (FLINK-4858) Remove Legacy Checkpointing Interfaces

2016-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15742647#comment-15742647 ] Robert Metzger commented on FLINK-4858: --- Okay, thank you for your input. I'lll remov

[jira] [Created] (FLINK-5326) IllegalStateException: Bug in Netty consumer logic: reader queue got notified by partition about available data, but none was available

2016-12-13 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5326: - Summary: IllegalStateException: Bug in Netty consumer logic: reader queue got notified by partition about available data, but none was available Key: FLINK-5326 URL: https://i

[jira] [Updated] (FLINK-4820) Slf4j / log4j version upgrade to support dynamic change of log levels.

2016-12-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4820: -- Component/s: Build System > Slf4j / log4j version upgrade to support dynamic change of log level

[jira] [Commented] (FLINK-4820) Slf4j / log4j version upgrade to support dynamic change of log levels.

2016-12-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748456#comment-15748456 ] Robert Metzger commented on FLINK-4820: --- Log4j 2 supports dynamic log level changes.

[jira] [Created] (FLINK-5339) Ensure Flink works with Log4j version 2

2016-12-14 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5339: - Summary: Ensure Flink works with Log4j version 2 Key: FLINK-5339 URL: https://issues.apache.org/jira/browse/FLINK-5339 Project: Flink Issue Type: Improveme

[jira] [Resolved] (FLINK-4429) Move Redis Sink from Flink to Bahir

2016-12-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4429. --- Resolution: Fixed Fix Version/s: 1.2.0 Redis is now in Bahir, so I deleted it from Flin

[jira] [Resolved] (FLINK-4446) Move Flume Sink from Flink to Bahir

2016-12-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4446. --- Resolution: Fixed Fix Version/s: 1.2.0 Resolved for Flink in http://git-wip-us.apache.

[jira] [Updated] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

2016-12-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3398: -- Priority: Critical (was: Blocker) > Flink Kafka consumer should support auto-commit opt-outs >

[jira] [Created] (FLINK-5345) IOManager failed to properly clean up temp file directory

2016-12-15 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5345: - Summary: IOManager failed to properly clean up temp file directory Key: FLINK-5345 URL: https://issues.apache.org/jira/browse/FLINK-5345 Project: Flink Iss

[jira] [Commented] (FLINK-4631) NullPointerException during stream task cleanup

2016-12-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751655#comment-15751655 ] Robert Metzger commented on FLINK-4631: --- The issue persists for Flink 1.1.4 RC3 > N

[jira] [Created] (FLINK-5356) librocksdbjni*.so is not deleted from /tmp directory

2016-12-16 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5356: - Summary: librocksdbjni*.so is not deleted from /tmp directory Key: FLINK-5356 URL: https://issues.apache.org/jira/browse/FLINK-5356 Project: Flink Issue Ty

[jira] [Commented] (FLINK-5356) librocksdbjni*.so is not deleted from /tmp directory

2016-12-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15754996#comment-15754996 ] Robert Metzger commented on FLINK-5356: --- No, I would not backport it. If its fixed i

[jira] [Resolved] (FLINK-5356) librocksdbjni*.so is not deleted from /tmp directory

2016-12-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-5356. --- Resolution: Invalid Fix Version/s: 1.2.0 > librocksdbjni*.so is not deleted from /tmp d

[jira] [Commented] (FLINK-3150) Make YARN container invocation configurable

2016-12-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15761074#comment-15761074 ] Robert Metzger commented on FLINK-3150: --- I ran into this issue again. I'll try to op

[jira] [Updated] (FLINK-3150) Make YARN container invocation configurable

2016-12-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3150: -- Labels: qa (was: ) > Make YARN container invocation configurable >

[jira] [Commented] (FLINK-5353) Elasticsearch Sink loses well-formed documents when there are malformed documents

2016-12-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15761442#comment-15761442 ] Robert Metzger commented on FLINK-5353: --- Do you have any information why ES is loosi

[jira] [Commented] (FLINK-5353) Elasticsearch Sink loses well-formed documents when there are malformed documents

2016-12-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15761537#comment-15761537 ] Robert Metzger commented on FLINK-5353: --- Okay, I will do some experiments to see wha

[jira] [Created] (FLINK-5379) Flink CliFrontend does not return when not logged in with kerberos

2016-12-21 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5379: - Summary: Flink CliFrontend does not return when not logged in with kerberos Key: FLINK-5379 URL: https://issues.apache.org/jira/browse/FLINK-5379 Project: Flink

[jira] [Updated] (FLINK-5379) Flink CliFrontend does not return when not logged in with kerberos

2016-12-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5379: -- Description: In pre 1.2 versions, Flink immediately fails when trying to deploy it on YARN and

[jira] [Created] (FLINK-5380) Number of outgoing records not reported in web interface

2016-12-21 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5380: - Summary: Number of outgoing records not reported in web interface Key: FLINK-5380 URL: https://issues.apache.org/jira/browse/FLINK-5380 Project: Flink Issu

[jira] [Updated] (FLINK-5380) Number of outgoing records not reported in web interface

2016-12-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5380: -- Attachment: outRecordsNotreported.png > Number of outgoing records not reported in web interface

[jira] [Created] (FLINK-5381) Scrolling in some web interface pages doesn't work (taskmanager details, jobmanager config)

2016-12-21 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5381: - Summary: Scrolling in some web interface pages doesn't work (taskmanager details, jobmanager config) Key: FLINK-5381 URL: https://issues.apache.org/jira/browse/FLINK-5381

[jira] [Created] (FLINK-5382) Taskmanager log download button causes 404

2016-12-21 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5382: - Summary: Taskmanager log download button causes 404 Key: FLINK-5382 URL: https://issues.apache.org/jira/browse/FLINK-5382 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5383) TaskManager fails with SIGBUS when loading RocksDB

2016-12-21 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5383: - Summary: TaskManager fails with SIGBUS when loading RocksDB Key: FLINK-5383 URL: https://issues.apache.org/jira/browse/FLINK-5383 Project: Flink Issue Type

[jira] [Commented] (FLINK-5382) Taskmanager log download button causes 404

2016-12-26 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15778843#comment-15778843 ] Robert Metzger commented on FLINK-5382: --- Did you use Flink on YARN to reproduce the

[jira] [Resolved] (FLINK-4861) Package optional project artifacts

2017-01-03 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4861. --- Resolution: Fixed Resolved in https://github.com/apache/flink/commit/5c76baa1734303a01472afd1

[jira] [Updated] (FLINK-4391) Provide support for asynchronous operations over streams

2017-01-03 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4391: -- Fix Version/s: 1.2.0 > Provide support for asynchronous operations over streams > --

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

2017-01-03 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15794719#comment-15794719 ] Robert Metzger commented on FLINK-4391: --- I could not find any documentation in f5283

[jira] [Updated] (FLINK-5264) Improve error message when assigning uid to intermediate operator

2017-01-03 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5264: -- Component/s: Java API > Improve error message when assigning uid to intermediate operator >

[jira] [Commented] (FLINK-3710) ScalaDocs for org.apache.flink.streaming.scala are missing from the web site

2017-01-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15798948#comment-15798948 ] Robert Metzger commented on FLINK-3710: --- I agree that the current situation is not a

[jira] [Commented] (FLINK-3710) ScalaDocs for org.apache.flink.streaming.scala are missing from the web site

2017-01-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15798959#comment-15798959 ] Robert Metzger commented on FLINK-3710: --- I removed the links in this commit: http:/

[jira] [Resolved] (FLINK-5382) Taskmanager log download button causes 404

2017-01-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-5382. --- Resolution: Fixed Fix Version/s: 1.3.0 1.2.0 Resolved for 1.3 (maste

[jira] [Resolved] (FLINK-5383) TaskManager fails with SIGBUS when loading RocksDB

2017-01-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-5383. --- Resolution: Fixed Assignee: Stephan Ewen Fix Version/s: 1.3.0 > TaskManager fa

[jira] [Commented] (FLINK-5383) TaskManager fails with SIGBUS when loading RocksDB

2017-01-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15811424#comment-15811424 ] Robert Metzger commented on FLINK-5383: --- I can confirm that the mentioned commit is

[jira] [Commented] (FLINK-4973) Flakey Yarn tests due to recently added latency marker

2017-01-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15814982#comment-15814982 ] Robert Metzger commented on FLINK-4973: --- Any objections for logging only the excepti

[jira] [Commented] (FLINK-5297) Relocate Flink's Hadoop dependency and its transitive dependencies

2017-01-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15815050#comment-15815050 ] Robert Metzger commented on FLINK-5297: --- I've created a branch that shades ALL hadoo

[jira] [Commented] (FLINK-4973) Flakey Yarn tests due to recently added latency marker

2017-01-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15815053#comment-15815053 ] Robert Metzger commented on FLINK-4973: --- The stack trace is only logged in the Laten

[jira] [Created] (FLINK-5450) WindowOperator logs about "re-registering state from an older Flink version" even though its not a restored window

2017-01-11 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5450: - Summary: WindowOperator logs about "re-registering state from an older Flink version" even though its not a restored window Key: FLINK-5450 URL: https://issues.apache.org/jira/b

[jira] [Commented] (FLINK-4973) Flakey Yarn tests due to recently added latency marker

2017-01-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15819056#comment-15819056 ] Robert Metzger commented on FLINK-4973: --- {code} 2017-01-10 04:59:22,578 INFO org.ap

[jira] [Created] (FLINK-5462) Flink job fails due to java.util.concurrent.CancellationException while snapshotting

2017-01-11 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5462: - Summary: Flink job fails due to java.util.concurrent.CancellationException while snapshotting Key: FLINK-5462 URL: https://issues.apache.org/jira/browse/FLINK-5462

[jira] [Created] (FLINK-5463) RocksDB.disposeInternal does not react to interrupts, blocks task cancellation

2017-01-11 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5463: - Summary: RocksDB.disposeInternal does not react to interrupts, blocks task cancellation Key: FLINK-5463 URL: https://issues.apache.org/jira/browse/FLINK-5463 Projec

[jira] [Created] (FLINK-5464) MetricQueryService throws NullPointerException on JobManager

2017-01-11 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5464: - Summary: MetricQueryService throws NullPointerException on JobManager Key: FLINK-5464 URL: https://issues.apache.org/jira/browse/FLINK-5464 Project: Flink

[jira] [Created] (FLINK-5465) RocksDB fails with segfault while calling AbstractRocksDBState.clear()

2017-01-11 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5465: - Summary: RocksDB fails with segfault while calling AbstractRocksDBState.clear() Key: FLINK-5465 URL: https://issues.apache.org/jira/browse/FLINK-5465 Project: Flink

[jira] [Updated] (FLINK-5465) RocksDB fails with segfault while calling AbstractRocksDBState.clear()

2017-01-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5465: -- Attachment: hs-err-pid26662.log I've attached the error report file, containing the stack trace

[jira] [Commented] (FLINK-3158) Shading does not remove google guava from flink-dist fat jar

2015-12-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15050615#comment-15050615 ] Robert Metzger commented on FLINK-3158: --- There is a check in our travis build to ens

[jira] [Created] (FLINK-3159) YARN AM should shutdown itself after a the job for which the AM was started has finished

2015-12-10 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3159: - Summary: YARN AM should shutdown itself after a the job for which the AM was started has finished Key: FLINK-3159 URL: https://issues.apache.org/jira/browse/FLINK-3159

[jira] [Resolved] (FLINK-3156) FlinkKafkaConsumer fails with NPE on notifyCheckpointComplete

2015-12-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3156. --- Resolution: Fixed Fix Version/s: 1.0.0 Fixed for 1.0 in http://git-wip-us.apache.org/re

[jira] [Commented] (FLINK-3121) Watermark forwarding does not work for sources not producing any data

2015-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15054424#comment-15054424 ] Robert Metzger commented on FLINK-3121: --- Just for clarification: Your fix resolves t

[jira] [Reopened] (FLINK-3067) Kafka source fails during checkpoint notifications with NPE

2015-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-3067: --- The issue is still not resolved. Next approach: We update ZK using Apache Curator. > Kafka sourc

[jira] [Resolved] (FLINK-3023) Show Flink version + commit id for -SNAPSHOT versions in web frontend

2015-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3023. --- Resolution: Fixed Fix Version/s: 1.0.0 Resolved in master: http://git-wip-us.apache.org

[jira] [Resolved] (FLINK-3077) Add "version" command to CliFrontend for showing the version of the installation

2015-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3077. --- Resolution: Fixed Resolved for 1.0.0 in http://git-wip-us.apache.org/repos/asf/flink/commit/6

[jira] [Updated] (FLINK-3123) Allow setting custom start-offsets for the Kafka consumer

2015-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3123: -- Assignee: (was: Robert Metzger) > Allow setting custom start-offsets for the Kafka consumer

[jira] [Commented] (FLINK-3003) Add container allocation timeout to YARN CLI

2015-12-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15055746#comment-15055746 ] Robert Metzger commented on FLINK-3003: --- Gang scheduling support in YARN would be th

[jira] [Commented] (FLINK-3170) Expose task manager metrics via JMX

2015-12-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15056336#comment-15056336 ] Robert Metzger commented on FLINK-3170: --- How about using the https://github.com/drop

[jira] [Commented] (FLINK-3168) Make checkpointing properties configurable from flink-conf.yaml

2015-12-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058054#comment-15058054 ] Robert Metzger commented on FLINK-3168: --- As a workaround for now, you could use the

[jira] [Commented] (FLINK-3188) Deletes in Kafka source should be passed on to KeyedDeserializationSchema

2015-12-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15066567#comment-15066567 ] Robert Metzger commented on FLINK-3188: --- Thank you for providing a patch for the iss

[jira] [Assigned] (FLINK-3188) Deletes in Kafka source should be passed on to KeyedDeserializationSchema

2015-12-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-3188: - Assignee: Robert Metzger > Deletes in Kafka source should be passed on to KeyedDeserializ

[jira] [Commented] (FLINK-3188) Deletes in Kafka source should be passed on to KeyedDeserializationSchema

2016-01-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15081011#comment-15081011 ] Robert Metzger commented on FLINK-3188: --- Thank you for providing a test case. I'll o

[jira] [Commented] (FLINK-3188) Deletes in Kafka source should be passed on to KeyedDeserializationSchema

2016-01-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15081172#comment-15081172 ] Robert Metzger commented on FLINK-3188: --- I've now opened a pull request from your ch

[jira] [Commented] (FLINK-3090) Create a Parcel Distribution for Cloudera Manager

2016-01-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15081570#comment-15081570 ] Robert Metzger commented on FLINK-3090: --- There seems to be more interest in this: h

[jira] [Resolved] (FLINK-3188) Deletes in Kafka source should be passed on to KeyedDeserializationSchema

2016-01-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3188. --- Resolution: Fixed Fix Version/s: 1.0.0 Resolved for 1.0.0 in http://git-wip-us.apache.

[jira] [Created] (FLINK-3204) TaskManagers are not shutting down properly on YARN

2016-01-06 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3204: - Summary: TaskManagers are not shutting down properly on YARN Key: FLINK-3204 URL: https://issues.apache.org/jira/browse/FLINK-3204 Project: Flink Issue Typ

[jira] [Created] (FLINK-3205) Remove the flink-staging module

2016-01-06 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3205: - Summary: Remove the flink-staging module Key: FLINK-3205 URL: https://issues.apache.org/jira/browse/FLINK-3205 Project: Flink Issue Type: Task Co

[jira] [Updated] (FLINK-2833) Unstage Gelly and Module refactoring

2016-01-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2833: -- Issue Type: Sub-task (was: Task) Parent: FLINK-3205 > Unstage Gelly and Module refactor

[jira] [Updated] (FLINK-2877) Move Streaming API out of Staging

2016-01-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2877: -- Issue Type: Sub-task (was: Improvement) Parent: FLINK-3205 > Move Streaming API out of

[jira] [Updated] (FLINK-2877) Move Streaming API out of Staging

2016-01-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2877: -- Parent Issue: FLINK-1712 (was: FLINK-3205) > Move Streaming API out of Staging > --

[jira] [Updated] (FLINK-2833) Unstage Gelly and Module refactoring

2016-01-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2833: -- Parent Issue: FLINK-1712 (was: FLINK-3205) > Unstage Gelly and Module refactoring > ---

[jira] [Closed] (FLINK-3205) Remove the flink-staging module

2016-01-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-3205. - Resolution: Duplicate Fix Version/s: (was: 1.0.0) Duplicate of FLINK-1712 > Remove the

[jira] [Commented] (FLINK-3093) Introduce annotations for interface stability

2016-01-07 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15087541#comment-15087541 ] Robert Metzger commented on FLINK-3093: --- Annotations for flink-core have been merged

[jira] [Commented] (FLINK-3210) Unnecessary call to deserializer#deserialize() in LegacyFetcher#SimpleConsumerThread#run()

2016-01-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15089566#comment-15089566 ] Robert Metzger commented on FLINK-3210: --- I think this issue is invalid. A null value

<    3   4   5   6   7   8   9   10   11   12   >