[jira] [Commented] (FLINK-26473) Observer should support JobManager deployment crashed or deleted externally

2022-03-03 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17501207#comment-17501207 ] Gyula Fora commented on FLINK-26473: I think this is related to

[GitHub] [flink] flinkbot edited a comment on pull request #18976: [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18976: URL: https://github.com/apache/flink/pull/18976#issuecomment-1058916391 ## CI report: * 9f3c4d1ba885027bc2c6a4f19da76f78dd16d97a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18975: [FLINK-26474][hive] fix the issue of failing to call some hive udf re…

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18975: URL: https://github.com/apache/flink/pull/18975#issuecomment-1058886429 ## CI report: * 1580c5b496be40ca3d7a0f7814c043d314247931 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18955: [FLINK-26440] CompactorOperatorStateHandler can not work with unaligned checkpoint.

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18955: URL: https://github.com/apache/flink/pull/18955#issuecomment-1056126485 ## CI report: * 19fcc0e5728e9dd843c77f3f81c83e79d32cc84d Azure:

[jira] [Created] (FLINK-26487) Upgrade to Operator SDK 2.2.0 and replace custom informereventsource logic

2022-03-03 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-26487: -- Summary: Upgrade to Operator SDK 2.2.0 and replace custom informereventsource logic Key: FLINK-26487 URL: https://issues.apache.org/jira/browse/FLINK-26487 Project:

[GitHub] [flink] flinkbot edited a comment on pull request #18931: [FLINK-26396][state/changelog] Fail upload if last attempt times out

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18931: URL: https://github.com/apache/flink/pull/18931#issuecomment-1054455643 ## CI report: * 9f3c4d1ba885027bc2c6a4f19da76f78dd16d97a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18976: [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18976: URL: https://github.com/apache/flink/pull/18976#issuecomment-1058916391 ## CI report: * 9f3c4d1ba885027bc2c6a4f19da76f78dd16d97a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18975: [FLINK-26474][hive] fix the issue of failing to call some hive udf re…

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18975: URL: https://github.com/apache/flink/pull/18975#issuecomment-1058886429 ## CI report: * 1580c5b496be40ca3d7a0f7814c043d314247931 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18931: [FLINK-26396][state/changelog] Fail upload if last attempt times out

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18931: URL: https://github.com/apache/flink/pull/18931#issuecomment-1054455643 ## CI report: * 9f3c4d1ba885027bc2c6a4f19da76f78dd16d97a Azure:

[GitHub] [flink] Myasuka commented on a change in pull request #18931: [FLINK-26396][state/changelog] Fail upload if last attempt times out

2022-03-03 Thread GitBox
Myasuka commented on a change in pull request #18931: URL: https://github.com/apache/flink/pull/18931#discussion_r819336603 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/RetryingExecutor.java ## @@ -172,16 +225,19 @@ private RetriableTask

[jira] [Updated] (FLINK-26485) [Changelog] State not discarded after multiple retries

2022-03-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26485: --- Labels: pull-request-available (was: ) > [Changelog] State not discarded after multiple

[jira] [Closed] (FLINK-25631) Support enhanced `show tables` statement

2022-03-03 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-25631. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: 8d9489d7b34676a7dcdd86bb9ae54343b2a978b4 >

[GitHub] [flink] flinkbot commented on pull request #18976: [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

2022-03-03 Thread GitBox
flinkbot commented on pull request #18976: URL: https://github.com/apache/flink/pull/18976#issuecomment-1058916391 ## CI report: * 9f3c4d1ba885027bc2c6a4f19da76f78dd16d97a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] wuchong merged pull request #18361: [FLINK-25631][table] Support enhanced `show tables` syntax

2022-03-03 Thread GitBox
wuchong merged pull request #18361: URL: https://github.com/apache/flink/pull/18361 -- 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] flinkbot edited a comment on pull request #18975: [FLINK-26474][hive] fix the issue of failing to call some hive udf re…

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18975: URL: https://github.com/apache/flink/pull/18975#issuecomment-1058886429 ## CI report: * 1580c5b496be40ca3d7a0f7814c043d314247931 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18931: [FLINK-26396][state/changelog] Fail upload if last attempt times out

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18931: URL: https://github.com/apache/flink/pull/18931#issuecomment-1054455643 ## CI report: * 9f3c4d1ba885027bc2c6a4f19da76f78dd16d97a Azure:

