[jira] [Commented] (FLINK-6376) when deploy flink cluster on the yarn, it is lack of hdfs delegation token.

2017-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16018301#comment-16018301 ] ASF GitHub Bot commented on FLINK-6376: --- Github user Rucongzhang commented on the issue:

[GitHub] flink issue #3776: [FLINK-6376]when deploy flink cluster on the yarn, it is ...

2017-05-19 Thread Rucongzhang
Github user Rucongzhang commented on the issue: https://github.com/apache/flink/pull/3776 @StephanEwen , we resolve this problem. We only add the HDFS delegation token in JM、TM yarn container context. And when we configuration the keytab, the JM、TM use the keytab to

[jira] [Closed] (FLINK-6639) Java/Scala code tabs broken in CEP docs

2017-05-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6639. --- Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 1.3:

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

2017-05-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5636. --- Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 1.3:

[jira] [Closed] (FLINK-6586) InputGateMetrics#refreshAndGetMin returns Integer.MAX_VALUE for local channels

2017-05-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6586. --- Resolution: Fixed 1.3: c3ab5c8253b32bddc3fb9bf0c1085813e7f97e2f 1.4:

[jira] [Closed] (FLINK-6439) Unclosed InputStream in OperatorSnapshotUtil#readStateHandle()

2017-05-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6439. --- Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 1.3:

[jira] [Commented] (FLINK-6332) Upgrade Scala version to 2.11.11

2017-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16018079#comment-16018079 ] ASF GitHub Bot commented on FLINK-6332: --- GitHub user greghogan opened a pull request:

[GitHub] flink pull request #3957: [FLINK-6332] [build] Upgrade Scala versions

2017-05-19 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/3957 [FLINK-6332] [build] Upgrade Scala versions Upgrade to the last maintenance releases of Scala 2.10 and 2.11. You can merge this pull request into a Git repository by running: $ git pull

[GitHub] flink pull request #3950: [FLINK-5636][metrics] Measure numRecordsIn in Stre...

2017-05-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3950 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

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

2017-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16018018#comment-16018018 ] ASF GitHub Bot commented on FLINK-5636: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-6639) Java/Scala code tabs broken in CEP docs

2017-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16018017#comment-16018017 ] ASF GitHub Bot commented on FLINK-6639: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3952: [FLINK-6639] fix code tabs in CEP docs

2017-05-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3952 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-6586) InputGateMetrics#refreshAndGetMin returns Integer.MAX_VALUE for local channels

2017-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16018020#comment-16018020 ] ASF GitHub Bot commented on FLINK-6586: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-6439) Unclosed InputStream in OperatorSnapshotUtil#readStateHandle()

2017-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16018019#comment-16018019 ] ASF GitHub Bot commented on FLINK-6439: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3907: [FLINK-6586] InputGateMetrics return 0 as minimum ...

2017-05-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3907 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #3854: [hotfix] [rat] Add exclusion for test state snapsh...

2017-05-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3854 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #3904: [FLINK-6439] Fix close OutputStream && InputStream...

2017-05-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3904 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

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

2017-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017956#comment-16017956 ] ASF GitHub Bot commented on FLINK-5005: --- Github user frankbohman commented on the issue:

[GitHub] flink issue #3703: [FLINK-5005] WIP: publish scala 2.12 artifacts

2017-05-19 Thread frankbohman
Github user frankbohman commented on the issue: https://github.com/apache/flink/pull/3703 where can i watch the status page-thing.. that tells us when we can get off of old 2.11 ? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[jira] [Created] (FLINK-6648) Transforms for Gelly examples

2017-05-19 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-6648: - Summary: Transforms for Gelly examples Key: FLINK-6648 URL: https://issues.apache.org/jira/browse/FLINK-6648 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-6647) Fail-fast on invalid RocksDBStateBackend configuration

