[jira] [Updated] (FLINK-20113) Test K8s High Availability Service

2020-11-17 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-20113: --- Description: Added in https://issues.apache.org/jira/browse/FLINK-12884 [General

[jira] [Updated] (FLINK-20112) Test Flink 1.12 release

2020-11-17 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-20112: --- Description: This is an umbrella ticket for the Flink 1.12 testing efforts. General inform

[jira] [Commented] (FLINK-20153) Add documentation for BATCH execution mode

2020-11-17 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233523#comment-17233523 ] Robert Metzger commented on FLINK-20153: Does this ticket cover documenting the

[jira] [Commented] (FLINK-20115) Test Batch execution for the DataStream API 

2020-11-17 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233522#comment-17233522 ] Robert Metzger commented on FLINK-20115: [~aljoscha] is there already an end to

[GitHub] [flink] flinkbot commented on pull request #14097: [FLINK-20028][table-planner-blink] FileCompactionITCase is unstable

2020-11-17 Thread GitBox
flinkbot commented on pull request #14097: URL: https://github.com/apache/flink/pull/14097#issuecomment-728858752 ## CI report: * 970674205915931d4577ef7fa32e4ef72316d27a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #14096: [FLINK-17159] Use testcontainers for Elasticsearch ITCases

2020-11-17 Thread GitBox
flinkbot edited a comment on pull request #14096: URL: https://github.com/apache/flink/pull/14096#issuecomment-728845125 ## CI report: * 6f861ddbe95f20ef85e5028180f556408cbae70f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-20189) Restored feedback events may be silently dropped if per key-group header bytes were not fully read

2020-11-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20189: --- Labels: pull-request-available (was: ) > Restored feedback events may be silently dropped i

[GitHub] [flink-statefun] tzulitai opened a new pull request #175: [FLINK-20189] [core] Fix Header.skipHeaderSilently to fully fill the header bytes read buffer before comparing

2020-11-17 Thread GitBox
tzulitai opened a new pull request #175: URL: https://github.com/apache/flink-statefun/pull/175 This PR fixes the per key-group `Header.skipHeaderSilently` operation to properly fully fill the header bytes read buffer, before comparing it with the expected header bytes. Since {{Inpu

[GitHub] [flink] flinkbot edited a comment on pull request #14068: [FLINK-200137][python] Emit timestamps of current records to downstream in PythonFunctionOperator.

2020-11-17 Thread GitBox
flinkbot edited a comment on pull request #14068: URL: https://github.com/apache/flink/pull/14068#issuecomment-726851708 ## CI report: * 04c250c0c8c9489eb622c91f057a7e5a496f1f35 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-18712) Flink RocksDB statebackend memory leak issue

2020-11-17 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233509#comment-17233509 ] Robert Metzger commented on FLINK-18712: If nobody objects in 24 hours, I'll rem

[GitHub] [flink] flinkbot commented on pull request #14097: [FLINK-20028][table-planner-blink] FileCompactionITCase is unstable

2020-11-17 Thread GitBox
flinkbot commented on pull request #14097: URL: https://github.com/apache/flink/pull/14097#issuecomment-728848360 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Commented] (FLINK-20028) FileCompactionITCase is unstable

2020-11-17 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233510#comment-17233510 ] Robert Metzger commented on FLINK-20028: Thanks a lot! > FileCompactionITCase i

[GitHub] [flink] aljoscha commented on pull request #14096: [FLINK-17159] Use testcontainers for Elasticsearch ITCases

2020-11-17 Thread GitBox
aljoscha commented on pull request #14096: URL: https://github.com/apache/flink/pull/14096#issuecomment-728847795 @echauchot Sure, but this is just touching the tests as little. 😅 This is an automated message from the Apache

[GitHub] [flink] JingsongLi opened a new pull request #14097: [FLINK-20028][table-planner-blink] FileCompactionITCase is unstable

2020-11-17 Thread GitBox
JingsongLi opened a new pull request #14097: URL: https://github.com/apache/flink/pull/14097 ## What is the purpose of the change `CompactionITCaseBase` use `ParallelFiniteTestSource`, but there is some risk that a source task never end: - A `ParallelFiniteTestSource` task wai

[jira] [Updated] (FLINK-14592) FlinkKafkaInternalProducerITCase fails with BindException

2020-11-17 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14592: --- Fix Version/s: (was: 1.12.0) 1.13.0 > FlinkKafkaInternalProducerITCas

