Re: [jira] [Created] (FLINK-37222) Table planner exception when sql client submit job

Hi, Would it be possible to have the Fix Version/s of the Jira issue FLINK-37222 [1] updated to reflect the fix has been backported to into release-1.20? This issue is closed as fixed in version 2.1.0 only, so it is not reflected in changes expected. In the next maintenance release 1.20.2 [2]

Re: [jira] [Created] (FLINK-28897) Fail to use udf in added jar when enabling checkpoint

Hi Team, Here is the summary on the outcomes from the PR review: Externally added jars are resolved using the FlinkUserCodeClassLoader(child classloader) in flink. This fix involved updating the class loader at the graph execution level with the user code class loader which is expected as per na

Re: [jira] [Created] (FLINK-37202) Introduce TDengine connector

Hi there, I think a new connector is an improvement that requires a Flip https://cwiki.apache.org/confluence/display/FLINK/Flink+Improvement+Proposals so this can be discussed and voted on by the community, Kind regards, David. From: kevinmen (Jira) Date: Wednesday, 22 January 2025 at 1

RE: [jira] [Created] (FLINK-28897) Fail to use udf in added jar when enabling checkpoint

Hi Team, I have raised a PR (https://github.com/apache/flink/pull/25656) to 1.20 version with probable fix for this issue. Can I get a review done for this please. Thanks in advance. Regards, Ammu Parvathy On 2022/08/10 03:39:00 "Liu (Jira)" wrote: > Liu created FLINK-28897: > -

RE: [jira] [Created] (FLINK-36739) Update NodeJS to v18.20.5 (LTS)

Hello, This issue is currently blocked by the CI build which has Ubuntu version 16.04 and the new NodeJS version requires a newer Ubuntu version (from 20.04). We have seen the problem https://issues.apache.org/jira/browse/FLINK-34194 which deals with updating the build CI image used in the Flink bu

RE: [jira] [Created] (FLINK-36716) Address vulnerabilities in Flink UI

Hi, I already started working on this issue to remove the critical/high vulnerabilities and I'm currently able to raise a PR. Could you please assign the current issue to me ? On 2024/11/14 13:13:00 "Mehdi (Jira)" wrote: > Mehdi created FLINK-36716: > - > >

Re: [jira] [Created] (FLINK-36476) Remove all deprecated methods under public APIs in table modules

hello, xuyang, I want to contribute code or ask some questions in jira, who can help me register an account? thanks xuyang (Jira) 于2024年10月11日周五 10:40写道： > xuyang created FLINK-36476: > -- > > Summary: Remove all deprecated methods under public APIs in >

Re: [jira](FLINK-36127) Apply for a jira account and repair bug

Welcome Yuming to join the Flink Community！ Your Jira account has been created and I’ve assigned ticket FLINK-36127 to you. Best, Leonard > 2024年8月22日 下午8:14，Yu Chen 写道： > > Hi Yunming, > > Thanks for help to resolve the ticket FLINK-36127, and welcome to join flink > community. > > I notic

Re: [jira](FLINK-36127) Apply for a jira account and repair bug

Hi Yunming, Thanks for help to resolve the ticket FLINK-36127, and welcome to join flink community. I noticed that Leonard was processing request recently, and cc’ed. Best, Yu Chen. > 2024年8月22日 20:01，Yunming Tang 写道： > > Dear committers, > I'm willing to repair the bug of FLINK-36127 and

Re: [jira](FLINK-35444) Apply for a jira account and repair bug

Copy that! I've logged into jira and left a comment for FLINK-35444, please assign this issue to me. Many thanks! Leonard Xu 于2024年8月22日周四 17:43写道： > Welcome @kyzheng for joining Flink Community, I just processed jira > account pending requests these days, hope your jira account have been > cre

Re: [jira](FLINK-35444) Apply for a jira account and repair bug

Welcome @kyzheng for joining Flink Community, I just processed jira account pending requests these days, hope your jira account have been created. I’m not sure the result because the jira account request doesn’t contains applier’s email address, feel free to ping me if your account still not rea

Re: [jira](FLINK-35444) Apply for a jira account and repair bug

Hi, I think you can file PR wihout jira access. Once the PR is there we can handle the rest. Please read through the contribution guide [1], which can give you good corner points. [1] https://flink.apache.org/how-to-contribute/contribute-code/ BR, G On Thu, Aug 22, 2024 at 10:06 AM 郑恺原 wrote:

Re: jira account permission

Hi Zhengke, You can fill in information on this page: https://selfserve.apache.org/jira-account.html to request a JIRA account. If you are new and want to contribute to Apache Flink, you can refer to the contribution guide here[1]. Wish you a great experience! refer: [1] https://flink.apache.org

Re: [jira] [Updated] (FLINK-35336) SQL failed to restore from savepoint after change in default-parallelism

Hi Keith Lee, Yes, a FLIP will be required. Best regards, Martijn On Mon, May 13, 2024 at 2:51 PM Keith Lee wrote: > Thank you Martijn for confirming and switching the Jira to New Feature. > > I intend to explore approaches on implementing the feature to allow for: > > 1. Configurations that

Re: [jira] [Updated] (FLINK-35336) SQL failed to restore from savepoint after change in default-parallelism

Thank you Martijn for confirming and switching the Jira to New Feature. I intend to explore approaches on implementing the feature to allow for: 1. Configurations that will make Flink SQL job restore robust to parallelism changes 2. Configurations that will allow best effort Flink SQL job restore

Re: [jira] [Created] (FLINK-35336) SQL failed to restore from savepoint after change in default-parallelismFlink/Flink:User

Hi all, I ran into issue where unmodified SQL failed to restore from savepoint after change in default-parallelism. This seems to be quite a big limitation it prevents Flink SQL user from scaling freely. Would appreciate if anyone can dis/confirm that this is a bug before I start disambiguating t

Re: [jira] [Created] (FLINK-34696) GSRecoverableWriterCommitter is generating excessive data blobs

Yes, the issue is recoverability. However, there is one thing you can do. Create a separate bucket in GCP for temporary files and initialize the filesystem configuration (via FileSystem.initialize) with *gs.writer.temporary.bucket.name * set to the name of th

Re: jira permission request

Hi, In order to contribute to Apache Flink, please ping the author of the Jira ticket that you would like to work on, so it can be assigned to you. There are no other permissions required. Best regards, Martijn On Tue, Feb 6, 2024 at 2:25 AM 李游 wrote: > > HI, > I want to contribute to Apache f

Re:[jira] [Created] (FLINK-34018) Add flink 1.19 verison in ci for flink-connector-aws

退订 At 2024-01-08 17:49:00, "Zhongqiang Gong (Jira)" wrote: >Zhongqiang Gong created FLINK-34018: >--- > > Summary: Add flink 1.19 verison in ci for flink-connector-aws > Key: FLINK-34018 > URL: https://issue

Re: [jira] [Created] (FLINK-33753) ContinuousFileReaderOperator consume records as mini batch

I understand the operator wouldn't be causing the checkpoint issue based on your comments. I need to debug further, but the symptoms are not showing up again for my Cx. I will close this as not a problem. Thanks for the detailed explanations. On Wed, Dec 6, 2023 at 8:22 PM Darin Amos wrote: > Ju

Re: [jira] [Created] (FLINK-33753) ContinuousFileReaderOperator consume records as mini batch

Just to confirm, I ran a test this morning using a large file with only a single file split that took over 10 minutes to process. My checkpoints still executed as expected every minute with minimal latency (sub second). Though I ran this with 1.15.4. What evidence do you have that this operator is

Re: [jira] [Created] (FLINK-33753) ContinuousFileReaderOperator consume records as mini batch

Thanks Darin for the details. Below is the problematic StreamTask, which has not processed the priority event (checkpoint barrier) from the mailbox, and has been there throughout the checkpoint timeout interval. And it is reading and collecting all the records from the split. Not sure why the exec

Re: [jira] [Created] (FLINK-33753) ContinuousFileReaderOperator consume records as mini batch

I apologize, I was a little off with my description, it's been a while since I have looked at this code but I have refreshed myself. The line I referred to earlier was correct though. This operator only processes records in a file split while the operator is idle, meaning there are no more incomin

Re: [jira] [Created] (FLINK-33753) ContinuousFileReaderOperator consume records as mini batch

They way I understand this loop is that the ContinuiousFileReaderOperator only processes records in the background while the operator is idle, i.e. while it's not receiving any records. At the very bottom of that loop here

Re: [jira] [Created] (FLINK-33753) ContinuousFileReaderOperator consume records as mini batch

This is the loop - code reference , where it fetches all records from the split, and then only the MailboxProcessor gets control to

Re: [jira] [Created] (FLINK-33753) ContinuousFileReaderOperator consume records as mini batch

I thought for sure this was already the existing behavior with this operator. Does it not check the mailbox executor after every record read? On Tue, Dec 5, 2023 at 6:48 AM Prabhu Joseph (Jira) wrote: > Prabhu Joseph created FLINK-33753: > - > > S

Re: JIRA Permission Opening Application

Thank you, Weihua. Yes, I have created a new Issue to familiarize myself with the complete process of contribution! > 2023年7月11日 13:37，Weihua Hu 写道： > > ​满帮安全提示: 此封邮件来自公司外部，除非您能判断发件人和知道邮件内容安全，否则请勿打开链接或者附件。 > MB Security Tips: Please do not click on links or open attachments unless you > trust

Re: JIRA Permission Opening Application

Hi YongPing Thank you for your willingness to contribute, no special permissions are required, just find the issue you want to contribute to or create a new one and then you contribute the code, refer to the how-to-contribute[1] [1] https://flink.apache.org/how-to-contribute/contribute-code/ Bes

Re: [jira] [Created] (FLINK-32130) previous checkpoint will be broke by the subsequent incremental checkpoint

How to unsubscribe? On Fri, May 19, 2023 at 8:13 AM Feifan Wang (Jira) wrote: > Feifan Wang created FLINK-32130: > --- > > Summary: previous checkpoint will be broke by the subsequent > incremental checkpoint > Key: FLINK-32130 >

Re: [jira] [Created] (FLINK-31798) Add config to enable/disable Kubernetes Events

Yanko24 > 在 2023年4月13日，22:40，Daren Wong (Jira) 写道： > > Daren Wong created FLINK-31798: > -- > > Summary: Add config to enable/disable Kubernetes Events > Key: FLINK-31798 > URL: https://issues.apache.org/jira/browse

Re: [jira] [Created] (FLINK-31690) The current key is not set for KeyedCoProcessOperator

Hi, you need send email to dev-unsubscr...@flink.apache.org with any contents or subject [1] https://flink.apache.org/community.html#how-to-subscribe-to-a-mailing-list Best, Weihua On Mon, Apr 3, 2023 at 10:35 AM 越张 wrote: > 退订 > > Dian Fu (Jira) 于2023年4月3日周一 10:33写道： > > > Dian Fu created

Re: [jira] [Created] (FLINK-31690) The current key is not set for KeyedCoProcessOperator

退订 Dian Fu (Jira) 于2023年4月3日周一 10:33写道： > Dian Fu created FLINK-31690: > --- > > Summary: The current key is not set for KeyedCoProcessOperator > Key: FLINK-31690 > URL: https://issues.apache.org/jira/browse/FLINK-31690 >

Re: [jira] [Created] (FLINK-31660) flink-connectors-kafka is not runnable in the IDE

Hi, Beshada. I got same problem before. And it's indeed a IDE bug not flink project. Some of my previous attempts, I hope it will be useful to you 1.you can try to reimport the flink project (clear cache & make a clean env). 2.uou can temporarily work around this by running a kafka test with mvn t

Re: [jira] [Created] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

Yes, the StreamingFileSink is not affected. Best, Fabian

Re: [jira] [Created] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

Thanks Fabian. Do you know if the legacy StreamingFileSink has the same issues? Not asking you to do research but just wondering if you happen to know. On Tue, Nov 29, 2022 at 8:46 AM Fabian Paul wrote: > Hi folks, > > I did some initial investigation, and the problem seems twofold. > > If no

Re: [jira] [Created] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

Hi folks, I did some initial investigation, and the problem seems twofold. If no post-commit topology is used, we do not run into a problem where we could lose data but since we do not clean up the state correctly, we will hit this [1] when trying to stop the pipeline with a savepoint after we ha

Re: [jira] [Created] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

Let's loop in Fabian to clarify. I'm not sure if this only occurs when using a post-commit topology (like compaction), but he can definitely clarify :) On Tue, Nov 29, 2022 at 2:19 PM Galen Warren wrote: > This seems scary -- am I interpreting it correctly to mean that unified > FileSink doesn't

