[jira] [Comment Edited] (FLINK-19940) Task names on web UI should change when an operator chain is chained with sources

2020-11-19 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235968#comment-17235968 ] Caizhi Weng edited comment on FLINK-19940 at 11/20/20, 7:58 AM: --

[GitHub] [flink] flinkbot edited a comment on pull request #8532: [FLINK-12541][REST] Support to submit Python Table API jobs via REST API

2020-11-19 Thread GitBox
flinkbot edited a comment on pull request #8532: URL: https://github.com/apache/flink/pull/8532#issuecomment-730962739 ## CI report: * d24c4f7af0dbf8890d87f040a932121ef9e8d869 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/202984747) Bot commands

[jira] [Comment Edited] (FLINK-19940) Task names on web UI should change when an operator chain is chained with sources

2020-11-19 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235968#comment-17235968 ] Caizhi Weng edited comment on FLINK-19940 at 11/20/20, 7:57 AM: --

[jira] [Comment Edited] (FLINK-19940) Task names on web UI should change when an operator chain is chained with sources

2020-11-19 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235968#comment-17235968 ] Caizhi Weng edited comment on FLINK-19940 at 11/20/20, 7:54 AM: --

[jira] [Comment Edited] (FLINK-19940) Task names on web UI should change when an operator chain is chained with sources

2020-11-19 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235968#comment-17235968 ] Caizhi Weng edited comment on FLINK-19940 at 11/20/20, 7:54 AM: --

[jira] [Commented] (FLINK-19940) Task names on web UI should change when an operator chain is chained with sources

2020-11-19 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235968#comment-17235968 ] Caizhi Weng commented on FLINK-19940: - [~roman_khachatryan] It's not truncated. It's

[jira] [Comment Edited] (FLINK-19940) Task names on web UI should change when an operator chain is chained with sources

2020-11-19 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235968#comment-17235968 ] Caizhi Weng edited comment on FLINK-19940 at 11/20/20, 7:53 AM: --

[GitHub] [flink] rkhachatryan commented on a change in pull request #14139: [FLINK-20247][config] Hide unused unaligned checkpoint configuration options

2020-11-19 Thread GitBox
rkhachatryan commented on a change in pull request #14139: URL: https://github.com/apache/flink/pull/14139#discussion_r527497144 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/ExecutionCheckpointingOptions.java ## @@ -162,10 +162,11

[GitHub] [flink] flinkbot edited a comment on pull request #14141: [FLINK-20145][checkpointing] Fix priority event handling.

2020-11-19 Thread GitBox
flinkbot edited a comment on pull request #14141: URL: https://github.com/apache/flink/pull/14141#issuecomment-730461048 ## CI report: * 0126e8f9cb660e5205c32e080fbe8c20481fc476 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14139: [FLINK-20247][config] Hide unused unaligned checkpoint configuration options

2020-11-19 Thread GitBox
flinkbot edited a comment on pull request #14139: URL: https://github.com/apache/flink/pull/14139#issuecomment-730377256 ## CI report: * e7f30f23c854949e8af6b0465631ee214839597a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14111: [FLINK-20191][document] Add documents for FLIP-95 ability interfaces

2020-11-19 Thread GitBox
flinkbot edited a comment on pull request #14111: URL: https://github.com/apache/flink/pull/14111#issuecomment-729488072 ## CI report: * ec3b7418bcca38b4b60ad5491a8f802244b6227a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14150: [FLINK-18452][table-runtime-blink] Fix StateMigrationException because RetractableTopNFunction#ComparatorWrapper might be incompatible

2020-11-19 Thread GitBox
flinkbot commented on pull request #14150: URL: https://github.com/apache/flink/pull/14150#issuecomment-730968094 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 pro

[GitHub] [flink] wuchong commented on pull request #14150: [FLINK-18452][table-runtime-blink] Fix StateMigrationException because RetractableTopNFunction#ComparatorWrapper might be incompatible