[jira] [Updated] (FLINK-20028) FileCompactionITCase is unstable

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

[jira] [Assigned] (FLINK-20166) FlinkKafkaProducerITCase.testRunOutOfProducersInThePool failed with "CheckpointException: Could not complete snapshot 1 for operator MockTask (1/1)#0. Failure reason: C

2020-11-17 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-20166: - Assignee: Roman Khachatryan > FlinkKafkaProducerITCase.testRunOutOfProducersInT

[jira] [Commented] (FLINK-14592) FlinkKafkaInternalProducerITCase fails with BindException

2020-11-17 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233508#comment-17233508 ] Robert Metzger commented on FLINK-14592: It seems that the PR is outdated, but t

[jira] [Assigned] (FLINK-20157) SourceCoordinatorProvider kills JobManager with IllegalStateException on job submission

2020-11-17 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-20157: -- Assignee: Jiangjie Qin > SourceCoordinatorProvider kills JobManager with IllegalState

[jira] [Created] (FLINK-20189) Restored feedback events may be silently dropped if per key-group header bytes were not fully read

2020-11-17 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-20189: --- Summary: Restored feedback events may be silently dropped if per key-group header bytes were not fully read Key: FLINK-20189 URL: https://issues.apache.org/jira/brow

[jira] [Commented] (FLINK-20113) Test K8s High Availability Service

2020-11-17 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233506#comment-17233506 ] Robert Metzger commented on FLINK-20113: Note, according to an offline discussio

[GitHub] [flink] flinkbot commented on pull request #14096: [FLINK-17159] Use testcontainers for Elasticsearch ITCases

2020-11-17 Thread GitBox
flinkbot commented on pull request #14096: URL: https://github.com/apache/flink/pull/14096#issuecomment-728845125 ## CI report: * 6f861ddbe95f20ef85e5028180f556408cbae70f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-19940) Task names on web UI should change when an operator chain is chained with sources

2020-11-17 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233504#comment-17233504 ] Roman Khachatryan commented on FLINK-19940: --- Yes, exactly. The question is, w

[jira] [Commented] (FLINK-20151) Test SQL Hive integration

2020-11-17 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233505#comment-17233505 ] Robert Metzger commented on FLINK-20151: I assigned Dawid, who offered to take a

[GitHub] [flink] twalthr commented on pull request #14081: [FLINK-20147][connector-kafka] Replace lambdas with classes to prevent serialization issues

2020-11-17 Thread GitBox
twalthr commented on pull request #14081: URL: https://github.com/apache/flink/pull/14081#issuecomment-728844466 Thanks for helping here @echauchot! Yes, anyone can help reviewing PRs. This is an automated message from the Ap

[GitHub] [flink] flinkbot edited a comment on pull request #14085: [FLINK-19997] Implement an e2e test for sql-client with Confluent Registry Avro format

2020-11-17 Thread GitBox
flinkbot edited a comment on pull request #14085: URL: https://github.com/apache/flink/pull/14085#issuecomment-728305152 ## CI report: * fc50ae390f9b72a74af0d38d91a1b25b7d8bce0c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14068: [FLINK-200137][python] Emit timestamps of current records to downstream in PythonFunctionOperator.

2020-11-17 Thread GitBox
flinkbot edited a comment on pull request #14068: URL: https://github.com/apache/flink/pull/14068#issuecomment-726851708 ## CI report: * 04c250c0c8c9489eb622c91f057a7e5a496f1f35 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20166) FlinkKafkaProducerITCase.testRunOutOfProducersInThePool failed with "CheckpointException: Could not complete snapshot 1 for operator MockTask (1/1)#0. Failure reason:

2020-11-17 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233503#comment-17233503 ] Robert Metzger commented on FLINK-20166: [~roman_khachatryan] can you take a loo

[GitHub] [flink] echauchot commented on pull request #14096: [FLINK-17159] Use testcontainers for Elasticsearch ITCases

2020-11-17 Thread GitBox
echauchot commented on pull request #14096: URL: https://github.com/apache/flink/pull/14096#issuecomment-728843363 @aljoscha I can take a look as well if you want as I coded the Apache Beam connectors for ES. This is an auto

[GitHub] [flink] flinkbot edited a comment on pull request #14052: [FLINK-20030][network] Rewrite RemoteInputChannel#getInflightBuffersUnsafe to use sequence numbers