Re: [jira] [Created] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

This seems scary -- am I interpreting it correctly to mean that unified FileSink doesn't work properly with jobs that need to be stopped-with-savepoints and restarted? Should one use the deprecated StreamingFileSink until this is resolved? On Tue, Nov 29, 2022 at 6:02 AM Fabian Paul (Jira) wrote

Re: [jira] [Created] (FLINK-30134) Annotate all the public classes for the delegation token framework

unsubscript Gabor Somogyi (Jira) 于2022年11月22日周二 15:37写道： > Gabor Somogyi created FLINK-30134: > - > > Summary: Annotate all the public classes for the delegation > token framework > Key: FLINK-30134 > URL: https:/

Re: [jira] [Created] (FLINK-29856) Triggering savepoint does not trigger source operator checkpoint

This sounds like a pretty serious issue. Has anybody looked into this already? -Max On Thu, Nov 3, 2022 at 3:51 AM Mason Chen (Jira) wrote: > Mason Chen created FLINK-29856: > -- > > Summary: Triggering savepoint does not trigger source > operator ch

Re: [jira] [Created] (FLINK-28372) Investigate Akka Artery

Hi Razin, https://issues.apache.org/jira/browse/FLINK-29281 is the ticket to keep an eye on regarding this topic. Best regards, Martijn On Fri, Nov 4, 2022 at 11:11 PM Razin Bouzar wrote: > Hi all, > > Has there been any further work or discussions around this issue? The Netty > security vuln

