[GitHub] [flink] flinkbot commented on pull request #19494: [FLINK-27267][contrib] Migrate tests to JUnit5

2022-04-15 Thread GitBox
flinkbot commented on PR #19494: URL: https://github.com/apache/flink/pull/19494#issuecomment-1100499721 ## CI report: * 4b20ff4a6cbbc48cc8ce3e1baa10befdee58840a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-27267) [JUnit5 Migration] Module: flink-contrib

2022-04-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27267: --- Labels: pull-request-available (was: ) > [JUnit5 Migration] Module: flink-contrib >

[GitHub] [flink] RocMarshal opened a new pull request, #19494: [FLINK-27267][contrib] Migrate tests to JUnit5

2022-04-15 Thread GitBox
RocMarshal opened a new pull request, #19494: URL: https://github.com/apache/flink/pull/19494 ## What is the purpose of the change Migrate tests to JUnit5 ## Brief change log Migrate tests to JUnit5 ## Verifying this change This change

[jira] [Created] (FLINK-27267) [JUnit5 Migration] Module: flink-contrib

2022-04-15 Thread RocMarshal (Jira)
RocMarshal created FLINK-27267: -- Summary: [JUnit5 Migration] Module: flink-contrib Key: FLINK-27267 URL: https://issues.apache.org/jira/browse/FLINK-27267 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-21501) Sync Chinese documentation with FLINK-21343

2022-04-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21501: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned

[jira] [Updated] (FLINK-20561) Add documentation for `records-lag-max` metric.

2022-04-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20561: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

[jira] [Updated] (FLINK-20778) [FLINK-20778] the comment for the type of kafka consumer is wrong at KafkaPartitionSplit

2022-04-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20778: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned

[jira] [Updated] (FLINK-26104) KeyError: 'type_info' in PyFlink test

2022-04-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26104: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira

[jira] [Updated] (FLINK-25442) HBaseConnectorITCase.testTableSink failed on azure

2022-04-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25442: --- Labels: auto-deprioritized-critical test-stability (was: stale-critical test-stability)

[jira] [Updated] (FLINK-20918) Avoid excessive flush of Hadoop output stream

2022-04-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20918: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

[jira] [Updated] (FLINK-20938) Implement Flink's own tencent COS filesystem

2022-04-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20938: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

[jira] [Updated] (FLINK-26110) AvroStreamingFileSinkITCase failed on azure

2022-04-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26110: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira

[jira] [Updated] (FLINK-26047) Support usrlib in HDFS for YARN application mode

2022-04-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26047: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-21643) JDBC sink should be able to execute statements on multiple tables

2022-04-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21643: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

[jira] [Updated] (FLINK-25529) java.lang.ClassNotFoundException: org.apache.orc.PhysicalWriter when write bulkly into hive-2.1.1 orc table

2022-04-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25529: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-20979) Wrong description of 'sink.bulk-flush.max-actions'

2022-04-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20979: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available starter

[jira] [Updated] (FLINK-26109) Avro Confluent Schema Registry nightly end-to-end test failed on azure

2022-04-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26109: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira

[jira] [Updated] (FLINK-21440) Translate Real Time Reporting with the Table API doc and correct a spelling mistake

2022-04-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21440: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

[jira] [Updated] (FLINK-21444) Lookup joins should deal with intermediate table scans correctly

2022-04-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21444: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was:

[jira] [Updated] (FLINK-21686) Duplicate code in hive parser file should be abstracted into functions