2020-11-17 Thread GitBox
flinkbot edited a comment on pull request #14052: URL: https://github.com/apache/flink/pull/14052#issuecomment-726216034 ## CI report: * 14e0929bf9cebd4db7c60c5928d71e631fb4ad47 UNKNOWN * 9b6d028dde24fc8fd21e3a3542756c813fca9c13 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-20115) Test Batch execution for the DataStream API 

2020-11-17 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-20115: --- Description: Test the following new features: - https://issues.apache.org/jira/browse/FLINK

[GitHub] [flink] flinkbot edited a comment on pull request #13907: [FLINK-19942][Connectors / JDBC]Support sink parallelism configuration to JDBC connector

2020-11-17 Thread GitBox
flinkbot edited a comment on pull request #13907: URL: https://github.com/apache/flink/pull/13907#issuecomment-721230727 ## CI report: * f034600ded37284e626caf3784e783c5ae67a8eb Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Assigned] (FLINK-20186) FactoryUtil will give an incorrect error message when multiple factories fit the connector identifier

2020-11-17 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-20186: Assignee: Timo Walther > FactoryUtil will give an incorrect error message when multiple f

[jira] [Commented] (FLINK-20186) FactoryUtil will give an incorrect error message when multiple factories fit the connector identifier

2020-11-17 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233500#comment-17233500 ] Timo Walther commented on FLINK-20186: -- Thanks for reporting this [~TsReaper]. I wi

[jira] [Commented] (FLINK-19940) Task names on web UI should change when an operator chain is chained with sources

2020-11-17 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233498#comment-17233498 ] Caizhi Weng commented on FLINK-19940: - [~roman_khachatryan] The "explain" functional

[jira] [Commented] (FLINK-18545) Sql api cannot specify flink job name

2020-11-17 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233496#comment-17233496 ] Dawid Wysakowicz commented on FLINK-18545: -- Just one comment, let's not forget

[GitHub] [flink] aljoscha commented on a change in pull request #14096: [FLINK-17159] Use testcontainers for Elasticsearch ITCases

2020-11-17 Thread GitBox
aljoscha commented on a change in pull request #14096: URL: https://github.com/apache/flink/pull/14096#discussion_r525047494 ## File path: flink-connectors/flink-connector-elasticsearch6/src/test/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkI

[GitHub] [flink] AHeise commented on a change in pull request #14096: [FLINK-17159] Use testcontainers for Elasticsearch ITCases

2020-11-17 Thread GitBox
AHeise commented on a change in pull request #14096: URL: https://github.com/apache/flink/pull/14096#discussion_r525045036 ## File path: flink-connectors/flink-connector-elasticsearch5/src/test/java/org/apache/flink/streaming/connectors/elasticsearch5/ElasticsearchSinkITCase.java

[jira] [Commented] (FLINK-18545) Sql api cannot specify flink job name

2020-11-17 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233495#comment-17233495 ] Timo Walther commented on FLINK-18545: -- [~godfreyhe] yes, that should be fine. We h

[jira] [Assigned] (FLINK-18545) Sql api cannot specify flink job name

2020-11-17 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-18545: Assignee: godfrey he (was: Timo Walther) > Sql api cannot specify flink job name > -

[jira] [Commented] (FLINK-17424) SQL Client end-to-end test (Old planner) Elasticsearch (v7.5.1) failed due to download error

2020-11-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233492#comment-17233492 ] Dian Fu commented on FLINK-17424: - https://dev.azure.com/apache-flink/apache-flink/_buil

[GitHub] [flink] flinkbot commented on pull request #14096: [FLINK-17159] Use testcontainers for Elasticsearch ITCases

2020-11-17 Thread GitBox
flinkbot commented on pull request #14096: URL: https://github.com/apache/flink/pull/14096#issuecomment-728831304 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[GitHub] [flink] aljoscha opened a new pull request #14096: [FLINK-17159] Use testcontainers for Elasticsearch ITCases

2020-11-17 Thread GitBox
aljoscha opened a new pull request #14096: URL: https://github.com/apache/flink/pull/14096 This should harden the tests because we now use random ports for the ES nodes. I have a suspicion that we had clashes before, which were causing test instability. Additionally, this allows

[GitHub] [flink] flinkbot edited a comment on pull request #14085: [FLINK-19997] Implement an e2e test for sql-client with Confluent Registry Avro format

