Issue adding new IO(InfluxDB) with coder in Apache flink

Hi Dev, We have developed our own sdk io functions for read/write InfluxDBIO operations in apache BEAM. it is works with default coder, which is StringUtf8Coder.of(). PCollection output = pipeline.apply( InfluxDbIO.read() .withUri("http://localhost:8086";)

Re: Re: Re: Question about type cast in ExpressionReducer's reduce procedure

Hi Aegeaner, I have replied you on FLINK-7036. Regards, Jark 2017-06-29 23:45 GMT+08:00 郭健 : > Thanks Jark, > I have captured the generated code as follow, noticed one line: `int > result$4;` , maybe it’s the result of ExpressionReducer’s type casting. > > > public class ExpressionReducer

[jira] [Created] (FLINK-7049) TestingApplicationMaster keeps running after integration tests finish

Ted Yu created FLINK-7049: - Summary: TestingApplicationMaster keeps running after integration tests finish Key: FLINK-7049 URL: https://issues.apache.org/jira/browse/FLINK-7049 Project: Flink Issue

[jira] [Created] (FLINK-7048) Define javadoc skipping in travis watchdog script

Chesnay Schepler created FLINK-7048: --- Summary: Define javadoc skipping in travis watchdog script Key: FLINK-7048 URL: https://issues.apache.org/jira/browse/FLINK-7048 Project: Flink Issue T

[jira] [Created] (FLINK-7047) Reorganize build profiles

Chesnay Schepler created FLINK-7047: --- Summary: Reorganize build profiles Key: FLINK-7047 URL: https://issues.apache.org/jira/browse/FLINK-7047 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7046) Hide logging about downloaded artifacts on travis

Chesnay Schepler created FLINK-7046: --- Summary: Hide logging about downloaded artifacts on travis Key: FLINK-7046 URL: https://issues.apache.org/jira/browse/FLINK-7046 Project: Flink Issue T

Re: Re: Switch to Scala 2.11 as a default build profile

+10 I think it makes sense spark is also using 2.11 as the default for quite some time. On Thu, Jun 29, 2017 at 8:14 PM, Bowen Li wrote: > EMR's builtin Flink is always 1 or 2 versions behind Flink latest release. > We choose to install Flink on EMR ourselves. > > On Thu, Jun 29, 2017 at 2:37 AM

[jira] [Created] (FLINK-7045) Reduce element count of UdfStreamOperatorCheckpointingITCase

Chesnay Schepler created FLINK-7045: --- Summary: Reduce element count of UdfStreamOperatorCheckpointingITCase Key: FLINK-7045 URL: https://issues.apache.org/jira/browse/FLINK-7045 Project: Flink

Re: Re: Switch to Scala 2.11 as a default build profile

EMR's builtin Flink is always 1 or 2 versions behind Flink latest release. We choose to install Flink on EMR ourselves. On Thu, Jun 29, 2017 at 2:37 AM, 郭健 wrote: > +1 > Most of the time I need to build scala-2.11 version, although I can use > the script tools/change-version.sh to change scala v

[jira] [Created] (FLINK-7044) Add methods to the client API that take the stateDescriptor itself.

Kostas Kloudas created FLINK-7044: - Summary: Add methods to the client API that take the stateDescriptor itself. Key: FLINK-7044 URL: https://issues.apache.org/jira/browse/FLINK-7044 Project: Flink

[jira] [Created] (FLINK-7043) Optimize state handling in NFA

Kostas Kloudas created FLINK-7043: - Summary: Optimize state handling in NFA Key: FLINK-7043 URL: https://issues.apache.org/jira/browse/FLINK-7043 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7042) Fix jar file discovery in YARN tests

Greg Hogan created FLINK-7042: - Summary: Fix jar file discovery in YARN tests Key: FLINK-7042 URL: https://issues.apache.org/jira/browse/FLINK-7042 Project: Flink Issue Type: Bug Compon

Re: [DISCUSS] Release 1.3.2 planning

Gordon and I found this (in my opinion) blocking issue: https://issues.apache.org/jira/browse/FLINK-7041 I’m trying to quickly provide a fix. > On 26. Jun 2017, at 15:30, Timo Walther wrote: > > I just opened a PR which should be included in

[jira] [Created] (FLINK-7041) Deserialize StateBackend from JobCheckpointingSettings with user classloader

Aljoscha Krettek created FLINK-7041: --- Summary: Deserialize StateBackend from JobCheckpointingSettings with user classloader Key: FLINK-7041 URL: https://issues.apache.org/jira/browse/FLINK-7041 Proj

Re: Re: Re: Question about type cast in ExpressionReducer's reduce procedure

Thanks Jark, I have captured the generated code as follow, noticed one line: `int result$4;` , maybe it’s the result of ExpressionReducer’s type casting. public class ExpressionReducer$6 extends org.apache.flink.api.common.functions.RichMapFunction { transient org.apac

[jira] [Created] (FLINK-7040) Define Dispatcher interface

Till Rohrmann created FLINK-7040: Summary: Define Dispatcher interface Key: FLINK-7040 URL: https://issues.apache.org/jira/browse/FLINK-7040 Project: Flink Issue Type: Sub-task Re

Re: [外部邮件] Re: Question about type cast in ExpressionReducer's reduce procedure

That's wired. Can you print the generated code ? Add this line before https://github.com/apache/flink/blob/master/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/ExpressionReducer.scala#L96 println(generatedFunction.code) 2017-06-29 14:50 GMT+08:00 郭健 : > Hi Jark Wu, >

[jira] [Created] (FLINK-7039) Increase forkCountTestPackage for sudo-based Trav

Greg Hogan created FLINK-7039: - Summary: Increase forkCountTestPackage for sudo-based Trav Key: FLINK-7039 URL: https://issues.apache.org/jira/browse/FLINK-7039 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7038) Several misused "KeyedDataStream" term in docs and Javadocs

Tzu-Li (Gordon) Tai created FLINK-7038: -- Summary: Several misused "KeyedDataStream" term in docs and Javadocs Key: FLINK-7038 URL: https://issues.apache.org/jira/browse/FLINK-7038 Project: Flink

Re: Re: Switch to Scala 2.11 as a default build profile

+1 Most of the time I need to build scala-2.11 version, although I can use the script tools/change-version.sh to change scala version in all poms, it breaks the code consistency with the master branch. Aegeaner On 6/28/17, 22:23, "Piotr Nowojski" wrote: Yes, I know and I’m proposing to

[jira] [Created] (FLINK-7037) Remove scala suffix from flink-examples module

Chesnay Schepler created FLINK-7037: --- Summary: Remove scala suffix from flink-examples module Key: FLINK-7037 URL: https://issues.apache.org/jira/browse/FLINK-7037 Project: Flink Issue Type

[jira] [Created] (FLINK-7036) Type cast in ExpressionReducer's reduce broke CodeGen's compile stage

Aegeaner created FLINK-7036: --- Summary: Type cast in ExpressionReducer's reduce broke CodeGen's compile stage Key: FLINK-7036 URL: https://issues.apache.org/jira/browse/FLINK-7036 Project: Flink Is

Re: Switch to Scala 2.11 as a default build profile

EMR has a flink package. Just go to advanced options and but a checkbox on flink. No need to build yourself. > On 29. Jun 2017, at 05:56, Bowen Li wrote: > > +1. > > AWS EMR eco system is using Scala 2.11, and breaks with Scala 2.10. We had > to build several Flink components (e.g. flink-kines