[GitHub] [flink] BenoitHanotte opened a new pull request #10843: [FLINK-15565][table-planner-blink] Remove deprecated logic in LogicalTypeDataTypeConverter.fromDataTypeToLogicalType

BenoitHanotte opened a new pull request #10843: [FLINK-15565][table-planner-blink] Remove deprecated logic in LogicalTypeDataTypeConverter.fromDataTypeToLogicalType URL: https://github.com/apache/flink/pull/10843 ## What is the purpose of the change It seems there exists 2 paths to

[jira] [Commented] (FLINK-15557) Cannot connect to Azure Event Hub/Kafka since Jan 5th 2020. Kafka version issue

[ https://issues.apache.org/jira/browse/FLINK-15557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014339#comment-17014339 ] Chris commented on FLINK-15557: --- We have discovered that the issue is specifically related to entity level

[GitHub] [flink] azagrebin commented on issue #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

azagrebin commented on issue #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#issuecomment-573687637 Thanks for the review @tillrohrmann, I addressed comments.

[GitHub] [flink] azagrebin 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

azagrebin 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_r365830481 ## File path:

[GitHub] [flink] flinkbot commented on issue #10843: [FLINK-15574][table-planner-blink] Remove deprecated logic in LogicalTypeDataTypeConverter.fromDataTypeToLogicalType

flinkbot commented on issue #10843: [FLINK-15574][table-planner-blink] Remove deprecated logic in LogicalTypeDataTypeConverter.fromDataTypeToLogicalType URL: https://github.com/apache/flink/pull/10843#issuecomment-573702126 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10835: [FLINK-15533] Fix parallelism setting propagation during graph instantiation.

flinkbot edited a comment on issue #10835: [FLINK-15533] Fix parallelism setting propagation during graph instantiation. URL: https://github.com/apache/flink/pull/10835#issuecomment-573416112 ## CI report: * 0590888514ff79680992bf39f72235a4d90bb75b Travis:

[jira] [Closed] (FLINK-15541) FlinkKinesisConsumerTest.testSourceSynchronization is unstable on travis.

[ https://issues.apache.org/jira/browse/FLINK-15541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-15541. Resolution: Fixed Fixed on release-1.10 in 5bea705408ba455bd462d72d6943a59ee46e2a90 Fixed

[jira] [Updated] (FLINK-15541) FlinkKinesisConsumerTest.testSourceSynchronization is unstable on travis.

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

[GitHub] [flink] aljoscha closed pull request #10837: [FLINK-15541] Fix unstable case FlinkKinesisConsumerTest

aljoscha closed pull request #10837: [FLINK-15541] Fix unstable case FlinkKinesisConsumerTest URL: https://github.com/apache/flink/pull/10837 This is an automated message from the Apache Git Service. To respond to the

[jira] [Updated] (FLINK-15474) In TypeSerializerUpgradeTestBase, create serializer snapshots "on demand"

[ https://issues.apache.org/jira/browse/FLINK-15474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-15474: - Issue Type: Improvement (was: Bug) > In TypeSerializerUpgradeTestBase, create

[GitHub] [flink] flinkbot commented on issue #10845: [FLINK-15355][plugins] Classloader avoids loading unrelated services.

flinkbot commented on issue #10845: [FLINK-15355][plugins] Classloader avoids loading unrelated services. URL: https://github.com/apache/flink/pull/10845#issuecomment-573728399 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] flinkbot edited a comment on issue #10835: [FLINK-15533] Fix parallelism setting propagation during graph instantiation.

flinkbot edited a comment on issue #10835: [FLINK-15533] Fix parallelism setting propagation during graph instantiation. URL: https://github.com/apache/flink/pull/10835#issuecomment-573416112 ## CI report: * 0590888514ff79680992bf39f72235a4d90bb75b Travis:

[jira] [Commented] (FLINK-15355) Nightly streaming file sink fails with unshaded hadoop

[ https://issues.apache.org/jira/browse/FLINK-15355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014442#comment-17014442 ] Arvid Heise commented on FLINK-15355: - [~liyu], you are right this issue is related to the

[jira] [Comment Edited] (FLINK-15574) DataType to LogicalType conversion issue

[ https://issues.apache.org/jira/browse/FLINK-15574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014333#comment-17014333 ] Benoit Hanotte edited comment on FLINK-15574 at 1/13/20 4:35 PM: - I

[jira] [Created] (FLINK-15574) DataType to LogicalType conversion issue

Benoit Hanotte created FLINK-15574: -- Summary: DataType to LogicalType conversion issue Key: FLINK-15574 URL: https://issues.apache.org/jira/browse/FLINK-15574 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on issue #10604: [FLINK-15292] Rename Executor to PipelineExecutor

flinkbot edited a comment on issue #10604: [FLINK-15292] Rename Executor to PipelineExecutor URL: https://github.com/apache/flink/pull/10604#issuecomment-566505090 ## CI report: * c9c41c58f335e2e737a1e234ae84c3ac6c401df6 Travis:

[GitHub] [flink] zentol merged pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9

zentol merged pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9 URL: https://github.com/apache/flink/pull/10762 This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] azagrebin 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

azagrebin 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_r365833036 ## File path:

[jira] [Commented] (FLINK-15318) RocksDBWriteBatchPerformanceTest.benchMark fails on ppc64le

[ https://issues.apache.org/jira/browse/FLINK-15318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014379#comment-17014379 ] Ronald O. Edmark commented on FLINK-15318: -- [~yunta] thanks again for helping.   This is a

[jira] [Updated] (FLINK-15530) Replace process memory with flink memory for TMs in default flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-15530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-15530: Description: The issue is based on the discussion outcome on [Dev

[jira] [Updated] (FLINK-15559) Missing {{site.baseurl}} in some docs

[ https://issues.apache.org/jira/browse/FLINK-15559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15559: --- Labels: pull-request-available (was: ) > Missing {{site.baseurl}} in some docs >

[GitHub] [flink] libenchao opened a new pull request #10844: [FLINK-15559][docs] Fix broken links due to missing baseurl

libenchao opened a new pull request #10844: [FLINK-15559][docs] Fix broken links due to missing baseurl URL: https://github.com/apache/flink/pull/10844 ## What is the purpose of the change Fix broken links in docs due to missing baseurl. ## Brief change log Fix

[GitHub] [flink] flinkbot commented on issue #10845: [FLINK-15355][plugins] Classloader avoids loading unrelated services.

flinkbot commented on issue #10845: [FLINK-15355][plugins] Classloader avoids loading unrelated services. URL: https://github.com/apache/flink/pull/10845#issuecomment-573736294 ## CI report: * 0942cb8b913ba50ecf8d7ca28832c4c92bf78e6c UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on issue #10843: [FLINK-15574][table-planner-blink] Remove deprecated logic in LogicalTypeDataTypeConverter.fromDataTypeToLogicalType

flinkbot edited a comment on issue #10843: [FLINK-15574][table-planner-blink] Remove deprecated logic in LogicalTypeDataTypeConverter.fromDataTypeToLogicalType URL: https://github.com/apache/flink/pull/10843#issuecomment-573702126 ## CI report: *

[GitHub] [flink] flinkbot commented on issue #10844: [FLINK-15559][docs] Fix broken links due to missing baseurl

flinkbot commented on issue #10844: [FLINK-15559][docs] Fix broken links due to missing baseurl URL: https://github.com/apache/flink/pull/10844#issuecomment-573736138 ## CI report: * a356df63a802f15c8a1e6982cf68c51da30b454c UNKNOWN Bot commands The @flinkbot bot

[jira] [Updated] (FLINK-15574) DataType to LogicalType conversion issue

[ https://issues.apache.org/jira/browse/FLINK-15574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoit Hanotte updated FLINK-15574: --- Description: We seem to be encountering an issue with the conversion from DataType to

[GitHub] [flink] flinkbot edited a comment on issue #10841: [FLINK-15565][table-planner-blink] Fix error conversion of TinyInt, SmallInt literals between Flink and Calcite

flinkbot edited a comment on issue #10841: [FLINK-15565][table-planner-blink] Fix error conversion of TinyInt,SmallInt literals between Flink and Calcite URL: https://github.com/apache/flink/pull/10841#issuecomment-573572659 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10842: [FLINK-15489][web]: add cache control no-cache to log api

flinkbot edited a comment on issue #10842: [FLINK-15489][web]: add cache control no-cache to log api URL: https://github.com/apache/flink/pull/10842#issuecomment-573632115 ## CI report: * fbc3d61dc5657907e9e55497cf70431ceff2d2d9 Travis:

[GitHub] [flink] azagrebin 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

azagrebin 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_r365814215 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10841: [FLINK-15565][table-planner-blink] Fix error conversion of TinyInt, SmallInt literals between Flink and Calcite

flinkbot edited a comment on issue #10841: [FLINK-15565][table-planner-blink] Fix error conversion of TinyInt,SmallInt literals between Flink and Calcite URL: https://github.com/apache/flink/pull/10841#issuecomment-573572659 ## CI report: *

[GitHub] [flink] kl0u commented on a change in pull request #10835: [FLINK-15533] Fix parallelism setting propagation during graph instantiation.

kl0u commented on a change in pull request #10835: [FLINK-15533] Fix parallelism setting propagation during graph instantiation. URL: https://github.com/apache/flink/pull/10835#discussion_r365821297 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10604: [FLINK-15292] Rename Executor to PipelineExecutor

flinkbot edited a comment on issue #10604: [FLINK-15292] Rename Executor to PipelineExecutor URL: https://github.com/apache/flink/pull/10604#issuecomment-566505090 ## CI report: * c9c41c58f335e2e737a1e234ae84c3ac6c401df6 Travis:

[jira] [Commented] (FLINK-14163) Execution#producedPartitions is possibly not assigned when used

[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014376#comment-17014376 ] Andrey Zagrebin commented on FLINK-14163: - Thanks [~zjwang] and [~ym] ! The question is how long

[GitHub] [flink] aljoscha commented on issue #10837: [FLINK-15541] Fix unstable case FlinkKinesisConsumerTest

aljoscha commented on issue #10837: [FLINK-15541] Fix unstable case FlinkKinesisConsumerTest URL: https://github.com/apache/flink/pull/10837#issuecomment-573708186 Yes, this looks good! I'll merge it. This is an automated

[GitHub] [flink] flinkbot edited a comment on issue #10674: [FLINK-15220][Connector/Kafka][Table] Add startFromTimestamp in KafkaTableSource

flinkbot edited a comment on issue #10674: [FLINK-15220][Connector/Kafka][Table] Add startFromTimestamp in KafkaTableSource URL: https://github.com/apache/flink/pull/10674#issuecomment-568687684 ## CI report: * f59106d121f9dd0fc40b23640ec2ad8a663d6020 Travis:

[GitHub] [flink] GJL commented on a change in pull request #10814: [FLINK-15434][Tests]Fix unstable tests in JobMasterTest

GJL commented on a change in pull request #10814: [FLINK-15434][Tests]Fix unstable tests in JobMasterTest URL: https://github.com/apache/flink/pull/10814#discussion_r365855118 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterTest.java

[jira] [Commented] (FLINK-13590) flink-on-yarn sometimes could create many little files that are xxx-taskmanager-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-13590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014422#comment-17014422 ] Gary Yao commented on FLINK-13590: -- In my opinion a backport to 1.7 is not needed. > flink-on-yarn

[jira] [Assigned] (FLINK-15517) Use back 'network' in 'shuffle' memory config option names

[ https://issues.apache.org/jira/browse/FLINK-15517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-15517: --- Assignee: Andrey Zagrebin > Use back 'network' in 'shuffle' memory config option

[jira] [Created] (FLINK-15575) Azure Filesystem Shades Wrong Package "httpcomponents"

Konstantin Knauf created FLINK-15575: Summary: Azure Filesystem Shades Wrong Package "httpcomponents" Key: FLINK-15575 URL: https://issues.apache.org/jira/browse/FLINK-15575 Project: Flink

[GitHub] [flink] kl0u closed pull request #10604: [FLINK-15292] Rename Executor to PipelineExecutor

kl0u closed pull request #10604: [FLINK-15292] Rename Executor to PipelineExecutor URL: https://github.com/apache/flink/pull/10604 This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] kl0u commented on issue #10604: [FLINK-15292] Rename Executor to PipelineExecutor

kl0u commented on issue #10604: [FLINK-15292] Rename Executor to PipelineExecutor URL: https://github.com/apache/flink/pull/10604#issuecomment-573652409 Merged This is an automated message from the Apache Git Service. To

[jira] [Closed] (FLINK-15292) Rename Executor interface to PipelineExecutor

[ https://issues.apache.org/jira/browse/FLINK-15292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-15292. -- Resolution: Fixed Merged on master with d82b6042626a6d5119861438e498292541faa20d and on

[jira] [Commented] (FLINK-15574) DataType to LogicalType conversion issue

[ https://issues.apache.org/jira/browse/FLINK-15574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014298#comment-17014298 ] Jark Wu commented on FLINK-15574: - Could you attach a test which can reproduce the problem? > DataType

[GitHub] [flink] azagrebin 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

azagrebin 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_r365811773 ## File path:

[jira] [Closed] (FLINK-15115) Drop Kafka 0.8/0.9

[ https://issues.apache.org/jira/browse/FLINK-15115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-15115. Release Note: The Kafka 0.8 and 0.9 connectors are no longer under active development.

[GitHub] [flink] aljoscha commented on a change in pull request #10835: [FLINK-15533] Fix parallelism setting propagation during graph instantiation.

aljoscha commented on a change in pull request #10835: [FLINK-15533] Fix parallelism setting propagation during graph instantiation. URL: https://github.com/apache/flink/pull/10835#discussion_r365811483 ## File path:

[GitHub] [flink] flinkbot commented on issue #10843: [FLINK-15574][table-planner-blink] Remove deprecated logic in LogicalTypeDataTypeConverter.fromDataTypeToLogicalType

flinkbot commented on issue #10843: [FLINK-15574][table-planner-blink] Remove deprecated logic in LogicalTypeDataTypeConverter.fromDataTypeToLogicalType URL: https://github.com/apache/flink/pull/10843#issuecomment-573673896 Thanks a lot for your contribution to the Apache Flink project.

[GitHub] [flink] flinkbot edited a comment on issue #10842: [FLINK-15489][web]: add cache control no-cache to log api

flinkbot edited a comment on issue #10842: [FLINK-15489][web]: add cache control no-cache to log api URL: https://github.com/apache/flink/pull/10842#issuecomment-573632115 ## CI report: * fbc3d61dc5657907e9e55497cf70431ceff2d2d9 Travis:

[GitHub] [flink] GJL commented on a change in pull request #10801: [FLINK-15521][e2e] Follow symbolic link when copying distribution

GJL commented on a change in pull request #10801: [FLINK-15521][e2e] Follow symbolic link when copying distribution URL: https://github.com/apache/flink/pull/10801#discussion_r365815918 ## File path:

[GitHub] [flink] libenchao commented on issue #10713: [FLINK-15431][CEP] Add numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency in CepOperator

libenchao commented on issue #10713: [FLINK-15431][CEP] Add numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency in CepOperator URL: https://github.com/apache/flink/pull/10713#issuecomment-573706295 @dawidwys Thanks for your response. I have updated pr according to the

[GitHub] [flink] flinkbot edited a comment on issue #10835: [FLINK-15533] Fix parallelism setting propagation during graph instantiation.

flinkbot edited a comment on issue #10835: [FLINK-15533] Fix parallelism setting propagation during graph instantiation. URL: https://github.com/apache/flink/pull/10835#issuecomment-573416112 ## CI report: * 0590888514ff79680992bf39f72235a4d90bb75b Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10844: [FLINK-15559][docs] Fix broken links due to missing baseurl

flinkbot edited a comment on issue #10844: [FLINK-15559][docs] Fix broken links due to missing baseurl URL: https://github.com/apache/flink/pull/10844#issuecomment-573736138 ## CI report: * a356df63a802f15c8a1e6982cf68c51da30b454c Travis:

[jira] [Commented] (FLINK-15559) Missing {{site.baseurl}} in some docs

[ https://issues.apache.org/jira/browse/FLINK-15559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014277#comment-17014277 ] Jark Wu commented on FLINK-15559: - Thanks for the explanation. I got what you mean. I think you can

[jira] [Commented] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

[ https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014318#comment-17014318 ] Andrey Zagrebin commented on FLINK-15493: - Looks the same

[jira] [Commented] (FLINK-15574) DataType to LogicalType conversion issue

[ https://issues.apache.org/jira/browse/FLINK-15574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014329#comment-17014329 ] Benoit Hanotte commented on FLINK-15574: Hello [~jark], I added a patch for a simple unit test

[jira] [Commented] (FLINK-11774) IllegalArgumentException in HeapPriorityQueueSet

[ https://issues.apache.org/jira/browse/FLINK-11774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014344#comment-17014344 ] Felix Wollschläger commented on FLINK-11774: This error still occurs +sometimes+ if we use

[GitHub] [flink] flinkbot edited a comment on issue #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

flinkbot edited a comment on issue #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#issuecomment-568850864 ## CI report: * a7411a5d1a86381078670898c1f20be4fe3a88f4

[GitHub] [flink] flinkbot edited a comment on issue #10674: [FLINK-15220][Connector/Kafka][Table] Add startFromTimestamp in KafkaTableSource

flinkbot edited a comment on issue #10674: [FLINK-15220][Connector/Kafka][Table] Add startFromTimestamp in KafkaTableSource URL: https://github.com/apache/flink/pull/10674#issuecomment-568687684 ## CI report: * f59106d121f9dd0fc40b23640ec2ad8a663d6020 Travis:

[jira] [Commented] (FLINK-15318) RocksDBWriteBatchPerformanceTest.benchMark fails on ppc64le

[ https://issues.apache.org/jira/browse/FLINK-15318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014361#comment-17014361 ] Yun Tang commented on FLINK-15318: -- [~redmark-ibm] thanks for your feedback. What's your hardware

[jira] [Commented] (FLINK-15566) Flink implicitly order the fields in PojoTypeInfo

[ https://issues.apache.org/jira/browse/FLINK-15566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014360#comment-17014360 ] Timo Walther commented on FLINK-15566: -- I hope we can finally have it in 1.11, I'm actively working

[GitHub] [flink] azagrebin 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

azagrebin 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_r365833036 ## File path:

[GitHub] [flink] langdangjushi commented on issue #8400: [FLINK-12472][yarn] Support setting attemptFailuresValidityInterval o…

langdangjushi commented on issue #8400: [FLINK-12472][yarn] Support setting attemptFailuresValidityInterval o… URL: https://github.com/apache/flink/pull/8400#issuecomment-573740782 @jiasheng55 凹,,那是前人的锅,,flink on yarn 10秒确实不合理...很容易无限重启

[jira] [Commented] (FLINK-15566) Flink implicitly order the fields in PojoTypeInfo

[ https://issues.apache.org/jira/browse/FLINK-15566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014269#comment-17014269 ] Timo Walther commented on FLINK-15566: -- This problem will be solved by FLIP-65. In FLIP-65 we use

[jira] [Updated] (FLINK-15574) DataType to LogicalType conversion issue

[ https://issues.apache.org/jira/browse/FLINK-15574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoit Hanotte updated FLINK-15574: --- Description: We seem to be encountering an issue with the conversion from DataType to

[jira] [Updated] (FLINK-15574) DataType to LogicalType conversion issue

[ https://issues.apache.org/jira/browse/FLINK-15574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoit Hanotte updated FLINK-15574: --- Description: We seem to be encountering an issue with the conversion from DataType to

[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:

[GitHub] [flink] flinkbot edited a comment on issue #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

flinkbot edited a comment on issue #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#issuecomment-568850864 ## CI report: * a7411a5d1a86381078670898c1f20be4fe3a88f4

[GitHub] [flink] flinkbot commented on issue #10844: [FLINK-15559][docs] Fix broken links due to missing baseurl

flinkbot commented on issue #10844: [FLINK-15559][docs] Fix broken links due to missing baseurl URL: https://github.com/apache/flink/pull/10844#issuecomment-573716598 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] [flink] flinkbot edited a comment on issue #10845: [FLINK-15355][plugins] Classloader avoids loading unrelated services.

flinkbot edited a comment on issue #10845: [FLINK-15355][plugins] Classloader avoids loading unrelated services. URL: https://github.com/apache/flink/pull/10845#issuecomment-573736294 ## CI report: * 0942cb8b913ba50ecf8d7ca28832c4c92bf78e6c Travis:

[GitHub] [flink] flinkbot commented on issue #10846: [FLINK-15576] remove isTemporary property from CatalogFunction API

flinkbot commented on issue #10846: [FLINK-15576] remove isTemporary property from CatalogFunction API URL: https://github.com/apache/flink/pull/10846#issuecomment-573891234 ## CI report: * 80e2955738437b0dd0b6004fac252f383fb6b426 UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on issue #10835: [FLINK-15533] Fix parallelism setting propagation during graph instantiation.

flinkbot edited a comment on issue #10835: [FLINK-15533] Fix parallelism setting propagation during graph instantiation. URL: https://github.com/apache/flink/pull/10835#issuecomment-573416112 ## CI report: * 0590888514ff79680992bf39f72235a4d90bb75b Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10846: [FLINK-15576] remove isTemporary property from CatalogFunction API

flinkbot edited a comment on issue #10846: [FLINK-15576] remove isTemporary property from CatalogFunction API URL: https://github.com/apache/flink/pull/10846#issuecomment-573891234 ## CI report: * 80e2955738437b0dd0b6004fac252f383fb6b426 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx

flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx URL: https://github.com/apache/flink/pull/9848#issuecomment-538885706 ## CI report: * dd22d245973b8caf25f8f26a392a1ca95f863736 Travis:

[jira] [Updated] (FLINK-15577) WindowAggregate RelNodes missing Window specs in digest

[ https://issues.apache.org/jira/browse/FLINK-15577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoit Hanotte updated FLINK-15577: --- Description: The RelNode's digest (AbstractRelNode.getDigest()), along its RowType, is used

[GitHub] [flink] flinkbot edited a comment on issue #10835: [FLINK-15533] Fix parallelism setting propagation during graph instantiation.

flinkbot edited a comment on issue #10835: [FLINK-15533] Fix parallelism setting propagation during graph instantiation. URL: https://github.com/apache/flink/pull/10835#issuecomment-573416112 ## CI report: * 0590888514ff79680992bf39f72235a4d90bb75b Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10835: [FLINK-15533] Fix parallelism setting propagation during graph instantiation.

flinkbot edited a comment on issue #10835: [FLINK-15533] Fix parallelism setting propagation during graph instantiation. URL: https://github.com/apache/flink/pull/10835#issuecomment-573416112 ## CI report: * 0590888514ff79680992bf39f72235a4d90bb75b Travis:

[GitHub] [flink] flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx

flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx URL: https://github.com/apache/flink/pull/9848#issuecomment-538885706 ## CI report: * dd22d245973b8caf25f8f26a392a1ca95f863736 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10845: [FLINK-15355][plugins] Classloader avoids loading unrelated services.

flinkbot edited a comment on issue #10845: [FLINK-15355][plugins] Classloader avoids loading unrelated services. URL: https://github.com/apache/flink/pull/10845#issuecomment-573736294 ## CI report: * 0942cb8b913ba50ecf8d7ca28832c4c92bf78e6c Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10835: [FLINK-15533] Fix parallelism setting propagation during graph instantiation.

flinkbot edited a comment on issue #10835: [FLINK-15533] Fix parallelism setting propagation during graph instantiation. URL: https://github.com/apache/flink/pull/10835#issuecomment-573416112 ## CI report: * 0590888514ff79680992bf39f72235a4d90bb75b Travis:

[jira] [Created] (FLINK-15576) remove isTemporary property from CatalogFunction API

Bowen Li created FLINK-15576: Summary: remove isTemporary property from CatalogFunction API Key: FLINK-15576 URL: https://issues.apache.org/jira/browse/FLINK-15576 Project: Flink Issue Type: Bug

[GitHub] [flink] bowenli86 opened a new pull request #10846: [FLINK-15576] remove isTemporary property from CatalogFunction API

bowenli86 opened a new pull request #10846: [FLINK-15576] remove isTemporary property from CatalogFunction API URL: https://github.com/apache/flink/pull/10846 ## What is the purpose of the change according to FLIP-79, CatalogFunction shouldn't have "isTemporary" property. Moving

[jira] [Updated] (FLINK-15576) remove isTemporary property from CatalogFunction API

[ https://issues.apache.org/jira/browse/FLINK-15576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15576: --- Labels: pull-request-available (was: ) > remove isTemporary property from CatalogFunction

[jira] [Updated] (FLINK-15577) LoggicalWindowAggregate Rel nodes missing Window specs in digest

[ https://issues.apache.org/jira/browse/FLINK-15577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoit Hanotte updated FLINK-15577: --- Component/s: (was: Table SQL / Planner) Table SQL / Legacy Planner >

[jira] [Updated] (FLINK-15577) LoggicalWindowAggregate Rel nodes missing Window specs in digest

[ https://issues.apache.org/jira/browse/FLINK-15577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoit Hanotte updated FLINK-15577: --- Component/s: Table SQL / Planner > LoggicalWindowAggregate Rel nodes missing Window specs

[jira] [Updated] (FLINK-15577) LoggicalWindowAggregate Rel nodes missing Window specs in digest

[ https://issues.apache.org/jira/browse/FLINK-15577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoit Hanotte updated FLINK-15577: --- Affects Version/s: 1.9.1 > LoggicalWindowAggregate Rel nodes missing Window specs in digest

[jira] [Created] (FLINK-15577) LoggicalWindowAggregate Rel nodes missing Window specs in digest

Benoit Hanotte created FLINK-15577: -- Summary: LoggicalWindowAggregate Rel nodes missing Window specs in digest Key: FLINK-15577 URL: https://issues.apache.org/jira/browse/FLINK-15577 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx

flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx URL: https://github.com/apache/flink/pull/9848#issuecomment-538885706 ## CI report: * dd22d245973b8caf25f8f26a392a1ca95f863736 Travis:

[jira] [Created] (FLINK-15578) Implement exactly-once JDBC sink

Roman Khachatryan created FLINK-15578: - Summary: Implement exactly-once JDBC sink Key: FLINK-15578 URL: https://issues.apache.org/jira/browse/FLINK-15578 Project: Flink Issue Type: New

[GitHub] [flink] lukess edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx

lukess edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx URL: https://github.com/apache/flink/pull/9848#issuecomment-573252493 @aljoscha I'm running the new SignalFXReporter in our environments. Current implementation: 1. current metric

[jira] [Updated] (FLINK-15577) WindowAggregate RelNodes missing Window specs in digest

[ https://issues.apache.org/jira/browse/FLINK-15577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoit Hanotte updated FLINK-15577: --- Summary: WindowAggregate RelNodes missing Window specs in digest (was:

[GitHub] [flink] flinkbot commented on issue #10846: [FLINK-15576] remove isTemporary property from CatalogFunction API

flinkbot commented on issue #10846: [FLINK-15576] remove isTemporary property from CatalogFunction API URL: https://github.com/apache/flink/pull/10846#issuecomment-573876423 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Updated] (FLINK-15577) WindowAggregate RelNodes missing Window specs in digest

[ https://issues.apache.org/jira/browse/FLINK-15577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoit Hanotte updated FLINK-15577: --- Description: The RelNode's digest (AbstractRelNode.getDigest()), along its RowType, is used

[jira] [Commented] (FLINK-14933) translate "Data Streaming Fault Tolerance" page in to Chinese

[ https://issues.apache.org/jira/browse/FLINK-14933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014730#comment-17014730 ] Eleanore Jin commented on FLINK-14933: -- Hi [~jark], [~Zhangcheng], just wonder are you working one

[GitHub] [flink] flinkbot edited a comment on issue #10847: [FLINK-15578][connectors/jdbc] JDBC exactly once sink

flinkbot edited a comment on issue #10847: [FLINK-15578][connectors/jdbc] JDBC exactly once sink URL: https://github.com/apache/flink/pull/10847#issuecomment-573933799 ## CI report: * 1f19ab63df12c2a0cbc75644a34bcab26c08d7f6 Travis:

[GitHub] [flink] Li-Aihua removed a comment on issue #10378: [FLINK-14919] [flink-end-to-end-perf-tests] Add performance e2e test suite for basic operations

Li-Aihua removed a comment on issue #10378: [FLINK-14919] [flink-end-to-end-perf-tests] Add performance e2e test suite for basic operations URL: https://github.com/apache/flink/pull/10378#issuecomment-562954416 case results: scenarioName qps

[GitHub] [flink] flinkbot edited a comment on issue #10784: [FLINK-15494] Fix time field index wrong in LogicalWindowAggregateRul…

flinkbot edited a comment on issue #10784: [FLINK-15494] Fix time field index wrong in LogicalWindowAggregateRul… URL: https://github.com/apache/flink/pull/10784#issuecomment-571473399 ## CI report: * d0e5cb3e0d2cc118c98cd91e0470c5123219d1ec Travis:

[GitHub] [flink] Li-Aihua commented on a change in pull request #10378: [FLINK-14919] [flink-end-to-end-perf-tests] Add performance e2e test suite for basic operations

Li-Aihua commented on a change in pull request #10378: [FLINK-14919] [flink-end-to-end-perf-tests] Add performance e2e test suite for basic operations URL: https://github.com/apache/flink/pull/10378#discussion_r366122095 ## File path:

[jira] [Commented] (FLINK-15505) flink-clients test failing on Red Hat 7.6 PowerPC Linux

[ https://issues.apache.org/jira/browse/FLINK-15505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014801#comment-17014801 ] Yang Wang commented on FLINK-15505: --- Hi, [~wangxiyuan] I think this issue was introduced by

[GitHub] [flink] JingsongLi commented on a change in pull request #10839: [FLINK-15567][table][docs] Add documentation for INSERT statements for Flink SQL

JingsongLi commented on a change in pull request #10839: [FLINK-15567][table][docs] Add documentation for INSERT statements for Flink SQL URL: https://github.com/apache/flink/pull/10839#discussion_r366125955 ## File path: docs/dev/table/sql/insert.md ## @@ -0,0 +1,173 @@

[jira] [Commented] (FLINK-15307) Subclasses of FailoverStrategy are easily confused with implementation classes of RestartStrategy

[ https://issues.apache.org/jira/browse/FLINK-15307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014810#comment-17014810 ] Andrew.D.lin commented on FLINK-15307: -- [~zhuzh] sorry, I missed it, Let me modify it > Subclasses

<    1   2   3   4   5   >