[jira] [Closed] (FLINK-26436) SharedIndexInformer should respect watched namespaces

2022-03-03 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-26436. -- Resolution: Fixed merged: d7f9482a6a64c4c936a716011f2087bbe148edfd > SharedIndexInformer should

[jira] [Created] (FLINK-26485) [Changelog] State not discarded after multiple retries

2022-03-03 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-26485: - Summary: [Changelog] State not discarded after multiple retries Key: FLINK-26485 URL: https://issues.apache.org/jira/browse/FLINK-26485 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #18975: [FLINK-26474][hive] fix the issue of failing to call some hive udf re…

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18975: URL: https://github.com/apache/flink/pull/18975#issuecomment-1058886429 ## CI report: * 1580c5b496be40ca3d7a0f7814c043d314247931 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18966: [FLINK-26422][docs-zh][table]update chinese doc with the new TablePipeline docs

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18966: URL: https://github.com/apache/flink/pull/18966#issuecomment-1057770962 ## CI report: * f78050affc49e419250112c763c4aac5fd888478 Azure:

[GitHub] [flink] Vancior commented on a change in pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-03 Thread GitBox
Vancior commented on a change in pull request #18957: URL: https://github.com/apache/flink/pull/18957#discussion_r819330802 ## File path: flink-python/pyflink/fn_execution/datastream/window/window_assigner.py ## @@ -0,0 +1,376 @@ +import math +from typing import Iterable,

[jira] [Created] (FLINK-26486) The operator restart ingress is lost

2022-03-03 Thread leinenglian (Jira)
leinenglian created FLINK-26486: --- Summary: The operator restart ingress is lost Key: FLINK-26486 URL: https://issues.apache.org/jira/browse/FLINK-26486 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #18975: [FLINK-26474][hive] fix the issue of failing to call some hive udf re…

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18975: URL: https://github.com/apache/flink/pull/18975#issuecomment-1058886429 ## CI report: * 1580c5b496be40ca3d7a0f7814c043d314247931 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18966: [FLINK-26422][docs-zh][table]update chinese doc with the new TablePipeline docs

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18966: URL: https://github.com/apache/flink/pull/18966#issuecomment-1057770962 ## CI report: * f78050affc49e419250112c763c4aac5fd888478 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18361: [FLINK-25631][table] Support enhanced `show tables` syntax

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18361: URL: https://github.com/apache/flink/pull/18361#issuecomment-1012985152 ## CI report: * 2cc11dc827e18da7442ba18dfd1daa427d6bcf4e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18975: [FLINK-26474][hive] fix the issue of failing to call some hive udf re…

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18975: URL: https://github.com/apache/flink/pull/18975#issuecomment-1058886429 ## CI report: * 1580c5b496be40ca3d7a0f7814c043d314247931 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18966: [FLINK-26422][docs-zh][table]update chinese doc with the new TablePipeline docs

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18966: URL: https://github.com/apache/flink/pull/18966#issuecomment-1057770962 ## CI report: * f78050affc49e419250112c763c4aac5fd888478 Azure:

[jira] [Commented] (FLINK-26473) Observer should support JobManager deployment crashed or deleted externally

2022-03-03 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17501194#comment-17501194 ] Yang Wang commented on FLINK-26473: --- In the current implementation of {{{}Observer{}}}, when the

