[GitHub] [flink] flinkbot commented on pull request #13113: [FLINK-18883][python] Support reduce() operation for Python KeyedStream.

2020-08-10 Thread GitBox
flinkbot commented on pull request #13113: URL: https://github.com/apache/flink/pull/13113#issuecomment-671738552 ## CI report: * eae680339ac50d4def95156c5c680628e9c16ff6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Closed] (FLINK-15611) KafkaITCase.testOneToOneSources fails on Travis

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-15611. -- Resolution: Cannot Reproduce I'm closing this ticket due to inactivity for now. >

[GitHub] [flink] flinkbot edited a comment on pull request #13098: [FLINK-18866][python] Support filter() operation for Python DataStrea…

2020-08-10 Thread GitBox
flinkbot edited a comment on pull request #13098: URL: https://github.com/apache/flink/pull/13098#issuecomment-671163278 ## CI report: * af3d92942065464e267e9715696ec3154ed32ee9 Azure:

[jira] [Closed] (FLINK-16956) Git fetch failed with exit code 128

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-16956. -- Fix Version/s: (was: 1.12.0) Resolution: Cannot Reproduce > Git fetch failed with

[jira] [Closed] (FLINK-16982) scala-maven-plugin JVM runs out of memory in flink-runtime

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-16982. -- Resolution: Cannot Reproduce > scala-maven-plugin JVM runs out of memory in flink-runtime >

[jira] [Updated] (FLINK-17458) TaskExecutorSubmissionTest#testFailingScheduleOrUpdateConsumers

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17458: --- Component/s: Runtime / Coordination >

[GitHub] [flink] flinkbot commented on pull request #13113: [FLINK-18883][python] Support reduce() operation for Python KeyedStream.

2020-08-10 Thread GitBox
flinkbot commented on pull request #13113: URL: https://github.com/apache/flink/pull/13113#issuecomment-671735664 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

[jira] [Updated] (FLINK-18883) Support reduce() operation for Python KeyedStream.

2020-08-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18883: --- Labels: pull-request-available (was: ) > Support reduce() operation for Python

[GitHub] [flink] Myracle commented on pull request #13051: [FLINK-18760][runtime] Redundant task managers should be released when there's no job running in session cluster

2020-08-10 Thread GitBox
Myracle commented on pull request #13051: URL: https://github.com/apache/flink/pull/13051#issuecomment-671735098 Thank you, @xintongsong This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] hequn8128 opened a new pull request #13113: [FLINK-18883][python] Support reduce() operation for Python KeyedStream.

2020-08-10 Thread GitBox
hequn8128 opened a new pull request #13113: URL: https://github.com/apache/flink/pull/13113 ## What is the purpose of the change This pull request adds reduce operation and reduce functions for Python DataStream API. ## Brief change log - Adds reduce

[jira] [Commented] (FLINK-17949) KafkaShuffleITCase.testSerDeIngestionTime:156->testRecordSerDe:388 expected:<310> but was:<0>

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175253#comment-17175253 ] Robert Metzger commented on FLINK-17949: The latest failure Dian reported is on master. >

[GitHub] [flink] flinkbot edited a comment on pull request #13098: [FLINK-18866][python] Support filter() operation for Python DataStrea…

2020-08-10 Thread GitBox
flinkbot edited a comment on pull request #13098: URL: https://github.com/apache/flink/pull/13098#issuecomment-671163278 ## CI report: * af3d92942065464e267e9715696ec3154ed32ee9 Azure:

[jira] [Closed] (FLINK-18321) AbstractCloseableRegistryTest.testClose unstable

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-18321. -- Resolution: Duplicate Closing. Duplicate of FLINK-18815. >

[jira] [Closed] (FLINK-18356) Exit code 137 returned from process when testing pyflink

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-18356. -- Resolution: Cannot Reproduce > Exit code 137 returned from process when testing pyflink >

[jira] [Closed] (FLINK-18817) 'Kerberized YARN per-job on Docker test' failed

2020-08-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18817. --- Resolution: Duplicate Have checked the

