[jira] [Commented] (FLINK-7067) Cancel with savepoint does not restart checkpoint scheduler on failure

2017-10-19 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16210839#comment-16210839 ] Ufuk Celebi commented on FLINK-7067: Hey Till, I think the fix is done from my side. The open question

[jira] [Commented] (FLINK-7722) MiniCluster does not appear to honor Log4j settings

2017-09-27 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16183221#comment-16183221 ] Ufuk Celebi commented on FLINK-7722: I think this is the output of the client that is actually

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

2017-09-24 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-7677. -- > Add side outputs to ProcessWindowFunction > - > >

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

2017-09-23 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-7677: -- Summary: Add side outputs to ProcessWindowFunction Key: FLINK-7677 URL: https://issues.apache.org/jira/browse/FLINK-7677 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7676) ContinuousFileMonitoringFunction fails with GoogleHadoopFileSystem

2017-09-23 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-7676: -- Summary: ContinuousFileMonitoringFunction fails with GoogleHadoopFileSystem Key: FLINK-7676 URL: https://issues.apache.org/jira/browse/FLINK-7676 Project: Flink

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

2017-09-23 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-7674: -- Summary: NullPointerException in ContinuousFileMonitoringFunction close Key: FLINK-7674 URL: https://issues.apache.org/jira/browse/FLINK-7674 Project: Flink

[jira] [Created] (FLINK-7666) ContinuousFileReaderOperator swallows chained watermarks

2017-09-21 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-7666: -- Summary: ContinuousFileReaderOperator swallows chained watermarks Key: FLINK-7666 URL: https://issues.apache.org/jira/browse/FLINK-7666 Project: Flink Issue

[jira] [Created] (FLINK-7665) Use wait/notify in ContinuousFileReaderOperator

2017-09-21 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-7665: -- Summary: Use wait/notify in ContinuousFileReaderOperator Key: FLINK-7665 URL: https://issues.apache.org/jira/browse/FLINK-7665 Project: Flink Issue Type:

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

2017-09-19 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-7643: -- Summary: HadoopFileSystem always reloads GlobalConfiguration Key: FLINK-7643 URL: https://issues.apache.org/jira/browse/FLINK-7643 Project: Flink Issue Type:

[jira] [Updated] (FLINK-7595) Removing stateless task from task chain breaks savepoint restore

2017-09-06 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-7595: --- Attachment: ChainedTaskRemoveTest.java I've attached a test that produces the problem (if I'm correct

[jira] [Created] (FLINK-7595) Removing stateless task from task chain breaks savepoint restore

2017-09-06 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-7595: -- Summary: Removing stateless task from task chain breaks savepoint restore Key: FLINK-7595 URL: https://issues.apache.org/jira/browse/FLINK-7595 Project: Flink

[jira] [Assigned] (FLINK-7575) Dashboard jobs/tasks metrics display 0 when metrics are not yet available

2017-09-04 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-7575: -- Assignee: James Lafa > Dashboard jobs/tasks metrics display 0 when metrics are not yet

[jira] [Created] (FLINK-7462) Add very obvious warning about outdated docs

2017-08-16 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-7462: -- Summary: Add very obvious warning about outdated docs Key: FLINK-7462 URL: https://issues.apache.org/jira/browse/FLINK-7462 Project: Flink Issue Type:

[jira] [Commented] (FLINK-3785) Add REST resource to query information about checkpointing

2017-08-11 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123515#comment-16123515 ] Ufuk Celebi commented on FLINK-3785: It is possible but not documented as part of the rest API. We

[jira] [Commented] (FLINK-7409) WebRuntimeMonitor blocks serving threads

2017-08-11 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123101#comment-16123101 ] Ufuk Celebi commented on FLINK-7409: Thanks! I think it's really nice that you fixed this in your PR

[jira] [Commented] (FLINK-7409) WebRuntimeMonitor blocks serving threads

2017-08-11 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16123037#comment-16123037 ] Ufuk Celebi commented on FLINK-7409: I brought this issue up a while back too (in FLINK-3182). If we

