Re: Incompatible Apache Http lib in Flink kinesis connector

Guys, This is the PR https://github.com/apache/flink/pull/4150 On Tue, Jun 20, 2017 at 1:37 PM, Bowen Li wrote: > Hi Ted and Gordon, > I found the root cause and a solution. Basically > https://ci.apache.org/projects/flink/flink-docs- > release-1.3/setup/aws.html#flink-for-

Re: Switch to Scala 2.11 as a default build profile

+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-kinesis-connector) ourselves in order to run on EMR. Defaulting to Scala 2.11 will greatly reduce adoption cost for Flink on EMR On Wed, Jun 28, 2017 at 9:34 AM, Till Rohr

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

Re: [POLL] Who still uses Java 7 with Flink ?

> > > > >> > > > > > >> > > > > On Thu, Mar 23, 2017 at 2:42 PM, Theodore Vasiloudis < > >> > > > theodoros.vasilou...@gmail.com >> theodoros.vasilou...@gmail.com > >> > >> > >> > > > wrote:

Re: [ANNOUNCE] New Flink PMC member: Tzu-Li (Gordon) Tai

Congrats! On Wed, Jul 12, 2017 at 3:30 AM, Stavros Kontopoulos < st.kontopou...@gmail.com> wrote: > Congrats Gordon! > > On Wed, Jul 12, 2017 at 5:29 AM, Evans Ye wrote: > > > Congrats Gordon! > > > > Tzu-Li (Gordon) Tai 於 2017年7月12日 週三，上午2:28寫道： > > > > > Thanks everyone :) > > > It has always

Re: [DISCUSS] Release 1.3.2 planning

Hi Aljoscha, I'd like to see https://issues.apache.org/jira/browse/FLINK-6951 fixed in 1.3.2, if it makes sense. Thanks, Bowen On Wed, Jul 12, 2017 at 3:06 AM, Aljoscha Krettek wrote: > Short update, we resolved some blockers and discovered some new ones. > There’s this nifty Jira page if y

Re: Akka dissassociated

The amount of resource assigned to JobManager looks fine. How much resource (CPU and memory) did you allocate for TaskManager? On Wed, Jul 19, 2017 at 3:07 AM, Stephan Ewen wrote: > Hi Greg! > > Akka disassociation means that the network connection between the > JobManager and TaskManager broke.

Re: [ANNOUNCE] New Flink PMC member: Chesnay Schepler

Congrats, Chesnay! On Fri, Jul 28, 2017 at 11:48 AM, N Sa wrote: > Congratulations Chesnay! > > On Jul 28, 2017 11:44 AM, "Aljoscha Krettek" wrote: > > Well deserved! Congrats. :-) > > > On 28. Jul 2017, at 17:45, Tzu-Li (Gordon) Tai > wrote: > > > > Congrats Chesnay! > > > > On Fri, Jul 28, 2

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

Hi everyone, I read the doc, and found that we are not even testing Flink against Kinesis with *flink-connector-kinesis*. According to our experience, *flink-connector-kinesis *releases tend to have more issues w.r.t. dependency version conflicts, performance, capability, and stability. We've rep

Re: [RESULT][VOTE] Release 1.3.2, release candidate #3

Hi Aljoscha, That'll be great. Look forward to a better Kinesis connector from Flink! Thanks, Bowen On Fri, Aug 4, 2017 at 11:07 PM, Aljoscha Krettek wrote: > The voting time has passed and I'm happy to announce that we've collected > enough votes to release this RC as Flink 1.3.2. > > +1

Which branch should I build for Flink 1.3.2

Hi guys, I'm trying to build Flink 1.3.2 myself from source code, and which branch I should build from? 'release-1.3' or 'release-1.3.2-rc3'? I think it should be the former one, but want you confirm on it. Thanks, Bowen

Re: Which branch should I build for Flink 1.3.2