[GitHub] [flink] klion26 commented on a change in pull request #13089: [FLINK-18813][docs-zh] Translate the 'Local Installation' page of 'Try Flink' into Chinese

2020-08-10 Thread GitBox
klion26 commented on a change in pull request #13089: URL: https://github.com/apache/flink/pull/13089#discussion_r468330314 ## File path: docs/try-flink/local_installation.zh.md ## @@ -26,36 +26,35 @@ under the License. {% if site.version contains "SNAPSHOT" %} - NOTE:

[jira] [Updated] (FLINK-9657) Suspicious output from Bucketing sink E2E test on travis

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-9657: -- Labels: test-stability (was: ) > Suspicious output from Bucketing sink E2E test on travis >

[jira] [Closed] (FLINK-10182) AsynchronousBufferFileWriterTest deadlocks on travis

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-10182. -- Resolution: Cannot Reproduce Closing ticket due to inactivity. >

[jira] [Updated] (FLINK-10182) AsynchronousBufferFileWriterTest deadlocks on travis

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10182: --- Labels: test-stability (was: ) > AsynchronousBufferFileWriterTest deadlocks on travis >

[jira] [Commented] (FLINK-4295) CoGroupGroupSortTranslationTest#testGroupSortTuplesDefaultCoGroup fails to run

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175240#comment-17175240 ] Robert Metzger commented on FLINK-4295: --- The test is ignored, however, it passes when I run it.

[GitHub] [flink] flinkbot edited a comment on pull request #13098: [FLINK-18866][python] Support filter() operation for Python DataStrea…

2020-08-10 Thread GitBox
flinkbot edited a comment on pull request #13098: URL: https://github.com/apache/flink/pull/13098#issuecomment-671163278 ## CI report: * af3d92942065464e267e9715696ec3154ed32ee9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13090: [FLINK-18844][json][maxwell] Support maxwell-json format to read Maxwell changelogs

2020-08-10 Thread GitBox
flinkbot edited a comment on pull request #13090: URL: https://github.com/apache/flink/pull/13090#issuecomment-670818966 ## CI report: * d2a7bde48d5c4e4106e9f889e0a3729c5a71c716 Azure:

[jira] [Updated] (FLINK-4295) CoGroupGroupSortTranslationTest#testGroupSortTuplesDefaultCoGroup fails to run

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4295: -- Labels: test-stability (was: ) >

[jira] [Closed] (FLINK-12542) Kafka011ITCase#testAutoOffsetRetrievalAndCommitToKafka test failed

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-12542. -- Resolution: Cannot Reproduce Closing ticket due to inactivity. >

[jira] [Closed] (FLINK-12196) FlinkKafkaProducer011ITCase#testRunOutOfProducersInThePool throws NPE

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-12196. -- Resolution: Cannot Reproduce Closing ticket due to inactivity. >

[jira] [Updated] (FLINK-12196) FlinkKafkaProducer011ITCase#testRunOutOfProducersInThePool throws NPE

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12196: --- Labels: test-stability (was: ) >

[jira] [Closed] (FLINK-12244) SynchronousCheckpointITCase hang up

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-12244. -- Resolution: Cannot Reproduce Closing ticket due to inactivity. > SynchronousCheckpointITCase

[jira] [Updated] (FLINK-12244) SynchronousCheckpointITCase hang up

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12244: --- Labels: test-stability (was: ) > SynchronousCheckpointITCase hang up >

[jira] [Updated] (FLINK-12542) Kafka011ITCase#testAutoOffsetRetrievalAndCommitToKafka test failed

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12542: --- Labels: test-stability (was: ) > Kafka011ITCase#testAutoOffsetRetrievalAndCommitToKafka

[jira] [Updated] (FLINK-12773) Unstable kafka e2e test

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12773: --- Labels: test-stability (was: ) > Unstable kafka e2e test > --- > >

[jira] [Closed] (FLINK-12773) Unstable kafka e2e test

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-12773. -- Resolution: Cannot Reproduce Closing ticket due to inactivity. > Unstable kafka e2e test >