Re: [jira] [Created] (FLINK-28372) Investigate Akka Artery

Hi all, Has there been any further work or discussions around this issue? The Netty security vulnerabilities in 3.10.6 are of some concern. On Mon, Jul 4, 2022 at 3:45 AM Chesnay Schepler (Jira) wrote: > Chesnay Schepler created FLINK-28372: > > >

Re: [jira] [Created] (FLINK-29807) Drop TypeSerializerConfigSnapshot and savepoint support from Flink versions < 1.8.0

Hi, 15725139602 Please send email to dev-unsubscr...@flink.apache.org if you want to unsubscribe the mail from dev , and you can refer[1] for more details. Best, Leonard [1]https://flink.apache.org/community.html#mailing-lists > 2022年10月31日 下午6:02，m15725139602 <15725139...@163.com> 写道： > > u

Re: [jira] [Created] (FLINK-29807) Drop TypeSerializerConfigSnapshot and savepoint support from Flink versions < 1.8.0

unsubscribe | | 15725139...@163.com | | 邮箱：15725139...@163.com | Replied Message | From | Piotr Nowojski (Jira) | | Date | 10/31/2022 17:55 | | To | dev@flink.apache.org | | Cc | | | Subject | [jira] [Created] (FLINK-29807) Drop TypeSerializerConfigSnapshot and savepoint support f