Cheers, Fabian > > > Am 11.08.2017 11:56 nachm. schrieb "Ted Yu" : > > From > http://search-hadoop.com/m/Flink/VkLeQ4jYZR3pCAq1?subj=+ > ANNOUNCE+Apache+Flink+1+3+2+released > , you can find this link: > > https://flink.apache.org/downloads.html#source >

Which window function to use to start a window at anytime

Hi guys, I sent this email to Flink user email alias but didn't get any feedbacks. I'm sending it here. We are trying use Flink to count millions of keyed items of an hour window hourly as `time(SlidingEventTimeWindows.of(1hour, 1hour))`. According to the sliding window doc

[Discuss] adding a new command line argument -sd/--savepointdirectory

Hi guys, I want to start on discussion on FLINK-7566 if there's only one checkpointing metadata file in , `flink run -s ` should resume from that metadata file. We need a way to programmatically start a Flink job from a checkpoint without having

Re: [jira] [Created] (FLINK-7597) broken flink-connectors-kinesis setup in Intellij that potentially results from improper pom.xml

not > allow us to build it by default :-( > (The Amazon Software License). > > Can you go to the maven profiles in IntelliJ and activate the profile to > include maven? That should help! > > Best, > Stephan > > > On Thu, Sep 7, 2017 at 8:30 AM, Bowen Li (

Re: [DISCUSS] Dropping Scala 2.10

+1 for dropping support for Scala 2.10 On Tue, Sep 19, 2017 at 3:29 AM, Sean Owen wrote: > For the curious, here's the overall task in Spark: > > https://issues.apache.org/jira/browse/SPARK-14220 > > and most of the code-related changes: > > https://github.com/apache/spark/pull/18645 > > and wh

Logistic Regression in Flink ML

Hi guys, I checked that FlinkML still doesn't have a logistic regression model, and the following two PRs are waiting to be merged. - https://github.com/apache/flink/pull/3428 for https://issues.apache.org/jira/browse/FLINK-1743 - https://github.com/apache/flink/pull/3756 Can any committer pleas

Re: Dependency convergence

+1. This is great, Piotrek! BTW, can you clarify what you mean by 'project wide'? Is it the whole `flink` project or just `flink-connector-kafka`? I think it's useful to be applied to the whole flink project. I've seen dependencies conflict problem like this in flink-connector-kinesis. Enabling th

Re: System resource logger

System and processor info, marked as 'logged once' in gist shared by Piotr, should still be logged instead of registered as metrics, right? On Thu, Oct 5, 2017 at 2:38 AM, Till Rohrmann wrote: > Thanks for the proposal Piotr. I like it a lot since it will help people to > better understand their

Re: Unable to write snapshots to S3 on EMR

Hi Andy, I believe it's because you didn't set your s3 impl correctly. Try to set your core-site.xml by following https://ci.apache.org/ projects/flink/flink-docs-release-1.4/ops/deployment/aws.html#s3afilesystem- recommended Bowen On Fri, Oct 6, 2017 at 7:59 AM, Andy M. wrote: > Hi Till, > >

Re: 回复：[DISCUSS] Releasing Flink 1.4

+1. To give users a heads up, might be good to start to change the ‘target release’ of some Jira tickets from 1.4 to 1.5. Sent from my iPhone > On Oct 13, 2017, at 11:02 PM, Zhijiang(wangzhijiang999) > wrote: > > totally agree with the > way.-

Re: Improving Javadocs

Hi Kent, A “[hotfix]” should be enough Sent from my iPhone > On Oct 20, 2017, at 1:58 AM, Kent Murra wrote: > > Does improving Javadocs require a JIRA or should I submit as a hotfix? > > In particular, I find the Javadocs for RichFunction.open and > RichFunction.close a bit too sparse since it

Re: [ANNOUNCE] New committer: Haohui Mai

Congratulations! On Wed, Nov 1, 2017 at 8:39 AM, Xingcan Cui wrote: > Congratulations! > > On Wed, Nov 1, 2017 at 9:37 PM, Kurt Young wrote: > > > Congrats and welcome on board! > > > > Best, > > Kurt > > > > On Wed, Nov 1, 2017 at 8:15 PM, Hai Zhou wrote: > > > >> Congratulations! > >> > >> O

Re: [ANNOUNCE] Flink 1.4 feature-freeze date and release burn-down

Hi Aljoscha, Thank you for taking on the releasing branch work! I'm wondering what's the status of it? And when will we open master branch for PRs of 1.5 features? Thanks! Bowen On Thu, Oct 19, 2017 at 2:17 AM, Aljoscha Krettek wrote: > Hi Everyone, > > It seems everyone agrees on releasin

Clean up flink-contrib: Remove flink-streaming-contrib and migrate its class to other modules

Hello Flink devs, I'd like to propose removinh of flink-contrib/flink-streaming-contrib and migrate its classes to flink-streaming-java/scala, for the following reasons: 1. flink-streaming-contrib is so small that has only 4 classes (3 java and 1 scala), which isn't worth a dedicated jar for Flin

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

Hi Aljoscha, I found Flink's State doc and javaDoc are very ambiguous on what the replacement of FoldingState is, which will confuse a lot of users. We need to fix it in 1.4 release. I have submitted a PR at https://github.com/apache/flink/pull/5129 Thanks, Bowen On Wed, Dec 6, 2017 at 5:56 AM

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

the 1.4 doc > on the website will update as soon as the doc on the release-1.4 branch is > updated. > > > On 6. Dec 2017, at 20:47, Bowen Li wrote: > > > > Hi Aljoscha, > > > > I found Flink's State doc and javaDoc are very ambiguous on what the > >

[SEATTLE MEETUP] Announcing First Seattle Apache Flink Meetup

drinks will be provided. Plenty of onsite parking spots. DATE: Jan 17th, 2018, Wednesday TALKS: - Haitao Wang, Senior Staff Engineer at Alibaba, will give a presentation on large-scale streaming processing with Flink and Flink SQL at Alibaba and several internal use cases. - Bowen Li will talk

[Discuss] Proposing FLIP-25 - Support User State TTL Natively in Flink

Hi guys, I want to propose a new FLIP -- FLIP-25 - Support User State TTL Natively in Flink. This has been one of most handy and most frequently asked features in Flink community. The jira ticket is FLINK-3089 . I've written a rough design

Re: [ANNOUNCE] Apache Flink 1.4.1 released

Congratulations everyone! On Thu, Feb 15, 2018 at 10:04 AM, Tzu-Li (Gordon) Tai wrote: > The Apache Flink community is very happy to announce the release of Apache > Flink 1.4.1, which is the first bugfix release for the Apache Flink 1.4 > series. > > > Apache Flink® is an open-source stream pro

Re: [DISCUSS] Move Flink Docker Files from Flink to 'docker-flink'

+1. flink-contrib is an experiment land, docker-flink should graduate from it. This also helps to clean up flink-contrib/ On Wed, Feb 21, 2018 at 1:41 PM, Stephan Ewen wrote: > Hi all! > > I want to start the discussion to whether to drop the " > *flink-contrib/docker-flink*" subproject and i

Re: [DISCUSS] Releasing Flink 1.5.0

Hi guys, Can we get FLINK-8667 into 1.5.0? I've been waiting for it for quite a few days. The reason I really want to get it into 1.5.0 is because KeyedBroadcastProce ssFunction will be released in 1.5.0 and there's no compatibility issues. If we don't

Re: Proposal - Change shard discovery in Flink Kinesis Connector to use ListShards

If ListShards() gives all the info that Flink needs, +1 on switching. DescribeStreams() has a limitation of 5 requests/sec, which is pretty bad But, I believe the goal of switching APIs should be *making Flink jobs that read from Kinesis more stable*, rather than having faster shard discovery

Re: Proposal - Change shard discovery in Flink Kinesis Connector to use ListShards

Good for AWS has increased the limit from 5txn/s last year to 10txn/s On Mon, Mar 5, 2018 at 8:32 AM, Thomas Weise wrote: > On Sun, Mar 4, 2018 at 11:38 PM, Bowen Li wrote: > > > If ListShards() gives all the info that Flink needs, +1 on switching. > > DescribeStreams() has

Re: [DISCUSS] Releasing Flink 1.3.3 with only critical fixes

+1 On Thu, Mar 8, 2018 at 7:36 AM, Aljoscha Krettek wrote: > Hi, > > We fixed a critical bug in the ZooKeeper checkpoint store but never > released a 1.3.x version of Flink with the fix. I'm proposing to release > 1.3.3 with only fixes for this issue so that users can benefit from the fix > and

Re: [DISCUSS] Add end-to-end tests using Docker Compose

This would be nice. BTW, the [3] link is missing I have a few questions, given concerns that 1) the full build time will take longer and longer time and 2) build queue on Travis will be more congested - How much time will be added to full build time according to estimation? - Do we have pl

