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

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

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

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

[GitHub] [flink] wuchong commented on pull request #15144: [FLINK-21709][table] Officially deprecate the legacy planner

2021-03-10 Thread GitBox
wuchong commented on pull request #15144: URL: https://github.com/apache/flink/pull/15144#issuecomment-796543528 We just introduced `table.planner` option, maybe we should also add deprecation information on the docs. https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/table/co

[GitHub] [flink] flinkbot edited a comment on pull request #15134: [FLINK-21654][test] Added @throws information to tests

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

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

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

[GitHub] [flink] flinkbot edited a comment on pull request #15088: [FLINK-21328] Optimize the initialization of DefaultExecutionTopology

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

[GitHub] [flink] wuchong commented on a change in pull request #15006: [FLINK-21485][sql-client] Simplify the ExecutionContext

2021-03-10 Thread GitBox
wuchong commented on a change in pull request #15006: URL: https://github.com/apache/flink/pull/15006#discussion_r592119863 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/context/DefaultContext.java ## @@ -0,0 +1,296 @@ +/* + * L

[jira] [Updated] (FLINK-21731) Add benchmarks for DefaultScheduler#startScheduling

2021-03-10 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-21731: - Summary: Add benchmarks for DefaultScheduler#startScheduling (was: Add a benchmark for DefaultS

[jira] [Created] (FLINK-21731) Add a benchmark for DefaultScheduler#startScheduling

2021-03-10 Thread Zhilong Hong (Jira)
Zhilong Hong created FLINK-21731: Summary: Add a benchmark for DefaultScheduler#startScheduling Key: FLINK-21731 URL: https://issues.apache.org/jira/browse/FLINK-21731 Project: Flink Issue Ty

[GitHub] [flink] XComp commented on pull request #15134: [FLINK-21654][test] Added @throws information to tests

2021-03-10 Thread GitBox
XComp commented on pull request #15134: URL: https://github.com/apache/flink/pull/15134#issuecomment-796530551 I left the commits unsquashed for now to be transparent on the test runs as well. This is an automated message fr

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

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

[GitHub] [flink] flinkbot edited a comment on pull request #15112: [FLINK-21480][runtime] Respect external resources from resource requirements

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

[GitHub] [flink] flinkbot edited a comment on pull request #15088: [FLINK-21328] Optimize the initialization of DefaultExecutionTopology

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

[GitHub] [flink] flinkbot edited a comment on pull request #15006: [FLINK-21485][sql-client] Simplify the ExecutionContext

2021-03-10 Thread GitBox
flinkbot edited a comment on pull request #15006: URL: https://github.com/apache/flink/pull/15006#issuecomment-785114095 ## CI report: * 4cd5563d44a62aec2b8db80cfe8da650fddf4ffa UNKNOWN * 83446f3a0e26473892f97f68de12b5f4a8e50cc5 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Created] (FLINK-21730) Introduce ExecNodeTranslator

2021-03-10 Thread godfrey he (Jira)
godfrey he created FLINK-21730: -- Summary: Introduce ExecNodeTranslator Key: FLINK-21730 URL: https://issues.apache.org/jira/browse/FLINK-21730 Project: Flink Issue Type: Sub-task Compo

[GitHub] [flink] flinkbot edited a comment on pull request #14784: [FLINK-21160][connector/kafka] Fix bug of referencing uninitialized deserializer when using KafkaRecordDeserializer#valueOnly

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

[GitHub] [flink] XComp commented on pull request #15134: [FLINK-21654][test] Added @throws information to tests

2021-03-10 Thread GitBox
XComp commented on pull request #15134: URL: https://github.com/apache/flink/pull/15134#issuecomment-796527987 I tried reproducing the failure first in [this build](https://dev.azure.com/mapohl/flink/_build/results?buildId=331&view=results) with [4515bd2](https://github.com/XComp/flink/co

[jira] [Assigned] (FLINK-21697) Support StreamExecMiniBatchAssigner json serialization/deserialization

2021-03-10 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-21697: -- Assignee: godfrey he > Support StreamExecMiniBatchAssigner json serialization/deserialization