[jira] [Commented] (FLINK-7296) Validate commit messages in git pre-receive hook

2017-07-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16105155#comment-16105155 ] Ufuk Celebi commented on FLINK-7296: Thanks for looking into this. We should also allow messages like

[jira] [Closed] (FLINK-7258) IllegalArgumentException in Netty bootstrap with large memory state segment size

2017-07-25 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-7258. -- Resolution: Fixed Fix Version/s: 1.3.2 1.4.0 Fixed in 96ccffd (release-1.3),

[jira] [Updated] (FLINK-7258) IllegalArgumentException in Netty bootstrap with large memory state segment size

2017-07-24 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-7258: --- Priority: Minor (was: Major) > IllegalArgumentException in Netty bootstrap with large memory state

[jira] [Updated] (FLINK-7258) IllegalArgumentException in Netty bootstrap with large memory state segment size

2017-07-24 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-7258: --- Description: In NettyBootstrap we configure the low and high watermarks in the following order:

[jira] [Created] (FLINK-7258) IllegalArgumentException in Netty bootstrap with large memory state segment size

2017-07-24 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-7258: -- Summary: IllegalArgumentException in Netty bootstrap with large memory state segment size Key: FLINK-7258 URL: https://issues.apache.org/jira/browse/FLINK-7258 Project:

[jira] [Commented] (FLINK-7067) Cancel with savepoint does not restart checkpoint scheduler on failure

2017-07-21 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16096109#comment-16096109 ] Ufuk Celebi commented on FLINK-7067: I agree with Stephan's opinion. That's why I also have the test

[jira] [Updated] (FLINK-7127) Remove unnecessary null check or add null check

2017-07-07 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-7127: --- Priority: Trivial (was: Major) > Remove unnecessary null check or add null check >

[jira] [Updated] (FLINK-7127) Remove unnecessary null check or add null check

2017-07-07 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-7127: --- Labels: starter (was: ) > Remove unnecessary null check or add null check >

[jira] [Created] (FLINK-7127) Remove unnecessary null check or add null check

2017-07-07 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-7127: -- Summary: Remove unnecessary null check or add null check Key: FLINK-7127 URL: https://issues.apache.org/jira/browse/FLINK-7127 Project: Flink Issue Type:

[jira] [Commented] (FLINK-4371) Add ability to take savepoints from job manager RESTful API

2017-07-04 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16073630#comment-16073630 ] Ufuk Celebi commented on FLINK-4371: Hey [~zhenzhongxu], would you mind if I assign this issue to

[jira] [Closed] (FLINK-7032) Intellij is constantly changing language level of sub projects back to 1.6

2017-07-04 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-7032. -- Resolution: Fixed Fix Version/s: 1.3.2 1.4.0 Fixed in 5f4296e (release-1.3),

[jira] [Created] (FLINK-7067) Cancel with savepoint does not restart checkpoint scheduler on failure

2017-07-03 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-7067: -- Summary: Cancel with savepoint does not restart checkpoint scheduler on failure Key: FLINK-7067 URL: https://issues.apache.org/jira/browse/FLINK-7067 Project: Flink

[jira] [Closed] (FLINK-6952) Add link to Javadocs

2017-06-22 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-6952. -- Resolution: Fixed Fix Version/s: 1.4.0 1.3.1 1.2.2 Fixed

[jira] [Closed] (FLINK-6985) Remove bugfix version from docs title

2017-06-22 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-6985. -- Resolution: Fixed Fix Version/s: 1.2.0 1.3.0 1.4.0 Fixed

[jira] [Updated] (FLINK-6985) Remove bugfix version from docs title

2017-06-22 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-6985: --- Summary: Remove bugfix version from docs title (was: Remove minor version from docs title) > Remove

[jira] [Created] (FLINK-6985) Remove minor version from docs title

2017-06-22 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-6985: -- Summary: Remove minor version from docs title Key: FLINK-6985 URL: https://issues.apache.org/jira/browse/FLINK-6985 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-6952) Add link to Javadocs

