[GitHub] [flink] aljoscha closed pull request #7547: [FLINK-11401] Allow setting of compression on ParquetWriter

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

[jira] [Closed] (FLINK-20725) TableFunction#getTypeInference is not work well for JdbcRowDataLookupFunction, it's always throws Exception

[ https://issues.apache.org/jira/browse/FLINK-20725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-20725. Resolution: Won't Fix The contributor did not respond. I will close this issue for now. Feel free

[GitHub] [flink] tillrohrmann closed pull request #14515: [FLINK-20770][k8s] Correct the description of kubernetes config option 'kubernetes.rest-service.exposed.type'

tillrohrmann closed pull request #14515: URL: https://github.com/apache/flink/pull/14515 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 g

[GitHub] [flink] flinkbot commented on pull request #14616: [FLINK-20879][table-api] Use MemorySize type instead of String type for memory ConfigOption in ExecutionConfigOptions

flinkbot commented on pull request #14616: URL: https://github.com/apache/flink/pull/14616#issuecomment-758518623 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-20879) Use MemorySize type instead of String type for memory ConfigOption in ExecutionConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-20879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20879: --- Labels: pull-request-available (was: ) > Use MemorySize type instead of String type for mem

[GitHub] [flink] xiaoHoly opened a new pull request #14616: [FLINK-20879][table-api] Use MemorySize type instead of String type for memory ConfigOption in ExecutionConfigOptions

xiaoHoly opened a new pull request #14616: URL: https://github.com/apache/flink/pull/14616 ## What is the purpose of the change Use MemorySize type instead of String type for memory ConfigOption in ExecutionConfigOptions ## Brief change log ## Verify

[jira] [Updated] (FLINK-20937) Drop table can fails, when i create a table with "watermark for proctime()" syntax

[ https://issues.apache.org/jira/browse/FLINK-20937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangzq updated FLINK-20937: --- Attachment: drop table fail.png > Drop table can fails, when i create a table with "watermark for proctime()

[jira] [Updated] (FLINK-20937) Drop table can fails, when i create a table with "watermark for proctime()" syntax

[ https://issues.apache.org/jira/browse/FLINK-20937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangzq updated FLINK-20937: --- Attachment: (was: image-2021-01-12-16-47-53-894.png) > Drop table can fails, when i create a table with

[jira] [Created] (FLINK-20937) Drop table can fails, when i create a table with "watermark for proctime()" syntax

wangzq created FLINK-20937: -- Summary: Drop table can fails, when i create a table with "watermark for proctime()" syntax Key: FLINK-20937 URL: https://issues.apache.org/jira/browse/FLINK-20937 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #14615: [FLINK-20930][runtime] Remove AbstractExecutionSlotAllocator

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

[GitHub] [flink] flinkbot commented on pull request #14614: [FLINK-20911][state-backend-rocksdb] Support configuration of RocksDB log level

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

[GitHub] [flink] flinkbot edited a comment on pull request #14613: [FLINK-20935][yarn] can't write flink configuration to tmp file and a…

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

[GitHub] [flink] gaoyunhaii commented on a change in pull request #14558: [FLINK-18685] [runtime] Make MiniClusterJobClient#getAccumulators non-blocking in Streaming mode

gaoyunhaii commented on a change in pull request #14558: URL: https://github.com/apache/flink/pull/14558#discussion_r97955 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterJobClient.java ## @@ -106,7 +108,25 @@ public JobID getJobID

[GitHub] [flink] gaoyunhaii commented on pull request #14558: [FLINK-18685] [runtime] Make MiniClusterJobClient#getAccumulators non-blocking in Streaming mode

gaoyunhaii commented on pull request #14558: URL: https://github.com/apache/flink/pull/14558#issuecomment-758508420 > @rmetzger I fixed one of the failing tests. But for _UnalignedCheckpointCompatibilityITCase_ savepoint tests, I know we need to get the accumulators from _JobExecutionResul

[GitHub] [flink] flinkbot commented on pull request #14615: [FLINK-20930][runtime] Remove AbstractExecutionSlotAllocator

flinkbot commented on pull request #14615: URL: https://github.com/apache/flink/pull/14615#issuecomment-758507929 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-20930) Remove AbstractExecutionSlotAllocator

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

[GitHub] [flink] SteNicholas opened a new pull request #14615: [FLINK-20930][runtime] Remove AbstractExecutionSlotAllocator

SteNicholas opened a new pull request #14615: URL: https://github.com/apache/flink/pull/14615 ## What is the purpose of the change *`DefaultExecutionSlotAllocator` was removed in #14465. Therefore `AbstractExecutionSlotAllocator` is no longer used and could be removed.* ## Bri

[GitHub] [flink] flinkbot commented on pull request #14614: [FLINK-20911][state-backend-rocksdb] Support configuration of RocksDB log level

flinkbot commented on pull request #14614: URL: https://github.com/apache/flink/pull/14614#issuecomment-758504127 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-20911) Support configuration of RocksDB log level

[ https://issues.apache.org/jira/browse/FLINK-20911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20911: --- Labels: pull-request-available (was: ) > Support configuration of RocksDB log level > -

[GitHub] [flink] 1996fanrui opened a new pull request #14614: [FLINK-20911][state-backend-rocksdb] Support configuration of RocksDB log level

1996fanrui opened a new pull request #14614: URL: https://github.com/apache/flink/pull/14614 ## What is the purpose of the change Support configuration of RocksDB log level ## Brief change log - add config `state.backend.rocksdb.log.level` ## Verifying this chan

[GitHub] [flink] gaoyunhaii commented on a change in pull request #14558: [FLINK-18685] [runtime] Make MiniClusterJobClient#getAccumulators non-blocking in Streaming mode

gaoyunhaii commented on a change in pull request #14558: URL: https://github.com/apache/flink/pull/14558#discussion_r97955 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterJobClient.java ## @@ -106,7 +108,25 @@ public JobID getJobID

[jira] [Updated] (FLINK-20911) Support configuration of RocksDB log level

[ https://issues.apache.org/jira/browse/FLINK-20911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fanrui updated FLINK-20911: --- Summary: Support configuration of RocksDB log level (was: Support to modify RocksDB LOG level) > Support c

[GitHub] [flink] flinkbot edited a comment on pull request #14607: [FLINK-20921][python] Support SqlTimeTypeInfo in Python DataStream

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

[GitHub] [flink] flinkbot edited a comment on pull request #14597: [FLINK-20905][k8s] Format the description of 'kubernetes.container.image' option

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

[GitHub] [flink] flinkbot edited a comment on pull request #14606: [Flink-20876][table-planner-blink] Separate the implementation of StreamExecTemporalJoin

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

[GitHub] [flink] flinkbot edited a comment on pull request #14567: [FLINK-20453][runtime][checkpoint] Move checkpointing classes to an a…

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

[GitHub] [flink] flinkbot edited a comment on pull request #14536: [FLINK-20812][Connector][Hbase] hbase in sql mode,can use 'properties.*' add Configuration parameter.

flinkbot edited a comment on pull request #14536: URL: https://github.com/apache/flink/pull/14536#issuecomment-752909965 ## CI report: * a4c6b2e3d222c1679ce19d21a7f108d63d8dc3fc UNKNOWN * e8c1e77209e80aa39985342f01c3d8d566220d1a UNKNOWN * ba7aceff1a94c93ce89ed15359c992f62ad8

[GitHub] [flink] flinkbot edited a comment on pull request #14530: [FLINK-20348][kafka] Make "schema-registry.subject" optional for Kafka sink with avro-confluent format

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

[jira] [Assigned] (FLINK-20879) Use MemorySize type instead of String type for memory ConfigOption in ExecutionConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-20879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20879: --- Assignee: jiawen xiao > Use MemorySize type instead of String type for memory ConfigOption in > Ex

[GitHub] [flink] flinkbot edited a comment on pull request #14597: [FLINK-20905][k8s] Format the description of 'kubernetes.container.image' option

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

[GitHub] [flink] flinkbot edited a comment on pull request #14567: [FLINK-20453][runtime][checkpoint] Move checkpointing classes to an a…

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

[GitHub] [flink] flinkbot edited a comment on pull request #14536: [FLINK-20812][Connector][Hbase] hbase in sql mode,can use 'properties.*' add Configuration parameter.

flinkbot edited a comment on pull request #14536: URL: https://github.com/apache/flink/pull/14536#issuecomment-752909965 ## CI report: * a4c6b2e3d222c1679ce19d21a7f108d63d8dc3fc UNKNOWN * e8c1e77209e80aa39985342f01c3d8d566220d1a UNKNOWN * ba7aceff1a94c93ce89ed15359c992f62ad8

[GitHub] [flink] flinkbot edited a comment on pull request #14530: [FLINK-20348][kafka] Make "schema-registry.subject" optional for Kafka sink with avro-confluent format

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

[GitHub] [flink] flinkbot edited a comment on pull request #14516: [FLINK-20783][table-planner-blink] Separate implementation of ExecNode and PhysicalNode in batch join

flinkbot edited a comment on pull request #14516: URL: https://github.com/apache/flink/pull/14516#issuecomment-752024061 ## CI report: * 61ab76b08a6b4603d6f9dd554bddd742a8d6fde9 UNKNOWN * 0ca863216b6a5d5e54f833bacf6eb5c794bb142d Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] wangyang0918 commented on pull request #14597: [FLINK-20905][k8s] Format the description of 'kubernetes.container.image' option

wangyang0918 commented on pull request #14597: URL: https://github.com/apache/flink/pull/14597#issuecomment-758479683 cc @xintongsong Could you have a final check and help with merging? This is an automated message from the A

[jira] [Commented] (FLINK-9806) Add a canonical link element to documentation HTML

[ https://issues.apache.org/jira/browse/FLINK-9806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17263139#comment-17263139 ] wiwa888 commented on FLINK-9806: https://mgwin88-th.com/casino.html > Add a canonical li

<    1   2   3   4   5