[GitHub] [flink] zhijiangW commented on a change in pull request #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition

zhijiangW commented on a change in pull request #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition URL: https://github.com/apache/flink/pull/11786#discussion_r410355533 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition

zhijiangW commented on a change in pull request #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition URL: https://github.com/apache/flink/pull/11786#discussion_r410355482 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11768: [FLINK-16943][python] Support set the configuration option "pipeline.jars" in PyFlink.

flinkbot edited a comment on issue #11768: [FLINK-16943][python] Support set the configuration option "pipeline.jars" in PyFlink. URL: https://github.com/apache/flink/pull/11768#issuecomment-614482552 ## CI report: * 01280e72a363ee72180dd385dc95e0013f60650f Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition

flinkbot edited a comment on issue #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition URL: https://github.com/apache/flink/pull/11786#issuecomment-615087816 ## CI report: * 539aab54392550e3fc872cfa70681e6593b1a46e Travis:

[jira] [Created] (FLINK-17228) Streaming sql with nested GROUP BY got wrong results

Xingxing Di created FLINK-17228: --- Summary: Streaming sql with nested GROUP BY got wrong results Key: FLINK-17228 URL: https://issues.apache.org/jira/browse/FLINK-17228 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on issue #11727: [FLINK-17106][table] Support create and drop view in Flink SQL

flinkbot edited a comment on issue #11727: [FLINK-17106][table] Support create and drop view in Flink SQL URL: https://github.com/apache/flink/pull/11727#issuecomment-613273432 ## CI report: * fa5592cec0a6a5dcecc4f45c4bf72caf6e166eb4 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11782: [FLINK-15801] fix Timestamp extractor created from properties does no…

flinkbot edited a comment on issue #11782: [FLINK-15801] fix Timestamp extractor created from properties does no… URL: https://github.com/apache/flink/pull/11782#issuecomment-614731103 ## CI report: * ad173d3dc532165e63be755a323f90231eb961e6 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11754: [FLINK-17156][checkpointing] support cancellation of unaligned checkpoints

flinkbot edited a comment on issue #11754: [FLINK-17156][checkpointing] support cancellation of unaligned checkpoints URL: https://github.com/apache/flink/pull/11754#issuecomment-613990642 ## CI report: * aebef0a50172e17d7cd02b4cd44c15f03b4b2d2e Travis:

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

AHeise commented on a change in pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle URL: https://github.com/apache/flink/pull/11725#discussion_r410300111 ## File path: flink-core/src/main/java/org/apache/flink/util/PropertiesUtil.java

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

AHeise commented on a change in pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle URL: https://github.com/apache/flink/pull/11725#discussion_r410295578 ## File path: flink-core/src/main/java/org/apache/flink/util/PropertiesUtil.java

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

AHeise commented on a change in pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle URL: https://github.com/apache/flink/pull/11725#discussion_r410296442 ## File path: flink-core/src/main/java/org/apache/flink/util/PropertiesUtil.java

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

AHeise commented on a change in pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle URL: https://github.com/apache/flink/pull/11725#discussion_r410310549 ## File path:

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

AHeise commented on a change in pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle URL: https://github.com/apache/flink/pull/11725#discussion_r410311171 ## File path:

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

AHeise commented on a change in pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle URL: https://github.com/apache/flink/pull/11725#discussion_r410311086 ## File path:

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

AHeise commented on a change in pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle URL: https://github.com/apache/flink/pull/11725#discussion_r410307365 ## File path:

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

AHeise commented on a change in pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle URL: https://github.com/apache/flink/pull/11725#discussion_r410296820 ## File path: flink-core/src/main/java/org/apache/flink/util/PropertiesUtil.java

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

AHeise commented on a change in pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle URL: https://github.com/apache/flink/pull/11725#discussion_r410302920 ## File path: flink-core/src/main/java/org/apache/flink/util/PropertiesUtil.java

[GitHub] [flink] klion26 commented on a change in pull request #11590: [FLINK-16102][docs-zh] Translate docs/dev/table/hive/scala_shell_hive.zh.md into Chinese