Re: [DISCUSS] Add end-to-end tests using Docker Compose

The idea being > the the former are executed for each pull request, as they are now. The > latter are executed nightly or manually if you want to verify a release. > This way, the nightly tests can get quite involved without blowing up build > time. What do you think? > > Best, &g

Re: [VOTE] Release 1.5.0, release candidate #1

Hi Till, FLINK-8837 is marked as a blocker for release 1.5.0. I've opened a PR for it, can you please take a look at it? Bowen On Tue, Apr 3, 2018 at 8:45 AM, simone wrote: > > On 03/04/2018 17:40, simone wrote: > >> >> I tried to run a simple

[jira] [Created] (FLINK-13046) rename hive-site-path to hive-conf-dir to be consistent with standard name in Hive

Bowen Li created FLINK-13046: Summary: rename hive-site-path to hive-conf-dir to be consistent with standard name in Hive Key: FLINK-13046 URL: https://issues.apache.org/jira/browse/FLINK-13046 Project

[jira] [Created] (FLINK-13048) support decimal in Flink's integration with Hive user defined functions

Bowen Li created FLINK-13048: Summary: support decimal in Flink's integration with Hive user defined functions Key: FLINK-13048 URL: https://issues.apache.org/jira/browse/FLINK-13048 Project:

[jira] [Created] (FLINK-13066) append hive-site.xml to path defined in 'hive-conf-dir'