2020-11-17 Thread GitBox
flinkbot edited a comment on pull request #14085: URL: https://github.com/apache/flink/pull/14085#issuecomment-728305152 ## CI report: * 6bc29df5f1107d4fd49ed23aa48f156eda02ec2e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Closed] (FLINK-19806) Job may try to leave SUSPENDED state in ExecutionGraph#failJob()

2020-11-17 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-19806. --- Resolution: Fixed Fixed via: 1.12: 1538e5695c561d10c4e92fed9d0cf561b3125f0a 1.11: 4054aa01ebb70aa7e4bf9b3bf9

[GitHub] [flink] flinkbot edited a comment on pull request #13907: [FLINK-19942][Connectors / JDBC]Support sink parallelism configuration to JDBC connector

2020-11-17 Thread GitBox
flinkbot edited a comment on pull request #13907: URL: https://github.com/apache/flink/pull/13907#issuecomment-721230727 ## CI report: * f034600ded37284e626caf3784e783c5ae67a8eb Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13900: [FLINK-19949][csv] Unescape CSV format line delimiter character

2020-11-17 Thread GitBox
flinkbot edited a comment on pull request #13900: URL: https://github.com/apache/flink/pull/13900#issuecomment-720989833 ## CI report: * d9e47451664a976692e4e6110bbffa2842f2ae7a UNKNOWN * 8fa5cec4dee415ba723208bd2fd45cf61ea6a0a8 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-20028) FileCompactionITCase is unstable

2020-11-17 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233482#comment-17233482 ] Jingsong Lee commented on FLINK-20028: -- I think I found the reason, a {{ParallelFin

[GitHub] [flink] kl0u commented on a change in pull request #14028: [FLINK-20020][client] Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract

2020-11-17 Thread GitBox
kl0u commented on a change in pull request #14028: URL: https://github.com/apache/flink/pull/14028#discussion_r525017417 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobResult.java ## @@ -133,26 +132,32 @@ public JobExecutionResult toJobExecuti

[GitHub] [flink] kl0u commented on a change in pull request #14028: [FLINK-20020][client] Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract

2020-11-17 Thread GitBox
kl0u commented on a change in pull request #14028: URL: https://github.com/apache/flink/pull/14028#discussion_r525017417 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobResult.java ## @@ -133,26 +132,32 @@ public JobExecutionResult toJobExecuti

[GitHub] [flink] zhuxiaoshang commented on pull request #13932: [FLINK-19947][Connectors / Common]Support sink parallelism configuration for Print connector

2020-11-17 Thread GitBox
zhuxiaoshang commented on pull request #13932: URL: https://github.com/apache/flink/pull/13932#issuecomment-728812129 cc @JingsongLi @wuchong This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [flink] flinkbot edited a comment on pull request #14095: [FLINK-18500][table] Make the legacy planner exception more clear whe…

2020-11-17 Thread GitBox
flinkbot edited a comment on pull request #14095: URL: https://github.com/apache/flink/pull/14095#issuecomment-728802421 ## CI report: * e5c8a552008f54fdcd96f5485129521432a25d63 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14052: [FLINK-20030][network] Rewrite RemoteInputChannel#getInflightBuffersUnsafe to use sequence numbers

2020-11-17 Thread GitBox
flinkbot edited a comment on pull request #14052: URL: https://github.com/apache/flink/pull/14052#issuecomment-726216034 ## CI report: * 14e0929bf9cebd4db7c60c5928d71e631fb4ad47 UNKNOWN * 9b6d028dde24fc8fd21e3a3542756c813fca9c13 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] zhuxiaoshang commented on pull request #13907: [FLINK-19942][Connectors / JDBC]Support sink parallelism configuration to JDBC connector

2020-11-17 Thread GitBox
zhuxiaoshang commented on pull request #13907: URL: https://github.com/apache/flink/pull/13907#issuecomment-728811786 cc @JingsongLi @wuchong This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [flink] godfreyhe commented on a change in pull request #13291: [FLINK-18988][table] Continuous query with LATERAL and LIMIT produces…

2020-11-17 Thread GitBox
godfreyhe commented on a change in pull request #13291: URL: https://github.com/apache/flink/pull/13291#discussion_r525005001 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkStreamProgram.scala ## @@

[GitHub] [flink] rkhachatryan commented on a change in pull request #14052: [FLINK-20030][network] Rewrite RemoteInputChannel#getInflightBuffersUnsafe to use sequence numbers