klion26 commented on a change in pull request #11590: [FLINK-16102][docs-zh] Translate docs/dev/table/hive/scala_shell_hive.zh.md into Chinese URL: https://github.com/apache/flink/pull/11590#discussion_r410331894 ## File path: docs/dev/table/hive/scala_shell_hive.zh.md ##

[GitHub] [flink] klion26 commented on a change in pull request #11590: [FLINK-16102][docs-zh] Translate docs/dev/table/hive/scala_shell_hive.zh.md into Chinese

klion26 commented on a change in pull request #11590: [FLINK-16102][docs-zh] Translate docs/dev/table/hive/scala_shell_hive.zh.md into Chinese URL: https://github.com/apache/flink/pull/11590#discussion_r410333729 ## File path: docs/dev/table/hive/scala_shell_hive.zh.md ##

[GitHub] [flink] klion26 commented on a change in pull request #11590: [FLINK-16102][docs-zh] Translate docs/dev/table/hive/scala_shell_hive.zh.md into Chinese

klion26 commented on a change in pull request #11590: [FLINK-16102][docs-zh] Translate docs/dev/table/hive/scala_shell_hive.zh.md into Chinese URL: https://github.com/apache/flink/pull/11590#discussion_r410328532 ## File path: docs/dev/table/hive/scala_shell_hive.zh.md ##

[GitHub] [flink] klion26 commented on a change in pull request #11590: [FLINK-16102][docs-zh] Translate docs/dev/table/hive/scala_shell_hive.zh.md into Chinese

klion26 commented on a change in pull request #11590: [FLINK-16102][docs-zh] Translate docs/dev/table/hive/scala_shell_hive.zh.md into Chinese URL: https://github.com/apache/flink/pull/11590#discussion_r410332889 ## File path: docs/dev/table/hive/scala_shell_hive.zh.md ##

[GitHub] [flink] flinkbot edited a comment on issue #11791: [FLINK-17210][sql-parser][hive] Implement database DDLs for Hive dialect

flinkbot edited a comment on issue #11791: [FLINK-17210][sql-parser][hive] Implement database DDLs for Hive dialect URL: https://github.com/apache/flink/pull/11791#issuecomment-615162346 ## CI report: * a6642cdfead306f1192f73c861e7201af9d38c56 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * 5bad018f00f85a7359345187a12d7938aa510d25

[GitHub] [flink] flinkbot edited a comment on issue #11759: FLINK-17142: Bump ORC dependency version to 1.5.6

flinkbot edited a comment on issue #11759: FLINK-17142: Bump ORC dependency version to 1.5.6 URL: https://github.com/apache/flink/pull/11759#issuecomment-614064345 ## CI report: * 7cd94f991031d892a7ba5cb78284972e050d74b7 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

flinkbot edited a comment on issue #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks URL: https://github.com/apache/flink/pull/11692#issuecomment-611530487 ## CI report: * 4c854e0afe5cb934d919f37eb0891719063938ac Travis:

[GitHub] [flink] flinkbot commented on issue #11799: [Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpointing mode.

flinkbot commented on issue #11799: [Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpointing mode. URL: https://github.com/apache/flink/pull/11799#issuecomment-615330367 Thanks a lot for your contribution to the

[GitHub] [flink] zlb1028 closed pull request #11799: [Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpointing mode.

zlb1028 closed pull request #11799: [Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpointing mode. URL: https://github.com/apache/flink/pull/11799

[GitHub] [flink] zenfenan edited a comment on issue #11759: FLINK-17142: Bump ORC dependency version to 1.5.6

zenfenan edited a comment on issue #11759: FLINK-17142: Bump ORC dependency version to 1.5.6 URL: https://github.com/apache/flink/pull/11759#issuecomment-615322834 @zentol `flink-sql-connector-hive-xyz` modules still use 1.4.3 so I am not touching their NOTICE files. @JingsongLi I

[GitHub] [flink] zenfenan commented on issue #11474: FLINK-10114: Add ORC BulkWriter support for StreamingFileSink