Bowen Li created FLINK-13066: Summary: append hive-site.xml to path defined in 'hive-conf-dir' Key: FLINK-13066 URL: https://issues.apache.org/jira/browse/FLINK-13066 Project: Flink

[jira] [Created] (FLINK-13085) unable to run python test locally

Bowen Li created FLINK-13085: Summary: unable to run python test locally Key: FLINK-13085 URL: https://issues.apache.org/jira/browse/FLINK-13085 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-13086) add Chinese documentation for catalogs

Bowen Li created FLINK-13086: Summary: add Chinese documentation for catalogs Key: FLINK-13086 URL: https://issues.apache.org/jira/browse/FLINK-13086 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-13128) make HiveGenericUDAF expose accumulator type

Bowen Li created FLINK-13128: Summary: make HiveGenericUDAF expose accumulator type Key: FLINK-13128 URL: https://issues.apache.org/jira/browse/FLINK-13128 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-13134) override default hadoop version from 2.4.1 to 2.7.5 in flink-connector-hive

Bowen Li created FLINK-13134: Summary: override default hadoop version from 2.4.1 to 2.7.5 in flink-connector-hive Key: FLINK-13134 URL: https://issues.apache.org/jira/browse/FLINK-13134 Project: Flink

[jira] [Created] (FLINK-13135) unify configs for meta-objects in HiveCatalog

