[jira] [Updated] (FLINK-18934) Idle stream does not advance watermark in connected stream

[ https://issues.apache.org/jira/browse/FLINK-18934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-18934: - Fix Version/s: 1.13.1 > Idle stream does not advance watermark in connected stream >

[jira] [Commented] (FLINK-20228) ESsink accur thread blocked

[ https://issues.apache.org/jira/browse/FLINK-20228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319376#comment-17319376 ] Konstantin Knauf commented on FLINK-20228: -- Deprioritzed to Major. Flink 1.9 is not supported

[jira] [Commented] (FLINK-22134) Test the reactive mode

[ https://issues.apache.org/jira/browse/FLINK-22134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319374#comment-17319374 ] Xintong Song commented on FLINK-22134: -- cc [~trohrmann], [~rmetzger], [~chesnay] I've done my

[jira] [Updated] (FLINK-20228) ESsink accur thread blocked

[ https://issues.apache.org/jira/browse/FLINK-20228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-20228: - Priority: Major (was: Blocker) > ESsink accur thread blocked >

[jira] [Updated] (FLINK-18934) Idle stream does not advance watermark in connected stream

[ https://issues.apache.org/jira/browse/FLINK-18934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-18934: - Priority: Blocker (was: Major) > Idle stream does not advance watermark in connected

[jira] [Commented] (FLINK-18934) Idle stream does not advance watermark in connected stream

[ https://issues.apache.org/jira/browse/FLINK-18934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319373#comment-17319373 ] Dawid Wysakowicz commented on FLINK-18934: -- Actually it is a blocker that we've not handled

[GitHub] [flink] flinkbot commented on pull request #15573: [hotfix][docs] Fix the consumer committed destination in Kafka doc

flinkbot commented on pull request #15573: URL: https://github.com/apache/flink/pull/15573#issuecomment-817726652 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-18934) Idle stream does not advance watermark in connected stream

[ https://issues.apache.org/jira/browse/FLINK-18934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-18934: - Priority: Major (was: Blocker) > Idle stream does not advance watermark in connected

[jira] [Commented] (FLINK-18934) Idle stream does not advance watermark in connected stream

[ https://issues.apache.org/jira/browse/FLINK-18934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319371#comment-17319371 ] Konstantin Knauf commented on FLINK-18934: -- As this is clearly not a Blocker (open for > 6

[jira] [Commented] (FLINK-18894) StateFun job stalls on stop-with-savepoint

[ https://issues.apache.org/jira/browse/FLINK-18894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319369#comment-17319369 ] Konstantin Knauf commented on FLINK-18894: -- [~igal] Is this ticket resolved? If not, it is

[GitHub] [flink] wsz94 opened a new pull request #15573: [hotfix][docs] Fix the consumer committed destination in Kafka doc

wsz94 opened a new pull request #15573: URL: https://github.com/apache/flink/pull/15573 As kafka.md shown, it said that 'If checkpointing is disabled, the Kafka consumer will periodically commit the offsets to Zookeeper'. But at present, 90% services committed offsets to brokers not

[jira] [Commented] (FLINK-21996) Transient RPC failure without TaskManager failure can lead to split assignment loss

[ https://issues.apache.org/jira/browse/FLINK-21996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319367#comment-17319367 ] Kezhu Wang commented on FLINK-21996: bq. We cannot trigger checkpoints while we are "in limbo"

[jira] [Commented] (FLINK-21743) JdbcXaSinkFunction throws XAER_RMFAIL when calling snapshotState and beginTx

[ https://issues.apache.org/jira/browse/FLINK-21743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319363#comment-17319363 ] Yuan Mei commented on FLINK-21743: -- Hey [~weihao], you are right, the suggested setup can not work

[GitHub] [flink] flinkbot commented on pull request #15572: [FLINK-22202][parquet] Thread safety in ParquetColumnarRowInputFormat

flinkbot commented on pull request #15572: URL: https://github.com/apache/flink/pull/15572#issuecomment-817715303 ## CI report: * a8680249e8ac09c5faf032f39f05028665ab08ac UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15571: [FLINK-22166][table] Empty values with sort willl fail

flinkbot edited a comment on pull request #15571: URL: https://github.com/apache/flink/pull/15571#issuecomment-817703167 ## CI report: * dc6c96ec8a5f8d96cae0a753660f692afebcf1f6 Azure:

[jira] [Commented] (FLINK-6042) Display last n exceptions/causes for job restarts in Web UI

[ https://issues.apache.org/jira/browse/FLINK-6042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319360#comment-17319360 ] Dawid Wysakowicz commented on FLINK-6042: - Hey [~mapohl] What is the status of this task? Has it

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[jira] [Updated] (FLINK-22215) Rename RECOVERING state to INITIALIZING

[ https://issues.apache.org/jira/browse/FLINK-22215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-22215: -- Description: Task https://issues.apache.org/jira/browse/FLINK-17012  introduced new

[jira] [Created] (FLINK-22238) Investigate angular native flamegraph library

Chesnay Schepler created FLINK-22238: Summary: Investigate angular native flamegraph library Key: FLINK-22238 URL: https://issues.apache.org/jira/browse/FLINK-22238 Project: Flink Issue

[jira] [Updated] (FLINK-22215) Rename RECOVERING state to INITIALIZING

[ https://issues.apache.org/jira/browse/FLINK-22215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-22215: -- Summary: Rename RECOVERING state to INITIALIZING (was: Rename RECOVERING state to

[jira] [Commented] (FLINK-21996) Transient RPC failure without TaskManager failure can lead to split assignment loss

[ https://issues.apache.org/jira/browse/FLINK-21996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319358#comment-17319358 ] Kezhu Wang commented on FLINK-21996: [~sewen] Taking no source tasks into account, these guarantees

[jira] [Created] (FLINK-22237) Cleanup flamegraph html component

Chesnay Schepler created FLINK-22237: Summary: Cleanup flamegraph html component Key: FLINK-22237 URL: https://issues.apache.org/jira/browse/FLINK-22237 Project: Flink Issue Type:

[jira] [Updated] (FLINK-22236) Document opt-in behavior of flamegraph

[ https://issues.apache.org/jira/browse/FLINK-22236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22236: - Affects Version/s: 1.13.0 > Document opt-in behavior of flamegraph >

[jira] [Updated] (FLINK-22236) Document opt-in behavior of flamegraph

[ https://issues.apache.org/jira/browse/FLINK-22236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22236: - Priority: Blocker (was: Major) > Document opt-in behavior of flamegraph >

[jira] [Created] (FLINK-22236) Document opt-in behavior of flamegraph

Chesnay Schepler created FLINK-22236: Summary: Document opt-in behavior of flamegraph Key: FLINK-22236 URL: https://issues.apache.org/jira/browse/FLINK-22236 Project: Flink Issue Type:

[jira] [Created] (FLINK-22235) Document stability concerns of flamegraphs for heavier jobs

Chesnay Schepler created FLINK-22235: Summary: Document stability concerns of flamegraphs for heavier jobs Key: FLINK-22235 URL: https://issues.apache.org/jira/browse/FLINK-22235 Project: Flink

[jira] [Commented] (FLINK-21844) Do not auto-configure maxParallelism when setting "scheduler-mode: reactive"

[ https://issues.apache.org/jira/browse/FLINK-21844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319357#comment-17319357 ] Chesnay Schepler commented on FLINK-21844: -- I've created FLINK-22234 as the follow-up. > Do

[jira] [Created] (FLINK-22234) Read savepoint before creating ExecutionGraph

Chesnay Schepler created FLINK-22234: Summary: Read savepoint before creating ExecutionGraph Key: FLINK-22234 URL: https://issues.apache.org/jira/browse/FLINK-22234 Project: Flink Issue

[GitHub] [flink] hameizi commented on pull request #15564: [FLINK-22207][connectors/hive]Hive Catalog retrieve Flink Properties …

hameizi commented on pull request #15564: URL: https://github.com/apache/flink/pull/15564#issuecomment-817708105 > Thanks for the fix, could you add a test case? hello , I test the fix in sql-client "clickhousetableflink_append_stream" have propertie

[jira] [Updated] (FLINK-22233) Spelling error of word "constant" in source code

[ https://issues.apache.org/jira/browse/FLINK-22233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 王高超 updated FLINK-22233: Description: When I write the data to MySQL and forget to add the primary key, I report such an error： '

[jira] [Commented] (FLINK-22233) Spelling error of word "constant" in source code

[ https://issues.apache.org/jira/browse/FLINK-22233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319352#comment-17319352 ] Dawid Wysakowicz commented on FLINK-22233: -- Thank you for updating the description! > Spelling

[jira] [Updated] (FLINK-22233) Spelling error of word "constant" in source code

[ https://issues.apache.org/jira/browse/FLINK-22233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22233: - Labels: starter (was: ) > Spelling error of word "constant" in source code >

[jira] [Updated] (FLINK-22233) Spelling error of word "constant" in source code

[ https://issues.apache.org/jira/browse/FLINK-22233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22233: - Affects Version/s: (was: 1.12.2) > Spelling error of word "constant" in source code

[jira] [Updated] (FLINK-22233) Spelling error of word "constant" in source code

[ https://issues.apache.org/jira/browse/FLINK-22233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22233: - Priority: Minor (was: Trivial) > Spelling error of word "constant" in source code >

[jira] [Commented] (FLINK-15472) Support SQL Client Gateway

[ https://issues.apache.org/jira/browse/FLINK-15472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319351#comment-17319351 ] Jark Wu commented on FLINK-15472: - [~xiangtao] yes. > Support SQL Client Gateway >

[jira] [Updated] (FLINK-22233) Spelling error of word "constant" in source code

[ https://issues.apache.org/jira/browse/FLINK-22233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 王高超 updated FLINK-22233: Description: ' org.apache.flink.table.api.ValidationException: Flink doesn't support ENFORCED mode for PRIMARY

[GitHub] [flink] flinkbot commented on pull request #15571: [FLINK-22166][table] Empty values with sort willl fail

flinkbot commented on pull request #15571: URL: https://github.com/apache/flink/pull/15571#issuecomment-817703167 ## CI report: * dc6c96ec8a5f8d96cae0a753660f692afebcf1f6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15570: [FLINK-22016][table-planner-blink] RexNodeExtractor#visitLiteral now deal with NULL literals correctly

flinkbot edited a comment on pull request #15570: URL: https://github.com/apache/flink/pull/15570#issuecomment-817676016 ## CI report: * d25d03d4b3793064e7ff77ae7c03bfb60e43536f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15568: [FLINK-17371][table-runtime] Add cases for decimal casting

flinkbot edited a comment on pull request #15568: URL: https://github.com/apache/flink/pull/15568#issuecomment-817675780 ## CI report: * 0fadc09a8fa301dc7a46c5893d16390f76379853 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15569: [FLINK-21247][table] Fix problem in MapDataSerializer#copy when there…

flinkbot edited a comment on pull request #15569: URL: https://github.com/apache/flink/pull/15569#issuecomment-817675895 ## CI report: * 567f33cdbb0bcba800140cecb357c294800e7dfc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15561: [FLINK-20695][ha] Clean up ha data for job if globally terminated

flinkbot edited a comment on pull request #15561: URL: https://github.com/apache/flink/pull/15561#issuecomment-817508957 ## CI report: * 85afc0e14a28cdf84f44a2013306e3257421 Azure:

[GitHub] [flink] flinkbot commented on pull request #15572: [FLINK-22202][parquet] Thread safety in ParquetColumnarRowInputFormat

flinkbot commented on pull request #15572: URL: https://github.com/apache/flink/pull/15572#issuecomment-817702728 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-22233) Spelling error of word "constant" in source code

[ https://issues.apache.org/jira/browse/FLINK-22233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 王高超 updated FLINK-22233: Description: ' org.apache.flink.table.api.ValidationException: Flink doesn't support ENFORCED mode for PRIMARY

[GitHub] [flink] flinkbot edited a comment on pull request #15525: [FLINK-22154][table-planner-blink] Fix bug where PushFilterIntoTableSourceScanRule fails to deal with IN expressions

flinkbot edited a comment on pull request #15525: URL: https://github.com/apache/flink/pull/15525#issuecomment-815836876 ## CI report: * 0bafe11dfac9bc4a29b5cf20842bd5b87b3ed182 Azure:

[jira] [Assigned] (FLINK-22196) FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out the column indices which the does not exist in current row schema

[ https://issues.apache.org/jira/browse/FLINK-22196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22196: --- Assignee: Lsw_aka_laplace > FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out the column

[jira] [Updated] (FLINK-22202) Thread safety in ParquetColumnarRowInputFormat

[ https://issues.apache.org/jira/browse/FLINK-22202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22202: --- Labels: pull-request-available (was: ) > Thread safety in ParquetColumnarRowInputFormat >

[GitHub] [flink] JingsongLi opened a new pull request #15572: [FLINK-22202][parquet] Thread safety in ParquetColumnarRowInputFormat

JingsongLi opened a new pull request #15572: URL: https://github.com/apache/flink/pull/15572 ## What is the purpose of the change In a VectorizedColumnBatch, the dictionary will be lazied deserialized. If there are multiple batches at the same time, there may be thread

[jira] [Updated] (FLINK-21713) Correct function CURRENT_TIMESTAMP/CURRENT_TIME/CURRENT_DATE/NOW/LOCALTIME/LOCALTIMESTAMP

[ https://issues.apache.org/jira/browse/FLINK-21713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-21713: - Release Note: (was: ) > Correct function >

[jira] [Commented] (FLINK-20727) Pulsar SourceFunction

[ https://issues.apache.org/jira/browse/FLINK-20727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319346#comment-17319346 ] Dawid Wysakowicz commented on FLINK-20727: -- Moved over from release notes: {quote}

[jira] [Comment Edited] (FLINK-20728) Pulsar SinkFunction

[ https://issues.apache.org/jira/browse/FLINK-20728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319345#comment-17319345 ] Dawid Wysakowicz edited comment on FLINK-20728 at 4/12/21, 10:36 AM: -

[jira] [Comment Edited] (FLINK-20728) Pulsar SinkFunction

[ https://issues.apache.org/jira/browse/FLINK-20728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319345#comment-17319345 ] Dawid Wysakowicz edited comment on FLINK-20728 at 4/12/21, 10:36 AM: -

[jira] [Commented] (FLINK-20728) Pulsar SinkFunction

[ https://issues.apache.org/jira/browse/FLINK-20728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319345#comment-17319345 ] Dawid Wysakowicz commented on FLINK-20728: -- SourceFunction and SinkFunction interfaces will be

[jira] [Updated] (FLINK-20727) Pulsar SourceFunction

[ https://issues.apache.org/jira/browse/FLINK-20727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-20727: - Release Note: (was: SourceFunction and SinkFunction interfaces will be deprecated in

[jira] [Updated] (FLINK-20728) Pulsar SinkFunction

[ https://issues.apache.org/jira/browse/FLINK-20728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-20728: - Release Note: (was: SourceFunction and SinkFunction interfaces will be deprecated in

[jira] [Commented] (FLINK-21996) Transient RPC failure without TaskManager failure can lead to split assignment loss

[ https://issues.apache.org/jira/browse/FLINK-21996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319341#comment-17319341 ] Stephan Ewen commented on FLINK-21996: -- [~kezhuw] I think the guarantees that we need on the Task

[jira] [Updated] (FLINK-21696) scala code in "Writing WatermarkGenerators" documentation missing/deprecated

[ https://issues.apache.org/jira/browse/FLINK-21696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-21696: - Release Note: (was: continuation of

[jira] [Updated] (FLINK-22005) SQL Client end-to-end test (Old planner) Elasticsearch (v7.5.1)

[ https://issues.apache.org/jira/browse/FLINK-22005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22005: - Release Note: (was: fix in the master c375f4cfd394c10b54110eac446873055b716b89) >

[jira] [Commented] (FLINK-22005) SQL Client end-to-end test (Old planner) Elasticsearch (v7.5.1)

[ https://issues.apache.org/jira/browse/FLINK-22005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319337#comment-17319337 ] Dawid Wysakowicz commented on FLINK-22005: -- fix in the master

[GitHub] [flink] zentol commented on a change in pull request #15553: [FLINK-22069] Reduce various logging issues

zentol commented on a change in pull request #15553: URL: https://github.com/apache/flink/pull/15553#discussion_r611509118 ## File path: flink-dist/src/main/resources/flink-conf.yaml ## @@ -145,7 +145,7 @@ jobmanager.execution.failover-strategy: region # The address to

[jira] [Commented] (FLINK-22233) 源码中单词"constaint"拼写错误

[ https://issues.apache.org/jira/browse/FLINK-22233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319334#comment-17319334 ] Dawid Wysakowicz commented on FLINK-22233: -- Please use English in JIRA. > 源码中单词"constaint"拼写错误

[jira] [Assigned] (FLINK-22030) Add Technical Debt Issue Type

[ https://issues.apache.org/jira/browse/FLINK-22030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reassigned FLINK-22030: Assignee: Konstantin Knauf > Add Technical Debt Issue Type >

[jira] [Created] (FLINK-22233) 源码中单词"constaint"拼写错误

王高超 created FLINK-22233: --- Summary: 源码中单词"constaint"拼写错误 Key: FLINK-22233 URL: https://issues.apache.org/jira/browse/FLINK-22233 Project: Flink Issue Type: Improvement Components: Table SQL /

[jira] [Updated] (FLINK-13031) Support dynamic offset in tumbling windows

[ https://issues.apache.org/jira/browse/FLINK-13031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-13031: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-18280) Kotlin adapters for Flink types?

[ https://issues.apache.org/jira/browse/FLINK-18280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-18280: - Issue Type: New Feature (was: Wish) As part of

[GitHub] [flink] KurtYoung commented on a change in pull request #15570: [FLINK-22016][table-planner-blink] RexNodeExtractor#visitLiteral now deal with NULL literals correctly

KurtYoung commented on a change in pull request #15570: URL: https://github.com/apache/flink/pull/15570#discussion_r611500610 ## File path:

[jira] [Updated] (FLINK-15158) Why convert integer to bigdecimal for formart-json when kafka is used

[ https://issues.apache.org/jira/browse/FLINK-15158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-15158: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-20480) Methods from CheckpointedFunction interface in FlinkKafkaConsumerBase are set to final

[ https://issues.apache.org/jira/browse/FLINK-20480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-20480: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-17714) Support custom RestartBackoffTimeStrategy

[ https://issues.apache.org/jira/browse/FLINK-17714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-17714: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-2681) Scala API does not support Either type to be used as key

[ https://issues.apache.org/jira/browse/FLINK-2681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-2681: Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-14001) add a API to enable user to get the operator code generated by Flink engine

[ https://issues.apache.org/jira/browse/FLINK-14001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-14001: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-8510) Provide access to Delivery envelope in RabbitMQ Source

[ https://issues.apache.org/jira/browse/FLINK-8510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-8510: Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-10904) Expose Classloader before Pipeline execution

[ https://issues.apache.org/jira/browse/FLINK-10904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-10904: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-9586) Make collection sources parallelisable

[ https://issues.apache.org/jira/browse/FLINK-9586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-9586: Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-15610) How to achieve the udf that the number of return column is uncertain

[ https://issues.apache.org/jira/browse/FLINK-15610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-15610: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-14741) Document pluggable sources and sinks in the production code for testing

[ https://issues.apache.org/jira/browse/FLINK-14741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-14741: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-18649) Add a MongoDB Connector with Exactly-Once Semantics

[ https://issues.apache.org/jira/browse/FLINK-18649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-18649: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-6576) Allow ConfigOptions to validate the configured value

[ https://issues.apache.org/jira/browse/FLINK-6576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-6576: Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-6099) not able to auto infer the row type when getting information from jdbc vertica

[ https://issues.apache.org/jira/browse/FLINK-6099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-6099: Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-15404) How to insert hive table in streaming mode and blink planner

[ https://issues.apache.org/jira/browse/FLINK-15404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-15404: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-15596) Support key-value messages for KafkaTableSink for flink SQL \Table

[ https://issues.apache.org/jira/browse/FLINK-15596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-15596: - Issue Type: Improvement (was: Wish) As part of

[jira] [Closed] (FLINK-22200) Flink SQL Client Error with: Could not find any factory for identifier 'hudi' that implements 'org.apache.flink.table.factories.DynamicTableSourceFactory

[ https://issues.apache.org/jira/browse/FLINK-22200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-22200. Resolution: Won't Fix It seems there is no `META-INF` in the Hudi JAR file. Or something else is

[jira] [Updated] (FLINK-19846) Grammar mistakes in annotations and log

[ https://issues.apache.org/jira/browse/FLINK-19846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-19846: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-9044) Fork a new stream in a stream

[ https://issues.apache.org/jira/browse/FLINK-9044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-9044: Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-17641) How to secure flink applications on yarn on multi-tenant environment

[ https://issues.apache.org/jira/browse/FLINK-17641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-17641: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-14034) In FlinkKafkaProducer, KafkaTransactionState should be made public or invoke should be made final

[ https://issues.apache.org/jira/browse/FLINK-14034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-14034: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-18344) Avoid wrong check with shardId in DynamoDB Streams

[ https://issues.apache.org/jira/browse/FLINK-18344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-18344: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-16584) Whether to support the long type field in table planner when the source is kafka and event time field's type is long

[ https://issues.apache.org/jira/browse/FLINK-16584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-16584: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-20201) Support automatic adjustment of window parameters

[ https://issues.apache.org/jira/browse/FLINK-20201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-20201: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-15165) support upsert (Hive ACID) in Hive sink

[ https://issues.apache.org/jira/browse/FLINK-15165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-15165: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-17079) CsvTableSinkFactoryBase add numFiles and writeMode config when createTableSink

[ https://issues.apache.org/jira/browse/FLINK-17079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-17079: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-1552) Allow secondary sorts in Vertex Centric Iteration

[ https://issues.apache.org/jira/browse/FLINK-1552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-1552: Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-17122) Support InputSelectable and BoundedMultiInput operators with checkpointing

[ https://issues.apache.org/jira/browse/FLINK-17122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-17122: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-21585) Provide a configurable way to skip metrics

[ https://issues.apache.org/jira/browse/FLINK-21585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-21585: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-15514) Bump Elasticsearch version from 6.3.1 to 6.8.6 for es6 connector

[ https://issues.apache.org/jira/browse/FLINK-15514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-15514: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-19847) Can we create a fast support on the Nested table join?

[ https://issues.apache.org/jira/browse/FLINK-19847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-19847: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-6490) Explicitly support dynamic defaults in ConfigOption

[ https://issues.apache.org/jira/browse/FLINK-6490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-6490: Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-12023) Override TaskManager memory when submitting a Flink job

[ https://issues.apache.org/jira/browse/FLINK-12023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-12023: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-19686) Cast question for data | time |timestamp type

[ https://issues.apache.org/jira/browse/FLINK-19686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-19686: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-9814) CsvTableSource "lack of column" warning

[ https://issues.apache.org/jira/browse/FLINK-9814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-9814: Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-15142) Extend Redis Sink Connector to Redis Streams

[ https://issues.apache.org/jira/browse/FLINK-15142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-15142: - Issue Type: Improvement (was: Wish) As part of

<    1   2   3   4   5   6   7   8   >