2017-06-20 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-6952: -- Summary: Add link to Javadocs Key: FLINK-6952 URL: https://issues.apache.org/jira/browse/FLINK-6952 Project: Flink Issue Type: Improvement Components:

[jira] [Closed] (FLINK-5777) Pass savepoint information to CheckpointingOperation

2017-05-15 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5777. -- Resolution: Fixed Fix Version/s: 1.3.0 Fixed in 6e7a91741708a2b167a2bbca5dda5b2059df5e18. >

[jira] [Commented] (FLINK-5778) Split FileStateHandle into fileName and basePath

2017-05-08 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16000443#comment-16000443 ] Ufuk Celebi commented on FLINK-5778: No, I don't think so. I was waiting for FLINK-5823

[jira] [Commented] (FLINK-5440) Misleading error message when migrating and scaling down from savepoint

2017-05-05 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15998371#comment-15998371 ] Ufuk Celebi commented on FLINK-5440: Unfortunately, I haven't followed the most recent development in

[jira] [Commented] (FLINK-5439) Adjust max parallelism when migrating

2017-05-05 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15998369#comment-15998369 ] Ufuk Celebi commented on FLINK-5439: Unfortunately, I haven't followed the most recent development in

[jira] [Closed] (FLINK-6337) Remove the buffer provider from PartitionRequestServerHandler

2017-05-02 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-6337. -- Resolution: Fixed Fix Version/s: 1.3.0 Fixed in 464d6f5 (master). > Remove the buffer provider

[jira] [Commented] (FLINK-5125) ContinuousFileProcessingCheckpointITCase is Flaky

2017-05-02 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15992746#comment-15992746 ] Ufuk Celebi commented on FLINK-5125: https://api.travis-ci.org/jobs/227891378/log.txt?deansi=true >

[jira] [Commented] (FLINK-4052) Unstable test ConnectionUtilsTest

2017-05-02 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15992741#comment-15992741 ] Ufuk Celebi commented on FLINK-4052: Happened again here:

[jira] [Commented] (FLINK-6337) Remove the buffer provider from PartitionRequestServerHandler

2017-04-25 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982936#comment-15982936 ] Ufuk Celebi commented on FLINK-6337: Just double checked this and I think you are right. We currently

[jira] [Commented] (FLINK-6337) Remove the buffer provider from PartitionRequestServerHandler

2017-04-25 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982545#comment-15982545 ] Ufuk Celebi commented on FLINK-6337: Hey [~zjwang]! I think the buffer pool is required for spillable

[jira] [Closed] (FLINK-3031) Consistent Shutdown of Streaming Jobs

2017-04-03 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-3031. -- Resolution: Invalid Yes > Consistent Shutdown of Streaming Jobs >

[jira] [Closed] (FLINK-6194) More broken links in docs

2017-03-27 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-6194. -- Resolution: Fixed Fix Version/s: 1.3.0 Merged in 037b5cb (master). > More broken links in docs

[jira] [Closed] (FLINK-6182) Fix possible NPE in SourceStreamTask

2017-03-24 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-6182. -- Resolution: Fixed Fix Version/s: 1.2.1 1.3.0 Fixed in b703a24 (release-1.2),

[jira] [Created] (FLINK-6182) Fix possible NPE in SourceStreamTask

2017-03-24 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-6182: -- Summary: Fix possible NPE in SourceStreamTask Key: FLINK-6182 URL: https://issues.apache.org/jira/browse/FLINK-6182 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6175) HistoryServerTest.testFullArchiveLifecycle fails

2017-03-23 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-6175: -- Summary: HistoryServerTest.testFullArchiveLifecycle fails Key: FLINK-6175 URL: https://issues.apache.org/jira/browse/FLINK-6175 Project: Flink Issue Type: Test

[jira] [Closed] (FLINK-6170) Some checkpoint metrics rely on latest stat snapshot

2017-03-22 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-6170. -- Resolution: Fixed Fix Version/s: 1.2.1 1.3.0 Fixed in d0695c0 (master),

[jira] [Closed] (FLINK-6171) Some checkpoint metrics rely on latest stat snapshot