zenfenan commented on issue #11474: FLINK-10114: Add ORC BulkWriter support for StreamingFileSink URL: https://github.com/apache/flink/pull/11474#issuecomment-615329178 @kl0u I checked your branch and I think it looks exactly like what you had commented earlier. My changes pretty much are

[GitHub] [flink] zlb1028 opened a new pull request #11799: [Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpointing mode.

zlb1028 opened a new pull request #11799: [Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpointing mode. URL: https://github.com/apache/flink/pull/11799 ## What is the purpose of the change This pull

[GitHub] [flink] flinkbot edited a comment on issue #11759: FLINK-17142: Bump ORC dependency version to 1.5.6

flinkbot edited a comment on issue #11759: FLINK-17142: Bump ORC dependency version to 1.5.6 URL: https://github.com/apache/flink/pull/11759#issuecomment-614064345 ## CI report: * 7cd94f991031d892a7ba5cb78284972e050d74b7 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

flinkbot edited a comment on issue #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks URL: https://github.com/apache/flink/pull/11692#issuecomment-611530487 ## CI report: * ef3631f8697ef9e49de937d32112b3742324a731 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * 5bad018f00f85a7359345187a12d7938aa510d25

[GitHub] [flink] twalthr commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

twalthr commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks URL: https://github.com/apache/flink/pull/11692#discussion_r410319752 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11668: [FLINK-17013][python] Support Python UDTF in old planner under batch mode

flinkbot edited a comment on issue #11668: [FLINK-17013][python] Support Python UDTF in old planner under batch mode URL: https://github.com/apache/flink/pull/11668#issuecomment-610845431 ## CI report: * 7d2e31fab3e7e023346cbec86fbb239c80310895 Travis:

[jira] [Comment Edited] (FLINK-17225) Support native k8s for scala shell