Bowen Li created FLINK-13135: Summary: unify configs for meta-objects in HiveCatalog Key: FLINK-13135 URL: https://issues.apache.org/jira/browse/FLINK-13135 Project: Flink Issue Type: Sub-task

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

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

[jira] [Created] (FLINK-13175) FLINK-12951 breaks SQL CLI's ExecutionContextTest

Bowen Li created FLINK-13175: Summary: FLINK-12951 breaks SQL CLI's ExecutionContextTest Key: FLINK-13175 URL: https://issues.apache.org/jira/browse/FLINK-13175 Project: Flink Issue Type

[jira] [Created] (FLINK-13176) remember current catalog and database in SQL CLI SessionContext

Bowen Li created FLINK-13176: Summary: remember current catalog and database in SQL CLI SessionContext Key: FLINK-13176 URL: https://issues.apache.org/jira/browse/FLINK-13176 Project: Flink

[jira] [Created] (FLINK-13177) make FunctionCatalog able to reference functions across catalogs

Bowen Li created FLINK-13177: Summary: make FunctionCatalog able to reference functions across catalogs Key: FLINK-13177 URL: https://issues.apache.org/jira/browse/FLINK-13177 Project: Flink

[jira] [Created] (FLINK-13178) persist Flink's functions to catalog

Bowen Li created FLINK-13178: Summary: persist Flink's functions to catalog Key: FLINK-13178 URL: https://issues.apache.org/jira/browse/FLINK-13178 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-13197) support querying Hive's view in Flink

Bowen Li created FLINK-13197: Summary: support querying Hive's view in Flink Key: FLINK-13197 URL: https://issues.apache.org/jira/browse/FLINK-13197 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-13232) TemporalTypesTest>ExpressionTestBase.evaluateExprs fails on PST Timezone

Bowen Li created FLINK-13232: Summary: TemporalTypesTest>ExpressionTestBase.evaluateExprs fails on PST Timezone Key: FLINK-13232 URL: https://issues.apache.org/jira/browse/FLINK-13232 Project: Fl

[jira] [Created] (FLINK-13233) add end-to-end tests for "USE CATALOG" and "USE DATABASE" commands in SQL CLI

Bowen Li created FLINK-13233: Summary: add end-to-end tests for "USE CATALOG" and "USE DATABASE" commands in SQL CLI Key: FLINK-13233 URL: https://issues.apache.org/jira/browse/FLINK-13233

[jira] [Created] (FLINK-13276) write a quickstart documentation for Hive integration

Bowen Li created FLINK-13276: Summary: write a quickstart documentation for Hive integration Key: FLINK-13276 URL: https://issues.apache.org/jira/browse/FLINK-13276 Project: Flink Issue Type

[jira] [Created] (FLINK-13277) add documentation of Hive connector

Bowen Li created FLINK-13277: Summary: add documentation of Hive connector Key: FLINK-13277 URL: https://issues.apache.org/jira/browse/FLINK-13277 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-13278) add Chinese documentation for Hive source/sink

Bowen Li created FLINK-13278: Summary: add Chinese documentation for Hive source/sink Key: FLINK-13278 URL: https://issues.apache.org/jira/browse/FLINK-13278 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-13279) not able to query table registered in catalogs

Bowen Li created FLINK-13279: Summary: not able to query table registered in catalogs Key: FLINK-13279 URL: https://issues.apache.org/jira/browse/FLINK-13279 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-13294) disable LocalExecutorITCase.testUseCatalogAndUseDatabase

Bowen Li created FLINK-13294: Summary: disable LocalExecutorITCase.testUseCatalogAndUseDatabase Key: FLINK-13294 URL: https://issues.apache.org/jira/browse/FLINK-13294 Project: Flink Issue Type

[jira] [Created] (FLINK-13295) set current catalog and database after registering tables and views in SQL CLI

