[GitHub] [flink] flinkbot edited a comment on pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

2020-05-14 Thread GitBox
flinkbot edited a comment on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-613252882 ## CI report: * 066795205734add3b142a92c687c98b25253985e UNKNOWN * ba529bb050fb3fa07c15fc620b5c29e3fa73ae7f Azure:

[GitHub] [flink] rkhachatryan commented on pull request #11948: [FLINK-17467] Align channels on savepoint in UC mode

2020-05-14 Thread GitBox
rkhachatryan commented on pull request #11948: URL: https://github.com/apache/flink/pull/11948#issuecomment-628694257 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] dawidwys commented on a change in pull request #12147: [FLINK-17653] FLIP-126: Unify (and separate) Watermark Assigners

2020-05-14 Thread GitBox
dawidwys commented on a change in pull request #12147: URL: https://github.com/apache/flink/pull/12147#discussion_r425205009 ## File path: flink-core/src/test/java/org/apache/flink/api/common/eventtime/WatermarkStrategiesTest.java ## @@ -0,0 +1,101 @@ +/* + * Licensed to the

[jira] [Updated] (FLINK-17698) Support for comparing instance of all types

2020-05-14 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-17698: - Description: Ensure that all comparable types can be compared. e.g. revisit

[jira] [Commented] (FLINK-17697) JDK11: JdbcFullTest.testEnrichedClassCastException: expected:<[java.lang.String cannot be cast to java.lang.Double], field index: 3, fi...> but was:<[class java.lang.S

2020-05-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107387#comment-17107387 ] Jark Wu commented on FLINK-17697: - There are 2 failure cases: {code:java} 2020-05-13T23:32:03.7853981Z

[jira] [Assigned] (FLINK-17697) JDK11: JdbcFullTest.testEnrichedClassCastException: expected:<[java.lang.String cannot be cast to java.lang.Double], field index: 3, fi...> but was:<[class java.lang.St

2020-05-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17697: --- Assignee: Leonard Xu > JDK11: JdbcFullTest.testEnrichedClassCastException: >

[jira] [Updated] (FLINK-17698) Support for comparing instance of all types

2020-05-14 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-17698: - Parent: FLINK-12251 Issue Type: Sub-task (was: Bug) > Support for comparing instance

[jira] [Created] (FLINK-17699) Reduce scope for SourceOperator arguments and initialize more eagerly

2020-05-14 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-17699: Summary: Reduce scope for SourceOperator arguments and initialize more eagerly Key: FLINK-17699 URL: https://issues.apache.org/jira/browse/FLINK-17699 Project: Flink

[jira] [Created] (FLINK-17698) Support for comparing instance of all types

2020-05-14 Thread Timo Walther (Jira)
Timo Walther created FLINK-17698: Summary: Support for comparing instance of all types Key: FLINK-17698 URL: https://issues.apache.org/jira/browse/FLINK-17698 Project: Flink Issue Type: Bug

[GitHub] [flink] dawidwys commented on a change in pull request #12147: [FLINK-17653] FLIP-126: Unify (and separate) Watermark Assigners

2020-05-14 Thread GitBox
dawidwys commented on a change in pull request #12147: URL: https://github.com/apache/flink/pull/12147#discussion_r425197840 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java ## @@ -910,40 +930,25 @@ public

[jira] [Updated] (FLINK-17686) Add document to dataGen, print, blackhole connectors

2020-05-14 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-17686: - Affects Version/s: 1.11.0 > Add document to dataGen, print, blackhole connectors >

[jira] [Commented] (FLINK-17693) Add createTypeInformation to DynamicTableSink#Context

2020-05-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107375#comment-17107375 ] Jark Wu commented on FLINK-17693: - Hi [~ykt836], we already introduced this method in

[GitHub] [flink] flinkbot edited a comment on pull request #12130: [FLINK-17668][table] Fix shortcomings in new data structures

2020-05-14 Thread GitBox
flinkbot edited a comment on pull request #12130: URL: https://github.com/apache/flink/pull/12130#issuecomment-628151265 ## CI report: * 98c8478be10b5b927695eacafb581dfb0a5004f5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12132: [FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

2020-05-14 Thread GitBox
flinkbot edited a comment on pull request #12132: URL: https://github.com/apache/flink/pull/12132#issuecomment-628151415 ## CI report: * c4a7063174f4ee31dd5de5d6a3eed652e0ed95f7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12131: [FLINK-17161][docs][docker] Document the official docker hub image and examples of how to use it

2020-05-14 Thread GitBox
flinkbot edited a comment on pull request #12131: URL: https://github.com/apache/flink/pull/12131#issuecomment-628151351 ## CI report: * 531427273f179ba94af3397a354418ecac7d0d4f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12025: [FLINK-17435] [hive] Hive non-partitioned source supports streaming read

2020-05-14 Thread GitBox
flinkbot edited a comment on pull request #12025: URL: https://github.com/apache/flink/pull/12025#issuecomment-625292121 ## CI report: * 536fe9b624ee00e02522c57cb904a4c795d425c7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12110: [FLINK-17652][config] Legacy JM heap options should fallback to new JVM_HEAP_MEMORY in standalone

2020-05-14 Thread GitBox
flinkbot edited a comment on pull request #12110: URL: https://github.com/apache/flink/pull/12110#issuecomment-627830489 ## CI report: * 650972d1cce62e96571b1650b27f926a1e7613b9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12121: [FLINK-17222][table-common] Ensure deterministic field order in FieldsDataType

2020-05-14 Thread GitBox
flinkbot edited a comment on pull request #12121: URL: https://github.com/apache/flink/pull/12121#issuecomment-628150673 ## CI report: * 0158bb73250ede9a8494eb531c02c5d0b5eac565 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12092: [FLINK-17596][python] Move the Python UDF runner script out of the jar of flink-python

2020-05-14 Thread GitBox
flinkbot edited a comment on pull request #12092: URL: https://github.com/apache/flink/pull/12092#issuecomment-627157672 ## CI report: * a9c696fd00358fc2e142f0546524ce5d30d8f7e8 UNKNOWN * 93f0b4a7d77e6c8ad8597b90ba3c28bc8b68b660 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11814: [FLINK-17218][tests] Adding recoverable failures and correctness chec…

2020-05-14 Thread GitBox
flinkbot edited a comment on pull request #11814: URL: https://github.com/apache/flink/pull/11814#issuecomment-616347961 ## CI report: * 1e0c61b438830bd4d377ae16f7f8d2b1bc0ce047 UNKNOWN * 6abf4ce6e94c0b9d16370bc58381c4e4c3951267 UNKNOWN *

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

2020-05-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107367#comment-17107367 ] Robert Metzger commented on FLINK-16947:

[jira] [Created] (FLINK-17697) JDK11: JdbcFullTest.testEnrichedClassCastException: expected:<[java.lang.String cannot be cast to java.lang.Double], field index: 3, fi...> but was:<[class java.lang.Str

2020-05-14 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-17697: -- Summary: JDK11: JdbcFullTest.testEnrichedClassCastException: expected:<[java.lang.String cannot be cast to java.lang.Double], field index: 3, fi...> but was:<[class java.lang.String Key:

[GitHub] [flink] wuchong commented on pull request #12154: [FLINK-17693][table] Add createTypeInformation to DynamicTableSink#Contxt

2020-05-14 Thread GitBox
wuchong commented on pull request #12154: URL: https://github.com/apache/flink/pull/12154#issuecomment-628678359 Hi @twalthr , we can't support `copy()` for `RawValueData`. So `RowData.copy()` is a limited function. `TypeSerializer` is a more generel solution, and we can get

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

2020-05-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107361#comment-17107361 ] Robert Metzger commented on FLINK-16908: another instance

[jira] [Commented] (FLINK-12030) KafkaITCase.testMultipleSourcesOnePartition is unstable: This server does not host this topic-partition

2020-05-14 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107360#comment-17107360 ] Robert Metzger commented on FLINK-12030: Another case

[GitHub] [flink] TsReaper commented on pull request #12037: [FLINK-14807][runtime][client] Introduce communication through REST API between the clients and the operator coordinators

2020-05-14 Thread GitBox
TsReaper commented on pull request #12037: URL: https://github.com/apache/flink/pull/12037#issuecomment-628675695 @tillrohrmann @zentol I've rebased onto master and marked `ClientCoordinationHeaders` with `@ExcludeFromDocumentation`, please take another look. Thanks.

[GitHub] [flink] aljoscha commented on pull request #12136: [FLINK-17578][flink-streaming] Union of 2 SideOutputs behaviour incorrect

2020-05-14 Thread GitBox
aljoscha commented on pull request #12136: URL: https://github.com/apache/flink/pull/12136#issuecomment-628669248 Thanks a lot for this fix!  I merged This is an automated message from the Apache Git Service. To respond to

[jira] [Closed] (FLINK-17578) Union of 2 SideOutputs behaviour incorrect

2020-05-14 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17578. Fix Version/s: 1.10.2 1.11.0 Resolution: Fixed master:

[GitHub] [flink] flinkbot edited a comment on pull request #12154: [FLINK-17693][table] Add createTypeInformation to DynamicTableSink#Contxt

2020-05-14 Thread GitBox
flinkbot edited a comment on pull request #12154: URL: https://github.com/apache/flink/pull/12154#issuecomment-628652804 ## CI report: * b70730438a4981edc94f9161a3e2b1ab3481dbfe Azure:

[GitHub] [flink] aljoscha closed pull request #12136: [FLINK-17578][flink-streaming] Union of 2 SideOutputs behaviour incorrect

2020-05-14 Thread GitBox
aljoscha closed pull request #12136: URL: https://github.com/apache/flink/pull/12136 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

[GitHub] [flink] flinkbot edited a comment on pull request #12152: [FLINK-17149][debezium][canal] Introduce Debezium and Canal changelog format

2020-05-14 Thread GitBox
flinkbot edited a comment on pull request #12152: URL: https://github.com/apache/flink/pull/12152#issuecomment-628617951 ## CI report: * 81d1f17f7dad4bed004616df23aa37a0e700b96a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12144: [FLINK-17384][flink-dist] support read hbase conf dir from flink.conf.

2020-05-14 Thread GitBox
flinkbot edited a comment on pull request #12144: URL: https://github.com/apache/flink/pull/12144#issuecomment-628475376 ## CI report: * 5addfcff9eb59b5153e76627ed74e7255fe8b69b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12132: [FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

2020-05-14 Thread GitBox
flinkbot edited a comment on pull request #12132: URL: https://github.com/apache/flink/pull/12132#issuecomment-628151415 ## CI report: * c4a7063174f4ee31dd5de5d6a3eed652e0ed95f7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12121: [FLINK-17222][table-common] Ensure deterministic field order in FieldsDataType

2020-05-14 Thread GitBox
flinkbot edited a comment on pull request #12121: URL: https://github.com/apache/flink/pull/12121#issuecomment-628150673 ## CI report: * 0158bb73250ede9a8494eb531c02c5d0b5eac565 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12148: [FLINK-13811][python] Support converting flink Table to pandas DataFrame

2020-05-14 Thread GitBox
flinkbot edited a comment on pull request #12148: URL: https://github.com/apache/flink/pull/12148#issuecomment-628530225 ## CI report: * 634970c61d1579a1456f36d9374230f5b93098c2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12131: [FLINK-17161][docs][docker] Document the official docker hub image and examples of how to use it

2020-05-14 Thread GitBox
flinkbot edited a comment on pull request #12131: URL: https://github.com/apache/flink/pull/12131#issuecomment-628151351 ## CI report: * 531427273f179ba94af3397a354418ecac7d0d4f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12110: [FLINK-17652][config] Legacy JM heap options should fallback to new JVM_HEAP_MEMORY in standalone

2020-05-14 Thread GitBox
flinkbot edited a comment on pull request #12110: URL: https://github.com/apache/flink/pull/12110#issuecomment-627830489 ## CI report: * 650972d1cce62e96571b1650b27f926a1e7613b9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12069: [FLINK-14807][streaming] Add specialized collecting sink function

2020-05-14 Thread GitBox
flinkbot edited a comment on pull request #12069: URL: https://github.com/apache/flink/pull/12069#issuecomment-626515528 ## CI report: * 2af1ec04f8659cc749ba61efdb103342d44f2c96 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12025: [FLINK-17435] [hive] Hive non-partitioned source supports streaming read

2020-05-14 Thread GitBox
flinkbot edited a comment on pull request #12025: URL: https://github.com/apache/flink/pull/12025#issuecomment-625292121 ## CI report: * 536fe9b624ee00e02522c57cb904a4c795d425c7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11814: [FLINK-17218][tests] Adding recoverable failures and correctness chec…

2020-05-14 Thread GitBox
flinkbot edited a comment on pull request #11814: URL: https://github.com/apache/flink/pull/11814#issuecomment-616347961 ## CI report: * 1e0c61b438830bd4d377ae16f7f8d2b1bc0ce047 UNKNOWN * 6abf4ce6e94c0b9d16370bc58381c4e4c3951267 UNKNOWN *

[jira] [Commented] (FLINK-17487) Do not delete old checkpoints when stop the job.

2020-05-14 Thread nobleyd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107341#comment-17107341 ] nobleyd commented on FLINK-17487: - [~rmetzger] No, if I cancel the job, the checkpoints will be retained

[GitHub] [flink] pnowojski commented on pull request #11948: [FLINK-17467] Align channels on savepoint in UC mode

2020-05-14 Thread GitBox
pnowojski commented on pull request #11948: URL: https://github.com/apache/flink/pull/11948#issuecomment-628664949 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Closed] (FLINK-16383) KafkaProducerExactlyOnceITCase. testExactlyOnceRegularSink fails with "The producer has already been closed"

2020-05-14 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-16383. Assignee: Aljoscha Krettek Resolution: Fixed I added a potential fix on master in

[GitHub] [flink] aljoscha commented on pull request #12151: [FLINK-16383] Set close = true in monitor/lock scope in KafkaProducer

2020-05-14 Thread GitBox
aljoscha commented on pull request #12151: URL: https://github.com/apache/flink/pull/12151#issuecomment-628664053 Thanks for the swift reviews! This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] aljoscha closed pull request #12151: [FLINK-16383] Set close = true in monitor/lock scope in KafkaProducer

2020-05-14 Thread GitBox
aljoscha closed pull request #12151: URL: https://github.com/apache/flink/pull/12151 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] [Assigned] (FLINK-17680) Support @ExcludeFromDocumentation in RestAPIDocGenerator

2020-05-14 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-17680: - Assignee: Caizhi Weng > Support @ExcludeFromDocumentation in RestAPIDocGenerator >

[jira] [Resolved] (FLINK-17680) Support @ExcludeFromDocumentation in RestAPIDocGenerator

2020-05-14 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-17680. --- Resolution: Fixed Fixed via f8fe4a462a1dbed6a1567df28d2c0386a79f880f > Support

[GitHub] [flink] tillrohrmann commented on pull request #12037: [FLINK-14807][runtime][client] Introduce communication through REST API between the clients and the operator coordinators

2020-05-14 Thread GitBox
tillrohrmann commented on pull request #12037: URL: https://github.com/apache/flink/pull/12037#issuecomment-628663314 @TsReaper I have merged #12141. You could now rebase this PR on the current master and add the `@ExcludeFromDocumentation` annotation.

[GitHub] [flink-statefun] igalshilman commented on a change in pull request #108: [FLINK-17516] [e2e] Exactly-once verification E2E

2020-05-14 Thread GitBox
igalshilman commented on a change in pull request #108: URL: https://github.com/apache/flink-statefun/pull/108#discussion_r425158368 ## File path: statefun-e2e-tests/statefun-exactly-once-e2e/src/test/resources/wrapped-messages-ingress-module/module.yaml ## @@ -0,0 +1,36 @@

[GitHub] [flink] tillrohrmann closed pull request #12141: [FLINK-17680][docs] Support @ExcludeFromDocumentation when generating REST API documentations

2020-05-14 Thread GitBox
tillrohrmann closed pull request #12141: URL: https://github.com/apache/flink/pull/12141 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

[jira] [Commented] (FLINK-17493) Possible direct memory leak in cassandra sink

2020-05-14 Thread nobleyd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107331#comment-17107331 ] nobleyd commented on FLINK-17493: - [~xintongsong], I readjusted the affected version, which was

[jira] [Closed] (FLINK-16178) Prerequisite cleanups and refactorings in the Checkpoint Coordinator

2020-05-14 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-16178. > Prerequisite cleanups and refactorings in the Checkpoint Coordinator >

[jira] [Closed] (FLINK-17303) Return TableResult for Python TableEnvironment

2020-05-14 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-17303. --- Resolution: Resolved > Return TableResult for Python TableEnvironment >

[jira] [Resolved] (FLINK-16178) Prerequisite cleanups and refactorings in the Checkpoint Coordinator

2020-05-14 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-16178. -- Resolution: Fixed > Prerequisite cleanups and refactorings in the Checkpoint Coordinator >

[jira] [Comment Edited] (FLINK-16178) Prerequisite cleanups and refactorings in the Checkpoint Coordinator

2020-05-14 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17044983#comment-17044983 ] Stephan Ewen edited comment on FLINK-16178 at 5/14/20, 2:07 PM: Fixed in

[jira] [Commented] (FLINK-17303) Return TableResult for Python TableEnvironment

2020-05-14 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107326#comment-17107326 ] Hequn Cheng commented on FLINK-17303: - Resolved in 1.11.0 via

[GitHub] [flink] hequn8128 closed pull request #12009: [FLINK-17303][python]Return TableResult for Python TableEnvironment

2020-05-14 Thread GitBox
hequn8128 closed pull request #12009: URL: https://github.com/apache/flink/pull/12009 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-17696) Support eager initialization of operators with OperatorEventDispatcher

2020-05-14 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-17696: Summary: Support eager initialization of operators with OperatorEventDispatcher Key: FLINK-17696 URL: https://issues.apache.org/jira/browse/FLINK-17696 Project:

[GitHub] [flink] KurtYoung commented on a change in pull request #12069: [FLINK-14807][streaming] Add specialized collecting sink function

2020-05-14 Thread GitBox
KurtYoung commented on a change in pull request #12069: URL: https://github.com/apache/flink/pull/12069#discussion_r425160259 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkFunction.java ## @@ -0,0 +1,381 @@ +/* +

[jira] [Updated] (FLINK-17493) Possible direct memory leak in cassandra sink

2020-05-14 Thread nobleyd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nobleyd updated FLINK-17493: Attachment: image-2020-05-14-21-58-59-152.png > Possible direct memory leak in cassandra sink >

[jira] [Created] (FLINK-17695) Simplify SourceOperator by using a utility SimpleVersionedListState

2020-05-14 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-17695: Summary: Simplify SourceOperator by using a utility SimpleVersionedListState Key: FLINK-17695 URL: https://issues.apache.org/jira/browse/FLINK-17695 Project: Flink

[GitHub] [flink] guoweiM commented on pull request #12132: [FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

2020-05-14 Thread GitBox
guoweiM commented on pull request #12132: URL: https://github.com/apache/flink/pull/12132#issuecomment-628654263 Thanks for your reminding. I would update pr latter today. This is an automated message from the Apache Git

[GitHub] [flink] azagrebin commented on pull request #12110: [FLINK-17652][config] Legacy JM heap options should fallback to new JVM_HEAP_MEMORY in standalone

2020-05-14 Thread GitBox
azagrebin commented on pull request #12110: URL: https://github.com/apache/flink/pull/12110#issuecomment-628654517 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-17493) Possible direct memory leak in cassandra sink

2020-05-14 Thread nobleyd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nobleyd updated FLINK-17493: Affects Version/s: (was: 1.9.3) 1.9.0 > Possible direct memory leak in

[GitHub] [flink] flinkbot edited a comment on pull request #12131: [FLINK-17161][docs][docker] Document the official docker hub image and examples of how to use it

2020-05-14 Thread GitBox
flinkbot edited a comment on pull request #12131: URL: https://github.com/apache/flink/pull/12131#issuecomment-628151351 ## CI report: * 531427273f179ba94af3397a354418ecac7d0d4f Azure:

[jira] [Commented] (FLINK-17693) Add createTypeInformation to DynamicTableSink#Context

2020-05-14 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107316#comment-17107316 ] Kurt Young commented on FLINK-17693: TypeInformation will cause some confuse for table users. It's

[GitHub] [flink] flinkbot commented on pull request #12154: [FLINK-17693][table] Add createTypeInformation to DynamicTableSink#Contxt

2020-05-14 Thread GitBox
flinkbot commented on pull request #12154: URL: https://github.com/apache/flink/pull/12154#issuecomment-628652804 ## CI report: * b70730438a4981edc94f9161a3e2b1ab3481dbfe UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Created] (FLINK-17694) Wrong min-length check in SimpleVersionedSerialization

2020-05-14 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-17694: Summary: Wrong min-length check in SimpleVersionedSerialization Key: FLINK-17694 URL: https://issues.apache.org/jira/browse/FLINK-17694 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #12151: [FLINK-16383] Set close = true in monitor/lock scope in KafkaProducer

2020-05-14 Thread GitBox
flinkbot edited a comment on pull request #12151: URL: https://github.com/apache/flink/pull/12151#issuecomment-628604664 ## CI report: * c38ce628f6d041da0daa96d2faa881df60caef35 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12148: [FLINK-13811][python] Support converting flink Table to pandas DataFrame

2020-05-14 Thread GitBox
flinkbot edited a comment on pull request #12148: URL: https://github.com/apache/flink/pull/12148#issuecomment-628530225 ## CI report: * 634970c61d1579a1456f36d9374230f5b93098c2 Azure:

[GitHub] [flink] tillrohrmann commented on a change in pull request #12141: [FLINK-17680][docs] Support @ExcludeFromDocumentation when generating REST API documentations

2020-05-14 Thread GitBox
tillrohrmann commented on a change in pull request #12141: URL: https://github.com/apache/flink/pull/12141#discussion_r425153435 ## File path: flink-docs/src/test/java/org/apache/flink/docs/rest/RestAPIDocGeneratorTest.java ## @@ -0,0 +1,87 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #12119: [FLINK-17649][table-planner-blink] Generated hash aggregate code may …

2020-05-14 Thread GitBox
flinkbot edited a comment on pull request #12119: URL: https://github.com/apache/flink/pull/12119#issuecomment-628150518 ## CI report: * 13962fa6930cf29f65ab11a368660f95ff4f29bc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12130: [FLINK-17668][table] Fix shortcomings in new data structures

2020-05-14 Thread GitBox
flinkbot edited a comment on pull request #12130: URL: https://github.com/apache/flink/pull/12130#issuecomment-628151265 ## CI report: * 3ce911785950f69b2ab7d6b1f74352cdc962cd94 Azure:

[jira] [Commented] (FLINK-17693) Add createTypeInformation to DynamicTableSink#Context

2020-05-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107314#comment-17107314 ] Jark Wu commented on FLINK-17693: - [~ykt836], returning a TypeInformation is more flexible.

[jira] [Comment Edited] (FLINK-17693) Add createTypeInformation to DynamicTableSink#Context

2020-05-14 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107314#comment-17107314 ] Jark Wu edited comment on FLINK-17693 at 5/14/20, 1:52 PM: --- [~ykt836],

[GitHub] [flink] flinkbot edited a comment on pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

2020-05-14 Thread GitBox
flinkbot edited a comment on pull request #11877: URL: https://github.com/apache/flink/pull/11877#issuecomment-618273998 ## CI report: * ae90bc7d6d3753da3e9bbadcc99c80a152801e43 Azure:

[GitHub] [flink] TsReaper commented on a change in pull request #12069: [FLINK-14807][streaming] Add specialized collecting sink function

2020-05-14 Thread GitBox
TsReaper commented on a change in pull request #12069: URL: https://github.com/apache/flink/pull/12069#discussion_r425153205 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkFunction.java ## @@ -0,0 +1,381 @@ +/* + *

[jira] [Commented] (FLINK-17645) REAPER_THREAD.start() in SafetyNetCloseableRegistry failed, causing the repeated failover.

2020-05-14 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107313#comment-17107313 ] Stephan Ewen commented on FLINK-17645: -- What are we gaining by special case handling the reaper

[jira] [Closed] (FLINK-15138) Add e2e Test for PyFlink

2020-05-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-15138. --- Resolution: Resolved Merged to master via b51101bdeb1d7052d0a89ee51c9342aeed5bd153 > Add e2e Test for

[GitHub] [flink] zhengcanbin edited a comment on pull request #12105: [FLINK-16624][k8s] Support user-specified annotations for the rest Service

2020-05-14 Thread GitBox
zhengcanbin edited a comment on pull request #12105: URL: https://github.com/apache/flink/pull/12105#issuecomment-628639728 @TisonKun Could you help review this PR? This is an automated message from the Apache Git Service.

[GitHub] [flink] azagrebin commented on pull request #12131: [FLINK-17161][docs][docker] Document the official docker hub image and examples of how to use it

2020-05-14 Thread GitBox
azagrebin commented on pull request #12131: URL: https://github.com/apache/flink/pull/12131#issuecomment-628647297 Thanks for the review @zentol , I addressed the current comments. Yes, I will copy English files to the Chinese at the end.

[jira] [Assigned] (FLINK-15138) Add e2e Test for PyFlink

2020-05-14 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-15138: --- Assignee: Wei Zhong > Add e2e Test for PyFlink > > > Key:

[GitHub] [flink] dianfu closed pull request #12104: [FLINK-15138][e2e][python] Add PyFlink e2e tests.

2020-05-14 Thread GitBox
dianfu closed pull request #12104: URL: https://github.com/apache/flink/pull/12104 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] azagrebin commented on a change in pull request #12131: [FLINK-17161][docs][docker] Document the official docker hub image and examples of how to use it

2020-05-14 Thread GitBox
azagrebin commented on a change in pull request #12131: URL: https://github.com/apache/flink/pull/12131#discussion_r425147269 ## File path: docs/ops/deployment/docker.md ## @@ -24,119 +24,476 @@ under the License. --> [Docker](https://www.docker.com) is a popular container

[GitHub] [flink] morsapaes commented on a change in pull request #12057: [FLINK-16210][docs] Extending the "Flink Architecture" section.

2020-05-14 Thread GitBox
morsapaes commented on a change in pull request #12057: URL: https://github.com/apache/flink/pull/12057#discussion_r425146659 ## File path: docs/concepts/flink-architecture.md ## @@ -129,4 +167,108 @@ two main benefits: +## Flink Application Execution + +A _Flink

[jira] [Comment Edited] (FLINK-17565) Bump fabric8 version from 4.5.2 to 4.9.1

2020-05-14 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104007#comment-17104007 ] Canbin Zheng edited comment on FLINK-17565 at 5/14/20, 1:42 PM: Hi

[GitHub] [flink] dawidwys commented on a change in pull request #12147: [FLINK-17653] FLIP-126: Unify (and separate) Watermark Assigners

2020-05-14 Thread GitBox
dawidwys commented on a change in pull request #12147: URL: https://github.com/apache/flink/pull/12147#discussion_r425145921 ## File path: flink-core/src/test/java/org/apache/flink/api/common/eventtime/WatermarkMatchers.java ## @@ -0,0 +1,68 @@ +/* + * Licensed to the Apache

[GitHub] [flink] azagrebin commented on a change in pull request #12131: [FLINK-17161][docs][docker] Document the official docker hub image and examples of how to use it

2020-05-14 Thread GitBox
azagrebin commented on a change in pull request #12131: URL: https://github.com/apache/flink/pull/12131#discussion_r425144968 ## File path: docs/ops/deployment/docker.md ## @@ -24,119 +24,476 @@ under the License. --> [Docker](https://www.docker.com) is a popular container

[GitHub] [flink] flinkbot commented on pull request #12154: [FLINK-17693][table] Add createTypeInformation to DynamicTableSink#Contxt

2020-05-14 Thread GitBox
flinkbot commented on pull request #12154: URL: https://github.com/apache/flink/pull/12154#issuecomment-628641286 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-16624) Support user-specified annotations for the rest Service

2020-05-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16624: --- Labels: pull-request-available (was: ) > Support user-specified annotations for the rest

[GitHub] [flink] zhengcanbin commented on pull request #12105: [FLINK-16624][k8s] Support user-specified annotations for the rest Service

2020-05-14 Thread GitBox
zhengcanbin commented on pull request #12105: URL: https://github.com/apache/flink/pull/12105#issuecomment-628639728 @TisonKun @tillrohrmann @wangyang0918 Could you help review this PR? This is an automated message from the

[jira] [Commented] (FLINK-17196) Improve the implementation of Fabric8FlinkKubeClient#getRestEndpoint

2020-05-14 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107300#comment-17107300 ] Canbin Zheng commented on FLINK-17196: -- Yes [~fly_in_gis]. Hi, [~trohrmann], could you help assign

[jira] [Updated] (FLINK-17693) Add createTypeInformation to DynamicTableSink#Context

2020-05-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17693: --- Labels: pull-request-available (was: ) > Add createTypeInformation to

[jira] [Commented] (FLINK-17693) Add createTypeInformation to DynamicTableSink#Context

2020-05-14 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107299#comment-17107299 ] Kurt Young commented on FLINK-17693: isn't TypeSerializer enough? > Add createTypeInformation to

[GitHub] [flink-web] yangjf2019 commented on a change in pull request #268: [FLINK-13343][docs-zh] Translate "Contribute Code" page into Chinese

2020-05-14 Thread GitBox
yangjf2019 commented on a change in pull request #268: URL: https://github.com/apache/flink-web/pull/268#discussion_r425139109 ## File path: contributing/contribute-code.zh.md ## @@ -2,17 +2,17 @@ title: "贡献代码" --- -Apache Flink is maintained, improved, and extended by

[GitHub] [flink] wuchong opened a new pull request #12154: [FLINK-17693][table] Add createTypeInformation to DynamicTableSink#Contxt

2020-05-14 Thread GitBox
wuchong opened a new pull request #12154: URL: https://github.com/apache/flink/pull/12154 ## What is the purpose of the change Currently, we have `createTypeInformation` on `DynamicTableSource#Context`, but not on `DynamicTableSink#Context`. In some sink connectors,

[GitHub] [flink] aljoscha commented on a change in pull request #12151: [FLINK-16383] Set close = true in monitor/lock scope in KafkaProducer

2020-05-14 Thread GitBox
aljoscha commented on a change in pull request #12151: URL: https://github.com/apache/flink/pull/12151#discussion_r425137936 ## File path: flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/FlinkKafkaProducer.java ##

[GitHub] [flink] asfgit closed pull request #12111: [hotfix][test] Disable Google PubSub Emulator e2e test on aarch64

2020-05-14 Thread GitBox
asfgit closed pull request #12111: URL: https://github.com/apache/flink/pull/12111 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] asfgit closed pull request #12083: [hotfix][runtime] Remove useless class ZooKeeperCompletedCheckpointStoreITCase#HeapStateStorageHelper

2020-05-14 Thread GitBox
asfgit closed pull request #12083: URL: https://github.com/apache/flink/pull/12083 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] asfgit closed pull request #12068: [hotfix][typo]Fix typo in task_lifecycle docs

2020-05-14 Thread GitBox
asfgit closed pull request #12068: URL: https://github.com/apache/flink/pull/12068 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

<    1   2   3   4   5   6   7   8   9   10   >