2017-03-22 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-6171. -- Resolution: Duplicate > Some checkpoint metrics rely on latest stat snapshot >

[jira] [Assigned] (FLINK-6170) Some checkpoint metrics rely on latest stat snapshot

2017-03-22 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-6170: -- Assignee: Ufuk Celebi > Some checkpoint metrics rely on latest stat snapshot >

[jira] [Created] (FLINK-6171) Some checkpoint metrics rely on latest stat snapshot

2017-03-22 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-6171: -- Summary: Some checkpoint metrics rely on latest stat snapshot Key: FLINK-6171 URL: https://issues.apache.org/jira/browse/FLINK-6171 Project: Flink Issue Type:

[jira] [Created] (FLINK-6170) Some checkpoint metrics rely on latest stat snapshot

2017-03-22 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-6170: -- Summary: Some checkpoint metrics rely on latest stat snapshot Key: FLINK-6170 URL: https://issues.apache.org/jira/browse/FLINK-6170 Project: Flink Issue Type:

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

2017-03-22 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15936454#comment-15936454 ] Ufuk Celebi commented on FLINK-6167: I think we should wait to see whether the FileSystem based

[jira] [Created] (FLINK-6127) Add MissingDeprecatedCheck to checkstyle

2017-03-20 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-6127: -- Summary: Add MissingDeprecatedCheck to checkstyle Key: FLINK-6127 URL: https://issues.apache.org/jira/browse/FLINK-6127 Project: Flink Issue Type: Improvement

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

2017-03-20 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-6122. -- Resolution: Implemented Fix Version/s: (was: 1.2.1) Implemented in 486f724 (master). > add

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

2017-03-15 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5635. -- Resolution: Fixed Fix Version/s: 1.3.0 Fixed in 227478b, a3627f2 (master). > Improve Docker

[jira] [Commented] (FLINK-5985) Flink treats every task as stateful (making topology changes impossible)

2017-03-10 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904869#comment-15904869 ] Ufuk Celebi commented on FLINK-5985: Thanks again for reporting this. You are right, we accidentally

[jira] [Commented] (FLINK-5985) Flink treats every task as stateful (making topology changes impossible)

2017-03-10 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904779#comment-15904779 ] Ufuk Celebi commented on FLINK-5985: Thanks for taking the time to create the example, Gyula. > Flink

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

2017-03-09 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-6002. -- Resolution: Fixed Fix Version/s: 1.3.0 Fixed in 2a32af8 (1.2), 8d92f86 (master). >

[jira] [Commented] (FLINK-5985) Flink treats every task as stateful (making topology changes impossible)

2017-03-08 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901356#comment-15901356 ] Ufuk Celebi commented on FLINK-5985: Is it possible to share the driver program (privately works as

[jira] [Created] (FLINK-5999) MiniClusterITCase.runJobWithMultipleRpcServices fails

2017-03-08 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5999: -- Summary: MiniClusterITCase.runJobWithMultipleRpcServices fails Key: FLINK-5999 URL: https://issues.apache.org/jira/browse/FLINK-5999 Project: Flink Issue Type:

[jira] [Commented] (FLINK-5999) MiniClusterITCase.runJobWithMultipleRpcServices fails

2017-03-08 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901330#comment-15901330 ] Ufuk Celebi commented on FLINK-5999:

[jira] [Commented] (FLINK-5780) Extend ConfigOption with descriptions

2017-03-08 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901053#comment-15901053 ] Ufuk Celebi commented on FLINK-5780: [~dawidwys] Thanks for picking this up. > Extend ConfigOption

[jira] [Commented] (FLINK-5985) Flink treats every task as stateful (making topology changes impossible)

2017-03-08 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901040#comment-15901040 ] Ufuk Celebi commented on FLINK-5985: I fully agree that this whole UID business is very tricky and

[jira] [Commented] (FLINK-5996) Jobmanager HA should not crash on lost ZK node

2017-03-08 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901032#comment-15901032 ] Ufuk Celebi commented on FLINK-5996: Just to understand this correctly, eventually the JM recovers