[jira] [Updated] (FLINK-14348) YarnFileStageTestS3ITCase. testRecursiveUploadForYarnS3a fails to delete files

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14348: --- Labels: test-stability (was: ) > YarnFileStageTestS3ITCase. testRecursiveUploadForYarnS3a

[jira] [Closed] (FLINK-15315) Add test case for rest

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-15315. -- Resolution: Cannot Reproduce Closing this ticket due to inactivity. Please reopen if there

[jira] [Updated] (FLINK-15611) KafkaITCase.testOneToOneSources fails on Travis

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-15611: --- Labels: test-stability (was: ) > KafkaITCase.testOneToOneSources fails on Travis >

[jira] [Updated] (FLINK-15451) TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure failed on azure

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-15451: --- Labels: test-stability (was: ) >

[jira] [Updated] (FLINK-15745) KafkaITCase.testKeyValueSupport failure due to assertion error.

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-15745: --- Labels: test-stability (was: ) > KafkaITCase.testKeyValueSupport failure due to assertion

[jira] [Updated] (FLINK-17379) testScaleDownBeforeFirstCheckpoint Error reading field 'api_versions': Error reading field 'max_version':

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17379: --- Labels: test-stability (was: ) > testScaleDownBeforeFirstCheckpoint Error reading field

[jira] [Updated] (FLINK-15619) GroupWindowTableAggregateITCase.testAllProcessingTimeTumblingGroupWindowOverCount failed on Azure

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-15619: --- Labels: test-stability (was: ) >

[jira] [Updated] (FLINK-17482) KafkaITCase.testMultipleSourcesOnePartition unstable

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17482: --- Labels: test-stability (was: ) > KafkaITCase.testMultipleSourcesOnePartition unstable >

[jira] [Updated] (FLINK-16298) GroupWindowTableAggregateITCase.testEventTimeTumblingWindow fails on Travis

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-16298: --- Labels: test-stability (was: ) >

[jira] [Updated] (FLINK-16368) ZooKeeperHighAvailabilityITCase test fail

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-16368: --- Labels: test-stability (was: ) > ZooKeeperHighAvailabilityITCase test fail >

[jira] [Updated] (FLINK-17458) TaskExecutorSubmissionTest#testFailingScheduleOrUpdateConsumers

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17458: --- Labels: test-stability (was: ) >

[jira] [Updated] (FLINK-18174) EventTimeWindowCheckpointingITCase crashes with exit code 127

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18174: --- Component/s: API / DataStream > EventTimeWindowCheckpointingITCase crashes with exit code

[jira] [Updated] (FLINK-17510) StreamingKafkaITCase. testKafka timeouts on downloading Kafka

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17510: --- Labels: test-stability (was: ) > StreamingKafkaITCase. testKafka timeouts on downloading

[jira] [Updated] (FLINK-18174) EventTimeWindowCheckpointingITCase crashes with exit code 127

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18174: --- Labels: test-stability (was: ) > EventTimeWindowCheckpointingITCase crashes with exit code

[jira] [Updated] (FLINK-18476) PythonEnvUtilsTest#testStartPythonProcess fails locally

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18476: --- Labels: test-stability (was: ) > PythonEnvUtilsTest#testStartPythonProcess fails locally

[jira] [Updated] (FLINK-18817) 'Kerberized YARN per-job on Docker test' failed

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18817: --- Labels: test-stability (was: ) > 'Kerberized YARN per-job on Docker test' failed >

[jira] [Commented] (FLINK-18845) class not found exception when i use sql client to try mysql as datasource.

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175220#comment-17175220 ] Robert Metzger commented on FLINK-18845: I reduced the priority of this ticket until it is

[jira] [Updated] (FLINK-18845) class not found exception when i use sql client to try mysql as datasource.

2020-08-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18845: --- Priority: Minor (was: Blocker) > class not found exception when i use sql client to try

[GitHub] [flink] flinkbot edited a comment on pull request #13051: [FLINK-18760][runtime] Redundant task managers should be released when there's no job running in session cluster

