[jira] [Created] (FLINK-15141) Using decimal type in a sink table, the result returns a not match ValidationException

2019-12-08 Thread xiaojin.wy (Jira)
xiaojin.wy created FLINK-15141: -- Summary: Using decimal type in a sink table, the result returns a not match ValidationException Key: FLINK-15141 URL: https://issues.apache.org/jira/browse/FLINK-15141

Re: [DISCUSS] Drop Heap Backend Synchronous snapshots

2019-12-08 Thread Congxian Qiu
+1 from my side. Best, Congxian Yun Tang 于2019年12月6日周五 下午12:30写道: > +1 from my side for I did not see any real benefits if using synchronous > snapshots. > > Moreover, I think we should also remove the support of synchronous > snapshots in DefaultOpeatorStateBackend and deprecate the config >

Re: [DISCUSS] Adding e2e tests for Flink's Mesos integration

2019-12-08 Thread Yang Wang
Thanks Yangze for starting this discussion. Just share my thoughts. If the mesos official docker image could not meet our requirement, i suggest to build the image locally. We have done the same things for yarn e2e tests. This way is more flexible and easy to maintain. However, i have no idea

Reminder: Clean up 1.10.0 open issues

2019-12-08 Thread Yu Li
Hi All, Since we're approaching feature freeze and will cut branch for 1.10 release soon, while we still have 34 in-progress and 124 to-do issues [1]. Please check and clean up the open issues for 1.10.0. More specifically: * For JIRAs still in "Open" status, please change the fix version for

[jira] [Created] (FLINK-15140) Shuffle data compression does not work with BroadcastRecordWriter.

2019-12-08 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-15140: --- Summary: Shuffle data compression does not work with BroadcastRecordWriter. Key: FLINK-15140 URL: https://issues.apache.org/jira/browse/FLINK-15140 Project: Flink

Re: [VOTE] Release 1.8.3, release candidate #3

2019-12-08 Thread Jingsong Li
Hi Hequn, +1 (non-binding) Thank you for driving this. - Verified signatures and checksums - Maven build from source skip tests (Scala 2.11 and Scala 2.12) - Start local cluster and web ui is accessible (Scala 2.11 and Scala 2.12) - Submit WordCount example of both batch and streaming, good

Re: [DISCUSS] Migrate build infrastructure from Travis CI to Azure Pipelines

2019-12-08 Thread Congxian Qiu
+1 for migrating to Azure pipelines as this can have shorter build time, and faster response. Best, Congxian Xiyuan Wang 于2019年12月9日周一 上午10:13写道: > Hi Robert, > Thanks for bring up this topic. The 2 ARM machines(16cores) which I > donated is just for POC test. We(Huawei) can donate more

Re: [DISCUSS] Drop Kafka 0.8/0.9

2019-12-08 Thread Jingsong Li
Thanks Chesnay, +1 to make it official that we no longer actively develop them but user can still use. Best, Jingsong Lee On Mon, Dec 9, 2019 at 4:47 AM Chesnay Schepler wrote: > Users can continue to use the 1.9 versions of the 0.8/0.9 connectors > with future versions of Flink. > > We just

Re: [VOTE] Release 1.8.3, release candidate #3

2019-12-08 Thread jincheng sun
+1 (binding) - checked signatures [SUCCESS] - built from source without tests [SUCCESS] - run some tests in IDE [SUCCESS] - start local cluster and submit word count example [SUCCESS] - announcement PR for website looks good! (I have left a few comments) Best, Jincheng Hequn Cheng

[jira] [Created] (FLINK-15139) misc end to end test failed on 'SQL Client end-to-end test (Old planner)'

2019-12-08 Thread wangxiyuan (Jira)
wangxiyuan created FLINK-15139: -- Summary: misc end to end test failed on 'SQL Client end-to-end test (Old planner)' Key: FLINK-15139 URL: https://issues.apache.org/jira/browse/FLINK-15139 Project: Flink

[jira] [Created] (FLINK-15138) Add e2e Test for PyFlink

2019-12-08 Thread sunjincheng (Jira)
sunjincheng created FLINK-15138: --- Summary: Add e2e Test for PyFlink Key: FLINK-15138 URL: https://issues.apache.org/jira/browse/FLINK-15138 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-15137) Improve schema derivation for Avro format

2019-12-08 Thread Jark Wu (Jira)
Jark Wu created FLINK-15137: --- Summary: Improve schema derivation for Avro format Key: FLINK-15137 URL: https://issues.apache.org/jira/browse/FLINK-15137 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] Migrate build infrastructure from Travis CI to Azure Pipelines

2019-12-08 Thread Xiyuan Wang
Hi Robert, Thanks for bring up this topic. The 2 ARM machines(16cores) which I donated is just for POC test. We(Huawei) can donate more once moving to official Azure pipeline. :) Robert Metzger 于2019年12月6日周五 上午3:25写道: > Thanks for your comments Yun. > If there's strong support for idea 2, it