[GitHub] [flink] flinkbot edited a comment on pull request #18975: [FLINK-26474][hive] fix the issue of failing to call some hive udf re…

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18975: URL: https://github.com/apache/flink/pull/18975#issuecomment-1058886429 ## CI report: * 1580c5b496be40ca3d7a0f7814c043d314247931 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18966: [FLINK-26422][docs-zh][table]update chinese doc with the new TablePipeline docs

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18966: URL: https://github.com/apache/flink/pull/18966#issuecomment-1057770962 ## CI report: * f78050affc49e419250112c763c4aac5fd888478 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18975: [FLINK-26474][hive] fix the issue of failing to call some hive udf re…

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18975: URL: https://github.com/apache/flink/pull/18975#issuecomment-1058886429 ## CI report: * 1580c5b496be40ca3d7a0f7814c043d314247931 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18966: [FLINK-26422][docs-zh][table]update chinese doc with the new TablePipeline docs

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18966: URL: https://github.com/apache/flink/pull/18966#issuecomment-1057770962 ## CI report: * f78050affc49e419250112c763c4aac5fd888478 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18966: [FLINK-26422][docs-zh][table]update chinese doc with the new TablePipeline docs

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18966: URL: https://github.com/apache/flink/pull/18966#issuecomment-1057770962 ## CI report: * 3968c560b0057d50f6f5ab312320f3453915d015 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18975: [FLINK-26474][hive] fix the issue of failing to call some hive udf re…

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18975: URL: https://github.com/apache/flink/pull/18975#issuecomment-1058886429 ## CI report: * 1580c5b496be40ca3d7a0f7814c043d314247931 Azure:

[jira] [Updated] (FLINK-26476) Introduce flink-kubernetes-shaded to avoid overlapping classes

2022-03-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26476: --- Labels: pull-request-available (was: ) > Introduce flink-kubernetes-shaded to avoid

[GitHub] [flink] leonardBang commented on pull request #18966: [FLINK-26422][docs-zh][table]update chinese doc with the new TablePipeline docs

2022-03-03 Thread GitBox
leonardBang commented on pull request #18966: URL: https://github.com/apache/flink/pull/18966#issuecomment-1058897608 > @leonardBang done. cool, let's wait the CI passed -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] zoucao commented on pull request #18966: [FLINK-26422][docs-zh][table]update chinese doc with the new TablePipeline docs

2022-03-03 Thread GitBox
zoucao commented on pull request #18966: URL: https://github.com/apache/flink/pull/18966#issuecomment-1058897323 @leonardBang done. -- 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

[GitHub] [flink] XComp commented on pull request #18963: [FLINK-26450][fs] Adds error handling to FileStateHandle.discardState

2022-03-03 Thread GitBox
XComp commented on pull request #18963: URL: https://github.com/apache/flink/pull/18963#issuecomment-1058893234 I noticed the `FileSystem.delete` inconsistency also makes problems for the BlobServer cleanup (FLINK-26484). I guess, we need to fix it in the `FileSystem` rather than the

[GitHub] [flink] RocMarshal removed a comment on pull request #18928: [FLINK-25545][flink-clients][JUnit5 Migration] Module: flink-clients.

2022-03-03 Thread GitBox
RocMarshal removed a comment on pull request #18928: URL: https://github.com/apache/flink/pull/18928#issuecomment-1055029965 @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

[GitHub] [flink] flinkbot edited a comment on pull request #18975: [FLINK-26474][hive] fix the issue of failing to call some hive udf re…

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18975: URL: https://github.com/apache/flink/pull/18975#issuecomment-1058886429 ## CI report: * 1580c5b496be40ca3d7a0f7814c043d314247931 Azure:

[GitHub] [flink] SteNicholas commented on a change in pull request #18933: [FLINK-26368] [kafka] Add setProperty method to KafkaSinkBuilder

2022-03-03 Thread GitBox
SteNicholas commented on a change in pull request #18933: URL: https://github.com/apache/flink/pull/18933#discussion_r819308955 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSinkBuilder.java ## @@ -61,16 +62,30

[GitHub] [flink] flinkbot commented on pull request #18975: [FLINK-26474][hive] fix the issue of failing to call some hive udf re…

2022-03-03 Thread GitBox
flinkbot commented on pull request #18975: URL: https://github.com/apache/flink/pull/18975#issuecomment-1058886429 ## CI report: * 1580c5b496be40ca3d7a0f7814c043d314247931 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-26334) When timestamp - offset + windowSize < 0, elements cannot be assigned to the correct window

2022-03-03 Thread realdengziqi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] realdengziqi updated FLINK-26334: - Description: h2. issue         Hello!         When we were studying the flink source code, we

[jira] [Updated] (FLINK-26474) Fail to call hive udf when secondary parameter required constant but pass value like "-1"

2022-03-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26474: --- Labels: pull-request-available (was: ) > Fail to call hive udf when secondary parameter

[GitHub] [flink] luoyuxia opened a new pull request #18975: [FLINK-26474][hive] fix the issue of failing to call some hive udf re…