2022-04-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21686: --- Labels: auto-deprioritized-minor pull-request-available (was: pull-request-available

[jira] [Commented] (FLINK-27255) Flink-avro does not support serialization and deserialization of avro schema longer than 65535 characters

2022-04-15 Thread Steven Zhen Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522943#comment-17522943 ] Steven Zhen Wu commented on FLINK-27255: [~jinyius] this issue existed for a while now. not sth

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #165: [FLINK-26140] Support rollback strategies

2022-04-15 Thread GitBox
gyfora commented on PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#issuecomment-1100367932 @wangyang0918 I think for the suspend to work, I need to fix 2 things basically: 1. If the user suspends a job, the spec should be automatically marked as

[GitHub] [flink] metaswirl commented on a diff in pull request #17228: [FLINK-24236] Migrate tests to factory approach

2022-04-15 Thread GitBox
metaswirl commented on code in PR #17228: URL: https://github.com/apache/flink/pull/17228#discussion_r851495599 ## flink-runtime/src/test/java/org/apache/flink/runtime/metrics/ReporterSetupTest.java: ## @@ -47,17 +50,30 @@ import static org.junit.Assert.assertTrue; /**

[GitHub] [flink] flinkbot commented on pull request #19493: [FLINK-27205][docs-zh] Translate "Concepts -> Glossary" page into Chinese.

2022-04-15 Thread GitBox
flinkbot commented on PR #19493: URL: https://github.com/apache/flink/pull/19493#issuecomment-1100198258 ## CI report: * 42bb3147bb7ab02a51fdc0c0b9cca28c15289a91 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] liuzhuang2017 opened a new pull request, #19493: [FLINK-27205][docs-zh] Translate "Concepts -> Glossary" page into Chinese.

2022-04-15 Thread GitBox
liuzhuang2017 opened a new pull request, #19493: URL: https://github.com/apache/flink/pull/19493 ## What is the purpose of the change ![image](https://user-images.githubusercontent.com/95120044/163592412-7e4e94b7-1800-422a-8675-e78b34c0601d.png)

[jira] [Updated] (FLINK-27264) Add ITCase for concurrent batch overwrite and streaming insert

2022-04-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27264: --- Labels: pull-request-available (was: ) > Add ITCase for concurrent batch overwrite and

[GitHub] [flink-table-store] LadyForest opened a new pull request, #91: [FLINK-27264] Add IT case for concurrent batch overwrite and streaming insert into

2022-04-15 Thread GitBox
LadyForest opened a new pull request, #91: URL: https://github.com/apache/flink-table-store/pull/91 Add it case to cover the user story -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink-web] liuzhuang2017 commented on pull request #521: [hotfix][docs] Fix link tags typo.

2022-04-15 Thread GitBox
liuzhuang2017 commented on PR #521: URL: https://github.com/apache/flink-web/pull/521#issuecomment-1100116349 @wuchong ,Hi,please help me review this pr when you are free time, thank you. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] flinkbot commented on pull request #19492: Update TimeWindow.java

2022-04-15 Thread GitBox
flinkbot commented on PR #19492: URL: https://github.com/apache/flink/pull/19492#issuecomment-1100089900 ## CI report: * e5b4f082ff6f70ab1e93b3c6384e08424a71e97f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Comment Edited] (FLINK-26793) Flink Cassandra connector performance issue

2022-04-15 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522355#comment-17522355 ] Etienne Chauchot edited comment on FLINK-26793 at 4/15/22 12:58 PM:

[jira] [Comment Edited] (FLINK-26824) Upgrade Flink's supported Cassandra versions to match with the Cassandra community supported versions

2022-04-15 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521203#comment-17521203 ] Etienne Chauchot edited comment on FLINK-26824 at 4/15/22 12:57 PM:

[GitHub] [flink] huacaicai commented on pull request #19492: Update TimeWindow.java

2022-04-15 Thread GitBox
huacaicai commented on PR #19492: URL: https://github.com/apache/flink/pull/19492#issuecomment-1100087484 Based on the rolling window is a special window with a step size equal to the window size, so I modified the parameter to the window step size, which can better express the meaning of

[jira] [Comment Edited] (FLINK-6755) Allow triggering Checkpoints through command line client

2022-04-15 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458438#comment-17458438 ] Piotr Nowojski edited comment on FLINK-6755 at 4/15/22 12:52 PM: - The

[jira] [Created] (FLINK-27266) in hive_read_write.md, there is an extra backtick in the description

2022-04-15 Thread Jira
陈磊 created FLINK-27266: -- Summary: in hive_read_write.md, there is an extra backtick in the description Key: FLINK-27266 URL: https://issues.apache.org/jira/browse/FLINK-27266 Project: Flink Issue

[GitHub] [flink] huacaicai commented on pull request #19492: Update TimeWindow.java

2022-04-15 Thread GitBox
huacaicai commented on PR #19492: URL: https://github.com/apache/flink/pull/19492#issuecomment-1100087060 The window size cannot accurately express the true meaning of the parameter, because the sliding window needs to pass in the step size, and the rolling window passes in the window

[GitHub] [flink] huacaicai commented on pull request #19492: Update TimeWindow.java

2022-04-15 Thread GitBox
huacaicai commented on PR #19492: URL: https://github.com/apache/flink/pull/19492#issuecomment-1100086913 The window size cannot accurately express the true meaning of the parameter, because the sliding window needs to pass in the step size, and the rolling window passes in the window

[jira] [Comment Edited] (FLINK-6755) Allow triggering Checkpoints through command line client

2022-04-15 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458438#comment-17458438 ] Piotr Nowojski edited comment on FLINK-6755 at 4/15/22 12:51 PM: - The

[GitHub] [flink] huacaicai opened a new pull request, #19492: Update TimeWindow.java

2022-04-15 Thread GitBox
huacaicai opened a new pull request, #19492: URL: https://github.com/apache/flink/pull/19492 The window size cannot accurately express the true meaning of the parameter, because the sliding window needs to pass in the step size, and the rolling window passes in the window size. Based on

[jira] [Comment Edited] (FLINK-27101) Periodically break the chain of incremental checkpoint

2022-04-15 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522815#comment-17522815 ] Piotr Nowojski edited comment on FLINK-27101 at 4/15/22 12:48 PM: --

[jira] [Comment Edited] (FLINK-6755) Allow triggering Checkpoints through command line client

2022-04-15 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458438#comment-17458438 ] Piotr Nowojski edited comment on FLINK-6755 at 4/15/22 12:48 PM: - The

[jira] [Comment Edited] (FLINK-27101) Periodically break the chain of incremental checkpoint

2022-04-15 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522815#comment-17522815 ] Piotr Nowojski edited comment on FLINK-27101 at 4/15/22 12:47 PM: --

[GitHub] [flink] flinkbot commented on pull request #19491: [hotfix][docs-zh] Delete the "mongodb.md" file under "Formats" under "DataStream Connectors".

2022-04-15 Thread GitBox
flinkbot commented on PR #19491: URL: https://github.com/apache/flink/pull/19491#issuecomment-1100083966 ## CI report: * 4523dd09c135ef477ff1698f8a4bae96ab3e4c20 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] liuzhuang2017 commented on pull request #19491: [hotfix][docs-zh] Delete the "mongodb.md" file under "Formats" under "DataStream Connectors".

2022-04-15 Thread GitBox
liuzhuang2017 commented on PR #19491: URL: https://github.com/apache/flink/pull/19491#issuecomment-1100083881 @wuchong ,Hi,please help me review this pr when you are free time, thank you. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Commented] (FLINK-27101) Periodically break the chain of incremental checkpoint

2022-04-15 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522815#comment-17522815 ] Piotr Nowojski commented on FLINK-27101: Checkpoint would be still owned by the Flink itself.

[jira] [Commented] (FLINK-27265) The problem described by the filesystem.md documentation

2022-04-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-27265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522814#comment-17522814 ] 陈磊 commented on FLINK-27265: [https://github.com/apache/flink/pull/19489] [~MartijnVisser] Hi, Could you

[GitHub] [flink] liuzhuang2017 opened a new pull request, #19491: [hotfix][docs-zh] Delete the "mongodb.md" file under "Formats" under "DataStream Connectors".

2022-04-15 Thread GitBox
liuzhuang2017 opened a new pull request, #19491: URL: https://github.com/apache/flink/pull/19491 ## What is the purpose of the change # This is the English document:

[GitHub] [flink] luoyuxia commented on pull request #19435: [FLINK-27121][docs-zh]Translate "Configuration#overview" paragraph and the code example in "Application Development > Table API & SQL" to Ch

2022-04-15 Thread GitBox
luoyuxia commented on PR #19435: URL: https://github.com/apache/flink/pull/19435#issuecomment-1100081624 @leizhou666 Thanks for you contribution. LGTM @MartijnVisser Could you please help merge? -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-27265) The problem described by the filesystem.md documentation

2022-04-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-27265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 陈磊 updated FLINK-27265: --- Description: in filesystem.md, flink comes with four built-in BulkWriter factories, in fact, the list has five.

[jira] [Updated] (FLINK-27265) The problem described by the filesystem.md documentation

2022-04-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-27265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 陈磊 updated FLINK-27265: --- Attachment: (was: image-2022-04-15-20-26-09-895.png) > The problem described by the filesystem.md documentation

[jira] [Updated] (FLINK-27265) The problem described by the filesystem.md documentation

2022-04-15 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-27265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 陈磊 updated FLINK-27265: --- Attachment: (was: image-2022-04-15-20-20-00-116.png) > The problem described by the filesystem.md documentation

[jira] [Commented] (FLINK-27155) Reduce multiple reads to the same Changelog file in the same taskmanager during restore

2022-04-15 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522810#comment-17522810 ] Feifan Wang commented on FLINK-27155: - Hi [~roman] , I think we can achieve this by : *

[jira] [Created] (FLINK-27265) The problem described by the filesystem.md and hive_write_read.mddocumentation

2022-04-15 Thread Jira
陈磊 created FLINK-27265: -- Summary: The problem described by the filesystem.md and hive_write_read.mddocumentation Key: FLINK-27265 URL: https://issues.apache.org/jira/browse/FLINK-27265 Project: Flink

[jira] [Assigned] (FLINK-27264) Add ITCase for concurrent batch overwrite and streaming insert

2022-04-15 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-27264: Assignee: Jane Chan > Add ITCase for concurrent batch overwrite and streaming insert >

[jira] [Commented] (FLINK-27212) Failed to CAST('abcde', VARBINARY)

2022-04-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522807#comment-17522807 ] Jark Wu commented on FLINK-27212: - Hi [~matriv], {{x'45F0AB'}} is a {{BINARY}} not {{CHAR/VARCHAR}}

[jira] [Comment Edited] (FLINK-27212) Failed to CAST('abcde', VARBINARY)

2022-04-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522807#comment-17522807 ] Jark Wu edited comment on FLINK-27212 at 4/15/22 12:13 PM: --- Hi [~matriv],

[GitHub] [flink] luoyuxia commented on a diff in pull request #19419: [FLINK-22317][table] Support DROP column/constraint/watermark for ALTER TABLE statement

2022-04-15 Thread GitBox
luoyuxia commented on code in PR #19419: URL: https://github.com/apache/flink/pull/19419#discussion_r848239830 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/OperationConverterUtils.java: ## @@ -117,6 +128,193 @@ public static Operation

[jira] [Commented] (FLINK-27261) Disable web.cancel.enable for session jobs

2022-04-15 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522797#comment-17522797 ] Gyula Fora commented on FLINK-27261: But isn’t this something only the session cluster could

[jira] [Updated] (FLINK-27264) Add ITCase for concurrent batch overwrite and streaming insert

2022-04-15 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-27264: -- Description: !image-2022-04-15-19-26-09-649.png|width=609,height=241! Add it case for user story >

[jira] [Updated] (FLINK-27264) Add ITCase for concurrent batch overwrite and streaming insert

2022-04-15 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-27264: -- Attachment: image-2022-04-15-19-26-09-649.png > Add ITCase for concurrent batch overwrite and

[jira] [Created] (FLINK-27264) Add ITCase for concurrent batch overwrite and streaming insert

2022-04-15 Thread Jane Chan (Jira)
Jane Chan created FLINK-27264: - Summary: Add ITCase for concurrent batch overwrite and streaming insert Key: FLINK-27264 URL: https://issues.apache.org/jira/browse/FLINK-27264 Project: Flink

[jira] [Updated] (FLINK-27237) Partitioned table statement enhancement

2022-04-15 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-27237: -- Description: This is an umbrella issue which is used to track the syntax enhancement about

[GitHub] [flink] zoltar9264 commented on pull request #19252: [FLINK-25867][docs] translate ChangelogBackend documentation to chinese

2022-04-15 Thread GitBox
zoltar9264 commented on PR #19252: URL: https://github.com/apache/flink/pull/19252#issuecomment-1100046811 Thank you very much @Myasuka , your suggestion does look better, learn a lot ! I hive committed those change and squash them into first commit in this pr. (Last three commits are

[GitHub] [flink] flinkbot commented on pull request #19490: [FLINK-27263][table] Rename the metadata column to the user specified…

2022-04-15 Thread GitBox
flinkbot commented on PR #19490: URL: https://github.com/apache/flink/pull/19490#issuecomment-1100045930 ## CI report: * b98759b38d05a732ef3c9ceabfc844dfaf4bd2e8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

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

2022-04-15 Thread jeff-zou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522793#comment-17522793 ] jeff-zou commented on FLINK-27018: -- I think it's better to be consistent  in converting, because many

[jira] [Updated] (FLINK-27263) Rename the metadata column to the user specified name in DDL

2022-04-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27263: --- Labels: pull-request-available (was: ) > Rename the metadata column to the user specified

[GitHub] [flink] fsk119 opened a new pull request, #19490: [FLINK-27263][table] Rename the metadata column to the user specified…

2022-04-15 Thread GitBox
fsk119 opened a new pull request, #19490: URL: https://github.com/apache/flink/pull/19490 … name in DDL ## What is the purpose of the change *Currently the source output the metadata column with the `"$metadata"+ metadata key` as the column name. It's better that keep

[jira] [Created] (FLINK-27263) Rename the metadata column to the user specified name in DDL

2022-04-15 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-27263: - Summary: Rename the metadata column to the user specified name in DDL Key: FLINK-27263 URL: https://issues.apache.org/jira/browse/FLINK-27263 Project: Flink

[GitHub] [flink] MartijnVisser merged pull request #19401: [FLINK-25716][docs-zh] Translate "Streaming Concepts" page of "Applic…

2022-04-15 Thread GitBox
MartijnVisser merged PR #19401: URL: https://github.com/apache/flink/pull/19401 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] MartijnVisser commented on pull request #19401: [FLINK-25716][docs-zh] Translate "Streaming Concepts" page of "Applic…

2022-04-15 Thread GitBox
MartijnVisser commented on PR #19401: URL: https://github.com/apache/flink/pull/19401#issuecomment-1100038830 @snailHumming Thanks for the PR. I've squashed and rebased commits. The successful CI run was in

[GitHub] [flink] MartijnVisser commented on pull request #19489: in filesystem.md, flink comes with four built-in BulkWriter factories…

2022-04-15 Thread GitBox
MartijnVisser commented on PR #19489: URL: https://github.com/apache/flink/pull/19489#issuecomment-1100037906 @chenlei677 Thanks for the PR. Please check and follow the code contribution guide at https://flink.apache.org/contributing/contribute-code.html and update your PR, else it can't

[GitHub] [flink] MartijnVisser commented on pull request #19487: in filesystem.md, the format parameter described is incomplete.

2022-04-15 Thread GitBox
MartijnVisser commented on PR #19487: URL: https://github.com/apache/flink/pull/19487#issuecomment-1100037548 @chenlei677 Thanks for the PR. However, the list of formats in the documentation is not an extensive list of all formats. I don't think adding one adds a lot of value in this case.

[GitHub] [flink] MartijnVisser closed pull request #19485: Mssql branch

2022-04-15 Thread GitBox
MartijnVisser closed pull request #19485: Mssql branch URL: https://github.com/apache/flink/pull/19485 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] MartijnVisser commented on pull request #19485: Mssql branch

2022-04-15 Thread GitBox
MartijnVisser commented on PR #19485: URL: https://github.com/apache/flink/pull/19485#issuecomment-1100036893 @yinweiwen Please check and follow the code contribution guide at https://flink.apache.org/contributing/contribute-code.html - This PR is incorrect, therefore I'm closing it --

[jira] [Updated] (FLINK-22246) when use HiveCatalog create table , can't set Table owner property correctly

2022-04-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22246: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

[jira] [Updated] (FLINK-21699) SecurityUtils JaasModule make JVM dirty

2022-04-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21699: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

[jira] [Updated] (FLINK-22644) Translate "Native Kubernetes" page into Chinese

2022-04-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22644: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned

[jira] [Updated] (FLINK-22663) Release YARN resource very slow when cancel the job after some NodeManagers shutdown

2022-04-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22663: --- Labels: YARN auto-deprioritized-major auto-deprioritized-minor pull-request-available

[jira] [Updated] (FLINK-22437) Miss adding parallesim for filter operator in batch mode

2022-04-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22437: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned

[jira] [Updated] (FLINK-22679) code optimization:Transformation.equals

2022-04-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22679: --- Labels: auto-deprioritized-minor pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-22798) Exception handling of transactional producer

