[jira] [Updated] (FLINK-20105) Temporary Table does not work when Kafka is used as the versioned side (planner PK problem)

[ https://issues.apache.org/jira/browse/FLINK-20105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoît Paris updated FLINK-20105: - Description:   This is probably an early bug report, that I'm making before 0.12 is out.

[jira] [Updated] (FLINK-20105) Temporary Table does not work when Kafka is used as the versioned side (planner PK problem)

[ https://issues.apache.org/jira/browse/FLINK-20105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoît Paris updated FLINK-20105: - Description:   This is probably an early bug report that I'm making before 0.12 is out.

[jira] [Created] (FLINK-20106) flink 1.10 kafka connector通用版本，使用FlinkFixedPartitioner分区器，获取不到parallelInstanceId，parallelInstanceId始终是0，导致数据都被sink到一个kafka 分区上了

赵富午 created FLINK-20106: --- Summary: flink 1.10 kafka connector通用版本，使用FlinkFixedPartitioner分区器，获取不到parallelInstanceId，parallelInstanceId始终是0，导致数据都被sink到一个kafka 分区上了 Key: FLINK-20106 URL: https://issues.apache.org/jira

[jira] [Commented] (FLINK-20092) [Java 11] Multi-thread Flink compilation not working

[ https://issues.apache.org/jira/browse/FLINK-20092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230651#comment-17230651 ] Maciej Bryński commented on FLINK-20092: I don't know. I didn't

[jira] [Comment Edited] (FLINK-20092) [Java 11] Multi-thread Flink compilation not working

[ https://issues.apache.org/jira/browse/FLINK-20092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230651#comment-17230651 ] Maciej Bryński edited comment on FLINK-20092 at 11/12/20, 2:0

[jira] [Commented] (FLINK-20105) Temporary Table does not work when Kafka is used as the versioned side (planner PK problem)

[ https://issues.apache.org/jira/browse/FLINK-20105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230745#comment-17230745 ] Benoît Paris commented on FLINK-20105: -- Thanks a lot, [~jark]! Works like a c

[jira] [Updated] (FLINK-20105) Temporary Table does not work when Kafka is used as the versioned side (planner PK problem)

[ https://issues.apache.org/jira/browse/FLINK-20105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoît Paris updated FLINK-20105: - Priority: Minor (was: Major) > Temporary Table does not work when Kafka is used as

[jira] [Created] (FLINK-20130) Add ZStandard format to inputs

João Boto created FLINK-20130: - Summary: Add ZStandard format to inputs Key: FLINK-20130 URL: https://issues.apache.org/jira/browse/FLINK-20130 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-20092) [Java 11] Multi-thread Flink compilation not working

[ https://issues.apache.org/jira/browse/FLINK-20092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231271#comment-17231271 ] Maciej Bryński commented on FLINK-20092: [~chesnay] Maybe we can avoi

[jira] [Commented] (FLINK-15867) LAST_VALUE and FIRST_VALUE aggregate function does not support time-related types

[ https://issues.apache.org/jira/browse/FLINK-15867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232086#comment-17232086 ] Benoît Paris commented on FLINK-15867: -- Edited it if that's ok with y

[jira] [Updated] (FLINK-15867) LAST_VALUE and FIRST_VALUE aggregate function does not support time-related types

[ https://issues.apache.org/jira/browse/FLINK-15867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoît Paris updated FLINK-15867: - Summary: LAST_VALUE and FIRST_VALUE aggregate function does not support time-related types

[jira] [Comment Edited] (FLINK-15867) LAST_VALUE and FIRST_VALUE aggregate function does not support time-related types

[ https://issues.apache.org/jira/browse/FLINK-15867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232086#comment-17232086 ] Benoît Paris edited comment on FLINK-15867 at 11/14/20, 5:2

[jira] [Created] (FLINK-20195) Jobs endpoint returns duplicated jobs

Ingo Bürk created FLINK-20195: - Summary: Jobs endpoint returns duplicated jobs Key: FLINK-20195 URL: https://issues.apache.org/jira/browse/FLINK-20195 Project: Flink Issue Type: Bug Affects

[jira] [Created] (FLINK-20226) Temporal Table Functions cannot be created with a view reference

Benoît Paris created FLINK-20226: Summary: Temporal Table Functions cannot be created with a view reference Key: FLINK-20226 URL: https://issues.apache.org/jira/browse/FLINK-20226 Project: Flink

[jira] [Updated] (FLINK-20226) Temporal Table Functions cannot be created with a view reference

[ https://issues.apache.org/jira/browse/FLINK-20226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoît Paris updated FLINK-20226: - Description: Temporal Table Functions fail to be created if the history side `Table` is

[jira] [Commented] (FLINK-20260) YAML for SQL client only supports legacy interfaces

[ https://issues.apache.org/jira/browse/FLINK-20260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17236039#comment-17236039 ] Ingo Bürk commented on FLINK-20260: --- This is somewhat related to FLINK-11478. &g

[jira] [Created] (FLINK-20260) YAML for SQL client only supports legacy interfaces

Ingo Bürk created FLINK-20260: - Summary: YAML for SQL client only supports legacy interfaces Key: FLINK-20260 URL: https://issues.apache.org/jira/browse/FLINK-20260 Project: Flink Issue Type

[jira] [Updated] (FLINK-20260) YAML for SQL client only supports legacy interfaces

[ https://issues.apache.org/jira/browse/FLINK-20260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk updated FLINK-20260: -- Component/s: Table SQL / Client > YAML for SQL client only supports legacy interfa

[jira] [Created] (FLINK-20277) flink-1.11.2 ContinuousFileMonitoringFunction cannot restore from failure

谢波 created FLINK-20277: -- Summary: flink-1.11.2 ContinuousFileMonitoringFunction cannot restore from failure Key: FLINK-20277 URL: https://issues.apache.org/jira/browse/FLINK-20277 Project: Flink Issue

[jira] [Updated] (FLINK-20277) flink-1.11.2 ContinuousFileMonitoringFunction cannot restore from failure

[ https://issues.apache.org/jira/browse/FLINK-20277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 谢波 updated FLINK-20277: --- Description: 流式消费Hive表，出现失败时，任务无法正常恢复，一直重启。 一直报错：The ContinuousFileMonitoringFunction has already restored from a

[jira] [Commented] (FLINK-20277) flink-1.11.2 ContinuousFileMonitoringFunction cannot restore from failure

[ https://issues.apache.org/jira/browse/FLINK-20277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237143#comment-17237143 ] 谢波 commented on FLINK-20277: Sorry, I'll pay attention next time. I have a job t

[jira] [Commented] (FLINK-20260) YAML for SQL client only supports legacy interfaces

[ https://issues.apache.org/jira/browse/FLINK-20260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237884#comment-17237884 ] Ingo Bürk commented on FLINK-20260: --- [~jark] Is there any way to execute SQL from

[jira] [Comment Edited] (FLINK-20260) YAML for SQL client only supports legacy interfaces

[ https://issues.apache.org/jira/browse/FLINK-20260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237884#comment-17237884 ] Ingo Bürk edited comment on FLINK-20260 at 11/24/20, 6:0

[jira] [Commented] (FLINK-20260) YAML for SQL client only supports legacy interfaces

[ https://issues.apache.org/jira/browse/FLINK-20260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237945#comment-17237945 ] Ingo Bürk commented on FLINK-20260: --- As a suggestion, maybe we can just sup

[jira] [Created] (FLINK-20319) Improving the visitor pattern for operations

Ingo Bürk created FLINK-20319: - Summary: Improving the visitor pattern for operations Key: FLINK-20319 URL: https://issues.apache.org/jira/browse/FLINK-20319 Project: Flink Issue Type

[jira] [Created] (FLINK-20372) flink sql kafka connector cannot config kerberos

谢波 created FLINK-20372: -- Summary: flink sql kafka connector cannot config kerberos Key: FLINK-20372 URL: https://issues.apache.org/jira/browse/FLINK-20372 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20377) flink-1.11.2 -kerberos config on kafka connector not working

谢波 created FLINK-20377: -- Summary: flink-1.11.2 -kerberos config on kafka connector not working Key: FLINK-20377 URL: https://issues.apache.org/jira/browse/FLINK-20377 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-20377) flink-1.11.2 -kerberos config on kafka connector not working

[ https://issues.apache.org/jira/browse/FLINK-20377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 谢波 updated FLINK-20377: --- Description: I refer to the configuration on the official website to configure Kafka and flink-conf.yaml ,but the

[jira] [Created] (FLINK-20390) Programmatic access to the back-pressure

Gaël Renoux created FLINK-20390: --- Summary: Programmatic access to the back-pressure Key: FLINK-20390 URL: https://issues.apache.org/jira/browse/FLINK-20390 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-20195) Jobs endpoint returns duplicated jobs

[ https://issues.apache.org/jira/browse/FLINK-20195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17240522#comment-17240522 ] Ingo Bürk commented on FLINK-20195: --- [~chesnay] Yes, we only observed this duri

[jira] [Created] (FLINK-20415) Parsed QueryOperation does not contain watermark in schema

Ingo Bürk created FLINK-20415: - Summary: Parsed QueryOperation does not contain watermark in schema Key: FLINK-20415 URL: https://issues.apache.org/jira/browse/FLINK-20415 Project: Flink Issue

[jira] [Updated] (FLINK-20415) Parsed QueryOperation does not contain watermark in schema

[ https://issues.apache.org/jira/browse/FLINK-20415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk updated FLINK-20415: -- Description: A parsed QueryOperation (e.g. from Parser#parse) does not contain the watermark

[jira] [Updated] (FLINK-20415) Parsed QueryOperation does not contain watermark in schema

[ https://issues.apache.org/jira/browse/FLINK-20415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk updated FLINK-20415: -- Description: A parsed QueryOperation (e.g. from Parser#parse) does not contain the watermark

[jira] [Commented] (FLINK-16544) Flink FileSystem for web.uploadDir

[ https://issues.apache.org/jira/browse/FLINK-16544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068496#comment-17068496 ] Angel Barragán commented on FLINK-16544: Hi tried several times to

[jira] [Created] (FLINK-16846) Add docker images with python

Ismaël Mejía created FLINK-16846: Summary: Add docker images with python Key: FLINK-16846 URL: https://issues.apache.org/jira/browse/FLINK-16846 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-16846) Add docker images with python

[ https://issues.apache.org/jira/browse/FLINK-16846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17070016#comment-17070016 ] Ismaël Mejía commented on FLINK-16846: -- [~plucas] WDYT? I will write a messag

[jira] [Commented] (FLINK-16773) Flink 1.10 test execution is broken due to premature test cluster shutdown

[ https://issues.apache.org/jira/browse/FLINK-16773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17070020#comment-17070020 ] Ismaël Mejía commented on FLINK-16773: -- Was this bug intended to be created on

[jira] [Updated] (FLINK-16846) Add python docker images

[ https://issues.apache.org/jira/browse/FLINK-16846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated FLINK-16846: - Summary: Add python docker images (was: Add docker images with python) > Add python doc

[jira] [Comment Edited] (FLINK-16846) Add python docker images

[ https://issues.apache.org/jira/browse/FLINK-16846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17070016#comment-17070016 ] Ismaël Mejía edited comment on FLINK-16846 at 3/28/20, 9:1

[jira] [Commented] (FLINK-16596) Support Enum-Values as part of a Key

[ https://issues.apache.org/jira/browse/FLINK-16596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072213#comment-17072213 ] Felix Wollschläger commented on FLINK-16596: Of course, users can a

[jira] [Created] (FLINK-16907) did not react to cancelling signal for 30 seconds, but is stuck in method:

辛羿彤 created FLINK-16907: --- Summary: did not react to cancelling signal for 30 seconds, but is stuck in method: Key: FLINK-16907 URL: https://issues.apache.org/jira/browse/FLINK-16907 Project: Flink

[jira] [Updated] (FLINK-16907) did not react to cancelling signal for 30 seconds, but is stuck in method:

[ https://issues.apache.org/jira/browse/FLINK-16907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 辛羿彤 updated FLINK-16907: Fix Version/s: 1.9.1 Flags: Important Description: 2020-04-01 16:44:02,516 WARN

[jira] [Reopened] (FLINK-16907) did not react to cancelling signal for 30 seconds, but is stuck in method:

[ https://issues.apache.org/jira/browse/FLINK-16907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 辛羿彤 reopened FLINK-16907: - > did not react to cancelling signal for 30 seconds, but is stuck in met

[jira] [Updated] (FLINK-16907) did not react to cancelling signal for 30 seconds, but is stuck in method:

[ https://issues.apache.org/jira/browse/FLINK-16907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 辛羿彤 updated FLINK-16907: Attachment: flink-root-taskexecutor-1-dqapp121002.log > did not react to cancelling signal for 30 seconds, but

[jira] [Updated] (FLINK-16907) did not react to cancelling signal for 30 seconds, but is stuck in method:

[ https://issues.apache.org/jira/browse/FLINK-16907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 辛羿彤 updated FLINK-16907: Fix Version/s: 1.9.1 Description: public UserInfo map(String s) throws Exception { if (StringUtils.isBlank

[jira] [Updated] (FLINK-16907) did not react to cancelling signal for 30 seconds, but is stuck in method:

[ https://issues.apache.org/jira/browse/FLINK-16907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 辛羿彤 updated FLINK-16907: Attachment: flink-root-standalonesession-0-dqapp121003.log > did not react to cancelling signal for 30 seco

[jira] [Closed] (FLINK-16907) did not react to cancelling signal for 30 seconds, but is stuck in method:

[ https://issues.apache.org/jira/browse/FLINK-16907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 辛羿彤 closed FLINK-16907. --- Resolution: Later > did not react to cancelling signal for 30 seconds, but is stuck in met

[jira] [Updated] (FLINK-16632) Cast string to timestamp fail

[ https://issues.apache.org/jira/browse/FLINK-16632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 吴彦祖 updated FLINK-16632: Attachment: image-2020-04-03-15-39-35-702.png > Cast string to timestamp f

[jira] [Commented] (FLINK-16632) Cast string to timestamp fail

[ https://issues.apache.org/jira/browse/FLINK-16632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17074380#comment-17074380 ] 吴彦祖 commented on FLINK-16632: - !image-2020-04-03-15-39-35-702.png! I found a bug rel

[jira] [Comment Edited] (FLINK-9173) RestClient - Received response is abnormal

[ https://issues.apache.org/jira/browse/FLINK-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17074738#comment-17074738 ] François Lacombe edited comment on FLINK-9173 at 4/3/20, 5:0

[jira] [Commented] (FLINK-9173) RestClient - Received response is abnormal

[ https://issues.apache.org/jira/browse/FLINK-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17074738#comment-17074738 ] François Lacombe commented on FLINK-9173: - This issue is still alive with F

[jira] [Updated] (FLINK-16697) Disable JMX rebinding

[ https://issues.apache.org/jira/browse/FLINK-16697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated FLINK-16697: - Fix Version/s: 1.10.1 > Disable JMX rebinding > - > >

[jira] [Updated] (FLINK-16697) Disable JMX rebinding

[ https://issues.apache.org/jira/browse/FLINK-16697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated FLINK-16697: - Affects Version/s: 1.10.0 > Disable JMX rebind

[jira] [Updated] (FLINK-16697) Disable JMX rebinding

[ https://issues.apache.org/jira/browse/FLINK-16697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated FLINK-16697: - Fix Version/s: (was: 1.11.0) > Disable JMX rebind

[jira] [Commented] (FLINK-8357) enable rolling in default log settings

[ https://issues.apache.org/jira/browse/FLINK-8357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17194194#comment-17194194 ] Jörn Kottmann commented on FLINK-8357: -- Actually I still really need to get

[jira] [Created] (FLINK-19209) Single bucket

Michał Strużek created FLINK-19209: -- Summary: Single bucket Key: FLINK-19209 URL: https://issues.apache.org/jira/browse/FLINK-19209 Project: Flink Issue Type: Bug Components: API

[jira] [Commented] (FLINK-8357) enable rolling in default log settings

[ https://issues.apache.org/jira/browse/FLINK-8357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17195667#comment-17195667 ] Jörn Kottmann commented on FLINK-8357: -- Kafka is using hourly rotating logs wit

[jira] [Commented] (FLINK-8357) enable rolling in default log settings

[ https://issues.apache.org/jira/browse/FLINK-8357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17196043#comment-17196043 ] Jörn Kottmann commented on FLINK-8357: -- Sounds good to me, you are right the

[jira] [Commented] (FLINK-8357) enable rolling in default log settings

[ https://issues.apache.org/jira/browse/FLINK-8357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17196060#comment-17196060 ] Jörn Kottmann commented on FLINK-8357: -- Ok, thats how we will do it, I will s

[jira] [Commented] (FLINK-19005) Document JDBC drivers as source of Metaspace leaks

[ https://issues.apache.org/jira/browse/FLINK-19005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17196116#comment-17196116 ] Guillermo Sánchez commented on FLINK-19005: --- Thanks [~chesnay], the pro

[jira] [Created] (FLINK-19407) Translate "Elasticsearch Connector" page of "Connectors" into Chinese

魏旭斌 created FLINK-19407: --- Summary: Translate "Elasticsearch Connector" page of "Connectors" into Chinese Key: FLINK-19407 URL: https://issues.apache.org/jira/browse/FLINK-19407 Project: F

[jira] [Commented] (FLINK-19407) Translate "Elasticsearch Connector" page of "Connectors" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-19407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17201890#comment-17201890 ] 魏旭斌 commented on FLINK-19407: - Hi [~jark] ,I would like to translate this page . Could

[jira] [Created] (FLINK-21012) AvroFileFormatFactory uses non-deserializable lambda function

Ingo Bürk created FLINK-21012: - Summary: AvroFileFormatFactory uses non-deserializable lambda function Key: FLINK-21012 URL: https://issues.apache.org/jira/browse/FLINK-21012 Project: Flink

[jira] [Commented] (FLINK-20390) Programmatic access to the back-pressure

[ https://issues.apache.org/jira/browse/FLINK-20390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267392#comment-17267392 ] Gaël Renoux commented on FLINK-20390: - Most of the time it's a Kafka input

[jira] [Created] (FLINK-21049) query_configuration.html content out date

谢波 created FLINK-21049: -- Summary: query_configuration.html content out date Key: FLINK-21049 URL: https://issues.apache.org/jira/browse/FLINK-21049 Project: Flink Issue Type: Bug Components

[jira] [Created] (FLINK-21058) The Show Partitinos command is supported under the Flink dialect to show all partitions

孙铮 created FLINK-21058: -- Summary: The Show Partitinos command is supported under the Flink dialect to show all partitions Key: FLINK-21058 URL: https://issues.apache.org/jira/browse/FLINK-21058 Project: Flink

[jira] [Updated] (FLINK-21058) Add SHOW PARTITION syntax support for flink

[ https://issues.apache.org/jira/browse/FLINK-21058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 孙铮 updated FLINK-21058: --- Summary: Add SHOW PARTITION syntax support for flink (was: The Show Partitinos command is supported under the

[jira] [Commented] (FLINK-21058) Add SHOW PARTITION syntax support for flink

[ https://issues.apache.org/jira/browse/FLINK-21058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17269057#comment-17269057 ] 孙铮 commented on FLINK-21058: [~jark] Yes, I want to add SHOW PARTITION syntax suppor

[jira] [Updated] (FLINK-21058) Add SHOW PARTITION syntax support for flink

[ https://issues.apache.org/jira/browse/FLINK-21058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 孙铮 updated FLINK-21058: --- Description: I want to add SHOW PARTITION syntax support to flink (was: The Show Partitinos command is supported

[jira] [Commented] (FLINK-21049) query_configuration.html content out date

[ https://issues.apache.org/jira/browse/FLINK-21049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17269116#comment-17269116 ] 谢波 commented on FLINK-21049: [~jark] How to？Can you give me a

[jira] [Created] (FLINK-21064) Format docs incorrectly contain "format" property

Ingo Bürk created FLINK-21064: - Summary: Format docs incorrectly contain "format" property Key: FLINK-21064 URL: https://issues.apache.org/jira/browse/FLINK-21064 Project: Flink

[jira] [Commented] (FLINK-20977) can not use `use` command to switch database

[ https://issues.apache.org/jira/browse/FLINK-20977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17269793#comment-17269793 ] 孙铮 commented on FLINK-20977: [~jark] I submitted a PR ,Can you help me review? Th

[jira] [Commented] (FLINK-21049) query_configuration.html content out date

[ https://issues.apache.org/jira/browse/FLINK-21049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17269907#comment-17269907 ] 谢波 commented on FLINK-21049: [~jark]，hello jark，how to build the docs on win10。I ge

[jira] [Commented] (FLINK-20977) can not use `use` command to switch database

[ https://issues.apache.org/jira/browse/FLINK-20977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17269921#comment-17269921 ] 孙铮 commented on FLINK-20977: [~jark] I created a `mod` table and executed it successf

[jira] [Commented] (FLINK-21058) Add SHOW PARTITION syntax support for flink

[ https://issues.apache.org/jira/browse/FLINK-21058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270022#comment-17270022 ] 孙铮 commented on FLINK-21058: [~jark] [~nicholasjiang] Yes, I am going to refer to the

[jira] [Comment Edited] (FLINK-21058) Add SHOW PARTITION syntax support for flink

[ https://issues.apache.org/jira/browse/FLINK-21058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270022#comment-17270022 ] 孙铮 edited comment on FLINK-21058 at 1/22/21, 9:16 AM: -- [~

[jira] [Issue Comment Deleted] (FLINK-21058) Add SHOW PARTITION syntax support for flink

[ https://issues.apache.org/jira/browse/FLINK-21058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 孙铮 updated FLINK-21058: --- Comment: was deleted (was: [~jark] [~nicholasjiang] Yes, I am going to refer to the hive catalog SHOW PARTITIONS

[jira] [Updated] (FLINK-21058) Add SHOW PARTITION syntax support for flink

[ https://issues.apache.org/jira/browse/FLINK-21058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 孙铮 updated FLINK-21058: --- Description: Hive catalog show partitions  SHOW PARTITIONS [db_name.]table_name [PARTITION(partition_spec

[jira] [Updated] (FLINK-21058) Add SHOW PARTITION syntax support for flink

[ https://issues.apache.org/jira/browse/FLINK-21058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 孙铮 updated FLINK-21058: --- Description: Hive dialect already supports show partitions syntax   {code:java} SHOW PARTITIONS table_name

[jira] [Updated] (FLINK-21058) Add SHOW PARTITION syntax support for flink

[ https://issues.apache.org/jira/browse/FLINK-21058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 孙铮 updated FLINK-21058: --- Description: Hive dialect already supports show partitions syntax   {code:java} SHOW PARTITIONS [db_name

[jira] [Commented] (FLINK-21058) Add SHOW PARTITION syntax support for flink

[ https://issues.apache.org/jira/browse/FLINK-21058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17270044#comment-17270044 ] 孙铮 commented on FLINK-21058: [~jark] [~nicholasjiang]  I modified the description, thi

[jira] [Created] (FLINK-21162) FLINK SQL IF function semantic incorrect

谢波 created FLINK-21162: -- Summary: FLINK SQL IF function semantic incorrect Key: FLINK-21162 URL: https://issues.apache.org/jira/browse/FLINK-21162 Project: Flink Issue Type: Bug Components

[jira] [Commented] (FLINK-21162) FLINK SQL IF function semantic incorrect

[ https://issues.apache.org/jira/browse/FLINK-21162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17272735#comment-17272735 ] 谢波 commented on FLINK-21162: I using the COALESCE(return_flag, '') solve the

[jira] [Comment Edited] (FLINK-21162) FLINK SQL IF function semantic incorrect

[ https://issues.apache.org/jira/browse/FLINK-21162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17272735#comment-17272735 ] 谢波 edited comment on FLINK-21162 at 1/27/21, 10:06 AM: --- I u

[jira] [Created] (FLINK-21219) FlinkKafkaConsumer ignores offset overrides for new topics when restoring from savepoint.

Dominik Wosiński created FLINK-21219: Summary: FlinkKafkaConsumer ignores offset overrides for new topics when restoring from savepoint. Key: FLINK-21219 URL: https://issues.apache.org/jira/browse/FLINK-21219

[jira] [Commented] (FLINK-21219) FlinkKafkaConsumer ignores offset overrides for new topics when restoring from savepoint.

[ https://issues.apache.org/jira/browse/FLINK-21219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276020#comment-17276020 ] Dominik Wosiński commented on FLINK-21219: -- I would like to work on

[jira] [Commented] (FLINK-21219) FlinkKafkaConsumer ignores offset overrides for new topics when restoring from savepoint.

[ https://issues.apache.org/jira/browse/FLINK-21219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276739#comment-17276739 ] Dominik Wosiński commented on FLINK-21219: -- Thanks, tried looking for that

[jira] [Commented] (FLINK-10806) Support multiple consuming offsets when discovering a new topic

[ https://issues.apache.org/jira/browse/FLINK-10806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276741#comment-17276741 ] Dominik Wosiński commented on FLINK-10806: -- Hey,  can I tackle

[jira] [Commented] (FLINK-10806) Support multiple consuming offsets when discovering a new topic

[jira] [Commented] (FLINK-11395) Support for Avro StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-11395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16997078#comment-16997078 ] Grzegorz Kołakowski commented on FLINK-11395: - What about repla

[jira] [Comment Edited] (FLINK-11395) Support for Avro StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-11395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16997078#comment-16997078 ] Grzegorz Kołakowski edited comment on FLINK-11395 at 12/16/19 8:1

[jira] [Comment Edited] (FLINK-11395) Support for Avro StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-11395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16997078#comment-16997078 ] Grzegorz Kołakowski edited comment on FLINK-11395 at 12/16/19 3:1

[jira] [Comment Edited] (FLINK-11395) Support for Avro StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-11395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16997078#comment-16997078 ] Grzegorz Kołakowski edited comment on FLINK-11395 at 12/16/19 3:1

[jira] [Created] (FLINK-15357) schema created by JsonRowSchemaConverter are not suitable for TableEnv.sqlQuery table schema

巫旭阳 created FLINK-15357: --- Summary: schema created by JsonRowSchemaConverter are not suitable for TableEnv.sqlQuery table schema Key: FLINK-15357 URL: https://issues.apache.org/jira/browse/FLINK-15357 Project

[jira] [Commented] (FLINK-15357) schema created by JsonRowSchemaConverter are not suitable for TableEnv.sqlQuery table schema

[ https://issues.apache.org/jira/browse/FLINK-15357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17002075#comment-17002075 ] 巫旭阳 commented on FLINK-15357: - Hi, Of course that would solve the problem. The poin

[jira] [Created] (FLINK-15438) Counter metrics are incorrectly reported as total counts to DataDog

Jörn Kottmann created FLINK-15438: - Summary: Counter metrics are incorrectly reported as total counts to DataDog Key: FLINK-15438 URL: https://issues.apache.org/jira/browse/FLINK-15438 Project: Flink

[jira] [Commented] (FLINK-15438) Counter metrics are incorrectly reported as total counts to DataDog

[ https://issues.apache.org/jira/browse/FLINK-15438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17005487#comment-17005487 ] Jörn Kottmann commented on FLINK-15438: --- Yes, one of the counters I nee

[jira] [Commented] (FLINK-15438) Counter metrics are incorrectly reported as total counts to DataDog

[ https://issues.apache.org/jira/browse/FLINK-15438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17005760#comment-17005760 ] Jörn Kottmann commented on FLINK-15438: --- I would like to propose to ch

[jira] [Commented] (FLINK-9272) DataDog API "counter" metric type is deprecated

[ https://issues.apache.org/jira/browse/FLINK-9272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006007#comment-17006007 ] Jörn Kottmann commented on FLINK-9272: -- The name changed from counter to count

[jira] [Commented] (FLINK-12461) Flink 1.8 not working with Scala 2.12.8

[ https://issues.apache.org/jira/browse/FLINK-12461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006931#comment-17006931 ] Gaël Renoux commented on FLINK-12461: - By the way, I just tested Scala 2.12.10

<    5   6   7   8   9   10   11   12   13   14   >