[jira] [Assigned] (FLINK-21704) Support StreamExecChangelogNormalize json serde

2021-03-10 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-21704: -- Assignee: Wenlong Lyu > Support StreamExecChangelogNormalize json serde > ---

[jira] [Updated] (FLINK-21704) Support StreamExecChangelogNormalize json serde

2021-03-10 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-21704: --- Component/s: Table SQL / Planner > Support StreamExecChangelogNormalize json serde > ---

[jira] [Updated] (FLINK-21704) Support StreamExecChangelogNormalize json serde

2021-03-10 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-21704: --- Fix Version/s: 1.13.0 > Support StreamExecChangelogNormalize json serde > --

[GitHub] [flink] AHeise merged pull request #15139: [BP-1.12][hotfix][connectors/kafka] Correctly check required configs in KafkaSourceBuilder

2021-03-10 Thread GitBox
AHeise merged pull request #15139: URL: https://github.com/apache/flink/pull/15139 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] AHeise commented on pull request #15139: [BP-1.12][hotfix][connectors/kafka] Correctly check required configs in KafkaSourceBuilder

2021-03-10 Thread GitBox
AHeise commented on pull request #15139: URL: https://github.com/apache/flink/pull/15139#issuecomment-796517842 Test failure is unrelated (FLINK-21647). Merging. Thanks again. This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on pull request #15145: [FLINK-21177][runtime] Support limiting max resources with FineGrainedSlotManager

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

[GitHub] [flink] flinkbot edited a comment on pull request #15144: [FLINK-21709][table] Officially deprecate the legacy planner

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

[GitHub] [flink] WeiZhong94 commented on a change in pull request #15130: [FLINK-21632][python] Add NamespacedStateView and PerWindowStateDataViewStore

2021-03-10 Thread GitBox
WeiZhong94 commented on a change in pull request #15130: URL: https://github.com/apache/flink/pull/15130#discussion_r592109738 ## File path: flink-python/pyflink/fn_execution/state_data_view.py ## @@ -99,9 +114,35 @@ def __hash__(self) -> int: return hash([i for i in s

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #14784: [FLINK-21160][connector/kafka] Fix bug of referencing uninitialized deserializer when using KafkaRecordDeserializer#valueOnly

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

[GitHub] [flink] flinkbot edited a comment on pull request #13845: [FLINK-19801] Adding virtual channels for rescaling unaligned checkpoints.

2021-03-10 Thread GitBox
flinkbot edited a comment on pull request #13845: URL: https://github.com/apache/flink/pull/13845#issuecomment-718853990 ## CI report: * f63fa7264bda0bafc3e97ac79b920eb34cae3e95 UNKNOWN * 3d418c42a5ffe60a99d17a22a6aaba9955e347f9 UNKNOWN * 6cc4a796b26b66b761f50730f7534c36afad

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

2021-03-10 Thread GitBox
LinyuYao1021 edited a comment on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-795179693 This is my pipeline, directly to run my commit to see what's the problem: -https://dev.azure.com/yaolinyu3547/PrivateFlink/_build/results?buildId=5&view=result

[GitHub] [flink] PatrickRen commented on pull request #14784: [FLINK-21160][connector/kafka] Fix bug of referencing uninitialized deserializer when using KafkaRecordDeserializer#valueOnly

2021-03-10 Thread GitBox
PatrickRen commented on pull request #14784: URL: https://github.com/apache/flink/pull/14784#issuecomment-796507472 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [flink] PatrickRen commented on pull request #14784: [FLINK-21160][connector/kafka] Fix bug of referencing uninitialized deserializer when using KafkaRecordDeserializer#valueOnly

2021-03-10 Thread GitBox
PatrickRen commented on pull request #14784: URL: https://github.com/apache/flink/pull/14784#issuecomment-796507360 I investigated two Azure builds and both two CI failure are caused by E2E tests. The first E2E run was timed out, and the second one failed because of a K8S session test, loo

[GitHub] [flink-statefun] tzulitai closed pull request #212: [FLINK-21721] Add EgressMessageBuilder

2021-03-10 Thread GitBox
tzulitai closed pull request #212: URL: https://github.com/apache/flink-statefun/pull/212 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