[jira] [Created] (FLINK-5993) Add section about Azure deployment

2017-03-08 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5993: -- Summary: Add section about Azure deployment Key: FLINK-5993 URL: https://issues.apache.org/jira/browse/FLINK-5993 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-5985) Flink treats every task as stateful (making topology changes impossible)

2017-03-08 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900973#comment-15900973 ] Ufuk Celebi commented on FLINK-5985: It should be possible to change the topology if you set the UIDs

[jira] [Closed] (FLINK-5965) Typo on DropWizard wrappers

2017-03-06 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5965. -- Resolution: Fixed Fix Version/s: 1.2.1 1.3.0 Fixed in 32a55a2 (release-1.2),

[jira] [Closed] (FLINK-5402) Fails AkkaRpcServiceTest#testTerminationFuture

2017-03-01 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5402. -- Resolution: Fixed Fix Version/s: 1.3.0 Fixed in 72f18dc (master). > Fails

[jira] [Closed] (FLINK-5389) Fails #testAnswerFailureWhenSavepointReadFails

2017-03-01 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5389. -- Resolution: Fixed Fix Version/s: 1.3.0 Fixed in b59c14e (master). > Fails

[jira] [Closed] (FLINK-2573) Add Kerberos test case

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-2573. -- Resolution: Fixed All sub issues are resolved > Add Kerberos test case > -- > >

[jira] [Closed] (FLINK-4634) TaskStopTest.testStopExecution() times out

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4634. -- Resolution: Cannot Reproduce > TaskStopTest.testStopExecution() times out >

[jira] [Commented] (FLINK-3704) JobManagerHAProcessFailureBatchRecoveryITCase.testJobManagerProcessFailure unstable

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15888456#comment-15888456 ] Ufuk Celebi commented on FLINK-3704: [~dernasherbrezon] No, I think it is as Till says an issue with

[jira] [Closed] (FLINK-3812) Kafka09ITCase testAllDeletes fails on Travis

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-3812. -- Resolution: Cannot Reproduce > Kafka09ITCase testAllDeletes fails on Travis >

[jira] [Closed] (FLINK-4071) JobManagerHAJobGraphRecoveryITCase.testJobManagerCleanUp failed on Travis

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4071. -- Resolution: Cannot Reproduce I think this has been fixed with the introduction of the SUSPENDED state.

[jira] [Commented] (FLINK-3990) ZooKeeperLeaderElectionTest kills the JVM

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15888414#comment-15888414 ] Ufuk Celebi commented on FLINK-3990: This seems to be unrelated to the mentioned tests. I think we can

[jira] [Commented] (FLINK-5389) Fails #testAnswerFailureWhenSavepointReadFails

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15888400#comment-15888400 ] Ufuk Celebi commented on FLINK-5389: I would increase the timeout here and in FLINK-5402. > Fails

[jira] [Closed] (FLINK-4060) WebRuntimeMonitorITCase.testStandaloneWebRuntimeMonitor failed on Travis

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4060. -- Resolution: Cannot Reproduce > WebRuntimeMonitorITCase.testStandaloneWebRuntimeMonitor failed on Travis

[jira] [Commented] (FLINK-5125) ContinuousFileProcessingCheckpointITCase is Flaky

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15888387#comment-15888387 ] Ufuk Celebi commented on FLINK-5125: Any progress on this [~kkl0u]]? >

[jira] [Closed] (FLINK-3212) JobManagerCheckpointRecoveryITCase

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-3212. -- Resolution: Cannot Reproduce > JobManagerCheckpointRecoveryITCase > --

[jira] [Closed] (FLINK-4153) ExecutionGraphRestartTest Fails

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4153. -- Resolution: Cannot Reproduce Respective test code changed since this issue was created and it was not

[jira] [Closed] (FLINK-4995) YarnFlinkResourceManagerTest JobManager Lost Leadership test failed

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4995. -- Resolution: Cannot Reproduce Test removed > YarnFlinkResourceManagerTest JobManager Lost Leadership

