[GitHub] [flink] flinkbot edited a comment on issue #10764: [FLINK-13027][fs-connector] SFS bulk-encoded writer supports customized checkpoint policy

flinkbot edited a comment on issue #10764: [FLINK-13027][fs-connector] SFS bulk-encoded writer supports customized checkpoint policy URL: https://github.com/apache/flink/pull/10764#issuecomment-570760745 ## CI report: * 5a909d7767744f8c9030965b58fc0fbaa1c0cffb Travis: [SUCCESS](

[GitHub] [flink] flinkbot edited a comment on issue #10764: [FLINK-13027][fs-connector] SFS bulk-encoded writer supports customized checkpoint policy

flinkbot edited a comment on issue #10764: [FLINK-13027][fs-connector] SFS bulk-encoded writer supports customized checkpoint policy URL: https://github.com/apache/flink/pull/10764#issuecomment-570760745 ## CI report: * 5a909d7767744f8c9030965b58fc0fbaa1c0cffb Travis: [PENDING](

[jira] [Updated] (FLINK-15472) Support SQL Client Gateway

[ https://issues.apache.org/jira/browse/FLINK-15472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-15472: --- Description: FLIP-91: https://cwiki.apache.org/confluence/display/FLINK/FLIP-91%3A+Support+SQL+Clien

[GitHub] [flink] flinkbot commented on issue #10764: [FLINK-13027][fs-connector] SFS bulk-encoded writer supports customized checkpoint policy

flinkbot commented on issue #10764: [FLINK-13027][fs-connector] SFS bulk-encoded writer supports customized checkpoint policy URL: https://github.com/apache/flink/pull/10764#issuecomment-570760745 ## CI report: * 5a909d7767744f8c9030965b58fc0fbaa1c0cffb UNKNOWN Bot com

[GitHub] [flink] flinkbot commented on issue #10764: [FLINK-13027][fs-connector] SFS bulk-encoded writer supports customized checkpoint policy

flinkbot commented on issue #10764: [FLINK-13027][fs-connector] SFS bulk-encoded writer supports customized checkpoint policy URL: https://github.com/apache/flink/pull/10764#issuecomment-570759004 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] tweise opened a new pull request #10764: [FLINK-13027][fs-connector] SFS bulk-encoded writer supports customized checkpoint policy

tweise opened a new pull request #10764: [FLINK-13027][fs-connector] SFS bulk-encoded writer supports customized checkpoint policy URL: https://github.com/apache/flink/pull/10764 backport of https://github.com/apache/flink/pull/10653

[GitHub] [flink] tweise merged pull request #10653: [FLINK-13027][streaming]: StreamingFileSink bulk-encoded writer supports customized checkpoint policy

tweise merged pull request #10653: [FLINK-13027][streaming]: StreamingFileSink bulk-encoded writer supports customized checkpoint policy URL: https://github.com/apache/flink/pull/10653 This is an automated message from the A

[GitHub] [flink] flinkbot edited a comment on issue #10738: [FLINK-15385][table][docs] Translate SQL section of Table API into Chinese

flinkbot edited a comment on issue #10738: [FLINK-15385][table][docs] Translate SQL section of Table API into Chinese URL: https://github.com/apache/flink/pull/10738#issuecomment-570073257 ## CI report: * 8b4f68255a0a91f32757394d86405e46f60118c5 Travis: [SUCCESS](https://travis-

[GitHub] [flink] flinkbot edited a comment on issue #10716: [FLINK-15367][runtime] Handle backwards compatibility of "taskmanager.heap.size" differently for standalone / active setups

flinkbot edited a comment on issue #10716: [FLINK-15367][runtime] Handle backwards compatibility of "taskmanager.heap.size" differently for standalone / active setups URL: https://github.com/apache/flink/pull/10716#issuecomment-569571340 ## CI report: * 68e5c62f5520559749307a6e2

[GitHub] [flink] flinkbot edited a comment on issue #10653: [FLINK-13027][streaming]: StreamingFileSink bulk-encoded writer supports customized checkpoint policy

flinkbot edited a comment on issue #10653: [FLINK-13027][streaming]: StreamingFileSink bulk-encoded writer supports customized checkpoint policy URL: https://github.com/apache/flink/pull/10653#issuecomment-568135707 ## CI report: * b36738feabf0ce5dc1feeed6cf7940d61e771a0e Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10738: [FLINK-15385][table][docs] Translate SQL section of Table API into Chinese

flinkbot edited a comment on issue #10738: [FLINK-15385][table][docs] Translate SQL section of Table API into Chinese URL: https://github.com/apache/flink/pull/10738#issuecomment-570073257 ## CI report: * 8b4f68255a0a91f32757394d86405e46f60118c5 Travis: [SUCCESS](https://travis-

[GitHub] [flink] flinkbot edited a comment on issue #10717: [FLINK-15369][runtime] MiniCluster use fixed network / managed memory sizes by default

flinkbot edited a comment on issue #10717: [FLINK-15369][runtime] MiniCluster use fixed network / managed memory sizes by default URL: https://github.com/apache/flink/pull/10717#issuecomment-569571352 ## CI report: * 3e35131da349b322ab298ec38f55bfdc21ba0e17 Travis: [SUCCESS](htt

[GitHub] [flink] flinkbot edited a comment on issue #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source

flinkbot edited a comment on issue #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source URL: https://github.com/apache/flink/pull/10763#issuecomment-570630824 ## CI report: * 19e2bf9244667af4490f1463bdf48ba40d02e5ed T

[GitHub] [flink] flinkbot edited a comment on issue #10738: [FLINK-15385][table][docs] Translate SQL section of Table API into Chinese

flinkbot edited a comment on issue #10738: [FLINK-15385][table][docs] Translate SQL section of Table API into Chinese URL: https://github.com/apache/flink/pull/10738#issuecomment-570073257 ## CI report: * 8b4f68255a0a91f32757394d86405e46f60118c5 Travis: [SUCCESS](https://travis-

[GitHub] [flink] flinkbot edited a comment on issue #10716: [FLINK-15367][runtime] Handle backwards compatibility of "taskmanager.heap.size" differently for standalone / active setups

flinkbot edited a comment on issue #10716: [FLINK-15367][runtime] Handle backwards compatibility of "taskmanager.heap.size" differently for standalone / active setups URL: https://github.com/apache/flink/pull/10716#issuecomment-569571340 ## CI report: * 68e5c62f5520559749307a6e2

[GitHub] [flink] flinkbot edited a comment on issue #10653: [FLINK-13027][streaming]: StreamingFileSink bulk-encoded writer supports customized checkpoint policy

flinkbot edited a comment on issue #10653: [FLINK-13027][streaming]: StreamingFileSink bulk-encoded writer supports customized checkpoint policy URL: https://github.com/apache/flink/pull/10653#issuecomment-568135707 ## CI report: * b36738feabf0ce5dc1feeed6cf7940d61e771a0e Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source

flinkbot edited a comment on issue #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source URL: https://github.com/apache/flink/pull/10763#issuecomment-570630824 ## CI report: * 19e2bf9244667af4490f1463bdf48ba40d02e5ed T

[GitHub] [flink] flinkbot edited a comment on issue #10717: [FLINK-15369][runtime] MiniCluster use fixed network / managed memory sizes by default

flinkbot edited a comment on issue #10717: [FLINK-15369][runtime] MiniCluster use fixed network / managed memory sizes by default URL: https://github.com/apache/flink/pull/10717#issuecomment-569571352 ## CI report: * 3e35131da349b322ab298ec38f55bfdc21ba0e17 Travis: [SUCCESS](htt

[GitHub] [flink] flinkbot edited a comment on issue #10716: [FLINK-15367][runtime] Handle backwards compatibility of "taskmanager.heap.size" differently for standalone / active setups

flinkbot edited a comment on issue #10716: [FLINK-15367][runtime] Handle backwards compatibility of "taskmanager.heap.size" differently for standalone / active setups URL: https://github.com/apache/flink/pull/10716#issuecomment-569571340 ## CI report: * 68e5c62f5520559749307a6e2

[jira] [Assigned] (FLINK-11964) Avoid hash collision of partition and bucket in HybridHashTable in Blink SQL

[ https://issues.apache.org/jira/browse/FLINK-11964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-11964: -- Assignee: Jingsong Lee > Avoid hash collision of partition and bucket in HybridHashTable in B

[GitHub] [flink] xintongsong edited a comment on issue #10608: [FLINK-15300][Runtime] Fix sanity check to not fail if shuffle memory fraction is out of min/max range

xintongsong edited a comment on issue #10608: [FLINK-15300][Runtime] Fix sanity check to not fail if shuffle memory fraction is out of min/max range URL: https://github.com/apache/flink/pull/10608#issuecomment-570752333 @tillrohrmann I would consider `RangeFraction` as a data structure

[GitHub] [flink] xintongsong commented on issue #10608: [FLINK-15300][Runtime] Fix sanity check to not fail if shuffle memory fraction is out of min/max range

xintongsong commented on issue #10608: [FLINK-15300][Runtime] Fix sanity check to not fail if shuffle memory fraction is out of min/max range URL: https://github.com/apache/flink/pull/10608#issuecomment-570752333 @tillrohrmann I would consider `RangeFraction` as a data structure that se

[GitHub] [flink] flinkbot edited a comment on issue #10653: [FLINK-13027][streaming]: StreamingFileSink bulk-encoded writer supports customized checkpoint policy

flinkbot edited a comment on issue #10653: [FLINK-13027][streaming]: StreamingFileSink bulk-encoded writer supports customized checkpoint policy URL: https://github.com/apache/flink/pull/10653#issuecomment-568135707 ## CI report: * b36738feabf0ce5dc1feeed6cf7940d61e771a0e Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source

flinkbot edited a comment on issue #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source URL: https://github.com/apache/flink/pull/10763#issuecomment-570630824 ## CI report: * 19e2bf9244667af4490f1463bdf48ba40d02e5ed T

[GitHub] [flink] xintongsong commented on issue #10716: [FLINK-15367][runtime] Handle backwards compatibility of "taskmanager.heap.size" differently for standalone / active setups

xintongsong commented on issue #10716: [FLINK-15367][runtime] Handle backwards compatibility of "taskmanager.heap.size" differently for standalone / active setups URL: https://github.com/apache/flink/pull/10716#issuecomment-570750908 @tillrohrmann Thank you for the review. I've addressed y

[GitHub] [flink] flinkbot edited a comment on issue #10717: [FLINK-15369][runtime] MiniCluster use fixed network / managed memory sizes by default

flinkbot edited a comment on issue #10717: [FLINK-15369][runtime] MiniCluster use fixed network / managed memory sizes by default URL: https://github.com/apache/flink/pull/10717#issuecomment-569571352 ## CI report: * 3e35131da349b322ab298ec38f55bfdc21ba0e17 Travis: [SUCCESS](htt

[GitHub] [flink] flinkbot edited a comment on issue #10653: [FLINK-13027][streaming]: StreamingFileSink bulk-encoded writer supports customized checkpoint policy

flinkbot edited a comment on issue #10653: [FLINK-13027][streaming]: StreamingFileSink bulk-encoded writer supports customized checkpoint policy URL: https://github.com/apache/flink/pull/10653#issuecomment-568135707 ## CI report: * b36738feabf0ce5dc1feeed6cf7940d61e771a0e Travis:

[GitHub] [flink] xintongsong commented on issue #10717: [FLINK-15369][runtime] MiniCluster use fixed network / managed memory sizes by default

xintongsong commented on issue #10717: [FLINK-15369][runtime] MiniCluster use fixed network / managed memory sizes by default URL: https://github.com/apache/flink/pull/10717#issuecomment-570747981 @tillrohrmann, thanks for the review. I have addressed the comments. ---

[GitHub] [flink] yxu-valleytider commented on issue #10653: [FLINK-13027][streaming]: StreamingFileSink bulk-encoded writer supports customized checkpoint policy

yxu-valleytider commented on issue #10653: [FLINK-13027][streaming]: StreamingFileSink bulk-encoded writer supports customized checkpoint policy URL: https://github.com/apache/flink/pull/10653#issuecomment-570744150 Created [FLINK-15476](https://issues.apache.org/jira/browse/FLINK-15476) -

[jira] [Updated] (FLINK-15476) Update StreamingFileSink documentation -- bulk encoded writer now supports customized checkpoint policy

[ https://issues.apache.org/jira/browse/FLINK-15476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ying Xu updated FLINK-15476: Component/s: Documentation Description: Per FLINK-13027, {{StreamingFileSink}}'s bulk encoded writer (

[jira] [Created] (FLINK-15476) Update StreamingFileSink documentation -- bulk encoded writer now supports customized checkpoint policy

Ying Xu created FLINK-15476: --- Summary: Update StreamingFileSink documentation -- bulk encoded writer now supports customized checkpoint policy Key: FLINK-15476 URL: https://issues.apache.org/jira/browse/FLINK-15476

[GitHub] [flink] yxu-valleytider commented on issue #10653: [FLINK-13027][streaming]: StreamingFileSink bulk-encoded writer supports customized checkpoint policy

yxu-valleytider commented on issue #10653: [FLINK-13027][streaming]: StreamingFileSink bulk-encoded writer supports customized checkpoint policy URL: https://github.com/apache/flink/pull/10653#issuecomment-570741727 @tweise Thanks for the review. I can follow up with a separate PR addressin

[GitHub] [flink] flinkbot edited a comment on issue #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9

flinkbot edited a comment on issue #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9 URL: https://github.com/apache/flink/pull/10762#issuecomment-570591280 ## CI report: * 6bfb6d18af5fdfbddadf6da53adab78567d64aa9 Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/builds/143008

[jira] [Updated] (FLINK-15473) Add support for Linux on ppc64le to MemoryArchitecture

[ https://issues.apache.org/jira/browse/FLINK-15473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ronald O. Edmark updated FLINK-15473: - Priority: Major (was: Minor) > Add support for Linux on ppc64le to MemoryArchitecture >

[GitHub] [flink] flinkbot edited a comment on issue #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9

flinkbot edited a comment on issue #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9 URL: https://github.com/apache/flink/pull/10762#issuecomment-570591280 ## CI report: * 6bfb6d18af5fdfbddadf6da53adab78567d64aa9 Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/builds/143008

[GitHub] [flink] flinkbot edited a comment on issue #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9

flinkbot edited a comment on issue #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9 URL: https://github.com/apache/flink/pull/10762#issuecomment-570591280 ## CI report: * 6bfb6d18af5fdfbddadf6da53adab78567d64aa9 Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/builds/143008

[GitHub] [flink] flinkbot edited a comment on issue #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9

flinkbot edited a comment on issue #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9 URL: https://github.com/apache/flink/pull/10762#issuecomment-570591280 ## CI report: * 6bfb6d18af5fdfbddadf6da53adab78567d64aa9 Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/builds/143008

[GitHub] [flink] flinkbot edited a comment on issue #10692: [FLINK-15387] Expose missing RocksDB properties out via RocksDBNativeMetricOptions

flinkbot edited a comment on issue #10692: [FLINK-15387] Expose missing RocksDB properties out via RocksDBNativeMetricOptions URL: https://github.com/apache/flink/pull/10692#issuecomment-568924184 ## CI report: * cf3539fdec7d4ff9ad218545f3544b6cea3a2e24 Travis: [SUCCESS](https:/

[GitHub] [flink] flinkbot edited a comment on issue #10692: [FLINK-15387] Expose missing RocksDB properties out via RocksDBNativeMetricOptions

flinkbot edited a comment on issue #10692: [FLINK-15387] Expose missing RocksDB properties out via RocksDBNativeMetricOptions URL: https://github.com/apache/flink/pull/10692#issuecomment-568924184 ## CI report: * cf3539fdec7d4ff9ad218545f3544b6cea3a2e24 Travis: [SUCCESS](https:/

[GitHub] [flink] flinkbot edited a comment on issue #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager

flinkbot edited a comment on issue #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager URL: https://github.com/apache/flink/pull/10532#issuecomment-564535655 ## CI report: * 252fe96f7a6254a18341f78cdb1bcbd24ae25a1c Travis: [CANCELED](https://travi

[GitHub] [flink] flinkbot edited a comment on issue #10692: [FLINK-15387] Expose missing RocksDB properties out via RocksDBNativeMetricOptions

flinkbot edited a comment on issue #10692: [FLINK-15387] Expose missing RocksDB properties out via RocksDBNativeMetricOptions URL: https://github.com/apache/flink/pull/10692#issuecomment-568924184 ## CI report: * cf3539fdec7d4ff9ad218545f3544b6cea3a2e24 Travis: [SUCCESS](https:/

[GitHub] [flink] flinkbot edited a comment on issue #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source

flinkbot edited a comment on issue #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source URL: https://github.com/apache/flink/pull/10763#issuecomment-570630824 ## CI report: * 19e2bf9244667af4490f1463bdf48ba40d02e5ed T

[GitHub] [flink] flinkbot edited a comment on issue #10692: [FLINK-15387] Expose missing RocksDB properties out via RocksDBNativeMetricOptions

flinkbot edited a comment on issue #10692: [FLINK-15387] Expose missing RocksDB properties out via RocksDBNativeMetricOptions URL: https://github.com/apache/flink/pull/10692#issuecomment-568924184 ## CI report: * cf3539fdec7d4ff9ad218545f3544b6cea3a2e24 Travis: [SUCCESS](https:/

[GitHub] [flink] flinkbot edited a comment on issue #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager

flinkbot edited a comment on issue #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager URL: https://github.com/apache/flink/pull/10532#issuecomment-564535655 ## CI report: * 252fe96f7a6254a18341f78cdb1bcbd24ae25a1c Travis: [CANCELED](https://travi

[GitHub] [flink] flinkbot edited a comment on issue #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source

flinkbot edited a comment on issue #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source URL: https://github.com/apache/flink/pull/10763#issuecomment-570630824 ## CI report: * 19e2bf9244667af4490f1463bdf48ba40d02e5ed T

[jira] [Updated] (FLINK-15475) Add isOutputTypeUsed() API to Transformation

[ https://issues.apache.org/jira/browse/FLINK-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-15475: -- Description: Currently there's no way to "peek" into a `Transformation` object and see if `typeUsed`

[GitHub] [flink] flinkbot edited a comment on issue #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager

flinkbot edited a comment on issue #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager URL: https://github.com/apache/flink/pull/10532#issuecomment-564535655 ## CI report: * 252fe96f7a6254a18341f78cdb1bcbd24ae25a1c Travis: [CANCELED](https://travi

[jira] [Updated] (FLINK-15475) Add isOutputTypeUsed() API to Transformation

[ https://issues.apache.org/jira/browse/FLINK-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-15475: -- Description: Currently there's no way to "peek" into a `Transformation` object and see if `typeUsed`

[jira] [Updated] (FLINK-15475) Add isOutputTypeUsed() API to Transformation

[ https://issues.apache.org/jira/browse/FLINK-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-15475: -- Description: Currently there's no way to "peek" into a `Transformation` object and see if `typeUsed`

[GitHub] [flink] walterddr commented on issue #9373: [FLINK-13596][ml] Add two utils for Table transformations

walterddr commented on issue #9373: [FLINK-13596][ml] Add two utils for Table transformations URL: https://github.com/apache/flink/pull/9373#issuecomment-570632426 thanks @qiuxiafei for the contribution. I've added https://issues.apache.org/jira/browse/FLINK-15475 to track the improvement

[jira] [Created] (FLINK-15475) Add isOutputTypeUsed() API to Transformation

Rong Rong created FLINK-15475: - Summary: Add isOutputTypeUsed() API to Transformation Key: FLINK-15475 URL: https://issues.apache.org/jira/browse/FLINK-15475 Project: Flink Issue Type: Improvemen

[GitHub] [flink] Myasuka commented on a change in pull request #10692: [FLINK-15387] Expose missing RocksDB properties out via RocksDBNativeMetricOptions

Myasuka commented on a change in pull request #10692: [FLINK-15387] Expose missing RocksDB properties out via RocksDBNativeMetricOptions URL: https://github.com/apache/flink/pull/10692#discussion_r362882872 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java

[GitHub] [flink] flinkbot commented on issue #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source

flinkbot commented on issue #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source URL: https://github.com/apache/flink/pull/10763#issuecomment-570630824 ## CI report: * 19e2bf9244667af4490f1463bdf48ba40d02e5ed UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #10761: [FLINK-15457][yarn] Remove finished TODO in YarnEntrypointUtils

flinkbot edited a comment on issue #10761: [FLINK-15457][yarn] Remove finished TODO in YarnEntrypointUtils URL: https://github.com/apache/flink/pull/10761#issuecomment-570553190 ## CI report: * 544ee0be382ed4beaa34e9c56c59efb6bc36a384 Travis: [SUCCESS](https://travis-ci.com/flin

[GitHub] [flink] flinkbot edited a comment on issue #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9

flinkbot edited a comment on issue #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9 URL: https://github.com/apache/flink/pull/10762#issuecomment-570591280 ## CI report: * 6bfb6d18af5fdfbddadf6da53adab78567d64aa9 Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/builds/143008

[jira] [Commented] (FLINK-12462) Classloading fails in 1.8.0 when Scalatest is loaded first

[ https://issues.apache.org/jira/browse/FLINK-12462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007621#comment-17007621 ] sophie commented on FLINK-12462: So the upgrade fails, u still use the workaround? [~gae

[GitHub] [flink] wangyang0918 commented on issue #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager

wangyang0918 commented on issue #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager URL: https://github.com/apache/flink/pull/10532#issuecomment-570628439 @tillrohrmann I have added a fixup to address your comments. Please take a look. -

[GitHub] [flink] walterddr closed pull request #9373: [FLINK-13596][ml] Add two utils for Table transformations

walterddr closed pull request #9373: [FLINK-13596][ml] Add two utils for Table transformations URL: https://github.com/apache/flink/pull/9373 This is an automated message from the Apache Git Service. To respond to the messag

[jira] [Comment Edited] (FLINK-12462) Classloading fails in 1.8.0 when Scalatest is loaded first

[ https://issues.apache.org/jira/browse/FLINK-12462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006936#comment-17006936 ] Gaël Renoux edited comment on FLINK-12462 at 1/3/20 4:44 PM: -

[jira] [Issue Comment Deleted] (FLINK-12461) Flink 1.8 not working with Scala 2.12.8

[ https://issues.apache.org/jira/browse/FLINK-12461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gaël Renoux updated FLINK-12461: Comment: was deleted (was: I messed up my test, Flink 1.9.1 has the same problem. It's still only

[jira] [Comment Edited] (FLINK-12461) Flink 1.8 not working with Scala 2.12.8

[ https://issues.apache.org/jira/browse/FLINK-12461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006931#comment-17006931 ] Gaël Renoux edited comment on FLINK-12461 at 1/3/20 4:44 PM: -

[jira] [Comment Edited] (FLINK-12462) Classloading fails in 1.8.0 when Scalatest is loaded first

[ https://issues.apache.org/jira/browse/FLINK-12462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006936#comment-17006936 ] Gaël Renoux edited comment on FLINK-12462 at 1/3/20 4:43 PM: -

[jira] [Issue Comment Deleted] (FLINK-12462) Classloading fails in 1.8.0 when Scalatest is loaded first

[ https://issues.apache.org/jira/browse/FLINK-12462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gaël Renoux updated FLINK-12462: Comment: was deleted (was: I spoke too soon, I messed up my test. It still doesn't work.) > Class

[jira] [Commented] (FLINK-12461) Flink 1.8 not working with Scala 2.12.8

[ https://issues.apache.org/jira/browse/FLINK-12461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007618#comment-17007618 ] Gaël Renoux commented on FLINK-12461: - I messed up my test, Flink 1.9.1 has the same

[GitHub] [flink] wangyang0918 edited a comment on issue #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager

wangyang0918 edited a comment on issue #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager URL: https://github.com/apache/flink/pull/10532#issuecomment-570588137 @tillrohrmann I take a serious consideration and tend to remove the windows escape code. Since t

[jira] [Commented] (FLINK-12462) Classloading fails in 1.8.0 when Scalatest is loaded first

[ https://issues.apache.org/jira/browse/FLINK-12462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007615#comment-17007615 ] Gaël Renoux commented on FLINK-12462: - I spoke too soon, I messed up my test. It sti

[GitHub] [flink] wangyang0918 edited a comment on issue #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager

wangyang0918 edited a comment on issue #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager URL: https://github.com/apache/flink/pull/10532#issuecomment-570588137 @tillrohrmann I take a serious consideration and tend to remove the windows escape code. Since t

[GitHub] [flink] flinkbot edited a comment on issue #10761: [FLINK-15457][yarn] Remove finished TODO in YarnEntrypointUtils

flinkbot edited a comment on issue #10761: [FLINK-15457][yarn] Remove finished TODO in YarnEntrypointUtils URL: https://github.com/apache/flink/pull/10761#issuecomment-570553190 ## CI report: * 544ee0be382ed4beaa34e9c56c59efb6bc36a384 Travis: [SUCCESS](https://travis-ci.com/flin

[GitHub] [flink] flinkbot commented on issue #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source

flinkbot commented on issue #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source URL: https://github.com/apache/flink/pull/10763#issuecomment-570620627 Thanks a lot for your contribution to the Apache Flink project. I'm the @fl

[jira] [Updated] (FLINK-14200) Temporal Table Function Joins do not work on Tables (only TableSources) on the query side

[ https://issues.apache.org/jira/browse/FLINK-14200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14200: --- Labels: pull-request-available (was: ) > Temporal Table Function Joins do not work on Table

[GitHub] [flink] wuchong opened a new pull request #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source

wuchong opened a new pull request #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source URL: https://github.com/apache/flink/pull/10763 ## What is the purpose of the change Fix NPE when left input is a query (e

[jira] [Commented] (FLINK-11120) The bug of timestampadd handles time

[ https://issues.apache.org/jira/browse/FLINK-11120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007605#comment-17007605 ] Rong Rong commented on FLINK-11120: --- Hi [~x1q1j1] yes it will be in 1.10 release and i

[jira] [Comment Edited] (FLINK-15462) Support Prestosql JDBC source/sink

[ https://issues.apache.org/jira/browse/FLINK-15462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007560#comment-17007560 ] li yu edited comment on FLINK-15462 at 1/3/20 4:16 PM: --- [~lzljs362

[GitHub] [flink] GJL commented on issue #10116: [FLINK-14655] Change Type of Field jobStatusListeners from CopyOnWriteArrayList to ArrayList

GJL commented on issue #10116: [FLINK-14655] Change Type of Field jobStatusListeners from CopyOnWriteArrayList to ArrayList URL: https://github.com/apache/flink/pull/10116#issuecomment-570619142 Merging. This is an automated

[jira] [Updated] (FLINK-14765) Remove STATE_UPDATER in Execution

[ https://issues.apache.org/jira/browse/FLINK-14765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-14765: - Description: After making access to ExecutionGraph single-threaded in FLINK-11417, we can simplify execu

[jira] [Closed] (FLINK-14765) Remove STATE_UPDATER in Execution

[ https://issues.apache.org/jira/browse/FLINK-14765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-14765. Resolution: Fixed master: f503664da181972f12aae6af2e8e6eb71d356085 > Remove STATE_UPDATER in Execution >

[GitHub] [flink] GJL closed pull request #10288: [FLINK-14765] Remove STATE_UPDATER in Execution

GJL closed pull request #10288: [FLINK-14765] Remove STATE_UPDATER in Execution URL: https://github.com/apache/flink/pull/10288 This is an automated message from the Apache Git Service. To respond to the message, please log o

[GitHub] [flink] wangyang0918 edited a comment on issue #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager

wangyang0918 edited a comment on issue #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager URL: https://github.com/apache/flink/pull/10532#issuecomment-570588137 @tillrohrmann I take a serious consideration and tend to remove the windows escape code. Since t

[GitHub] [flink] flinkbot edited a comment on issue #10761: [FLINK-15457][yarn] Remove finished TODO in YarnEntrypointUtils

flinkbot edited a comment on issue #10761: [FLINK-15457][yarn] Remove finished TODO in YarnEntrypointUtils URL: https://github.com/apache/flink/pull/10761#issuecomment-570553190 ## CI report: * 544ee0be382ed4beaa34e9c56c59efb6bc36a384 Travis: [SUCCESS](https://travis-ci.com/flin

[GitHub] [flink] flinkbot edited a comment on issue #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9

flinkbot edited a comment on issue #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9 URL: https://github.com/apache/flink/pull/10762#issuecomment-570591280 ## CI report: * 6bfb6d18af5fdfbddadf6da53adab78567d64aa9 Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/builds/143008

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#discussion_r362825818 ## File path: flink-runtime/src/test/java/org/

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#discussion_r362852268 ## File path: flink-runtime/src/main/java/org/

[jira] [Assigned] (FLINK-14200) Temporal Table Function Joins do not work on Tables (only TableSources) on the query side

[ https://issues.apache.org/jira/browse/FLINK-14200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14200: --- Assignee: Jark Wu > Temporal Table Function Joins do not work on Tables (only TableSources) on > t

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#discussion_r362821873 ## File path: flink-runtime/src/main/java/org/

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#discussion_r362823684 ## File path: flink-runtime/src/test/java/org/

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#discussion_r362841392 ## File path: flink-runtime/src/test/java/org/

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#discussion_r362840043 ## File path: flink-runtime/src/test/java/org/

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#discussion_r362840658 ## File path: flink-runtime/src/test/java/org/

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#discussion_r362826624 ## File path: flink-runtime/src/main/java/org/

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#discussion_r362835993 ## File path: flink-runtime/src/main/java/org/

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#discussion_r362826149 ## File path: flink-runtime/src/test/java/org/

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#discussion_r362836388 ## File path: flink-runtime/src/main/java/org/

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#discussion_r362847991 ## File path: flink-runtime/src/test/java/org/

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#discussion_r362841198 ## File path: flink-runtime/src/test/java/org/

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#discussion_r362839773 ## File path: flink-runtime/src/test/java/org/

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#discussion_r362825084 ## File path: flink-runtime/src/test/java/org/

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#discussion_r362836806 ## File path: flink-runtime/src/test/java/org/

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#discussion_r362826032 ## File path: flink-runtime/src/test/java/org/

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#discussion_r362829356 ## File path: flink-runtime/src/main/java/org/

[GitHub] [flink] tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

tillrohrmann commented on a change in pull request #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#discussion_r362823661 ## File path: flink-runtime/src/test/java/org/

  1   2   3   4   >