2020-08-10 Thread GitBox
flinkbot edited a comment on pull request #13051: URL: https://github.com/apache/flink/pull/13051#issuecomment-667970728 ## CI report: * b387eae159be898230e9b5a410a295f9960dabb1 UNKNOWN * 0742547410ef77d61dd2566555e0540ff1558f4c UNKNOWN * Unknown: [CANCELED](TBD)

[GitHub] [flink] flinkbot edited a comment on pull request #13051: [FLINK-18760][runtime] Redundant task managers should be released when there's no job running in session cluster

2020-08-10 Thread GitBox
flinkbot edited a comment on pull request #13051: URL: https://github.com/apache/flink/pull/13051#issuecomment-667970728 ## CI report: * b387eae159be898230e9b5a410a295f9960dabb1 UNKNOWN * Unknown: [CANCELED](TBD) * 0742547410ef77d61dd2566555e0540ff1558f4c UNKNOWN

[GitHub] [flink] xintongsong commented on pull request #13051: [FLINK-18760][runtime] Redundant task managers should be released when there's no job running in session cluster

2020-08-10 Thread GitBox
xintongsong commented on pull request #13051: URL: https://github.com/apache/flink/pull/13051#issuecomment-671715738 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] xintongsong commented on a change in pull request #13051: [FLINK-18760][runtime] Redundant task managers should be released when there's no job running in session cluster

2020-08-10 Thread GitBox
xintongsong commented on a change in pull request #13051: URL: https://github.com/apache/flink/pull/13051#discussion_r468315396 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerImpl.java ## @@ -1256,7 +1256,10 @@ void

[GitHub] [flink] JingsongLi commented on a change in pull request #13101: [FLINK-18867][hive] Generic table stored in Hive catalog is incompati…

2020-08-10 Thread GitBox
JingsongLi commented on a change in pull request #13101: URL: https://github.com/apache/flink/pull/13101#discussion_r468312971 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/catalog/hive/HiveCatalogGenericMetadataTest.java ## @@ -65,6

[GitHub] [flink] JingsongLi commented on a change in pull request #13101: [FLINK-18867][hive] Generic table stored in Hive catalog is incompati…

2020-08-10 Thread GitBox
JingsongLi commented on a change in pull request #13101: URL: https://github.com/apache/flink/pull/13101#discussion_r468312570 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/catalog/hive/HiveCatalogGenericMetadataTest.java ## @@ -65,6

[jira] [Commented] (FLINK-18520) New Table Function type inference fails

2020-08-10 Thread Mulan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175204#comment-17175204 ] Mulan commented on FLINK-18520: --- Has AsyncTableFunction fixed? > New Table Function type inference fails

[GitHub] [flink] flinkbot edited a comment on pull request #13090: [FLINK-18844][json][maxwell] Support maxwell-json format to read Maxwell changelogs

2020-08-10 Thread GitBox
flinkbot edited a comment on pull request #13090: URL: https://github.com/apache/flink/pull/13090#issuecomment-670818966 ## CI report: * 3faa1b539faff3a59454cf9710ea69f4dd395e05 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13107: [FLINK-18874][python] Support conversion between Table and DataStream.

2020-08-10 Thread GitBox
flinkbot edited a comment on pull request #13107: URL: https://github.com/apache/flink/pull/13107#issuecomment-671348618 ## CI report: * d5d59fc29f056d9f50c0bf13b34a699076a890a6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13112: [BP-1.11][FLINK-18862][table-planner-blink] Fix LISTAGG throws BinaryRawValueData cannot be cast to StringData exception during runti

2020-08-10 Thread GitBox
flinkbot edited a comment on pull request #13112: URL: https://github.com/apache/flink/pull/13112#issuecomment-671705106 ## CI report: * cea1a0f705453b6e5a03f8aade0cf4fc513fb608 Azure:

[GitHub] [flink] JingsongLi commented on a change in pull request #13010: [FLINK-18735][table] Add support for more types to DataGen source

2020-08-10 Thread GitBox
JingsongLi commented on a change in pull request #13010: URL: https://github.com/apache/flink/pull/13010#discussion_r468310256 ## File path: docs/dev/table/connectors/datagen.md ## @@ -29,25 +29,24 @@ under the License. * This will be replaced by the TOC {:toc} -The