Bowen Li created FLINK-13295: Summary: set current catalog and database after registering tables and views in SQL CLI Key: FLINK-13295 URL: https://issues.apache.org/jira/browse/FLINK-13295 Project

[jira] [Created] (FLINK-13296) FunctionCatalog.lookupFunction() should check in memory functions if the target function doesn't exist in catalog

Bowen Li created FLINK-13296: Summary: FunctionCatalog.lookupFunction() should check in memory functions if the target function doesn't exist in catalog Key: FLINK-13296 URL: https://issues.apache.org/jira/b

[jira] [Created] (FLINK-13297) Flink SQL should be able to reference functions across catalogs with full path

Bowen Li created FLINK-13297: Summary: Flink SQL should be able to reference functions across catalogs with full path Key: FLINK-13297 URL: https://issues.apache.org/jira/browse/FLINK-13297 Project

[jira] [Created] (FLINK-13298) write Chinese documentation and quickstart for Flink-Hive compatibility

Bowen Li created FLINK-13298: Summary: write Chinese documentation and quickstart for Flink-Hive compatibility Key: FLINK-13298 URL: https://issues.apache.org/jira/browse/FLINK-13298 Project: Flink

[jira] [Created] (FLINK-13312) move tests for data type mappings between Flink and Hive into its own test class

Bowen Li created FLINK-13312: Summary: move tests for data type mappings between Flink and Hive into its own test class Key: FLINK-13312 URL: https://issues.apache.org/jira/browse/FLINK-13312 Project

[jira] [Created] (FLINK-13313) create CatalogTableBuilder to support building CatalogTable from descriptors

Bowen Li created FLINK-13313: Summary: create CatalogTableBuilder to support building CatalogTable from descriptors Key: FLINK-13313 URL: https://issues.apache.org/jira/browse/FLINK-13313 Project: Flink

[jira] [Created] (FLINK-13328) add IT case for reading and writing generic table metadata via HiveCatalog

Bowen Li created FLINK-13328: Summary: add IT case for reading and writing generic table metadata via HiveCatalog Key: FLINK-13328 URL: https://issues.apache.org/jira/browse/FLINK-13328 Project: Flink

[jira] [Created] (FLINK-13706) add documentation of using Hive functions in Flink

Bowen Li created FLINK-13706: Summary: add documentation of using Hive functions in Flink Key: FLINK-13706 URL: https://issues.apache.org/jira/browse/FLINK-13706 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-13741) FunctionCatalog.getUserDefinedFunctions() does not return Flink built-in functions' names

Bowen Li created FLINK-13741: Summary: FunctionCatalog.getUserDefinedFunctions() does not return Flink built-in functions' names Key: FLINK-13741 URL: https://issues.apache.org/jira/browse/FLINK-

[jira] [Created] (FLINK-13755) support Hive built-in functions in Flink

Bowen Li created FLINK-13755: Summary: support Hive built-in functions in Flink Key: FLINK-13755 URL: https://issues.apache.org/jira/browse/FLINK-13755 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-13790) Support -e option with a sql script file as input

Bowen Li created FLINK-13790: Summary: Support -e option with a sql script file as input Key: FLINK-13790 URL: https://issues.apache.org/jira/browse/FLINK-13790 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-13866) develop testing plan for many Hive versions that we support

Bowen Li created FLINK-13866: Summary: develop testing plan for many Hive versions that we support Key: FLINK-13866 URL: https://issues.apache.org/jira/browse/FLINK-13866 Project: Flink Issue

[jira] [Created] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

Bowen Li created FLINK-14055: Summary: Add advanced function DDL syntax "USING JAR/FILE/ACHIVE" Key: FLINK-14055 URL: https://issues.apache.org/jira/browse/FLINK-14055 Project: Flink

[jira] [Created] (FLINK-14090) FLIP-57 Rework FunctionCatalog

