[GitHub] [flink] lirui-apache commented on pull request #14203: [FLINK-20241][hive] Improve exception message when hive deps are miss…

lirui-apache commented on pull request #14203: URL: https://github.com/apache/flink/pull/14203#issuecomment-734138103 @StephanEwen @JingsongLi Would you mind have a look at the PR? Thanks. This is an automated message from th

[jira] [Assigned] (FLINK-20365) The native k8s cluster could not be unregistered when executing Python DataStream application attachedly.

[ https://issues.apache.org/jira/browse/FLINK-20365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20365: --- Assignee: Shuiqiang Chen > The native k8s cluster could not be unregistered when executing Python

[jira] [Commented] (FLINK-20345) Adds an Expand node only if there are multiple distinct aggregate functions in an Aggregate when executes SplitAggregateRule

[ https://issues.apache.org/jira/browse/FLINK-20345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239107#comment-17239107 ] Jingsong Lee commented on FLINK-20345: -- [~qingru zhang] Assigned to u > Adds an Ex

[jira] [Updated] (FLINK-20345) Adds an Expand node only if there are multiple distinct aggregate functions in an Aggregate when executes SplitAggregateRule

[ https://issues.apache.org/jira/browse/FLINK-20345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-20345: - Fix Version/s: (was: 1.11.3) 1.13.0 > Adds an Expand node only if there a

[jira] [Assigned] (FLINK-20345) Adds an Expand node only if there are multiple distinct aggregate functions in an Aggregate when executes SplitAggregateRule

[ https://issues.apache.org/jira/browse/FLINK-20345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-20345: Assignee: Andy > Adds an Expand node only if there are multiple distinct aggregate functi

[GitHub] [flink] flinkbot commented on pull request #14228: [FLINK-20349][table-planner-blink] Fix checking for deadlock caused by exchange

flinkbot commented on pull request #14228: URL: https://github.com/apache/flink/pull/14228#issuecomment-734132510 ## CI report: * 523a5b439481c59e89ed2c548b36cc0ae8df69c9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] AHeise commented on pull request #13885: [FLINK-19911] add read buffer for input stream

AHeise commented on pull request #13885: URL: https://github.com/apache/flink/pull/13885#issuecomment-734129526 > > > > `LocalFileSystem` > > > > > > > > > Yes, it looks like `LocalFileSystem` should also be a good candidate. In particular `#open(Path, int)` currently ignores the

[jira] [Commented] (FLINK-20345) Adds an Expand node only if there are multiple distinct aggregate functions in an Aggregate when executes SplitAggregateRule

[ https://issues.apache.org/jira/browse/FLINK-20345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239105#comment-17239105 ] Andy commented on FLINK-20345: -- [~lzljs3620320] I agree with you. Could I take this issue?

[jira] [Closed] (FLINK-20362) Broken Link in dev/table/sourceSinks.zh.md

[ https://issues.apache.org/jira/browse/FLINK-20362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20362. --- Resolution: Fixed Fixed in - master via 47d81ce1328fb5979e237048bdfc8bae5d88d283 - release-1.12 via 3ebeb6c

[GitHub] [flink] flinkbot edited a comment on pull request #14227: [FLINK-20245][hive][docs] Document how to create a Hive catalog from DDL

flinkbot edited a comment on pull request #14227: URL: https://github.com/apache/flink/pull/14227#issuecomment-734118464 ## CI report: * 22f1148159795b2c6e292bc018df4292fd0692a8 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] dianfu closed pull request #14226: [FLINK-20362][doc] Fix broken link in sourceSinks.zh.md

dianfu closed pull request #14226: URL: https://github.com/apache/flink/pull/14226 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 commented on pull request #14228: [FLINK-20349][table-planner-blink] Fix checking for deadlock caused by exchange

flinkbot commented on pull request #14228: URL: https://github.com/apache/flink/pull/14228#issuecomment-734123858 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-20349) Query fails with "A conflict is detected. This is unexpected."

[ https://issues.apache.org/jira/browse/FLINK-20349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20349: --- Labels: pull-request-available (was: ) > Query fails with "A conflict is detected. This is

[GitHub] [flink] TsReaper opened a new pull request #14228: [FLINK-20349][table-planner-blink] Fix checking for deadlock caused by exchange

TsReaper opened a new pull request #14228: URL: https://github.com/apache/flink/pull/14228 ## What is the purpose of the change This is the bug fix for FLINK-20349, where the checking for deadlock caused by exchange in the deadlock break-up algorithm does not work for some cases.

[jira] [Comment Edited] (FLINK-20331) UnalignedCheckpointITCase.execute failed with "Sequence number for checkpoint 20 is not known (it was likely been overwritten by a newer checkpoint 21)"

[ https://issues.apache.org/jira/browse/FLINK-20331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239097#comment-17239097 ] Arvid Heise edited comment on FLINK-20331 at 11/26/20, 7:18 AM: --

[jira] [Commented] (FLINK-20327) The Hive's read/write page should redirect to SQL Fileystem connector

[ https://issues.apache.org/jira/browse/FLINK-20327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239100#comment-17239100 ] Leonard Xu commented on FLINK-20327: I'd like to take this, could you help assign th

[jira] [Closed] (FLINK-20339) `FileWriter` support to load StreamingFileSink's state.

[ https://issues.apache.org/jira/browse/FLINK-20339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma closed FLINK-20339. - Resolution: Won't Fix > `FileWriter` support to load StreamingFileSink's state. > --

[jira] [Closed] (FLINK-20338) Make the `StatefulSinkWriterOperator` load `StreamingFileSink`'s state.

[ https://issues.apache.org/jira/browse/FLINK-20338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma closed FLINK-20338. - Resolution: Won't Fix > Make the `StatefulSinkWriterOperator` load `StreamingFileSink`'s state. > --

[jira] [Commented] (FLINK-20337) Make migrate `StreamingFileSink` to `FileSink` possible

[ https://issues.apache.org/jira/browse/FLINK-20337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239098#comment-17239098 ] Guowei Ma commented on FLINK-20337: --- Sorry [~kkl0u] for responsing so late. I think it

[GitHub] [flink] flinkbot commented on pull request #14227: [FLINK-20245][hive][docs] Document how to create a Hive catalog from DDL

flinkbot commented on pull request #14227: URL: https://github.com/apache/flink/pull/14227#issuecomment-734118464 ## CI report: * 22f1148159795b2c6e292bc018df4292fd0692a8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Resolved] (FLINK-20331) UnalignedCheckpointITCase.execute failed with "Sequence number for checkpoint 20 is not known (it was likely been overwritten by a newer checkpoint 21)"

[ https://issues.apache.org/jira/browse/FLINK-20331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-20331. - Resolution: Fixed > UnalignedCheckpointITCase.execute failed with "Sequence number for checkpoin

[jira] [Commented] (FLINK-20331) UnalignedCheckpointITCase.execute failed with "Sequence number for checkpoint 20 is not known (it was likely been overwritten by a newer checkpoint 21)"

[ https://issues.apache.org/jira/browse/FLINK-20331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239097#comment-17239097 ] Arvid Heise commented on FLINK-20331: - Not a real bug but a too strict assumption.

[GitHub] [flink] flinkbot edited a comment on pull request #13983: [FLINK-19989][python] Add collect operation in Python DataStream API

flinkbot edited a comment on pull request #13983: URL: https://github.com/apache/flink/pull/13983#issuecomment-723574143 ## CI report: * fe0505f91d71c3a5947bdac49a8b3fb91983d5c5 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] 1996fanrui commented on pull request #13885: [FLINK-19911] add read buffer for input stream

1996fanrui commented on pull request #13885: URL: https://github.com/apache/flink/pull/13885#issuecomment-734116774 > > > `LocalFileSystem` > > > > > > Yes, it looks like `LocalFileSystem` should also be a good candidate. In particular `#open(Path, int)` currently ignores the buf

[GitHub] [flink] AHeise merged pull request #14218: [FLINK-20331][checkpointing][task] Don't fail the task if unaligned checkpoint was subsumed

AHeise merged pull request #14218: URL: https://github.com/apache/flink/pull/14218 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] [Commented] (FLINK-20213) Partition commit is delayed when records keep coming

[ https://issues.apache.org/jira/browse/FLINK-20213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239096#comment-17239096 ] zouyunhe commented on FLINK-20213: -- [~lzljs3620320] OK > Partition commit is delayed w

[jira] [Created] (FLINK-20367) Show the in-use config of job to users

zlzhang0122 created FLINK-20367: --- Summary: Show the in-use config of job to users Key: FLINK-20367 URL: https://issues.apache.org/jira/browse/FLINK-20367 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-20316) update the deduplication section of query page

[ https://issues.apache.org/jira/browse/FLINK-20316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20316. --- Resolution: Fixed Fixed in - master (1.13.0): 54ac81a4b2acc8239f9ff809e4b2c7d090740e1b - 1.12.0: 4c8a71b6b

[GitHub] [flink] lirui-apache commented on pull request #14227: [FLINK-20245][hive][docs] Document how to create a Hive catalog from DDL

lirui-apache commented on pull request #14227: URL: https://github.com/apache/flink/pull/14227#issuecomment-734106437 @dawidwys @JingsongLi Could you take a look at the PR? It only updates the eng page, I'll sync the changes to zh page once we think it's good enough. -

[GitHub] [flink] flinkbot commented on pull request #14227: [FLINK-20245][hive][docs] Document how to create a Hive catalog from DDL

flinkbot commented on pull request #14227: URL: https://github.com/apache/flink/pull/14227#issuecomment-734106347 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 #13983: [FLINK-19989][python] Add collect operation in Python DataStream API

flinkbot edited a comment on pull request #13983: URL: https://github.com/apache/flink/pull/13983#issuecomment-723574143 ## CI report: * fe0505f91d71c3a5947bdac49a8b3fb91983d5c5 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] lirui-apache commented on pull request #14227: [FLINK-20245][hive][docs] Document how to create a Hive catalog from DDL

lirui-apache commented on pull request #14227: URL: https://github.com/apache/flink/pull/14227#issuecomment-734105833  Attached is a screenshot of

[jira] [Updated] (FLINK-20245) Document how to create a Hive catalog from DDL

[ https://issues.apache.org/jira/browse/FLINK-20245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20245: --- Labels: pull-request-available (was: ) > Document how to create a Hive catalog from DDL > -

[GitHub] [flink] lirui-apache opened a new pull request #14227: [FLINK-20245][hive][docs] Document how to create a Hive catalog from DDL

lirui-apache opened a new pull request #14227: URL: https://github.com/apache/flink/pull/14227 ## What is the purpose of the change Document how to create `HiveCatalog` with DDL and add table of supported options. ## Brief change log - Document how to crea

[jira] [Commented] (FLINK-20366) ColumnIntervalUtil#getColumnIntervalWithFilter does not consider the case when the predicate is a false constant

[ https://issues.apache.org/jira/browse/FLINK-20366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239086#comment-17239086 ] godfrey he commented on FLINK-20366: good catch [~TsReaper], I will fix it > Column

[GitHub] [flink] wuchong merged pull request #14214: [FLINK-20316][doc] update the deduplication section of query page

wuchong merged pull request #14214: URL: https://github.com/apache/flink/pull/14214 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-20366) ColumnIntervalUtil#getColumnIntervalWithFilter does not consider the case when the predicate is a false constant

[ https://issues.apache.org/jira/browse/FLINK-20366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-20366: -- Assignee: godfrey he > ColumnIntervalUtil#getColumnIntervalWithFilter does not consider the c

[jira] [Closed] (FLINK-20184) update hive streaming read and temporal table documents

[ https://issues.apache.org/jira/browse/FLINK-20184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-20184. Resolution: Fixed master (1.13): 47ae3341b5f5796e397ff255baadc95d4426e15d release-1.12: f05151070

[jira] [Commented] (FLINK-20366) ColumnIntervalUtil#getColumnIntervalWithFilter does not consider the case when the predicate is a false constant

[ https://issues.apache.org/jira/browse/FLINK-20366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239084#comment-17239084 ] Caizhi Weng commented on FLINK-20366: - [~godfreyhe] please take a look. > ColumnInt

[jira] [Created] (FLINK-20366) ColumnIntervalUtil#getColumnIntervalWithFilter does not consider the case when the predicate is a false constant

Caizhi Weng created FLINK-20366: --- Summary: ColumnIntervalUtil#getColumnIntervalWithFilter does not consider the case when the predicate is a false constant Key: FLINK-20366 URL: https://issues.apache.org/jira/browse

[GitHub] [flink] JingsongLi merged pull request #14182: [FLINK-20184][doc] update hive streaming read and temporal table document

JingsongLi merged pull request #14182: URL: https://github.com/apache/flink/pull/14182 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

[GitHub] [flink] flinkbot edited a comment on pull request #14204: [FLINK-20325][build] Move docs_404_check to CI stage

flinkbot edited a comment on pull request #14204: URL: https://github.com/apache/flink/pull/14204#issuecomment-733048767 ## CI report: * 6550d3e1b01af94d4f652f993834b75272da1020 UNKNOWN * 595ab82c651f8c225193eeeba90d6366fdff341d Azure: [CANCELED](https://dev.azure.com/apache-f

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

flinkbot edited a comment on pull request #14103: URL: https://github.com/apache/flink/pull/14103#issuecomment-729030820 ## CI report: * cda47b16b8fa216fefb5399249026c2a54e907ed Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20213) Partition commit is delayed when records keep coming

[ https://issues.apache.org/jira/browse/FLINK-20213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239080#comment-17239080 ] Jingsong Lee commented on FLINK-20213: -- Hi [~zouyunhe], I think your correct commit

[jira] [Commented] (FLINK-20213) Partition commit is delayed when records keep coming

[ https://issues.apache.org/jira/browse/FLINK-20213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239075#comment-17239075 ] zouyunhe commented on FLINK-20213: -- [~lzljs3620320] the commit delay is 1 min, the tblp

[jira] [Commented] (FLINK-20213) Partition commit is delayed when records keep coming

[ https://issues.apache.org/jira/browse/FLINK-20213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239073#comment-17239073 ] Jingsong Lee commented on FLINK-20213: -- [~zouyunhe] What is the delay? > Partition

[GitHub] [flink] wuchong merged pull request #14211: [hotfix] Fix typo `dispatcherResourceManagreComponentRpcServiceFactory`

wuchong merged pull request #14211: URL: https://github.com/apache/flink/pull/14211 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] [Comment Edited] (FLINK-20123) Test native support of PyFlink on Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-20123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239070#comment-17239070 ] Shuiqiang Chen edited comment on FLINK-20123 at 11/26/20, 5:27 AM: ---

[jira] [Comment Edited] (FLINK-20123) Test native support of PyFlink on Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-20123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239070#comment-17239070 ] Shuiqiang Chen edited comment on FLINK-20123 at 11/26/20, 5:27 AM: ---

[jira] [Updated] (FLINK-20365) The native k8s cluster could not be unregistered when executing Python DataStream application attachedly.

[ https://issues.apache.org/jira/browse/FLINK-20365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuiqiang Chen updated FLINK-20365: --- Affects Version/s: (was: 1.12.0) > The native k8s cluster could not be unregistered when

[jira] [Updated] (FLINK-20365) The native k8s cluster could not be unregistered when executing Python DataStream application attachedly.

[ https://issues.apache.org/jira/browse/FLINK-20365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuiqiang Chen updated FLINK-20365: --- Fix Version/s: 1.12.0 > The native k8s cluster could not be unregistered when executing Pyth

[jira] [Commented] (FLINK-20123) Test native support of PyFlink on Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-20123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239070#comment-17239070 ] Shuiqiang Chen commented on FLINK-20123: Hi [~rmetzger] I found that the native

[jira] [Created] (FLINK-20365) The native k8s cluster could not be unregistered when executing Python DataStream application attachedly.

Shuiqiang Chen created FLINK-20365: -- Summary: The native k8s cluster could not be unregistered when executing Python DataStream application attachedly. Key: FLINK-20365 URL: https://issues.apache.org/jira/browse/

[jira] [Commented] (FLINK-20119) Test Temporal Table DDL and Temporal Table Join

[ https://issues.apache.org/jira/browse/FLINK-20119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239064#comment-17239064 ] Leonard Xu commented on FLINK-20119: I've finished the test, let me update the comme

[jira] [Resolved] (FLINK-20119) Test Temporal Table DDL and Temporal Table Join

[ https://issues.apache.org/jira/browse/FLINK-20119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-20119. Resolution: Resolved > Test Temporal Table DDL and Temporal Table Join > -

[GitHub] [flink] flinkbot edited a comment on pull request #14226: [FLINK-20362][doc] Fix broken link in sourceSinks.zh.md

flinkbot edited a comment on pull request #14226: URL: https://github.com/apache/flink/pull/14226#issuecomment-734044273 ## CI report: * e0e112b0a92a02a62de739fa37a98f2d132e5a46 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #14103: URL: https://github.com/apache/flink/pull/14103#issuecomment-729030820 ## CI report: * 938cbb403a01e6d31cbc605a49f9baf7b3b9bf31 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20364) Add support for scheduling with slot sharing

[ https://issues.apache.org/jira/browse/FLINK-20364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239059#comment-17239059 ] Guruh Fajar Samudra commented on FLINK-20364: - Github user GJL commented on

[jira] [Commented] (FLINK-20364) Add support for scheduling with slot sharing

[ https://issues.apache.org/jira/browse/FLINK-20364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239058#comment-17239058 ] Guruh Fajar Samudra commented on FLINK-20364: - Github user GJL commented on

[jira] [Commented] (FLINK-20364) Add support for scheduling with slot sharing

[ https://issues.apache.org/jira/browse/FLINK-20364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239056#comment-17239056 ] Guruh Fajar Samudra commented on FLINK-20364: - Github user GJL commented on

[jira] [Commented] (FLINK-20364) Add support for scheduling with slot sharing

[ https://issues.apache.org/jira/browse/FLINK-20364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239057#comment-17239057 ] Guruh Fajar Samudra commented on FLINK-20364: - Github user GJL commented on

[jira] [Commented] (FLINK-20364) Add support for scheduling with slot sharing

[ https://issues.apache.org/jira/browse/FLINK-20364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239055#comment-17239055 ] Guruh Fajar Samudra commented on FLINK-20364: - Github user GJL commented on

[jira] [Commented] (FLINK-20364) Add support for scheduling with slot sharing

[ https://issues.apache.org/jira/browse/FLINK-20364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239054#comment-17239054 ] Guruh Fajar Samudra commented on FLINK-20364: - Github user GJL commented on

[jira] [Commented] (FLINK-20364) Add support for scheduling with slot sharing

[ https://issues.apache.org/jira/browse/FLINK-20364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239053#comment-17239053 ] Guruh Fajar Samudra commented on FLINK-20364: - Github user GJL commented on

[jira] [Commented] (FLINK-20364) Add support for scheduling with slot sharing

[ https://issues.apache.org/jira/browse/FLINK-20364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239052#comment-17239052 ] Guruh Fajar Samudra commented on FLINK-20364: - GitHub user tillrohrmann open

[jira] [Closed] (FLINK-20364) Add support for scheduling with slot sharing

[ https://issues.apache.org/jira/browse/FLINK-20364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guruh Fajar Samudra closed FLINK-20364. --- Resolution: Fixed > Add support for scheduling with slot sharing > -

[GitHub] [flink] flinkbot edited a comment on pull request #14204: [FLINK-20325][build] Move docs_404_check to CI stage

flinkbot edited a comment on pull request #14204: URL: https://github.com/apache/flink/pull/14204#issuecomment-733048767 ## CI report: * 6550d3e1b01af94d4f652f993834b75272da1020 UNKNOWN * c460e22339284c6817e5aad3ea947e87743272e7 Azure: [SUCCESS](https://dev.azure.com/apache-fl

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

flinkbot edited a comment on pull request #14103: URL: https://github.com/apache/flink/pull/14103#issuecomment-729030820 ## CI report: * 938cbb403a01e6d31cbc605a49f9baf7b3b9bf31 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20213) Partition commit is delayed when records keep coming

[ https://issues.apache.org/jira/browse/FLINK-20213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239051#comment-17239051 ] zouyunhe commented on FLINK-20213: -- [~lzljs3620320]  We found the watermark as below, t

[jira] [Updated] (FLINK-20364) Add support for scheduling with slot sharing

[ https://issues.apache.org/jira/browse/FLINK-20364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guruh Fajar Samudra updated FLINK-20364: External issue URL: https://github.com/apache/flink/pull/5091 > Add support for sc

[jira] [Updated] (FLINK-20213) Partition commit is delayed when records keep coming

[ https://issues.apache.org/jira/browse/FLINK-20213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zouyunhe updated FLINK-20213: - Attachment: image-2020-11-26-12-00-23-542.png > Partition commit is delayed when records keep coming > -

[jira] [Updated] (FLINK-20213) Partition commit is delayed when records keep coming

[ https://issues.apache.org/jira/browse/FLINK-20213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zouyunhe updated FLINK-20213: - Attachment: image-2020-11-26-12-00-55-829.png > Partition commit is delayed when records keep coming > -

[jira] [Created] (FLINK-20364) Add support for scheduling with slot sharing

Guruh Fajar Samudra created FLINK-20364: --- Summary: Add support for scheduling with slot sharing Key: FLINK-20364 URL: https://issues.apache.org/jira/browse/FLINK-20364 Project: Flink Is

[GitHub] [flink] flinkbot edited a comment on pull request #13580: [hotfix][flink-runtime-web] modify checkpoint time format

flinkbot edited a comment on pull request #13580: URL: https://github.com/apache/flink/pull/13580#issuecomment-706475658 ## CI report: * c8adc676db1403b4a2eef7f9898970f2051dea1f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20213) Partition commit is delayed when records keep coming

[ https://issues.apache.org/jira/browse/FLINK-20213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239050#comment-17239050 ] Jingsong Lee commented on FLINK-20213: -- [~zouyunhe] Thanks for you feedback, Can yo

[GitHub] [flink] flinkbot edited a comment on pull request #13580: [hotfix][flink-runtime-web] modify checkpoint time format

flinkbot edited a comment on pull request #13580: URL: https://github.com/apache/flink/pull/13580#issuecomment-706475658 ## CI report: * c8adc676db1403b4a2eef7f9898970f2051dea1f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-20289) Computed columns can be calculated after ChangelogNormalize to reduce shuffle

[ https://issues.apache.org/jira/browse/FLINK-20289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20289: Description: In FLINK-19878, we improved that the ChangelogNormalize is applied after WatermarkAssigner t

[jira] [Commented] (FLINK-20289) Computed columns can be calculated after ChangelogNormalize to reduce shuffle

[ https://issues.apache.org/jira/browse/FLINK-20289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239047#comment-17239047 ] Jark Wu commented on FLINK-20289: - It is an improvement that only rowtime expressions sh

[jira] [Comment Edited] (FLINK-20289) Computed columns can be calculated after ChangelogNormalize to reduce shuffle

[ https://issues.apache.org/jira/browse/FLINK-20289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238118#comment-17238118 ] Nicholas Jiang edited comment on FLINK-20289 at 11/26/20, 3:20 AM: ---

[GitHub] [flink] flinkbot edited a comment on pull request #14226: [FLINK-20362][doc] Fix broken link in sourceSinks.zh.md

flinkbot edited a comment on pull request #14226: URL: https://github.com/apache/flink/pull/14226#issuecomment-734044273 ## CI report: * e0e112b0a92a02a62de739fa37a98f2d132e5a46 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14204: [FLINK-20325][build] Move docs_404_check to CI stage

flinkbot edited a comment on pull request #14204: URL: https://github.com/apache/flink/pull/14204#issuecomment-733048767 ## CI report: * 6550d3e1b01af94d4f652f993834b75272da1020 UNKNOWN * c460e22339284c6817e5aad3ea947e87743272e7 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-13611) Introduce analyze statistic utility to generate table & column statistics

[ https://issues.apache.org/jira/browse/FLINK-13611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239041#comment-17239041 ] Zou commented on FLINK-13611: - Big +1 for this feature, it is a very important feature for b

[jira] [Commented] (FLINK-20348) Make "schema-registry.subject" optional for Kafka sink with avro-confluent format

[ https://issues.apache.org/jira/browse/FLINK-20348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239040#comment-17239040 ] Jark Wu commented on FLINK-20348: - [~dwysakowicz] yes, you are right. Kafka connector wi

[jira] [Updated] (FLINK-20301) Flink sql 1.10 : Legacy Decimal and decimal for Array that is not Compatible

[ https://issues.apache.org/jira/browse/FLINK-20301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-20301: -- Affects Version/s: 1.10.0 > Flink sql 1.10 : Legacy Decimal and decimal for Array that is not Compat

[jira] [Commented] (FLINK-20361) Using sliding window with duration of hours in Table API returns wrong time

[ https://issues.apache.org/jira/browse/FLINK-20361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239036#comment-17239036 ] Jark Wu commented on FLINK-20361: - The result is as expected. You can see the sliding wi

[jira] [Resolved] (FLINK-19998) Invalid Links in docs

[ https://issues.apache.org/jira/browse/FLINK-19998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-19998. -- Resolution: Fixed > Invalid Links in docs > - > > Key: FLINK-19998

[jira] [Commented] (FLINK-19998) Invalid Links in docs

[ https://issues.apache.org/jira/browse/FLINK-19998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239033#comment-17239033 ] Yun Tang commented on FLINK-19998: -- merged in master c008907d2a629449c8d0ad9725d13b0604

[jira] [Updated] (FLINK-20225) Broken link in the document

[ https://issues.apache.org/jira/browse/FLINK-20225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20225: Summary: Broken link in the document (was: broken link in the document) > Broken link in the document > -

[jira] [Updated] (FLINK-20225) broken link in the document

[ https://issues.apache.org/jira/browse/FLINK-20225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20225: Summary: broken link in the document (was: Break link in the document) > broken link in the document > --

[GitHub] [flink] flinkbot commented on pull request #14226: [FLINK-20362][doc] Fix broken link in sourceSinks.zh.md

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

[jira] [Assigned] (FLINK-20362) Broken Link in dev/table/sourceSinks.zh.md

[ https://issues.apache.org/jira/browse/FLINK-20362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20362: --- Assignee: Shengkai Fang > Broken Link in dev/table/sourceSinks.zh.md >

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

wuchong commented on a change in pull request #14103: URL: https://github.com/apache/flink/pull/14103#discussion_r530745246 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java ## @@ -2330,4 +2330,8 @@ publ

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

wuchong commented on a change in pull request #14103: URL: https://github.com/apache/flink/pull/14103#discussion_r530745246 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java ## @@ -2330,4 +2330,8 @@ publ

[GitHub] [flink] wuchong commented on pull request #14204: [FLINK-20325][build] Move docs_404_check to CI stage

wuchong commented on pull request #14204: URL: https://github.com/apache/flink/pull/14204#issuecomment-734042205 Hi @rmetzger , the build should fail because there are some 404 pages, however it is passed. I looked into the log, it did report an unfounded page by the web server

[jira] [Commented] (FLINK-20284) Error happens in TaskExecutor when closing JobMaster connection if there was a python UDF

[ https://issues.apache.org/jira/browse/FLINK-20284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239030#comment-17239030 ] Zhu Zhu commented on FLINK-20284: - Thanks for the investigation and fixing this problem!

[GitHub] [flink] flinkbot commented on pull request #14226: [FLINK-20362][doc] Fix broken link in sourceSinks.zh.md

flinkbot commented on pull request #14226: URL: https://github.com/apache/flink/pull/14226#issuecomment-734041759 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] [Commented] (FLINK-20123) Test native support of PyFlink on Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-20123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239029#comment-17239029 ] Yang Wang commented on FLINK-20123: --- I am afraid [~csq] has found a issue about cancel

[jira] [Updated] (FLINK-20349) Query fails with "A conflict is detected. This is unexpected."

[ https://issues.apache.org/jira/browse/FLINK-20349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-20349: --- Affects Version/s: 1.12.0 > Query fails with "A conflict is detected. This is unexpected." > ---

[jira] [Updated] (FLINK-20362) Broken Link in dev/table/sourceSinks.zh.md

[ https://issues.apache.org/jira/browse/FLINK-20362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20362: --- Labels: pull-request-available (was: ) > Broken Link in dev/table/sourceSinks.zh.md > -

[GitHub] [flink] fsk119 opened a new pull request #14226: [FLINK-20362][doc] Fix broken link in sourceSinks.zh.md

fsk119 opened a new pull request #14226: URL: https://github.com/apache/flink/pull/14226 ## What is the purpose of the change *Fix broken link `{% link dev/table/legacySourceSinks.md %} ->({% link dev/table/legacySourceSinks.zh.md %})`* -

  1   2   3   4   5   6   >