[jira] [Created] (FLINK-12389) flink codegen set String type for ByteBuffer fields

2019-05-01 Thread Yu Yang (JIRA)
Yu Yang created FLINK-12389: --- Summary: flink codegen set String type for ByteBuffer fields Key: FLINK-12389 URL: https://issues.apache.org/jira/browse/FLINK-12389 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-12388) Update the production readyness checklist

2019-05-01 Thread Seth Wiesman (JIRA)
Seth Wiesman created FLINK-12388: Summary: Update the production readyness checklist Key: FLINK-12388 URL: https://issues.apache.org/jira/browse/FLINK-12388 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-12387) Salesforce

2019-05-01 Thread Mukesh Jha (JIRA)
Mukesh Jha created FLINK-12387: -- Summary: Salesforce Key: FLINK-12387 URL: https://issues.apache.org/jira/browse/FLINK-12387 Project: Flink Issue Type: Test Reporter: Mukesh Jha

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

2019-05-01 Thread Rong Rong
Hi Shaoxuan/Weihua, Thanks for the proposal and driving the effort. I also replied to the original discussion thread, and still a +1 on moving towards the ski-learn model. I just left a few comments on the API details and some general questions. Please kindly take a look. There's another thread r

Re: Checkpoint Vs Job Completion

2019-05-01 Thread vijikarthi
It looks like the problem statement is similar to what we have in "FLIP-34: Terminate/Suspend Job with Savepoint"? -- Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/

Checkpoint Vs Job Completion

2019-05-01 Thread vijikarthi
Hi, I have a question regarding how checkpoint works when a job is getting finished. Let's imagine that I have a custom sink implementation which is making use of checkpointing mechanism to commit the writes (i.e., data will be flushed only when commit API call is invoked and the invocation of c

Re: [DISCUSS] Update our Roadmap

2019-05-01 Thread Bowen Li
+1 On Mon, Apr 29, 2019 at 11:41 PM jincheng sun wrote: > Hi Jeff&Fabian, > > I have open the PR about add Python Table API section to the roadmap. I > appreciate if you have time to look at it. :) > > https://github.com/apache/flink-web/pull/204 > > Regards, > Jincheng > > jincheng sun 于2019年4

[jira] [Created] (FLINK-12386) Support complete mapping between Flink and Hive data types

2019-05-01 Thread Bowen Li (JIRA)
Bowen Li created FLINK-12386: Summary: Support complete mapping between Flink and Hive data types Key: FLINK-12386 URL: https://issues.apache.org/jira/browse/FLINK-12386 Project: Flink Issue Type

[jira] [Created] (FLINK-12385) RestClusterClient can hang indefinitely during job submission

2019-05-01 Thread Matt Dailey (JIRA)
Matt Dailey created FLINK-12385: --- Summary: RestClusterClient can hang indefinitely during job submission Key: FLINK-12385 URL: https://issues.apache.org/jira/browse/FLINK-12385 Project: Flink

[jira] [Created] (FLINK-12384) Rolling the etcd servers causes "Connected to an old server; r-o mode will be unavailable"

2019-05-01 Thread Henrik (JIRA)
Henrik created FLINK-12384: -- Summary: Rolling the etcd servers causes "Connected to an old server; r-o mode will be unavailable" Key: FLINK-12384 URL: https://issues.apache.org/jira/browse/FLINK-12384 Projec

[jira] [Created] (FLINK-12383) "Log file environment variable 'log.file' is not set" despite web.log.path being set

2019-05-01 Thread Henrik (JIRA)
Henrik created FLINK-12383: -- Summary: "Log file environment variable 'log.file' is not set" despite web.log.path being set Key: FLINK-12383 URL: https://issues.apache.org/jira/browse/FLINK-12383 Project: Fli

[jira] [Created] (FLINK-12382) HA + ResourceManager exception: Fencing token not set

2019-05-01 Thread Henrik (JIRA)
Henrik created FLINK-12382: -- Summary: HA + ResourceManager exception: Fencing token not set Key: FLINK-12382 URL: https://issues.apache.org/jira/browse/FLINK-12382 Project: Flink Issue Type: Bug

Re: HA lock nodes, Checkpoints, and JobGraphs after failure

2019-05-01 Thread dyana . rose
Like all the best problems, I can't get this to reproduce locally. Everything has worked as expected. I started up a test job with 5 retained checkpoints, let it run and watched the nodes in zookeeper. Then shut down and restarted the Flink cluster. The ephemeral lock nodes in the retained chec

[jira] [Created] (FLINK-12381) Without failover (aka "HA") configured, full restarts' checkpointing crashes

2019-05-01 Thread Henrik (JIRA)
Henrik created FLINK-12381: -- Summary: Without failover (aka "HA") configured, full restarts' checkpointing crashes Key: FLINK-12381 URL: https://issues.apache.org/jira/browse/FLINK-12381 Project: Flink

[jira] [Created] (FLINK-12380) Add thread name in the log4j.properties

2019-05-01 Thread Yun Tang (JIRA)
Yun Tang created FLINK-12380: Summary: Add thread name in the log4j.properties Key: FLINK-12380 URL: https://issues.apache.org/jira/browse/FLINK-12380 Project: Flink Issue Type: Improvement