[jira] [Commented] (FLINK-14197) Increasing trend for state size of keyed stream using ProcessWindowFunction with ProcessingTimeSessionWindows

[ https://issues.apache.org/jira/browse/FLINK-14197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16937009#comment-16937009 ] Ken Krugler commented on FLINK-14197: - On the Flink user mailing list, [this

[jira] [Commented] (FLINK-14056) AtOm+Electron+TypedE-Mail

[ https://issues.apache.org/jira/browse/FLINK-14056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928011#comment-16928011 ] Ken Krugler commented on FLINK-14056: - Seems like this user should get blocked... >

[jira] [Updated] (FLINK-13956) Add sequence file format with repeated sync blocks

[ https://issues.apache.org/jira/browse/FLINK-13956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ken Krugler updated FLINK-13956: Description: The current {{SerializedOutputFormat}} produces files that are tightly bound to the

[jira] [Commented] (FLINK-13844) AtOmXpLuS

[ https://issues.apache.org/jira/browse/FLINK-13844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16915255#comment-16915255 ] Ken Krugler commented on FLINK-13844: - Hi [~AtOmXpLuS] - please add more details, as currently this

[jira] [Commented] (FLINK-13472) taskmanager.jvm-exit-on-oom doesn't work reliably with YARN

[ https://issues.apache.org/jira/browse/FLINK-13472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16896510#comment-16896510 ] Ken Krugler commented on FLINK-13472: - Hi [~pawelbartoszek] - In my experience, when a Flink

[jira] [Comment Edited] (FLINK-13163) Support execution of batch jobs with fewer slots than requested

[ https://issues.apache.org/jira/browse/FLINK-13163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882022#comment-16882022 ] Ken Krugler edited comment on FLINK-13163 at 7/10/19 12:55 PM: --- Hi

[jira] [Commented] (FLINK-13163) Support execution of batch jobs with fewer slots than requested

[ https://issues.apache.org/jira/browse/FLINK-13163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882022#comment-16882022 ] Ken Krugler commented on FLINK-13163: - Hi [~zhuzh] - thanks for this report, and the notes. I've

[jira] [Commented] (FLINK-12522) Error While Initializing S3A FileSystem

[ https://issues.apache.org/jira/browse/FLINK-12522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16840806#comment-16840806 ] Ken Krugler commented on FLINK-12522: - Hi Manish Bellani - please post to the Flink user list first,

[jira] [Commented] (FLINK-12504) NullPoint here NullPointException there.. It's every where

[ https://issues.apache.org/jira/browse/FLINK-12504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16839718#comment-16839718 ] Ken Krugler commented on FLINK-12504: - If I Google "Flink user mailing list", the first hit is for 

[jira] [Commented] (FLINK-12504) NullPoint here NullPointException there.. It's every where

[ https://issues.apache.org/jira/browse/FLINK-12504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16838959#comment-16838959 ] Ken Krugler commented on FLINK-12504: - Not sure why you say "It's not print". Your stacktrace ends

[jira] [Commented] (FLINK-12504) NullPoint here NullPointException there.. It's every where

[ https://issues.apache.org/jira/browse/FLINK-12504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16838782#comment-16838782 ] Ken Krugler commented on FLINK-12504: - Hi [~chethanuk] - a few comments...   # Before filing a

[jira] [Commented] (FLINK-12205) Internal server error.,

[ https://issues.apache.org/jira/browse/FLINK-12205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16818240#comment-16818240 ] Ken Krugler commented on FLINK-12205: - Hi [~hbchen] - I didn't see this posted on the user mailing

[jira] [Commented] (FLINK-12093) Apache Flink:Active MQ consumer job is getting finished after first message consume.

[ https://issues.apache.org/jira/browse/FLINK-12093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16808800#comment-16808800 ] Ken Krugler commented on FLINK-12093: - Hi [~shivk4464] - please post this question to the [Flink

[jira] [Commented] (FLINK-11933) Exception in thread "main" java.lang.RuntimeException: No data sinks have been created yet. A program needs at least one sink that consumes data. Examples are writing

[ https://issues.apache.org/jira/browse/FLINK-11933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16793700#comment-16793700 ] Ken Krugler commented on FLINK-11933: - Hi thinktothings - please post problems like this to the

[jira] [Commented] (FLINK-11906) Getting error while submitting job

[ https://issues.apache.org/jira/browse/FLINK-11906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16791994#comment-16791994 ] Ken Krugler commented on FLINK-11906: - Hi Ramesh - for a problem like this, please first post to the

[jira] [Commented] (FLINK-10959) sometimes most taskmanger in the same node

[ https://issues.apache.org/jira/browse/FLINK-10959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16695163#comment-16695163 ] Ken Krugler commented on FLINK-10959: - Hi [~luyee] - this is something that would be best to first

[jira] [Commented] (FLINK-10952) How to stream MySQl data and Store in Flink Dataset

[ https://issues.apache.org/jira/browse/FLINK-10952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16693678#comment-16693678 ] Ken Krugler commented on FLINK-10952: - Hi [~vinothmahalingam] - for problems with Flink, it's best

[jira] [Comment Edited] (FLINK-9541) Add robots.txt and sitemap.xml to Flink website

[ https://issues.apache.org/jira/browse/FLINK-9541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689936#comment-16689936 ] Ken Krugler edited comment on FLINK-9541 at 11/19/18 11:38 PM: --- I'd asked

[jira] [Comment Edited] (FLINK-9541) Add robots.txt and sitemap.xml to Flink website

[ https://issues.apache.org/jira/browse/FLINK-9541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689936#comment-16689936 ] Ken Krugler edited comment on FLINK-9541 at 11/19/18 11:37 PM: --- I'd asked

[jira] [Commented] (FLINK-9541) Add robots.txt and sitemap.xml to Flink website

[ https://issues.apache.org/jira/browse/FLINK-9541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692292#comment-16692292 ] Ken Krugler commented on FLINK-9541: Hi [~fhueske] - thanks for the input, some comments below. * In

[jira] [Commented] (FLINK-9541) Add robots.txt and sitemap.xml to Flink website

[ https://issues.apache.org/jira/browse/FLINK-9541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16691951#comment-16691951 ] Ken Krugler commented on FLINK-9541: The use of canonical links should only be for pages that are

[jira] [Commented] (FLINK-9541) Add robots.txt and sitemap.xml to Flink website

[ https://issues.apache.org/jira/browse/FLINK-9541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689955#comment-16689955 ] Ken Krugler commented on FLINK-9541: Should there be any directories in ci.apache.org/projects/flink

[jira] [Commented] (FLINK-9541) Add robots.txt and sitemap.xml to Flink website

[ https://issues.apache.org/jira/browse/FLINK-9541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689941#comment-16689941 ] Ken Krugler commented on FLINK-9541: Also, I've confirmed that the ci.apache.org

[jira] [Commented] (FLINK-9541) Add robots.txt and sitemap.xml to Flink website

[ https://issues.apache.org/jira/browse/FLINK-9541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689936#comment-16689936 ] Ken Krugler commented on FLINK-9541: I'd asked [on the 

[jira] [Commented] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop

[ https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503401#comment-16503401 ] Ken Krugler commented on FLINK-9506: @swy - the questions about setting up RocksDB, and your

[jira] [Commented] (FLINK-9535) log4j.properties specified in env.java.options doesn't get picked.

[ https://issues.apache.org/jira/browse/FLINK-9535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503396#comment-16503396 ] Ken Krugler commented on FLINK-9535: I believe that {{log4j.configuration}} takes a path to a file,

[jira] [Commented] (FLINK-9506) Flink ReducingState.add causing more than 100% performance drop

[ https://issues.apache.org/jira/browse/FLINK-9506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16499560#comment-16499560 ] Ken Krugler commented on FLINK-9506: Why are you creating a new {{AggregrationFunction}} every time

[jira] [Commented] (FLINK-9442) Flink Scaling not working

[ https://issues.apache.org/jira/browse/FLINK-9442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16491708#comment-16491708 ] Ken Krugler commented on FLINK-9442: Hi there - before opening a bug in Jira, it would be best to post

[jira] [Created] (FLINK-9300) Improve error message when in-memory state is too large

Ken Krugler created FLINK-9300: -- Summary: Improve error message when in-memory state is too large Key: FLINK-9300 URL: https://issues.apache.org/jira/browse/FLINK-9300 Project: Flink Issue

[jira] [Created] (FLINK-9299) ProcessWindowFunction documentation Java examples have errors

Ken Krugler created FLINK-9299: -- Summary: ProcessWindowFunction documentation Java examples have errors Key: FLINK-9299 URL: https://issues.apache.org/jira/browse/FLINK-9299 Project: Flink

[jira] [Commented] (FLINK-9120) Task Manager Fault Tolerance issue

[ https://issues.apache.org/jira/browse/FLINK-9120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16422768#comment-16422768 ] Ken Krugler commented on FLINK-9120: Hi [~dhirajpraj] - this _might_ be a bug, but it's best to first

[jira] [Commented] (FLINK-9058) Relax ListState.addAll() and ListState.update() to take Iterable

[ https://issues.apache.org/jira/browse/FLINK-9058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1640#comment-1640 ] Ken Krugler commented on FLINK-9058: Would it make sense to file a related enhancement issue, for the

[jira] [Updated] (FLINK-8883) ExceptionUtils.rethrowIfFatalError should treat ThreadDeath as fatal

[ https://issues.apache.org/jira/browse/FLINK-8883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ken Krugler updated FLINK-8883: --- Summary: ExceptionUtils.rethrowIfFatalError should treat ThreadDeath as fatal (was:

[jira] [Created] (FLINK-8849) Wrong link from concepts/runtime to doc on chaining

Ken Krugler created FLINK-8849: -- Summary: Wrong link from concepts/runtime to doc on chaining Key: FLINK-8849 URL: https://issues.apache.org/jira/browse/FLINK-8849 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8848) bin/start-cluster.sh won't start jobmanager on master machine.

[ https://issues.apache.org/jira/browse/FLINK-8848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16385157#comment-16385157 ] Ken Krugler commented on FLINK-8848: Hi [~manifoldQAQ] - in general it's best to first post to the

[jira] [Commented] (FLINK-7477) Use "hadoop classpath" to augment classpath when available

[ https://issues.apache.org/jira/browse/FLINK-7477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16377679#comment-16377679 ] Ken Krugler commented on FLINK-7477: The odd stuff (some of which might be bogus)... # I had to

[jira] [Commented] (FLINK-8717) Flink seems to deadlock due to buffer starvation when iterating

[ https://issues.apache.org/jira/browse/FLINK-8717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16371539#comment-16371539 ] Ken Krugler commented on FLINK-8717: Hi [~rrevol] - sadly the iteration improvements (FLIP-15,

[jira] [Commented] (FLINK-8717) Flink seems to deadlock due to buffer starvation when iterating

[ https://issues.apache.org/jira/browse/FLINK-8717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370301#comment-16370301 ] Ken Krugler commented on FLINK-8717: Hi [~rrevol] - I believe what you're seeing is caused by circular

[jira] [Commented] (FLINK-7477) Use "hadoop classpath" to augment classpath when available

[ https://issues.apache.org/jira/browse/FLINK-7477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16368677#comment-16368677 ] Ken Krugler commented on FLINK-7477: It works (at least when running with YARN via EMR). I believe

[jira] [Commented] (FLINK-7477) Use "hadoop classpath" to augment classpath when available

[ https://issues.apache.org/jira/browse/FLINK-7477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16367750#comment-16367750 ] Ken Krugler commented on FLINK-7477: Hi [~aljoscha] - I encountered this issue when running locally

[jira] [Commented] (FLINK-8658) NoClassDefFoundError: Could not initialize class org.elasticsearch.transport.client.PreBuiltTransportClient

[ https://issues.apache.org/jira/browse/FLINK-8658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364597#comment-16364597 ] Ken Krugler commented on FLINK-8658: Hi [~sathyadev] - if you're sure this is a Flink bug, then

[jira] [Updated] (FLINK-8625) Move OutputFlusher thread to Netty scheduled executor

[ https://issues.apache.org/jira/browse/FLINK-8625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ken Krugler updated FLINK-8625: --- Summary: Move OutputFlusher thread to Netty scheduled executor (was: Move OutputFlasherThread to

[jira] [Closed] (FLINK-8615) Configuring Apache Flink Local Set up with Pseudo distributed Yarn

[ https://issues.apache.org/jira/browse/FLINK-8615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ken Krugler closed FLINK-8615. -- Resolution: Not A Bug > Configuring Apache Flink Local Set up with Pseudo distributed Yarn >

[jira] [Commented] (FLINK-8615) Configuring Apache Flink Local Set up with Pseudo distributed Yarn

[ https://issues.apache.org/jira/browse/FLINK-8615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16357916#comment-16357916 ] Ken Krugler commented on FLINK-8615: https://flink.apache.org/community.html > Configuring Apache

[jira] [Commented] (FLINK-8615) Configuring Apache Flink Local Set up with Pseudo distributed Yarn

[ https://issues.apache.org/jira/browse/FLINK-8615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16357418#comment-16357418 ] Ken Krugler commented on FLINK-8615: Hi Karrtik - for a support/configuration question like this,

[jira] [Commented] (FLINK-7477) Use "hadoop classpath" to augment classpath when available

[ https://issues.apache.org/jira/browse/FLINK-7477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16347685#comment-16347685 ] Ken Krugler commented on FLINK-7477: I posted to the mailing list about an issue that this change

[jira] [Updated] (FLINK-7732) Test instability in Kafka end-to-end test (invalid Kafka offset)

[ https://issues.apache.org/jira/browse/FLINK-7732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ken Krugler updated FLINK-7732: --- Summary: Test instability in Kafka end-to-end test (invalid Kafka offset) (was: test instability in

[jira] [Commented] (FLINK-3839) Support wildcards in classpath parameters

[ https://issues.apache.org/jira/browse/FLINK-3839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15327406#comment-15327406 ] Ken Krugler commented on FLINK-3839: -C (or --classpath) seems like the right approach. Interesting

[jira] [Commented] (FLINK-3839) Support wildcards in classpath parameters

[ https://issues.apache.org/jira/browse/FLINK-3839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15326513#comment-15326513 ] Ken Krugler commented on FLINK-3839: Hi Robert, >From my email on this... bq. But this doesn’t seem

[jira] [Commented] (FLINK-3985) A metric with the name * was already registered

[ https://issues.apache.org/jira/browse/FLINK-3985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15305411#comment-15305411 ] Ken Krugler commented on FLINK-3985: Any chance this is related to the change made for [FLINK-3880]?

[jira] [Commented] (FLINK-3895) Remove Focs for Program Packaging via Plans

[ https://issues.apache.org/jira/browse/FLINK-3895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15278231#comment-15278231 ] Ken Krugler commented on FLINK-3895: Maybe "Remove Docs for Program..."? :) > Remove Focs for

[jira] [Created] (FLINK-3880) Use ConcurrentHashMap for Accumulators

Ken Krugler created FLINK-3880: -- Summary: Use ConcurrentHashMap for Accumulators Key: FLINK-3880 URL: https://issues.apache.org/jira/browse/FLINK-3880 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-3878) File cache doesn't support multiple duplicate temp directories

[ https://issues.apache.org/jira/browse/FLINK-3878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15273572#comment-15273572 ] Ken Krugler commented on FLINK-3878: I confirmed this fixes the issue - I was able to run with four

[jira] [Updated] (FLINK-3878) File cache doesn't support multiple duplicate temp directories

[ https://issues.apache.org/jira/browse/FLINK-3878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ken Krugler updated FLINK-3878: --- Attachment: FLINK-3878.patch > File cache doesn't support multiple duplicate temp directories >

[jira] [Created] (FLINK-3878) File cache doesn't support multiple duplicate temp directories

Ken Krugler created FLINK-3878: -- Summary: File cache doesn't support multiple duplicate temp directories Key: FLINK-3878 URL: https://issues.apache.org/jira/browse/FLINK-3878 Project: Flink

[jira] [Created] (FLINK-3839) Support wildcards in classpath parameters

Ken Krugler created FLINK-3839: -- Summary: Support wildcards in classpath parameters Key: FLINK-3839 URL: https://issues.apache.org/jira/browse/FLINK-3839 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3838) CLI parameter parser is munging application params

Ken Krugler created FLINK-3838: -- Summary: CLI parameter parser is munging application params Key: FLINK-3838 URL: https://issues.apache.org/jira/browse/FLINK-3838 Project: Flink Issue Type: Bug