[GitHub] [flink] leonardBang commented on pull request #14152: [FLINK-19082][doc] Add docs for temporal table and temporal table join

leonardBang commented on pull request #14152: URL: https://github.com/apache/flink/pull/14152#issuecomment-733534487 Hi, @dawidwys @sjwiesman I've rebase and fix the conflicts, appreciate if you have a more look. This is an

[jira] [Updated] (FLINK-20326) Broken links to "How to define LookupableTableSource"

[ https://issues.apache.org/jira/browse/FLINK-20326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-20326: - Description: I found at least two pages that have a link to a non-existing anchor: * ht

[jira] [Commented] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

[ https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238586#comment-17238586 ] Matthias commented on FLINK-19863: -- And another one happened on master today:  [2020112

[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=17238585#comment-17238585 ] Arvid Heise commented on FLINK-20331: - This ticket is most likely a real bug. I hope

[GitHub] [flink] flinkbot commented on pull request #14210: [FLINK-20328][tests] Fixed buffer calculation in UnalignedCheckpointITCase.

flinkbot commented on pull request #14210: URL: https://github.com/apache/flink/pull/14210#issuecomment-733527507 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-20328) UnalignedCheckpointITCase.execute failed with "Insufficient number of network buffers: required 1, but only 0 available"

[ https://issues.apache.org/jira/browse/FLINK-20328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20328: --- Labels: pull-request-available test-stability (was: test-stability) > UnalignedCheckpointIT

[jira] [Commented] (FLINK-20309) UnalignedCheckpointTestBase.execute is failed

[ https://issues.apache.org/jira/browse/FLINK-20309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238580#comment-17238580 ] Dian Fu commented on FLINK-20309: - [~AHeise] Thanks a lot~ > UnalignedCheckpointTestBas

[GitHub] [flink] AHeise opened a new pull request #14210: [FLINK-20328][tests] Fixed buffer calculation in UnalignedCheckpointITCase.

AHeise opened a new pull request #14210: URL: https://github.com/apache/flink/pull/14210 ## What is the purpose of the change For low parallelism, recovery competed with regular task creation for the buffers. ## Brief change log - Fixed calculation.

[GitHub] [flink] flinkbot commented on pull request #14209: [FLINK-20297] Make SerializerTestBase::getTestData return List

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

[GitHub] [flink] flinkbot commented on pull request #14208: [FLINK-20338] Make the `StatefulSinkWriterOperator` load `StreamingFileSink`'s state.

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

[GitHub] [flink] flinkbot edited a comment on pull request #14207: [FLINK-20250][table-runtime] NPE when invoking AsyncLookupJoinRunner#close method

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

[GitHub] [flink] flinkbot edited a comment on pull request #14206: [FLINK-20314][planner] Add rule to remove empty calc

flinkbot edited a comment on pull request #14206: URL: https://github.com/apache/flink/pull/14206#issuecomment-733458079 ## CI report: * 0a06b6ce2f629cd6fdea5ab86b67bf2a855a90e8 UNKNOWN * fe867e4f487096c5908ebace4e20b4f2f6b98677 Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14201: [FLINK-20322][table-planner-blink] Rename union-all-as-breakpoint configuration and change the default value

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

[GitHub] [flink] flinkbot edited a comment on pull request #14191: [FLINK-20310][doc] Add documentation for Debezium, Canal, Raw support for Filesystem connector

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

[GitHub] [flink] flinkbot edited a comment on pull request #14160: [FLINK-19795][table-blink] Fix Flink SQL throws exception when changelog source contains duplicate change events

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

[GitHub] [flink] flinkbot edited a comment on pull request #14116: [FLINK-20213][fs-connector] Partition commit is delayed when records keep coming

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

[jira] [Commented] (FLINK-20309) UnalignedCheckpointTestBase.execute is failed

[ https://issues.apache.org/jira/browse/FLINK-20309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238568#comment-17238568 ] Arvid Heise commented on FLINK-20309: - I tracked down the issue to be related by dup

[jira] [Closed] (FLINK-19027) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnParallelRemoteChannel failed because of test timeout

[ https://issues.apache.org/jira/browse/FLINK-19027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-19027. --- Resolution: Fixed > UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnParallelRemoteChanne

[jira] [Commented] (FLINK-19027) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnParallelRemoteChannel failed because of test timeout

[ https://issues.apache.org/jira/browse/FLINK-19027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238565#comment-17238565 ] Arvid Heise commented on FLINK-19027: - Same underlying issue as FLINK-20309, so trac

[GitHub] [flink] SteNicholas commented on a change in pull request #13983: [FLINK-19989][python] Add collect operation in Python DataStream API

SteNicholas commented on a change in pull request #13983: URL: https://github.com/apache/flink/pull/13983#discussion_r530141360 ## File path: flink-python/pyflink/datastream/utils.py ## @@ -0,0 +1,75 @@ +##

[GitHub] [flink] flinkbot commented on pull request #14209: [FLINK-20297] Make SerializerTestBase::getTestData return List

flinkbot commented on pull request #14209: URL: https://github.com/apache/flink/pull/14209#issuecomment-733512879 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-20297) Make `SerializerTestBase::getTestData` return List

[ https://issues.apache.org/jira/browse/FLINK-20297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20297: --- Labels: pull-request-available (was: ) > Make `SerializerTestBase::getTestData` return List

[GitHub] [flink] guoweiM opened a new pull request #14209: [FLINK-20297] Make SerializerTestBase::getTestData return List

guoweiM opened a new pull request #14209: URL: https://github.com/apache/flink/pull/14209 ## What is the purpose of the change For making the developer write scala serializer test based on 'SerializerTestBase' the patch makes SerializerTestBase::getTestData return List.

[GitHub] [flink] flinkbot commented on pull request #14207: [FLINK-20250][table-runtime] NPE when invoking AsyncLookupJoinRunner#close method

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

[GitHub] [flink] flinkbot edited a comment on pull request #14206: [FLINK-20314][planner] Add rule to remove empty calc

flinkbot edited a comment on pull request #14206: URL: https://github.com/apache/flink/pull/14206#issuecomment-733458079 ## CI report: * 0a06b6ce2f629cd6fdea5ab86b67bf2a855a90e8 UNKNOWN * fe867e4f487096c5908ebace4e20b4f2f6b98677 Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14201: [FLINK-20322][table-planner-blink] Rename union-all-as-breakpoint configuration and change the default value

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

[GitHub] [flink] flinkbot edited a comment on pull request #14191: [FLINK-20310][doc] Add documentation for Debezium, Canal, Raw support for Filesystem connector

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

[GitHub] [flink] flinkbot edited a comment on pull request #14116: [FLINK-20213][fs-connector] Partition commit is delayed when records keep coming

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

[GitHub] [flink] SteNicholas commented on a change in pull request #13983: [FLINK-19989][python] Add collect operation in Python DataStream API

SteNicholas commented on a change in pull request #13983: URL: https://github.com/apache/flink/pull/13983#discussion_r530145180 ## File path: flink-python/pyflink/common/typeinfo.py ## @@ -300,7 +325,7 @@ class RowTypeInfo(WrapperTypeInfo): TypeInformation for Row. ""

[GitHub] [flink] wuchong commented on a change in pull request #14160: [FLINK-19795][table-blink] Fix Flink SQL throws exception when changelog source contains duplicate change events

wuchong commented on a change in pull request #14160: URL: https://github.com/apache/flink/pull/14160#discussion_r530144974 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/sources/DynamicSourceUtils.java ## @@ -267,6 +302,20 @@

[jira] [Updated] (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 ] ASF GitHub Bot updated FLINK-20338: --- Labels: pull-request-available (was: ) > Make the `StatefulSinkWriterOperator` load `Stream

[GitHub] [flink] flinkbot commented on pull request #14208: [FLINK-20338] Make the `StatefulSinkWriterOperator` load `StreamingFileSink`'s state.

flinkbot commented on pull request #14208: URL: https://github.com/apache/flink/pull/14208#issuecomment-733507213 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-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 ] Dian Fu updated FLINK-20338: Fix Version/s: 1.12.0 > Make the `StatefulSinkWriterOperator` load `StreamingFileSink`'s state. >

[jira] [Updated] (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 ] Dian Fu updated FLINK-20339: Fix Version/s: 1.12.0 > `FileWriter` support to load StreamingFileSink's state. >

[GitHub] [flink] JingsongLi commented on pull request #14191: [FLINK-20310][doc] Add documentation for Debezium, Canal, Raw support for Filesystem connector

JingsongLi commented on pull request #14191: URL: https://github.com/apache/flink/pull/14191#issuecomment-733507113 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, plea

[jira] [Commented] (FLINK-19027) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnParallelRemoteChannel failed because of test timeout

[ https://issues.apache.org/jira/browse/FLINK-19027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238555#comment-17238555 ] Arvid Heise commented on FLINK-19027: - I tracked down the issue to be related by dup

[jira] [Updated] (FLINK-20340) Use StreamFormat instead of DelimitedInputFormat in DeserializationSchemaAdapter

[ https://issues.apache.org/jira/browse/FLINK-20340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-20340: - Description: We've thought about using StreamFormat, but we don't have splittable StreamFormat i

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

[ https://issues.apache.org/jira/browse/FLINK-20337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20337: Fix Version/s: 1.12.0 > Make migrate `StreamingFileSink` to `FileSink` possible >

[jira] [Assigned] (FLINK-20328) UnalignedCheckpointITCase.execute failed with "Insufficient number of network buffers: required 1, but only 0 available"

[ https://issues.apache.org/jira/browse/FLINK-20328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-20328: --- Assignee: Arvid Heise > UnalignedCheckpointITCase.execute failed with "Insufficient number

[jira] [Created] (FLINK-20340) Use StreamFormat instead of DelimitedInputFormat in DeserializationSchemaAdapter

Jingsong Lee created FLINK-20340: Summary: Use StreamFormat instead of DelimitedInputFormat in DeserializationSchemaAdapter Key: FLINK-20340 URL: https://issues.apache.org/jira/browse/FLINK-20340 Proj

[GitHub] [flink] guoweiM opened a new pull request #14208: [FLINK-203388] Make the `StatefulSinkWriterOperator` load `StreamingFileSink`'s state.

guoweiM opened a new pull request #14208: URL: https://github.com/apache/flink/pull/14208 ## What is the purpose of the change Flink-1.12 introduces the `FileSink` in FLINK-19510, which can guarantee the exactly once semantics both in the streaming and batch execution mode. W

[GitHub] [flink] SteNicholas commented on a change in pull request #13983: [FLINK-19989][python] Add collect operation in Python DataStream API

SteNicholas commented on a change in pull request #13983: URL: https://github.com/apache/flink/pull/13983#discussion_r530142601 ## File path: flink-python/src/main/java/org/apache/flink/api/common/python/PythonBridgeUtils.java ## @@ -266,6 +278,92 @@ private static Object getP

[jira] [Assigned] (FLINK-20309) UnalignedCheckpointTestBase.execute is failed

[ https://issues.apache.org/jira/browse/FLINK-20309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-20309: --- Assignee: Arvid Heise > UnalignedCheckpointTestBase.execute is failed > ---

[jira] [Commented] (FLINK-20295) File Source lost data when reading from directories created by FileSystemTableSink with JSON format

[ https://issues.apache.org/jira/browse/FLINK-20295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238554#comment-17238554 ] Jingsong Lee commented on FLINK-20295: -- [~sewen] Yes, it is a bug in the {{Deserial

[GitHub] [flink] SteNicholas commented on a change in pull request #13983: [FLINK-19989][python] Add collect operation in Python DataStream API

SteNicholas commented on a change in pull request #13983: URL: https://github.com/apache/flink/pull/13983#discussion_r530141360 ## File path: flink-python/pyflink/datastream/utils.py ## @@ -0,0 +1,75 @@ +##

[jira] [Updated] (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 updated FLINK-20338: -- Summary: Make the `StatefulSinkWriterOperator` load `StreamingFileSink`'s state. (was: Make the `Stat

[GitHub] [flink] flinkbot commented on pull request #14207: [FLINK-20250][table-runtime] NPE when invoking AsyncLookupJoinRunner#close method

flinkbot commented on pull request #14207: URL: https://github.com/apache/flink/pull/14207#issuecomment-733503888 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-20250) NPE when invoking AsyncLookupJoinRunner#close method

[ https://issues.apache.org/jira/browse/FLINK-20250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20250: --- Labels: pull-request-available (was: ) > NPE when invoking AsyncLookupJoinRunner#close meth

[jira] [Commented] (FLINK-15507) Activate local recovery for RocksDB backends by default

[ https://issues.apache.org/jira/browse/FLINK-15507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238551#comment-17238551 ] Zakelly Lan commented on FLINK-15507: - I'm glad we bring this into discussion again.

[GitHub] [flink] SteNicholas opened a new pull request #14207: [FLINK-20250][table-runtime] NPE when invoking AsyncLookupJoinRunner#close method

SteNicholas opened a new pull request #14207: URL: https://github.com/apache/flink/pull/14207 ## What is the purpose of the change *When the Flink job failed before it was initialized, the `close()` method of `AsyncLookupJoinRunner` could cause the `NullPointerException` for `allRes

[GitHub] [flink] wuchong commented on a change in pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

wuchong commented on a change in pull request #14165: URL: https://github.com/apache/flink/pull/14165#discussion_r530138153 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/delegation/StreamPlanner.scala ## @@ -129,6 +129,13 @@

[GitHub] [flink] wuchong commented on a change in pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

wuchong commented on a change in pull request #14165: URL: https://github.com/apache/flink/pull/14165#discussion_r530138153 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/delegation/StreamPlanner.scala ## @@ -129,6 +129,13 @@

[GitHub] [flink] wuchong commented on a change in pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

wuchong commented on a change in pull request #14165: URL: https://github.com/apache/flink/pull/14165#discussion_r530138153 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/delegation/StreamPlanner.scala ## @@ -129,6 +129,13 @@

[GitHub] [flink] gaoyunhaii commented on pull request #14116: [FLINK-20213][fs-connector] Partition commit is delayed when records keep coming

gaoyunhaii commented on pull request #14116: URL: https://github.com/apache/flink/pull/14116#issuecomment-733501300 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, plea

[jira] [Closed] (FLINK-20295) File Source lost data when reading from directories created by FileSystemTableSink with JSON format

[ https://issues.apache.org/jira/browse/FLINK-20295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-20295. Resolution: Fixed master (1.12): 07a449e2f68384007cad61c10d0dcbbe0cf89c26 > File Source lost data

[GitHub] [flink] flinkbot edited a comment on pull request #14192: [FLINK-20295][table][fs-connector] Table File Source lost data when reading from directories with JSON format

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

[GitHub] [flink] JingsongLi merged pull request #14192: [FLINK-20295][table][fs-connector] Table File Source lost data when reading from directories with JSON format

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

[jira] [Closed] (FLINK-20306) Accessing a versioned table as of time fails with a cryptic message

[ https://issues.apache.org/jira/browse/FLINK-20306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20306. --- Resolution: Fixed Fixed in master (1.12.0): c41051f37651c2e81182c2145ac535f657133bbc > Accessing a versione

[GitHub] [flink] flinkbot edited a comment on pull request #14172: [FLINK-19545][e2e] Add e2e test for native Kubernetes HA

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

[GitHub] [flink] wuchong merged pull request #14200: [FLINK-20306][table-planner-blink] Throw a meaningful exception when accessing temporal table as of constant timestamp

wuchong merged pull request #14200: URL: https://github.com/apache/flink/pull/14200 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] wuchong commented on pull request #14200: [FLINK-20306][table-planner-blink] Throw a meaningful exception when accessing temporal table as of constant timestamp

wuchong commented on pull request #14200: URL: https://github.com/apache/flink/pull/14200#issuecomment-733499443 Merging... This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] fsk119 commented on a change in pull request #14206: [FLINK-20314][planner] Add rule to remove empty calc

fsk119 commented on a change in pull request #14206: URL: https://github.com/apache/flink/pull/14206#discussion_r530133529 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkStreamRuleSets.scala ## @@ -365,6 +365,8

[jira] [Commented] (FLINK-20324) Support customizing of containers for native kubernetes setup

[ https://issues.apache.org/jira/browse/FLINK-20324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238542#comment-17238542 ] Yang Wang commented on FLINK-20324: --- [~lublinsky] Since release-1.12 is feature featur

[GitHub] [flink] godfreyhe commented on a change in pull request #14206: [FLINK-20314][planner] Add rule to remove empty calc

godfreyhe commented on a change in pull request #14206: URL: https://github.com/apache/flink/pull/14206#discussion_r530131206 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkStreamRuleSets.scala ## @@ -365,6 +36

[GitHub] [flink] flinkbot edited a comment on pull request #14201: [FLINK-20322][table-planner-blink] Rename table.optimizer.union-all-as-breakpoint-disabled to table.optimizer.union-all-as-breakpoint

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

[GitHub] [flink] flinkbot edited a comment on pull request #14172: [FLINK-19545][e2e] Add e2e test for native Kubernetes HA

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

[GitHub] [flink] xintongsong commented on a change in pull request #14195: [FLINK-20300] Add Flink 1.12 release notes

xintongsong commented on a change in pull request #14195: URL: https://github.com/apache/flink/pull/14195#discussion_r530130297 ## File path: docs/release-notes/flink-1.12.md ## @@ -0,0 +1,193 @@ +--- +title: "Release Notes - Flink 1.12" +--- + + + +These release notes discuss

[jira] [Commented] (FLINK-20236) flink-dist.jar and hive-exec.jar have conflict with protobuf-java.jar

[ https://issues.apache.org/jira/browse/FLINK-20236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238539#comment-17238539 ] Rui Li commented on FLINK-20236: [~ZhuShang] I'm not familiar with the last error you po

[jira] [Commented] (FLINK-20151) Test SQL Hive integration

[ https://issues.apache.org/jira/browse/FLINK-20151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238535#comment-17238535 ] Rui Li commented on FLINK-20151: [~dwysakowicz] That's not supported at the moment. Not

[GitHub] [flink] flinkbot edited a comment on pull request #14203: [FLINK-20241][hive] Improve exception message when hive deps are miss…

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

[GitHub] [flink] flinkbot edited a comment on pull request #14206: [FLINK-20314][planner] Add rule to remove empty calc

flinkbot edited a comment on pull request #14206: URL: https://github.com/apache/flink/pull/14206#issuecomment-733458079 ## CI report: * 0a06b6ce2f629cd6fdea5ab86b67bf2a855a90e8 UNKNOWN * fe867e4f487096c5908ebace4e20b4f2f6b98677 Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14203: [FLINK-20241][hive] Improve exception message when hive deps are miss…

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

[jira] [Commented] (FLINK-20249) Rethink the necessity of the k8s internal Service even in non-HA mode

[ https://issues.apache.org/jira/browse/FLINK-20249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238514#comment-17238514 ] Ruguo Yu commented on FLINK-20249: -- Nice [~xintongsong], I approve your vote. And I agr

[GitHub] [flink] shuiqiangchen commented on a change in pull request #13983: [FLINK-19989][python] Add collect operation in Python DataStream API

shuiqiangchen commented on a change in pull request #13983: URL: https://github.com/apache/flink/pull/13983#discussion_r530096275 ## File path: flink-python/pyflink/datastream/data_stream.py ## @@ -597,6 +598,34 @@ def add_sink(self, sink_func: SinkFunction) -> 'DataStreamSink

[GitHub] [flink] flinkbot edited a comment on pull request #14206: [FLINK-20314][planner] Add rule to remove empty calc

flinkbot edited a comment on pull request #14206: URL: https://github.com/apache/flink/pull/14206#issuecomment-733458079 ## CI report: * 0a06b6ce2f629cd6fdea5ab86b67bf2a855a90e8 UNKNOWN * fe867e4f487096c5908ebace4e20b4f2f6b98677 UNKNOWN Bot commands The @flinkbo

[GitHub] [flink] flinkbot edited a comment on pull request #14205: [FLINK-20333][python] Fix the bug that Flink standalone cluster throws metaspace OOM after submitting multiple PyFlink UDF jobs.

flinkbot edited a comment on pull request #14205: URL: https://github.com/apache/flink/pull/14205#issuecomment-733452012 ## CI report: * 848f8434b33e6610ad59a1e9717cec0a4a738011 UNKNOWN * 3198ead312c2c97189f0ff76c79fed110edbed89 Azure: [PENDING](https://dev.azure.com/apache-fl

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

[ https://issues.apache.org/jira/browse/FLINK-20337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20337: -- Description: Flink-1.12 introduces the `FileSink` in FLINK-19510, which can guarantee the exactly onc

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

[ https://issues.apache.org/jira/browse/FLINK-20338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20338: -- Summary: Make the `StatefulSinkWriterOperator` load previous `StreamingFileSink`'s state. (was: Make

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

[ https://issues.apache.org/jira/browse/FLINK-20337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20337: -- Description: Flink-1.12 introduces the `FileSink` in FLINK-19510, which can guarantee the exactly onc

[GitHub] [flink] leonardBang commented on a change in pull request #14160: [FLINK-19795][table-blink] Fix Flink SQL throws exception when changelog source contains duplicate change events

leonardBang commented on a change in pull request #14160: URL: https://github.com/apache/flink/pull/14160#discussion_r530101454 ## File path: docs/dev/table/connectors/formats/canal.zh.md ## @@ -219,6 +219,17 @@ Format 参数 +注意事项 + + +### 重复的变更事件 + +在正常的

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

Guowei Ma created FLINK-20339: - Summary: `FileWriter` support to load StreamingFileSink's state. Key: FLINK-20339 URL: https://issues.apache.org/jira/browse/FLINK-20339 Project: Flink Issue Type:

[jira] [Updated] (FLINK-20338) Make the StatefulSinkWriterOperator load previous sink's state.

[ https://issues.apache.org/jira/browse/FLINK-20338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20338: -- Summary: Make the StatefulSinkWriterOperator load previous sink's state. (was: Make the SinkWriter lo

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

[ https://issues.apache.org/jira/browse/FLINK-20337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20337: -- Description: Flink-1.12 introduces the `FileSink` in FLINK-19510, which can guarantee the exactly onc

[jira] [Created] (FLINK-20338) Make the SinkWriter load previous sink's state.

Guowei Ma created FLINK-20338: - Summary: Make the SinkWriter load previous sink's state. Key: FLINK-20338 URL: https://issues.apache.org/jira/browse/FLINK-20338 Project: Flink Issue Type: Sub-tas

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

Guowei Ma created FLINK-20337: - Summary: Make migrate `StreamingFileSink` to `FileSink` possible Key: FLINK-20337 URL: https://issues.apache.org/jira/browse/FLINK-20337 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on pull request #14206: [FLINK-20314][planner] Add rule to remove empty calc

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

[GitHub] [flink] flinkbot edited a comment on pull request #14205: [FLINK-20333][python] Fix the bug that Flink standalone cluster throws metaspace OOM after submitting multiple PyFlink UDF jobs.

flinkbot edited a comment on pull request #14205: URL: https://github.com/apache/flink/pull/14205#issuecomment-733452012 ## CI report: * 848f8434b33e6610ad59a1e9717cec0a4a738011 UNKNOWN * 3198ead312c2c97189f0ff76c79fed110edbed89 UNKNOWN Bot commands The @flinkbo

[jira] [Created] (FLINK-20336) RequestReplyFunction should not silently ignore UNRECOGNIZED state value mutations types

Tzu-Li (Gordon) Tai created FLINK-20336: --- Summary: RequestReplyFunction should not silently ignore UNRECOGNIZED state value mutations types Key: FLINK-20336 URL: https://issues.apache.org/jira/browse/FLINK-2

[jira] [Created] (FLINK-20335) Remove support for eager state specifications in module YAML definitions

Tzu-Li (Gordon) Tai created FLINK-20335: --- Summary: Remove support for eager state specifications in module YAML definitions Key: FLINK-20335 URL: https://issues.apache.org/jira/browse/FLINK-20335

[GitHub] [flink] flinkbot commented on pull request #14206: [FLINK-20314][planner] Add rule to remove empty calc

flinkbot commented on pull request #14206: URL: https://github.com/apache/flink/pull/14206#issuecomment-733454266 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-20314) Empty Calc is not removed by CalcRemoveRule

[ https://issues.apache.org/jira/browse/FLINK-20314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20314: --- Labels: pull-request-available (was: ) > Empty Calc is not removed by CalcRemoveRule >

[GitHub] [flink] fsk119 opened a new pull request #14206: [FLINK-20314][planner] Add rule to remove empty calc

fsk119 opened a new pull request #14206: URL: https://github.com/apache/flink/pull/14206 ## What is the purpose of the change *Remove the empty calc node in the logical rewrite phase.* The empty calc is produced by the rule `PushWatermarkIntoTableSourceScanRule`. Howev

[GitHub] [flink] flinkbot commented on pull request #14205: [FLINK-20333][python] Fix the bug that Flink standalone cluster throws metaspace OOM after submitting multiple PyFlink UDF jobs.

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

[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: * a3c5ecb5ed33edb5472c0987d4aafb67fc48cc8e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-20334) Introduce function endpoint path templating in module YAML specifications

[ https://issues.apache.org/jira/browse/FLINK-20334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-20334: Description: In the current module specifications, function endpoints are defined

[jira] [Updated] (FLINK-20334) Introduce function endpoint path templating in module YAML specifications

[ https://issues.apache.org/jira/browse/FLINK-20334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-20334: Component/s: Stateful Functions > Introduce function endpoint path templating in m

[jira] [Created] (FLINK-20334) Introduce function endpoint path templating in module YAML specifications

Tzu-Li (Gordon) Tai created FLINK-20334: --- Summary: Introduce function endpoint path templating in module YAML specifications Key: FLINK-20334 URL: https://issues.apache.org/jira/browse/FLINK-20334

[GitHub] [flink] flinkbot commented on pull request #14205: [FLINK-20333][python] Fix the bug that Flink standalone cluster throws metaspace OOM after submitting multiple PyFlink UDF jobs.

flinkbot commented on pull request #14205: URL: https://github.com/apache/flink/pull/14205#issuecomment-733449842 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] [Assigned] (FLINK-20333) Flink standalone cluster throws metaspace OOM after submitting multiple PyFlink UDF jobs.

[ https://issues.apache.org/jira/browse/FLINK-20333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20333: --- Assignee: Wei Zhong > Flink standalone cluster throws metaspace OOM after submitting multiple > Py

[jira] [Updated] (FLINK-20333) Flink standalone cluster throws metaspace OOM after submitting multiple PyFlink UDF jobs.

[ https://issues.apache.org/jira/browse/FLINK-20333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20333: Description: Currently the Flink standalone cluster will throw metaspace OOM after submitting multiple Py

  1   2   3   4   5   6   >