2022-03-03 Thread GitBox
luoyuxia opened a new pull request #18975: URL: https://github.com/apache/flink/pull/18975 …quired constant parameters with implicit constant passed. ## What is the purpose of the change The change is to enable ExprNode folding and to fold UDFOPNegative. It's mainly

[jira] [Comment Edited] (FLINK-26473) Observer should support JobManager deployment crashed or deleted externally

2022-03-03 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17501185#comment-17501185 ] Nicholas Jiang edited comment on FLINK-26473 at 3/4/22, 6:48 AM: -

[jira] [Updated] (FLINK-26334) When timestamp - offset + windowSize < 0, elements cannot be assigned to the correct window

2022-03-03 Thread realdengziqi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] realdengziqi updated FLINK-26334: - Description: h2. issue         Hello!         When we were studying the flink source code, we

[jira] [Commented] (FLINK-26473) Observer should support JobManager deployment crashed or deleted externally

2022-03-03 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17501185#comment-17501185 ] Nicholas Jiang commented on FLINK-26473: [~wangyang0918], do you mean that the observer should

[jira] [Created] (FLINK-26484) BlobServer cleanup does not work for the presto filesystem

2022-03-03 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-26484: - Summary: BlobServer cleanup does not work for the presto filesystem Key: FLINK-26484 URL: https://issues.apache.org/jira/browse/FLINK-26484 Project: Flink

[jira] [Commented] (FLINK-26461) Throw CannotPlanException in TableFunction

2022-03-03 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17501182#comment-17501182 ] lincoln lee commented on FLINK-26461: - Another attempt case also running ok: {code} /** test. */

[jira] [Created] (FLINK-26483) Support WindowedStream.aggregate in Python DataStream API

2022-03-03 Thread Dian Fu (Jira)
Dian Fu created FLINK-26483: --- Summary: Support WindowedStream.aggregate in Python DataStream API Key: FLINK-26483 URL: https://issues.apache.org/jira/browse/FLINK-26483 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #18966: [FLINK-26422][docs-zh][table]update chinese doc with the new TablePipeline docs

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18966: URL: https://github.com/apache/flink/pull/18966#issuecomment-1057770962 ## CI report: * 3968c560b0057d50f6f5ab312320f3453915d015 Azure:

[jira] [Commented] (FLINK-24372) Deprecate Elasticsearch Sinkfunctions

2022-03-03 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17501177#comment-17501177 ] Yangze Guo commented on FLINK-24372: Hi, [~fpaul]. Would you please help me to understand why do we

[jira] [Created] (FLINK-26482) Support WindowedStream.reduce in Python DataStream API

2022-03-03 Thread Dian Fu (Jira)
Dian Fu created FLINK-26482: --- Summary: Support WindowedStream.reduce in Python DataStream API Key: FLINK-26482 URL: https://issues.apache.org/jira/browse/FLINK-26482 Project: Flink Issue Type:

[jira] [Created] (FLINK-26481) Support side output for windowing in Python DataStream API

2022-03-03 Thread Dian Fu (Jira)
Dian Fu created FLINK-26481: --- Summary: Support side output for windowing in Python DataStream API Key: FLINK-26481 URL: https://issues.apache.org/jira/browse/FLINK-26481 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #18966: [FLINK-26422][docs-zh][table]update chinese doc with the new TablePipeline docs

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18966: URL: https://github.com/apache/flink/pull/18966#issuecomment-1057770962 ## CI report: * 3968c560b0057d50f6f5ab312320f3453915d015 Azure:

[GitHub] [flink] zoucao commented on pull request #18966: [FLINK-26422][docs-zh][table]update chinese doc with the new TablePipeline docs

2022-03-03 Thread GitBox
zoucao commented on pull request #18966: URL: https://github.com/apache/flink/pull/18966#issuecomment-1058874277 Hi, @leonardBang , thanks for your time, I have updated the pr following your advice. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #18966: [FLINK-26422][docs-zh][table]update chinese doc with the new TablePipeline docs

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18966: URL: https://github.com/apache/flink/pull/18966#issuecomment-1057770962 ## CI report: * 3968c560b0057d50f6f5ab312320f3453915d015 Azure:

