Re: [RESULT][VOTE] Migrate to sponsored Travis account

2019-07-08 Thread Chesnay Schepler
Yes we can do that; for the time being you can add an empty commit to re-trigger the CI. On 08/07/2019 03:49, Congxian Qiu wrote: As we used flink bot to trigger the CI test, could we add a command for flink bot to retrigger the CI(sometimes we may encounter some flaky tests) Best, Congxian

[jira] [Created] (FLINK-13139) Various Hive tests fail on Travis

2019-07-08 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-13139: - Summary: Various Hive tests fail on Travis Key: FLINK-13139 URL: https://issues.apache.org/jira/browse/FLINK-13139 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-13140) PushFilterIntoTableSourceScanRuleTest.testWithUd fails on Travis

2019-07-08 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-13140: - Summary: PushFilterIntoTableSourceScanRuleTest.testWithUd fails on Travis Key: FLINK-13140 URL: https://issues.apache.org/jira/browse/FLINK-13140 Project: Flink

[jira] [Created] (FLINK-13141) Remove getBufferSize method from BufferPoolFactory

2019-07-08 Thread zhijiang (JIRA)
zhijiang created FLINK-13141: Summary: Remove getBufferSize method from BufferPoolFactory Key: FLINK-13141 URL: https://issues.apache.org/jira/browse/FLINK-13141 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-13142) Fix unstable AggregateITCase#testNestedGroupByAgg IT case

2019-07-08 Thread Jark Wu (JIRA)
Jark Wu created FLINK-13142: --- Summary: Fix unstable AggregateITCase#testNestedGroupByAgg IT case Key: FLINK-13142 URL: https://issues.apache.org/jira/browse/FLINK-13142 Project: Flink Issue Type:

[jira] [Created] (FLINK-13143) Clear CheckpointExceptionHandler relevant classes

2019-07-08 Thread vinoyang (JIRA)
vinoyang created FLINK-13143: Summary: Clear CheckpointExceptionHandler relevant classes Key: FLINK-13143 URL: https://issues.apache.org/jira/browse/FLINK-13143 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-13144) Add takeAsList to Table

2019-07-08 Thread Jeff Zhang (JIRA)
Jeff Zhang created FLINK-13144: -- Summary: Add takeAsList to Table Key: FLINK-13144 URL: https://issues.apache.org/jira/browse/FLINK-13144 Project: Flink Issue Type: Improvement Compone

Apply for being a contributor

2019-07-08 Thread hongton122
Hi, I want to contribute to Apache Flink. Would you please give me the contributor permission? My JIRA ID is XD122, my fullname is Xiang Dong. Tanks very much;

[jira] [Created] (FLINK-13145) Run HA dataset/datastream E2E test with new RestartPipelinedRegionStrategy

2019-07-08 Thread Gary Yao (JIRA)
Gary Yao created FLINK-13145: Summary: Run HA dataset/datastream E2E test with new RestartPipelinedRegionStrategy Key: FLINK-13145 URL: https://issues.apache.org/jira/browse/FLINK-13145 Project: Flink

Re: [jira] [Created] (FLINK-13139) Various Hive tests fail on Travis

2019-07-08 Thread 不常用邮箱
Hello all: I meet this problem with can’t import follow class in test file. org.apache.flink.table.catalog.hive.HiveCatalog; org.apache.flink.table.catalog.hive.HiveTestUtils; org.apache.flink.table.catalog.hive.HivePartitionConfig; org.apache.flink.table.catalog.hive.HiveCatalogConfig; org.apache

Re: [DISCUSS]Support Upsert mode for Streaming Non-window FlatAggregate

2019-07-08 Thread Jark Wu
Thanks Jincheng, I think approach 3 there is no ambiguity in the semantics and can better explain a deterministic result, although it is not so easy to use. So I'm +1 to approach 3. Best, Jark On Fri, 5 Jul 2019 at 18:13, jincheng sun wrote: > Hi, > > @Kurt @Jark thanks again for your comments

[jira] [Created] (FLINK-13146) GET request of: org/apache/avro/avro/1.8.2/avro-1.8.2.jar from google-maven-central failed

2019-07-08 Thread vinoyang (JIRA)
vinoyang created FLINK-13146: Summary: GET request of: org/apache/avro/avro/1.8.2/avro-1.8.2.jar from google-maven-central failed Key: FLINK-13146 URL: https://issues.apache.org/jira/browse/FLINK-13146 Pr

Apply for being a contributor

2019-07-08 Thread highfei2011
Hi , Good evening ! I am from China. I want to contribute to Apache Flink.Would you please give me the contributor permission? My JIRA ID is highfei2...@126.com, my fullname is Jeff Yang. Thank you very much ! I am looking forward to hearing from your soon.

[jira] [Created] (FLINK-13147) Duplicated code in 'if' conditional statement