Re: jira

Hi Simon, Thanks for your passion for contributing to the Flink community. You don't need a contributor permission to contribute your code to Flink. Find an open issue you are interested in at http://issues.apache.org/jira/browse/FLINK and comment with your ideas. It would be a good start for issu

Re: [jira] [Created] (FLINK-25443) Embedded statefulfunction jakson /java8 date time issue

Are you using RequestReplyFunctionBuilder? This may be the same issue I ran into: [FLINK-25197] Using Statefun RequestReplyFunctionBuilder fails with Java 8 date/time type `java.time.Duration` not supported by default: add Module "org.apache.flink.shaded.jackson2.com.fasterxml.jackson.datatype:jac

Re: [jira] [Created] (FLINK-25197) Using Statefun RequestReplyFunctionBuilder fails with Java 8 date/time type `java.time.Duration` not supported by default: add Module "org.apache.flink.shaded.jackso

Thanks for getting back to me and Happy Holidays! I'll open a PR soon, it's a simple fix. On Mon, Dec 20, 2021 at 9:42 AM Seth Wiesman wrote: > Hi Galen, > > Sorry for the late reply, a lot of people are on sporadic schedules with > the holidays. A PR would be very welcome! I've gone ahead and a

Re: [jira] [Created] (FLINK-25197) Using Statefun RequestReplyFunctionBuilder fails with Java 8 date/time type `java.time.Duration` not supported by default: add Module "org.apache.flink.shaded.jackso

Hi Galen, Sorry for the late reply, a lot of people are on sporadic schedules with the holidays. A PR would be very welcome! I've gone ahead and assigned you the Jira. And I'll watch the repo to review your pr. cheers, Seth On Mon, Dec 20, 2021 at 8:24 AM Galen Warren wrote: > I just wanted t

Re: [jira] [Created] (FLINK-25197) Using Statefun RequestReplyFunctionBuilder fails with Java 8 date/time type `java.time.Duration` not supported by default: add Module "org.apache.flink.shaded.jackso

I just wanted to check in on this, is there any interest in a PR to fix this issue? Looking at the master branch, it still looks to be a problem. Thanks. On Mon, Dec 6, 2021 at 9:52 AM Galen Warren (Jira) wrote: > Galen Warren created FLINK-25197: > > >