Bowen Li created FLINK-14090: Summary: FLIP-57 Rework FunctionCatalog Key: FLINK-14090 URL: https://issues.apache.org/jira/browse/FLINK-14090 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-15933) update content of how generic table schema is stored in hive via HiveCatalog

Bowen Li created FLINK-15933: Summary: update content of how generic table schema is stored in hive via HiveCatalog Key: FLINK-15933 URL: https://issues.apache.org/jira/browse/FLINK-15933 Project: Flink

[jira] [Created] (FLINK-15960) support creating Hive tables, views, functions within Flink

Bowen Li created FLINK-15960: Summary: support creating Hive tables, views, functions within Flink Key: FLINK-15960 URL: https://issues.apache.org/jira/browse/FLINK-15960 Project: Flink Issue

[jira] [Created] (FLINK-15983) add native reader for Hive parquet files

Bowen Li created FLINK-15983: Summary: add native reader for Hive parquet files Key: FLINK-15983 URL: https://issues.apache.org/jira/browse/FLINK-15983 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-15984) support hive stream table sink

Bowen Li created FLINK-15984: Summary: support hive stream table sink Key: FLINK-15984 URL: https://issues.apache.org/jira/browse/FLINK-15984 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-15985) offload runtime params from DDL to table hints in DML/queries

Bowen Li created FLINK-15985: Summary: offload runtime params from DDL to table hints in DML/queries Key: FLINK-15985 URL: https://issues.apache.org/jira/browse/FLINK-15985 Project: Flink Issue

[jira] [Created] (FLINK-15986) support setting or changing session properties in Flink SQL

Bowen Li created FLINK-15986: Summary: support setting or changing session properties in Flink SQL Key: FLINK-15986 URL: https://issues.apache.org/jira/browse/FLINK-15986 Project: Flink Issue

[jira] [Created] (FLINK-16023) jdbc connector's 'connector.table' property should be optional rather than required

Bowen Li created FLINK-16023: Summary: jdbc connector's 'connector.table' property should be optional rather than required Key: FLINK-16023 URL: https://issues.apache.org/jira/browse/FLINK-16023

[jira] [Created] (FLINK-16024) support filter pushdown in jdbc connector

Bowen Li created FLINK-16024: Summary: support filter pushdown in jdbc connector Key: FLINK-16024 URL: https://issues.apache.org/jira/browse/FLINK-16024 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-16027) kafka connector's 'connector.topic' property should be optional rather than required

Bowen Li created FLINK-16027: Summary: kafka connector's 'connector.topic' property should be optional rather than required Key: FLINK-16027 URL: https://issues.apache.org/jira/browse/FLINK-16027

[jira] [Created] (FLINK-16028) hbase connector's 'connector.table-name' property should be optional rather than required

Bowen Li created FLINK-16028: Summary: hbase connector's 'connector.table-name' property should be optional rather than required Key: FLINK-16028 URL: https://issues.apache.org/jira/bro

[jira] [Created] (FLINK-16107) github link on statefun.io should point to https://github.com/apache/flink-statefun

Bowen Li created FLINK-16107: Summary: github link on statefun.io should point to https://github.com/apache/flink-statefun Key: FLINK-16107 URL: https://issues.apache.org/jira/browse/FLINK-16107 Project

[jira] [Created] (FLINK-16448) add documentation for Hive table sink parallelism setting strategy

Bowen Li created FLINK-16448: Summary: add documentation for Hive table sink parallelism setting strategy Key: FLINK-16448 URL: https://issues.apache.org/jira/browse/FLINK-16448 Project: Flink

[jira] [Created] (FLINK-16471) develop PostgresJDBCCatalog

Bowen Li created FLINK-16471: Summary: develop PostgresJDBCCatalog Key: FLINK-16471 URL: https://issues.apache.org/jira/browse/FLINK-16471 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16472) support precision of timestamp and time data types

