[GitHub] [flink] flinkbot commented on pull request #15167: [BP-1.12][FLINK-21733][table-planner-blink] WatermarkAssigner incorrectly recomputing the rowtime index which may cause ArrayIndexOutOfBound

2021-03-11 Thread GitBox
flinkbot commented on pull request #15167: URL: https://github.com/apache/flink/pull/15167#issuecomment-797307255 ## CI report: * 16548a8804a2d1f7483de775d6f76746944af166 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15166: [hotfix][doc] fix Image rendering error in generating_watermarks.md

2021-03-11 Thread GitBox
flinkbot edited a comment on pull request #15166: URL: https://github.com/apache/flink/pull/15166#issuecomment-797298557 ## CI report: * 3079f8c19c648129348c0e601d2816fa5ea5bc50 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354][statebackend] Introduce ChangelogStateBackend to delegate state access

2021-03-11 Thread GitBox
curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r592973364 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@ -0,0

[GitHub] [flink] KurtYoung commented on a change in pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

2021-03-11 Thread GitBox
KurtYoung commented on a change in pull request #15136: URL: https://github.com/apache/flink/pull/15136#discussion_r592973280 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/expressions/utils/ExpressionTestBase.scala ## @@ -108

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354][statebackend] Introduce ChangelogStateBackend to delegate state access

2021-03-11 Thread GitBox
curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r592973129 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@ -0,0

[GitHub] [flink] flinkbot edited a comment on pull request #14754: [FLINK-21127][runtime][checkpoint] Stores finished status for fully finished operators in checkpoint

2021-03-11 Thread GitBox
flinkbot edited a comment on pull request #14754: URL: https://github.com/apache/flink/pull/14754#issuecomment-766965862 ## CI report: * 574e29c9ba5c4a144b2ad6029c96c3fa2af43647 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] curcur commented on a change in pull request #14943: [FLINK-21354][statebackend] Introduce ChangelogStateBackend to delegate state access

2021-03-11 Thread GitBox
curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r592973129 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@ -0,0

[GitHub] [flink] gaoyunhaii edited a comment on pull request #14754: [FLINK-21127][runtime][checkpoint] Stores finished status for fully finished operators in checkpoint

2021-03-11 Thread GitBox
gaoyunhaii edited a comment on pull request #14754: URL: https://github.com/apache/flink/pull/14754#issuecomment-797303630 Hi Roman @rkhachatryan , very thanks for the review! I updated the PR to address the comments. And very sorry for not pay attention to the test result... Now I fixed

[GitHub] [flink] gaoyunhaii commented on pull request #14754: [FLINK-21127][runtime][checkpoint] Stores finished status for fully finished operators in checkpoint

2021-03-11 Thread GitBox
gaoyunhaii commented on pull request #14754: URL: https://github.com/apache/flink/pull/14754#issuecomment-797303630 Hi Roman @rkhachatryan , very thanks for the review! I updated the PR to address the comments. And very sorry for not pay attention to the result... Now I fixed the issue vi

[GitHub] [flink] rkhachatryan commented on pull request #10847: [FLINK-15578][connectors/jdbc] implement exactly once JDBC sink

2021-03-11 Thread GitBox
rkhachatryan commented on pull request #10847: URL: https://github.com/apache/flink/pull/10847#issuecomment-797302969 The current transaction must be in `PREPARED` state by the time of `beginTx()` call, so `XAER_RMFAIL` shouldn't be thrown. Do you observe this behavior? If so, would you

[GitHub] [flink] gaoyunhaii commented on a change in pull request #14754: [FLINK-21127][runtime][checkpoint] Stores finished status for fully finished operators in checkpoint

2021-03-11 Thread GitBox
gaoyunhaii commented on a change in pull request #14754: URL: https://github.com/apache/flink/pull/14754#discussion_r592968789 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV3Serializer.java ## @@ -103,11 +105,16 @@ protected vo

[GitHub] [flink] KurtYoung commented on a change in pull request #15133: [FLINK-21621] [table-planner] Support TIMESTAMP_LTZ arithmetic

2021-03-11 Thread GitBox
KurtYoung commented on a change in pull request #15133: URL: https://github.com/apache/flink/pull/15133#discussion_r592966733 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala ## @@ -272,6 +