Re: [jira] [Created] (FLINK-23872) The example of EXPLAIN Statements in the official document is wrong, and the ‘)’ is missing

Hi, Leonard Xu Thanks, my mistake. Best, Chuang Li | | Chuang Li | | jasonlee1...@163.com | 签名由网易邮箱大师定制 On 08/20/2021 10:17，Leonard Xu wrote： 在 2021年8月19日，21:42，Chuang Li 写道： The similar document PR[1] you sent me, I found that it is not the same problem. I'm not sure if I misunderstood.

Re: [jira] [Created] (FLINK-23872) The example of EXPLAIN Statements in the official document is wrong, and the ‘)’ is missing

> 在 2021年8月19日，21:42，Chuang Li 写道： > > The similar document PR[1] you sent me, I found that it is not the same > problem. I'm not sure if I misunderstood. > I mean the PR fixed the issue you reported and you can take a look when you fix. Best, Leonard

Re: [jira] [Created] (FLINK-23872) The example of EXPLAIN Statements in the official document is wrong, and the ‘)’ is missing

Hi, Leonard Xu Thank you for your answers. Maybe I didn’t describe it clearly. I think there is an error here in The following examples show how to run an EXPLAIN statement in TableEnvironment. There is a problem that the')' mabye is missing in the create table statement, for example the case

Re: [jira] [Created] (FLINK-23872) The example of EXPLAIN Statements in the official document is wrong, and the ‘)’ is missing

Hi, Chuang Li Thanks for open the issue, I just reviewed a similar document PR[1] for master branch, maybe you can refer it for branch release-1.13/release-1.12/release-1.11 Best, Leonard [1] https://github.com/apache/flink/pull/16051 > 在 2021年8月19日，18:00，Chuang Li 写道： > > > > Dear all, >

Re:[jira] [Created] (FLINK-23872) The example of EXPLAIN Statements in the official document is wrong, and the ‘)’ is missing

Dear all, I'm very sorry to report twice due to a network issue. Thanks, Chuang Li | | Chuang Li | | jasonlee1...@163.com | 签名由网易邮箱大师定制 On 08/19/2021 17:52，JasonLee (Jira) wrote： JasonLee created FLINK-23872: Summary: The example of EXPLAIN Statements in th

Re: [jira] [Created] (FLINK-23674) flink restart with checkpoint ,kafka producer throw exception

退订 发自我的iPhone -- Original -- From: meetsong (Jira)

Re: [jira] [Created] (FLINK-22401) Python tests fail with "Slot ... is not allocated by job ..."

hi,   can you share your parameters about the tm slots and job parallelism?                                                 best wishes                                              liang ---Original--- From: "Dawid Wysakowicz (Jira)"https://issues.apache.org/jira/browse/FLINK-22401    

Re: [jira] [Created] (FLINK-21986) taskmanager native memory not release timely after restart

Thanks for raising this issue Feifan. I think it is very important to fix it. I will take a look at your PR. Cheers, Till On Tue, Apr 20, 2021 at 5:35 AM zoltar9264 wrote: > > > Hi community, > I raised this issue about three weeks ago. After several weeks of > investigation, I found th

Re:[jira] [Created] (FLINK-21986) taskmanager native memory not release timely after restart