2020-11-19 Thread GitBox
wuchong commented on pull request #14150: URL: https://github.com/apache/flink/pull/14150#issuecomment-730965603 @leonardBang , could you help to review this? This is an automated message from the Apache Git Service. To respo

[jira] [Updated] (FLINK-18452) Flaws in RetractableTopNFunction.ComparatorWrapper#equals method prevent state access after restoration

2020-11-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18452: --- Labels: pull-request-available (was: ) > Flaws in RetractableTopNFunction.ComparatorWrapper

[GitHub] [flink] wuchong opened a new pull request #14150: [FLINK-18452][table-runtime-blink] Fix StateMigrationException because RetractableTopNFunction#ComparatorWrapper might be incompatible

2020-11-19 Thread GitBox
wuchong opened a new pull request #14150: URL: https://github.com/apache/flink/pull/14150 ## What is the purpose of the change TopN query may throw StateMigrationException because the `RetractableTopNFunction#ComparatorWrapper` in serializer might be incompatible. Th

[GitHub] [flink] flinkbot commented on pull request #8532: [FLINK-12541][REST] Support to submit Python Table API jobs via REST API

2020-11-19 Thread GitBox
flinkbot commented on pull request #8532: URL: https://github.com/apache/flink/pull/8532#issuecomment-730962739 ## CI report: * d24c4f7af0dbf8890d87f040a932121ef9e8d869 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run

[jira] [Commented] (FLINK-20221) DelimitedInputFormat does not restore compressed filesplits correctly leading to dataloss

2020-11-19 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235955#comment-17235955 ] Robert Metzger commented on FLINK-20221: [~gyfora] What's the plan with merging

[jira] [Closed] (FLINK-17096) Mini-batch group aggregation doesn't expire state even if state ttl is enabled

2020-11-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17096. --- Resolution: Fixed Fixed in master (1.12.0): - d84ad5e585c6573635a388de4a5602fe4229fa06 - df8de4ac45884bd3

[GitHub] [flink] wuchong closed pull request #11830: [FLINK-17096] [table] Mini-batch group aggregation doesn't expire state even if state ttl is enabled

2020-11-19 Thread GitBox
wuchong closed pull request #11830: URL: https://github.com/apache/flink/pull/11830 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] twalthr commented on pull request #14103: [FLINK-18545] Introduce `pipeline.name` to allow users to specify job name by configuration

2020-11-19 Thread GitBox
twalthr commented on pull request #14103: URL: https://github.com/apache/flink/pull/14103#issuecomment-730959217 I agree with @jark and @godfreyhe. The name is just used for logging and easier identification in UIs. The user can always change it before the next execution. ---

[GitHub] [flink] wuchong commented on pull request #11830: [FLINK-17096] [table] Mini-batch group aggregation doesn't expire state even if state ttl is enabled

2020-11-19 Thread GitBox
wuchong commented on pull request #11830: URL: https://github.com/apache/flink/pull/11830#issuecomment-730959172 Build is passed: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=9847&view=results This

[GitHub] [flink] flinkbot edited a comment on pull request #14149: [FLINK-20035][tests] Fix wrong config key in JobGraphRunningUtil

2020-11-19 Thread GitBox
flinkbot edited a comment on pull request #14149: URL: https://github.com/apache/flink/pull/14149#issuecomment-730947533 ## CI report: * c090c7ec80bef6783cdd667b0d15d1f0b5fd9b57 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-12541) Add deploy a Python Flink job and session cluster on Kubernetes support.

2020-11-19 Thread Eui Heo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235951#comment-17235951 ] Eui Heo commented on FLINK-12541: - How is it going? I want to submit a python job inside

[jira] [Updated] (FLINK-18983) Job doesn't changed to failed if close function has blocked