2022-04-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22798: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

[jira] [Updated] (FLINK-22526) Rename TopicId to topic in Kafka related code

2022-04-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22526: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

[jira] [Updated] (FLINK-23158) Source transformation is not added to the StreamExecutionEnvironment explicitly

2022-04-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23158: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

[jira] [Updated] (FLINK-23163) Add debug ability for kubernetes client

2022-04-15 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23163: --- Labels: auto-deprioritized-minor pull-request-available (was: pull-request-available

[GitHub] [flink] flinkbot commented on pull request #19489: in filesystem.md, flink comes with four built-in BulkWriter factories…

2022-04-15 Thread GitBox
flinkbot commented on PR #19489: URL: https://github.com/apache/flink/pull/19489#issuecomment-1100028822 ## CI report: * ab93146354ccd9d981e5fb854dcdfb9ce33047e1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-27218) Serializer in OperatorState has not been updated when new Serializers are NOT incompatible

2022-04-15 Thread Yue Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522779#comment-17522779 ] Yue Ma commented on FLINK-27218: [~yunta] ok i'm glad to do this fix, i'll submit a pr soon >

[GitHub] [flink] chenlei677 opened a new pull request, #19489: in filesystem.md, flink comes with four built-in BulkWriter factories…

2022-04-15 Thread GitBox
chenlei677 opened a new pull request, #19489: URL: https://github.com/apache/flink/pull/19489 ## What is the purpose of the change in filesystem.md, flink comes with four built-in BulkWriter factories, in fact, the list has five. ## Brief change log in filesystem.md,

[GitHub] [flink] Myasuka commented on a diff in pull request #19252: [FLINK-25867][docs] translate ChangelogBackend documentation to chinese

2022-04-15 Thread GitBox
Myasuka commented on code in PR #19252: URL: https://github.com/apache/flink/pull/19252#discussion_r851163050 ## docs/content.zh/docs/ops/state/state_backends.md: ## @@ -306,77 +329,75 @@ public class MyOptionsFactory implements ConfigurableRocksDBOptionsFactory { {{< top

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on pull request #165: [FLINK-26140] Support rollback strategies

2022-04-15 Thread GitBox
wangyang0918 commented on PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#issuecomment-1100014552 @gyfora No hurry, take your time. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Commented] (FLINK-27215) JDBC sink transiently deleted a record because of -u message of that record

2022-04-15 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522764#comment-17522764 ] Shengkai Fang commented on FLINK-27215: --- Hi, [~yulei0824]. It's up to the planner to determine

[GitHub] [flink] luoyuxia commented on a diff in pull request #19424: [FLINK-22732][table] Restrict ALTER TABLE from setting empty table op…

2022-04-15 Thread GitBox
luoyuxia commented on code in PR #19424: URL: https://github.com/apache/flink/pull/19424#discussion_r851182447 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/SqlToOperationConverter.java: ## @@ -547,6 +547,12 @@ private Operation

[jira] [Updated] (FLINK-27237) Partitioned table statement enhancement

2022-04-15 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-27237: -- Description: This is an umbrella issue which is used to track the syntax enhancement about

[jira] [Comment Edited] (FLINK-27237) Partitioned table statement enhancement

2022-04-15 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522755#comment-17522755 ] dalongliu edited comment on FLINK-27237 at 4/15/22 9:31 AM: We have

[jira] [Comment Edited] (FLINK-27237) Partitioned table statement enhancement

2022-04-15 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522755#comment-17522755 ] dalongliu edited comment on FLINK-27237 at 4/15/22 9:30 AM: We have

[jira] [Commented] (FLINK-27261) Disable web.cancel.enable for session jobs

2022-04-15 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522757#comment-17522757 ] Yang Wang commented on FLINK-27261: --- Hmm. I mean to disable for all the session jobs, not a per job

[jira] [Commented] (FLINK-27237) Partitioned table statement enhancement

2022-04-15 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522755#comment-17522755 ] dalongliu commented on FLINK-27237: --- We have discussed and voted this ticket in

[jira] [Comment Edited] (FLINK-27237) Partitioned table statement enhancement

2022-04-15 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522755#comment-17522755 ] dalongliu edited comment on FLINK-27237 at 4/15/22 9:29 AM: We have

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #165: [FLINK-26140] Support rollback strategies

2022-04-15 Thread GitBox
gyfora commented on PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#issuecomment-102022 @wangyang0918 thanks, I will work on fixing this and covering with tests. Also I have a few follow up Jiras in mind including the sessionjob support I am traveling

[GitHub] [flink] wuchong merged pull request #19483: [hotfix][docs-zh] Fix "Google Cloud PubSub" Chinese page under "DataStream Connectors"

2022-04-15 Thread GitBox
wuchong merged PR #19483: URL: https://github.com/apache/flink/pull/19483 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-27261) Disable web.cancel.enable for session jobs

2022-04-15 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522753#comment-17522753 ] Gyula Fora commented on FLINK-27261: I don’t think we can do this on a per job level and session

[GitHub] [flink] snailHumming commented on pull request #19488: [FLINK-25716][docs-zh] Apply CR changes

2022-04-15 Thread GitBox
snailHumming commented on PR #19488: URL: https://github.com/apache/flink/pull/19488#issuecomment-1099983403 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

  1   2   >