[jira] [Commented] (FLINK-16908) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired while initializing transactional state in 60000ms.

[ https://issues.apache.org/jira/browse/FLINK-16908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224005#comment-17224005 ] Dian Fu commented on FLINK-16908: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Updated] (FLINK-19865) YARN tests failed with "java.lang.NumberFormatException: For input string: "${env:MAX_LOG_FILE_NUMBER}"

[ https://issues.apache.org/jira/browse/FLINK-19865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19865: Priority: Blocker (was: Critical) > YARN tests failed with "java.lang.NumberFormatException: For input st

[jira] [Commented] (FLINK-19865) YARN tests failed with "java.lang.NumberFormatException: For input string: "${env:MAX_LOG_FILE_NUMBER}"

[ https://issues.apache.org/jira/browse/FLINK-19865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223983#comment-17223983 ] Dian Fu commented on FLINK-19865: - Upgrade to "Blocker" as this test case is continuousl

[jira] [Commented] (FLINK-19865) YARN tests failed with "java.lang.NumberFormatException: For input string: "${env:MAX_LOG_FILE_NUMBER}" java.lang.NumberFormatException: For input string: "${env:MAX_L

[ https://issues.apache.org/jira/browse/FLINK-19865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223981#comment-17223981 ] Dian Fu commented on FLINK-19865: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Updated] (FLINK-19865) YARN tests failed with "java.lang.NumberFormatException: For input string: "${env:MAX_LOG_FILE_NUMBER}"

[ https://issues.apache.org/jira/browse/FLINK-19865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19865: Summary: YARN tests failed with "java.lang.NumberFormatException: For input string: "${env:MAX_LOG_FILE_NU

[jira] [Commented] (FLINK-19843) ParquetFsStreamingSinkITCase.testPart failed with "Trying to access closed classloader"

[ https://issues.apache.org/jira/browse/FLINK-19843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223980#comment-17223980 ] Dian Fu commented on FLINK-19843: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-19645) ShuffleCompressionITCase.testDataCompressionForBlockingShuffle is instable

[ https://issues.apache.org/jira/browse/FLINK-19645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223978#comment-17223978 ] Dian Fu commented on FLINK-19645: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-19838) SQLClientKafkaITCase times out

[ https://issues.apache.org/jira/browse/FLINK-19838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223976#comment-17223976 ] Dian Fu commented on FLINK-19838: - https://dev.azure.com/apache-flink/apache-flink/_buil

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

[ https://issues.apache.org/jira/browse/FLINK-17424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223970#comment-17223970 ] Dian Fu commented on FLINK-17424: - "SQL Client end-to-end test (Blink planner) Elasticse

[jira] [Closed] (FLINK-19892) Replace __metaclass__ field with metaclass keyword

[ https://issues.apache.org/jira/browse/FLINK-19892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-19892. --- Fix Version/s: 1.11.3 1.12.0 Resolution: Fixed Merged to master via a7abe7d6a13bfc

[jira] [Commented] (FLINK-7589) org.apache.http.ConnectionClosedException: Premature end of Content-Length delimited message body (expected: 159764230; received: 64638536)

[ https://issues.apache.org/jira/browse/FLINK-7589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223957#comment-17223957 ] Yongjun Zhang commented on FLINK-7589: -- HI Folks, thanks for the work here, you may

[jira] [Assigned] (FLINK-19866) FunctionsStateBootstrapOperator.createStateAccessor fails due to uninitialized runtimeContext

[ https://issues.apache.org/jira/browse/FLINK-19866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-19866: Assignee: wang > FunctionsStateBootstrapOperator.createStateAccessor fails due to > unin

[jira] [Comment Edited] (FLINK-19701) Unaligned Checkpoint might misuse the number of buffers to persist from the previous barrier

[ https://issues.apache.org/jira/browse/FLINK-19701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223767#comment-17223767 ] Roman Khachatryan edited comment on FLINK-19701 at 10/30/20, 7:44 PM:

[jira] [Comment Edited] (FLINK-19701) Unaligned Checkpoint might misuse the number of buffers to persist from the previous barrier

[ https://issues.apache.org/jira/browse/FLINK-19701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223767#comment-17223767 ] Roman Khachatryan edited comment on FLINK-19701 at 10/30/20, 7:43 PM:

[jira] [Commented] (FLINK-19701) Unaligned Checkpoint might misuse the number of buffers to persist from the previous barrier

[ https://issues.apache.org/jira/browse/FLINK-19701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223767#comment-17223767 ] Roman Khachatryan commented on FLINK-19701: --- Another related issue occurs in t

[jira] [Assigned] (FLINK-19897) Improve UI related to FLIP-102

[ https://issues.apache.org/jira/browse/FLINK-19897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias reassigned FLINK-19897: Assignee: Yadong Xie > Improve UI related to FLIP-102 > -- > >

[jira] [Assigned] (FLINK-19904) Update documentation to address difference between -Xmx and the metric for maximum heap

[ https://issues.apache.org/jira/browse/FLINK-19904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias reassigned FLINK-19904: Assignee: Matthias > Update documentation to address difference between -Xmx and the metric for

[jira] [Updated] (FLINK-19904) Update documentation to address difference between -Xmx and the metric for maximum heap

[ https://issues.apache.org/jira/browse/FLINK-19904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-19904: - Description: We observed a difference between the configured maximum heap and the maximum heap returned

[jira] [Comment Edited] (FLINK-17159) ES6 ElasticsearchSinkITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-17159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223730#comment-17223730 ] Till Rohrmann edited comment on FLINK-17159 at 10/30/20, 4:24 PM:

[jira] [Comment Edited] (FLINK-17159) ES6 ElasticsearchSinkITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-17159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223730#comment-17223730 ] Till Rohrmann edited comment on FLINK-17159 at 10/30/20, 4:22 PM:

[jira] [Commented] (FLINK-17159) ES6 ElasticsearchSinkITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-17159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223730#comment-17223730 ] Till Rohrmann commented on FLINK-17159: --- Another instability where the ES6 server

[jira] [Commented] (FLINK-19882) E2E: SQLClientHBaseITCase crash

[ https://issues.apache.org/jira/browse/FLINK-19882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223725#comment-17223725 ] Till Rohrmann commented on FLINK-19882: --- https://dev.azure.com/apache-flink/apache

[jira] [Updated] (FLINK-19882) E2E: SQLClientHBaseITCase crash

[ https://issues.apache.org/jira/browse/FLINK-19882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-19882: -- Fix Version/s: 1.12.0 > E2E: SQLClientHBaseITCase crash > --- > >

[jira] [Updated] (FLINK-19882) E2E: SQLClientHBaseITCase crash

[ https://issues.apache.org/jira/browse/FLINK-19882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-19882: -- Priority: Critical (was: Major) > E2E: SQLClientHBaseITCase crash > -

[jira] [Updated] (FLINK-19882) E2E: SQLClientHBaseITCase crash

[ https://issues.apache.org/jira/browse/FLINK-19882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-19882: -- Labels: test-stability (was: testability) > E2E: SQLClientHBaseITCase crash > ---

[jira] [Updated] (FLINK-18570) SQLClientHBaseITCase.testHBase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-18570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18570: -- Fix Version/s: 1.12.0 > SQLClientHBaseITCase.testHBase fails on azure > --

[jira] [Updated] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

[ https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-19863: -- Fix Version/s: 1.12.0 > SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Proce

[jira] [Comment Edited] (FLINK-19865) YARN tests failed with "java.lang.NumberFormatException: For input string: "${env:MAX_LOG_FILE_NUMBER}" java.lang.NumberFormatException: For input string: "${env:

[ https://issues.apache.org/jira/browse/FLINK-19865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223717#comment-17223717 ] Till Rohrmann edited comment on FLINK-19865 at 10/30/20, 4:11 PM:

[jira] [Comment Edited] (FLINK-19865) YARN tests failed with "java.lang.NumberFormatException: For input string: "${env:MAX_LOG_FILE_NUMBER}" java.lang.NumberFormatException: For input string: "${env:

[ https://issues.apache.org/jira/browse/FLINK-19865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223717#comment-17223717 ] Till Rohrmann edited comment on FLINK-19865 at 10/30/20, 4:11 PM:

[jira] [Updated] (FLINK-19865) YARN tests failed with "java.lang.NumberFormatException: For input string: "${env:MAX_LOG_FILE_NUMBER}" java.lang.NumberFormatException: For input string: "${env:MAX_LOG

[ https://issues.apache.org/jira/browse/FLINK-19865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-19865: -- Fix Version/s: 1.12.0 > YARN tests failed with "java.lang.NumberFormatException: For input str

[jira] [Commented] (FLINK-19865) YARN tests failed with "java.lang.NumberFormatException: For input string: "${env:MAX_LOG_FILE_NUMBER}" java.lang.NumberFormatException: For input string: "${env:MAX_L

[ https://issues.apache.org/jira/browse/FLINK-19865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223717#comment-17223717 ] Till Rohrmann commented on FLINK-19865: --- Could you take a look at the problem [~rm

[jira] [Commented] (FLINK-19864) TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but was:<-9223372036854775808>"

[ https://issues.apache.org/jira/browse/FLINK-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223716#comment-17223716 ] Till Rohrmann commented on FLINK-19864: --- cc [~chesnay] > TwoInputStreamTaskTest.t

[jira] [Updated] (FLINK-19864) TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but was:<-9223372036854775808>"

[ https://issues.apache.org/jira/browse/FLINK-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-19864: -- Fix Version/s: 1.12.0 > TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1>

[jira] [Updated] (FLINK-19864) TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but was:<-9223372036854775808>"

[ https://issues.apache.org/jira/browse/FLINK-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-19864: -- Priority: Critical (was: Major) > TwoInputStreamTaskTest.testWatermarkMetrics failed with "ex

[jira] [Commented] (FLINK-19369) BlobClientTest.testGetFailsDuringStreamingForJobPermanentBlob hangs

[ https://issues.apache.org/jira/browse/FLINK-19369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223710#comment-17223710 ] Matthias commented on FLINK-19369: -- Ok, the stacktraces I mentioned in the comments see

[jira] [Closed] (FLINK-19369) BlobClientTest.testGetFailsDuringStreamingForJobPermanentBlob hangs

[ https://issues.apache.org/jira/browse/FLINK-19369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias closed FLINK-19369. Resolution: Won't Fix > BlobClientTest.testGetFailsDuringStreamingForJobPermanentBlob hangs >

[jira] [Updated] (FLINK-19897) Improve UI related to FLIP-102

[ https://issues.apache.org/jira/browse/FLINK-19897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-19897: - Description: This ticket collects issues that came up after merging FLIP-102 related changes into maste

[jira] [Updated] (FLINK-19661) Implement changes required to resolve FLIP-104

[ https://issues.apache.org/jira/browse/FLINK-19661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-19661: - Summary: Implement changes required to resolve FLIP-104 (was: MlH!) > Implement changes required to res

[jira] [Updated] (FLINK-19661) MlH!

[ https://issues.apache.org/jira/browse/FLINK-19661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-19661: - Summary: MlH! (was: Implement changes required to resolve FLIP-104) > MlH! > > > K

[jira] [Created] (FLINK-19904) Update documentation to address difference between -Xmx and the metric for maximum heap

Matthias created FLINK-19904: Summary: Update documentation to address difference between -Xmx and the metric for maximum heap Key: FLINK-19904 URL: https://issues.apache.org/jira/browse/FLINK-19904 Proje

[jira] [Updated] (FLINK-19897) Improve UI related to FLIP-102

[ https://issues.apache.org/jira/browse/FLINK-19897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-19897: - Description: This ticket collects issues that came up after merging FLIP-102 related changes into maste

[jira] [Updated] (FLINK-19903) Allow to read metadata for filesystem connector

[ https://issues.apache.org/jira/browse/FLINK-19903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-19903: - Parent: FLINK-15869 Issue Type: Sub-task (was: Improvement) > Allow to read met

[jira] [Updated] (FLINK-19903) Allow to read metadata in filesystem connector

[ https://issues.apache.org/jira/browse/FLINK-19903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-19903: - Summary: Allow to read metadata in filesystem connector (was: Allow to read metadata fo

[jira] [Updated] (FLINK-19903) Allow to read metadata for filesystem connector

[ https://issues.apache.org/jira/browse/FLINK-19903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-19903: - Summary: Allow to read metadata for filesystem connector (was: Expose filesystem metada

[jira] [Updated] (FLINK-19903) Expose filesystem metada

[ https://issues.apache.org/jira/browse/FLINK-19903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-19903: - Summary: Expose filesystem metada (was: Implement equivalent of Spark's f.input_file_n

[jira] [Updated] (FLINK-19903) Implement equivalent of Spark's f.input_file_name()

[ https://issues.apache.org/jira/browse/FLINK-19903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19903: - Component/s: (was: API / Core) Table SQL / API > Implement equivale

[jira] [Updated] (FLINK-19901) Unable to exclude metrics variables for the last metrics reporter.

[ https://issues.apache.org/jira/browse/FLINK-19901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-19901: - Fix Version/s: 1.11.3 1.10.3 1.12.0 > Unable to ex

[jira] [Updated] (FLINK-19901) Unable to exclude metrics variables for the last metrics reporter.

[ https://issues.apache.org/jira/browse/FLINK-19901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-19901: - Affects Version/s: (was: 1.11.2) 1.10.0 > Unable to exclude m

[jira] [Created] (FLINK-19903) Implement equivalent of Spark's f.input_file_name()

Ruben Laguna created FLINK-19903: Summary: Implement equivalent of Spark's f.input_file_name() Key: FLINK-19903 URL: https://issues.apache.org/jira/browse/FLINK-19903 Project: Flink Issue Typ

[jira] [Assigned] (FLINK-19901) Unable to exclude metrics variables for the last metrics reporter.

[ https://issues.apache.org/jira/browse/FLINK-19901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-19901: Assignee: Chesnay Schepler > Unable to exclude metrics variables for the last met

[jira] [Closed] (FLINK-18363) Add user classloader to context in DeSerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-18363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-18363. Resolution: Implemented Implemented in da67eeb90dda7d6610c5328f061ab417a5c4edbc > Add use

[jira] [Closed] (FLINK-19762) Selecting Job-ID and TaskManager-ID in web UI covers more than the ID

[ https://issues.apache.org/jira/browse/FLINK-19762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-19762. Resolution: Fixed master: ddc163a98a35f07f9afebddabd0ca65a7007255b > Selecting Job-ID and

[jira] [Closed] (FLINK-19835) Don't emit intermediate watermarks from sources in BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-19835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-19835. Fix Version/s: 1.12.0 Resolution: Implemented master: 16e40b6239d41dd33db1b7bcc4fa1

[jira] [Created] (FLINK-19902) Adjust JobMasterTest to be compatible

Chesnay Schepler created FLINK-19902: Summary: Adjust JobMasterTest to be compatible Key: FLINK-19902 URL: https://issues.apache.org/jira/browse/FLINK-19902 Project: Flink Issue Type: Sub

[jira] [Commented] (FLINK-19901) Unable to exclude metrics variables for the last metrics reporter.

[ https://issues.apache.org/jira/browse/FLINK-19901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223565#comment-17223565 ] Truong Duc Kien commented on FLINK-19901: - [~chesnay] Can you take look ? Thanks

[jira] [Created] (FLINK-19901) Unable to exclude metrics variables for the last metrics reporter.

Truong Duc Kien created FLINK-19901: --- Summary: Unable to exclude metrics variables for the last metrics reporter. Key: FLINK-19901 URL: https://issues.apache.org/jira/browse/FLINK-19901 Project: Fli

[jira] [Updated] (FLINK-19900) Wrong property name for surefire log4j configuration

[ https://issues.apache.org/jira/browse/FLINK-19900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-19900: - Priority: Trivial (was: Major) > Wrong property name for surefire log4j configuration >

[jira] [Commented] (FLINK-19900) Wrong property name for surefire log4j configuration

[ https://issues.apache.org/jira/browse/FLINK-19900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223563#comment-17223563 ] Chesnay Schepler commented on FLINK-19900: -- We can just remove it; the log4j fi

[GitHub] [flink] flinkbot edited a comment on pull request #13834: [FLINK-19872][Formats/Csv] Support to parse millisecond for TIME type in CSV format

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

[GitHub] [flink] flinkbot edited a comment on pull request #13833: [FLINK-19867][table-common] Validation fails for UDF that accepts var…

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

[jira] [Updated] (FLINK-19900) Wrong property name for surefire log4j configuration

[ https://issues.apache.org/jira/browse/FLINK-19900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19900: --- Labels: pull-request-available (was: ) > Wrong property name for surefire log4j configurati

[GitHub] [flink] dawidwys opened a new pull request #13858: [FLINK-19900] Fix surefire log4j configuration

dawidwys opened a new pull request #13858: URL: https://github.com/apache/flink/pull/13858 ## What is the purpose of the change Log4j uses `log4j.configurationFile` system property for passing a configuration file. In our surefire configuration we use `log4j.configuration` property

[GitHub] [flink] flinkbot edited a comment on pull request #13828: [FLINK-19835] Don't emit intermediate watermarks from sources in BATCH execution mode

flinkbot edited a comment on pull request #13828: URL: https://github.com/apache/flink/pull/13828#issuecomment-718083567 ## CI report: * cbef03730f1eef907bcc6aaacda3525410cb6080 UNKNOWN * b2332fd1a5e22460e043267a3b7d296e59c804b6 UNKNOWN * 098a3e0039824c161d1fe815a65e6a982f16

[jira] [Updated] (FLINK-19900) Wrong property name for surefire log4j configuration

[ https://issues.apache.org/jira/browse/FLINK-19900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-19900: - Description: Log4j uses {{log4j.configurationFile}} system property for passing a confi

[GitHub] [flink] flinkbot edited a comment on pull request #13766: [FLINK-19703][runtime] Untrack a result partition if its producer task failed in TaskManager

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

[jira] [Created] (FLINK-19900) Wrong property name for surefire log4j configuration

Dawid Wysakowicz created FLINK-19900: Summary: Wrong property name for surefire log4j configuration Key: FLINK-19900 URL: https://issues.apache.org/jira/browse/FLINK-19900 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #13648: [FLINK-19632] Introduce a new ResultPartitionType for Approximate Local Recovery

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

[GitHub] [flink] flinkbot edited a comment on pull request #13523: [FLINK-15981][network] Implement FileRegion way to shuffle file-based blocking partition in network stack

flinkbot edited a comment on pull request #13523: URL: https://github.com/apache/flink/pull/13523#issuecomment-701325670 ## CI report: * 81b40b201a250bc3c738b30d3d820657b9f749ee UNKNOWN * c012a3b687c0ceab428913a5e6cea6f9d3948932 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Closed] (FLINK-19824) Refactor and merge SupportsComputedColumnPushDown and SupportsWatermarkPushDown interfaces

[ https://issues.apache.org/jira/browse/FLINK-19824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19824. --- Fix Version/s: 1.12.0 Resolution: Fixed Fixed in master: 3bf5786655c3bb914ce02ebb0e4a1863b205b829 >

[jira] [Assigned] (FLINK-19276) Allow to read metadata for Debezium format

[ https://issues.apache.org/jira/browse/FLINK-19276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-19276: Assignee: Timo Walther > Allow to read metadata for Debezium format > ---

[GitHub] [flink] wuchong merged pull request #13806: [FLINK-19824][table-api] Refactor and merge SupportsComputedColumnPushDown and SupportsWatermarkPushDown interfaces

wuchong merged pull request #13806: URL: https://github.com/apache/flink/pull/13806 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

[GitHub] [flink] wuchong commented on pull request #13806: [FLINK-19824][table-api] Refactor and merge SupportsComputedColumnPushDown and SupportsWatermarkPushDown interfaces

wuchong commented on pull request #13806: URL: https://github.com/apache/flink/pull/13806#issuecomment-719471595 Thanks for the reviewing @godfreyhe . This is an automated message from the Apache Git Service. To respond to th

[jira] [Commented] (FLINK-19276) Allow to read metadata for Debezium format

[ https://issues.apache.org/jira/browse/FLINK-19276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223558#comment-17223558 ] Timo Walther commented on FLINK-19276: -- Thanks for offering your help [~lsy]. I wou

[jira] [Updated] (FLINK-19896) Support first-n-rows deduplication in the Deduplicate operator

[ https://issues.apache.org/jira/browse/FLINK-19896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19896: Fix Version/s: (was: 1.11.2) > Support first-n-rows deduplication in the Deduplicate operator > --

[jira] [Updated] (FLINK-19896) Support first-n-rows deduplication in the Deduplicate operator

[ https://issues.apache.org/jira/browse/FLINK-19896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19896: Affects Version/s: (was: 1.11.3) (was: 1.12.0) > Support first-n-rows dedup

[jira] [Comment Edited] (FLINK-19896) Support first-n-rows deduplication in the Deduplicate operator

[ https://issues.apache.org/jira/browse/FLINK-19896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223557#comment-17223557 ] Jark Wu edited comment on FLINK-19896 at 10/30/20, 10:25 AM: -

[GitHub] [flink] flinkbot edited a comment on pull request #13331: [FLINK-19079][table-runtime] Import rowtime deduplicate operator

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

[jira] [Commented] (FLINK-19899) [Kinesis][EFO] Optimise error handling to use a separate exception delivery mechanism

[ https://issues.apache.org/jira/browse/FLINK-19899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223555#comment-17223555 ] Danny Cranmer commented on FLINK-19899: --- [~tzulitai] as discussed, I will publish

[jira] [Commented] (FLINK-19896) Support first-n-rows deduplication in the Deduplicate operator

[ https://issues.apache.org/jira/browse/FLINK-19896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223557#comment-17223557 ] Jark Wu commented on FLINK-19896: - I'm not sure about this. If we support first-n-rows f

[jira] [Commented] (FLINK-19898) [Kinesis][EFO] Ignore ReadTimeoutException from SubcribeToShard retry policy

[ https://issues.apache.org/jira/browse/FLINK-19898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223556#comment-17223556 ] Danny Cranmer commented on FLINK-19898: --- [~tzulitai] as discussed, I will publish

[jira] [Created] (FLINK-19899) [Kinesis][EFO] Optimise error handling to use a separate exception delivery mechanism

Danny Cranmer created FLINK-19899: - Summary: [Kinesis][EFO] Optimise error handling to use a separate exception delivery mechanism Key: FLINK-19899 URL: https://issues.apache.org/jira/browse/FLINK-19899

[jira] [Assigned] (FLINK-19756) Use multi-input optimization by default

[ https://issues.apache.org/jira/browse/FLINK-19756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-19756: -- Assignee: godfrey he > Use multi-input optimization by default >

[jira] [Created] (FLINK-19898) [Kinesis][EFO] Ignore ReadTimeoutException from SubcribeToShard retry policy

Danny Cranmer created FLINK-19898: - Summary: [Kinesis][EFO] Ignore ReadTimeoutException from SubcribeToShard retry policy Key: FLINK-19898 URL: https://issues.apache.org/jira/browse/FLINK-19898 Projec

[GitHub] [flink] wuchong commented on a change in pull request #13834: [FLINK-19872][Formats/Csv] Support to parse millisecond for TIME type in CSV format

wuchong commented on a change in pull request #13834: URL: https://github.com/apache/flink/pull/13834#discussion_r514996865 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvRowDataSerDeSchemaTest.java ## @@ -109,6 +109,54 @@ public void testS

[GitHub] [flink] zhijiangW commented on pull request #13595: [FLINK-19582][network] Introduce sort-merge based blocking shuffle to Flink

zhijiangW commented on pull request #13595: URL: https://github.com/apache/flink/pull/13595#issuecomment-719467007 Thanks for the updates @wsry ! I think most of my previous comments were addressed except for https://github.com/apache/flink/pull/13595#discussion_r514988635. And as

[GitHub] [flink] zhijiangW commented on a change in pull request #13595: [FLINK-19582][network] Introduce sort-merge based blocking shuffle to Flink

zhijiangW commented on a change in pull request #13595: URL: https://github.com/apache/flink/pull/13595#discussion_r514994161 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PartitionedFileWriter.java ## @@ -0,0 +1,211 @@ +/* + * License

[GitHub] [flink] zhijiangW commented on pull request #13523: [FLINK-15981][network] Implement FileRegion way to shuffle file-based blocking partition in network stack

zhijiangW commented on pull request #13523: URL: https://github.com/apache/flink/pull/13523#issuecomment-719465267 @StephanEwen, I have updated the codes for addressing above comments. Regards the tests, I think the existing `BoundedBlockingSubpartitionTest` and `BoundedBlockingSubp

[jira] [Created] (FLINK-19897) Improve UI related to FLIP-102

Matthias created FLINK-19897: Summary: Improve UI related to FLIP-102 Key: FLINK-19897 URL: https://issues.apache.org/jira/browse/FLINK-19897 Project: Flink Issue Type: Bug Components:

[GitHub] [flink] flinkbot commented on pull request #13857: [FLINK-16268][table-planner-blink] Failed to run rank over window wit…

flinkbot commented on pull request #13857: URL: https://github.com/apache/flink/pull/13857#issuecomment-719465188 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] lirui-apache opened a new pull request #13857: [FLINK-16268][table-planner-blink] Failed to run rank over window wit…

lirui-apache opened a new pull request #13857: URL: https://github.com/apache/flink/pull/13857 …h Hive built-in functions ## What is the purpose of the change Fix NPEs when using hive UDFs. ## Brief change log - Properly handle hive UDFs in UserDefin

[GitHub] [flink] aljoscha commented on pull request #11895: [FLINK-10911][scala-shell] Enable flink-scala-shell with Scala 2.12

aljoscha commented on pull request #11895: URL: https://github.com/apache/flink/pull/11895#issuecomment-719463468 @zjffdu Should we still try and get this in for Flink 1.12? Sorry for the very long delay on this one! 😱 This

[GitHub] [flink] SteNicholas commented on pull request #13853: [FLINK-19837][DataStream] Don't emit intermediate watermarks from watermark operators in BATCH execution mode

SteNicholas commented on pull request #13853: URL: https://github.com/apache/flink/pull/13853#issuecomment-719462500 @aljoscha , sorry for my bad implementations. I agree with the steps you provided that use `assignTimestampsAndWatermarks()` logical operation instead of creating an operato

[GitHub] [flink] aljoscha commented on a change in pull request #13844: [FLINK-18363] Add user classloader to context in DeSerializationSchema

aljoscha commented on a change in pull request #13844: URL: https://github.com/apache/flink/pull/13844#discussion_r514989016 ## File path: flink-core/src/main/java/org/apache/flink/api/common/serialization/DeserializationSchema.java ## @@ -112,5 +114,13 @@ default void deseria

[GitHub] [flink] lirui-apache closed pull request #11209: [FLINK-16268][hive][table-planner-blink] Failed to run rank over wind…

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

[jira] [Updated] (FLINK-16268) Failed to run rank over window with Hive built-in functions

[ https://issues.apache.org/jira/browse/FLINK-16268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-16268: --- Fix Version/s: 1.11.3 > Failed to run rank over window with Hive built-in functions > --

[GitHub] [flink] zhijiangW commented on a change in pull request #13595: [FLINK-19582][network] Introduce sort-merge based blocking shuffle to Flink

zhijiangW commented on a change in pull request #13595: URL: https://github.com/apache/flink/pull/13595#discussion_r514990038 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java ## @@ -0,0 +1,360 @@ +/* + * Lice

[GitHub] [flink] zhijiangW commented on a change in pull request #13595: [FLINK-19582][network] Introduce sort-merge based blocking shuffle to Flink

zhijiangW commented on a change in pull request #13595: URL: https://github.com/apache/flink/pull/13595#discussion_r514989760 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java ## @@ -0,0 +1,360 @@ +/* + * Lice

[GitHub] [flink] flinkbot edited a comment on pull request #13855: [FLINK-19894][python] Use iloc for positional slicing instead of direct slicing in from_pandas

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

[GitHub] [flink] zhijiangW commented on a change in pull request #13595: [FLINK-19582][network] Introduce sort-merge based blocking shuffle to Flink

zhijiangW commented on a change in pull request #13595: URL: https://github.com/apache/flink/pull/13595#discussion_r514988635 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java ## @@ -0,0 +1,360 @@ +/* + * Lice

[GitHub] [flink] flinkbot edited a comment on pull request #13852: [FLINK-19875][table] Integrate file compaction to filesystem connector

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

  1   2   3   >