2020-11-19 Thread YufeiLiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YufeiLiu updated FLINK-18983: - Description: If a operator throw a exception, it will break process loop and dispose all operator. But

[jira] [Comment Edited] (FLINK-20118) Test New File Source API - Continuous Streaming Execution

2020-11-19 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235406#comment-17235406 ] Andrey Zagrebin edited comment on FLINK-20118 at 11/20/20, 7:20 AM: --

[GitHub] [flink] godfreyhe commented on pull request #14103: [FLINK-18545] Introduce `pipeline.name` to allow users to specify job name by configuration

2020-11-19 Thread GitBox
godfreyhe commented on pull request #14103: URL: https://github.com/apache/flink/pull/14103#issuecomment-730956823 @kl0u, different from job id, job name is not the key info of a StreamGraph, and `pipeline.name` is just used for overwriting the default job name. Just as @wuchong mentioned,

[GitHub] [flink] AHeise commented on a change in pull request #14139: [FLINK-20247][config] Hide unused unaligned checkpoint configuration options

2020-11-19 Thread GitBox
AHeise commented on a change in pull request #14139: URL: https://github.com/apache/flink/pull/14139#discussion_r527485088 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/ExecutionCheckpointingOptions.java ## @@ -162,10 +162,11 @@

[GitHub] [flink] elanv commented on pull request #8532: [FLINK-12541][REST] Support to submit Python Table API jobs via REST API

2020-11-19 Thread GitBox
elanv commented on pull request #8532: URL: https://github.com/apache/flink/pull/8532#issuecomment-730956677 How is it going? I want to submit a python job inside application, and it would be great if REST API supports it. T

[jira] [Resolved] (FLINK-20030) Barrier announcement causes outdated RemoteInputChannel#numBuffersOvertaken

2020-11-19 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-20030. - Resolution: Fixed > Barrier announcement causes outdated RemoteInputChannel#numBuffersOvertaken

[jira] [Commented] (FLINK-20030) Barrier announcement causes outdated RemoteInputChannel#numBuffersOvertaken

2020-11-19 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235948#comment-17235948 ] Arvid Heise commented on FLINK-20030: - Merged into master as a97fe1f3f24993ff8cce2dd

[jira] [Comment Edited] (FLINK-20118) Test New File Source API - Continuous Streaming Execution

2020-11-19 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235406#comment-17235406 ] Andrey Zagrebin edited comment on FLINK-20118 at 11/20/20, 7:15 AM: --

[GitHub] [flink] AHeise merged pull request #14052: [FLINK-20030][network] Rewrite RemoteInputChannel#getInflightBuffersUnsafe to use sequence numbers

2020-11-19 Thread GitBox
AHeise merged pull request #14052: URL: https://github.com/apache/flink/pull/14052 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 t

[jira] [Created] (FLINK-20255) Nested decorrelate failed

2020-11-19 Thread godfrey he (Jira)
godfrey he created FLINK-20255: -- Summary: Nested decorrelate failed Key: FLINK-20255 URL: https://issues.apache.org/jira/browse/FLINK-20255 Project: Flink Issue Type: Bug Components: T

[GitHub] [flink] wsry commented on pull request #14149: [FLINK-20035][tests] Fix wrong config key in JobGraphRunningUtil

2020-11-19 Thread GitBox
wsry commented on pull request #14149: URL: https://github.com/apache/flink/pull/14149#issuecomment-730947969 @rmetzger I used wrong config key in the fix of FLINK-20035, we should use RestOptions.BIND_PORT, but I used RestOptions.BIND_ADDRESS by mistake. Really sorry for that. I open this

[GitHub] [flink] flinkbot commented on pull request #14149: [FLINK-20035][tests] Fix wrong config key in JobGraphRunningUtil

2020-11-19 Thread GitBox
flinkbot commented on pull request #14149: URL: https://github.com/apache/flink/pull/14149#issuecomment-730947533 ## CI report: * c090c7ec80bef6783cdd667b0d15d1f0b5fd9b57 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #14148: [hotfix][javadocs] Fix typo in RichFunction