[jira] (FLINK-22315) Support ADD column/constraint/watermark for ALTER TABLE statement

2022-03-03 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22315 ] RocMarshal deleted comment on FLINK-22315: was (Author: rocmarshal): Changes in other SQL syntax can  cause easily conflicts between the current PR and the master branch, so it would be

[jira] [Created] (FLINK-26480) Support window_all in Python DataStream API

2022-03-03 Thread Dian Fu (Jira)
Dian Fu created FLINK-26480: --- Summary: Support window_all in Python DataStream API Key: FLINK-26480 URL: https://issues.apache.org/jira/browse/FLINK-26480 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-26461) Throw CannotPlanException in TableFunction

2022-03-03 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17501174#comment-17501174 ] lincoln lee commented on FLINK-26461: - Hi [~SpongebobZ], I cann't reproduce the exception above

[jira] [Updated] (FLINK-26479) Update the documentation of KeyedStream.window adding a few examples on how to create count window and time window in Python DataStream API

2022-03-03 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-26479: Component/s: Documentation > Update the documentation of KeyedStream.window adding a few examples on how

[jira] [Updated] (FLINK-26479) Update the documentation of KeyedStream.window adding a few examples on how to create count window and time window in Python DataStream API

2022-03-03 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-26479: Description: A few handy WindowAssigners have been added in FLINK-26444 and it would be great to add few

[jira] [Updated] (FLINK-26479) Update the documentation of KeyedStream.window adding a few examples on how to create count window and time window in Python DataStream API

2022-03-03 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-26479: Description: A few handy WindowAssigners have been added in FLINK-26444 and it would be great to add few

[jira] [Updated] (FLINK-26479) Update the documentation of KeyedStream.window adding a few examples on how to create count window and time window in Python DataStream API

2022-03-03 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-26479: Summary: Update the documentation of KeyedStream.window adding a few examples on how to create count

[jira] [Created] (FLINK-26479) Add time_window and count_window in KeyedStream in Python DataStream API

2022-03-03 Thread Dian Fu (Jira)
Dian Fu created FLINK-26479: --- Summary: Add time_window and count_window in KeyedStream in Python DataStream API Key: FLINK-26479 URL: https://issues.apache.org/jira/browse/FLINK-26479 Project: Flink

[jira] [Created] (FLINK-26478) Support evictor in Python DataStream API

2022-03-03 Thread Dian Fu (Jira)
Dian Fu created FLINK-26478: --- Summary: Support evictor in Python DataStream API Key: FLINK-26478 URL: https://issues.apache.org/jira/browse/FLINK-26478 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-26444) Add a few commonly used window assigners in PyFlink DataStream API