2020-11-17 Thread GitBox
rkhachatryan commented on a change in pull request #14052: URL: https://github.com/apache/flink/pull/14052#discussion_r525008992 ## File path: flink-streaming-java/src/test/resources/log4j2-test.properties ## @@ -18,7 +18,7 @@ # Set root logger level to OFF to not flood buil

[GitHub] [flink] guoweiM commented on a change in pull request #14077: [FLINK-20180][fs-connector][translation] Translate FileSink document into Chinese

2020-11-17 Thread GitBox
guoweiM commented on a change in pull request #14077: URL: https://github.com/apache/flink/pull/14077#discussion_r524998101 ## File path: docs/dev/connectors/file_sink.zh.md ## @@ -26,11 +26,11 @@ under the License. * This will be replaced by the TOC {:toc} -这个连接器提供了一个在流和批模

[jira] [Commented] (FLINK-20187) FactoryUtil#createTableSource will be confused by a table source and a table sink factory with same identifier

2020-11-17 Thread Fangliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233478#comment-17233478 ] Fangliang Liu commented on FLINK-20187: --- [~TsReaper] I will take a look, thanks fo

[GitHub] [flink] zhuxiaoshang commented on pull request #13933: [FLINK-19946][Connectors / HBase]Support sink parallelism configuration for Hbase connector

2020-11-17 Thread GitBox
zhuxiaoshang commented on pull request #13933: URL: https://github.com/apache/flink/pull/13933#issuecomment-728804829 cc @JingsongLi @wuchong Could you plz have a review. This is an automated message from the Apache Git Servi

[GitHub] [flink] tillrohrmann closed pull request #14076: [FLINK-19775][test] SystemProcessingTimeServiceTest.testImmediateShutdown is instable

2020-11-17 Thread GitBox
tillrohrmann closed pull request #14076: URL: https://github.com/apache/flink/pull/14076 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to g

[GitHub] [flink] tillrohrmann commented on pull request #14076: [FLINK-19775][test] SystemProcessingTimeServiceTest.testImmediateShutdown is instable

2020-11-17 Thread GitBox
tillrohrmann commented on pull request #14076: URL: https://github.com/apache/flink/pull/14076#issuecomment-728802292 Closing this PR until the root cause of the problem has been found. This is an automated message from the A

[GitHub] [flink] flinkbot commented on pull request #14095: [FLINK-18500][table] Make the legacy planner exception more clear whe…

2020-11-17 Thread GitBox
flinkbot commented on pull request #14095: URL: https://github.com/apache/flink/pull/14095#issuecomment-728802421 ## CI report: * e5c8a552008f54fdcd96f5485129521432a25d63 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] tillrohrmann commented on a change in pull request #14076: [FLINK-19775][test] SystemProcessingTimeServiceTest.testImmediateShutdown is instable

2020-11-17 Thread GitBox
tillrohrmann commented on a change in pull request #14076: URL: https://github.com/apache/flink/pull/14076#discussion_r525004197 ## File path: flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/core/testutils/OneShotLatch.java ## @@ -61,7 +61,11 @@ p

[GitHub] [flink] flinkbot edited a comment on pull request #14090: [BP-1.11][FLINK-19906][table-planner-blink] Fix incorrect result when compare …

2020-11-17 Thread GitBox
flinkbot edited a comment on pull request #14090: URL: https://github.com/apache/flink/pull/14090#issuecomment-728696235 ## CI report: * cd3deba24c378ab2441ba2d0c621e1d175999797 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-18545) Sql api cannot specify flink job name

2020-11-17 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233475#comment-17233475 ] godfrey he commented on FLINK-18545: [~twalthr] I would like to pick up this ticket.

[jira] [Updated] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