[GitHub] [flink] JingsongLi commented on a change in pull request #13010: [FLINK-18735][table] Add support for more types to DataGen source

2020-08-10 Thread GitBox
JingsongLi commented on a change in pull request #13010: URL: https://github.com/apache/flink/pull/13010#discussion_r468309695 ## File path: flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/datagen/RandomGeneratorVisitor.java ## @@ -0,0

[GitHub] [flink] JingsongLi commented on a change in pull request #13010: [FLINK-18735][table] Add support for more types to DataGen source

2020-08-10 Thread GitBox
JingsongLi commented on a change in pull request #13010: URL: https://github.com/apache/flink/pull/13010#discussion_r468305915 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/DataGeneratorSource.java ## @@ -77,8 +102,11

[jira] [Commented] (FLINK-17511) "RocksDB Memory Management end-to-end test" fails with "Current block cache usage 202123272 larger than expected memory limit 200000000"

2020-08-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175198#comment-17175198 ] Dian Fu commented on FLINK-17511: - Another instance: 

[jira] [Updated] (FLINK-18885) Add partitioning interfaces for Python DataStream API.

2020-08-10 Thread Shuiqiang Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuiqiang Chen updated FLINK-18885: --- Summary: Add partitioning interfaces for Python DataStream API. (was: Add partitioning

[GitHub] [flink] flinkbot commented on pull request #13112: [BP-1.11][FLINK-18862][table-planner-blink] Fix LISTAGG throws BinaryRawValueData cannot be cast to StringData exception during runtime

2020-08-10 Thread GitBox
flinkbot commented on pull request #13112: URL: https://github.com/apache/flink/pull/13112#issuecomment-671705106 ## CI report: * cea1a0f705453b6e5a03f8aade0cf4fc513fb608 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-18888) Support execute_async for StreamExecutionEnvironment.

2020-08-10 Thread Shuiqiang Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuiqiang Chen updated FLINK-1: --- Summary: Support execute_async for StreamExecutionEnvironment. (was: Add ElasticSearch

[GitHub] [flink] flinkbot edited a comment on pull request #13107: [FLINK-18874][python] Support conversion between Table and DataStream.

2020-08-10 Thread GitBox
flinkbot edited a comment on pull request #13107: URL: https://github.com/apache/flink/pull/13107#issuecomment-671348618 ## CI report: * d5d59fc29f056d9f50c0bf13b34a699076a890a6 Azure:

[jira] [Updated] (FLINK-18887) Add ElasticSearch connector for Python DataStream API

2020-08-10 Thread Shuiqiang Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuiqiang Chen updated FLINK-18887: --- Fix Version/s: 1.12.0 > Add ElasticSearch connector for Python DataStream API >

[jira] [Created] (FLINK-18888) Add ElasticSearch connector for Python DataStream API

2020-08-10 Thread Shuiqiang Chen (Jira)
Shuiqiang Chen created FLINK-1: -- Summary: Add ElasticSearch connector for Python DataStream API Key: FLINK-1 URL: https://issues.apache.org/jira/browse/FLINK-1 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #13090: [FLINK-18844][json][maxwell] Support maxwell-json format to read Maxwell changelogs

2020-08-10 Thread GitBox
flinkbot edited a comment on pull request #13090: URL: https://github.com/apache/flink/pull/13090#issuecomment-670818966 ## CI report: * 3faa1b539faff3a59454cf9710ea69f4dd395e05 Azure:

[jira] [Updated] (FLINK-18887) Add ElasticSearch connector for Python DataStream API

2020-08-10 Thread Shuiqiang Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuiqiang Chen updated FLINK-18887: --- Component/s: API / Python > Add ElasticSearch connector for Python DataStream API >

[jira] [Created] (FLINK-18887) Add ElasticSearch connector for Python DataStream API

2020-08-10 Thread Shuiqiang Chen (Jira)
Shuiqiang Chen created FLINK-18887: -- Summary: Add ElasticSearch connector for Python DataStream API Key: FLINK-18887 URL: https://issues.apache.org/jira/browse/FLINK-18887 Project: Flink

[jira] [Created] (FLINK-18886) Support Kafka connectors for Python DataStream API

2020-08-10 Thread Shuiqiang Chen (Jira)
Shuiqiang Chen created FLINK-18886: -- Summary: Support Kafka connectors for Python DataStream API Key: FLINK-18886 URL: https://issues.apache.org/jira/browse/FLINK-18886 Project: Flink Issue

[jira] [Created] (FLINK-18885) Add partitioning interfaces for Python DataStream.

2020-08-10 Thread Shuiqiang Chen (Jira)
Shuiqiang Chen created FLINK-18885: -- Summary: Add partitioning interfaces for Python DataStream. Key: FLINK-18885 URL: https://issues.apache.org/jira/browse/FLINK-18885 Project: Flink Issue

[jira] [Updated] (FLINK-18884) Add chaining strategy and slot sharing group interfaces for Python DataStream API

2020-08-10 Thread Shuiqiang Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuiqiang Chen updated FLINK-18884: --- Summary: Add chaining strategy and slot sharing group interfaces for Python DataStream API

[jira] [Created] (FLINK-18884) Add chaining strategy and slot sharing group interfaces for DataStream

2020-08-10 Thread Shuiqiang Chen (Jira)
Shuiqiang Chen created FLINK-18884: -- Summary: Add chaining strategy and slot sharing group interfaces for DataStream Key: FLINK-18884 URL: https://issues.apache.org/jira/browse/FLINK-18884 Project:

[jira] [Created] (FLINK-18883) Support reduce() operation for Python KeyedStream.

2020-08-10 Thread Hequn Cheng (Jira)
Hequn Cheng created FLINK-18883: --- Summary: Support reduce() operation for Python KeyedStream. Key: FLINK-18883 URL: https://issues.apache.org/jira/browse/FLINK-18883 Project: Flink Issue Type:

[GitHub] [flink] shuiqiangchen commented on pull request #13107: [FLINK-18874][python] Support conversion between Table and DataStream.

2020-08-10 Thread GitBox
shuiqiangchen commented on pull request #13107: URL: https://github.com/apache/flink/pull/13107#issuecomment-671703560 @hequn8128 Thank you! I have added type hints for APIs in the latest commit, please have a look. And I think we could add examples for these apis in python document

[GitHub] [flink] flinkbot commented on pull request #13112: [BP-1.11][FLINK-18862][table-planner-blink] Fix LISTAGG throws BinaryRawValueData cannot be cast to StringData exception during runtime

2020-08-10 Thread GitBox
flinkbot commented on pull request #13112: URL: https://github.com/apache/flink/pull/13112#issuecomment-671702289 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

[jira] [Commented] (FLINK-18862) Fix LISTAGG throws BinaryRawValueData cannot be cast to StringData exception in runtime

2020-08-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175195#comment-17175195 ] Jark Wu commented on FLINK-18862: - Fixed in - master (1.12.0):

[GitHub] [flink] wuchong opened a new pull request #13112: [BP-1.11][FLINK-18862][table-planner-blink] Fix LISTAGG throws BinaryRawValueData cannot be cast to StringData exception during runtime

2020-08-10 Thread GitBox
wuchong opened a new pull request #13112: URL: https://github.com/apache/flink/pull/13112 This is a backport to release-1.11 branch. This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Closed] (FLINK-18872) Aggregate with mini-batch does not respect state retention

2020-08-10 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li closed FLINK-18872. -- Resolution: Duplicate > Aggregate with mini-batch does not respect state retention >

[jira] [Created] (FLINK-18882) Investigate supporting Hive interval type

2020-08-10 Thread Rui Li (Jira)
Rui Li created FLINK-18882: -- Summary: Investigate supporting Hive interval type Key: FLINK-18882 URL: https://issues.apache.org/jira/browse/FLINK-18882 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-18738) Revisit resource management model for python processes.

2020-08-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175189#comment-17175189 ] Xintong Song commented on FLINK-18738: -- Hi all, [~dianfu] and I had an offline discussion

[jira] [Commented] (FLINK-18872) Aggregate with mini-batch does not respect state retention

2020-08-10 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175185#comment-17175185 ] Benchao Li commented on FLINK-18872: [~lsy] sorry for the duplication, I'll close this issue. >

[GitHub] [flink] flinkbot edited a comment on pull request #13098: [FLINK-18866][python] Support filter() operation for Python DataStrea…

2020-08-10 Thread GitBox
flinkbot edited a comment on pull request #13098: URL: https://github.com/apache/flink/pull/13098#issuecomment-671163278 ## CI report: * 2577a9c0cca713f583f38d593c8803bc6d5506c8 Azure:

[jira] [Commented] (FLINK-18872) Aggregate with mini-batch does not respect state retention

2020-08-10 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175175#comment-17175175 ] dalongliu commented on FLINK-18872: --- [~libenchao], I have open a Jira issue for this problem months

[GitHub] [flink] flinkbot edited a comment on pull request #13098: [FLINK-18866][python] Support filter() operation for Python DataStrea…

2020-08-10 Thread GitBox
flinkbot edited a comment on pull request #13098: URL: https://github.com/apache/flink/pull/13098#issuecomment-671163278 ## CI report: * 2577a9c0cca713f583f38d593c8803bc6d5506c8 Azure:

[jira] [Commented] (FLINK-17949) KafkaShuffleITCase.testSerDeIngestionTime:156->testRecordSerDe:388 expected:<310> but was:<0>

2020-08-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175166#comment-17175166 ] Dian Fu commented on FLINK-17949: -

[jira] [Commented] (FLINK-18797) docs and examples use deprecated forms of keyBy

2020-08-10 Thread wulei0302 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175164#comment-17175164 ] wulei0302 commented on FLINK-18797: --- Hi [~jark], Do you think this needs to be done? I am willing to

[jira] [Updated] (FLINK-18881) Modify the Access Broken Link

2020-08-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18881: Fix Version/s: (was: 1.11.1) (was: 1.11.0) 1.11.2 > Modify

[jira] [Updated] (FLINK-18881) Modify the Access Broken Link

2020-08-10 Thread weizheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] weizheng updated FLINK-18881: - Description: In

[jira] [Updated] (FLINK-18881) Modify the Access Broken Link

2020-08-10 Thread weizheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] weizheng updated FLINK-18881: - Description: In