[GitHub] [flink-statefun] tzulitai commented on pull request #212: [FLINK-21721] Add EgressMessageBuilder

2021-03-10 Thread GitBox
tzulitai commented on pull request #212: URL: https://github.com/apache/flink-statefun/pull/212#issuecomment-796505407 LGTM! Merging. This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot commented on pull request #15144: [FLINK-21709][table] Officially deprecate the legacy planner

2021-03-10 Thread GitBox
flinkbot commented on pull request #15144: URL: https://github.com/apache/flink/pull/15144#issuecomment-796504890 ## CI report: * 8e5fd7e2561b85cd669e95fc172097925040e96a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #15145: [FLINK-21177][runtime] Support limiting max resources with FineGrainedSlotManager

2021-03-10 Thread GitBox
flinkbot commented on pull request #15145: URL: https://github.com/apache/flink/pull/15145#issuecomment-796504968 ## CI report: * 5188e3beafda857725ef62ff7fec7760822f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

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

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

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

2021-03-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21689: --- Priority: Critical (was: Major) > UnalignedCheckpointITCase does not terminate > --

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

2021-03-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17299338#comment-17299338 ] Robert Metzger commented on FLINK-21689: https://dev.azure.com/rmetzger/Flink/_b

[GitHub] [flink] flinkbot commented on pull request #15145: [FLINK-21177][runtime] Support limiting max resources with FineGrainedSlotManager

2021-03-10 Thread GitBox
flinkbot commented on pull request #15145: URL: https://github.com/apache/flink/pull/15145#issuecomment-796495918 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 #15006: [FLINK-21485][sql-client] Simplify the ExecutionContext

2021-03-10 Thread GitBox
flinkbot edited a comment on pull request #15006: URL: https://github.com/apache/flink/pull/15006#issuecomment-785114095 ## CI report: * 4cd5563d44a62aec2b8db80cfe8da650fddf4ffa UNKNOWN * 83446f3a0e26473892f97f68de12b5f4a8e50cc5 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot commented on pull request #15144: [FLINK-21709][table] Officially deprecate the legacy planner

2021-03-10 Thread GitBox
flinkbot commented on pull request #15144: URL: https://github.com/apache/flink/pull/15144#issuecomment-796494984 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 #15098: [FLINK-21396][table-common] Add ResolvedCatalog(View/Table) and Catalog(View/Table).of

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

[GitHub] [flink] xintongsong commented on pull request #15145: [FLINK-21177][runtime] Support limiting max resources with FineGrainedSlotManager

2021-03-10 Thread GitBox
xintongsong commented on pull request #15145: URL: https://github.com/apache/flink/pull/15145#issuecomment-796494374 cc @KarmaGYZ This is an automated message from the Apache Git Service. To respond to the message, please lo

[jira] [Updated] (FLINK-21177) Introduce the counterpart of slotmanager.number-of-slots.max in fine-grained resource management

2021-03-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21177: --- Labels: pull-request-available (was: ) > Introduce the counterpart of slotmanager.number-of

[GitHub] [flink] xintongsong opened a new pull request #15145: [FLINK-21177][runtime] Support limiting max resources with FineGrainedSlotManager

2021-03-10 Thread GitBox
xintongsong opened a new pull request #15145: URL: https://github.com/apache/flink/pull/15145 ## 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 the

[jira] [Created] (FLINK-21729) SimpleRecoveryFailureRateStrategyITBase fail

2021-03-10 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21729: - Summary: SimpleRecoveryFailureRateStrategyITBase fail Key: FLINK-21729 URL: https://issues.apache.org/jira/browse/FLINK-21729 Project: Flink Issue Type: Bug

[GitHub] [flink] twalthr commented on pull request #15144: [FLINK-21709][table] Officially deprecate the legacy planner

2021-03-10 Thread GitBox
twalthr commented on pull request #15144: URL: https://github.com/apache/flink/pull/15144#issuecomment-796488490 CC @sjwiesman? This is an automated message from the Apache Git Service. To respond to the message, please log o

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