2017-05-19 Thread Helder Pereira (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017687#comment-16017687 ] Helder Pereira commented on FLINK-6647: --- The {{File.pathSeparator}} seems a bit dangerous here, as

[jira] [Assigned] (FLINK-6332) Upgrade Scala version to 2.11.11

2017-05-19 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan reassigned FLINK-6332: - Assignee: Greg Hogan > Upgrade Scala version to 2.11.11 > > >

[GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink

2017-05-19 Thread nragon
Github user nragon commented on the issue: https://github.com/apache/flink/pull/2332 I've made a custom solution which works for my use cases. Notice that the code attached is not working because it's only a skeleton. This prototype uses asynchbase and tries to manage throttling

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

2017-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017665#comment-16017665 ] ASF GitHub Bot commented on FLINK-2055: --- Github user nragon commented on the issue:

[jira] [Commented] (FLINK-5898) Race-Condition with Amazon Kinesis KPL

2017-05-19 Thread Scott Kidder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017653#comment-16017653 ] Scott Kidder commented on FLINK-5898: - I created a new build of Flink that uses KPL {{0.12.4}} and AWS

[jira] [Commented] (FLINK-6603) Enable checkstyle on test sources

2017-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017625#comment-16017625 ] ASF GitHub Bot commented on FLINK-6603: --- Github user greghogan commented on the issue:

[GitHub] flink issue #3941: [FLINK-6603] [streaming] Enable checkstyle on test source...

2017-05-19 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3941 @StephanEwen please verify the first commit implements the desired/traditional import order. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[jira] [Created] (FLINK-6647) Fail-fast on invalid RocksDBStateBackend configuration

2017-05-19 Thread Andrey (JIRA)
Andrey created FLINK-6647: - Summary: Fail-fast on invalid RocksDBStateBackend configuration Key: FLINK-6647 URL: https://issues.apache.org/jira/browse/FLINK-6647 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-6009) Deprecate DataSetUtils#checksumHashCode

2017-05-19 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-6009. - Resolution: Implemented > Deprecate DataSetUtils#checksumHashCode >

[jira] [Reopened] (FLINK-6009) Deprecate DataSetUtils#checksumHashCode

2017-05-19 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan reopened FLINK-6009: --- > Deprecate DataSetUtils#checksumHashCode > --- > >

[jira] [Commented] (FLINK-6644) Don't register HUP unix signal handler on Windows

2017-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017600#comment-16017600 ] ASF GitHub Bot commented on FLINK-6644: --- Github user greghogan commented on the issue:

[GitHub] flink issue #3955: [FLINK-6644] Don't register HUP signal handler on Windows

2017-05-19 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3955 +1 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

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

2017-05-19 Thread Robert Metzger (JIRA)
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

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

2017-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017596#comment-16017596 ] ASF GitHub Bot commented on FLINK-2055: --- Github user fpompermaier commented on the issue:

[GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink

2017-05-19 Thread fpompermaier
Github user fpompermaier commented on the issue: https://github.com/apache/flink/pull/2332 anyone working on this? HBase streaming sink would be a very nice addition... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[jira] [Commented] (FLINK-6628) Cannot start taskmanager with cygwin in directory containing spaces

2017-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017595#comment-16017595 ] ASF GitHub Bot commented on FLINK-6628: --- Github user greghogan commented on the issue:

[GitHub] flink issue #3954: [FLINK-6628] Fix start scripts on Windows

2017-05-19 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3954 +1 and to fix in 1.3.0 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes

[jira] [Issue Comment Deleted] (FLINK-6576) Allow ConfigOptions to validate the configured value

2017-05-19 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-6576: -- Comment: was deleted (was: I happend to also look at this and in addition to {{taskmanager.sh}} the

[jira] [Commented] (FLINK-6551) OutputTag name should not be allowed to be empty

2017-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017588#comment-16017588 ] ASF GitHub Bot commented on FLINK-6551: --- Github user greghogan commented on the issue:

[GitHub] flink issue #3953: [FLINK-6551] Reject empty OutputTag names

2017-05-19 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3953 +1 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[jira] [Commented] (FLINK-6439) Unclosed InputStream in OperatorSnapshotUtil#readStateHandle()

2017-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017585#comment-16017585 ] ASF GitHub Bot commented on FLINK-6439: --- Github user zentol commented on the issue:

[GitHub] flink issue #3904: [FLINK-6439] Fix close OutputStream && InputStream in Ope...

2017-05-19 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3904 merging. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[jira] [Updated] (FLINK-6297) CEP timeout does not trigger under certain conditions

2017-05-19 Thread Vijayakumar Palaniappan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vijayakumar Palaniappan updated FLINK-6297: --- Issue is still reproducible Changes i did are - iterator as the source

[jira] [Commented] (FLINK-6586) InputGateMetrics#refreshAndGetMin returns Integer.MAX_VALUE for local channels

2017-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017580#comment-16017580 ] ASF GitHub Bot commented on FLINK-6586: --- Github user zentol commented on the issue:

[GitHub] flink issue #3907: [FLINK-6586] InputGateMetrics return 0 as minimum for loc...

2017-05-19 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3907 merging. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[jira] [Commented] (FLINK-6628) Cannot start taskmanager with cygwin in directory containing spaces

2017-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017579#comment-16017579 ] ASF GitHub Bot commented on FLINK-6628: --- Github user zentol commented on the issue:

[GitHub] flink issue #3954: [FLINK-6628] Fix start scripts on Windows

2017-05-19 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3954 @greghogan done. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or

[GitHub] flink pull request #3956: [FLINK-6642] Return -1 in EnvInfo#getOpenFileHandl...

2017-05-19 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3956 [FLINK-6642] Return -1 in EnvInfo#getOpenFileHandlesLimit Returns -1 for Windows, as the accessed UnixOSMXBean is obviously not available on Windows. This reduces logging noise on Windows.

[jira] [Created] (FLINK-6645) JobMasterTest failed on Travis

2017-05-19 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6645: --- Summary: JobMasterTest failed on Travis Key: FLINK-6645 URL: https://issues.apache.org/jira/browse/FLINK-6645 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-6586) InputGateMetrics#refreshAndGetMin returns Integer.MAX_VALUE for local channels

2017-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017572#comment-16017572 ] ASF GitHub Bot commented on FLINK-6586: --- Github user greghogan commented on the issue:

[GitHub] flink issue #3907: [FLINK-6586] InputGateMetrics return 0 as minimum for loc...

2017-05-19 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3907 +1 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

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

2017-05-19 Thread Robert Metzger (JIRA)
[ 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.

[GitHub] flink pull request #3955: [FLINK-6644] Don't register HUP signal handler on ...

2017-05-19 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3955 [FLINK-6644] Don't register HUP signal handler on Windows No longer registers the HUP signal handler on Windows to reduce noise in the logs as it is not available on windows. You can merge this

[jira] [Updated] (FLINK-6645) JobMasterTest failed on Travis

2017-05-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6645: Description: {code} Failed tests:

[jira] [Reopened] (FLINK-6577) Expand supported types for ConfigOptions

2017-05-19 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan reopened FLINK-6577: --- > Expand supported types for ConfigOptions > > >

[jira] [Closed] (FLINK-6577) Expand supported types for ConfigOptions

2017-05-19 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-6577. - Resolution: Fixed > Expand supported types for ConfigOptions > >

[jira] [Commented] (FLINK-6642) EnvInformation#getOpenFileHandlesLimit should return -1 for Windows

2017-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017553#comment-16017553 ] ASF GitHub Bot commented on FLINK-6642: --- GitHub user zentol opened a pull request:

[jira] [Commented] (FLINK-6644) Don't register HUP unix signal handler on Windows

2017-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017552#comment-16017552 ] ASF GitHub Bot commented on FLINK-6644: --- GitHub user zentol opened a pull request:

[jira] [Issue Comment Deleted] (FLINK-6577) Expand supported types for ConfigOptions

2017-05-19 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-6577: -- Comment: was deleted (was: Sorry about that. Too much tab hopping.) > Expand supported types for

[jira] [Assigned] (FLINK-6644) Don't register HUP unix signal handler on Windows

2017-05-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-6644: --- Assignee: Chesnay Schepler > Don't register HUP unix signal handler on Windows >

[jira] [Commented] (FLINK-6577) Expand supported types for ConfigOptions

2017-05-19 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017545#comment-16017545 ] Greg Hogan commented on FLINK-6577: --- Sorry about that. Too much tab hopping. > Expand supported types

[jira] [Closed] (FLINK-3155) Update Flink docker version to latest stable Flink version

2017-05-19 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3155. - Resolution: Fixed > Update Flink docker version to latest stable Flink version >

[jira] [Created] (FLINK-6644) Don't register HUP unix signal handler on Windows

2017-05-19 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6644: --- Summary: Don't register HUP unix signal handler on Windows Key: FLINK-6644 URL: https://issues.apache.org/jira/browse/FLINK-6644 Project: Flink Issue

[jira] [Commented] (FLINK-3155) Update Flink docker version to latest stable Flink version

2017-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017538#comment-16017538 ] ASF GitHub Bot commented on FLINK-3155: --- Github user greghogan commented on the issue:

[GitHub] flink issue #3490: [FLINK-3155] Update Docker to use the latest 1.1.x versio...

2017-05-19 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3490 @kdombeck thank you for this PR! We now have [official Docker images](https://ci.apache.org/projects/flink/flink-docs-release-1.3/setup/docker.html) and I see that the contrib Dockerfile no longer

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

2017-05-19 Thread Robert Metzger (JIRA)
[ 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] [Commented] (FLINK-6641) HA recovery on YARN fails due to missing files in HDFS

2017-05-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017534#comment-16017534 ] Robert Metzger commented on FLINK-6641: --- Yes, I agree. This JIRA is actually two issues. Let me

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

2017-05-19 Thread Robert Metzger (JIRA)
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

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

2017-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017532#comment-16017532 ] Till Rohrmann commented on FLINK-6641: -- I think one problem is that the {{ClusterClient}} calls

[jira] [Updated] (FLINK-6642) EnvInformation#getOpenFileHandlesLimit should return -1 for Windows

2017-05-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6642: Description: The {{EnvironmentInformation#getOpenFileHandlesLimit}} is accessing the sun

[jira] [Created] (FLINK-6642) EnvInformation#getOpenFileHandlesLimit should return -1 for Windows

2017-05-19 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6642: --- Summary: EnvInformation#getOpenFileHandlesLimit should return -1 for Windows Key: FLINK-6642 URL: https://issues.apache.org/jira/browse/FLINK-6642 Project:

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

2017-05-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-6641: Assignee: Till Rohrmann > HA recovery on YARN fails due to missing files in HDFS >

[jira] [Commented] (FLINK-6628) Cannot start taskmanager with cygwin in directory containing spaces

2017-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017521#comment-16017521 ] ASF GitHub Bot commented on FLINK-6628: --- Github user greghogan commented on the issue:

[GitHub] flink issue #3954: [FLINK-6628] Fix start scripts on Windows

2017-05-19 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3954 This affects more than Windows ... at least MacOS and I expect Linux as well. Also need to update `rotateLogFilesWithPrefix` in `config.sh` to: `rotateLogFile "$log"`. --- If your

[jira] [Commented] (FLINK-6446) Various improvements to the Web Frontend

2017-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017514#comment-16017514 ] ASF GitHub Bot commented on FLINK-6446: --- Github user greghogan commented on a diff in the pull

[GitHub] flink pull request #3946: [FLINK-6446] Fix some small issues in the web UI

2017-05-19 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/3946#discussion_r117504104 --- Diff: flink-runtime-web/web-dashboard/app/partials/jobs/job.plan.jade --- @@ -28,10 +28,10 @@ split a(ui-sref=".subtasks({nodeid:

[jira] [Commented] (FLINK-6576) Allow ConfigOptions to validate the configured value

2017-05-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017507#comment-16017507 ] Chesnay Schepler commented on FLINK-6576: - [~greghogan] wrong issue? :) Think you're looking for

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

2017-05-19 Thread Robert Metzger (JIRA)
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] [Commented] (FLINK-6628) Cannot start taskmanager with cygwin in directory containing spaces

2017-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017495#comment-16017495 ] ASF GitHub Bot commented on FLINK-6628: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #3954: [FLINK-6628] Fix start scripts on Windows

2017-05-19 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3954 [FLINK-6628] Fix start scripts on Windows This PR fixes the `flink-daemon.sh` and `taskmanager.sh` script for cygwin for directories containing spaces. They were broken in

[jira] [Commented] (FLINK-6576) Allow ConfigOptions to validate the configured value

2017-05-19 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017493#comment-16017493 ] Greg Hogan commented on FLINK-6576: --- I happend to also look at this and in addition to

[jira] [Assigned] (FLINK-6628) Cannot start taskmanager with cygwin in directory containing spaces

2017-05-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-6628: --- Assignee: Chesnay Schepler > Cannot start taskmanager with cygwin in directory

[jira] [Updated] (FLINK-6639) Java/Scala code tabs broken in CEP docs

2017-05-19 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-6639: -- Component/s: CEP > Java/Scala code tabs broken in CEP docs >

[jira] [Commented] (FLINK-6297) CEP timeout does not trigger under certain conditions

2017-05-19 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017482#comment-16017482 ] Kostas Kloudas commented on FLINK-6297: --- Hi [~vijayakumarpl], is this problem still occurring? If

[jira] [Commented] (FLINK-5753) CEP timeout handler.

2017-05-19 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017476#comment-16017476 ] Kostas Kloudas commented on FLINK-5753: --- Hi [~jurijuri], did the above solve your problem? If yes,

[jira] [Commented] (FLINK-5898) Race-Condition with Amazon Kinesis KPL

2017-05-19 Thread Scott Kidder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017473#comment-16017473 ] Scott Kidder commented on FLINK-5898: - Hi Gordon! I think this issue and FLINK-5946 warrant upgrading

[jira] [Closed] (FLINK-6634) NFA serializer does not serialize the ComputationState counter.

2017-05-19 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-6634. - Resolution: Fixed > NFA serializer does not serialize the ComputationState counter. >

[jira] [Updated] (FLINK-6634) NFA serializer does not serialize the ComputationState counter.

2017-05-19 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-6634: -- Summary: NFA serializer does not serialize the ComputationState counter. (was: NFA serializer

[jira] [Commented] (FLINK-6634) NFA serializer does not serialize the ValueTimeWrapper counter.

2017-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017465#comment-16017465 ] ASF GitHub Bot commented on FLINK-6634: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3945: [FLINK-6634] [cep] NFASerializer serializes Comput...

2017-05-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3945 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-6551) OutputTag name should not be allowed to be empty

2017-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017462#comment-16017462 ] ASF GitHub Bot commented on FLINK-6551: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #3953: [FLINK-6551] Reject empty OutputTag names

2017-05-19 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3953 [FLINK-6551] Reject empty OutputTag names With this PR we reject empty `OutputTag` names. Having an empty name prevents useful logging messages, as they would effectively contain no information

[jira] [Assigned] (FLINK-6551) OutputTag name should not be allowed to be empty

2017-05-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-6551: --- Assignee: Chesnay Schepler > OutputTag name should not be allowed to be empty >

[jira] [Commented] (FLINK-5898) Race-Condition with Amazon Kinesis KPL

2017-05-19 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017452#comment-16017452 ] Tzu-Li (Gordon) Tai commented on FLINK-5898: Thanks for the update Scott! Would it make sense

[jira] [Closed] (FLINK-5946) Kinesis Producer uses KPL that orphans threads that consume 100% CPU

2017-05-19 Thread Scott Kidder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Scott Kidder closed FLINK-5946. --- Resolution: Workaround The fix for this issue is included in release `0.12.4` of the AWS KPL,

[jira] [Closed] (FLINK-5898) Race-Condition with Amazon Kinesis KPL

2017-05-19 Thread Scott Kidder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Scott Kidder closed FLINK-5898. --- Resolution: Workaround Issue fixed in KPL version 0.12.4. > Race-Condition with Amazon Kinesis KPL >

[jira] [Commented] (FLINK-5898) Race-Condition with Amazon Kinesis KPL

2017-05-19 Thread Scott Kidder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017444#comment-16017444 ] Scott Kidder commented on FLINK-5898: - The fix for this issue is included in release `0.12.4` of the

[jira] [Created] (FLINK-6640) Ensure registration of shared state happens before externalizing a checkpoint

2017-05-19 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-6640: - Summary: Ensure registration of shared state happens before externalizing a checkpoint Key: FLINK-6640 URL: https://issues.apache.org/jira/browse/FLINK-6640

[jira] [Commented] (FLINK-6639) Java/Scala code tabs broken in CEP docs

2017-05-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16017426#comment-16017426 ] ASF GitHub Bot commented on FLINK-6639: --- Github user zentol commented on the issue:

[GitHub] flink issue #3952: [FLINK-6639] fix code tabs in CEP docs

2017-05-19 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3952 merging. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

  1   2   3   >