[ https://issues.apache.org/jira/browse/FLINK-17225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17085889#comment-17085889 ] Jeff Zhang edited comment on FLINK-17225 at 4/17/20, 3:59 PM: -- Thanks

[jira] [Commented] (FLINK-17225) Support native k8s for scala shell

[ https://issues.apache.org/jira/browse/FLINK-17225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17085889#comment-17085889 ] Jeff Zhang commented on FLINK-17225: Thanks [~fly_in_gis]  [~chesnay] Why does scala 2.12 support

[GitHub] [flink] aljoscha commented on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

aljoscha commented on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#issuecomment-615326507 @TisonKun to answer your question: in general we try to not break command line parameters.

[GitHub] [flink] aljoscha closed pull request #10773: DO NOT MERGE [FLINK-XXXXX][client] Executor inheritance cleanup

aljoscha closed pull request #10773: DO NOT MERGE [FLINK-X][client] Executor inheritance cleanup URL: https://github.com/apache/flink/pull/10773 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] aljoscha commented on issue #10773: DO NOT MERGE [FLINK-XXXXX][client] Executor inheritance cleanup

aljoscha commented on issue #10773: DO NOT MERGE [FLINK-X][client] Executor inheritance cleanup URL: https://github.com/apache/flink/pull/10773#issuecomment-615325301 Closing this for now. This is an automated message

[jira] [Created] (FLINK-17227) Remove Datadog relocations

Chesnay Schepler created FLINK-17227: Summary: Remove Datadog relocations Key: FLINK-17227 URL: https://issues.apache.org/jira/browse/FLINK-17227 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17226) Remove Prometheus relocations

Chesnay Schepler created FLINK-17226: Summary: Remove Prometheus relocations Key: FLINK-17226 URL: https://issues.apache.org/jira/browse/FLINK-17226 Project: Flink Issue Type: Sub-task

[GitHub] [flink] zenfenan commented on issue #11759: FLINK-17142: Bump ORC dependency version to 1.5.6

zenfenan commented on issue #11759: FLINK-17142: Bump ORC dependency version to 1.5.6 URL: https://github.com/apache/flink/pull/11759#issuecomment-615322834 @zentol `flink-sql-connector-hive-xyz` modules still use 1.4.3 so I am not touching their NOTICE files.

[jira] [Comment Edited] (FLINK-17023) Improve handling of unexpected input in config.sh#extractExecutionParams

[ https://issues.apache.org/jira/browse/FLINK-17023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17085885#comment-17085885 ] Chesnay Schepler edited comment on FLINK-17023 at 4/17/20, 3:50 PM:

[jira] [Updated] (FLINK-17023) Improve handling of unexpected input in config.sh#extractExecutionParams

[ https://issues.apache.org/jira/browse/FLINK-17023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-17023: - Issue Type: Improvement (was: Bug) > Improve handling of unexpected input in

[jira] [Closed] (FLINK-17023) Improve handling of unexpected input in config.sh#extractExecutionParams

[ https://issues.apache.org/jira/browse/FLINK-17023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-17023. Fix Version/s: 1.11.0 Resolution: Fixed master:

[jira] [Updated] (FLINK-17023) Improve handling of unexpected input in config.sh#extractExecutionParams

[ https://issues.apache.org/jira/browse/FLINK-17023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-17023: - Summary: Improve handling of unexpected input in config.sh#extractExecutionParams

[GitHub] [flink] zentol merged pull request #11764: [FLINK-17023][scripts] Fix format checking of extractExecutionParams in config.sh

zentol merged pull request #11764: [FLINK-17023][scripts] Fix format checking of extractExecutionParams in config.sh URL: https://github.com/apache/flink/pull/11764 This is an automated message from the Apache Git Service.

[GitHub] [flink] flinkbot edited a comment on issue #11797: [FLINK-17169][table-blink] Refactor BaseRow to use RowKind instead of byte header

flinkbot edited a comment on issue #11797: [FLINK-17169][table-blink] Refactor BaseRow to use RowKind instead of byte header URL: https://github.com/apache/flink/pull/11797#issuecomment-615294694 ## CI report: * 85f40e3041783b1dbda1eb3b812f23e77936f7b3 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11798: [RELEASE-1.10][Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpoi

flinkbot edited a comment on issue #11798: [RELEASE-1.10][Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpointing mode. URL: https://github.com/apache/flink/pull/11798#issuecomment-615305745 ## CI report:

[GitHub] [flink] flinkbot edited a comment on issue #11795: [FLINK-17220][python] Clean test environment after finishing test

flinkbot edited a comment on issue #11795: [FLINK-17220][python] Clean test environment after finishing test URL: https://github.com/apache/flink/pull/11795#issuecomment-615243201 ## CI report: * 365b9719bc3bcf169d8808a62eb7745f5b8dba91 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

flinkbot edited a comment on issue #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks URL: https://github.com/apache/flink/pull/11692#issuecomment-611530487 ## CI report: * c7a38961dc881a5bc69b505234bdf23cd887f75a Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * c15a33465aff4a5bcbb0b32a75393c19ef3c4e1e

[GitHub] [flink] wuchong commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

wuchong commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks URL: https://github.com/apache/flink/pull/11692#discussion_r410307402 ## File path:

[GitHub] [flink] twalthr commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

twalthr commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks URL: https://github.com/apache/flink/pull/11692#discussion_r410306261 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11708: [FLINK-15816][k8s] Limit the value of kubernetes.cluster-id to have no more than 45 characters

tillrohrmann commented on a change in pull request #11708: [FLINK-15816][k8s] Limit the value of kubernetes.cluster-id to have no more than 45 characters URL: https://github.com/apache/flink/pull/11708#discussion_r410293510 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11708: [FLINK-15816][k8s] Limit the value of kubernetes.cluster-id to have no more than 45 characters

tillrohrmann commented on a change in pull request #11708: [FLINK-15816][k8s] Limit the value of kubernetes.cluster-id to have no more than 45 characters URL: https://github.com/apache/flink/pull/11708#discussion_r410299043 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

dawidwys commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks URL: https://github.com/apache/flink/pull/11692#discussion_r410298403 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11764: [FLINK-17023][scripts] Fix format checking of extractExecutionParams in config.sh

flinkbot edited a comment on issue #11764: [FLINK-17023][scripts] Fix format checking of extractExecutionParams in config.sh URL: https://github.com/apache/flink/pull/11764#issuecomment-614393395 ## CI report: * 85d4202c20c3d4649dd4c860595ffae7ea3eba3e Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11795: [FLINK-17220][python] Clean test environment after finishing test

flinkbot edited a comment on issue #11795: [FLINK-17220][python] Clean test environment after finishing test URL: https://github.com/apache/flink/pull/11795#issuecomment-615243201 ## CI report: * 365b9719bc3bcf169d8808a62eb7745f5b8dba91 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11797: [FLINK-17169][table-blink] Refactor BaseRow to use RowKind instead of byte header

flinkbot edited a comment on issue #11797: [FLINK-17169][table-blink] Refactor BaseRow to use RowKind instead of byte header URL: https://github.com/apache/flink/pull/11797#issuecomment-615294694 ## CI report: * 85f40e3041783b1dbda1eb3b812f23e77936f7b3 UNKNOWN *

[GitHub] [flink] flinkbot commented on issue #11798: [RELEASE-1.10][Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpointing m

flinkbot commented on issue #11798: [RELEASE-1.10][Flink-16662] [table-blink/clients]Fix the bug that the blink Planner failed to generate JobGraph when use the udf in checkpointing mode. URL: https://github.com/apache/flink/pull/11798#issuecomment-615305745 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11790: [FLINK-17212][python] Disable the cython tests

flinkbot edited a comment on issue #11790: [FLINK-17212][python] Disable the cython tests URL: https://github.com/apache/flink/pull/11790#issuecomment-615142739 ## CI report: * 652a8b94695691eadae07074ab312e47fb50a9cb Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11788: [FLINK-17209][sql-client] Allow users to specify dialect in sql-clien…

flinkbot edited a comment on issue #11788: [FLINK-17209][sql-client] Allow users to specify dialect in sql-clien… URL: https://github.com/apache/flink/pull/11788#issuecomment-615123775 ## CI report: * 2f95bec8a81a317e912f447b3d5b643f728cca4b Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * c15a33465aff4a5bcbb0b32a75393c19ef3c4e1e

[GitHub] [flink] flinkbot edited a comment on issue #11727: [FLINK-17106][table] Support create and drop view in Flink SQL

flinkbot edited a comment on issue #11727: [FLINK-17106][table] Support create and drop view in Flink SQL URL: https://github.com/apache/flink/pull/11727#issuecomment-613273432 ## CI report: * fa5592cec0a6a5dcecc4f45c4bf72caf6e166eb4 UNKNOWN *

[GitHub] [flink] dawidwys commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

dawidwys commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks URL: https://github.com/apache/flink/pull/11692#discussion_r410291153 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

tillrohrmann commented on a change in pull request #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11323#discussion_r410289639 ## File path:

[GitHub] [flink] twalthr commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

twalthr commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks URL: https://github.com/apache/flink/pull/11692#discussion_r410289464 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

wuchong commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks URL: https://github.com/apache/flink/pull/11692#discussion_r410289360 ## File path:

[jira] [Commented] (FLINK-17225) Support native k8s for scala shell

[ https://issues.apache.org/jira/browse/FLINK-17225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17085857#comment-17085857 ] Yang Wang commented on FLINK-17225: --- [~chesnay] Thanks for your kindly reminding. cc [~zjffdu], since

[GitHub] [flink] twalthr commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

twalthr commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks URL: https://github.com/apache/flink/pull/11692#discussion_r410287174 ## File path:

[jira] [Assigned] (FLINK-17224) Precision of TIME type does not work correctly

[ https://issues.apache.org/jira/browse/FLINK-17224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17224: --- Assignee: Danny Chen > Precision of TIME type does not work correctly >

[GitHub] [flink] tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner

tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner URL: https://github.com/apache/flink/pull/11109#discussion_r410244991 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner

tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner URL: https://github.com/apache/flink/pull/11109#discussion_r410264001 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner

tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner URL: https://github.com/apache/flink/pull/11109#discussion_r410268864 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner

tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner URL: https://github.com/apache/flink/pull/11109#discussion_r410262958 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner

tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner URL: https://github.com/apache/flink/pull/11109#discussion_r410254078 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner

tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner URL: https://github.com/apache/flink/pull/11109#discussion_r410269608 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner

tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner URL: https://github.com/apache/flink/pull/11109#discussion_r410243332 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner

tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner URL: https://github.com/apache/flink/pull/11109#discussion_r410252956 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner

tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner URL: https://github.com/apache/flink/pull/11109#discussion_r410265250 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner

tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner URL: https://github.com/apache/flink/pull/11109#discussion_r410268774 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner

tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner URL: https://github.com/apache/flink/pull/11109#discussion_r410251612 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner

tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner URL: https://github.com/apache/flink/pull/11109#discussion_r410234004 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner

tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner URL: https://github.com/apache/flink/pull/11109#discussion_r410237975 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner

tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner URL: https://github.com/apache/flink/pull/11109#discussion_r410252210 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner

tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner URL: https://github.com/apache/flink/pull/11109#discussion_r410218003 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner

tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner URL: https://github.com/apache/flink/pull/11109#discussion_r410258640 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner

tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner URL: https://github.com/apache/flink/pull/11109#discussion_r410255110 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner

tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner URL: https://github.com/apache/flink/pull/11109#discussion_r410253550 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner

tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner URL: https://github.com/apache/flink/pull/11109#discussion_r410285430 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner

tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner URL: https://github.com/apache/flink/pull/11109#discussion_r410267635 ## File path:

[jira] [Comment Edited] (FLINK-17225) Support native k8s for scala shell

[ https://issues.apache.org/jira/browse/FLINK-17225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17085846#comment-17085846 ] Chesnay Schepler edited comment on FLINK-17225 at 4/17/20, 3:02 PM:

[jira] [Comment Edited] (FLINK-17225) Support native k8s for scala shell

[ https://issues.apache.org/jira/browse/FLINK-17225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17085846#comment-17085846 ] Chesnay Schepler edited comment on FLINK-17225 at 4/17/20, 3:01 PM:

[GitHub] [flink] flinkbot edited a comment on issue #11793: [FLINK-16683][scripts] Remove Windows scripts

flinkbot edited a comment on issue #11793: [FLINK-16683][scripts] Remove Windows scripts URL: https://github.com/apache/flink/pull/11793#issuecomment-615233681 ## CI report: * 7f61a76e49a0bd7feb82219a9906959a2181f89b UNKNOWN * ffce7893389ccebb00f3359d7a18dade73644abe Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11783: [FLINK-17181][runtime] Drop generic Types in SchedulingTopology Interface

flinkbot edited a comment on issue #11783: [FLINK-17181][runtime] Drop generic Types in SchedulingTopology Interface URL: https://github.com/apache/flink/pull/11783#issuecomment-614741571 ## CI report: * 4f3513668d0ef9764bf08a082746eab35dfedefe Travis:

[GitHub] [flink] flinkbot commented on issue #11797: [FLINK-17169][table-blink] Refactor BaseRow to use RowKind instead of byte header

flinkbot commented on issue #11797: [FLINK-17169][table-blink] Refactor BaseRow to use RowKind instead of byte header URL: https://github.com/apache/flink/pull/11797#issuecomment-615294694 ## CI report: * 85f40e3041783b1dbda1eb3b812f23e77936f7b3 UNKNOWN Bot commands

[jira] [Commented] (FLINK-17225) Support native k8s for scala shell

[ https://issues.apache.org/jira/browse/FLINK-17225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17085846#comment-17085846 ] Chesnay Schepler commented on FLINK-17225: -- Given the current state of the scala shell not

[GitHub] [flink] flinkbot edited a comment on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on issue #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * c15a33465aff4a5bcbb0b32a75393c19ef3c4e1e

<    1   2   3   4   5   6   7   8   >