2020-11-19 Thread GitBox
flinkbot edited a comment on pull request #14148: URL: https://github.com/apache/flink/pull/14148#issuecomment-730904115 ## CI report: * 714c860e2d34e0a6f034dc360b342e59bdde46e1 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14149: [FLINK-20035][tests] Fix wrong config key in JobGraphRunningUtil

2020-11-19 Thread GitBox
flinkbot commented on pull request #14149: URL: https://github.com/apache/flink/pull/14149#issuecomment-730925448 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 pro

[GitHub] [flink] wsry opened a new pull request #14149: [FLINK-20035][tests] Fix wrong config key in JobGraphRunningUtil

2020-11-19 Thread GitBox
wsry opened a new pull request #14149: URL: https://github.com/apache/flink/pull/14149 ## What is the purpose of the change Fix wrong config key in JobGraphRunningUtil, we should use RestOptions.BIND_PORT instead of RestOptions.BIND_ADDRESS. ## Brief change log - Fix

[GitHub] [flink] flinkbot commented on pull request #14148: [hotfix][javadocs] Fix typo in RichFunction

2020-11-19 Thread GitBox
flinkbot commented on pull request #14148: URL: https://github.com/apache/flink/pull/14148#issuecomment-730904115 ## CI report: * 714c860e2d34e0a6f034dc360b342e59bdde46e1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #14129: [hotfix] Reduce logging verbosity from the Checkpoint-related REST handlers

2020-11-19 Thread GitBox
flinkbot edited a comment on pull request #14129: URL: https://github.com/apache/flink/pull/14129#issuecomment-730245586 ## CI report: * 8773590fc0706ddd93ee910084e6151b3a581c44 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-17470) Flink task executor process permanently hangs on `flink-daemon.sh stop`, deletes PID file

