[jira] [Commented] (FLINK-17579) Set the resource id of taskexecutor according to environment variable if exist in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-17579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17135527#comment-17135527 ] Till Rohrmann commented on FLINK-17579: --- This sounds good to me [~karmagyz]. Maybe we don't need

[jira] [Commented] (FLINK-18290) Tests are crashing with exit code 239

[ https://issues.apache.org/jira/browse/FLINK-18290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17135526#comment-17135526 ] Robert Metzger commented on FLINK-18290: First occurrence of a related issue was build

[jira] [Created] (FLINK-18292) Savepoint for job error

Kayo created FLINK-18292: Summary: Savepoint for job error Key: FLINK-18292 URL: https://issues.apache.org/jira/browse/FLINK-18292 Project: Flink Issue Type: Bug Components: Command Line

[GitHub] [flink] godfreyhe commented on a change in pull request #12577: [FLINK-17599][docs] Update documents due to FLIP-84

godfreyhe commented on a change in pull request #12577: URL: https://github.com/apache/flink/pull/12577#discussion_r439968656 ## File path: docs/dev/table/sql/queries.md ## @@ -1,5 +1,5 @@ --- -title: "Queries" +title: "SELECT statements" Review comment: I will revert

[GitHub] [flink] azagrebin commented on pull request #12596: [FLINK-18250] Enrich OOM error messages with more details in ClusterEntrypoint

azagrebin commented on pull request #12596: URL: https://github.com/apache/flink/pull/12596#issuecomment-643943878 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-18238) RemoteChannelThroughputBenchmark deadlocks

[ https://issues.apache.org/jira/browse/FLINK-18238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17135506#comment-17135506 ] Yun Tang commented on FLINK-18238: -- Thanks for [~kevin.cyj] for investigating this. [~pnowojski], I

[GitHub] [flink] flinkbot commented on pull request #12649: [FLINK-18286] Implement type inference for GET/FLATTEN

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

[GitHub] [flink] dawidwys commented on pull request #12649: [FLINK-18286] Implement type inference for GET/FLATTEN

dawidwys commented on pull request #12649: URL: https://github.com/apache/flink/pull/12649#issuecomment-643942301 @twalthr Could you review the PR? This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] dawidwys commented on pull request #12649: [FLINK-18286] Implement type inference for GET/FLATTEN

dawidwys commented on pull request #12649: URL: https://github.com/apache/flink/pull/12649#issuecomment-643942158 @danny0405 Could you check changes in 11f71d1b13e2b6456722b5ce5f1081a6f9d1cef9 in classes: * `SqlDotOperator` * `SqlItemOperator` * `SqlValidatorScope` and say

[GitHub] [flink] flinkbot commented on pull request #12648: [FLINK-16432][build] Fix dependencies in Hive Connector build.

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

[GitHub] [flink] dawidwys opened a new pull request #12649: [FLINK-18286] Implement type inference for GET/FLATTEN

dawidwys opened a new pull request #12649: URL: https://github.com/apache/flink/pull/12649 ## What is the purpose of the change This PR implements type inference for GET/FLATTEN expressions. Additionally it aligns the behaviour between Table API & SQL. To achieve that it fixes

[jira] [Updated] (FLINK-18286) Implement type inference for functions on composite types

[ https://issues.apache.org/jira/browse/FLINK-18286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18286: --- Labels: pull-request-available (was: ) > Implement type inference for functions on

[jira] [Commented] (FLINK-18238) RemoteChannelThroughputBenchmark deadlocks

[ https://issues.apache.org/jira/browse/FLINK-18238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17135502#comment-17135502 ] Zhijiang commented on FLINK-18238: -- The downstream task can receive the abort rpc call from

[jira] [Comment Edited] (FLINK-18238) RemoteChannelThroughputBenchmark deadlocks

[ https://issues.apache.org/jira/browse/FLINK-18238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17135502#comment-17135502 ] Zhijiang edited comment on FLINK-18238 at 6/15/20, 6:56 AM: The downstream

[GitHub] [flink] flinkbot edited a comment on pull request #12507: [FLINK-18162][connector/common] Serialize the splits in the AddSplitsEvent

flinkbot edited a comment on pull request #12507: URL: https://github.com/apache/flink/pull/12507#issuecomment-639959577 ## CI report: * 0670d44c13aa29f678e7aeb9e2e8ca7f4c67b4d4 Azure:

[jira] [Commented] (FLINK-18238) RemoteChannelThroughputBenchmark deadlocks

[ https://issues.apache.org/jira/browse/FLINK-18238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17135499#comment-17135499 ] Piotr Nowojski commented on FLINK-18238: {quote} But the downstream side still waits for barrier

[jira] [Comment Edited] (FLINK-18238) RemoteChannelThroughputBenchmark deadlocks

[ https://issues.apache.org/jira/browse/FLINK-18238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17135499#comment-17135499 ] Piotr Nowojski edited comment on FLINK-18238 at 6/15/20, 6:54 AM: --

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

[ https://issues.apache.org/jira/browse/FLINK-17768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-17768: Test is failing again:

[jira] [Commented] (FLINK-18290) Tests are crashing with exit code 239

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

[jira] [Commented] (FLINK-18290) Tests are crashing with exit code 239

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

[jira] [Commented] (FLINK-17752) Align the timestamp format with Flink SQL types in JSON format

[ https://issues.apache.org/jira/browse/FLINK-17752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17135479#comment-17135479 ] Jark Wu commented on FLINK-17752: - +1 to postpone the custom option, we can revisit this when we collect

[jira] [Updated] (FLINK-18238) RemoteChannelThroughputBenchmark deadlocks

[ https://issues.apache.org/jira/browse/FLINK-18238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-18238: --- Component/s: (was: Runtime / Network) (was: Benchmarks)

[jira] [Commented] (FLINK-18290) Tests are crashing with exit code 239

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

[jira] [Commented] (FLINK-16768) HadoopS3RecoverableWriterITCase.testRecoverWithStateWithMultiPart hangs

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

[jira] [Commented] (FLINK-18290) Tests are crashing with exit code 239

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

[GitHub] [flink] flinkbot commented on pull request #12648: [FLINK-16432][build] Fix dependencies in Hive Connector build.

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

[GitHub] [flink] AHeise opened a new pull request #12648: [FLINK-16432][build] Fix dependencies in Hive Connector build.

AHeise opened a new pull request #12648: URL: https://github.com/apache/flink/pull/12648 (unchanged backport of https://github.com/apache/flink/pull/11316) ## What is the purpose of the change Get release-1.10 building again. ## Brief change log -

[jira] [Commented] (FLINK-18290) Tests are crashing with exit code 239

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

[jira] [Commented] (FLINK-18290) Tests are crashing with exit code 239

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

[jira] [Commented] (FLINK-18291) Streaming File Sink s3 end-to-end test stalls

[ https://issues.apache.org/jira/browse/FLINK-18291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17135463#comment-17135463 ] Robert Metzger commented on FLINK-18291: I guess the first step is to introduce a timeout to get

[jira] [Commented] (FLINK-17752) Align the timestamp format with Flink SQL types in JSON format

[ https://issues.apache.org/jira/browse/FLINK-17752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17135462#comment-17135462 ] Dawid Wysakowicz commented on FLINK-17752: -- Hmm those are valid questions. Ad. 1 I think there

[jira] [Created] (FLINK-18291) Streaming File Sink s3 end-to-end test stalls

Robert Metzger created FLINK-18291: -- Summary: Streaming File Sink s3 end-to-end test stalls Key: FLINK-18291 URL: https://issues.apache.org/jira/browse/FLINK-18291 Project: Flink Issue

[jira] [Commented] (FLINK-18290) Tests are crashing with exit code 239

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

[jira] [Commented] (FLINK-18161) Changing parallelism is not possible in sql-client.sh

[ https://issues.apache.org/jira/browse/FLINK-18161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17135461#comment-17135461 ] Jark Wu commented on FLINK-18161: - I have the similar thought,  either (1) we fix

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

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

[jira] [Reopened] (FLINK-16432) Building Hive connector gives problems

[ https://issues.apache.org/jira/browse/FLINK-16432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reopened FLINK-16432: - Assignee: Arvid Heise (was: Niels Basjes) Also 1.10 affected. > Building Hive connector

[jira] [Updated] (FLINK-16432) Building Hive connector gives problems

[ https://issues.apache.org/jira/browse/FLINK-16432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-16432: Affects Version/s: 1.10.2 > Building Hive connector gives problems >

[jira] [Commented] (FLINK-17579) Set the resource id of taskexecutor according to environment variable if exist in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-17579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17135451#comment-17135451 ] Yangze Guo commented on FLINK-17579: Yes, I think it could work. So, it seems that it is still

[jira] [Commented] (FLINK-18158) Add a utility to create a DDL statement from avro schema

[ https://issues.apache.org/jira/browse/FLINK-18158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17135449#comment-17135449 ] Jark Wu commented on FLINK-18158: - Hi [~twalthr], regarding to the DDL of derving schema from some meta

[jira] [Commented] (FLINK-18290) Tests are crashing with exit code 239

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

[GitHub] [flink] dawidwys commented on pull request #12591: [FLINK-18223][avro] Fixed AvroSerializer to correctly initialize GenericRecords

dawidwys commented on pull request #12591: URL: https://github.com/apache/flink/pull/12591#issuecomment-643923832 Thanks for the update @nicusX Have you by chance rebased master on top of your branch? For the future you should rather rebase your branch on top of master and then you

[jira] [Commented] (FLINK-18290) Tests are crashing with exit code 239

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

[jira] [Commented] (FLINK-18290) Tests are crashing with exit code 239

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

[jira] [Assigned] (FLINK-18290) Tests are crashing with exit code 239

[ https://issues.apache.org/jira/browse/FLINK-18290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-18290: -- Assignee: Robert Metzger > Tests are crashing with exit code 239 >

[jira] [Updated] (FLINK-18290) Tests are crashing with exit code 239

[ https://issues.apache.org/jira/browse/FLINK-18290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18290: --- Description:

[jira] [Updated] (FLINK-18290) Tests are crashing with exit code 239

[ https://issues.apache.org/jira/browse/FLINK-18290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18290: --- Component/s: (was: Tests) (was: Connectors / Kafka) > Tests are

[jira] [Updated] (FLINK-18290) Tests are crashing with exit code 239

[ https://issues.apache.org/jira/browse/FLINK-18290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18290: --- Priority: Blocker (was: Critical) > Tests are crashing with exit code 239 >

[jira] [Commented] (FLINK-18290) Tests are crashing with exit code 239

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

[jira] [Commented] (FLINK-18290) Tests are crashing with exit code 239

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

[jira] [Commented] (FLINK-18290) Tests are crashing with exit code 239

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

[jira] [Commented] (FLINK-18290) Tests are crashing with exit code 239

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

[jira] [Commented] (FLINK-18290) Tests are crashing with exit code 239

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

[jira] [Commented] (FLINK-18020) SQLClientKafkaITCase.testKafka is flaky

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

[jira] [Commented] (FLINK-18290) Tests are crashing with exit code 239

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

[jira] [Commented] (FLINK-18290) Tests are crashing with exit code 239

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

[jira] [Updated] (FLINK-18290) Kafka011ProducerExactlyOnceITCase sometimes crashes with exit code 239

[ https://issues.apache.org/jira/browse/FLINK-18290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18290: --- Description:

[jira] [Updated] (FLINK-18290) Tests are crashing with exit code 239

[ https://issues.apache.org/jira/browse/FLINK-18290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18290: --- Summary: Tests are crashing with exit code 239 (was: Kafka011ProducerExactlyOnceITCase

[jira] [Updated] (FLINK-18290) Kafka011ProducerExactlyOnceITCase sometimes crashes with exit code 239

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

[jira] [Commented] (FLINK-18290) Kafka011ProducerExactlyOnceITCase sometimes crashes with exit code 239

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

[jira] [Commented] (FLINK-13987) Better TM/JM Log Display

[ https://issues.apache.org/jira/browse/FLINK-13987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17135430#comment-17135430 ] Jiayi Liao commented on FLINK-13987: [~lining] [~vthinkxie]  Any plan for the support of showing

[jira] [Issue Comment Deleted] (FLINK-18290) Kafka011ProducerExactlyOnceITCase sometimes crashes with exit code 239

[ https://issues.apache.org/jira/browse/FLINK-18290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18290: --- Comment: was deleted (was: related?) > Kafka011ProducerExactlyOnceITCase sometimes crashes

[jira] [Commented] (FLINK-15414) KafkaITCase#prepare failed in travis

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

<    2   3   4   5   6   7