[jira] [Created] (FLINK-35332) Manually setting rest.bind-address does not work for Flink running on Hadoop Yarn dual network environment

Yao Zhang created FLINK-35332: - Summary: Manually setting rest.bind-address does not work for Flink running on Hadoop Yarn dual network environment Key: FLINK-35332 URL: https://issues.apache.org/jira/browse/FLINK-353

[jira] [Commented] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812169#comment-17812169 ] Yao Zhang commented on FLINK-26760: --- Hi community, I submitted a PR and could someone

[jira] [Commented] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17809842#comment-17809842 ] Yao Zhang commented on FLINK-26760: --- Hi community, The encoding issue could be solved

[jira] [Commented] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17804098#comment-17804098 ] Yao Zhang commented on FLINK-26760: --- Hi community, I got the same issue with Flink 1.

[jira] [Commented] (FLINK-32721) agg max/min supports char type

[ https://issues.apache.org/jira/browse/FLINK-32721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783908#comment-17783908 ] Yao Zhang commented on FLINK-32721: --- Hi Community,   It seems that there is a contra

[jira] [Commented] (FLINK-32721) agg max/min supports char type

[ https://issues.apache.org/jira/browse/FLINK-32721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783126#comment-17783126 ] Yao Zhang commented on FLINK-32721: ---  Hi [~jackylau], [~libenchao] and [~lsy], It see

[jira] [Commented] (FLINK-32763) Uncaught exceptions cause retry not to take effect in SocketTextStreamFunction

[ https://issues.apache.org/jira/browse/FLINK-32763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783074#comment-17783074 ] Yao Zhang commented on FLINK-32763: --- Hi community, I got the same issue and wanna wor

[jira] [Commented] (FLINK-32716) Give 'Default'(or maybe 'None') option for 'scheduler-mode'

[ https://issues.apache.org/jira/browse/FLINK-32716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17778491#comment-17778491 ] Yao Zhang commented on FLINK-32716: --- Hi [~kination], The title of your PR now is [FLI

[jira] [Commented] (FLINK-32716) Give 'Default'(or maybe 'None') option for 'scheduler-mode'

[ https://issues.apache.org/jira/browse/FLINK-32716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1520#comment-1520 ] Yao Zhang commented on FLINK-32716: --- Hi [~kination] , The issue ID in your commit mes

[jira] [Commented] (FLINK-32721) agg max/min supports char type

[ https://issues.apache.org/jira/browse/FLINK-32721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1518#comment-1518 ] Yao Zhang commented on FLINK-32721: --- Hi [~jackylau], Are you still working on this? B

[jira] [Commented] (FLINK-32740) Introduce literal null value for flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-32740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17752603#comment-17752603 ] Yao Zhang commented on FLINK-32740: --- After further investigation Configuration only pr

[jira] [Commented] (FLINK-32740) Introduce literal null value for flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-32740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750916#comment-17750916 ] Yao Zhang commented on FLINK-32740: --- Hi [~JunRuiLi], Good question. It is also my con

[jira] [Created] (FLINK-32740) Introduce literal null value for flink-conf.yaml

Yao Zhang created FLINK-32740: - Summary: Introduce literal null value for flink-conf.yaml Key: FLINK-32740 URL: https://issues.apache.org/jira/browse/FLINK-32740 Project: Flink Issue Type: Improv

[jira] [Commented] (FLINK-32721) agg max/min supports char type

[ https://issues.apache.org/jira/browse/FLINK-32721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750618#comment-17750618 ] Yao Zhang commented on FLINK-32721: --- Hi [~libenchao] and [~jackylau], Thank you for y

[jira] [Comment Edited] (FLINK-32716) Give 'None' option for 'scheduler-mode'

[ https://issues.apache.org/jira/browse/FLINK-32716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750514#comment-17750514 ] Yao Zhang edited comment on FLINK-32716 at 8/3/23 1:09 AM: --- Hi

[jira] [Commented] (FLINK-32716) Give 'None' option for 'scheduler-mode'

[ https://issues.apache.org/jira/browse/FLINK-32716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750514#comment-17750514 ] Yao Zhang commented on FLINK-32716: --- Hi [~kination], I got the same problem. Currentl

[jira] [Commented] (FLINK-32721) agg supports char type

[ https://issues.apache.org/jira/browse/FLINK-32721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750154#comment-17750154 ] Yao Zhang commented on FLINK-32721: --- Hi community: It seems that Flink does not suppo

[jira] [Commented] (FLINK-31603) Line break should be removed in create table with-clauses, load module with-clauses and table hints for both keys and values

[ https://issues.apache.org/jira/browse/FLINK-31603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17705214#comment-17705214 ] Yao Zhang commented on FLINK-31603: --- Hi community, For some of the properties like 'l

[jira] [Created] (FLINK-31603) Line break should be removed in create table with-clauses, load module with-clauses and table hints for both keys and values

Yao Zhang created FLINK-31603: - Summary: Line break should be removed in create table with-clauses, load module with-clauses and table hints for both keys and values Key: FLINK-31603 URL: https://issues.apache.org/jir

[jira] [Commented] (FLINK-31518) HighAvailabilityServiceUtils resolves wrong webMonitorAddress in Standalone mode

[ https://issues.apache.org/jira/browse/FLINK-31518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703867#comment-17703867 ] Yao Zhang commented on FLINK-31518: --- Hi [~prabhujoseph] , It seems that we can retrie

[jira] [Commented] (FLINK-30857) Create table does not create topic with multiple partitions

[ https://issues.apache.org/jira/browse/FLINK-30857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687684#comment-17687684 ] Yao Zhang commented on FLINK-30857: --- Hi [~lzljs3620320] , As the latest hotfix remove

[jira] [Commented] (FLINK-30857) Create table does not create topic with multiple partitions

[ https://issues.apache.org/jira/browse/FLINK-30857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17686276#comment-17686276 ] Yao Zhang commented on FLINK-30857: --- Hi community, After further investigation, I thi

[jira] [Commented] (FLINK-30857) Create table does not create topic with multiple partitions

[ https://issues.apache.org/jira/browse/FLINK-30857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17685140#comment-17685140 ] Yao Zhang commented on FLINK-30857: --- Hi all, I am currently investigating this issue.

[jira] [Commented] (FLINK-30888) Flink Doc(zh version) has misspelled words

[ https://issues.apache.org/jira/browse/FLINK-30888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17684528#comment-17684528 ] Yao Zhang commented on FLINK-30888: --- Hi all, I would like to fix this. > Flink Doc(z

[jira] [Commented] (FLINK-30857) Create table does not create topic with multiple partitions

[ https://issues.apache.org/jira/browse/FLINK-30857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17684525#comment-17684525 ] Yao Zhang commented on FLINK-30857: --- Hi [~vicky_papavas] , Could you please tell me w

[jira] [Commented] (FLINK-25916) Using upsert-kafka with a flush buffer results in Null Pointer Exception

[ https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17668604#comment-17668604 ] Yao Zhang commented on FLINK-25916: --- Hi all， Could someone help review the code pleas

[jira] [Created] (FLINK-30347) Connecting SqlGateway via beeline gets java.lang.UnsupportedOperationException:: Unrecognized TGetInfoType value: CLI_ODBC_KEYWORDS

Yao Zhang created FLINK-30347: - Summary: Connecting SqlGateway via beeline gets java.lang.UnsupportedOperationException:: Unrecognized TGetInfoType value: CLI_ODBC_KEYWORDS Key: FLINK-30347 URL: https://issues.apache

[jira] [Commented] (FLINK-25916) Using upsert-kafka with a flush buffer results in Null Pointer Exception

[ https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17569880#comment-17569880 ] Yao Zhang commented on FLINK-25916: --- Hi all, As ProducerRecord allows null timestamp

[jira] [Commented] (FLINK-27579) The param client.timeout can not be set by dynamic properties when stopping the job

[ https://issues.apache.org/jira/browse/FLINK-27579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17565208#comment-17565208 ] Yao Zhang commented on FLINK-27579: --- Hi [~wangyang0918] , Thank you very much for you

[jira] [Commented] (FLINK-28275) Table.execute().print() prints SqlRawValue

[ https://issues.apache.org/jira/browse/FLINK-28275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563096#comment-17563096 ] Yao Zhang commented on FLINK-28275: --- Hi all, It might not be a good practice to deser

[jira] [Commented] (FLINK-28275) Table.execute().print() prints SqlRawValue

[ https://issues.apache.org/jira/browse/FLINK-28275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563049#comment-17563049 ] Yao Zhang commented on FLINK-28275: --- Hi all, I tested in both Flink 1.14.3 and 1.15.0

[jira] [Commented] (FLINK-27579) The param client.timeout can not be set by dynamic properties when stopping the job

[ https://issues.apache.org/jira/browse/FLINK-27579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562379#comment-17562379 ] Yao Zhang commented on FLINK-27579: --- Hi [~wangyang0918] ， Could you help review the c

[jira] [Commented] (FLINK-28365) TO_TIMESTAMP lose precision beyond seconds

[ https://issues.apache.org/jira/browse/FLINK-28365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562044#comment-17562044 ] Yao Zhang commented on FLINK-28365: --- Hi [~qingwei91] , Which version of Flink did you

[jira] [Commented] (FLINK-25916) Using upsert-kafka with a flush buffer results in Null Pointer Exception

[ https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550841#comment-17550841 ] Yao Zhang commented on FLINK-25916: --- Hi [~fpaul], After further investigation I found

[jira] [Commented] (FLINK-27579) The param client.timeout can not be set by dynamic properties when stopping the job

[ https://issues.apache.org/jira/browse/FLINK-27579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17542728#comment-17542728 ] Yao Zhang commented on FLINK-27579: --- Hi [~Jiangang] , I would like to do this. Please

[jira] [Commented] (FLINK-27579) The param client.timeout can not be set by dynamic properties when stopping the job

[ https://issues.apache.org/jira/browse/FLINK-27579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539339#comment-17539339 ] Yao Zhang commented on FLINK-27579: --- Hi [~Jiangang] , The option `client.timeout` is

[jira] [Commented] (FLINK-27519) Fix duplicates names when there are multiple levels of over window aggregate

[ https://issues.apache.org/jira/browse/FLINK-27519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17533238#comment-17533238 ] Yao Zhang commented on FLINK-27519: --- Hi [~hackergin] and [~TsReaper], I created a dem

[jira] [Commented] (FLINK-27519) Fix duplicates names when there are multiple levels of over window aggregate

[ https://issues.apache.org/jira/browse/FLINK-27519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17533219#comment-17533219 ] Yao Zhang commented on FLINK-27519: --- Hi [~hackergin] ， FlinkLogicalOverAggregate  is

[jira] [Commented] (FLINK-27519) Fix duplicates names when there are multiple levels of over window aggregate

[ https://issues.apache.org/jira/browse/FLINK-27519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17532816#comment-17532816 ] Yao Zhang commented on FLINK-27519: --- Hi [~martijnvisser] , I am not sure about this,

[jira] [Commented] (FLINK-27519) Fix duplicates names when there are multiple levels of over window aggregate

[ https://issues.apache.org/jira/browse/FLINK-27519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17532737#comment-17532737 ] Yao Zhang commented on FLINK-27519: --- Hi all, It should be an issue of Calcite. Calcit

[jira] [Commented] (FLINK-27437) Syntax error when running tpcds test

[ https://issues.apache.org/jira/browse/FLINK-27437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529250#comment-17529250 ] Yao Zhang commented on FLINK-27437: --- I will update the doc > Syntax error when runnin

[jira] [Created] (FLINK-27437) Syntax error when running tpcds test

Yao Zhang created FLINK-27437: - Summary: Syntax error when running tpcds test Key: FLINK-27437 URL: https://issues.apache.org/jira/browse/FLINK-27437 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-27018) timestamp missing end zero when outputing to kafka

[ https://issues.apache.org/jira/browse/FLINK-27018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17524799#comment-17524799 ] Yao Zhang commented on FLINK-27018: --- Hi [~jeff-zou] , We cannot simple use `LocalDate

[jira] [Commented] (FLINK-27018) timestamp missing end zero when outputing to kafka

[ https://issues.apache.org/jira/browse/FLINK-27018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520966#comment-17520966 ] Yao Zhang commented on FLINK-27018: --- Hi all, The root cause is the different behaviou

[jira] [Commented] (FLINK-27018) timestamp missing end zero when outputing to kafka

[ https://issues.apache.org/jira/browse/FLINK-27018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520882#comment-17520882 ] Yao Zhang commented on FLINK-27018: --- Hi [~fpaul] and [~jeff-zou] , I reproduced this

[jira] [Commented] (FLINK-22588) There is a configuration description error in the document

[ https://issues.apache.org/jira/browse/FLINK-22588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509640#comment-17509640 ] Yao Zhang commented on FLINK-22588: --- Hi [~jark] and [~chesnay] , I reviewed the codes

[jira] [Commented] (FLINK-26672) In Table/SQL API, Table configuration ' table.local-time-zone' does not work

[ https://issues.apache.org/jira/browse/FLINK-26672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17507455#comment-17507455 ] Yao Zhang commented on FLINK-26672: --- Hi all, I tested in my 1.13.1 local environment

[jira] [Commented] (FLINK-26672) In Table/SQL API, Table configuration ' table.local-time-zone' does not work

[ https://issues.apache.org/jira/browse/FLINK-26672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17507397#comment-17507397 ] Yao Zhang commented on FLINK-26672: --- Hi [~ruilin-zhang] , What is the timezone settin

[jira] [Comment Edited] (FLINK-25916) Using upsert-kafka with a flush buffer results in Null Pointer Exception

[ https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506786#comment-17506786 ] Yao Zhang edited comment on FLINK-25916 at 3/15/22, 8:41 AM: -

[jira] [Comment Edited] (FLINK-25916) Using upsert-kafka with a flush buffer results in Null Pointer Exception

[ https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506786#comment-17506786 ] Yao Zhang edited comment on FLINK-25916 at 3/15/22, 8:41 AM: -

[jira] [Commented] (FLINK-25916) Using upsert-kafka with a flush buffer results in Null Pointer Exception

[ https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506786#comment-17506786 ] Yao Zhang commented on FLINK-25916: --- Hi all, I think one potential point might be the

[jira] [Commented] (FLINK-26488) FileSystem.listFiles is not implemented consistently

[ https://issues.apache.org/jira/browse/FLINK-26488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506087#comment-17506087 ] Yao Zhang commented on FLINK-26488: --- HADOOP-6201 It suggests that FileSystem::ListSta

[jira] [Commented] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506009#comment-17506009 ] Yao Zhang commented on FLINK-26498: --- Hi [~jark] ,  Thanks. +1 with your idea. > The

[jira] [Commented] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17505943#comment-17505943 ] Yao Zhang commented on FLINK-26498: --- Hi [~jark] , Thank you very much for your reply.

[jira] [Comment Edited] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504158#comment-17504158 ] Yao Zhang edited comment on FLINK-26498 at 3/10/22, 10:22 AM:

[jira] [Commented] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17504158#comment-17504158 ] Yao Zhang commented on FLINK-26498: --- Hi [~jark] , How about my solution[[FLINK-26498|

[jira] [Commented] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503429#comment-17503429 ] Yao Zhang commented on FLINK-26498: --- Hi [~jark] , So what is the difference between s

[jira] [Commented] (FLINK-26488) FileSystem.listFiles is not implemented consistently

[ https://issues.apache.org/jira/browse/FLINK-26488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502662#comment-17502662 ] Yao Zhang commented on FLINK-26488: --- Hi [~mapohl] , I looked into some references to

[jira] [Comment Edited] (FLINK-26498) The window result may not have been emitted when use window emit feature and use lateTrigger.

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502108#comment-17502108 ] Yao Zhang edited comment on FLINK-26498 at 3/7/22, 8:45 AM:

[jira] [Commented] (FLINK-26498) The window result may not have been emitted when use window emit feature and use lateTrigger.

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502108#comment-17502108 ] Yao Zhang commented on FLINK-26498: --- Hi [~jark] , I would like to fix this issue. Per

[jira] [Commented] (FLINK-26381) Wrong document order of Chinese version

[ https://issues.apache.org/jira/browse/FLINK-26381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502055#comment-17502055 ] Yao Zhang commented on FLINK-26381: --- The page weight values of Chinese version are dif

[jira] [Commented] (FLINK-21278) NullpointExecption error is reported when using the evictor method to filter the data before the window calculation

[ https://issues.apache.org/jira/browse/FLINK-21278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489373#comment-17489373 ] Yao Zhang commented on FLINK-21278: --- Could someone help review this issue please? > N

[jira] [Commented] (FLINK-22588) There is a configuration description error in the document

[ https://issues.apache.org/jira/browse/FLINK-22588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17488639#comment-17488639 ] Yao Zhang commented on FLINK-22588: --- Hi [~jark] and [~chesnay] , It seems that this t

[jira] [Commented] (FLINK-24307) Some lines in Scala code example end with unnecessary semicolons. Also some Scala code blocks are wrongly typed with Java blocks

[ https://issues.apache.org/jira/browse/FLINK-24307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17488608#comment-17488608 ] Yao Zhang commented on FLINK-24307: --- Hi [~twalthr] , Could you please review this iss

[jira] [Comment Edited] (FLINK-25766) Chinese translation

[ https://issues.apache.org/jira/browse/FLINK-25766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480805#comment-17480805 ] Yao Zhang edited comment on FLINK-25766 at 1/24/22, 3:20 AM: -

[jira] [Commented] (FLINK-25766) Chinese translation

[ https://issues.apache.org/jira/browse/FLINK-25766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480805#comment-17480805 ] Yao Zhang commented on FLINK-25766: --- Please see FLINK-25766 > Chinese translation > -

[jira] [Closed] (FLINK-25766) Chinese translation

[ https://issues.apache.org/jira/browse/FLINK-25766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yao Zhang closed FLINK-25766. - Resolution: Invalid Wrong creating issue and will be abandoned. > Chinese translation > ---

[jira] [Commented] (FLINK-25767) Translation of page 'Working with State' is incomplete

[ https://issues.apache.org/jira/browse/FLINK-25767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480796#comment-17480796 ] Yao Zhang commented on FLINK-25767: --- I'd like to do this. Could any assign this issue

[jira] [Created] (FLINK-25767) Translation of page 'Working with State' is incomplete

Yao Zhang created FLINK-25767: - Summary: Translation of page 'Working with State' is incomplete Key: FLINK-25767 URL: https://issues.apache.org/jira/browse/FLINK-25767 Project: Flink Issue Type:

[jira] [Created] (FLINK-25766) Chinese translation

Yao Zhang created FLINK-25766: - Summary: Chinese translation Key: FLINK-25766 URL: https://issues.apache.org/jira/browse/FLINK-25766 Project: Flink Issue Type: Improvement Reporter: Y

[jira] [Updated] (FLINK-23935) Flink docs: the browser will unexpectedly scroll after clicking the tabs

[ https://issues.apache.org/jira/browse/FLINK-23935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yao Zhang updated FLINK-23935: -- Affects Version/s: 1.14.3 > Flink docs: the browser will unexpectedly scroll after clicking the tabs >

[jira] [Commented] (FLINK-25683) wrong result if table transfrom to DataStream then window process in batch mode

[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479252#comment-17479252 ] Yao Zhang commented on FLINK-25683: --- Hi [~dwysakowicz] , I still can't figure out wha

[jira] [Commented] (FLINK-25683) wrong result if table transfrom to DataStream then window process in batch mode

[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479223#comment-17479223 ] Yao Zhang commented on FLINK-25683: --- Hi [~dwysakowicz] and [~twalthr] , Thank you ver

[jira] [Commented] (FLINK-25683) wrong result if table transfrom to DataStream then window process in batch mode

[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17478355#comment-17478355 ] Yao Zhang commented on FLINK-25683: --- Hi [~twalthr] , This issue and FLINK-25471 is qu

[jira] [Commented] (FLINK-25683) wrong result if table transfrom to DataStream then window process in batch mode

[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17478297#comment-17478297 ] Yao Zhang commented on FLINK-25683: --- Hi [~zhangzihan] , Thank you very much for repor

[jira] [Commented] (FLINK-25471) wrong result if table transfrom to DataStream then keyby sum in Batch Mode

[ https://issues.apache.org/jira/browse/FLINK-25471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471677#comment-17471677 ] Yao Zhang commented on FLINK-25471: --- Thank you [~twalthr] . > wrong result if table t

[jira] [Commented] (FLINK-25471) wrong result if table transfrom to DataStream then keyby sum in Batch Mode

[ https://issues.apache.org/jira/browse/FLINK-25471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470277#comment-17470277 ] Yao Zhang commented on FLINK-25471: --- Hi [~twalthr] , In Flink 1.13 it transforms sum

[jira] [Commented] (FLINK-25471) wrong result if table transfrom to DataStream then keyby sum in Batch Mode

[ https://issues.apache.org/jira/browse/FLINK-25471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17469644#comment-17469644 ] Yao Zhang commented on FLINK-25471: --- Hi [~twalthr] , could you please assign this issu

[jira] [Commented] (FLINK-25471) wrong result if table transfrom to DataStream then keyby sum in Batch Mode

[ https://issues.apache.org/jira/browse/FLINK-25471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17469003#comment-17469003 ] Yao Zhang commented on FLINK-25471: --- Hi [~zhangzihan] , For Flink 1.13.3 even though

[jira] [Commented] (FLINK-25471) wrong result if table transfrom to DataStream then keyby sum in Batch Mode

[ https://issues.apache.org/jira/browse/FLINK-25471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17468932#comment-17468932 ] Yao Zhang commented on FLINK-25471: --- It should be a bug. Could anyone assign this to m

[jira] [Commented] (FLINK-25471) wrong result if table transfrom to DataStream then keyby sum in Batch Mode

[ https://issues.apache.org/jira/browse/FLINK-25471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17468387#comment-17468387 ] Yao Zhang commented on FLINK-25471: --- Hi [~zhangzihan] , I reproduced this issue with

[jira] [Commented] (FLINK-25501) npm ci hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-25501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17468294#comment-17468294 ] Yao Zhang commented on FLINK-25501: --- The unstable network connection to node repositor

[jira] [Commented] (FLINK-25048) 在某个option后设置watermark，如果这个option里面有 outputTag，则此outputTag 不会有数据输出，只会在主流输出数据

[ https://issues.apache.org/jira/browse/FLINK-25048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448996#comment-17448996 ] Yao Zhang commented on FLINK-25048: --- Hi [~liangxinli] , I debugged the StreamGraph ge

[jira] [Commented] (FLINK-24831) Upgrade DataStream Window examples

[ https://issues.apache.org/jira/browse/FLINK-24831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440939#comment-17440939 ] Yao Zhang commented on FLINK-24831: --- Hi [~sjwiesman] , I can help you with it. Should

[jira] [Commented] (FLINK-24369) Resource Leak may happen if flink cluster runs abnormally and repeatedly retry

[ https://issues.apache.org/jira/browse/FLINK-24369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433625#comment-17433625 ] Yao Zhang commented on FLINK-24369: --- Hi [~turtlebin], I am not quite sure that what h

[jira] [Commented] (FLINK-23935) Flink docs: the browser will unexpectedly scroll after clicking the tabs

[ https://issues.apache.org/jira/browse/FLINK-23935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433570#comment-17433570 ] Yao Zhang commented on FLINK-23935: --- Could anyone help review this commit please? > F

[jira] [Created] (FLINK-24307) Some lines in Scala code example end with unnecessary semicolons. Also some Scala code blocks are wrongly typed with Java blocks

Yao Zhang created FLINK-24307: - Summary: Some lines in Scala code example end with unnecessary semicolons. Also some Scala code blocks are wrongly typed with Java blocks Key: FLINK-24307 URL: https://issues.apache.org

[jira] [Commented] (FLINK-24307) Some lines in Scala code example end with unnecessary semicolons. Also some Scala code blocks are wrongly typed with Java blocks

[ https://issues.apache.org/jira/browse/FLINK-24307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415910#comment-17415910 ] Yao Zhang commented on FLINK-24307: --- Could anyone assign this issue to me pls? > Some

[jira] [Comment Edited] (FLINK-24224) Table change to stream for CEP , only event  is ROW  datatype can works on CEP,  but  other POJOs、maps、 JsonObject datatype event  do not work.    Any datatype f

[ https://issues.apache.org/jira/browse/FLINK-24224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414802#comment-17414802 ] Yao Zhang edited comment on FLINK-24224 at 9/14/21, 8:24 AM: -

[jira] [Commented] (FLINK-24224) Table change to stream for CEP , only event  is ROW  datatype can works on CEP,  but  other POJOs、maps、 JsonObject datatype event  do not work.    Any datatype for ev

[ https://issues.apache.org/jira/browse/FLINK-24224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414802#comment-17414802 ] Yao Zhang commented on FLINK-24224: --- Hi [~YUJIANBO], I failed to reproduce your issue

[jira] [Commented] (FLINK-24023) the names of metrics are incomplete

[ https://issues.apache.org/jira/browse/FLINK-24023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408709#comment-17408709 ] Yao Zhang commented on FLINK-24023: --- Hi [~linqichen178] [~jark], Could you pls assign

[jira] [Updated] (FLINK-23935) Flink docs: the browser will unexpectedly scroll after clicking the tabs

[ https://issues.apache.org/jira/browse/FLINK-23935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yao Zhang updated FLINK-23935: -- Summary: Flink docs: the browser will unexpectedly scroll after clicking the tabs (was: Flink docs: t

[jira] [Updated] (FLINK-23935) Flink docs: the browser will unexpected scroll when clicking the tabs

[ https://issues.apache.org/jira/browse/FLINK-23935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yao Zhang updated FLINK-23935: -- Summary: Flink docs: the browser will unexpected scroll when clicking the tabs (was: Flink docs) > F

[jira] [Commented] (FLINK-23935) Flink docs

[ https://issues.apache.org/jira/browse/FLINK-23935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17403569#comment-17403569 ] Yao Zhang commented on FLINK-23935: --- Could someone assign this issue to me? > Flink d

[jira] [Created] (FLINK-23935) Flink docs

Yao Zhang created FLINK-23935: - Summary: Flink docs Key: FLINK-23935 URL: https://issues.apache.org/jira/browse/FLINK-23935 Project: Flink Issue Type: Bug Components: Documentation

[jira] [Commented] (FLINK-23727) Skip null values in SimpleStringSchema#deserialize

[ https://issues.apache.org/jira/browse/FLINK-23727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400887#comment-17400887 ] Yao Zhang commented on FLINK-23727: --- I looked into this issue. It seems that in some S

[jira] [Commented] (FLINK-23727) Skip null values in SimpleStringSchema#deserialize

[ https://issues.apache.org/jira/browse/FLINK-23727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400771#comment-17400771 ] Yao Zhang commented on FLINK-23727: --- Hi [~Paul Lin], I encountered the same issue with

[jira] [Commented] (FLINK-23837) Differences between documentation and implementation for taskmanager.memory.network.max

[ https://issues.apache.org/jira/browse/FLINK-23837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400726#comment-17400726 ] Yao Zhang commented on FLINK-23837: --- Hi all, I looked into the default flink-conf.yml

[jira] [Commented] (FLINK-23702) SQL casting to decimal which cannot hold its original value throws 'Column 'EXPR$0' is NOT NULL, however, a null value is being written into it'

[ https://issues.apache.org/jira/browse/FLINK-23702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17398432#comment-17398432 ] Yao Zhang commented on FLINK-23702: --- Hi [~lzljs3620320], I debugged the codegen proce

[jira] [Commented] (FLINK-23602) org.codehaus.commons.compiler.CompileException: Line 84, Column 78: No applicable constructor/method found for actual parameters "org.apache.flink.table.data.DecimalDa

[ https://issues.apache.org/jira/browse/FLINK-23602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17397137#comment-17397137 ] Yao Zhang commented on FLINK-23602: --- Hi [~TsReaper], I reviewed codes in Calcite and

  1   2   >