[jira] [Commented] (FLINK-9875) Add concurrent creation of execution job vertex

2018-07-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553829#comment-16553829 ] ASF GitHub Bot commented on FLINK-9875: --- Github user TisonKun commented on the issue:

[GitHub] flink issue #6353: [FLINK-9875][runtime] Add concurrent creation of executio...

2018-07-23 Thread TisonKun
Github user TisonKun commented on the issue: https://github.com/apache/flink/pull/6353 @StephanEwen you're right. there is something could be done to parallelize the creation of input split. I wonder if the creation of InputSplit is always handled by InputFormat. There have been

[jira] [Commented] (FLINK-7761) Twitter example is not self-contained

2018-07-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553778#comment-16553778 ] ASF GitHub Bot commented on FLINK-7761: --- Github user aasyedd commented on the issue:

[GitHub] flink issue #4773: [FLINK-7761] [examples] Include shaded guava dependency i...

2018-07-23 Thread aasyedd
Github user aasyedd commented on the issue: https://github.com/apache/flink/pull/4773 I am facing the following error package com.fasterxml.jackson.databind does not exist; Please guide me how to fix it. Thanks. ---

[jira] [Commented] (FLINK-9931) watermark display bug.

2018-07-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553777#comment-16553777 ] ASF GitHub Bot commented on FLINK-9931: --- GitHub user luojiangyu opened a pull request:

[jira] [Updated] (FLINK-9931) watermark display bug.

2018-07-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9931: -- Labels: pull-request-available (was: ) > watermark display bug. > -- > >

[GitHub] flink pull request #6400: [FLINK-9931][ui] watermark display bug.

2018-07-23 Thread luojiangyu
GitHub user luojiangyu opened a pull request: https://github.com/apache/flink/pull/6400 [FLINK-9931][ui] watermark display bug. If the parallelism of the operator is bigger, the request url of watermark may access the limit of the length of http url, it results in watermark display

[jira] [Created] (FLINK-9931) watermark display bug.

2018-07-23 Thread luojiangyu (JIRA)
luojiangyu created FLINK-9931: - Summary: watermark display bug. Key: FLINK-9931 URL: https://issues.apache.org/jira/browse/FLINK-9931 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-9930) Flink slot memory leak after restarting job with static variables

2018-07-23 Thread Martin Shang (JIRA)
Martin Shang created FLINK-9930: --- Summary: Flink slot memory leak after restarting job with static variables Key: FLINK-9930 URL: https://issues.apache.org/jira/browse/FLINK-9930 Project: Flink

[jira] [Closed] (FLINK-9929) Add log10 mathematical function for table/sql API

2018-07-23 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang closed FLINK-9929. --- Resolution: Implemented > Add log10 mathematical function for table/sql API >

[jira] [Updated] (FLINK-5860) Replace all the file creating from java.io.tmpdir with TemporaryFolder

2018-07-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-5860: -- Labels: pull-request-available starter (was: starter) > Replace all the file creating from

[jira] [Commented] (FLINK-5860) Replace all the file creating from java.io.tmpdir with TemporaryFolder

2018-07-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553744#comment-16553744 ] ASF GitHub Bot commented on FLINK-5860: --- GitHub user maheshsenni opened a pull request:

[GitHub] flink pull request #6399: [FLINK-5860] [tests] Replace java.io.tmpdir with J...

2018-07-23 Thread maheshsenni
GitHub user maheshsenni opened a pull request: https://github.com/apache/flink/pull/6399 [FLINK-5860] [tests] Replace java.io.tmpdir with JUnit TemporaryFolder in tests ## What is the purpose of the change JUnit's TemporaryFolder is a better way to handle temporary folders

[jira] [Created] (FLINK-9929) Add log10 mathematical function for table/sql API

2018-07-23 Thread vinoyang (JIRA)
vinoyang created FLINK-9929: --- Summary: Add log10 mathematical function for table/sql API Key: FLINK-9929 URL: https://issues.apache.org/jira/browse/FLINK-9929 Project: Flink Issue Type: New