[jira] [Created] (FLINK-15136) Update the Chinese version of "Working with state"

2019-12-08 Thread Congxian Qiu(klion26) (Jira)
Congxian Qiu(klion26) created FLINK-15136: - Summary: Update the Chinese version of "Working with state" Key: FLINK-15136 URL: https://issues.apache.org/jira/browse/FLINK-15136 Project: Flink

[jira] [Created] (FLINK-15135) Adding e2e tests for Flink's Mesos integration

2019-12-08 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-15135: -- Summary: Adding e2e tests for Flink's Mesos integration Key: FLINK-15135 URL: https://issues.apache.org/jira/browse/FLINK-15135 Project: Flink Issue Type: Test

[jira] [Created] (FLINK-15134) Delete temporary files created in YarnClusterDescriptor

2019-12-08 Thread Zili Chen (Jira)
Zili Chen created FLINK-15134: - Summary: Delete temporary files created in YarnClusterDescriptor Key: FLINK-15134 URL: https://issues.apache.org/jira/browse/FLINK-15134 Project: Flink Issue

Re: [DISCUSS] FLIP-72: Introduce Pulsar Connector

2019-12-08 Thread Bowen Li
Hi Yijie, I took a look at the design doc. LGTM overall, left a few questions. On Tue, Dec 3, 2019 at 10:39 PM Becket Qin wrote: > Yes, you are absolutely right. Cannot believe I posted in the wrong > thread... > > On Wed, Dec 4, 2019 at 1:46 PM Jark Wu wrote: > >> Thanks Becket the the

[jira] [Created] (FLINK-15133) support sql_alchemy in Flink for broader python sql integration

2019-12-08 Thread Bowen Li (Jira)
Bowen Li created FLINK-15133: Summary: support sql_alchemy in Flink for broader python sql integration Key: FLINK-15133 URL: https://issues.apache.org/jira/browse/FLINK-15133 Project: Flink

Re: [DISCUSS] Drop Kafka 0.8/0.9

2019-12-08 Thread Chesnay Schepler
Users can continue to use the 1.9 versions of the 0.8/0.9 connectors with future versions of Flink. We just make it official that we no longer actively develop them, On 08/12/2019 12:22, Becket Qin wrote: Hi all, Sorry for being late on this thread. My hunch is that 0.8 and 0.9 is old enough

[ANNOUNCE] Weekly Community Update 2019/49

2019-12-08 Thread Konstantin Knauf
Dear community, happy to share this week's community digest with an update on Flink 1.8.3, a revival of the n-ary stream operator, a proposal to move our build infrastructure to Azure pipelines, and quite a few other topics. Enjoy. Flink Development == * [releases] The feature

[jira] [Created] (FLINK-15132) Checkpoint Coordinator does Checkpoint I/O in JobMaster Main Thread

2019-12-08 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-15132: Summary: Checkpoint Coordinator does Checkpoint I/O in JobMaster Main Thread Key: FLINK-15132 URL: https://issues.apache.org/jira/browse/FLINK-15132 Project: Flink

[jira] [Created] (FLINK-15131) Add Source API classes

2019-12-08 Thread Jiangjie Qin (Jira)
Jiangjie Qin created FLINK-15131: Summary: Add Source API classes Key: FLINK-15131 URL: https://issues.apache.org/jira/browse/FLINK-15131 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-15130) Drop "RequiredParameters" and "Options"

2019-12-08 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-15130: Summary: Drop "RequiredParameters" and "Options" Key: FLINK-15130 URL: https://issues.apache.org/jira/browse/FLINK-15130 Project: Flink Issue Type: Task

Re: [DISCUSS] Drop Kafka 0.8/0.9

2019-12-08 Thread Becket Qin
Hi all, Sorry for being late on this thread. My hunch is that 0.8 and 0.9 is old enough to deprecate. However, after checking the downloads statistics from Apache, I am not completely sure anymore. Here are some Kafka broker jar download stats from the past month according to Apache Nexus[1].

[jira] [Created] (FLINK-15129) Return JobClient instead of JobClient Future from executeAsync()

2019-12-08 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-15129: Summary: Return JobClient instead of JobClient Future from executeAsync() Key: FLINK-15129 URL: https://issues.apache.org/jira/browse/FLINK-15129 Project:

[jira] [Created] (FLINK-15128) Document support for Hive timestamp type

2019-12-08 Thread Rui Li (Jira)
Rui Li created FLINK-15128: -- Summary: Document support for Hive timestamp type Key: FLINK-15128 URL: https://issues.apache.org/jira/browse/FLINK-15128 Project: Flink Issue Type: Task