Bowen Li created FLINK-16472: Summary: support precision of timestamp and time data types Key: FLINK-16472 URL: https://issues.apache.org/jira/browse/FLINK-16472 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-16473) add documentation for PostgresJDBCCatalog

Bowen Li created FLINK-16473: Summary: add documentation for PostgresJDBCCatalog Key: FLINK-16473 URL: https://issues.apache.org/jira/browse/FLINK-16473 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16474) develop OracleJDBCCatalog to connect Flink with Oracle databases and ecosystem

Bowen Li created FLINK-16474: Summary: develop OracleJDBCCatalog to connect Flink with Oracle databases and ecosystem Key: FLINK-16474 URL: https://issues.apache.org/jira/browse/FLINK-16474 Project

[jira] [Created] (FLINK-16498) make Postgres table work end-2-end in Flink SQL with PostgresJDBCCatalog

Bowen Li created FLINK-16498: Summary: make Postgres table work end-2-end in Flink SQL with PostgresJDBCCatalog Key: FLINK-16498 URL: https://issues.apache.org/jira/browse/FLINK-16498 Project: Flink

[jira] [Created] (FLINK-16575) develop HBaseCatalog to integrate HBase metadata into Flink

Bowen Li created FLINK-16575: Summary: develop HBaseCatalog to integrate HBase metadata into Flink Key: FLINK-16575 URL: https://issues.apache.org/jira/browse/FLINK-16575 Project: Flink Issue

[jira] [Created] (FLINK-16702) develop JDBCCatalogFactory for service discovery

Bowen Li created FLINK-16702: Summary: develop JDBCCatalogFactory for service discovery Key: FLINK-16702 URL: https://issues.apache.org/jira/browse/FLINK-16702 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-16780) improve Flink lookup join

Bowen Li created FLINK-16780: Summary: improve Flink lookup join Key: FLINK-16780 URL: https://issues.apache.org/jira/browse/FLINK-16780 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-16781) add built-in cache mechanism for LookupableTableSource in lookup join

Bowen Li created FLINK-16781: Summary: add built-in cache mechanism for LookupableTableSource in lookup join Key: FLINK-16781 URL: https://issues.apache.org/jira/browse/FLINK-16781 Project: Flink

[jira] [Created] (FLINK-16810) add back PostgresCatalogITCase

Bowen Li created FLINK-16810: Summary: add back PostgresCatalogITCase Key: FLINK-16810 URL: https://issues.apache.org/jira/browse/FLINK-16810 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16811) introduce JDBCRowConverter

Bowen Li created FLINK-16811: Summary: introduce JDBCRowConverter Key: FLINK-16811 URL: https://issues.apache.org/jira/browse/FLINK-16811 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-16812) introduce PostgresRowConverter

Bowen Li created FLINK-16812: Summary: introduce PostgresRowConverter Key: FLINK-16812 URL: https://issues.apache.org/jira/browse/FLINK-16812 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16813) JDBCInputFormat doesn't correctly map Short

Bowen Li created FLINK-16813: Summary: JDBCInputFormat doesn't correctly map Short Key: FLINK-16813 URL: https://issues.apache.org/jira/browse/FLINK-16813 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-16814) StringUtils.arrayToString() doesn't convert byte[] correctly

Bowen Li created FLINK-16814: Summary: StringUtils.arrayToString() doesn't convert byte[] correctly Key: FLINK-16814 URL: https://issues.apache.org/jira/browse/FLINK-16814 Project: Flink

[jira] [Created] (FLINK-16815) add e2e tests for reading from postgres with JDBCTableSource and PostgresCatalog

Bowen Li created FLINK-16815: Summary: add e2e tests for reading from postgres with JDBCTableSource and PostgresCatalog Key: FLINK-16815 URL: https://issues.apache.org/jira/browse/FLINK-16815 Project

<    1   2   3   4   5   6   >