2022-03-03 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-26444: Summary: Add a few commonly used window assigners in PyFlink DataStream API (was: Window allocator

[jira] [Created] (FLINK-26477) Finalize the window support in Python DataStream API

2022-03-03 Thread Dian Fu (Jira)
Dian Fu created FLINK-26477: --- Summary: Finalize the window support in Python DataStream API Key: FLINK-26477 URL: https://issues.apache.org/jira/browse/FLINK-26477 Project: Flink Issue Type:

[jira] [Updated] (FLINK-26444) Window allocator supporting pyflink datastream API

2022-03-03 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-26444: Parent: FLINK-26477 Issue Type: Sub-task (was: New Feature) > Window allocator supporting

[jira] [Commented] (FLINK-26330) Test Adaptive Batch Scheduler manually

2022-03-03 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17501166#comment-17501166 ] Lijie Wang commented on FLINK-26330: Thanks for your efforts and feedback, [~nsemmler]   ->

[GitHub] [flink] flinkbot edited a comment on pull request #18963: [FLINK-26450][fs] Adds error handling to FileStateHandle.discardState

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18963: URL: https://github.com/apache/flink/pull/18963#issuecomment-1057183349 ## CI report: * 1d5701800b54f5d948576e41dec7396edb018acd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18963: [FLINK-26450][fs] Adds error handling to FileStateHandle.discardState

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18963: URL: https://github.com/apache/flink/pull/18963#issuecomment-1057183349 ## CI report: * 1d5701800b54f5d948576e41dec7396edb018acd Azure:

[GitHub] [flink-ml] mumuhhh commented on pull request #68: [FLINK-26404] support non-local file systems

2022-03-03 Thread GitBox
mumuhhh commented on pull request #68: URL: https://github.com/apache/flink-ml/pull/68#issuecomment-1058839818 > Hi @mumuhhh , Thanks for contributing to Flink ML. Could you please add more description about the motivation and the implementation principles for this PR? It would be even

[GitHub] [flink] flinkbot edited a comment on pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18224: URL: https://github.com/apache/flink/pull/18224#issuecomment-1002391830 ## CI report: * 595dbcb06a0d8eed4f7d7253809f4530c7f139f1 Azure:

[GitHub] [flink] masteryhx commented on a change in pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

2022-03-03 Thread GitBox
masteryhx commented on a change in pull request #18224: URL: https://github.com/apache/flink/pull/18224#discussion_r819269474 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogPeriodicMaterializationRescaleITCase.java ## @@ -0,0 +1,142 @@

[GitHub] [flink] flinkbot edited a comment on pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18224: URL: https://github.com/apache/flink/pull/18224#issuecomment-1002391830 ## CI report: * 595dbcb06a0d8eed4f7d7253809f4530c7f139f1 Azure:

[jira] [Commented] (FLINK-26471) Deleting the operator while jobs are running causes the jobs to fail

2022-03-03 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17501157#comment-17501157 ] Yang Wang commented on FLINK-26471: --- This is also a reason why I propose to separate the RBAC for

[jira] [Created] (FLINK-26476) Introduce flink-kubernetes-shaded to avoid overlapping classes

2022-03-03 Thread Yang Wang (Jira)
Yang Wang created FLINK-26476: - Summary: Introduce flink-kubernetes-shaded to avoid overlapping classes Key: FLINK-26476 URL: https://issues.apache.org/jira/browse/FLINK-26476 Project: Flink

[jira] [Assigned] (FLINK-26476) Introduce flink-kubernetes-shaded to avoid overlapping classes

2022-03-03 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-26476: - Assignee: Yang Wang > Introduce flink-kubernetes-shaded to avoid overlapping classes >

[GitHub] [flink] flinkbot edited a comment on pull request #18974: Flink 26028 sink documentation 2

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18974: URL: https://github.com/apache/flink/pull/18974#issuecomment-1058728223 ## CI report: * 021fb4c55be715f53ca03fbed6750be85a9913dc Azure:

[GitHub] [flink] leonardBang commented on a change in pull request #18966: [FLINK-26422][docs-zh][table]update chinese doc with the new TablePipeline docs

2022-03-03 Thread GitBox
leonardBang commented on a change in pull request #18966: URL: https://github.com/apache/flink/pull/18966#discussion_r819257593 ## File path: docs/content.zh/docs/dev/table/common.md ## @@ -645,7 +645,10 @@ Table API 和 SQL 查询的混用非常简单因为它们都返回 `Table` 对 请参考文档 [Table Sources &

[jira] [Created] (FLINK-26475) FileStoreScan supports delta consuming

2022-03-03 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-26475: Summary: FileStoreScan supports delta consuming Key: FLINK-26475 URL: https://issues.apache.org/jira/browse/FLINK-26475 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-26474) Fail to call hive udf when secondary parameter required constant but pass value like "-1"

2022-03-03 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26474: - Description: The exception can be reproduced using following code in HiveDialectITCase {code:java}

[GitHub] [flink] wuchong commented on pull request #18966: [FLINK-26422][docs-zh][table]update chinese doc with the new TablePipeline docs

2022-03-03 Thread GitBox
wuchong commented on pull request #18966: URL: https://github.com/apache/flink/pull/18966#issuecomment-1058803806 @RocMarshal , could you help to review this? -- 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-26334) When timestamp - offset + windowSize < 0, elements cannot be assigned to the correct window

2022-03-03 Thread realdengziqi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17501135#comment-17501135 ] realdengziqi commented on FLINK-26334: -- [~martijnvisser] Thanks for your attention, I've updated

[jira] [Updated] (FLINK-26334) When timestamp - offset + windowSize < 0, elements cannot be assigned to the correct window

2022-03-03 Thread realdengziqi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] realdengziqi updated FLINK-26334: - Release Note: I want work on this (was: If it's really a bug, we'd love to fix it

[jira] [Commented] (FLINK-26474) Fail to call hive udf when secondary parameter required constant but pass value like "-1"

2022-03-03 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17501130#comment-17501130 ] luoyuxia commented on FLINK-26474: -- I would like to fix it. > Fail to call hive udf when secondary

[jira] [Updated] (FLINK-26334) When timestamp - offset + windowSize < 0, elements cannot be assigned to the correct window

2022-03-03 Thread realdengziqi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] realdengziqi updated FLINK-26334: - Description: h2. issue         Hello!         When we were studying the flink source code, we