2020-11-19 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17470: --- Priority: Blocker (was: Critical) > Flink task executor process permanently hangs on `flink

[jira] [Created] (FLINK-20254) HiveTableSourceITCase.testStreamPartitionReadByCreateTime times out

2020-11-19 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-20254: -- Summary: HiveTableSourceITCase.testStreamPartitionReadByCreateTime times out Key: FLINK-20254 URL: https://issues.apache.org/jira/browse/FLINK-20254 Project: Flin

[GitHub] [flink] flinkbot commented on pull request #14148: [hotfix][javadocs] Fix typo in RichFunction

2020-11-19 Thread GitBox
flinkbot commented on pull request #14148: URL: https://github.com/apache/flink/pull/14148#issuecomment-730879019 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 pro

[GitHub] [flink] flinkbot edited a comment on pull request #14129: [hotfix] Reduce logging verbosity from the Checkpoint-related REST handlers

2020-11-19 Thread GitBox
flinkbot edited a comment on pull request #14129: URL: https://github.com/apache/flink/pull/14129#issuecomment-730245586 ## CI report: * 89144ae4ffb688a9ca039b311c0f2a9434a71be6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] dongxuwang opened a new pull request #14148: [hotfix][javadocs] Fix typo in RichFunction

2020-11-19 Thread GitBox
dongxuwang opened a new pull request #14148: URL: https://github.com/apache/flink/pull/14148 Just remove the duplicated two words. `of the` This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] rmetzger commented on pull request #14129: [hotfix] Reduce logging verbosity from the Checkpoint-related REST handlers

2020-11-19 Thread GitBox
rmetzger commented on pull request #14129: URL: https://github.com/apache/flink/pull/14129#issuecomment-730869724 Thanks a lot for your review. I addressed your comment, once CI is green, I'll merge it. This is an automated

[GitHub] [flink-statefun] klion26 commented on pull request #131: [FLINK-18968] Translate README.md to Chinese

2020-11-19 Thread GitBox
klion26 commented on pull request #131: URL: https://github.com/apache/flink-statefun/pull/131#issuecomment-730868665 @wangzzu is there any update? This is an automated message from the Apache Git Service. To respond to the m

[GitHub] [flink-web] klion26 closed pull request #395: [FLINK-17491] Translate Training page on project website

2020-11-19 Thread GitBox
klion26 closed pull request #395: URL: https://github.com/apache/flink-web/pull/395 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

[jira] [Assigned] (FLINK-20110) Support 'merge' method for first_value and last_value UDAF

2020-11-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20110: --- Assignee: hailong wang > Support 'merge' method for first_value and last_value UDAF > -

[GitHub] [flink] flinkbot edited a comment on pull request #14147: [FLINK-20059][table-common] Update Javadoc for "merge" method of AggregateFunction

2020-11-19 Thread GitBox
flinkbot edited a comment on pull request #14147: URL: https://github.com/apache/flink/pull/14147#issuecomment-730851946 ## CI report: * 68525d793b79e971b6d53ac654d738f16ab11d04 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14147: [FLINK-20059][table-common] Update Javadoc for "merge" method of AggregateFunction

2020-11-19 Thread GitBox
flinkbot commented on pull request #14147: URL: https://github.com/apache/flink/pull/14147#issuecomment-730851946 ## CI report: * 68525d793b79e971b6d53ac654d738f16ab11d04 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #14147: [FLINK-20059][table-common] Update Javadoc for "merge" method of AggregateFunction

2020-11-19 Thread GitBox
flinkbot commented on pull request #14147: URL: https://github.com/apache/flink/pull/14147#issuecomment-730847049 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 pro

[jira] [Updated] (FLINK-20059) Outdated SQL docs on aggregate functions' merge

2020-11-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20059: --- Labels: pull-request-available (was: ) > Outdated SQL docs on aggregate functions' merge >

[GitHub] [flink] wuchong opened a new pull request #14147: [FLINK-20059][table-common] Update Javadoc for "merge" method of AggregateFunction

2020-11-19 Thread GitBox
wuchong opened a new pull request #14147: URL: https://github.com/apache/flink/pull/14147 ## What is the purpose of the change In the java docs as well as the user docs, the merge method of an aggregation UDF is described as optional, e.g. ``` Merges a group

[jira] [Updated] (FLINK-20110) Support 'merge' method for first_value and last_value UDAF

2020-11-19 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-20110: - Fix Version/s: 1.13.0 > Support 'merge' method for first_value and last_value UDAF > ---

[jira] [Commented] (FLINK-20110) Support 'merge' method for first_value and last_value UDAF

2020-11-19 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235895#comment-17235895 ] hailong wang commented on FLINK-20110: -- [~jark] Yes, I can take it, thanks for assi

[jira] [Updated] (FLINK-20110) Support 'merge' method for first_value and last_value UDAF

2020-11-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20110: Component/s: Table SQL / Runtime > Support 'merge' method for first_value and last_value UDAF > --

[jira] [Commented] (FLINK-20110) Support 'merge' method for first_value and last_value UDAF

2020-11-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235892#comment-17235892 ] Jark Wu commented on FLINK-20110: - Hi [~hailong wang], do you want to try this? > Suppo

[jira] [Closed] (FLINK-20243) Remove useless words in documents

2020-11-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20243. --- Fix Version/s: 1.11.3 1.12.0 Assignee: xiaozilong Resolution: Fixed Fixed

[GitHub] [flink] wuchong merged pull request #14138: [FLINK-20243][docs]Remove useless words in documents

2020-11-19 Thread GitBox
wuchong merged pull request #14138: URL: https://github.com/apache/flink/pull/14138 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

[jira] [Closed] (FLINK-20204) Translate page 'upsert-kafka Connector' into Chinese