[GitHub] [flink] gaoyunhaii commented on a change in pull request #14754: [FLINK-21127][runtime][checkpoint] Stores finished status for fully finished operators in checkpoint

2021-03-11 Thread GitBox
gaoyunhaii commented on a change in pull request #14754: URL: https://github.com/apache/flink/pull/14754#discussion_r592967766 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/FullyFinishedOperatorState.java ## @@ -0,0 +1,43 @@ +/* + * Licensed to

[GitHub] [flink] wuchong commented on a change in pull request #15110: [FLINK-21579][table] Support "SHOW USER FUNCTIONS" statement

2021-03-11 Thread GitBox
wuchong commented on a change in pull request #15110: URL: https://github.com/apache/flink/pull/15110#discussion_r592966287 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java ## @@ -1108,11 +1109,20 @@ pri

[GitHub] [flink] flinkbot commented on pull request #15166: [hotfix][doc] fix Image rendering error in generating_watermarks.md

2021-03-11 Thread GitBox
flinkbot commented on pull request #15166: URL: https://github.com/apache/flink/pull/15166#issuecomment-797298557 ## CI report: * 3079f8c19c648129348c0e601d2816fa5ea5bc50 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15164: [FLINK-21645][FLINK-21646] Introduce StateDeclaration which could let the planner know the state description for an operator and supp

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

[GitHub] [flink] gaoyunhaii commented on a change in pull request #14754: [FLINK-21127][runtime][checkpoint] Stores finished status for fully finished operators in checkpoint

2021-03-11 Thread GitBox
gaoyunhaii commented on a change in pull request #14754: URL: https://github.com/apache/flink/pull/14754#discussion_r592964534 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/PendingCheckpoint.java ## @@ -308,6 +316,25 @@ public CompletedCheckpoin

[GitHub] [flink] flinkbot commented on pull request #15167: [BP-1.12][FLINK-21733][table-planner-blink] WatermarkAssigner incorrectly recomputing the rowtime index which may cause ArrayIndexOutOfBound

2021-03-11 Thread GitBox
flinkbot commented on pull request #15167: URL: https://github.com/apache/flink/pull/15167#issuecomment-797296030 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] weih1214 edited a comment on pull request #10847: [FLINK-15578][connectors/jdbc] implement exactly once JDBC sink

2021-03-11 Thread GitBox
weih1214 edited a comment on pull request #10847: URL: https://github.com/apache/flink/pull/10847#issuecomment-797293994 In JdbcXaSinkFunction class, When calling beginTx(), it will start a new transaction with a new XID, which will cause an Exception below `XAER_RMFAIL: The command c

[GitHub] [flink] wuchong opened a new pull request #15167: [BP-1.12][FLINK-21733][table-planner-blink] WatermarkAssigner incorrectly recomputing the rowtime index which may cause ArrayIndexOutOfBounds

2021-03-11 Thread GitBox
wuchong opened a new pull request #15167: URL: https://github.com/apache/flink/pull/15167 This is a cherry-pick backport to release-1.12 branch. This is an automated message from the Apache Git Service. To respond to the mess

[GitHub] [flink] weih1214 commented on pull request #10847: [FLINK-15578][connectors/jdbc] implement exactly once JDBC sink

2021-03-11 Thread GitBox
weih1214 commented on pull request #10847: URL: https://github.com/apache/flink/pull/10847#issuecomment-797293994 @Override public void snapshotState(FunctionSnapshotContext context) throws Exception { LOG.debug("snapshot state, checkpointId={}", context.getCheckpointId()

[jira] [Assigned] (FLINK-21355) Send changes to the state changelog (still proxy everything)