[jira] [Created] (FLINK-9928) Add LOG2 function for table/sql API

2018-07-23 Thread vinoyang (JIRA)
vinoyang created FLINK-9928: --- Summary: Add LOG2 function for table/sql API Key: FLINK-9928 URL: https://issues.apache.org/jira/browse/FLINK-9928 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type

2018-07-23 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-9294: - Description: Most of the UDF function signatures that includes composite types such as *{{MAP}}*,

[jira] [Closed] (FLINK-9726) Enable job task manager isolation use tag support

2018-07-23 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu closed FLINK-9726. - Resolution: Duplicate Duplicated > Enable job task manager isolation use tag support >

[jira] [Closed] (FLINK-9096) flip 6 allocates different resources for different jobs

2018-07-23 Thread Renjie Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu closed FLINK-9096. - Resolution: Duplicate Duplication of 5131 > flip 6 allocates different resources for different jobs >

[jira] [Assigned] (FLINK-9924) Upgrade zookeeper to 3.4.13

2018-07-23 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9924: --- Assignee: vinoyang > Upgrade zookeeper to 3.4.13 > --- > >

[jira] [Assigned] (FLINK-7550) Give names to REST client/server for clearer logging.

2018-07-23 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-7550: --- Assignee: vinoyang > Give names to REST client/server for clearer logging. >

[jira] [Assigned] (FLINK-9919) Remove unit from fullRestarts metric docs

2018-07-23 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9919: --- Assignee: vinoyang > Remove unit from fullRestarts metric docs >

[jira] [Commented] (FLINK-9061) add entropy to s3 path for better scalability