2020-11-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20204. --- Resolution: Fixed Fixed in master (1.12.0): 5b9625ef84c198b84b2116e10ef2e2915c560fd6 > Translate page 'upse

[GitHub] [flink] wuchong closed pull request #14126: [FLINK-20204][docs-zh] Translate page 'upsert-kafka Connector' into Chinese

2020-11-19 Thread GitBox
wuchong closed pull request #14126: URL: https://github.com/apache/flink/pull/14126 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] V1ncentzzZ commented on a change in pull request #14138: [FLINK-20243][docs]Remove useless words in documents

2020-11-19 Thread GitBox
V1ncentzzZ commented on a change in pull request #14138: URL: https://github.com/apache/flink/pull/14138#discussion_r527381858 ## File path: docs/ops/cli.zh.md ## @@ -36,7 +36,7 @@ The command line can be used to - cancel a running job, - provide information about a job, - l

[jira] [Updated] (FLINK-20253) `JsonRowDeserializationSchema` can not deserialize non utf-8 json string

2020-11-19 Thread zouyunhe (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zouyunhe updated FLINK-20253: - Description: We run a flink job and the input data is json format, and found the exception will throw w

[jira] [Comment Edited] (FLINK-20252) Manual Test for Approximate Local Recovery

2020-11-19 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235884#comment-17235884 ] Yuan Mei edited comment on FLINK-20252 at 11/20/20, 4:04 AM: -

[jira] [Commented] (FLINK-20252) Manual Test for Approximate Local Recovery

2020-11-19 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235884#comment-17235884 ] Yuan Mei commented on FLINK-20252: -- sink output:   {code:java} index:146; key:0; selec

[GitHub] [flink] wuchong commented on a change in pull request #14138: [FLINK-20243][docs]Remove useless words in documents

2020-11-19 Thread GitBox
wuchong commented on a change in pull request #14138: URL: https://github.com/apache/flink/pull/14138#discussion_r527379788 ## File path: docs/ops/cli.zh.md ## @@ -36,7 +36,7 @@ The command line can be used to - cancel a running job, - provide information about a job, - list

[jira] [Commented] (FLINK-19345) In Table File Sink, introduce streaming sink compaction

2020-11-19 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235882#comment-17235882 ] Jingsong Lee commented on FLINK-19345: -- Thank you for your in-depth exploration, ye

[jira] [Comment Edited] (FLINK-19345) In Table File Sink, introduce streaming sink compaction

2020-11-19 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235882#comment-17235882 ] Jingsong Lee edited comment on FLINK-19345 at 11/20/20, 4:00 AM: -

[jira] [Updated] (FLINK-20253) `JsonRowDeserializationSchema` can not deserialize non utf-8 json string

2020-11-19 Thread zouyunhe (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zouyunhe updated FLINK-20253: - Description: We run a flink job and the input data is json format, and found the exception will throw w

[jira] [Comment Edited] (FLINK-20252) Manual Test for Approximate Local Recovery

2020-11-19 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235878#comment-17235878 ] Yuan Mei edited comment on FLINK-20252 at 11/20/20, 3:59 AM: -

[GitHub] [flink] flinkbot edited a comment on pull request #14126: [FLINK-20204][docs-zh] Translate page 'upsert-kafka Connector' into Chinese

2020-11-19 Thread GitBox
flinkbot edited a comment on pull request #14126: URL: https://github.com/apache/flink/pull/14126#issuecomment-730132466 ## CI report: * a9fd72f26e6c70e68a6136890f155cd8b1aa024b Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Comment Edited] (FLINK-20252) Manual Test for Approximate Local Recovery

2020-11-19 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235878#comment-17235878 ] Yuan Mei edited comment on FLINK-20252 at 11/20/20, 3:59 AM: -

[jira] [Commented] (FLINK-20230) INSERT INTO EMPTY VALUES, THROW FileNotFoundException

2020-11-19 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235879#comment-17235879 ] Jingsong Lee commented on FLINK-20230: -- Looks like this is a bug in Filesystem **ba

[jira] [Commented] (FLINK-20252) Manual Test for Approximate Local Recovery

2020-11-19 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235878#comment-17235878 ] Yuan Mei commented on FLINK-20252: -- JM Log:   {code:java} 2020-11-20 11:05:40,914 INFO

[jira] [Updated] (FLINK-20253) `JsonRowDeserializationSchema` can not deserialize non utf-8 json string

2020-11-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20253: Component/s: Table SQL / Ecosystem > `JsonRowDeserializationSchema` can not deserialize non utf-8 json str

[jira] [Updated] (FLINK-20252) Manual Test for Approximate Local Recovery

2020-11-19 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20252: Fix Version/s: 1.12.0 > Manual Test for Approximate Local Recovery > -

[jira] [Updated] (FLINK-20252) Manual Test for Approximate Local Recovery

2020-11-19 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20252: Priority: Critical (was: Major) > Manual Test for Approximate Local Recovery > --

[jira] [Updated] (FLINK-20252) Manual Test for Approximate Local Recovery

2020-11-19 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20252: Parent: FLINK-20112 Issue Type: Sub-task (was: Bug) > Manual Test for Approximate Local Recovery

[jira] [Updated] (FLINK-20253) `JsonRowDeserializationSchema` can not deserialize non utf-8 json string

2020-11-19 Thread zouyunhe (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zouyunhe updated FLINK-20253: - Description: We run a flink job and the input data is json format, and found the exception will throw w

[jira] [Commented] (FLINK-20230) INSERT INTO EMPTY VALUES, THROW FileNotFoundException

2020-11-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235874#comment-17235874 ] Jark Wu commented on FLINK-20230: - Could you help to have a look at this? [~lzljs3620320

[jira] [Created] (FLINK-20253) `JsonRowDeserializationSchema` can not deserialize non utf-8 json string

2020-11-19 Thread zouyunhe (Jira)
zouyunhe created FLINK-20253: Summary: `JsonRowDeserializationSchema` can not deserialize non utf-8 json string Key: FLINK-20253 URL: https://issues.apache.org/jira/browse/FLINK-20253 Project: Flink

[jira] [Updated] (FLINK-20230) INSERT INTO EMPTY VALUES, THROW FileNotFoundException

2020-11-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20230: Description: table  USE SQL "INSERT INTO VALUES", WHEN THE VALUES IS NULL, AND IT WILL THROW  FileNotFound

[jira] [Updated] (FLINK-20230) INSERT INTO EMPTY VALUES, THROW FileNotFoundException

2020-11-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20230: Environment: (was: TABLE DDL: CREATE TABLE IF NOT EXISTS test1 ( uid string, truename string, dt st

[GitHub] [flink] wuchong commented on pull request #14103: [FLINK-18545] Introduce `pipeline.name` to allow users to specify job name by configuration

2020-11-19 Thread GitBox
wuchong commented on pull request #14103: URL: https://github.com/apache/flink/pull/14103#issuecomment-730823946 Hi @kl0u , I don't think the job name configuration conflicts with application mode. I think multi-execute applications may al so have same job name, e.g. use the default job na

[jira] [Updated] (FLINK-20252) Manual Test for Approximate Local Recovery

2020-11-19 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-20252: - Description: This manual test is to verify approximate failover works as expected in clusters.   *Tes

[GitHub] [flink] curcur closed pull request #14146: [FLINK-20252] Test Job for Approximate Local Recovery

2020-11-19 Thread GitBox
curcur closed pull request #14146: URL: https://github.com/apache/flink/pull/14146 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 t

[GitHub] [flink] flinkbot edited a comment on pull request #14126: [FLINK-20204][docs-zh] Translate page 'upsert-kafka Connector' into Chinese

2020-11-19 Thread GitBox
flinkbot edited a comment on pull request #14126: URL: https://github.com/apache/flink/pull/14126#issuecomment-730132466 ## CI report: * a9fd72f26e6c70e68a6136890f155cd8b1aa024b Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] lirui-apache commented on a change in pull request #14145: [FLINK-20239][docs] Confusing pages: Hive Read & Write and Hive Strea…

2020-11-19 Thread GitBox
lirui-apache commented on a change in pull request #14145: URL: https://github.com/apache/flink/pull/14145#discussion_r527368062 ## File path: docs/dev/table/hive/hive_read_write.md ## @@ -22,119 +22,199 @@ specific language governing permissions and limitations under the Lice

[GitHub] [flink] flinkbot commented on pull request #14146: [FLINK-20252] Test Job for Approximate Local Recovery

2020-11-19 Thread GitBox
flinkbot commented on pull request #14146: URL: https://github.com/apache/flink/pull/14146#issuecomment-730822458 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 pro

[jira] [Updated] (FLINK-20252) Manual Test for Approximate Local Recovery

2020-11-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20252: --- Labels: pull-request-available (was: ) > Manual Test for Approximate Local Recovery > -

[GitHub] [flink] flinkbot edited a comment on pull request #11830: [FLINK-17096] [table] Mini-batch group aggregation doesn't expire state even if state ttl is enabled

2020-11-19 Thread GitBox
flinkbot edited a comment on pull request #11830: URL: https://github.com/apache/flink/pull/11830#issuecomment-616574921 ## CI report: * aa11b396cf32dc372ebab32ec177172fb5388a62 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] curcur opened a new pull request #14146: [FLINK-20252] Test Job for Approximate Local Recovery

2020-11-19 Thread GitBox
curcur opened a new pull request #14146: URL: https://github.com/apache/flink/pull/14146 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them on

[jira] [Updated] (FLINK-20252) Manual Test for Approximate Local Recovery

2020-11-19 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-20252: - Description: This manual test is to verify approximate failover works as expected in clusters.   Test

[jira] [Commented] (FLINK-20246) Add documentation on Python worker memory tuning in the memory tuning page

2020-11-19 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235865#comment-17235865 ] Zhu Zhu commented on FLINK-20246: - Thanks for firing and taking this task! [~dian.fu] Li

[jira] [Commented] (FLINK-19775) SystemProcessingTimeServiceTest.testImmediateShutdown is instable

2020-11-19 Thread jiawen xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235861#comment-17235861 ] jiawen xiao commented on FLINK-19775: - hi, [~dian.fu],[~trohrmann],After my recent r

[GitHub] [flink] flinkbot edited a comment on pull request #14126: [FLINK-20204][docs-zh] Translate page 'upsert-kafka Connector' into Chinese

2020-11-19 Thread GitBox
flinkbot edited a comment on pull request #14126: URL: https://github.com/apache/flink/pull/14126#issuecomment-730132466 ## CI report: * a9fd72f26e6c70e68a6136890f155cd8b1aa024b Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-20252) Manual Test for Approximate Local Recovery

2020-11-19 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-20252: - Description: This  > Manual Test for Approximate Local Recovery > --

[jira] [Created] (FLINK-20252) Manual Test for Approximate Local Recovery

2020-11-19 Thread Yuan Mei (Jira)
Yuan Mei created FLINK-20252: Summary: Manual Test for Approximate Local Recovery Key: FLINK-20252 URL: https://issues.apache.org/jira/browse/FLINK-20252 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #11830: [FLINK-17096] [table] Mini-batch group aggregation doesn't expire state even if state ttl is enabled

2020-11-19 Thread GitBox
flinkbot edited a comment on pull request #11830: URL: https://github.com/apache/flink/pull/11830#issuecomment-616574921 ## CI report: * aa11b396cf32dc372ebab32ec177172fb5388a62 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

  1   2   3   4   5   >