2019-07-08 Thread lixiaobao (JIRA)
lixiaobao created FLINK-13147: - Summary: Duplicated code in 'if' conditional statement Key: FLINK-13147 URL: https://issues.apache.org/jira/browse/FLINK-13147 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-13148) Expose WindowedStream.sideOutputLateData() from CoGroupedStreams

2019-07-08 Thread Congxian Qiu(klion26) (JIRA)
Congxian Qiu(klion26) created FLINK-13148: - Summary: Expose WindowedStream.sideOutputLateData() from CoGroupedStreams Key: FLINK-13148 URL: https://issues.apache.org/jira/browse/FLINK-13148 Pr

[jira] [Created] (FLINK-13149) improve flink ui to make it easier to be used by other projects

2019-07-08 Thread Jie TANG (JIRA)
Jie TANG created FLINK-13149: Summary: improve flink ui to make it easier to be used by other projects Key: FLINK-13149 URL: https://issues.apache.org/jira/browse/FLINK-13149 Project: Flink Issu

[jira] [Created] (FLINK-13150) defaultCatalogName and defaultDatabaseName in TableEnvImpl is not updated after they are updated in TableEnvironment

2019-07-08 Thread Jeff Zhang (JIRA)
Jeff Zhang created FLINK-13150: -- Summary: defaultCatalogName and defaultDatabaseName in TableEnvImpl is not updated after they are updated in TableEnvironment Key: FLINK-13150 URL: https://issues.apache.org/jira/brow

[jira] [Created] (FLINK-13151) Rename JobManager (Process) to Flink Master

2019-07-08 Thread Konstantin Knauf (JIRA)
Konstantin Knauf created FLINK-13151: Summary: Rename JobManager (Process) to Flink Master Key: FLINK-13151 URL: https://issues.apache.org/jira/browse/FLINK-13151 Project: Flink Issue Typ

[FLIP-47] Savepoints vs Checkpoints

2019-07-08 Thread Kostas Kloudas
Hi Devs, Currently there is a number of efforts around checkpoints/savepoints, as reflected by the number of FLIPs. From a quick look FLIP-34, FLIP-41, FLIP-43, and FLIP-45 are all directly related to these topics. This reflects the importance of these two notions/features to the users of the fram

[jira] [Created] (FLINK-13152) Unable to run query when using HiveCatalog and DataSet api

2019-07-08 Thread Jeff Zhang (JIRA)
Jeff Zhang created FLINK-13152: -- Summary: Unable to run query when using HiveCatalog and DataSet api Key: FLINK-13152 URL: https://issues.apache.org/jira/browse/FLINK-13152 Project: Flink Issue

Re: [VOTE] How to Deal with Split/Select in DataStream API

2019-07-08 Thread Aljoscha Krettek
I think this would benefit from a FLIP, that neatly sums up the options, and which then gives us also a point where we can vote and ratify a decision. As a gut feeling, I most like Option 3). Initially I would have preferred option 1) (because of a sense of API purity), but by now I think it’s g

Re: [DISCUSS] Graceful Shutdown Handling by UDFs.

2019-07-08 Thread Kostas Kloudas
Hi Konstantin, Yes you are right that `cancel` falls under the "abrupt" termination of a job. I will update the FLIP accordingly. Cheers, Kostas On Sun, Jul 7, 2019 at 11:38 AM Konstantin Knauf wrote: > Hi Klou, > > +1 for this proposal. I am missing any mention of "cancel" in the design > doc

[jira] [Created] (FLINK-13153) SplitAggregateITCase.testMinMaxWithRetraction failed on Travis

2019-07-08 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-13153: - Summary: SplitAggregateITCase.testMinMaxWithRetraction failed on Travis Key: FLINK-13153 URL: https://issues.apache.org/jira/browse/FLINK-13153 Project: Flink

[jira] [Created] (FLINK-13154) Broken links in documentation

2019-07-08 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-13154: - Summary: Broken links in documentation Key: FLINK-13154 URL: https://issues.apache.org/jira/browse/FLINK-13154 Project: Flink Issue Type: Bug Com

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

2019-07-08 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-13155: - Summary: SQL Client end-to-end test fails on Travis Key: FLINK-13155 URL: https://issues.apache.org/jira/browse/FLINK-13155 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-13156) Elasticsearch (v1.7.1) sink end-to-end test failed on Travis

2019-07-08 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-13156: - Summary: Elasticsearch (v1.7.1) sink end-to-end test failed on Travis Key: FLINK-13156 URL: https://issues.apache.org/jira/browse/FLINK-13156 Project: Flink

Re: [RESULT][VOTE] Migrate to sponsored Travis account

2019-07-08 Thread Chesnay Schepler
I have temporarily re-enabled running PR builds on the ASF account; migrating to the Travis subscription caused some issues in the bot that I have to fix first. On 07/07/2019 23:01, Chesnay Schepler wrote: The vote has passed unanimously in favor of migrating to a separate Travis account. I