2021-03-10 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21728: - Summary: DegreesWithExceptionITCase crash Key: FLINK-21728 URL: https://issues.apache.org/jira/browse/FLINK-21728 Project: Flink Issue Type: Bug Componen

[jira] [Updated] (FLINK-21709) Officially deprecate the legacy planner

2021-03-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21709: --- Labels: pull-request-available (was: ) > Officially deprecate the legacy planner >

[GitHub] [flink] twalthr opened a new pull request #15144: [FLINK-21709][table] Officially deprecate the legacy planner

2021-03-10 Thread GitBox
twalthr opened a new pull request #15144: URL: https://github.com/apache/flink/pull/15144 ## What is the purpose of the change This deprecates the legacy planner in Java, Scala and Python API. It adds a warning to the documentation. ## Brief change log Add deprecation w

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

2021-03-10 Thread GitBox
wuchong commented on a change in pull request #15110: URL: https://github.com/apache/flink/pull/15110#discussion_r592087892 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ShowFunctionsOperation.java ## @@ -18,11 +18,21 @@ pack

[jira] [Created] (FLINK-21727) Support DDL in HiveParser

2021-03-10 Thread Rui Li (Jira)
Rui Li created FLINK-21727: -- Summary: Support DDL in HiveParser Key: FLINK-21727 URL: https://issues.apache.org/jira/browse/FLINK-21727 Project: Flink Issue Type: Sub-task Components: Conn

[jira] [Commented] (FLINK-21329) "Local recovery and sticky scheduling end-to-end test" does not finish within 600 seconds

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

[jira] [Assigned] (FLINK-21725) DataTypeExtractor extracts wrong fields ordering for Tuple12

2021-03-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-21725: Assignee: Timo Walther > DataTypeExtractor extracts wrong fields ordering for Tuple12 > -

[GitHub] [flink] flinkbot edited a comment on pull request #15098: [FLINK-21396][table-common] Add ResolvedCatalog(View/Table) and Catalog(View/Table).of

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

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

2021-03-10 Thread GitBox
yulei0824 commented on a change in pull request #15110: URL: https://github.com/apache/flink/pull/15110#discussion_r592082287 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ShowFunctionsOperation.java ## @@ -18,11 +18,21 @@ pa

[GitHub] [flink] KarmaGYZ commented on pull request #15112: [FLINK-21480][runtime] Respect external resources from resource requirements

2021-03-10 Thread GitBox
KarmaGYZ commented on pull request #15112: URL: https://github.com/apache/flink/pull/15112#issuecomment-796473222 @xintongsong Thanks for the review! PR updated. This is an automated message from the Apache Git Service. To re

[GitHub] [flink] twalthr commented on a change in pull request #15124: [FLINK-21620][table-api / sql-parser ] Support abbreviation TIMESTAMP_LTZ FOR TIMESTAMP WITH LOCAL TIME ZONE

2021-03-10 Thread GitBox
twalthr commented on a change in pull request #15124: URL: https://github.com/apache/flink/pull/15124#discussion_r592080944 ## File path: flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl ## @@ -1095,6 +1097,16 @@ SqlTypeNameSpec ExtendedSqlBasicTypeName()

[jira] [Comment Edited] (FLINK-21511) Flink connector elasticsearch 6.x has a bug about BulkProcessor hangs for threads deadlocked

2021-03-10 Thread zhangmeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17299316#comment-17299316 ] zhangmeng edited comment on FLINK-21511 at 3/11/21, 5:39 AM: -

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

2021-03-10 Thread GitBox
curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r592078898 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/resources/log4j2.properties ## @@ -0,0 +1,28 @@ +

[GitHub] [flink] twalthr commented on pull request #15098: [FLINK-21396][table-common] Add ResolvedCatalog(View/Table) and Catalog(View/Table).of

2021-03-10 Thread GitBox
twalthr commented on pull request #15098: URL: https://github.com/apache/flink/pull/15098#issuecomment-796470427 @Airblader I updated the PR. I hope I addressed your feedback. This is an automated message from the Apache Git

[jira] [Commented] (FLINK-21511) Flink connector elasticsearch 6.x has a bug about BulkProcessor hangs for threads deadlocked