Hi community, I raised this issue about three weeks ago. After several weeks of investigation, I found the root cause of this issue and explained it in the issue comments. And I raised a PR to fix this problem ( I'm sorry that I didn't know before that I should raise the PR a

Re: [jira] [Created] (FLINK-22228) Random log exception when tasks finish after a checkpoint was started

退订 On 04/12/2021 17:10, Chesnay Schepler (Jira) wrote: Chesnay Schepler created FLINK-8: Summary: Random log exception when tasks finish after a checkpoint was started Key: FLINK-8 URL: https://issues.a

Re: [jira] [Created] (FLINK-21820) JDBC connector shouldn't read all rows in per statement by default

unsubscribe Leonard Xu (Jira) 于2021年3月16日周二 下午8:05写道： > Leonard Xu created FLINK-21820: > -- > > Summary: JDBC connector shouldn't read all rows in per > statement by default > Key: FLINK-21820 > URL: https://issues.a

Re: JIRA Username

Hi, Welcome to the community! You don't need a contributor permission to contribute to Apache Flink. Simply find a JIRA ticket you'd like to work on and ask a committer to assign you to the ticket. You may find more details in the contribution guidelines [1]. [1] https://flink.apache.org/contribu

Re:[jira] [Created] (FLINK-21685) Flink JobManager failed to restart in K8S HA setup

Hello, looking at your error, it should be that the file could not be found, or there was a communication problem. Let me ask if your flink on k8s uses the StatefulSet mode? Or can you find the location of ck storage now? At 2021-03-09 15:23:00, "Peng Zhang (Jira)" wrote: >Peng

Re: [jira] [Created] (FLINK-16595) Support extra hadoop filesystem URLs for which to request delegation tokens

Hi all , I hava solved this problem in my production environment, and I would like to do something for the community, could you assign this issue to me？ -- Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/

Re: [jira] [Created] (FLINK-17491) Translate Training page on project website

It seems that the link of the md file needs to be updated. On Fri, May 1, 2020 at 7:10 AM David Anderson (Jira) wrote: > David Anderson created FLINK-17491: > -- > > Summary: Translate Training page on project website > Key: FLINK

Re: JIRA Contributor

Hi shx, Glad to hear that you're willing to contribute! Flink currently does not have contributor permissions. To contribute to an issue, just reply to the issue with your thoughts and create a PR after the discussion with community about the issue. shx <17611022...@163.com> 于2020年4月24日周五 下午3:59写

Re: [jira] [Commented] (FLINK-17200) Add connectors to ClickHouse

We discussed splitting the project not too long ago and decided against it due to maintenance overhead. In any case the Flink project does not have the capacity to maintain every connector. Frequently it happened that there was only 1 contributor working on a connector, at which point the proj

Re: [jira] [Commented] (FLINK-17200) Add connectors to ClickHouse

@Dawid @dev Can we separate the flink-connectors project so that we can support more connectors in the future? Like this jira：Add connectors to ClickHouse Best Regards jinhai...@gmail.com > 2020年4月17日 下午3:07，Dawid Wysakowicz (Jira) 写道： > > >[ > https://issues.apache.org/jira/browse/F

Re: [jira] [Created] (FLINK-17202) Add SQL for ClickHouse connector

Add Table API and SQL for ClickHouse connector is a better description > 在 2020年4月17日，下午1:43，jinhai (Jira) 写道： > > jinhai created FLINK-17202: > -- > > Summary: Add SQL for ClickHouse connector > Key: FLINK-17202 > URL: htt

Re: [jira] [Created] (FLINK-15644) Add support for SQL query validation

Ok thanks for the pointer, I wasn't awareof that! Il Dom 19 Gen 2020, 03:00 godfrey he ha scritto: > hi Flavio, TableEnvironment.getCompletionHints maybe already meet the > requirement. > > Flavio Pompermaier 于2020年1月18日周六 下午3:39写道： > > > Why not adding also a suggest() method (also unimplement

Re: [jira] [Created] (FLINK-15644) Add support for SQL query validation

hi Flavio, TableEnvironment.getCompletionHints maybe already meet the requirement. Flavio Pompermaier 于2020年1月18日周六 下午3:39写道： > Why not adding also a suggest() method (also unimplemented initially) that > would return the list of suitable completions/tokens on the current query? > How complex eo

Re: [jira] [Created] (FLINK-15644) Add support for SQL query validation

Why not adding also a suggest() method (also unimplemented initially) that would return the list of suitable completions/tokens on the current query? How complex eould it be to implement it in you opinion? Il Ven 17 Gen 2020, 18:32 Fabian Hueske (Jira) ha scritto: > Fabian Hueske created FLINK-1

Re: [jira] [Created] (FLINK-15017) add a thrift jdbc/odbc server for Flink

Hi gteeice, CC: godfrey and tsreaper. I know they are considering and designing JDBC support. I believe there will be a lot of progress on 1.11. Best, Jingsong Lee On Tue, Dec 24, 2019 at 11:07 AM 唐晨阳 wrote: > Is there any detailed plan or progress regarding jdbc support? > On 12/3/2019 04:41，

Re:[jira] [Created] (FLINK-15017) add a thrift jdbc/odbc server for Flink

Is there any detailed plan or progress regarding jdbc support? On 12/3/2019 04:41，Bowen Li (Jira) wrote： Bowen Li created FLINK-15017: Summary: add a thrift jdbc/odbc server for Flink Key: FLINK-15017 URL: https://issues.apache.org/jira/browse/FLINK-15017 Project:

Re: [jira] [Created] (FLINK-15283) Scala version of TableSinkUtils has a problem when validating sinks.

Hi jingjing, Please leave comment under the JIRA issue[1] to keep the discussion in one place. Thanks, Jark [1]: https://issues.apache.org/jira/browse/FLINK-15283 On Mon, 16 Dec 2019 at 23:00, jingjing bai wrote: >- > >I think you might have misunderstood the sink schema. It is a ord

Re: [jira] [Created] (FLINK-15283) Scala version of TableSinkUtils has a problem when validating sinks.

- I think you might have misunderstood the sink schema. It is a order field but not json (or mapping) field in table sink ddl. At least that's the case in Sql. - for exemple. DDL sink schema as and the sql is insert into table select A, C ,B from t2。 - A ,B and

Re: [jira] [Created] (FLINK-14535) Fix distinct key type for DecimalType in DistinctInfo

unsubscribe zha...@lenovocloud.com From: Zhenghua Gao (Jira) Date: 2019-10-26 09:33 To: dev Subject: [jira] [Created] (FLINK-14535) Fix distinct key type for DecimalType in DistinctInfo Zhenghua Gao created FLINK-14535: Summary: Fix distinct

Re: [jira] [Created] (FLINK-13987) add new logs api, see more log files and can see logs by pages

Hi folks, I have updated the description, this is the new : As the job running, the log files are becoming large. Current log api often blocks or don't work. It's unfriendly for user. As application runs on jvm, sometime user need see log of gc. Above all, i list new api: - list taskmanage

Re: Jira issue assignment privs

Hi Mans, There has been an announcement by the community[1] which apply a restrictive JIRA workflow. Briefly now it only allow committers and PMC members to assign somebody to a JIRA ticket. This is what you meet. You could send a request for assigning you to the ticket on dev list and hopefully

Re: [jira] [Created] (FLINK-6291) Internal Timer service cannot be "removed"

Hi everybody, I think I'm in the same issue above described in https://issues.apache.org/jira/browse/FLINK-6291 . Flink1-6.4 I have had this savepoint with a timer service belonging to a process function. When I restore a new job w/o the former process function ti fails in the following way. What i

Re: [jira] [Created] (FLINK-13248) Enhance mailbox executor with yield-to-downstream functionality

vg On Fri 12 Jul, 2019, 7:19 PM Stefan Richter (JIRA), wrote: > Stefan Richter created FLINK-13248: > -- > > Summary: Enhance mailbox executor with yield-to-downstream > functionality > Key: FLINK-13248 > URL: htt

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

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: [jira] [Created] (FLINK-13139) Various Hive tests fail on Travis

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: [jira] [Created] (FLINK-12196) FlinkKafkaProducerITCase#testRunOutOfProducersInThePool throws NPE

! Regards, Alex. Sent from my BlackBerry Passport.   Original Message   From: vinoyang (JIRA) Sent: Monday, April 15, 2019 4:08 PM To: dev@flink.apache.org Reply To: dev@flink.apache.org Subject: [jira] [Created] (FLINK-12196) FlinkKafkaProducerITCase#testRunOutOfProducersInThePool throws NPE vi

Re: [jira] [Created] (FLINK-12153) 提交flink job到flink环境下报错

Hi gaojunjie, 1. Please use English to describe your JIRA issue although I think this is more like a question not a bug report 2. You can send your question in flink-user-zh mailing list which Chinese is supported 3. I think the exception is clear enough that this feature is not supported in your H

Re: [jira] [Created] (FLINK-12002) Adaptive Parallelism of Job Vertex Execution

On 2019/03/25 08:30:00, "ryantaocer (JIRA)" wrote: > ryantaocer created FLINK-12002: > -- > > Summary: Adaptive Parallelism of Job Vertex Execution > Key: FLINK-12002 > URL: https://issues.apache.org/jira/browse/FL

Re: [jira] [Created] (FLINK-11654) ProducerFencedExceptions from Kafka in EXACTLY_ONCE mode due to identical transactional IDs in multiple jobs

thank you for the quick response. On Mon, Feb 18, 2019 at 8:58 PM Jürgen Kreileder (JIRA) wrote: > Jürgen Kreileder created FLINK-11654: > > > Summary: ProducerFencedExceptions from Kafka in EXACTLY_ONCE > mode due to identical transactional

Re: [jira] [Updated] (FLINK-11590) Redundant spaces occur when the string true is generated using 'case when' grammar

Hi, dong I think this is due to the `case when` expression will have the longest length of all branches, so in the example you post , It will be char(5). And a CHAR value will always be right-padded with the spaces to the declared length. You can fix this by cast the type to varchar or use the tr

Re: [jira] [Created] (FLINK-11311) StreamSource implements StreamOperator interface multiple times.

Hi all, Could any committer help me to review this issue? PR is now available on Github: https://github.com/apache/flink/pull/7492 Benchao Li (JIRA) 于2019年1月13日周日 下午10:23写道： > Benchao Li created FLINK-11311: > -- > > Summary: StreamSource implements

Re: JIRA notifications

It seems that some people find it useful to receive JIRA mails for new issues only. The "issues" mailing list gets all JIRA notifications, including updates to existing issues. So I'd leave things as they are now because JIRA doesn't allow individuals to configure receiving notifications only

Re: JIRA notifications

+1 Flavio Pompermaier 于2018年11月21日周三 下午7:24写道： > +1 > > On Wed, Nov 21, 2018 at 12:05 PM Saar Bar wrote: > > > 💯 agree > > > > Sent from my iPhone > > > > > On 21 Nov 2018, at 13:03, Maximilian Michels wrote: > > > > > > Hi! > > > > > > Do you think it would make sense to send JIRA notificatio

Re: JIRA notifications

+1 On Wed, Nov 21, 2018 at 12:05 PM Saar Bar wrote: > 💯 agree > > Sent from my iPhone > > > On 21 Nov 2018, at 13:03, Maximilian Michels wrote: > > > > Hi! > > > > Do you think it would make sense to send JIRA notifications to a > separate mailing list? Some people just want to casually follow

Re: JIRA notifications

💯 agree Sent from my iPhone > On 21 Nov 2018, at 13:03, Maximilian Michels wrote: > > Hi! > > Do you think it would make sense to send JIRA notifications to a separate > mailing list? Some people just want to casually follow the mailing list and > it requires a filter to delete all the JIRA

Re: JIRA assignment

Hi Joey, Thanks for your offer to help and contribute to Flink! Testing a release candidate is always a much appreciated. A new RC for Flink 1.7.0 should come out in the next days. Regarding the backlog of PRs, everybody is welcome to help reviewing contributions. I would recommend to have a loo

Re: JIRA assignment

Thanks Fabian! Let me know if I can help with backlog of PRs or with the 1.7 release. -Joey On Fri, Nov 16, 2018 at 1:46 AM Fabian Hueske wrote: > Hi Joey, > > First of all, sorry for the bad contribution experience so far. > I don't know the BlobManager well enough, otherwise I'd had a look a

Re: JIRA assignment

Hi Joey, First of all, sorry for the bad contribution experience so far. I don't know the BlobManager well enough, otherwise I'd had a look at your PR. The Flink community (and committers especially) are currently overwhelmed with the number of PRs. We receive all kinds of contributions from larg

Re: JIRA assignment

One quick follow up on this. The PR has been open for about a month. I don't want to bug the folks to review it, but I'm not sure what the etiquette is for getting PRs reviewed. Any help would be appreciated! Thanks! -Joey On Wed, Nov 7, 2018 at 6:44 AM Joey Echeverria wrote: > Thanks Till! >

Re: JIRA assignment

Thanks Till! -Joey > On Nov 7, 2018, at 02:32, Till Rohrmann wrote: > > I've given you permissions and assigned you to this ticket. > > Cheers, > Till > >> On Tue, Nov 6, 2018 at 7:25 PM Joey Echeverria wrote: >> I submitted a PR[1] for FLINK-10213[2] awhile ago, but I couldn't assign >> the

Re: JIRA assignment

I've given you permissions and assigned you to this ticket. Cheers, Till On Tue, Nov 6, 2018 at 7:25 PM Joey Echeverria wrote: > I submitted a PR[1] for FLINK-10213[2] awhile ago, but I couldn't assign > the issue to myself or update it's status in JIRA. Is there anything I > need to do to get

Re: [jira] [Created] (FLINK-10225) Cannot access state from a empty taskmanager

Thanks for posting this issue, I also recently saw this. The cause appears to be that the TaskExecutor's queryable state proxy knows only about jobs that are using slot(s) from that executor. Note FLINK-10117 calls for queryable state to be exposed via the REST endpoint, which may indirectly addr

Re: [jira] [Created] (FLINK-9832) Allow commas in job submission query params

A got a similar issue that single quote ‘ get removed too. See if you can reproduce. Sent from my iPhone > On Jul 12, 2018, at 05:33, Ufuk Celebi (JIRA) wrote: > > Ufuk Celebi created FLINK-9832: > -- > > Summary: Allow commas in job submission quer

  1   2   3   >