[jira] [Comment Edited] (FLINK-16267) Flink uses more memory than taskmanager.memory.process.size in Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-16267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109425#comment-17109425 ] Andrey Zagrebin edited comment on FLINK-16267 at 5/17/20, 10:47 AM:

[GitHub] [flink] curcur commented on pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

curcur commented on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-629777555 Javadocs for public API has been updated as well. This is an automated message from the Apache Git Service. To

[jira] [Comment Edited] (FLINK-16267) Flink uses more memory than taskmanager.memory.process.size in Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-16267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109425#comment-17109425 ] Andrey Zagrebin edited comment on FLINK-16267 at 5/17/20, 10:47 AM:

[jira] [Comment Edited] (FLINK-16267) Flink uses more memory than taskmanager.memory.process.size in Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-16267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109425#comment-17109425 ] Andrey Zagrebin edited comment on FLINK-16267 at 5/17/20, 10:46 AM:

[jira] [Commented] (FLINK-16267) Flink uses more memory than taskmanager.memory.process.size in Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-16267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109425#comment-17109425 ] Andrey Zagrebin commented on FLINK-16267: - [~trystan] I think what [~xintongsong] meant is that

[GitHub] [flink] flinkbot edited a comment on pull request #12198: [FLINK-17772][python] Fix to_pandas to make it work in JDK 11

flinkbot edited a comment on pull request #12198: URL: https://github.com/apache/flink/pull/12198#issuecomment-629772858 ## CI report: * b57c26b5c013c9083b0536e433d64263d48b7c94 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12168: [WIP][FLINK-14255][hive] Integrate hive to streaming file sink

flinkbot edited a comment on pull request #12168: URL: https://github.com/apache/flink/pull/12168#issuecomment-629179735 ## CI report: * ca3b38d640d3e7d3590ee882c76c94e203719146 Azure:

[GitHub] [flink] twalthr commented on a change in pull request #12103: [FLINK-16998][core] Add a changeflag to Row

twalthr commented on a change in pull request #12103: URL: https://github.com/apache/flink/pull/12103#discussion_r426245240 ## File path: flink-core/src/main/java/org/apache/flink/api/java/typeutils/RowTypeInfo.java ## @@ -286,6 +286,21 @@ public String toString() {

[jira] [Commented] (FLINK-17520) Extend CompositeTypeSerializerSnapshot to allow composite serializers to signal migration based on outer configuration

