[jira] [Created] (FLINK-12595) KinesisDataFetcherTest.testOriginalExceptionIsPreservedWhenInterruptedDuringShutdown deadlocks

2019-05-22 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-12595: Summary: KinesisDataFetcherTest.testOriginalExceptionIsPreservedWhenInterruptedDuringShutdown deadlocks Key: FLINK-12595 URL: https://issues.apache.org/jira/browse/FLINK-

Re: [DISCUSS] FLIP to Restructure, Update & Rework Apache Flink's Documentation

2019-05-22 Thread Jark Wu
Hi Konstantin, Thanks a lot for preparing this FLIP. It's great to see we can continue the work on improving documentation. I have read it and +1 from my side. And I will coordination Chinese translation work and this FLIP. Regards, Jark On Wed, 22 May 2019 at 16:02, Robert Metzger wrote: >

[jira] [Created] (FLINK-12594) Make Job ID Configurable for a Job Cluster

2019-05-22 Thread Chaoran Yu (JIRA)
Chaoran Yu created FLINK-12594: -- Summary: Make Job ID Configurable for a Job Cluster Key: FLINK-12594 URL: https://issues.apache.org/jira/browse/FLINK-12594 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-12593) Revise the document for CEP

2019-05-22 Thread Liya Fan (JIRA)
Liya Fan created FLINK-12593: Summary: Revise the document for CEP Key: FLINK-12593 URL: https://issues.apache.org/jira/browse/FLINK-12593 Project: Flink Issue Type: Improvement Compone

Re: Kinesis Connector RuntimeException

2019-05-22 Thread Thomas Weise
The error message says it all: Permission denied: tmp/amazon-kinesis-producer-native-binaries The producer as such is working, we run it on Flink 1.8 at scale. Thomas On Wed, May 22, 2019 at 8:36 AM PoolakkalMukkath, Shakir < shakir_poolakkalmukk...@comcast.com> wrote: > Hi Flink Team, > > > >

Kinesis Connector RuntimeException

2019-05-22 Thread PoolakkalMukkath, Shakir
Hi Flink Team, Getting the below error when using Kinesis Connector, FlinkKinesisProducer. Can you help ? I am using Flink 1.8 version Scala 2.11, both Flows and cluster. And this is on a standalone zookeeper ha cluster. java.lang.RuntimeException: Could not copy native binaries to tem

Re: [SURVEY] Usage of flink-ml and [DISCUSS] Delete flink-ml

2019-05-22 Thread Shaoxuan Wang
Hi Chesnay, Yes, you are right. There is not any active commit planned for the legacy Flink-ml package. It does not matter delete it now or later. I will open a PR and remove it. Shaoxuan On Wed, May 22, 2019 at 7:05 PM Chesnay Schepler wrote: > I believe we can remove it regardless since users

[jira] [Created] (FLINK-12592) StreamTableEnvironment object has no attribute connect

2019-05-22 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-12592: - Summary: StreamTableEnvironment object has no attribute connect Key: FLINK-12592 URL: https://issues.apache.org/jira/browse/FLINK-12592 Project: Flink Issu

Re: [DISCUSS] Correct the flink pom `artifactId` config before flink 1.9 release

2019-05-22 Thread Chesnay Schepler
You do have a point, but your output is mostly incorrect. There are only 3 modules that have a suffix, which don't need it: * flink-connector-hive * flink-queryable-state-client-java * flink-table-api-scala The remaining do need it since they have dependencies with a scala-suf

Re: [DISCUSS] Correct the flink pom `artifactId` config before flink 1.9 release

2019-05-22 Thread Chesnay Schepler
You do have a point, but your output is mostly incorrect. There are only 3 modules that have a suffix, which don't need it: * flink-connector-hive * flink-queryable-state-client-java * flink-table-api-scala The remaining do need it since they have dependencies with a scala-suf

[DISCUSS] Correct the flink pom `artifactId` config before flink 1.9 release