Re: [DISCUSS] Adopting a Code Style and Quality Guide

2019-07-08 Thread Robert Metzger
I've converted the google document into a markdown-based pull request here: https://github.com/apache/flink-web/pull/224 I didn't put a ton of effort into splitting the guide into multiple pages. It would be nice to reach consensus on the exact split in the PR. On Thu, Jun 27, 2019 at 10:48 PM Hu

Re: [jira] [Created] (FLINK-13139) Various Hive tests fail on Travis

2019-07-08 Thread Bowen Li
Hi Louis, Thanks for reporting the issue. The problem is due to Hive 2.3.4 not compatible with Hadoop 2.4, and requires at least 2.7. I'm not sure yet why the build succeeded most of the time on Travis CI and only fails occasionally, maybe it's because the build process has flink-shaded-hadoop-2-

Re: [RESULT][VOTE] Migrate to sponsored Travis account

2019-07-08 Thread Chesnay Schepler
The kinks have been worked out; the bot is running again and pr builds are yet again no longer running on ASF resources. PRs are mirrored to: https://github.com/flink-ci/flink Bot source: https://github.com/flink-ci/ci-bot On 08/07/2019 17:14, Chesnay Schepler wrote: I have temporarily re-enabl

[jira] [Created] (FLINK-13157) reeanble unit test HiveInputFormatTest.testReadComplextDataTypeFromHiveInputFormat() and resolve conflicts

2019-07-08 Thread Bowen Li (JIRA)
Bowen Li created FLINK-13157: Summary: reeanble unit test HiveInputFormatTest.testReadComplextDataTypeFromHiveInputFormat() and resolve conflicts Key: FLINK-13157 URL: https://issues.apache.org/jira/browse/FLINK-1315

Re: [DISCUSS] Proposal for Flink job execution/availability metrics impovement

2019-07-08 Thread Becket Qin
Hi Hwanju, thanks for the reply. Regarding the first two proposals, my main concern is whether it is necessary to have something deeply coupled with Flink runtime. To some extent, the SLA metrics are kind of custom metrics. It would be good if we can support custom metrics in general, instead of o

Re: [DISCUSS] ARM support for Flink

2019-07-08 Thread Xiyuan Wang
Thanks for your help. I built the frocksdb locally on ARM and all the related tests are passed now. Except some tests which can be fixed easily, it seems that both building and testing are ran well on ARM. Basing on my test, Is it possible to support Flink on ARM officailly? Seem the worklist is n

[jira] [Created] (FLINK-13158) Remove WebMonitor interface from webmonitor package

2019-07-08 Thread vinoyang (JIRA)
vinoyang created FLINK-13158: Summary: Remove WebMonitor interface from webmonitor package Key: FLINK-13158 URL: https://issues.apache.org/jira/browse/FLINK-13158 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-13159) java.lang.ClassNotFoundException when restore job

2019-07-08 Thread kring (JIRA)
kring created FLINK-13159: - Summary: java.lang.ClassNotFoundException when restore job Key: FLINK-13159 URL: https://issues.apache.org/jira/browse/FLINK-13159 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-13160) HiveTaleSource should implment PartitionableTableSource

2019-07-08 Thread zjuwangg (JIRA)
zjuwangg created FLINK-13160: Summary: HiveTaleSource should implment PartitionableTableSource Key: FLINK-13160 URL: https://issues.apache.org/jira/browse/FLINK-13160 Project: Flink Issue Type: S

Re: [VOTE] How to Deal with Split/Select in DataStream API

2019-07-08 Thread Xingcan Cui
Hi Aljoscha, Thanks for your response. With all this preliminary information collected, I’ll start a formal process. Thank everybody for your attention. Best, Xingcan > On Jul 8, 2019, at 10:17 AM, Aljoscha Krettek wrote: > > I think this would benefit from a FLIP, that neatly sums up the op

[jira] [Created] (FLINK-13161) numBuckets calculate wrong in BinaryHashBucketArea

2019-07-08 Thread Louis Xu (JIRA)
Louis Xu created FLINK-13161: Summary: numBuckets calculate wrong in BinaryHashBucketArea Key: FLINK-13161 URL: https://issues.apache.org/jira/browse/FLINK-13161 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-13162) Default value of slot.idle.timeout is too large for batch job

2019-07-08 Thread Jeff Zhang (JIRA)
Jeff Zhang created FLINK-13162: -- Summary: Default value of slot.idle.timeout is too large for batch job Key: FLINK-13162 URL: https://issues.apache.org/jira/browse/FLINK-13162 Project: Flink Is

[jira] [Created] (FLINK-13163) Default value of slot.request.timeout is too small for batch job

2019-07-08 Thread Jeff Zhang (JIRA)
Jeff Zhang created FLINK-13163: -- Summary: Default value of slot.request.timeout is too small for batch job Key: FLINK-13163 URL: https://issues.apache.org/jira/browse/FLINK-13163 Project: Flink