[jira] [Commented] (FLINK-32938) flink-connector-pulsar should remove all `PulsarAdmin` calls

[ https://issues.apache.org/jira/browse/FLINK-32938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761087#comment-17761087 ] Neng Lu commented on FLINK-32938: - I have prepared a draft PR for solve this issue: http

[jira] [Created] (FLINK-32938) flink-connector-pulsar should remove all `PulsarAdmin` calls

Neng Lu created FLINK-32938: --- Summary: flink-connector-pulsar should remove all `PulsarAdmin` calls Key: FLINK-32938 URL: https://issues.apache.org/jira/browse/FLINK-32938 Project: Flink Issue Typ

[jira] [Comment Edited] (FLINK-32710) The LeaderElection component IDs for running is only the JobID which might be confusing in the log output

[ https://issues.apache.org/jira/browse/FLINK-32710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748644#comment-17748644 ] Jiadong Lu edited comment on FLINK-32710 at 7/29/23 2:56 PM: -

[jira] [Commented] (FLINK-32710) The LeaderElection component IDs for running is only the JobID which might be confusing in the log output

[ https://issues.apache.org/jira/browse/FLINK-32710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748644#comment-17748644 ] Jiadong Lu commented on FLINK-32710: Hi, Matthias. If i understand correctly , this

[jira] [Commented] (FLINK-32157) Replaces LeaderConnectionInfo with LeaderInformation

[ https://issues.apache.org/jira/browse/FLINK-32157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17742235#comment-17742235 ] Jiadong Lu commented on FLINK-32157: hi [~mapohl] , i would like to address this iss

[jira] [Commented] (FLINK-24595) Programmatic configuration of S3 doesn't pass parameters to Hadoop FS

[ https://issues.apache.org/jira/browse/FLINK-24595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17721160#comment-17721160 ] Lu commented on FLINK-24595: i have the save problem in 1.15.2, it seems   flink-s3-fs-hado

[jira] [Created] (FLINK-32003) Release 3.0.0-1.16 and 1.16.1 doesn't work with OAuth2

Neng Lu created FLINK-32003: --- Summary: Release 3.0.0-1.16 and 1.16.1 doesn't work with OAuth2 Key: FLINK-32003 URL: https://issues.apache.org/jira/browse/FLINK-32003 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-30193) could flink has dynamic rebalance according to the load of downstream operators

Lu created FLINK-30193: -- Summary: could flink has dynamic rebalance according to the load of downstream operators Key: FLINK-30193 URL: https://issues.apache.org/jira/browse/FLINK-30193 Project: Flink

[jira] [Commented] (FLINK-30131) flink iterate will suspend when record is a bit large

[ https://issues.apache.org/jira/browse/FLINK-30131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638219#comment-17638219 ] Lu commented on FLINK-30131: [~gaoyunhaii]  thanks for your apply. the pictures below show u

[jira] [Updated] (FLINK-30131) flink iterate will suspend when record is a bit large

[ https://issues.apache.org/jira/browse/FLINK-30131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lu updated FLINK-30131: --- Attachment: image-2022-11-24-17-12-02-129.png > flink iterate will suspend when record is a bit large >

[jira] [Updated] (FLINK-30131) flink iterate will suspend when record is a bit large

[ https://issues.apache.org/jira/browse/FLINK-30131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lu updated FLINK-30131: --- Attachment: image-2022-11-24-17-12-47-024.png > flink iterate will suspend when record is a bit large >

[jira] [Updated] (FLINK-30131) flink iterate will suspend when record is a bit large

[ https://issues.apache.org/jira/browse/FLINK-30131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lu updated FLINK-30131: --- Attachment: image-2022-11-24-17-10-45-651.png > flink iterate will suspend when record is a bit large >

[jira] [Commented] (FLINK-30131) flink iterate will suspend when record is a bit large

[ https://issues.apache.org/jira/browse/FLINK-30131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17637525#comment-17637525 ] Lu commented on FLINK-30131: [~gaoyunhaii] ，I heard from [~Weijie Guo] that you are very pro

[jira] [Commented] (FLINK-30131) flink iterate will suspend when record is a bit large

[ https://issues.apache.org/jira/browse/FLINK-30131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17637523#comment-17637523 ] Lu commented on FLINK-30131: [~Weijie Guo] , Thanks for your reply. # yes, my job hanging f

[jira] [Created] (FLINK-30131) flink iterate will suspend when record is a bit large

Lu created FLINK-30131: -- Summary: flink iterate will suspend when record is a bit large Key: FLINK-30131 URL: https://issues.apache.org/jira/browse/FLINK-30131 Project: Flink Issue Type: Bug C

[jira] [Closed] (FLINK-29183) flink job ended before window time up while using bounded stream source

[ https://issues.apache.org/jira/browse/FLINK-29183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lu closed FLINK-29183. -- Resolution: Duplicate unify the discussion in FLINK-18647 and the mail list.  > flink job ended before window time up

[jira] [Commented] (FLINK-29183) flink job ended before window time up while using bounded stream source

[ https://issues.apache.org/jira/browse/FLINK-29183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621003#comment-17621003 ] Lu commented on FLINK-29183: [~gaoyunhaii]  Thanks for tell me this!   I have just looked at

[jira] [Commented] (FLINK-29183) flink job ended before window time up while using bounded stream source

[ https://issues.apache.org/jira/browse/FLINK-29183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17601576#comment-17601576 ] Lu commented on FLINK-29183: [~Weijie Guo] I know what do u mean.  But let's look at the ori

[jira] [Commented] (FLINK-29183) flink job ended before window time up while using bounded stream source

[ https://issues.apache.org/jira/browse/FLINK-29183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600713#comment-17600713 ] Lu commented on FLINK-29183: !image-2022-09-06-18-09-43-745.png|width=464,height=262! when

[jira] [Updated] (FLINK-29183) flink job ended before window time up while using bounded stream source

[ https://issues.apache.org/jira/browse/FLINK-29183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lu updated FLINK-29183: --- Attachment: image-2022-09-06-18-11-02-915.png > flink job ended before window time up while using bounded stream sou

[jira] [Updated] (FLINK-29183) flink job ended before window time up while using bounded stream source

[ https://issues.apache.org/jira/browse/FLINK-29183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lu updated FLINK-29183: --- Attachment: image-2022-09-06-18-10-11-848.png > flink job ended before window time up while using bounded stream sou

[jira] [Updated] (FLINK-29183) flink job ended before window time up while using bounded stream source

[ https://issues.apache.org/jira/browse/FLINK-29183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lu updated FLINK-29183: --- Attachment: image-2022-09-06-18-09-43-745.png > flink job ended before window time up while using bounded stream sou

[jira] [Updated] (FLINK-29183) flink job ended before window time up while using bounded stream source

[ https://issues.apache.org/jira/browse/FLINK-29183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lu updated FLINK-29183: --- Attachment: image-2022-09-06-18-09-40-132.png > flink job ended before window time up while using bounded stream sou

[jira] [Created] (FLINK-29183) flink job ended before window time up while using bounded stream source

Lu created FLINK-29183: -- Summary: flink job ended before window time up while using bounded stream source Key: FLINK-29183 URL: https://issues.apache.org/jira/browse/FLINK-29183 Project: Flink Issue Ty

[jira] [Commented] (FLINK-24882) Make SQL format identifier NOT case-sensitive.

[ https://issues.apache.org/jira/browse/FLINK-24882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17442930#comment-17442930 ] Neng Lu commented on FLINK-24882: - I think it's a conventions in flink sql that the `for

[jira] [Created] (FLINK-24389) getDescription() in `CatalogTableImpl` should check null

Neng Lu created FLINK-24389: --- Summary: getDescription() in `CatalogTableImpl` should check null Key: FLINK-24389 URL: https://issues.apache.org/jira/browse/FLINK-24389 Project: Flink Issue Type: Bu

[jira] [Commented] (FLINK-22667) Missing slash in URL

[ https://issues.apache.org/jira/browse/FLINK-22667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346170#comment-17346170 ] Yishuang Lu commented on FLINK-22667: - [~chesnay] Got it. Will do it next time   >

[jira] [Commented] (FLINK-22667) Fix the wrong file system ln java doc and documentation

[ https://issues.apache.org/jira/browse/FLINK-22667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345882#comment-17345882 ] Yishuang Lu commented on FLINK-22667: - Sure, thanks! > Fix the wrong file system ln

[jira] [Commented] (FLINK-22667) Fix the wrong file system ln java doc and documentation

[ https://issues.apache.org/jira/browse/FLINK-22667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344884#comment-17344884 ] Yishuang Lu commented on FLINK-22667: - The issue is addressed by this pull request: 

[jira] [Created] (FLINK-22667) Fix the wrong file system ln java doc and documentation

Yishuang Lu created FLINK-22667: --- Summary: Fix the wrong file system ln java doc and documentation Key: FLINK-22667 URL: https://issues.apache.org/jira/browse/FLINK-22667 Project: Flink Issue T

[jira] [Commented] (FLINK-21002) Support exactly once sink for JDBC in Table SQL API

[ https://issues.apache.org/jira/browse/FLINK-21002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266955#comment-17266955 ] bruce lu commented on FLINK-21002: -- *Super!  It's a great feature in Table/SQL*  > Sup

[jira] [Commented] (FLINK-18383) Translate "JDBC SQL Connector" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266739#comment-17266739 ] bruce lu commented on FLINK-18383: -- The translation job is finished! Hi, [~jark], could

[jira] [Commented] (FLINK-18383) Translate "JDBC SQL Connector" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17265780#comment-17265780 ] bruce lu commented on FLINK-18383: -- Okay! I got it! > Translate "JDBC SQL Connector" p

[jira] [Commented] (FLINK-18383) Translate "JDBC SQL Connector" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264876#comment-17264876 ] bruce lu commented on FLINK-18383: -- Maybe [~zhoupeijie] is off-line! I'm sure that I wi

[jira] [Commented] (FLINK-18383) Translate "JDBC SQL Connector" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264828#comment-17264828 ] bruce lu commented on FLINK-18383: -- I'm using and reviewing the source code of Flink JD

[jira] [Commented] (FLINK-14201) SQL supports redis sink connector

[ https://issues.apache.org/jira/browse/FLINK-14201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16937434#comment-16937434 ] Zijie Lu commented on FLINK-14201: -- [~karmagyz] There is a redis connector in the follo

[jira] [Created] (FLINK-14201) SQL supports redis sink connector

Zijie Lu created FLINK-14201: Summary: SQL supports redis sink connector Key: FLINK-14201 URL: https://issues.apache.org/jira/browse/FLINK-14201 Project: Flink Issue Type: Wish Componen

[jira] [Commented] (FLINK-13746) Elasticsearch (v2.3.5) sink end-to-end test fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16934921#comment-16934921 ] Zijie Lu commented on FLINK-13746: -- I have submitted a pull request [https://github.com

[jira] [Comment Edited] (FLINK-14099) SQL supports timestamp in Long

[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933009#comment-16933009 ] Zijie Lu edited comment on FLINK-14099 at 9/19/19 2:44 AM: --- I

[jira] [Commented] (FLINK-14099) SQL supports timestamp in Long

[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933009#comment-16933009 ] Zijie Lu commented on FLINK-14099: -- I have tried what you mentioned, but it seems that

[jira] [Comment Edited] (FLINK-13746) Elasticsearch (v2.3.5) sink end-to-end test fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932274#comment-16932274 ] Zijie Lu edited comment on FLINK-13746 at 9/18/19 3:23 PM: --- I

[jira] [Commented] (FLINK-13746) Elasticsearch (v2.3.5) sink end-to-end test fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932274#comment-16932274 ] Zijie Lu commented on FLINK-13746: -- I am planing to add a line in the "check_logs_for_e

[jira] [Comment Edited] (FLINK-13746) Elasticsearch (v2.3.5) sink end-to-end test fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932003#comment-16932003 ] Zijie Lu edited comment on FLINK-13746 at 9/18/19 8:39 AM: --- In

[jira] [Comment Edited] (FLINK-13746) Elasticsearch (v2.3.5) sink end-to-end test fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932003#comment-16932003 ] Zijie Lu edited comment on FLINK-13746 at 9/18/19 8:38 AM: --- In

[jira] [Comment Edited] (FLINK-13746) Elasticsearch (v2.3.5) sink end-to-end test fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932003#comment-16932003 ] Zijie Lu edited comment on FLINK-13746 at 9/18/19 8:35 AM: --- Is

[jira] [Comment Edited] (FLINK-14099) SQL supports timestamp in Long

[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932011#comment-16932011 ] Zijie Lu edited comment on FLINK-14099 at 9/18/19 7:52 AM: --- So

[jira] [Comment Edited] (FLINK-14099) SQL supports timestamp in Long

[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932011#comment-16932011 ] Zijie Lu edited comment on FLINK-14099 at 9/18/19 3:30 AM: --- Ma

[jira] [Comment Edited] (FLINK-14099) SQL supports timestamp in Long

[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932011#comment-16932011 ] Zijie Lu edited comment on FLINK-14099 at 9/18/19 3:30 AM: --- Ma

[jira] [Commented] (FLINK-14099) SQL supports timestamp in Long

[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932011#comment-16932011 ] Zijie Lu commented on FLINK-14099: -- Maybe we can add a parameter in the function timest

[jira] [Commented] (FLINK-14099) SQL supports timestamp in Long

[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932007#comment-16932007 ] Zijie Lu commented on FLINK-14099: -- I agree with [~felixzheng], So does the rowtime fie

[jira] [Commented] (FLINK-13746) Elasticsearch (v2.3.5) sink end-to-end test fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932003#comment-16932003 ] Zijie Lu commented on FLINK-13746: -- Is  [Terror] logged in the $FLINK_DIR/log? In the t

[jira] [Commented] (FLINK-14099) SQL supports timestamp in Long

[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931977#comment-16931977 ] Zijie Lu commented on FLINK-14099: -- I use a kafka connector and describe a schema as ro

[jira] [Created] (FLINK-14099) SQL supports timestamp in Long

Zijie Lu created FLINK-14099: Summary: SQL supports timestamp in Long Key: FLINK-14099 URL: https://issues.apache.org/jira/browse/FLINK-14099 Project: Flink Issue Type: New Feature Re

[jira] [Commented] (FLINK-13520) Add documentation for the different behavior of row count sliding window in blink planner

[ https://issues.apache.org/jira/browse/FLINK-13520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931133#comment-16931133 ] Zijie Lu commented on FLINK-13520: -- I am new and want to try it out. Can you assign thi

[jira] [Commented] (FLINK-992) Create CollectionDataSets by reading (client) local files.

[ https://issues.apache.org/jira/browse/FLINK-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931068#comment-16931068 ] Zijie Lu commented on FLINK-992: [~fhueske], I am new here. What's the status of this issu

[jira] [Commented] (FLINK-13746) Elasticsearch (v2.3.5) sink end-to-end test fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931043#comment-16931043 ] Zijie Lu commented on FLINK-13746: --  Do you mean the test class of Elasticsearch6SinkEx

[jira] [Issue Comment Deleted] (FLINK-13746) Elasticsearch (v2.3.5) sink end-to-end test fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zijie Lu updated FLINK-13746: - Comment: was deleted (was: Do you mean the test class of Elasticsearch6SinkExample?) > Elasticsearch (v

[jira] [Commented] (FLINK-13746) Elasticsearch (v2.3.5) sink end-to-end test fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931032#comment-16931032 ] Zijie Lu commented on FLINK-13746: -- Do you mean the test class of Elasticsearch6SinkExa

[jira] [Commented] (FLINK-13975) Translate "Upcoming Events" on Chinese index.html

[ https://issues.apache.org/jira/browse/FLINK-13975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931016#comment-16931016 ] Zijie Lu commented on FLINK-13975: -- I have interested in this issue. I want to try it o

[jira] [Commented] (FLINK-13682) Translate "Code Style - Scala Guide" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931014#comment-16931014 ] Zijie Lu commented on FLINK-13682: -- I want to try it out. Can you assign this issue to

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

[ https://issues.apache.org/jira/browse/FLINK-13278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931009#comment-16931009 ] Zijie Lu edited comment on FLINK-13278 at 9/17/19 2:09 AM: --- I

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

[ https://issues.apache.org/jira/browse/FLINK-13278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931009#comment-16931009 ] Zijie Lu commented on FLINK-13278: -- I want to try it out. Can you assign this issue to