2018-07-23 Thread Steve Loughran (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553596#comment-16553596 ] Steve Loughran commented on FLINK-9061: --- It'd still be good to conduct some experiments here about

[jira] [Updated] (FLINK-9927) Error in Python Stream API example on website

2018-07-23 Thread Joe Malt (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Malt updated FLINK-9927: Description: The [Python Programming Guide (Streaming) 

[jira] [Created] (FLINK-9927) Error in Python Stream API example on website

2018-07-23 Thread Joe Malt (JIRA)
Joe Malt created FLINK-9927: --- Summary: Error in Python Stream API example on website Key: FLINK-9927 URL: https://issues.apache.org/jira/browse/FLINK-9927 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-9926) Allow for ShardConsumer override in Kinesis consumer

2018-07-23 Thread Thomas Weise (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-9926: Description: There are various reasons why the user may want to override the consumer. Examples

[jira] [Created] (FLINK-9926) Allow for ShardConsumer override in Kinesis consumer

2018-07-23 Thread Thomas Weise (JIRA)
Thomas Weise created FLINK-9926: --- Summary: Allow for ShardConsumer override in Kinesis consumer Key: FLINK-9926 URL: https://issues.apache.org/jira/browse/FLINK-9926 Project: Flink Issue Type:

[jira] [Commented] (FLINK-9630) Kafka09PartitionDiscoverer cause connection leak on TopicAuthorizationException

2018-07-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553487#comment-16553487 ] ASF GitHub Bot commented on FLINK-9630: --- Github user ubyyj commented on the issue:

[GitHub] flink issue #6336: [FLINK-9630] [connector] Kafka09PartitionDiscoverer cause...

2018-07-23 Thread ubyyj
Github user ubyyj commented on the issue: https://github.com/apache/flink/pull/6336 @tzulitai is there anything else we need to do before we get this merged? ---

[jira] [Commented] (FLINK-9892) Disable local recovery in Jepsen tests

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

[jira] [Resolved] (FLINK-9892) Disable local recovery in Jepsen tests

2018-07-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9892. -- Resolution: Fixed Fixed via master: c9a3a8a395d01c2a729d0d86c9ef9cced08e2ba0 1.6.0:

[GitHub] flink pull request #6369: [FLINK-9892][tests] Disable local recovery in Jeps...

2018-07-23 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6369 ---

[jira] [Created] (FLINK-9925) ClientTest.testSimpleRequests fails on Travis

2018-07-23 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-9925: Summary: ClientTest.testSimpleRequests fails on Travis Key: FLINK-9925 URL: https://issues.apache.org/jira/browse/FLINK-9925 Project: Flink Issue Type: Bug

[jira] [Resolved] (FLINK-9838) Slot request failed Exceptions after completing a job

2018-07-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9838. -- Resolution: Fixed Fix Version/s: 1.6.0 1.5.2 Fixed via master:

[jira] [Closed] (FLINK-9908) Inconsistent state of SlotPool after ExecutionGraph cancellation

2018-07-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9908. Resolution: Fixed Fixed via master: c897471ddbe25ed85b9f9ec6b15fdbd11cf0cec5 1.6.0:

[jira] [Closed] (FLINK-9910) Non-queued scheduling failure sometimes does not return the slot

2018-07-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9910. Resolution: Fixed Fixed via master: 0180d068565d99db1db998944686064ceddf398f 1.6.0:

[jira] [Closed] (FLINK-9909) Remove cancellation of input futures from ConjunctFutures

2018-07-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9909. Resolution: Fixed Fixed via master: 9afda733a90a72be75ced9567452c6a7a5e3dc8c 1.6.0:

[jira] [Closed] (FLINK-9911) SlotPool#failAllocation is called outside of main thread

2018-07-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9911. Resolution: Fixed Fixed via master: f1c83a15852b50b004b5916d7da3212b68a89594 1.6.0:

[jira] [Commented] (FLINK-9911) SlotPool#failAllocation is called outside of main thread

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

[jira] [Commented] (FLINK-9838) Slot request failed Exceptions after completing a job

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

[GitHub] flink pull request #6383: [FLINK-9908][scheduling] Do not cancel individual ...

2018-07-23 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6383 ---

[GitHub] flink pull request #6385: [FLINK-9910][scheduling] Execution#scheduleForeExe...

2018-07-23 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6385 ---

[jira] [Commented] (FLINK-9909) Remove cancellation of input futures from ConjunctFutures

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

[jira] [Commented] (FLINK-9908) Inconsistent state of SlotPool after ExecutionGraph cancellation

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

[jira] [Commented] (FLINK-9910) Non-queued scheduling failure sometimes does not return the slot

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

[GitHub] flink pull request #6373: [FLINK-9838][logging] Don't log slot request failu...

2018-07-23 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6373 ---

[GitHub] flink pull request #6386: [FLINK-9911][JM] Use SlotPoolGateway to call failA...

2018-07-23 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6386 ---

[GitHub] flink pull request #6384: [FLINK-9909] ConjunctFuture does not cancel input ...

2018-07-23 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6384 ---

[jira] [Created] (FLINK-9924) Upgrade zookeeper to 3.4.13

2018-07-23 Thread Ted Yu (JIRA)
Ted Yu created FLINK-9924: - Summary: Upgrade zookeeper to 3.4.13 Key: FLINK-9924 URL: https://issues.apache.org/jira/browse/FLINK-9924 Project: Flink Issue Type: Task Reporter: Ted Yu

[jira] [Commented] (FLINK-9923) OneInputStreamTaskTest.testWatermarkMetrics fails on Travis

2018-07-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553393#comment-16553393 ] ASF GitHub Bot commented on FLINK-9923: --- Github user zentol commented on the issue:

[GitHub] flink issue #6398: [FLINK-9923][tests] Harden OneInputStreamTaskTest#testWat...

2018-07-23 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6398 Do you have a source for volatile longs not being supported in all JVM implementations? I'm asking since the (expected) behavior is defined in the [Java Language

[jira] [Closed] (FLINK-9922) OneInputStreamTaskTest.testWatermarkMetrics fails on Travis

2018-07-23 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9922. --- Resolution: Duplicate Fix Version/s: (was: 1.6.0) >

[jira] [Commented] (FLINK-9920) BucketingSinkFaultToleranceITCase fails on travis

2018-07-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553390#comment-16553390 ] Till Rohrmann commented on FLINK-9920: -- In the logs one sees the following exception {code} ERROR

[jira] [Commented] (FLINK-6222) YARN: setting environment variables in an easier fashion

2018-07-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553370#comment-16553370 ] ASF GitHub Bot commented on FLINK-6222: --- Github user dawidwys commented on the issue:

[GitHub] flink issue #6388: [FLINK-6222] Allow passing env variables to start scripts...

2018-07-23 Thread dawidwys
Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/6388 In the first place I thought it might make providing the variables a bit more flexible with `flink-env.sh`. In the end it is just a bash script, but the longer I think the more convinced I am it

[GitHub] flink pull request #6398: [FLINK-9923][tests] Harden OneInputStreamTaskTest#...

2018-07-23 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/6398 [FLINK-9923][tests] Harden OneInputStreamTaskTest#testWatermarkMetrics ## What is the purpose of the change Convert the WatermarkGauge's field currentWatermark from long to AtomicLong

[jira] [Commented] (FLINK-9923) OneInputStreamTaskTest.testWatermarkMetrics fails on Travis

2018-07-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553365#comment-16553365 ] ASF GitHub Bot commented on FLINK-9923: --- GitHub user tillrohrmann opened a pull request:

[jira] [Updated] (FLINK-9923) OneInputStreamTaskTest.testWatermarkMetrics fails on Travis

2018-07-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9923: -- Labels: pull-request-available test-stability (was: test-stability) >

[jira] [Commented] (FLINK-9923) OneInputStreamTaskTest.testWatermarkMetrics fails on Travis

2018-07-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553358#comment-16553358 ] Till Rohrmann commented on FLINK-9923: -- I think the problem is that {{WatermarkGauge's}}

[jira] [Commented] (FLINK-9920) BucketingSinkFaultToleranceITCase fails on travis

2018-07-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553349#comment-16553349 ] Till Rohrmann commented on FLINK-9920: -- Another instance:

[jira] [Updated] (FLINK-9920) BucketingSinkFaultToleranceITCase fails on travis

2018-07-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9920: - Labels: test-stability (was: ) > BucketingSinkFaultToleranceITCase fails on travis >

[jira] [Updated] (FLINK-9920) BucketingSinkFaultToleranceITCase fails on travis

2018-07-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9920: - Priority: Critical (was: Major) > BucketingSinkFaultToleranceITCase fails on travis >

[jira] [Created] (FLINK-9923) OneInputStreamTaskTest.testWatermarkMetrics fails on Travis

2018-07-23 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-9923: Summary: OneInputStreamTaskTest.testWatermarkMetrics fails on Travis Key: FLINK-9923 URL: https://issues.apache.org/jira/browse/FLINK-9923 Project: Flink

[jira] [Created] (FLINK-9922) OneInputStreamTaskTest.testWatermarkMetrics fails on Travis

2018-07-23 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-9922: Summary: OneInputStreamTaskTest.testWatermarkMetrics fails on Travis Key: FLINK-9922 URL: https://issues.apache.org/jira/browse/FLINK-9922 Project: Flink

[jira] [Commented] (FLINK-6222) YARN: setting environment variables in an easier fashion

2018-07-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553296#comment-16553296 ] ASF GitHub Bot commented on FLINK-6222: --- Github user zentol commented on the issue:

[GitHub] flink issue #6388: [FLINK-6222] Allow passing env variables to start scripts...

2018-07-23 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6388 If a feature isn't visibly documented chances are no one will use it ;) I'm not sure if the configuration page is the right place to put it, as it so far deals exclusively with settings set

[jira] [Closed] (FLINK-8770) CompletedCheckPoints stored on ZooKeeper is not up-to-date, when JobManager is restarted it fails to recover the job due to "checkpoint FileNotFound exception"

2018-07-23 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8770. --- Resolution: Cannot Reproduce Fix Version/s: (was: 1.5.2) > CompletedCheckPoints

[jira] [Updated] (FLINK-9499) Allow REST API for running a job to provide job configuration as body of POST request

2018-07-23 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9499: Issue Type: New Feature (was: Improvement) > Allow REST API for running a job to provide

[jira] [Updated] (FLINK-9706) DispatcherTest#testSubmittedJobGraphListener fails on Travis

2018-07-23 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9706: Issue Type: Bug (was: Improvement) > DispatcherTest#testSubmittedJobGraphListener fails

[jira] [Reopened] (FLINK-9499) Allow REST API for running a job to provide job configuration as body of POST request

2018-07-23 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-9499: - > Allow REST API for running a job to provide job configuration as body of POST > request >

[jira] [Reopened] (FLINK-9793) When submitting a flink job with yarn-cluster, flink-dist*.jar is repeatedly uploaded

2018-07-23 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-9793: - > When submitting a flink job with yarn-cluster, flink-dist*.jar is repeatedly > uploaded >

[jira] [Closed] (FLINK-9793) When submitting a flink job with yarn-cluster, flink-dist*.jar is repeatedly uploaded

2018-07-23 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9793. --- Resolution: Fixed > When submitting a flink job with yarn-cluster, flink-dist*.jar is

[jira] [Updated] (FLINK-9888) Remove unsafe defaults from release scripts

2018-07-23 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9888: Issue Type: Improvement (was: Bug) > Remove unsafe defaults from release scripts >

[jira] [Closed] (FLINK-9888) Remove unsafe defaults from release scripts

2018-07-23 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9888. --- Resolution: Fixed > Remove unsafe defaults from release scripts >

[jira] [Closed] (FLINK-9499) Allow REST API for running a job to provide job configuration as body of POST request

2018-07-23 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9499. --- Resolution: Fixed > Allow REST API for running a job to provide job configuration as body of

[jira] [Updated] (FLINK-9793) When submitting a flink job with yarn-cluster, flink-dist*.jar is repeatedly uploaded

2018-07-23 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9793: Issue Type: Bug (was: Improvement) > When submitting a flink job with yarn-cluster,

[jira] [Reopened] (FLINK-9888) Remove unsafe defaults from release scripts

2018-07-23 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-9888: - > Remove unsafe defaults from release scripts > ---

[jira] [Comment Edited] (FLINK-9159) Sanity check default timeout values

2018-07-23 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553247#comment-16553247 ] Gary Yao edited comment on FLINK-9159 at 7/23/18 6:42 PM: -- [~till.rohrmann]

[jira] [Comment Edited] (FLINK-9159) Sanity check default timeout values

2018-07-23 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553247#comment-16553247 ] Gary Yao edited comment on FLINK-9159 at 7/23/18 6:41 PM: -- [~till.rohrmann]

[jira] [Comment Edited] (FLINK-9159) Sanity check default timeout values

2018-07-23 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553247#comment-16553247 ] Gary Yao edited comment on FLINK-9159 at 7/23/18 6:41 PM: -- [~till.rohrmann]

[jira] [Comment Edited] (FLINK-9159) Sanity check default timeout values

2018-07-23 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553247#comment-16553247 ] Gary Yao edited comment on FLINK-9159 at 7/23/18 6:41 PM: -- [~till.rohrmann]

[jira] [Commented] (FLINK-9159) Sanity check default timeout values

2018-07-23 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553247#comment-16553247 ] Gary Yao commented on FLINK-9159: - [~till.rohrmann] Find below the config keys that I had a look at and

[jira] [Comment Edited] (FLINK-4319) Rework Cluster Management (FLIP-6)

2018-07-23 Thread Yinan Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553111#comment-16553111 ] Yinan Li edited comment on FLINK-4319 at 7/23/18 5:05 PM: -- Thanks for the

[jira] [Commented] (FLINK-4319) Rework Cluster Management (FLIP-6)

2018-07-23 Thread Yinan Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553111#comment-16553111 ] Yinan Li commented on FLINK-4319: - Thanks for the detailed answers again, [~till.rohrmann]! A couple of

[jira] [Resolved] (FLINK-9846) Add a Kafka table sink factory

2018-07-23 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-9846. - Resolution: Fixed Fix Version/s: 1.6.0 Fixed in 1.7.0:

[jira] [Commented] (FLINK-9846) Add a Kafka table sink factory

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

[GitHub] flink pull request #6387: [FLINK-9846] [table] Add a Kafka table sink factor...

2018-07-23 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6387 ---

[jira] [Commented] (FLINK-9694) Potentially NPE in CompositeTypeSerializerConfigSnapshot constructor

2018-07-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553026#comment-16553026 ] ASF GitHub Bot commented on FLINK-9694: --- Github user yanghua commented on the issue:

[GitHub] flink issue #6231: [FLINK-9694] Potentially NPE in CompositeTypeSerializerCo...

2018-07-23 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6231 @pnowojski thanks for giving a solution, I will try to verify it in our inner Flink version. ---

[jira] [Commented] (FLINK-6222) YARN: setting environment variables in an easier fashion

2018-07-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553015#comment-16553015 ] ASF GitHub Bot commented on FLINK-6222: --- Github user dawidwys commented on the issue:

[GitHub] flink issue #6388: [FLINK-6222] Allow passing env variables to start scripts...

2018-07-23 Thread dawidwys
Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/6388 I added a small section. I was thorn a little in the first place if we should make it highly visible in docs as it might be wrongly understood those variables will be distributed to the cluster as

[jira] [Commented] (FLINK-9916) Add FROM_BASE64 function for table/sql API

2018-07-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553012#comment-16553012 ] ASF GitHub Bot commented on FLINK-9916: --- GitHub user yanghua opened a pull request:

[jira] [Updated] (FLINK-9916) Add FROM_BASE64 function for table/sql API

2018-07-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9916: -- Labels: pull-request-available (was: ) > Add FROM_BASE64 function for table/sql API >

[GitHub] flink pull request #6397: [FLINK-9916] Add FROM_BASE64 function for table/sq...

2018-07-23 Thread yanghua
GitHub user yanghua opened a pull request: https://github.com/apache/flink/pull/6397 [FLINK-9916] Add FROM_BASE64 function for table/sql API ## What is the purpose of the change *This pull request adds FROM_BASE64 function for table/sql API* ## Brief change log

[jira] [Comment Edited] (FLINK-8712) Cannot execute job with multiple slot sharing groups on LocalExecutor

2018-07-23 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553008#comment-16553008 ] Konstantin Knauf edited comment on FLINK-8712 at 7/23/18 3:38 PM: --  

[jira] [Commented] (FLINK-8712) Cannot execute job with multiple slot sharing groups on LocalExecutor

2018-07-23 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553008#comment-16553008 ] Konstantin Knauf commented on FLINK-8712: -   {code:java} Configuration conf = new

[jira] [Commented] (FLINK-9914) Flink docker information in official website is out of date and should be update

2018-07-23 Thread Patrick Lucas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553007#comment-16553007 ] Patrick Lucas commented on FLINK-9914: -- The version numbers in those docs are just for example

[jira] [Assigned] (FLINK-9806) Add a canonical link element to documentation HTML

2018-07-23 Thread Patrick Lucas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Patrick Lucas reassigned FLINK-9806: Assignee: Patrick Lucas > Add a canonical link element to documentation HTML >

[jira] [Updated] (FLINK-9806) Add a canonical link element to documentation HTML

2018-07-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9806: -- Labels: pull-request-available (was: ) > Add a canonical link element to documentation HTML >

[jira] [Commented] (FLINK-9806) Add a canonical link element to documentation HTML

2018-07-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16553000#comment-16553000 ] ASF GitHub Bot commented on FLINK-9806: --- GitHub user patricklucas opened a pull request:

[GitHub] flink pull request #6396: [FLINK-9806][docs] Add canonical link element to d...

2018-07-23 Thread patricklucas
GitHub user patricklucas opened a pull request: https://github.com/apache/flink/pull/6396 [FLINK-9806][docs] Add canonical link element to docs ## What is the purpose of the change Flink's documentation's SEO is a mess, with web searches often returning results from many

  1   2   3   4   >