[jira] [Updated] (FLINK-26474) Fail to call hive udf when secondary parameter required constant but pass value like "-1"

2022-03-03 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26474: - Component/s: Connectors / Hive Fix Version/s: 1.16.0 Description: The exception can be

[jira] [Updated] (FLINK-26334) When timestamp - offset + windowSize < 0, elements cannot be assigned to the correct window

2022-03-03 Thread realdengziqi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] realdengziqi updated FLINK-26334: - Attachment: image-2022-03-04-11-37-10-035.png > When timestamp - offset + windowSize < 0,

[GitHub] [flink] flinkbot edited a comment on pull request #18955: [FLINK-26440] CompactorOperatorStateHandler can not work with unaligned checkpoint.

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18955: URL: https://github.com/apache/flink/pull/18955#issuecomment-1056126485 ## CI report: * 3399dc27d3ecf631828c90da6c99ecdbf4b5978c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18955: [FLINK-26440] CompactorOperatorStateHandler can not work with unaligned checkpoint.

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18955: URL: https://github.com/apache/flink/pull/18955#issuecomment-1056126485 ## CI report: * 3399dc27d3ecf631828c90da6c99ecdbf4b5978c Azure:

[jira] [Created] (FLINK-26474) Fail to call hive udf when secondary parameter required constant but pass value like "-1"

2022-03-03 Thread luoyuxia (Jira)
luoyuxia created FLINK-26474: Summary: Fail to call hive udf when secondary parameter required constant but pass value like "-1" Key: FLINK-26474 URL: https://issues.apache.org/jira/browse/FLINK-26474

[jira] [Updated] (FLINK-26334) When timestamp - offset + windowSize < 0, elements cannot be assigned to the correct window

2022-03-03 Thread realdengziqi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] realdengziqi updated FLINK-26334: - Attachment: image-2022-03-04-11-28-26-616.png Description: h2. issue         Hello!      

[jira] [Created] (FLINK-26473) Observer should support JobManager deployment crashed or deleted externally

2022-03-03 Thread Yang Wang (Jira)
Yang Wang created FLINK-26473: - Summary: Observer should support JobManager deployment crashed or deleted externally Key: FLINK-26473 URL: https://issues.apache.org/jira/browse/FLINK-26473 Project: Flink

[jira] [Updated] (FLINK-26473) Observer should support JobManager deployment crashed or deleted externally

2022-03-03 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-26473: -- Component/s: Kubernetes Operator > Observer should support JobManager deployment crashed or deleted

[GitHub] [flink] flinkbot edited a comment on pull request #18361: [FLINK-25631][table] Support enhanced `show tables` syntax

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18361: URL: https://github.com/apache/flink/pull/18361#issuecomment-1012985152 ## CI report: * Unknown: [CANCELED](TBD) * 2cc11dc827e18da7442ba18dfd1daa427d6bcf4e Azure:

[jira] [Commented] (FLINK-26370) Make Flink cluster communication asynchronous

2022-03-03 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17501126#comment-17501126 ] Yang Wang commented on FLINK-26370: --- I am thinking do we really need to get the job status for every

[GitHub] [flink] flinkbot edited a comment on pull request #18361: [FLINK-25631][table] Support enhanced `show tables` syntax

2022-03-03 Thread GitBox
flinkbot edited a comment on pull request #18361: URL: https://github.com/apache/flink/pull/18361#issuecomment-1012985152 ## CI report: * Unknown: [CANCELED](TBD) * 2cc11dc827e18da7442ba18dfd1daa427d6bcf4e UNKNOWN Bot commands The @flinkbot bot supports the

  1   2   3   4   5   >