[jira] [Commented] (FLINK-6492) Unclosed DataOutputViewStream in GenericArraySerializerConfigSnapshot#write()

[ https://issues.apache.org/jira/browse/FLINK-6492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016905#comment-16016905 ] ASF GitHub Bot commented on FLINK-6492: --- Github user zhangminglei commented on the issue:

[GitHub] flink issue #3898: [FLINK-6492] Fix unclosed DataOutputViewStream usage

Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/3898 Hi, @huafengw Welcome also. --- 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

[jira] [Commented] (FLINK-6492) Unclosed DataOutputViewStream in GenericArraySerializerConfigSnapshot#write()

[ https://issues.apache.org/jira/browse/FLINK-6492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016895#comment-16016895 ] ASF GitHub Bot commented on FLINK-6492: --- Github user huafengw commented on the issue:

[GitHub] flink issue #3898: [FLINK-6492] Fix unclosed DataOutputViewStream usage

Github user huafengw commented on the issue: https://github.com/apache/flink/pull/3898 Thank you guys :) --- 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,

[jira] [Commented] (FLINK-6492) Unclosed DataOutputViewStream in GenericArraySerializerConfigSnapshot#write()

[ https://issues.apache.org/jira/browse/FLINK-6492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016877#comment-16016877 ] ASF GitHub Bot commented on FLINK-6492: --- Github user gallenvara commented on the issue:

[GitHub] flink issue #3898: [FLINK-6492] Fix unclosed DataOutputViewStream usage

Github user gallenvara commented on the issue: https://github.com/apache/flink/pull/3898 Hi, @huafengw . Welcome to Flink family. Thanks for your PR and the changes look good to me. :) --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-6492) Unclosed DataOutputViewStream in GenericArraySerializerConfigSnapshot#write()

[ https://issues.apache.org/jira/browse/FLINK-6492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016874#comment-16016874 ] ASF GitHub Bot commented on FLINK-6492: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #3898: [FLINK-6492] Fix unclosed DataOutputViewStream usage

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3898 Hi @huafengw, thanks for the fixes! I'll probably merge this along with #3937 as there are some overlapping changes here and there. --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-6608) Relax Kerberos login contexts parsing by trimming whitespaces in contexts list

[ https://issues.apache.org/jira/browse/FLINK-6608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016861#comment-16016861 ] ASF GitHub Bot commented on FLINK-6608: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #3928: [FLINK-6608] [security, config] Relax Kerberos login cont...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3928 Merging to 1.3 and master --- 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

[jira] [Created] (FLINK-6632) Fix parameter case sensitive error for test passing/rejecting filter API

sunjincheng created FLINK-6632: -- Summary: Fix parameter case sensitive error for test passing/rejecting filter API Key: FLINK-6632 URL: https://issues.apache.org/jira/browse/FLINK-6632 Project: Flink

[jira] [Commented] (FLINK-6495) Migrate Akka configuration options

[ https://issues.apache.org/jira/browse/FLINK-6495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016789#comment-16016789 ] ASF GitHub Bot commented on FLINK-6495: --- Github user zjureel commented on a diff in the pull

[GitHub] flink pull request #3935: [FLINK-6495] Migrate Akka configuration options

Github user zjureel commented on a diff in the pull request: https://github.com/apache/flink/pull/3935#discussion_r117390018 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/AkkaOptions.java --- @@ -28,31 +28,143 @@ @PublicEvolving public class

[jira] [Commented] (FLINK-6288) FlinkKafkaProducer's custom Partitioner is always invoked with number of partitions of default topic

[ https://issues.apache.org/jira/browse/FLINK-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016783#comment-16016783 ] ASF GitHub Bot commented on FLINK-6288: --- Github user zjureel commented on the issue:

[GitHub] flink issue #3901: [FLINK-6288] fix FlinkKafkaProducer's custom Partitioner ...

Github user zjureel commented on the issue: https://github.com/apache/flink/pull/3901 @gyfora Thanks for you suggestion, and I agree with you that problems which cause errors to users should be addressed at a higher priority level. Thank you for merging this issues :)

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

[ https://issues.apache.org/jira/browse/FLINK-6328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016776#comment-16016776 ] Wei-Che Wei commented on FLINK-6328: Hi all, Are this and FLINK-6071 the similar issues? >

[jira] [Commented] (FLINK-6492) Unclosed DataOutputViewStream in GenericArraySerializerConfigSnapshot#write()

[ https://issues.apache.org/jira/browse/FLINK-6492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016774#comment-16016774 ] ASF GitHub Bot commented on FLINK-6492: --- Github user huafengw commented on the issue:

[GitHub] flink issue #3898: [FLINK-6492] Fix unclosed DataOutputViewStream usage

Github user huafengw commented on the issue: https://github.com/apache/flink/pull/3898 Hi @tzulitai, I'm new to Flink and would you mind taking a look at this one? --- 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

[jira] [Commented] (FLINK-6574) Support nested catalogs in ExternalCatalog

[ https://issues.apache.org/jira/browse/FLINK-6574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016746#comment-16016746 ] ASF GitHub Bot commented on FLINK-6574: --- Github user KurtYoung commented on a diff in the pull

[GitHub] flink pull request #3913: [FLINK-6574] Support nested catalogs in ExternalCa...

Github user KurtYoung commented on a diff in the pull request: https://github.com/apache/flink/pull/3913#discussion_r117385333 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalogTable.scala --- @@ -37,25 +36,10 @@ import

[jira] [Created] (FLINK-6631) Implement FLIP-6 MesosTaskExecutorRunner

Eron Wright created FLINK-6631: --- Summary: Implement FLIP-6 MesosTaskExecutorRunner Key: FLINK-6631 URL: https://issues.apache.org/jira/browse/FLINK-6631 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-6630) Implement FLIP-6 MesosAppMasterRunner

Eron Wright created FLINK-6630: --- Summary: Implement FLIP-6 MesosAppMasterRunner Key: FLINK-6630 URL: https://issues.apache.org/jira/browse/FLINK-6630 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-6379) Implement FLIP-6 Mesos Resource Manager

[ https://issues.apache.org/jira/browse/FLINK-6379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016733#comment-16016733 ] ASF GitHub Bot commented on FLINK-6379: --- Github user EronWright commented on the issue:

[GitHub] flink issue #3942: FLINK-6379 Mesos ResourceManager (FLIP-6)

Github user EronWright commented on the issue: https://github.com/apache/flink/pull/3942 This is a fairly straightforward port of the RM code to the FLIP-6 architecture. Follow-ups to occur in future PRs include: - adding support for releasing the worker -

[jira] [Commented] (FLINK-6379) Implement FLIP-6 Mesos Resource Manager

[ https://issues.apache.org/jira/browse/FLINK-6379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016730#comment-16016730 ] ASF GitHub Bot commented on FLINK-6379: --- GitHub user EronWright opened a pull request:

[GitHub] flink pull request #3942: FLINK-6379 Mesos ResourceManager (FLIP-6)

GitHub user EronWright opened a pull request: https://github.com/apache/flink/pull/3942 FLINK-6379 Mesos ResourceManager (FLIP-6) - Make the RPC gateway of the ResourceManager extensible to allow for framework-specific RPC methods - Introduce FLIP-6 MesosResourceManager w/

[jira] [Commented] (FLINK-6584) Support multiple consecutive windows in SQL

[ https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016703#comment-16016703 ] sunjincheng commented on FLINK-6584: Hi, [~twalthr] You had bring up a discussion for this JIRA. in

[jira] [Resolved] (FLINK-6595) Nested SQL queries do not expose proctime / rowtime attributes

[ https://issues.apache.org/jira/browse/FLINK-6595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai resolved FLINK-6595. --- Resolution: Duplicate > Nested SQL queries do not expose proctime / rowtime attributes >

[jira] [Commented] (FLINK-6595) Nested SQL queries do not expose proctime / rowtime attributes

[ https://issues.apache.org/jira/browse/FLINK-6595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016602#comment-16016602 ] Haohui Mai commented on FLINK-6595: --- This is addressed by FLINK-6483 via exposing the proctime in the

[jira] [Commented] (FLINK-6606) Create checkpoint hook with user classloader

[ https://issues.apache.org/jira/browse/FLINK-6606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016578#comment-16016578 ] ASF GitHub Bot commented on FLINK-6606: --- Github user EronWright commented on a diff in the pull

[GitHub] flink pull request #3933: [FLINK-6606] Create checkpoint hook with user clas...

Github user EronWright commented on a diff in the pull request: https://github.com/apache/flink/pull/3933#discussion_r117370390 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/hooks/MasterHooks.java --- @@ -267,6 +269,112 @@ else if

[jira] [Commented] (FLINK-6606) Create checkpoint hook with user classloader

[ https://issues.apache.org/jira/browse/FLINK-6606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016577#comment-16016577 ] ASF GitHub Bot commented on FLINK-6606: --- Github user EronWright commented on the issue:

[GitHub] flink issue #3933: [FLINK-6606] Create checkpoint hook with user classloader

Github user EronWright commented on the issue: https://github.com/apache/flink/pull/3933 Originally I pursued the path suggested by @tillrohrmann of setting the TCCL at the sites where the hook is invoked, but found that the classloader wasn't readily available.I found it more

[GitHub] flink pull request #3933: [FLINK-6606] Create checkpoint hook with user clas...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3933#discussion_r117370134 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/hooks/MasterHooks.java --- @@ -267,6 +269,112 @@ else if

[jira] [Commented] (FLINK-6606) Create checkpoint hook with user classloader

[ https://issues.apache.org/jira/browse/FLINK-6606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016575#comment-16016575 ] ASF GitHub Bot commented on FLINK-6606: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-6606) Create checkpoint hook with user classloader

[ https://issues.apache.org/jira/browse/FLINK-6606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016573#comment-16016573 ] ASF GitHub Bot commented on FLINK-6606: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #3933: [FLINK-6606] Create checkpoint hook with user classloader

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3933 I agree with @EronWright that it would be nice to offer all user code the a similar environment. This will become especially important if a `MasterTriggerRestoreHook` which is contained in the

[jira] [Created] (FLINK-6629) ClusterClient cannot submit jobs to HA cluster if address not set in configuration

Till Rohrmann created FLINK-6629: Summary: ClusterClient cannot submit jobs to HA cluster if address not set in configuration Key: FLINK-6629 URL: https://issues.apache.org/jira/browse/FLINK-6629

[jira] [Commented] (FLINK-6574) Support nested catalogs in ExternalCatalog

[ https://issues.apache.org/jira/browse/FLINK-6574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016438#comment-16016438 ] ASF GitHub Bot commented on FLINK-6574: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #3913: [FLINK-6574] Support nested catalogs in ExternalCa...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3913#discussion_r117349259 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalogTable.scala --- @@ -37,25 +36,10 @@ import

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

Chesnay Schepler created FLINK-6628: --- Summary: Cannot start taskmanager with cygwin in directory containing spaces Key: FLINK-6628 URL: https://issues.apache.org/jira/browse/FLINK-6628 Project:

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

[ https://issues.apache.org/jira/browse/FLINK-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016401#comment-16016401 ] ASF GitHub Bot commented on FLINK-6582: --- Github user greghogan commented on the issue:

[GitHub] flink issue #3910: [FLINK-6582] [docs] Project from maven archetype is not b...

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3910 @rmetzger latest commit is simpler and tested successfully for java and scala: `mvn org.apache.maven.plugins:maven-archetype-plugin:2.4:generate -DarchetypeGroupId=org.apache.flink

[jira] [Closed] (FLINK-6614) Applying function on window auxiliary function fails

[ https://issues.apache.org/jira/browse/FLINK-6614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6614. Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 Fixed for 1.3.0 with

[jira] [Closed] (FLINK-6543) Deprecate toDataStream

[ https://issues.apache.org/jira/browse/FLINK-6543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6543. Resolution: Done Fix Version/s: 1.4.0 Done for 1.3.0 with

[jira] [Closed] (FLINK-6585) Table examples are not runnable in IDE

[ https://issues.apache.org/jira/browse/FLINK-6585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6585. Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 Fixed for 1.3.0 with

[jira] [Closed] (FLINK-6618) Fix GroupWindowStringExpressionTest testcase bug

[ https://issues.apache.org/jira/browse/FLINK-6618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6618. Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 Fixed for 1.3.0 with

[GitHub] flink issue #3887: [hotfix] [docs] Fix link to docker-compose.yml

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3887 master: 47cb7347d8e02195088b2dc1900ac53bd5d02b0d 1.3.0: 542068760901cba2fd6f2b3f3ff6a980aee0e23e --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Closed] (FLINK-6616) Clarify provenance of official Docker images

[ https://issues.apache.org/jira/browse/FLINK-6616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-6616. - Resolution: Implemented master: 9a64d50f07c03102dfcb44656ec01852fdb56ac1 1.3.0:

[jira] [Commented] (FLINK-6616) Clarify provenance of official Docker images

[ https://issues.apache.org/jira/browse/FLINK-6616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016363#comment-16016363 ] ASF GitHub Bot commented on FLINK-6616: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3887: [hotfix] [docs] Fix link to docker-compose.yml

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3887 --- 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 #3932: [FLINK-6616] [docs] Clarify provenance of official...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3932 --- 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-6627) Expose tmp directories via API

[ https://issues.apache.org/jira/browse/FLINK-6627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016346#comment-16016346 ] Andrey commented on FLINK-6627: --- That's the problem. How cleanup script will know if "container" dir is used

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016321#comment-16016321 ] ASF GitHub Bot commented on FLINK-6582: --- Github user rmetzger commented on the issue:

[GitHub] flink issue #3910: [FLINK-6582] [docs] Project from maven archetype is not b...

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3910 Thank you. --- 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

[GitHub] flink pull request #3930: [FLINK-6614] [table] Fix translation of group auxi...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3930 --- 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-6614) Applying function on window auxiliary function fails

[ https://issues.apache.org/jira/browse/FLINK-6614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016312#comment-16016312 ] ASF GitHub Bot commented on FLINK-6614: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3905: [FLINK-6585] [table] Table examples are not runnab...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3905 --- 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-6543) Deprecate toDataStream

[ https://issues.apache.org/jira/browse/FLINK-6543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016311#comment-16016311 ] ASF GitHub Bot commented on FLINK-6543: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3929: [FLINK-6543] [table] Deprecate toDataStream

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3929 --- 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 #3936: [FLINK-6618][table] Fix GroupWindowStringExpressio...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3936 --- 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-6618) Fix GroupWindowStringExpressionTest testcase bug

[ https://issues.apache.org/jira/browse/FLINK-6618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016310#comment-16016310 ] ASF GitHub Bot commented on FLINK-6618: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-6585) Table examples are not runnable in IDE

[ https://issues.apache.org/jira/browse/FLINK-6585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016313#comment-16016313 ] ASF GitHub Bot commented on FLINK-6585: --- Github user asfgit closed the pull request at:

[jira] [Closed] (FLINK-6440) Noisy logs from metric fetcher

[ https://issues.apache.org/jira/browse/FLINK-6440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6440. --- Resolution: Fixed Fix Version/s: 1.4.0 1.3: 5569c4fafb08755ef12b7a96a173170dad883184

[jira] [Closed] (FLINK-6596) Disable javadoc generation in all travis builds

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

[jira] [Closed] (FLINK-6416) Potential divide by zero issue in InputGateMetrics#refreshAndGetAvg()

[ https://issues.apache.org/jira/browse/FLINK-6416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6416. --- Resolution: Fixed 1.3: 979228b3e2cac52c79c78855645a536d515befc9 1.4:

[jira] [Commented] (FLINK-6596) Disable javadoc generation in all travis builds

[ https://issues.apache.org/jira/browse/FLINK-6596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016272#comment-16016272 ] ASF GitHub Bot commented on FLINK-6596: --- Github user zentol closed the pull request at:

[jira] [Commented] (FLINK-6416) Potential divide by zero issue in InputGateMetrics#refreshAndGetAvg()

[ https://issues.apache.org/jira/browse/FLINK-6416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016273#comment-16016273 ] ASF GitHub Bot commented on FLINK-6416: --- Github user zentol closed the pull request at:

[jira] [Commented] (FLINK-6440) Noisy logs from metric fetcher

[ https://issues.apache.org/jira/browse/FLINK-6440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016269#comment-16016269 ] ASF GitHub Bot commented on FLINK-6440: --- Github user zentol closed the pull request at:

[GitHub] flink pull request #3914: [FLINK-6596][travis] Disable javadoc generation fo...

Github user zentol closed the pull request at: https://github.com/apache/flink/pull/3914 --- 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 #3906: [FLINK-6416] Fix divide-by-zero in InputGateMetric...

Github user zentol closed the pull request at: https://github.com/apache/flink/pull/3906 --- 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 #3917: [FLINK-6440][metrics] Downgrade fetching failure l...

Github user zentol closed the pull request at: https://github.com/apache/flink/pull/3917 --- 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-5685) Connection leak in Taskmanager

[ https://issues.apache.org/jira/browse/FLINK-5685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016260#comment-16016260 ] Gustavo Anatoly commented on FLINK-5685: Hi [~dernasherbrezon] Are you working in this issue?

[jira] [Commented] (FLINK-6610) WebServer could not be created,when set the "jobmanager.web.submit.enable" to false

[ https://issues.apache.org/jira/browse/FLINK-6610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016251#comment-16016251 ] Chesnay Schepler commented on FLINK-6610: - [~chenzio] How fast can you provide a fix for this? It

[jira] [Commented] (FLINK-6574) Support nested catalogs in ExternalCatalog

[ https://issues.apache.org/jira/browse/FLINK-6574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016247#comment-16016247 ] ASF GitHub Bot commented on FLINK-6574: --- Github user haohui commented on a diff in the pull request:

[GitHub] flink pull request #3913: [FLINK-6574] Support nested catalogs in ExternalCa...

Github user haohui commented on a diff in the pull request: https://github.com/apache/flink/pull/3913#discussion_r117325036 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalogTable.scala --- @@ -37,25 +36,10 @@ import

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

[ https://issues.apache.org/jira/browse/FLINK-6586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016225#comment-16016225 ] 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...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3907 That's a great point, haven't considered that. It may be easier to just compare the final result with `Integer.MAX_VALUE` and return `0` if the match. --- If your project is set up for it, you can

[GitHub] flink issue #3910: [FLINK-6582] [docs] Project from maven archetype is not b...

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3910 @rmetzger I am seeing the same issue and will look into this. --- 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

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

[ https://issues.apache.org/jira/browse/FLINK-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016162#comment-16016162 ] ASF GitHub Bot commented on FLINK-6582: --- Github user greghogan commented on the issue:

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

[ https://issues.apache.org/jira/browse/FLINK-6586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016156#comment-16016156 ] 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...

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3907 Does an `InputGate` contain both local and remote `InputChannel` such that the minimum positive value might be more desirable in that case? --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-6616) Clarify provenance of official Docker images

[ https://issues.apache.org/jira/browse/FLINK-6616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016149#comment-16016149 ] ASF GitHub Bot commented on FLINK-6616: --- Github user greghogan commented on the issue:

[GitHub] flink issue #3932: [FLINK-6616] [docs] Clarify provenance of official Docker...

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3932 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

[GitHub] flink issue #3887: [hotfix] [docs] Fix link to docker-compose.yml

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3887 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

[jira] [Commented] (FLINK-6560) Restore maven parallelism in flink-tests

[ https://issues.apache.org/jira/browse/FLINK-6560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016142#comment-16016142 ] ASF GitHub Bot commented on FLINK-6560: --- Github user greghogan commented on the issue:

[GitHub] flink issue #3875: [FLINK-6560] [build] Restore maven parallelism in flink-t...

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3875 @StephanEwen I see that you +1'd the ticket but this PR has not been reviewed. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

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

GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/3941 [FLINK-6603] [streaming] Enable checkstyle on test sources Follow-up to FLINK-6107. The first commit sets the import order as

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

[ https://issues.apache.org/jira/browse/FLINK-6603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016114#comment-16016114 ] ASF GitHub Bot commented on FLINK-6603: --- GitHub user greghogan opened a pull request:

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

[ https://issues.apache.org/jira/browse/FLINK-6603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016044#comment-16016044 ] sunjincheng commented on FLINK-6603: +1 > Enable checkstyle on test sources >

[jira] [Commented] (FLINK-6606) Create checkpoint hook with user classloader

[ https://issues.apache.org/jira/browse/FLINK-6606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016039#comment-16016039 ] ASF GitHub Bot commented on FLINK-6606: --- Github user rmetzger commented on the issue:

[GitHub] flink issue #3933: [FLINK-6606] Create checkpoint hook with user classloader

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3933 Lets see what Till says. In my opinion, both approaches are fine. What you are proposing makes things on Flink's side a bit more complicated, but the behavior is consistent with other places

[jira] [Commented] (FLINK-6288) FlinkKafkaProducer's custom Partitioner is always invoked with number of partitions of default topic

[ https://issues.apache.org/jira/browse/FLINK-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016028#comment-16016028 ] ASF GitHub Bot commented on FLINK-6288: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #3901: [FLINK-6288] fix FlinkKafkaProducer's custom Partitioner ...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3901 I'm currently waiting for a Travis run locally for https://github.com/tzulitai/flink/tree/FLINK-6288. That branch also includes more tests and tweak cleanups for the feature. Once it

[jira] [Commented] (FLINK-6606) Create checkpoint hook with user classloader

[ https://issues.apache.org/jira/browse/FLINK-6606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016010#comment-16016010 ] ASF GitHub Bot commented on FLINK-6606: --- Github user EronWright commented on the issue:

[GitHub] flink issue #3933: [FLINK-6606] Create checkpoint hook with user classloader

Github user EronWright commented on the issue: https://github.com/apache/flink/pull/3933 That's the sort of workaround that Android apps are forced to use. Why not continue the practice of setting the TCCL in transitions from system to user code? --- If your project is set up for

[GitHub] flink issue #3933: [FLINK-6606] Create checkpoint hook with user classloader

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3933 Till and I had an offline discussion about this. What you can do in your user code to set the TCCL properly is the following: ```

[jira] [Commented] (FLINK-6606) Create checkpoint hook with user classloader

[ https://issues.apache.org/jira/browse/FLINK-6606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016007#comment-16016007 ] ASF GitHub Bot commented on FLINK-6606: --- Github user rmetzger commented on the issue:

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

Andrey created FLINK-6627: - Summary: Expose tmp directories via API Key: FLINK-6627 URL: https://issues.apache.org/jira/browse/FLINK-6627 Project: Flink Issue Type: Improvement Affects Versions:

  1   2   3   >