2020-11-17 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-17726: Fix Version/s: (was: 1.13.0) (was: 1.11.3) (was:

[jira] [Comment Edited] (FLINK-18545) Sql api cannot specify flink job name

2020-11-17 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233421#comment-17233421 ] Timo Walther edited comment on FLINK-18545 at 11/17/20, 9:11 AM: -

[jira] [Created] (FLINK-20188) Add Documentation for new File Source

2020-11-17 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-20188: Summary: Add Documentation for new File Source Key: FLINK-20188 URL: https://issues.apache.org/jira/browse/FLINK-20188 Project: Flink Issue Type: Task

[GitHub] [flink] kl0u commented on pull request #14028: [FLINK-20020][client] Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract

2020-11-17 Thread GitBox
kl0u commented on pull request #14028: URL: https://github.com/apache/flink/pull/14028#issuecomment-728792980 thanks @SteNicholas , I will check your PR now This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] flinkbot edited a comment on pull request #14094: [FLINK-19398][connectors/hive] Fix the failure when creating hive connector from userclassloader

2020-11-17 Thread GitBox
flinkbot edited a comment on pull request #14094: URL: https://github.com/apache/flink/pull/14094#issuecomment-728774005 ## CI report: * dd70eaaee59a1c06b41dd0981d842905d6408197 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Closed] (FLINK-19177) FLIP-141: Intra-Slot Managed Memory Sharing

2020-11-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-19177. Release Note: In cases where Python UDFs are used together with RocksDB state backend in streaming

[jira] [Assigned] (FLINK-20116) Test Intra-Slot Managed Memory Sharing

2020-11-17 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-20116: -- Assignee: Zhu Zhu > Test Intra-Slot Managed Memory Sharing >

[GitHub] [flink] flinkbot edited a comment on pull request #14059: [FLINK-20102][docs][hbase] Update HBase connector documentation for H…

2020-11-17 Thread GitBox
flinkbot edited a comment on pull request #14059: URL: https://github.com/apache/flink/pull/14059#issuecomment-726515875 ## CI report: * 99743a187519a574e40820bb19ab48aed80147dc Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14095: [FLINK-18500][table] Make the legacy planner exception more clear whe…

2020-11-17 Thread GitBox
flinkbot commented on pull request #14095: URL: https://github.com/apache/flink/pull/14095#issuecomment-728785320 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[GitHub] [flink] danny0405 opened a new pull request #14095: [FLINK-18500][table] Make the legacy planner exception more clear whe…

2020-11-17 Thread GitBox
danny0405 opened a new pull request #14095: URL: https://github.com/apache/flink/pull/14095 …n resolving computed columns types for schema ## What is the purpose of the change The original stack trace throws an `UnsupportedOperationException` with null error message which is v

[jira] [Updated] (FLINK-20187) FactoryUtil#createTableSource will be confused by a table source and a table sink factory with same identifier

2020-11-17 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-20187: Description: When creating a table source I'm faced with the following exception: {code:java} Cau

[jira] [Updated] (FLINK-20142) Update the document for CREATE TABLE LIKE that source table from different catalog is supported

2020-11-17 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-20142: - Fix Version/s: 1.11.3 > Update the document for CREATE TABLE LIKE that source table from

[jira] [Comment Edited] (FLINK-20142) Update the document for CREATE TABLE LIKE that source table from different catalog is supported

2020-11-17 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233454#comment-17233454 ] Dawid Wysakowicz edited comment on FLINK-20142 at 11/17/20, 8:49 AM: -

[jira] [Closed] (FLINK-19182) Update document for intra-slot managed memory sharing

2020-11-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-19182. Resolution: Done Merged via * master: 1ba35fb14e25acbf82014edafc9358a33b82585c > Update document

[jira] [Updated] (FLINK-20187) FactoryUtil#createTableSource will be confused by a table source and a table sink factory with same identifier

2020-11-17 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-20187: Priority: Blocker (was: Major) > FactoryUtil#createTableSource will be confused by a table source

[jira] [Updated] (FLINK-20187) FactoryUtil#createTableSource will be confused by a table source and a table sink factory with same identifier

2020-11-17 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-20187: Description: When creating a table source I'm faced with the following exception: {code} Caused

[jira] [Updated] (FLINK-20186) FactoryUtil will give an incorrect error message when multiple factories fit the connector identifier

2020-11-17 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-20186: Description: I was playing with user-defined connectors when I found the following error message:

[jira] [Closed] (FLINK-20142) Update the document for CREATE TABLE LIKE that source table from different catalog is supported

2020-11-17 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-20142. Assignee: Danny Chen Resolution: Implemented Implemented in 23863e2d105fb566585f752c

[GitHub] [flink] xintongsong closed pull request #14079: [FLINK-19182][doc] Update documents for intra-slot managed memory sharing.

2020-11-17 Thread GitBox
xintongsong closed pull request #14079: URL: https://github.com/apache/flink/pull/14079 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[jira] [Created] (FLINK-20187) FactoryUtil#createTableSource will be confused by a table source and a table sink factory with same identifier

2020-11-17 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-20187: --- Summary: FactoryUtil#createTableSource will be confused by a table source and a table sink factory with same identifier Key: FLINK-20187 URL: https://issues.apache.org/jira/browse/F

[jira] [Commented] (FLINK-20028) FileCompactionITCase is unstable

2020-11-17 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233449#comment-17233449 ] Matthias commented on FLINK-20028: -- FLINK-20176 was created but actually seems to cover

[GitHub] [flink] xintongsong commented on pull request #14079: [FLINK-19182][doc] Update documents for intra-slot managed memory sharing.

2020-11-17 Thread GitBox
xintongsong commented on pull request #14079: URL: https://github.com/apache/flink/pull/14079#issuecomment-728778881 Thanks for the review, @tillrohrmann and @KarmaGYZ. The e2e failures are not related. Merging this. This

[GitHub] [flink] dawidwys merged pull request #14091: [FLINK-20142][doc] Update the document for CREATE TABLE LIKE that sou…

2020-11-17 Thread GitBox
dawidwys merged pull request #14091: URL: https://github.com/apache/flink/pull/14091 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Closed] (FLINK-20176) CompactionITCaseBase.testNonPartition failed with Timeout

2020-11-17 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias closed FLINK-20176. Resolution: Duplicate > CompactionITCaseBase.testNonPartition failed with Timeout > --

[jira] [Commented] (FLINK-20187) FactoryUtil#createTableSource will be confused by a table source and a table sink factory with same identifier

2020-11-17 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233451#comment-17233451 ] Caizhi Weng commented on FLINK-20187: - [~liufangliang] please take a look. > Factor

[jira] [Commented] (FLINK-19951) PyFlink end-to-end test stuck in "Reading kafka messages"

2020-11-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233448#comment-17233448 ] Xintong Song commented on FLINK-19951: -- I believe this is the same problem. https:/

[jira] [Updated] (FLINK-20153) Add documentation for BATCH execution mode

2020-11-17 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20153: - Priority: Critical (was: Major) > Add documentation for BATCH execution mode >

[jira] [Assigned] (FLINK-20151) Test SQL Hive integration

2020-11-17 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-20151: -- Assignee: Dawid Wysakowicz (was: Rui Li) > Test SQL Hive integration > -

[jira] [Assigned] (FLINK-20126) Test non-blocking job submission

2020-11-17 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-20126: -- Assignee: Till Rohrmann > Test non-blocking job submission >

[GitHub] [flink] flinkbot commented on pull request #14094: [FLINK-19398][connectors/hive] Fix the failure when creating hive connector from userclassloader

2020-11-17 Thread GitBox
flinkbot commented on pull request #14094: URL: https://github.com/apache/flink/pull/14094#issuecomment-728774005 ## CI report: * dd70eaaee59a1c06b41dd0981d842905d6408197 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Assigned] (FLINK-20122) Test Small file compaction

2020-11-17 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-20122: -- Assignee: Guowei Ma (was: Jingsong Lee) > Test Small file compaction > -

[jira] [Updated] (FLINK-20186) FactoryUtil will give an incorrect error message when multiple factories fit the connector identifier

2020-11-17 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-20186: Affects Version/s: 1.12.0 1.11.2 > FactoryUtil will give an incorrect error

[jira] [Commented] (FLINK-20186) FactoryUtil will give an incorrect error message when multiple factories fit the connector identifier

2020-11-17 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233442#comment-17233442 ] Caizhi Weng commented on FLINK-20186: - [~twalthr] please take a look. > FactoryUtil

[GitHub] [flink] flinkbot edited a comment on pull request #14079: [FLINK-19182][doc] Update documents for intra-slot managed memory sharing.

2020-11-17 Thread GitBox
flinkbot edited a comment on pull request #14079: URL: https://github.com/apache/flink/pull/14079#issuecomment-727879984 ## CI report: * dbcae3c77ca2aa151ba0a6a7aadc24c5278993e0 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14093: [FLINK-18500][table] Make the legacy planner exception more clear whe…

2020-11-17 Thread GitBox
flinkbot edited a comment on pull request #14093: URL: https://github.com/apache/flink/pull/14093#issuecomment-728764972 ## CI report: * cd8821757ac4086a837706136a438c849e5eeffb Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

<    1   2   3   4   5   6   >