Re: Flink Docker 1.5.x local mode

2018-07-23 Thread Till Rohrmann
Hi Thomas, I think the docker image has not been updated wrt the changes of Flip-6. In Flip-6 we no longer support a `local` execution mode which starts a JobMaster and a TaskExecutor in the same process. I think we need to update the images to start both processes if one wants to have single imag

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

2018-07-23 Thread vinoyang (JIRA)
vinoyang created FLINK-9914: --- Summary: Flink docker information in official website is out of date and should be update Key: FLINK-9914 URL: https://issues.apache.org/jira/browse/FLINK-9914 Project: Flink

[jira] [Created] (FLINK-9915) Add TO_BASE64 support function in table/sql API

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

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

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

[jira] [Created] (FLINK-9917) Remove superfluous lock from SlotSharingManager

2018-07-23 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-9917: Summary: Remove superfluous lock from SlotSharingManager Key: FLINK-9917 URL: https://issues.apache.org/jira/browse/FLINK-9917 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-9918) Outsource fastutil dependency to flink-shading.

2018-07-23 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-9918: - Summary: Outsource fastutil dependency to flink-shading. Key: FLINK-9918 URL: https://issues.apache.org/jira/browse/FLINK-9918 Project: Flink Issue Type: I

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

2018-07-23 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9919: --- Summary: Remove unit from fullRestarts metric docs Key: FLINK-9919 URL: https://issues.apache.org/jira/browse/FLINK-9919 Project: Flink Issue Type: Imp

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

2018-07-23 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9920: --- Summary: BucketingSinkFaultToleranceITCase fails on travis Key: FLINK-9920 URL: https://issues.apache.org/jira/browse/FLINK-9920 Project: Flink Issue T

[jira] [Created] (FLINK-9921) Update the rolling policy interface.

2018-07-23 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-9921: - Summary: Update the rolling policy interface. Key: FLINK-9921 URL: https://issues.apache.org/jira/browse/FLINK-9921 Project: Flink Issue Type: Sub-task

Re: Cherry picking FLINK-9753 and FLINK-9753 on release-1.6

2018-07-23 Thread Kostas Kloudas
Thanks for the +1’s. I added the relevant commits to the release-1.6 branch. Cheers, Kostas > On Jul 22, 2018, at 3:05 PM, Till Rohrmann wrote: > > I would be in favor of including FLINK-9903 and FLINK-9753 in Flink 1.6 > because they add more value for the user at a comparable small risk of >

Re: Flink Docker 1.5.x local mode

2018-07-23 Thread Thomas Weise
Hi Till, Thanks, this explains the confusion. I think there is still a benefit to run everything in a single Docker container for development purposes. I found the next closest match to be `./bin/start-cluster.sh`, even though that does not provide the combined logs in the console. I added https

[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 Is

[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 Is

[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 z

[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] [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] [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 C

Re: Cherry picking FLINK-9753 and FLINK-9753 on release-1.6

2018-07-23 Thread vino yang
I also see some file sink questions, so +1 for picking the PR about StreamingFileSink. Thanks, vino. 2018-07-23 20:53 GMT+08:00 Kostas Kloudas : > Thanks for the +1’s. > > I added the relevant commits to the release-1.6 branch. > > Cheers, > Kostas > > > On Jul 22, 2018, at 3:05 PM, Till Rohrman

[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 Com

[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 Feature

[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] [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: Webfront