2021-03-10 Thread zhangmeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17299316#comment-17299316 ] zhangmeng commented on FLINK-21511: --- [~karmagyz], thanks for you advice, I have runnin

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

2021-03-10 Thread GitBox
curcur commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r592078898 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/resources/log4j2.properties ## @@ -0,0 +1,28 @@ +

[jira] [Commented] (FLINK-21511) Flink connector elasticsearch 6.x has a bug about BulkProcessor hangs for threads deadlocked

2021-03-10 Thread zhangmeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17299315#comment-17299315 ] zhangmeng commented on FLINK-21511: --- @[~AHeise] thanks a lot, I have submit a pr [G

[GitHub] [flink] flinkbot edited a comment on pull request #15051: [FLINK-20379][connector/kafka] Update KafkaRecordDeserializationSchema to enable reuse of DeserializationSchema and KafkaDeserializat

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

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

2021-03-10 Thread GitBox
wuchong commented on a change in pull request #15133: URL: https://github.com/apache/flink/pull/15133#discussion_r592071263 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala ## @@ -224,28 +2

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #15006: [FLINK-21485][sql-client] Simplify the ExecutionContext

2021-03-10 Thread GitBox
flinkbot edited a comment on pull request #15006: URL: https://github.com/apache/flink/pull/15006#issuecomment-785114095 ## CI report: * 4cd5563d44a62aec2b8db80cfe8da650fddf4ffa UNKNOWN * 83446f3a0e26473892f97f68de12b5f4a8e50cc5 Azure: [FAILURE](https://dev.azure.com/apache-fl

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #15006: [FLINK-21485][sql-client] Simplify the ExecutionContext

2021-03-10 Thread GitBox
flinkbot edited a comment on pull request #15006: URL: https://github.com/apache/flink/pull/15006#issuecomment-785114095 ## CI report: * 4cd5563d44a62aec2b8db80cfe8da650fddf4ffa UNKNOWN * f5721f1c1aedfb0c344a14dfbecdbc8f6dff665d Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15143: [FLINK-20938] Flink cos fs hadoop feature

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

[GitHub] [flink] flinkbot edited a comment on pull request #15117: [FLINK-21655] [table-planner-blink] Fix incorrect simplification for coalesce call on a groupingsets' result

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

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

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

[jira] [Commented] (FLINK-21103) E2e tests time out on azure

2021-03-10 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17299296#comment-17299296 ] Guowei Ma commented on FLINK-21103: --- another case in the 1.12 https://dev.azure.com/a

[jira] [Updated] (FLINK-21726) Fix checkpoint stuck