2021-03-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-21355: - Assignee: Roman Khachatryan > Send changes to the state changelog (still proxy

[jira] [Commented] (FLINK-21520) ParquetInputFormat#setfilterPredicate() does not work

2021-03-11 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300105#comment-17300105 ] Danny Chen commented on FLINK-21520: I'm working on Flink on Apache HUDI now, and we

[jira] [Commented] (FLINK-21733) WatermarkAssigner incorrectly recomputing the rowtime index which may cause ArrayIndexOutOfBoundsException

2021-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300102#comment-17300102 ] Jark Wu commented on FLINK-21733: - Fixed in - master: c2d9e69450e0a1bf14aa866ecdd8f5c3

[GitHub] [flink] wuchong merged pull request #15150: [FLINK-21733][table-planner-blink] WatermarkAssigner incorrectly recomputing the rowtime index which may cause ArrayIndexOutOfBoundsException

2021-03-11 Thread GitBox
wuchong merged pull request #15150: URL: https://github.com/apache/flink/pull/15150 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] [Commented] (FLINK-21739) TopN with TUMBLE window get Incorrect result

2021-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300100#comment-17300100 ] Jark Wu commented on FLINK-21739: - Currently, the output of this query is an updating st

[jira] [Comment Edited] (FLINK-21739) TopN with TUMBLE window get Incorrect result

2021-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300100#comment-17300100 ] Jark Wu edited comment on FLINK-21739 at 3/12/21, 7:19 AM: --- Cu

[jira] [Commented] (FLINK-21738) reduce unnecessary method calls in ModuleManager

2021-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300099#comment-17300099 ] Jark Wu commented on FLINK-21738: - yes. It is called 6 times, because the planner doesn'

[jira] [Commented] (FLINK-21738) reduce unnecessary method calls in ModuleManager

2021-03-11 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300097#comment-17300097 ] Jane Chan commented on FLINK-21738: --- Hi [~zoucao], I guess using the `json_tuple` late

[GitHub] [flink] leonardBang commented on a change in pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

2021-03-11 Thread GitBox
leonardBang commented on a change in pull request #15136: URL: https://github.com/apache/flink/pull/15136#discussion_r592955052 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/expressions/utils/ExpressionTestBase.scala ## @@ -1

[GitHub] [flink] wuchong commented on pull request #14840: [FLINK-21231][sql-client] add "SHOW VIEWS" to SQL client

2021-03-11 Thread GitBox
wuchong commented on pull request #14840: URL: https://github.com/apache/flink/pull/14840#issuecomment-797286110 Hi @yulei0824, we have a Flink Contributor Group in DingTalk where we discuss and communicate about Flink issues. Are you insterested to join it? The group id is 32621805. ---

[GitHub] [flink] flinkbot edited a comment on pull request #15155: [FLINK-21660][table-api-java][hive] Stop using is_generic to differen…

2021-03-11 Thread GitBox
flinkbot edited a comment on pull request #15155: URL: https://github.com/apache/flink/pull/15155#issuecomment-79675 ## CI report: * a88d48b0e0330b74133a2f664bf1300f204b1f11 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] leonardBang commented on a change in pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

2021-03-11 Thread GitBox
leonardBang commented on a change in pull request #15136: URL: https://github.com/apache/flink/pull/15136#discussion_r592953188 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/expressions/TemporalTypesTest.scala ## @@ -1122,6 +

[GitHub] [flink] flinkbot edited a comment on pull request #15153: [FLINK-21707][runtime] Do not trigger scheduling of non-CREATED regions in PipelinedRegionSchedulingStrategy

2021-03-11 Thread GitBox
flinkbot edited a comment on pull request #15153: URL: https://github.com/apache/flink/pull/15153#issuecomment-796722164 ## CI report: * 51356714415e233af381f7098579db127b673d8b Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15147: [FLINK-21730][table-planner-blink] Introduce ExecNodeTranslator

2021-03-11 Thread GitBox
flinkbot edited a comment on pull request #15147: URL: https://github.com/apache/flink/pull/15147#issuecomment-796572532 ## CI report: * 1c9aa13cb15cbe2d3e8195e4281a551898f1cfe9 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #15133: [FLINK-21621] [table-planner] Support TIMESTAMP_LTZ arithmetic

2021-03-11 Thread GitBox
flinkbot edited a comment on pull request #15133: URL: https://github.com/apache/flink/pull/15133#issuecomment-795031750 ## CI report: * 2a1a5b445b5bc332b356a985d6bce8746111af76 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] leonardBang commented on a change in pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

2021-03-11 Thread GitBox
leonardBang commented on a change in pull request #15136: URL: https://github.com/apache/flink/pull/15136#discussion_r592952977 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/expressions/TemporalTypesTest.scala ## @@ -262,6 +2

[GitHub] [flink] flinkbot edited a comment on pull request #14916: [FLINK-21345][Table SQL / Planner] Fix BUG of Union All join Temporal…

2021-03-11 Thread GitBox
flinkbot edited a comment on pull request #14916: URL: https://github.com/apache/flink/pull/14916#issuecomment-776614443 ## CI report: * 524bb7d945c6d7436f75020ec37381eb98efa6bc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-21689) UnalignedCheckpointITCase does not terminate

2021-03-11 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300096#comment-17300096 ] Matthias commented on FLINK-21689: -- [One finding|https://issues.apache.org/jira/browse

[GitHub] [flink] flinkbot commented on pull request #15166: [hotfix][doc] fix Image rendering error in generating_watermarks.md

2021-03-11 Thread GitBox
flinkbot commented on pull request #15166: URL: https://github.com/apache/flink/pull/15166#issuecomment-797283279 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-21689) UnalignedCheckpointITCase does not terminate

2021-03-11 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300093#comment-17300093 ] Matthias commented on FLINK-21689: -- Another timeout of {{UnalignedCheckpointITCase}}:

[GitHub] [flink] zhoulii opened a new pull request #15166: [hotfix][doc] fix Image rendering error in generating_watermarks.md

2021-03-11 Thread GitBox
zhoulii opened a new pull request #15166: URL: https://github.com/apache/flink/pull/15166 ## What is the purpose of the change fix [Image](https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/datastream/event-time/generating_watermarks/#watermark-strategies-and-the-kafka-c

[jira] [Updated] (FLINK-21702) Support option `sql-client.verbose` to print the exception stack

2021-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21702: Summary: Support option `sql-client.verbose` to print the exception stack (was: Support option `sql-clien

[GitHub] [flink] KurtYoung commented on a change in pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

2021-03-11 Thread GitBox
KurtYoung commented on a change in pull request #15136: URL: https://github.com/apache/flink/pull/15136#discussion_r592940636 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/expressions/TemporalTypesTest.scala ## @@ -262,6 +263

[GitHub] [flink] flinkbot edited a comment on pull request #15162: [FLINK-21728][core] Ensure cleaner is called at most once when unsafe…

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

[GitHub] [flink] flinkbot edited a comment on pull request #15155: [FLINK-21660][table-api-java][hive] Stop using is_generic to differen…

2021-03-11 Thread GitBox
flinkbot edited a comment on pull request #15155: URL: https://github.com/apache/flink/pull/15155#issuecomment-79675 ## CI report: * a88d48b0e0330b74133a2f664bf1300f204b1f11 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15133: [FLINK-21621] [table-planner] Support TIMESTAMP_LTZ arithmetic

2021-03-11 Thread GitBox
flinkbot edited a comment on pull request #15133: URL: https://github.com/apache/flink/pull/15133#issuecomment-795031750 ## CI report: * 2a1a5b445b5bc332b356a985d6bce8746111af76 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-21416) FileBufferReaderITCase.testSequentialReading fails on azure

2021-03-11 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300080#comment-17300080 ] Matthias commented on FLINK-21416: -- Another one: https://dev.azure.com/mapohl/flink/_bu

[jira] [Updated] (FLINK-21462) Use configuration to store the option and value in Sql client

2021-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21462: Description: In this jira, we will also deprecate the yaml file. This will also deprecate old configurati

[jira] [Updated] (FLINK-21728) DegreesWithExceptionITCase crash

2021-03-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21728: --- Fix Version/s: 1.13.0 > DegreesWithExceptionITCase crash >

[jira] [Updated] (FLINK-21702) Support option `sql-client.verbos` to print the exception stack

2021-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21702: Labels: starer (was: ) > Support option `sql-client.verbos` to print the exception stack > --

[jira] [Updated] (FLINK-21728) DegreesWithExceptionITCase crash

2021-03-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21728: --- Priority: Critical (was: Major) > DegreesWithExceptionITCase crash > --

[GitHub] [flink] rmetzger commented on pull request #15159: [FLINK-21136] Adjust timeouts for reactive mode

2021-03-11 Thread GitBox
rmetzger commented on pull request #15159: URL: https://github.com/apache/flink/pull/15159#issuecomment-797272559 Reported CI failure: https://issues.apache.org/jira/browse/FLINK-21728 This is an automated message from the Ap

[jira] [Updated] (FLINK-21701) Support "RESET key" statement in the SQL Client

2021-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21701: Summary: Support "RESET key" statement in the SQL Client (was: Extend the `RESET` command in the sql clie

[jira] [Updated] (FLINK-21701) Support "RESET key" statement in the SQL Client

2021-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21701: Labels: starter (was: ) > Support "RESET key" statement in the SQL Client > -

[jira] [Commented] (FLINK-21728) DegreesWithExceptionITCase crash

2021-03-11 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300075#comment-17300075 ] Robert Metzger commented on FLINK-21728: https://dev.azure.com/apache-flink/apac

[jira] [Updated] (FLINK-21703) Add option `table.dml-sync`

2021-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21703: Parent: (was: FLINK-21454) Issue Type: Bug (was: Sub-task) > Add option `table.dml-sync` > --

[jira] [Updated] (FLINK-16441) Allow users to override flink-conf parameters from SQL CLI environment

2021-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16441: Parent: (was: FLINK-21454) Issue Type: New Feature (was: Sub-task) > Allow users to override

[jira] [Updated] (FLINK-21466) Make "embedded" parameter optional when start sql-client.sh

2021-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21466: Labels: starter (was: ) > Make "embedded" parameter optional when start sql-client.sh > -

[jira] [Updated] (FLINK-21466) Make "embedded" parameter optional when start sql-client.sh

2021-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21466: Summary: Make "embedded" parameter optional when start sql-client.sh (was: Simplify the command to start

[jira] [Updated] (FLINK-21465) Extend explain syntax

2021-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21465: Parent: (was: FLINK-21454) Issue Type: Bug (was: Sub-task) > Extend explain syntax > ---

[jira] [Updated] (FLINK-16384) Support SHOW CREATE TABLE command in SQL Client and TableEnvironment

2021-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16384: Summary: Support SHOW CREATE TABLE command in SQL Client and TableEnvironment (was: Support SHOW CREATE T

[jira] [Updated] (FLINK-20562) Support ExplainDetails for EXPLAIN sytnax

2021-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20562: Description: Currently, {{EXPLAIN}} syntax only supports to print the default AST, logical plan, and phys

[jira] [Closed] (FLINK-21465) Extend explain syntax

2021-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21465. --- Resolution: Duplicate > Extend explain syntax > -- > > Key: FLINK-21465

[jira] [Updated] (FLINK-20562) Support ExplainDetails for EXPLAIN sytnax

2021-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20562: Parent: FLINK-21454 Issue Type: Sub-task (was: New Feature) > Support ExplainDetails for EXPLAIN

[GitHub] [flink] flinkbot edited a comment on pull request #15151: [FLINK-21727][hive] Support DDL in HiveParser

2021-03-11 Thread GitBox
flinkbot edited a comment on pull request #15151: URL: https://github.com/apache/flink/pull/15151#issuecomment-796646661 ## CI report: * 5c3eccb782dbbe802a4954cb16411ef18592ca12 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-21465) Extend explain syntax

2021-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21465: Component/s: Table SQL / Client > Extend explain syntax > -- > > Key:

[GitHub] [flink] flinkbot edited a comment on pull request #14916: [FLINK-21345][Table SQL / Planner] Fix BUG of Union All join Temporal…

2021-03-11 Thread GitBox
flinkbot edited a comment on pull request #14916: URL: https://github.com/apache/flink/pull/14916#issuecomment-776614443 ## CI report: * a73741521d25539ad684a8a02bb131e15eef7657 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-03-11 Thread GitBox
flinkbot edited a comment on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-766281483 ## CI report: * 2e05b89cd87ce4ba54de32eff3c68985f766180f UNKNOWN * 288129b58edfbe6928104e517e3e7243e4b6e0d2 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-21465) Extend explain syntax

2021-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21465: Description: Allow users to specify the ExplainDetails in statement. {code:sql} EXPLAIN [ExplainDetail[,

[jira] [Commented] (FLINK-21416) FileBufferReaderITCase.testSequentialReading fails on azure

2021-03-11 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300071#comment-17300071 ] Yun Tang commented on FLINK-21416: -- Another instance but failed with timeout https://m

[jira] [Created] (FLINK-21741) Support SHOW JARS statement in SQL Client

2021-03-11 Thread Jark Wu (Jira)
Jark Wu created FLINK-21741: --- Summary: Support SHOW JARS statement in SQL Client Key: FLINK-21741 URL: https://issues.apache.org/jira/browse/FLINK-21741 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21742) Support REMOVE JAR statement in SQL Client

2021-03-11 Thread Jark Wu (Jira)
Jark Wu created FLINK-21742: --- Summary: Support REMOVE JAR statement in SQL Client Key: FLINK-21742 URL: https://issues.apache.org/jira/browse/FLINK-21742 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-12828) Support -f option with a sql script file as input

2021-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-12828: Parent: FLINK-21454 Issue Type: Sub-task (was: New Feature) > Support -f option with a sql script

[jira] [Updated] (FLINK-12828) Support -f option with a sql script file as input

2021-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-12828: Parent: (was: FLINK-7594) Issue Type: New Feature (was: Sub-task) > Support -f option with a

[jira] [Updated] (FLINK-20557) Support "STATEMENT SET" in SQL CLI

2021-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20557: Summary: Support "STATEMENT SET" in SQL CLI (was: Support statement set in SQL CLI) > Support "STATEMENT

[jira] [Comment Edited] (FLINK-21706) FlinkKafkaProducerITCase.testMigrateFromAtExactlyOnceToAtLeastOnce fails with "SchemaException: Error reading field 'api_keys': Error reading field 'api_key': jav

2021-03-11 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300066#comment-17300066 ] Dong Lin edited comment on FLINK-21706 at 3/12/21, 6:11 AM:

[jira] [Commented] (FLINK-21706) FlinkKafkaProducerITCase.testMigrateFromAtExactlyOnceToAtLeastOnce fails with "SchemaException: Error reading field 'api_keys': Error reading field 'api_key': java.nio

2021-03-11 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300066#comment-17300066 ] Dong Lin commented on FLINK-21706: -- I have investigated this bug. The bug is not curren

[jira] [Assigned] (FLINK-21706) FlinkKafkaProducerITCase.testMigrateFromAtExactlyOnceToAtLeastOnce fails with "SchemaException: Error reading field 'api_keys': Error reading field 'api_key': java.nio.

2021-03-11 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-21706: Assignee: Dong Lin > FlinkKafkaProducerITCase.testMigrateFromAtExactlyOnceToAtLeastOnce f

[GitHub] [flink] flinkbot edited a comment on pull request #15165: [FLINK-16829] Refactored Prometheus Metric Reporters to Use Constructor Initialization

2021-03-11 Thread GitBox
flinkbot edited a comment on pull request #15165: URL: https://github.com/apache/flink/pull/15165#issuecomment-797238421 ## CI report: * eae248838033c396af043472ec2133dec40eafd5 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14916: [FLINK-21345][Table SQL / Planner] Fix BUG of Union All join Temporal…

2021-03-11 Thread GitBox
flinkbot edited a comment on pull request #14916: URL: https://github.com/apache/flink/pull/14916#issuecomment-776614443 ## CI report: * a73741521d25539ad684a8a02bb131e15eef7657 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-21740) CliTableauResultViewTest.testCancelBatchResult fails

2021-03-11 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-21740: -- Description: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=14500&view=logs&j=

[jira] [Created] (FLINK-21740) CliTableauResultViewTest.testCancelBatchResult fails

2021-03-11 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21740: - Summary: CliTableauResultViewTest.testCancelBatchResult fails Key: FLINK-21740 URL: https://issues.apache.org/jira/browse/FLINK-21740 Project: Flink Issue Type: B

[GitHub] [flink] flinkbot edited a comment on pull request #15161: [FLINK-20114][connector/kafka,common] Fix a few KafkaSource-related bugs

2021-03-11 Thread GitBox
flinkbot edited a comment on pull request #15161: URL: https://github.com/apache/flink/pull/15161#issuecomment-797177953 ## CI report: * 10afa89b37842487ecbcb3e4835d7919b35406c0 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15160: [FLINK-17441][kinesis][test-stability] Updating test to assert if timeout occurs waiting for records

2021-03-11 Thread GitBox
flinkbot edited a comment on pull request #15160: URL: https://github.com/apache/flink/pull/15160#issuecomment-797120120 ## CI report: * 8686ee1c5bad0c52753a3f791856963bd41506af Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15165: [FLINK-16829] Refactored Prometheus Metric Reporters to Use Constructor Initialization

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

[jira] [Commented] (FLINK-21416) FileBufferReaderITCase.testSequentialReading fails on azure

2021-03-11 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300059#comment-17300059 ] Guowei Ma commented on FLINK-21416: --- another case: https://dev.azure.com/apache-flink/

[jira] [Commented] (FLINK-21738) reduce unnecessary method calls in ModuleManager

2021-03-11 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300058#comment-17300058 ] zoucao commented on FLINK-21738: hi [~qingyue] and [~jark], thanks for your quick reply,

[GitHub] [flink] flinkbot commented on pull request #15165: [FLINK-16829] Refactored Prometheus Metric Reporters to Use Constructor Initialization

2021-03-11 Thread GitBox
flinkbot commented on pull request #15165: URL: https://github.com/apache/flink/pull/15165#issuecomment-797238421 ## CI report: * eae248838033c396af043472ec2133dec40eafd5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] rionmonster edited a comment on pull request #15165: [FLINK-16829] Refactored Prometheus Metric Reporters to Use Constructor Initialization

2021-03-11 Thread GitBox
rionmonster edited a comment on pull request #15165: URL: https://github.com/apache/flink/pull/15165#issuecomment-797233206 @zentol / @tillrohrmann I through together what a draft of these changes might look like. It was roughly modeled after the `JmxReporter` implementation which s

[GitHub] [flink] rionmonster commented on pull request #15165: [FLINK-16829] Refactored Prometheus Metric Reporters to Use Constructor Initialization

2021-03-11 Thread GitBox
rionmonster commented on pull request #15165: URL: https://github.com/apache/flink/pull/15165#issuecomment-797233206 @zentol I through together what a draft of these changes might look like. It was roughly modeled after the `JmxReporter` implementation which seemed to do something

[GitHub] [flink] flinkbot commented on pull request #15165: [FLINK-16829] Refactored Prometheus Metric Reporters to Use Constructor Initialization

2021-03-11 Thread GitBox
flinkbot commented on pull request #15165: URL: https://github.com/apache/flink/pull/15165#issuecomment-797232381 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 #15147: [FLINK-21730][table-planner-blink] Introduce ExecNodeTranslator

2021-03-11 Thread GitBox
flinkbot edited a comment on pull request #15147: URL: https://github.com/apache/flink/pull/15147#issuecomment-796572532 ## CI report: * 4feee9044de0e88f3c6669b40ff528f85eec5677 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-16829) Pass PrometheusReporter arguments via constructor

2021-03-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16829: --- Labels: pull-request-available starter (was: starter) > Pass PrometheusReporter arguments v

[jira] [Created] (FLINK-21739) TopN with TUMBLE window get Incorrect result

2021-03-11 Thread wxmimperio (Jira)
wxmimperio created FLINK-21739: -- Summary: TopN with TUMBLE window get Incorrect result Key: FLINK-21739 URL: https://issues.apache.org/jira/browse/FLINK-21739 Project: Flink Issue Type: Bug

[GitHub] [flink] rionmonster opened a new pull request #15165: [FLINK-16829] Refactored Prometheus Metric Reporters to Use Constructor Initialization

2021-03-11 Thread GitBox
rionmonster opened a new pull request #15165: URL: https://github.com/apache/flink/pull/15165 ## What is the purpose of the change Clean-up for the initialization of the two Prometheus Metric Reporters (`PrometheusReporter` and `PrometheusPushGatewayReporter`) by explicitly passing

[GitHub] [flink] flinkbot edited a comment on pull request #15164: [FLINK-21645][FLINK-21646] Introduce StateDeclaration which could let the planner know the state description for an operator and supp

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

[jira] [Updated] (FLINK-21463) Unify SQL Client parser and TableEnvironment parser

2021-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21463: Priority: Critical (was: Major) > Unify SQL Client parser and TableEnvironment parser > -

[jira] [Updated] (FLINK-21463) Unify SQL Client parser and TableEnvironment parser

2021-03-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21463: Summary: Unify SQL Client parser and TableEnvironment parser (was: Refactor client parser) > Unify SQL C

[jira] [Closed] (FLINK-21624) Correct FLOOR/CEIL (TIMESTAMP/TIMESTAMP_LTZ/DATE TO WEEK) functions

2021-03-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-21624. -- Fix Version/s: 1.13.0 Resolution: Fixed fixed with: 615d5d150abdeab89d15f6830177eac238bdc2fc >

  1   2   3   4   5   6   >