[jira] [Updated] (FLINK-18881) Modify the Access Broken Link

2020-08-10 Thread weizheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] weizheng updated FLINK-18881: - Environment: (was: In

[jira] [Updated] (FLINK-18881) Modify the Access Broken Link

2020-08-10 Thread weizheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] weizheng updated FLINK-18881: - Description: In

[jira] [Created] (FLINK-18881) Modify the Access Broken Link

2020-08-10 Thread weizheng (Jira)
weizheng created FLINK-18881: Summary: Modify the Access Broken Link Key: FLINK-18881 URL: https://issues.apache.org/jira/browse/FLINK-18881 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-18333) UnsignedTypeConversionITCase failed caused by MariaDB4j "Asked to waitFor Program"

2020-08-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18333: Priority: Critical (was: Major) > UnsignedTypeConversionITCase failed caused by MariaDB4j "Asked to

[jira] [Commented] (FLINK-18333) UnsignedTypeConversionITCase failed caused by MariaDB4j "Asked to waitFor Program"

2020-08-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175161#comment-17175161 ] Dian Fu commented on FLINK-18333: - Another instance: 

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

2020-08-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175159#comment-17175159 ] Dian Fu commented on FLINK-17274: -

[jira] [Updated] (FLINK-18807) FlinkKafkaProducerITCase.testScaleUpAfterScalingDown failed with "Timeout expired after 60000milliseconds while awaiting EndTxn(COMMIT)"

2020-08-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18807: Fix Version/s: 1.12.0 > FlinkKafkaProducerITCase.testScaleUpAfterScalingDown failed with "Timeout >

  1   2   3   4   5   >