2021-03-10 Thread fanrui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fanrui updated FLINK-21726: --- Description: h1. 1. Bug description: When RocksDB Checkpoint, it may be stuck in `WaitUntilFlushWouldNotSta

[jira] [Updated] (FLINK-21726) Fix checkpoint stuck

2021-03-10 Thread fanrui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fanrui updated FLINK-21726: --- Component/s: Runtime / Checkpointing > Fix checkpoint stuck > > > Key:

[jira] [Created] (FLINK-21726) Fix checkpoint stuck

2021-03-10 Thread fanrui (Jira)
fanrui created FLINK-21726: -- Summary: Fix checkpoint stuck Key: FLINK-21726 URL: https://issues.apache.org/jira/browse/FLINK-21726 Project: Flink Issue Type: Bug Components: Runtime / Stat

[GitHub] [flink] flinkbot edited a comment on pull request #15143: [FLINK-20938] Flink cos fs hadoop feature

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

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

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

[GitHub] [flink] flinkbot edited a comment on pull request #15117: [FLINK-21655] [table-planner-blink] Fix incorrect simplification for coalesce call on a groupingsets' result

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

[jira] [Commented] (FLINK-21707) Job is possible to hang when restarting a FINISHED task with POINTWISE BLOCKING consumers

2021-03-10 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17299293#comment-17299293 ] Zhu Zhu commented on FLINK-21707: - Agreed to "removing this logic from the Intermediate

[jira] [Commented] (FLINK-21725) DataTypeExtractor extracts wrong fields ordering for Tuple12

2021-03-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17299294#comment-17299294 ] Jark Wu commented on FLINK-21725: - cc [~twalthr] > DataTypeExtractor extracts wrong fie

[jira] [Created] (FLINK-21725) DataTypeExtractor extracts wrong fields ordering for Tuple12

2021-03-10 Thread Jark Wu (Jira)
Jark Wu created FLINK-21725: --- Summary: DataTypeExtractor extracts wrong fields ordering for Tuple12 Key: FLINK-21725 URL: https://issues.apache.org/jira/browse/FLINK-21725 Project: Flink Issue Typ

[jira] [Commented] (FLINK-21578) Closeable Sink Committer/GlobalCommitter were created to function in onestep during job graph composition

2021-03-10 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17299284#comment-17299284 ] Kezhu Wang commented on FLINK-21578: Hi [~gaoyunhaii], in current situation there is

[GitHub] [flink] flinkbot commented on pull request #15143: [FLINK-20938] Flink cos fs hadoop feature

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

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

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

[GitHub] [flink] flinkbot edited a comment on pull request #15112: [FLINK-21480][runtime] Respect external resources from resource requirements

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

[GitHub] [flink] flinkbot edited a comment on pull request #15117: [FLINK-21655] [table-planner-blink] Fix incorrect simplification for coalesce call on a groupingsets' result

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

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

2021-03-10 Thread GitBox
wuchong commented on a change in pull request #15110: URL: https://github.com/apache/flink/pull/15110#discussion_r592044710 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ShowFunctionsOperation.java ## @@ -18,11 +18,21 @@ pack

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

2021-03-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20938: --- Labels: pull-request-available (was: ) > Implement Flink's own tencent COS filesystem > ---

[GitHub] [flink] flinkbot commented on pull request #15143: [FLINK-20938] Flink cos fs hadoop feature

2021-03-10 Thread GitBox
flinkbot commented on pull request #15143: URL: https://github.com/apache/flink/pull/15143#issuecomment-796418105 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] [Resolved] (FLINK-21690) remove redundant tolerableCheckpointFailureNumber setting in CheckpointConfig

2021-03-10 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-21690. -- Fix Version/s: 1.12.3 Resolution: Fixed > remove redundant tolerableCheckpointFailureNumber set

[jira] [Commented] (FLINK-21690) remove redundant tolerableCheckpointFailureNumber setting in CheckpointConfig

2021-03-10 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17299275#comment-17299275 ] Yun Tang commented on FLINK-21690: -- merged master: bfb1451c8b8451b8e5e9532781338bac908

[GitHub] [flink] haydenzhourepo opened a new pull request #15143: Flink cos fs hadoop feature

2021-03-10 Thread GitBox
haydenzhourepo opened a new pull request #15143: URL: https://github.com/apache/flink/pull/15143 ## What is the purpose of the change This PR will add an implementation of a file system that read from & write to Tencent's COS so that users can use COS with Flink without depe

[jira] [Updated] (FLINK-21294) Support state access API for the map/flat_map operation of Python ConnectedStreams

2021-03-10 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-21294: -- Summary: Support state access API for the map/flat_map operation of Python ConnectedStreams (was: Sup

[GitHub] [flink] flinkbot edited a comment on pull request #15112: [FLINK-21480][runtime] Respect external resources from resource requirements

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

[jira] [Commented] (FLINK-21436) Speed ​​up the restore of UnionListState

2021-03-10 Thread fanrui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17299267#comment-17299267 ] fanrui commented on FLINK-21436: [~yunta] Thanks for your comments.  I have read FLINK-

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

2021-03-10 Thread GitBox
yulei0824 commented on a change in pull request #15110: URL: https://github.com/apache/flink/pull/15110#discussion_r592039097 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ShowFunctionsOperation.java ## @@ -18,11 +18,21 @@ pa

[jira] [Closed] (FLINK-21242) Support state access API for the map/flat_map/filter/reduce operations of Python KeyedStream

2021-03-10 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong closed FLINK-21242. - Resolution: Fixed > Support state access API for the map/flat_map/filter/reduce operations of > Python

  1   2   3   4   5   >