[jira] [Closed] (FLINK-3571) SavepointITCase.testRestoreFailure fails on Travis

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-3571. -- Resolution: Cannot Reproduce Savepoint code changed quite a bit since this issue was created. I've not

[jira] [Closed] (FLINK-4397) Unstable test SlotCountExceedingParallelismTest.tearDown

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4397. -- Resolution: Cannot Reproduce > Unstable test SlotCountExceedingParallelismTest.tearDown >

[jira] [Closed] (FLINK-3331) Test instability: LocalFlinkMiniClusterITCase.testLocalFlinkMiniClusterWithMultipleTaskManagers

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-3331. -- Resolution: Cannot Reproduce Did not occur again and a lot of time passed since the original report. I

[jira] [Closed] (FLINK-3214) WindowCheckpointingITCase

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-3214. -- Resolution: Cannot Reproduce Did not occur again and a lot of time passed since the original report. I

[jira] [Closed] (FLINK-3238) EventTimeAllWindowCheckpointingITCase.testSlidingTimeWindow()

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-3238. -- Resolution: Cannot Reproduce Did not occur again and a lot of time passed since the original report. I

[jira] [Closed] (FLINK-3344) EventTimeWindowCheckpointingITCase.testPreAggregatedTumblingTimeWindow

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-3344. -- Resolution: Cannot Reproduce Did not occur again and a lot of time passed since the original report. I

[jira] [Closed] (FLINK-3356) JobClientActorRecoveryITCase.testJobClientRecovery

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-3356. -- Resolution: Cannot Reproduce Did not occur again and a lot of time passed since the original report. I

[jira] [Closed] (FLINK-3199) KafkaITCase.testOneToOneSources

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-3199. -- Resolution: Cannot Reproduce Did not occur again and a lot of time passed since the original report

[jira] [Closed] (FLINK-3142) CheckpointCoordinatorTest fails

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-3142. -- Resolution: Cannot Reproduce Did not occur again and a lot of time passed since the original report. I

[jira] [Closed] (FLINK-3053) SuccessAfterNetworkBuffersFailureITCase.testSuccessfulProgramAfterFailure

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-3053. -- Resolution: Cannot Reproduce Did not occur again and a lot of time passed since the original report. I

[jira] [Closed] (FLINK-3095) Test ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement unstable

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-3095. -- Resolution: Cannot Reproduce Did not occur again and a lot of time passed since the original report. I

[jira] [Closed] (FLINK-2911) AccumulatingAlignedProcessingTimeWindowOperatorTest.checkpointRestoreWithPendingWindowTumbling

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-2911. -- Resolution: Cannot Reproduce Did not occur again and a lot of time passed since the original report. I

[jira] [Closed] (FLINK-2965) KafkaITCase failure

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-2965. -- Resolution: Cannot Reproduce Did not occur again and a lot of time passed since the original report

[jira] [Closed] (FLINK-2771) IterateTest.testSimpleIteration fails on Travis

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-2771. -- Resolution: Invalid Test has been removed. > IterateTest.testSimpleIteration fails on Travis >

[jira] [Closed] (FLINK-2719) ProcessFailureStreamingRecoveryITCase>AbstractProcessFailureRecoveryTest.testTaskManagerProcessFailure failed on Travis

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-2719. -- Resolution: Cannot Reproduce Did not occur again and a lot of time passed since the original report. I

[jira] [Closed] (FLINK-2718) LeaserChangeCleanupTest sometimes fails

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-2718. -- Resolution: Cannot Reproduce Did not occur again and a lot of time passed since the original report. I

[jira] [Closed] (FLINK-2618) ExternalSortITCase failure

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-2618. -- Resolution: Cannot Reproduce Did not occur again and a lot of time passed since the original report. I

[jira] [Closed] (FLINK-2504) ExternalSortLargeRecordsITCase.testSortWithLongAndShortRecordsMixed failed spuriously

2017-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-2504. -- Resolution: Cannot Reproduce Did not occur again and a lot of time passed since the original report. I

  1   2   3   4   5   6   7   8   9   10   >