[ https://issues.apache.org/jira/browse/FLINK-17520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109423#comment-17109423 ] Timo Walther commented on FLINK-17520: -- I updated this issue to critical. [~tzulitai] do you think

[jira] [Updated] (FLINK-17520) Extend CompositeTypeSerializerSnapshot to allow composite serializers to signal migration based on outer configuration

[ https://issues.apache.org/jira/browse/FLINK-17520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-17520: - Fix Version/s: 1.11.0 > Extend CompositeTypeSerializerSnapshot to allow composite serializers

[jira] [Updated] (FLINK-17520) Extend CompositeTypeSerializerSnapshot to allow composite serializers to signal migration based on outer configuration

[ https://issues.apache.org/jira/browse/FLINK-17520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-17520: - Priority: Critical (was: Major) > Extend CompositeTypeSerializerSnapshot to allow composite

[GitHub] [flink] twalthr commented on pull request #12103: [FLINK-16998][core] Add a changeflag to Row

twalthr commented on pull request #12103: URL: https://github.com/apache/flink/pull/12103#issuecomment-629775903 @godfreyhe thanks for the review. I will address them now and merge this once the build gives green light.

[GitHub] [flink] StephanEwen commented on pull request #12122: [FLINK-15102] Add continuousSource() method to StreamExecutionEnvironment.

StephanEwen commented on pull request #12122: URL: https://github.com/apache/flink/pull/12122#issuecomment-629775791 Thanks for addressing the comments. Looks good to me, @becketqin. +1 to merge this This is an

[GitHub] [flink] flinkbot edited a comment on pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

flinkbot edited a comment on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-613252882 ## CI report: * 066795205734add3b142a92c687c98b25253985e UNKNOWN * aa6298086f01efe5d6ddd1356d7e289804f57a9b Azure:

[GitHub] [flink] TsReaper commented on pull request #12073: [FLINK-17735][streaming] Add specialized collecting iterator

TsReaper commented on pull request #12073: URL: https://github.com/apache/flink/pull/12073#issuecomment-629774445 Azure passed in https://dev.azure.com/tsreaper96/Flink/_build/results?buildId=20=results This is an automated

[GitHub] [flink] aljoscha commented on pull request #12132: [FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

aljoscha commented on pull request #12132: URL: https://github.com/apache/flink/pull/12132#issuecomment-629774351 @JingsongLi @guoweiM When you're done, please also go through the PR and see if there's any outstanding TODOs or missing Javadoc. That would help speed things up.

[jira] [Updated] (FLINK-17750) YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint failed on azure

[ https://issues.apache.org/jira/browse/FLINK-17750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-17750: Labels: test-stability (was: ) >

[jira] [Created] (FLINK-17773) Update documentation for new WatermarkGenerator/WatermarkStrategies

Aljoscha Krettek created FLINK-17773: Summary: Update documentation for new WatermarkGenerator/WatermarkStrategies Key: FLINK-17773 URL: https://issues.apache.org/jira/browse/FLINK-17773 Project:

[GitHub] [flink] flinkbot commented on pull request #12198: [FLINK-17772][python] Fix to_pandas to make it work in JDK 11

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

[GitHub] [flink] aljoscha commented on pull request #12132: [FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

aljoscha commented on pull request #12132: URL: https://github.com/apache/flink/pull/12132#issuecomment-629772729 Thanks for the update! @guoweiM I quite like your changes to the test because you simplified it quite a bit. However, the important point is that the test is added separately

[GitHub] [flink] flinkbot commented on pull request #12198: [FLINK-17772][python] Fix to_pandas to make it work in JDK 11

flinkbot commented on pull request #12198: URL: https://github.com/apache/flink/pull/12198#issuecomment-629771337 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

[jira] [Updated] (FLINK-17772) test_pandas_udf.py: NoClassDefFoundError RowDataArrowPythonScalarFunctionRunner

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

[GitHub] [flink] dianfu opened a new pull request #12198: [FLINK-17772][python] Fix to_pandas to make it work in JDK 11

dianfu opened a new pull request #12198: URL: https://github.com/apache/flink/pull/12198 ## What is the purpose of the change *This pull request fixes to_pandas to make it work in JDK 11 * ## Brief change log - *Call ArrowUtils.checkArrowUsable in

[GitHub] [flink] flinkbot edited a comment on pull request #12176: [FLINK-17029][jdbc]Introduce a new JDBC connector with new property keys

flinkbot edited a comment on pull request #12176: URL: https://github.com/apache/flink/pull/12176#issuecomment-629283127 ## CI report: * e557b09c5dc9371c42542211651b79ea749cbf03 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12172: [FLINK-17656][tests] Migrate docker e2e tests to flink-docker

flinkbot edited a comment on pull request #12172: URL: https://github.com/apache/flink/pull/12172#issuecomment-629230668 ## CI report: * acad8ebc3f6f4c834a15dab61b7167280d09454f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12197: [FLINK-17357][table-planner-blink] add 'DROP catalog' DDL to blink pl…

flinkbot edited a comment on pull request #12197: URL: https://github.com/apache/flink/pull/12197#issuecomment-629768433 ## CI report: * a2db8c158cd4492f84815d068176550d569d5c1f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12073: [FLINK-17735][streaming] Add specialized collecting iterator

flinkbot edited a comment on pull request #12073: URL: https://github.com/apache/flink/pull/12073#issuecomment-626524463 ## CI report: * 424d752d1d5e49c752ccd79561ce5cfcd5ea7d1d UNKNOWN * ca26d6edd7772ee46d24b05c01952a10887eb3f7 Azure:

[jira] [Commented] (FLINK-17772) test_pandas_udf.py: NoClassDefFoundError RowDataArrowPythonScalarFunctionRunner

[ https://issues.apache.org/jira/browse/FLINK-17772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109408#comment-17109408 ] Dian Fu commented on FLINK-17772: - Thanks [~rmetzger] for reporting this issue. I will take a look. >

[jira] [Assigned] (FLINK-17772) test_pandas_udf.py: NoClassDefFoundError RowDataArrowPythonScalarFunctionRunner

[ https://issues.apache.org/jira/browse/FLINK-17772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17772: --- Assignee: Dian Fu > test_pandas_udf.py: NoClassDefFoundError >

[GitHub] [flink] lirui-apache commented on pull request #12197: [FLINK-17357][table-planner-blink] add 'DROP catalog' DDL to blink pl…

lirui-apache commented on pull request #12197: URL: https://github.com/apache/flink/pull/12197#issuecomment-629769902 Thanks @SteNicholas for working on this. I think we should clarify that this is more like `unregister` than `drop`, which means "dropping" a catalog doesn't drop the

[jira] [Updated] (FLINK-17357) add "DROP catalog" DDL to blink planner

[ https://issues.apache.org/jira/browse/FLINK-17357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17357: --- Labels: pull-request-available (was: ) > add "DROP catalog" DDL to blink planner >

[GitHub] [flink] lirui-apache commented on a change in pull request #12197: [FLINK-17357][table-planner-blink] add 'DROP catalog' DDL to blink pl…

lirui-apache commented on a change in pull request #12197: URL: https://github.com/apache/flink/pull/12197#discussion_r426236545 ## File path: flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlDropCatalog.java ## @@ -0,0 +1,66 @@ +/* + * Licensed

[GitHub] [flink] flinkbot commented on pull request #12197: [FLINK-15349][table-planner-blink] add 'DROP catalog' DDL to blink pl…

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

[GitHub] [flink] flinkbot edited a comment on pull request #12195: [FLINK-17449][sql-parser][table-api-java][table-planner-blink][hive] …

flinkbot edited a comment on pull request #12195: URL: https://github.com/apache/flink/pull/12195#issuecomment-629749977 ## CI report: * eef0ff2deffeb35b7aa34da7e35c07a054bd1643 UNKNOWN * 64b2df57074876d050964bfd47143aba6a7f4011 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

flinkbot edited a comment on pull request #12184: URL: https://github.com/apache/flink/pull/12184#issuecomment-629425634 ## CI report: * 80bbdd72c2aeb3c802deef71436882603590d147 UNKNOWN * 513b2b6030c6dc4cbe4e56ab433dd57e838ed0a9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12168: [WIP][FLINK-14255][hive] Integrate hive to streaming file sink

flinkbot edited a comment on pull request #12168: URL: https://github.com/apache/flink/pull/12168#issuecomment-629179735 ## CI report: * 0824a047d1e106d1aa234c1659a98addb87012da Azure:

[jira] [Comment Edited] (FLINK-17767) Tumble and Hop window support offset

[ https://issues.apache.org/jira/browse/FLINK-17767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109405#comment-17109405 ] Jark Wu edited comment on FLINK-17767 at 5/17/20, 9:18 AM: --- I'm +1 to support

[jira] [Commented] (FLINK-17767) Tumble and Hop window support offset

[ https://issues.apache.org/jira/browse/FLINK-17767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109405#comment-17109405 ] Jark Wu commented on FLINK-17767: - I'm +1 to support this feature. EMIT syntax is planned in the next

[jira] [Created] (FLINK-17772) test_pandas_udf.py: NoClassDefFoundError RowDataArrowPythonScalarFunctionRunner

Robert Metzger created FLINK-17772: -- Summary: test_pandas_udf.py: NoClassDefFoundError RowDataArrowPythonScalarFunctionRunner Key: FLINK-17772 URL: https://issues.apache.org/jira/browse/FLINK-17772

[GitHub] [flink] flinkbot edited a comment on pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

flinkbot edited a comment on pull request #12184: URL: https://github.com/apache/flink/pull/12184#issuecomment-629425634 ## CI report: * 80bbdd72c2aeb3c802deef71436882603590d147 UNKNOWN * 513b2b6030c6dc4cbe4e56ab433dd57e838ed0a9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12195: [FLINK-17449][sql-parser][table-api-java][table-planner-blink][hive] …

flinkbot edited a comment on pull request #12195: URL: https://github.com/apache/flink/pull/12195#issuecomment-629749977 ## CI report: * eef0ff2deffeb35b7aa34da7e35c07a054bd1643 UNKNOWN * 64b2df57074876d050964bfd47143aba6a7f4011 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12073: [FLINK-17735][streaming] Add specialized collecting iterator

flinkbot edited a comment on pull request #12073: URL: https://github.com/apache/flink/pull/12073#issuecomment-626524463 ## CI report: * 424d752d1d5e49c752ccd79561ce5cfcd5ea7d1d UNKNOWN * ca26d6edd7772ee46d24b05c01952a10887eb3f7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12168: [WIP][FLINK-14255][hive] Integrate hive to streaming file sink

flinkbot edited a comment on pull request #12168: URL: https://github.com/apache/flink/pull/12168#issuecomment-629179735 ## CI report: * 0824a047d1e106d1aa234c1659a98addb87012da Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12153: [FLINK-16966][metrics][infuxdb] Convert InfluxDB reporter to plugin

flinkbot edited a comment on pull request #12153: URL: https://github.com/apache/flink/pull/12153#issuecomment-628618072 ## CI report: * 670bf0c510cee2e656e3ca9633f9da66506746b0 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/166440422) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12172: [FLINK-17656][tests] Migrate docker e2e tests to flink-docker

flinkbot edited a comment on pull request #12172: URL: https://github.com/apache/flink/pull/12172#issuecomment-629230668 ## CI report: * 59d7735635b83251b862eeedef8af62662dd0919 Azure:

[jira] [Commented] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

[ https://issues.apache.org/jira/browse/FLINK-17768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109401#comment-17109401 ] Robert Metzger commented on FLINK-17768:

[jira] [Created] (FLINK-17771) "PyFlink end-to-end test" fails with "The output result: [] is not as expected: [2, 3, 4]!" on Java11

Robert Metzger created FLINK-17771: -- Summary: "PyFlink end-to-end test" fails with "The output result: [] is not as expected: [2, 3, 4]!" on Java11 Key: FLINK-17771 URL:

[jira] [Created] (FLINK-17770) TPC-DS end-to-end test (Blink planner) fails with AskTimeoutException

Robert Metzger created FLINK-17770: -- Summary: TPC-DS end-to-end test (Blink planner) fails with AskTimeoutException Key: FLINK-17770 URL: https://issues.apache.org/jira/browse/FLINK-17770 Project:

[GitHub] [flink] flinkbot commented on pull request #12197: [FLINK-15349][table-planner-blink] add 'DROP catalog' DDL to blink pl…

flinkbot commented on pull request #12197: URL: https://github.com/apache/flink/pull/12197#issuecomment-629764797 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

[jira] [Updated] (FLINK-17769) Wrong order of log events on a task failure

[ https://issues.apache.org/jira/browse/FLINK-17769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17769: --- Priority: Critical (was: Blocker) > Wrong order of log events on a task failure >

[GitHub] [flink] SteNicholas opened a new pull request #12197: [FLINK-15349][table-planner-blink] add 'DROP catalog' DDL to blink pl…

SteNicholas opened a new pull request #12197: URL: https://github.com/apache/flink/pull/12197 ## What is the purpose of the change *DDL statement of table blink planner has no statement that drop catalog, this should add 'DROP catalog' DDL to blink planner.* ## Brief change

[jira] [Commented] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

[ https://issues.apache.org/jira/browse/FLINK-17768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109396#comment-17109396 ] Robert Metzger commented on FLINK-17768: upgrading to blocker

[jira] [Updated] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

[ https://issues.apache.org/jira/browse/FLINK-17768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17768: --- Priority: Blocker (was: Critical) >

[GitHub] [flink] pnowojski commented on a change in pull request #12186: [FLINK-16383][task] Do not relay notifyCheckpointComplete to closed operators

pnowojski commented on a change in pull request #12186: URL: https://github.com/apache/flink/pull/12186#discussion_r426235142 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointFailureReason.java ## @@ -44,6 +44,8 @@

[GitHub] [flink] JingsongLi commented on pull request #12132: [FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

JingsongLi commented on pull request #12132: URL: https://github.com/apache/flink/pull/12132#issuecomment-629763746 @guoweiM Thanks for updating, can you rebase master? This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on pull request #12172: [FLINK-17656][tests] Migrate docker e2e tests to flink-docker

flinkbot edited a comment on pull request #12172: URL: https://github.com/apache/flink/pull/12172#issuecomment-629230668 ## CI report: * 59d7735635b83251b862eeedef8af62662dd0919 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12153: [FLINK-16966][metrics][infuxdb] Convert InfluxDB reporter to plugin

flinkbot edited a comment on pull request #12153: URL: https://github.com/apache/flink/pull/12153#issuecomment-628618072 ## CI report: * 670bf0c510cee2e656e3ca9633f9da66506746b0 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/166440422) Azure:

[GitHub] [flink] JingsongLi commented on a change in pull request #12168: [WIP][FLINK-14255][hive] Integrate hive to streaming file sink

JingsongLi commented on a change in pull request #12168: URL: https://github.com/apache/flink/pull/12168#discussion_r426233687 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/write/HiveRecordWriterFactory.java ## @@ -167,56

[GitHub] [flink] JingsongLi commented on a change in pull request #12168: [WIP][FLINK-14255][hive] Integrate hive to streaming file sink

JingsongLi commented on a change in pull request #12168: URL: https://github.com/apache/flink/pull/12168#discussion_r42626 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #12168: [WIP][FLINK-14255][hive] Integrate hive to streaming file sink

JingsongLi commented on a change in pull request #12168: URL: https://github.com/apache/flink/pull/12168#discussion_r426233264 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/write/HadoopPathBasedPartFileWriterTest.java ## @@

[GitHub] [flink] JingsongLi commented on a change in pull request #12168: [WIP][FLINK-14255][hive] Integrate hive to streaming file sink

JingsongLi commented on a change in pull request #12168: URL: https://github.com/apache/flink/pull/12168#discussion_r426233235 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/PartFileWriter.java ## @@ -20,122 +20,172

[GitHub] [flink] JingsongLi commented on a change in pull request #12168: [WIP][FLINK-14255][hive] Integrate hive to streaming file sink

JingsongLi commented on a change in pull request #12168: URL: https://github.com/apache/flink/pull/12168#discussion_r426233102 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/write/HadoopPathBasedPartFileWriterTest.java ## @@

[GitHub] [flink] JingsongLi commented on a change in pull request #12168: [WIP][FLINK-14255][hive] Integrate hive to streaming file sink

JingsongLi commented on a change in pull request #12168: URL: https://github.com/apache/flink/pull/12168#discussion_r426233061 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSinkTest.java ## @@ -213,6 +228,95 @@

[jira] [Commented] (FLINK-17487) Do not delete old checkpoints when stop the job.

[ https://issues.apache.org/jira/browse/FLINK-17487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109386#comment-17109386 ] Congxian Qiu(klion26) commented on FLINK-17487: --- [~nobleyd] Do you mean the stop command

[GitHub] [flink] TsReaper commented on a change in pull request #12073: [FLINK-17735][streaming] Add specialized collecting iterator

TsReaper commented on a change in pull request #12073: URL: https://github.com/apache/flink/pull/12073#discussion_r426230954 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectResultFetcher.java ## @@ -0,0 +1,359 @@ +/* +

[GitHub] [flink] flinkbot edited a comment on pull request #12196: [FLINK-17353][docs] Fix Broken links in Flink docs master

flinkbot edited a comment on pull request #12196: URL: https://github.com/apache/flink/pull/12196#issuecomment-629757606 ## CI report: * d49a52910495b1328a0534bc893cb506d5a0911a Azure:

[GitHub] [flink] TsReaper commented on a change in pull request #12073: [FLINK-17735][streaming] Add specialized collecting iterator

TsReaper commented on a change in pull request #12073: URL: https://github.com/apache/flink/pull/12073#discussion_r426230954 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectResultFetcher.java ## @@ -0,0 +1,359 @@ +/* +

[GitHub] [flink] lirui-apache commented on a change in pull request #12168: [WIP][FLINK-14255][hive] Integrate hive to streaming file sink

lirui-apache commented on a change in pull request #12168: URL: https://github.com/apache/flink/pull/12168#discussion_r426141927 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveRowDataPartitionComputer.java ## @@ -0,0

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109381#comment-17109381 ] Hequn Cheng commented on FLINK-9528: [~jark] (y) > Incorrect results: Filter does not treat Upsert

[GitHub] [flink] TsReaper commented on a change in pull request #12073: [FLINK-17735][streaming] Add specialized collecting iterator

TsReaper commented on a change in pull request #12073: URL: https://github.com/apache/flink/pull/12073#discussion_r426229597 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectResultFetcher.java ## @@ -0,0 +1,359 @@ +/* +

[GitHub] [flink] flinkbot edited a comment on pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

flinkbot edited a comment on pull request #12184: URL: https://github.com/apache/flink/pull/12184#issuecomment-629425634 ## CI report: * 80bbdd72c2aeb3c802deef71436882603590d147 UNKNOWN * 513b2b6030c6dc4cbe4e56ab433dd57e838ed0a9 Azure:

[GitHub] [flink] flinkbot commented on pull request #12196: [FLINK-17353][docs] Fix Broken links in Flink docs master

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

[GitHub] [flink] flinkbot edited a comment on pull request #11920: [FLINK-17408] Introduce GPUDriver and discovery script

flinkbot edited a comment on pull request #11920: URL: https://github.com/apache/flink/pull/11920#issuecomment-619909940 ## CI report: * c8c6a5e4330862e9f54cd598b76e1adb2e11bb54 Azure:

[jira] [Closed] (FLINK-17428) Support SupportsProjectionPushDown in planner

[ https://issues.apache.org/jira/browse/FLINK-17428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17428. -- Fix Version/s: 1.11.0 Resolution: Fixed master: 7c7137173a2b14f49c4f87b191ff26026af2a4d0 >

[GitHub] [flink] KurtYoung merged pull request #12145: [FLINK-17428] [table-planner-blink] supports projection push down on new table source interface in blink planner

KurtYoung merged pull request #12145: URL: https://github.com/apache/flink/pull/12145 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-17451) Implement view DDLs for Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-17451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17451. -- Assignee: Rui Li Resolution: Fixed master: 81c37384e5c607cc8abd65b7db79fce78c925a62 >

[GitHub] [flink] KurtYoung closed pull request #12029: [FLINK-17451][sql-parser][table-planner-blink][hive] Implement view D…

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

[GitHub] [flink] yangyichao-mango commented on a change in pull request #12196: [FLINK-17353][docs] Fix Broken links in Flink docs master

yangyichao-mango commented on a change in pull request #12196: URL: https://github.com/apache/flink/pull/12196#discussion_r426228350 ## File path: docs/concepts/flink-architecture.zh.md ## @@ -0,0 +1,132 @@ +--- Review comment: This md is added for matching English

[jira] [Commented] (FLINK-17767) Tumble and Hop window support offset

[ https://issues.apache.org/jira/browse/FLINK-17767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109371#comment-17109371 ] hailong wang commented on FLINK-17767: -- Hi [~jark] , This feature is explicitly not supported from

[GitHub] [flink] yangyichao-mango commented on pull request #12196: [FLINK-17353][docs] Fix Broken links in Flink docs master

yangyichao-mango commented on pull request #12196: URL: https://github.com/apache/flink/pull/12196#issuecomment-629755819 cc @wuchong This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] TsReaper commented on a change in pull request #12073: [FLINK-17735][streaming] Add specialized collecting iterator

TsReaper commented on a change in pull request #12073: URL: https://github.com/apache/flink/pull/12073#discussion_r426227712 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectResultFetcher.java ## @@ -0,0 +1,359 @@ +/* +

[GitHub] [flink] flinkbot commented on pull request #12196: [FLINK-17353][docs] Fix Broken links in Flink docs master

flinkbot commented on pull request #12196: URL: https://github.com/apache/flink/pull/12196#issuecomment-629755223 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

[jira] [Updated] (FLINK-17353) Broken links in Flink docs master

[ https://issues.apache.org/jira/browse/FLINK-17353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17353: --- Labels: pull-request-available (was: ) > Broken links in Flink docs master >

[GitHub] [flink] yangyichao-mango opened a new pull request #12196: [FLINK-17353][docs] Fix Broken links in Flink docs master

yangyichao-mango opened a new pull request #12196: URL: https://github.com/apache/flink/pull/12196 ## What is the purpose of the change *Fix all of the broken links in Flink docs master mentioned in [[FLINK-17353](https://issues.apache.org/jira/browse/FLINK-17353)]*

[GitHub] [flink] flinkbot edited a comment on pull request #12195: [FLINK-17449][sql-parser][table-api-java][table-planner-blink][hive] …

flinkbot edited a comment on pull request #12195: URL: https://github.com/apache/flink/pull/12195#issuecomment-629749977 ## CI report: * eef0ff2deffeb35b7aa34da7e35c07a054bd1643 UNKNOWN * 64b2df57074876d050964bfd47143aba6a7f4011 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12122: [FLINK-15102] Add continuousSource() method to StreamExecutionEnvironment.

flinkbot edited a comment on pull request #12122: URL: https://github.com/apache/flink/pull/12122#issuecomment-628150752 ## CI report: * 800f130ee00200ee816d2ffa11755a9fa07780b3 Azure:

[jira] [Commented] (FLINK-16383) KafkaProducerExactlyOnceITCase. testExactlyOnceRegularSink fails with "The producer has already been closed"

[ https://issues.apache.org/jira/browse/FLINK-16383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109368#comment-17109368 ] Robert Metzger commented on FLINK-16383:

[jira] [Commented] (FLINK-13553) KvStateServerHandlerTest.readInboundBlocking unstable on Travis

[ https://issues.apache.org/jira/browse/FLINK-13553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109367#comment-17109367 ] Robert Metzger commented on FLINK-13553: New case:

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109366#comment-17109366 ] Robert Metzger commented on FLINK-17274:

[GitHub] [flink] KurtYoung commented on a change in pull request #12073: [FLINK-17735][streaming] Add specialized collecting iterator

KurtYoung commented on a change in pull request #12073: URL: https://github.com/apache/flink/pull/12073#discussion_r426226686 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectResultFetcher.java ## @@ -0,0 +1,359 @@ +/* +

[GitHub] [flink] pnowojski commented on a change in pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

pnowojski commented on a change in pull request #12120: URL: https://github.com/apache/flink/pull/12120#discussion_r426226419 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/FileBasedBufferIterator.java ## @@ -85,6 +90,6 @@ private int read(byte[]

[GitHub] [flink] pnowojski commented on a change in pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

pnowojski commented on a change in pull request #12120: URL: https://github.com/apache/flink/pull/12120#discussion_r426226419 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/FileBasedBufferIterator.java ## @@ -85,6 +90,6 @@ private int read(byte[]

[GitHub] [flink] KurtYoung commented on a change in pull request #12073: [FLINK-17735][streaming] Add specialized collecting iterator

KurtYoung commented on a change in pull request #12073: URL: https://github.com/apache/flink/pull/12073#discussion_r426223511 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectResultFetcher.java ## @@ -0,0 +1,359 @@ +/* +

[GitHub] [flink] pnowojski commented on a change in pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

pnowojski commented on a change in pull request #12120: URL: https://github.com/apache/flink/pull/12120#discussion_r426226419 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/FileBasedBufferIterator.java ## @@ -85,6 +90,6 @@ private int read(byte[]

[jira] [Commented] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

[ https://issues.apache.org/jira/browse/FLINK-17768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109365#comment-17109365 ] Robert Metzger commented on FLINK-17768:

[jira] [Commented] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

[ https://issues.apache.org/jira/browse/FLINK-17768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109364#comment-17109364 ] Robert Metzger commented on FLINK-17768:

[jira] [Updated] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

[ https://issues.apache.org/jira/browse/FLINK-17768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17768: --- Priority: Critical (was: Major) >

[GitHub] [flink] pnowojski commented on a change in pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

pnowojski commented on a change in pull request #12120: URL: https://github.com/apache/flink/pull/12120#discussion_r426226419 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/FileBasedBufferIterator.java ## @@ -85,6 +90,6 @@ private int read(byte[]

[jira] [Commented] (FLINK-17730) HadoopS3RecoverableWriterITCase.testRecoverAfterMultiplePersistsStateWithMultiPart times out

[ https://issues.apache.org/jira/browse/FLINK-17730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109363#comment-17109363 ] Robert Metzger commented on FLINK-17730:

[jira] [Commented] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

[ https://issues.apache.org/jira/browse/FLINK-17768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109362#comment-17109362 ] Robert Metzger commented on FLINK-17768:

<    1   2   3   4   5   6   >