2019-05-22 Thread jincheng sun
Hi all, I find a shell issue in `verify_scala_suffixes.sh`(line 145) as follows: ``` grep "${module}_\d\+\.\d\+" "{}" ``` This code want to find out all modules that the module's `artifactId` with a `scala_binary_version` suffix. but the problem is our all `artifactId` value is in the pattern of

[jira] [Created] (FLINK-12591) StatsDReporterTest is unstable

2019-05-22 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-12591: -- Summary: StatsDReporterTest is unstable Key: FLINK-12591 URL: https://issues.apache.org/jira/browse/FLINK-12591 Project: Flink Issue Type: Bug

Re: [SURVEY] Usage of flink-ml and [DISCUSS] Delete flink-ml

2019-05-22 Thread Chesnay Schepler
I believe we can remove it regardless since users could just use the 1.8 version against future releases. Generally speaking, any library/connector that is no longer actively developed can be removed from the project as existing users can always rely on previous versions, which should continue

Re: [DISCUSS] FLIP-39: Flink ML pipeline and ML libs

2019-05-22 Thread Shaoxuan Wang
Another consensus (from the offline discussion) is that we will delete/deprecate flink-libraries/flink-ml. I have started a survey and discussion [1] in dev/user-ml to collect the feedback. Depending on the replies, we will decide if we shall delete it in Flink1.9 or deprecate&delete in the next re

[SURVEY] Usage of flink-ml and [DISCUSS] Delete flink-ml

2019-05-22 Thread Shaoxuan Wang
Hi Flink community, We plan to delete/deprecate the legacy flink-libraries/flink-ml package in Flink1.9, and replace it with the new flink-ml interface proposed in FLIP39 (FLINK-12470). Before we remove this package, I want to reach out to you and ask if there is any active project still uses this

[jira] [Created] (FLINK-12590) Replace http links in documentation

2019-05-22 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-12590: Summary: Replace http links in documentation Key: FLINK-12590 URL: https://issues.apache.org/jira/browse/FLINK-12590 Project: Flink Issue Type: Impro

Re: rmetz...@apache.org

2019-05-22 Thread Robert Metzger
Thanks for reaching out. For the others on the list: I also received this email privately and responded there already. On Wed, May 22, 2019 at 10:53 AM tobeh...@gmail.com wrote: > Hi Mr. Metzger. > I've been studying flink for 4 months. > I am interesting in Translate the "Documents for Apache

rmetz...@apache.org

2019-05-22 Thread tobehalo
Hi Mr. Metzger. I've been studying flink for 4 months. I am interesting in Translate the "Documents for Apache Flink" into Chinese. Would you please give me the contributor permission? My JIRA ID is zxhe. My JIRA fullname is ZeXiong He

[jira] [Created] (FLINK-12589) SQL end-to-end test fails on Travis

2019-05-22 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-12589: Summary: SQL end-to-end test fails on Travis Key: FLINK-12589 URL: https://issues.apache.org/jira/browse/FLINK-12589 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-12588) Add TableSchema for Python Table API

2019-05-22 Thread Wei Zhong (JIRA)
Wei Zhong created FLINK-12588: - Summary: Add TableSchema for Python Table API Key: FLINK-12588 URL: https://issues.apache.org/jira/browse/FLINK-12588 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12587) Add pure-API Watermark class

2019-05-22 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-12587: Summary: Add pure-API Watermark class Key: FLINK-12587 URL: https://issues.apache.org/jira/browse/FLINK-12587 Project: Flink Issue Type: Improvement

Re: contribute to Apache Flink

2019-05-22 Thread Robert Metzger
Hey guys, I'm very happy to hear that you are interested in contributing to Flink. I have checked your past activity on Jira, and I didn't see any interaction with a Flink ticket yet. The Flink community has recently discussed that we intend to change the process of giving people contributor permis

Re: [DISCUSS] FLIP to Restructure, Update & Rework Apache Flink's Documentation

2019-05-22 Thread Robert Metzger
Thanks a lot for working on this FLIP! I just read it, and it seems well written and well thought out. +1 from my side to put it into Confluence and start working on the docs :) On Mon, May 20, 2019 at 7:23 PM Konstantin Knauf wrote: > Hi all, > > following our unsuccessful application to Sea