[jira] [Commented] (FLINK-17027) Introduce a new Elasticsearch connector with new property keys

[ https://issues.apache.org/jira/browse/FLINK-17027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17097831#comment-17097831 ] Jark Wu commented on FLINK-17027: - Hi [~molsion], this issue is still blocked by FLIP-95. > Introduce a

[jira] [Commented] (FLINK-17028) Introduce a new HBase connector with new property keys

[ https://issues.apache.org/jira/browse/FLINK-17028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17097830#comment-17097830 ] Jark Wu commented on FLINK-17028: - Hi [~molsion], this issue is still blocked by FLIP-95. > Introduce a

[GitHub] [flink] flinkbot edited a comment on pull request #11974: [FLINK-16970][build][metrics]Bundle JMXReporter separately from dist …

flinkbot edited a comment on pull request #11974: URL: https://github.com/apache/flink/pull/11974#issuecomment-622652948 ## CI report: * 4261809a08f0cfb516ea52db15de27f154b3ad73 Azure:

[jira] [Commented] (FLINK-12675) Event time synchronization in Kafka consumer

[ https://issues.apache.org/jira/browse/FLINK-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17097822#comment-17097822 ] Akshay Aggarwal commented on FLINK-12675: - Thanks [~thw]. I've raised a PR, can someone help

[jira] [Commented] (FLINK-17027) Introduce a new Elasticsearch connector with new property keys

[ https://issues.apache.org/jira/browse/FLINK-17027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17097813#comment-17097813 ] molsion mo commented on FLINK-17027: i want to take this task if no one work for it. > Introduce a

[GitHub] [flink] flinkbot edited a comment on pull request #11975: [FLINK-17496][kinesis] Upgrade amazon-kinesis-producer to 0.14.0

flinkbot edited a comment on pull request #11975: URL: https://github.com/apache/flink/pull/11975#issuecomment-622662116 ## CI report: * 89d8665ddbcdd11cff8652f39fea4d0601f809ac Azure:

[jira] [Commented] (FLINK-17028) Introduce a new HBase connector with new property keys

[ https://issues.apache.org/jira/browse/FLINK-17028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17097803#comment-17097803 ] molsion mo commented on FLINK-17028: I have read and understood FLIP-95 and i was contributor in

[GitHub] [flink] flinkbot commented on pull request #11975: [FLINK-17496][kinesis] Upgrade amazon-kinesis-producer to 0.14.0

flinkbot commented on pull request #11975: URL: https://github.com/apache/flink/pull/11975#issuecomment-622662116 ## CI report: * 89d8665ddbcdd11cff8652f39fea4d0601f809ac UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #11975: [FLINK-17496][kinesis] Upgrade amazon-kinesis-producer to 0.14.0

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

[GitHub] [flink] tweise opened a new pull request #11975: [FLINK-17496][kinesis] Upgrade amazon-kinesis-producer to 0.14.0

tweise opened a new pull request #11975: URL: https://github.com/apache/flink/pull/11975 ## What is the purpose of the change Kinesis producer 0.13.1 introduced a performance regression that can be addressed with the upgrade to 0.14.0 ## Verifying this change The

[jira] [Updated] (FLINK-17496) Performance regression with amazon-kinesis-producer 0.13.1 in Flink 1.10.x

[ https://issues.apache.org/jira/browse/FLINK-17496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17496: --- Labels: pull-request-available (was: ) > Performance regression with

[jira] [Created] (FLINK-17496) Performance regression with amazon-kinesis-producer 0.13.1 in Flink 1.10.x

Thomas Weise created FLINK-17496: Summary: Performance regression with amazon-kinesis-producer 0.13.1 in Flink 1.10.x Key: FLINK-17496 URL: https://issues.apache.org/jira/browse/FLINK-17496 Project:

[GitHub] [flink] flinkbot edited a comment on pull request #11974: [FLINK-16970][build][metrics]Bundle JMXReporter separately from dist …

flinkbot edited a comment on pull request #11974: URL: https://github.com/apache/flink/pull/11974#issuecomment-622652948 ## CI report: * 4261809a08f0cfb516ea52db15de27f154b3ad73 Azure:

[GitHub] [flink] flinkbot commented on pull request #11974: [FLINK-16970][build][metrics]Bundle JMXReporter separately from dist …

flinkbot commented on pull request #11974: URL: https://github.com/apache/flink/pull/11974#issuecomment-622652948 ## CI report: * 4261809a08f0cfb516ea52db15de27f154b3ad73 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] wanglijie95 commented on pull request #11499: [FLINK-16681][Connectors/JDBC]Jdbc JDBCOutputFormat and JDBCLookupFunction PreparedStatement loss connection, if long time not records to

wanglijie95 commented on pull request #11499: URL: https://github.com/apache/flink/pull/11499#issuecomment-622651532 @LakeShen Hi LakeShen, flink release 1.11 will enter the code freeze period on May 15. Maybe you can finish this PR before May 15 and merge to 1.11 .

[GitHub] [flink] flinkbot commented on pull request #11974: [FLINK-16970][build][metrics]Bundle JMXReporter separately from dist …

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

[GitHub] [flink] molsionmo opened a new pull request #11974: [FLINK-16970][build][metrics]Bundle JMXReporter separately from dist …

molsionmo opened a new pull request #11974: URL: https://github.com/apache/flink/pull/11974 ## What is the purpose of the change *Bundle JMXReporter separately from dist jar,and put it in folder /opt* ## Verifying this change This change is a trivial rework /

[GitHub] [flink] flinkbot edited a comment on pull request #11963: [FLINK-16408] Bind user code class loader to lifetime of Job on TaskExecutor

flinkbot edited a comment on pull request #11963: URL: https://github.com/apache/flink/pull/11963#issuecomment-621969588 ## CI report: * e07ec1bd9c216cdac0ac4faa79bc5509ab4129b6 UNKNOWN * 994fb5984ec6312126d76b75206d0023e8ae4212 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11973: [FLINK-17488] Now JdbcConnectionOptions supports autoCommit control

flinkbot edited a comment on pull request #11973: URL: https://github.com/apache/flink/pull/11973#issuecomment-622555129 ## CI report: * ccb23fef7822524883d71a604d4ef9e673307bc7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11963: [FLINK-16408] Bind user code class loader to lifetime of Job on TaskExecutor

flinkbot edited a comment on pull request #11963: URL: https://github.com/apache/flink/pull/11963#issuecomment-621969588 ## CI report: * e07ec1bd9c216cdac0ac4faa79bc5509ab4129b6 UNKNOWN * 7401f5580774397bd121736b1068f03009a2d980 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11963: [FLINK-16408] Bind user code class loader to lifetime of Job on TaskExecutor

flinkbot edited a comment on pull request #11963: URL: https://github.com/apache/flink/pull/11963#issuecomment-621969588 ## CI report: * e07ec1bd9c216cdac0ac4faa79bc5509ab4129b6 UNKNOWN * 7401f5580774397bd121736b1068f03009a2d980 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11971: [FLINK-17271] Translate new DataStream API tutorial

flinkbot edited a comment on pull request #11971: URL: https://github.com/apache/flink/pull/11971#issuecomment-622521983 ## CI report: * f4082786bad837955dea7f68fce466c6b7719912 Azure:

[jira] [Commented] (FLINK-16478) add restApi to modify loglevel

[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17097714#comment-17097714 ] Xingxing Di commented on FLINK-16478: - {quote}In general I think such a feature would be helpful for

[jira] [Commented] (FLINK-10672) Task stuck while writing output to flink

[ https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17097696#comment-17097696 ] Kyle Weaver commented on FLINK-10672: - Hi Yun, sorry I haven't had much time to look at this lately.

[GitHub] [flink] edu05 commented on pull request #11952: [FLINK-16638][runtime][checkpointing] Flink checkStateMappingCompleteness doesn't include UserDefinedOperatorIDs

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

[GitHub] [flink] flinkbot edited a comment on pull request #11973: [FLINK-17488] Now JdbcConnectionOptions supports autoCommit control

flinkbot edited a comment on pull request #11973: URL: https://github.com/apache/flink/pull/11973#issuecomment-622555129 ## CI report: * ccb23fef7822524883d71a604d4ef9e673307bc7 Azure:

[GitHub] [flink] flinkbot commented on pull request #11973: [FLINK-17488] Now JdbcConnectionOptions supports autoCommit control

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

[GitHub] [flink] flinkbot commented on pull request #11973: [FLINK-17488] Now JdbcConnectionOptions supports autoCommit control

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

[GitHub] [flink] pavel-hp opened a new pull request #11973: [FLINK-17488] Now JdbcConnectionOptions supports autoCommit control

pavel-hp opened a new pull request #11973: URL: https://github.com/apache/flink/pull/11973 - Now JdbcConnectionOptions supports autoCommit control Default behaviour hasn't changed. - Added logging information to be able to track batches ## What is the purpose of the

[jira] [Updated] (FLINK-17488) JdbcSink has to support setting autoCommit mode of DB

[ https://issues.apache.org/jira/browse/FLINK-17488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17488: --- Labels: pull-request-available (was: ) > JdbcSink has to support setting autoCommit mode

[GitHub] [flink] flinkbot edited a comment on pull request #11972: [FLINK-17058] Adding ProcessingTimeoutTrigger of nested triggers.

flinkbot edited a comment on pull request #11972: URL: https://github.com/apache/flink/pull/11972#issuecomment-622529341 ## CI report: * c06b5ebbdbe753d44ce2111dfde996ff9e0868f5 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/163266345) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11971: [FLINK-17271] Translate new DataStream API tutorial

flinkbot edited a comment on pull request #11971: URL: https://github.com/apache/flink/pull/11971#issuecomment-622521983 ## CI report: * f4082786bad837955dea7f68fce466c6b7719912 Azure:

[GitHub] [flink] flinkbot commented on pull request #11972: [FLINK-17058] Adding ProcessingTimeoutTrigger of nested triggers.

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

[jira] [Commented] (FLINK-17058) Adding TimeoutTrigger support nested triggers

[ https://issues.apache.org/jira/browse/FLINK-17058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17097624#comment-17097624 ] Roey Shem Tov commented on FLINK-17058: --- [~aljoscha] sorry for late response, took me a while to

[jira] [Updated] (FLINK-17289) Translate tutorials/etl.md to chinese

[ https://issues.apache.org/jira/browse/FLINK-17289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-17289: --- Description: This is one of the new tutorials, and it needs translation. The file is

[jira] [Updated] (FLINK-17291) Translate tutorial on event-driven applications to chinese

[ https://issues.apache.org/jira/browse/FLINK-17291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-17291: --- Description: Translate docs/training/event_driven.zh.md to Chinese. (was: Translate

[jira] [Updated] (FLINK-17271) Translate new DataStream API tutorial

[ https://issues.apache.org/jira/browse/FLINK-17271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-17271: --- Description: docs/training/datastream_api.zh.md needs to be translated. (was:

[jira] [Updated] (FLINK-17290) Translate Streaming Analytics tutorial to chinese

[ https://issues.apache.org/jira/browse/FLINK-17290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-17290: --- Description: The file to be translated is docs/training/streaming-analytics.zh.md. The

[jira] [Updated] (FLINK-17292) Translate Fault Tolerance tutorial to Chinese

[ https://issues.apache.org/jira/browse/FLINK-17292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-17292: --- Description: This ticket is about translating the new tutorial in

[jira] [Commented] (FLINK-17292) Translate Fault Tolerance tutorial to Chinese

[ https://issues.apache.org/jira/browse/FLINK-17292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17097618#comment-17097618 ] David Anderson commented on FLINK-17292: Yes, [~xbaith], that's right. > Translate Fault

[GitHub] [flink] flinkbot commented on pull request #11972: [FLINK-17058] Adding ProcessingTimeoutTrigger of nested triggers.

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

[GitHub] [flink] flinkbot commented on pull request #11971: [FLINK-17271] Translate new DataStream API tutorial

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

[GitHub] [flink] flinkbot edited a comment on pull request #11952: [FLINK-16638][runtime][checkpointing] Flink checkStateMappingCompleteness doesn't include UserDefinedOperatorIDs

flinkbot edited a comment on pull request #11952: URL: https://github.com/apache/flink/pull/11952#issuecomment-621589853 ## CI report: * 2113227fdc0076eb9e2f72ae7883c2d5d245cbab Azure:

[GitHub] [flink] roeyshemtov opened a new pull request #11972: [FLINK-17058] Adding ProcessingTimeoutTrigger of nested triggers.

roeyshemtov opened a new pull request #11972: URL: https://github.com/apache/flink/pull/11972 ## What is the purpose of the change Adding new feature of ProcessingTimeoutTrigger as mention in FLINK-17058 jira page. ## Verifying this change Adding UnitTests to the new code.

[jira] [Comment Edited] (FLINK-17292) Translate Fault Tolerance tutorial to Chinese

[ https://issues.apache.org/jira/browse/FLINK-17292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17097611#comment-17097611 ] Bai Xu edited comment on FLINK-17292 at 5/1/20, 7:02 PM: - Hi [~alpinegizmo].It's

[jira] [Commented] (FLINK-17292) Translate Fault Tolerance tutorial to Chinese

[ https://issues.apache.org/jira/browse/FLINK-17292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17097611#comment-17097611 ] Bai Xu commented on FLINK-17292: Hi [~alpinegizmo].It's me again.Let me drive this simple ticket. And 

[jira] [Updated] (FLINK-17058) Adding TimeoutTrigger support nested triggers

[ https://issues.apache.org/jira/browse/FLINK-17058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17058: --- Labels: pull-request-available (was: ) > Adding TimeoutTrigger support nested triggers >

[jira] [Comment Edited] (FLINK-17271) Translate new DataStream API tutorial

[ https://issues.apache.org/jira/browse/FLINK-17271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17097585#comment-17097585 ] Bai Xu edited comment on FLINK-17271 at 5/1/20, 6:39 PM: - [~alpinegizmo] Thanks

[jira] [Commented] (FLINK-17404) Running HA per-job cluster (rocks, non-incremental) gets stuck killing a non-existing pid

[ https://issues.apache.org/jira/browse/FLINK-17404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17097587#comment-17097587 ] Kostas Kloudas commented on FLINK-17404: Thanks [~rmetzger] > Running HA per-job cluster

[jira] [Commented] (FLINK-17271) Translate new DataStream API tutorial

[ https://issues.apache.org/jira/browse/FLINK-17271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17097585#comment-17097585 ] Bai Xu commented on FLINK-17271: [~alpinegizmo] Thanks for your patient! I have finshed this

[GitHub] [flink] flinkbot commented on pull request #11971: [FLINK-17271] Translate new DataStream API tutorial

flinkbot commented on pull request #11971: URL: https://github.com/apache/flink/pull/11971#issuecomment-622508565 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-17271) Translate new DataStream API tutorial

[ https://issues.apache.org/jira/browse/FLINK-17271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17271: --- Labels: pull-request-available (was: ) > Translate new DataStream API tutorial >

[GitHub] [flink] XBaith opened a new pull request #11971: [FLINK-17271] Translate new DataStream API tutorial

XBaith opened a new pull request #11971: URL: https://github.com/apache/flink/pull/11971 ## What is the purpose of the change *This pull request translates new "DataStream API tutorial" page into Chinese.* ## Verifying this change *This change is a docs work without

[GitHub] [flink] flinkbot edited a comment on pull request #11952: [FLINK-16638][runtime][checkpointing] Flink checkStateMappingCompleteness doesn't include UserDefinedOperatorIDs

flinkbot edited a comment on pull request #11952: URL: https://github.com/apache/flink/pull/11952#issuecomment-621589853 ## CI report: * cb00ba58dee155aceb27bd4b8bab837a77265699 Azure:

[jira] [Assigned] (FLINK-17271) Translate new DataStream API tutorial

[ https://issues.apache.org/jira/browse/FLINK-17271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson reassigned FLINK-17271: -- Assignee: Bai Xu > Translate new DataStream API tutorial >

[GitHub] [flink] flinkbot edited a comment on pull request #11936: [FLINK-17386][Security][hotfix] fix LinkageError not captured

flinkbot edited a comment on pull request #11936: URL: https://github.com/apache/flink/pull/11936#issuecomment-620683562 ## CI report: * a02867a0bce8f1a0174a6a3133b50b76167dbcc9 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/163208458) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11952: [FLINK-16638][runtime][checkpointing] Flink checkStateMappingCompleteness doesn't include UserDefinedOperatorIDs

flinkbot edited a comment on pull request #11952: URL: https://github.com/apache/flink/pull/11952#issuecomment-621589853 ## CI report: * cb00ba58dee155aceb27bd4b8bab837a77265699 Azure:

[GitHub] [flink] edu05 commented on pull request #11952: [FLINK-16638][runtime][checkpointing] Flink checkStateMappingCompleteness doesn't include UserDefinedOperatorIDs

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

[jira] [Updated] (FLINK-17488) JdbcSink has to support setting autoCommit mode of DB

[ https://issues.apache.org/jira/browse/FLINK-17488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Khokhlov Pavel updated FLINK-17488: --- Priority: Major (was: Critical) > JdbcSink has to support setting autoCommit mode of DB >

[GitHub] [flink] flinkbot edited a comment on pull request #11844: [FLINK-17125][python][doc] Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

flinkbot edited a comment on pull request #11844: URL: https://github.com/apache/flink/pull/11844#issuecomment-617177959 ## CI report: * 135e33f23db360cbb1b4cbc4870e7640e78241cf Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/163211195) Bot

[GitHub] [flink] flinkbot edited a comment on pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on pull request #11687: URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * 5bad018f00f85a7359345187a12d7938aa510d25 UNKNOWN * d51ce7f47381d99b843278cd701dcff223761a0b UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #11936: [FLINK-17386][Security][hotfix] fix LinkageError not captured

flinkbot edited a comment on pull request #11936: URL: https://github.com/apache/flink/pull/11936#issuecomment-620683562 ## CI report: * a02867a0bce8f1a0174a6a3133b50b76167dbcc9 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/163208458) Azure:

[jira] [Commented] (FLINK-17271) Translate new DataStream API tutorial

[ https://issues.apache.org/jira/browse/FLINK-17271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17097473#comment-17097473 ] Bai Xu commented on FLINK-17271: Hi,[~alpinegizmo] .Could you please assign this to me?Thank you! >

[jira] [Commented] (FLINK-17291) Translate tutorial on event-driven applications to chinese

[ https://issues.apache.org/jira/browse/FLINK-17291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17097467#comment-17097467 ] RocMarshal commented on FLINK-17291: [~alpinegizmo] I will translate the

[GitHub] [flink] curcur commented on a change in pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

curcur commented on a change in pull request #11725: URL: https://github.com/apache/flink/pull/11725#discussion_r418596170 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaShuffleProducer.java ## @@ -0,0

[GitHub] [flink] curcur commented on a change in pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

curcur commented on a change in pull request #11725: URL: https://github.com/apache/flink/pull/11725#discussion_r418596170 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaShuffleProducer.java ## @@ -0,0

[GitHub] [flink] curcur commented on a change in pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

curcur commented on a change in pull request #11725: URL: https://github.com/apache/flink/pull/11725#discussion_r418595393 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java ## @@ -1333,6 +1334,32 @@ public

[GitHub] [flink] curcur commented on a change in pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

curcur commented on a change in pull request #11725: URL: https://github.com/apache/flink/pull/11725#discussion_r418595542 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/SinkTransformation.java ## @@ -67,6 +68,22 @@ public

[GitHub] [flink] sjwiesman commented on pull request #11878: [FLINK-17125][python] Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

sjwiesman commented on pull request #11878: URL: https://github.com/apache/flink/pull/11878#issuecomment-622433861 Sure This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] flinkbot edited a comment on pull request #11963: [FLINK-16408] Bind user code class loader to lifetime of Job on TaskExecutor

flinkbot edited a comment on pull request #11963: URL: https://github.com/apache/flink/pull/11963#issuecomment-621969588 ## CI report: * e07ec1bd9c216cdac0ac4faa79bc5509ab4129b6 UNKNOWN * 7401f5580774397bd121736b1068f03009a2d980 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11969: [FLINK-17489][core] Support any kind of array in StringUtils.arrayAwareToString()

flinkbot edited a comment on pull request #11969: URL: https://github.com/apache/flink/pull/11969#issuecomment-622355748 ## CI report: * ddc6ff6bc782c78bae1688b8b61e51038e9c2fb9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11844: [FLINK-17125][python][doc] Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

flinkbot edited a comment on pull request #11844: URL: https://github.com/apache/flink/pull/11844#issuecomment-617177959 ## CI report: * ebadc9001eb68754a95b3eee329b26c7590dfdfc Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/163020392) *

[GitHub] [flink] flinkbot edited a comment on pull request #11936: [FLINK-17386][Security][hotfix] fix LinkageError not captured

flinkbot edited a comment on pull request #11936: URL: https://github.com/apache/flink/pull/11936#issuecomment-620683562 ## CI report: * 1dcd163a3f869576f9504233e152a2e76baef51c Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/163136724) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11963: [FLINK-16408] Bind user code class loader to lifetime of Job on TaskExecutor

flinkbot edited a comment on pull request #11963: URL: https://github.com/apache/flink/pull/11963#issuecomment-621969588 ## CI report: * e07ec1bd9c216cdac0ac4faa79bc5509ab4129b6 UNKNOWN * 7359ca7d6960774eb8294b49d915cbd1563644fe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11844: [FLINK-17125][python][doc] Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

flinkbot edited a comment on pull request #11844: URL: https://github.com/apache/flink/pull/11844#issuecomment-617177959 ## CI report: * ebadc9001eb68754a95b3eee329b26c7590dfdfc Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/163020392) *

[GitHub] [flink] HuangXingBo commented on pull request #11878: [FLINK-17125][python] Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

HuangXingBo commented on pull request #11878: URL: https://github.com/apache/flink/pull/11878#issuecomment-622409672 Thanks a lot for the fix @sjwiesman . I have cherry-pick these commits to release-1.10 https://github.com/apache/flink/pull/11844 and change the content of `Adding Jar

[GitHub] [flink] flinkbot edited a comment on pull request #11936: [FLINK-17386][Security][hotfix] fix LinkageError not captured

flinkbot edited a comment on pull request #11936: URL: https://github.com/apache/flink/pull/11936#issuecomment-620683562 ## CI report: * 1dcd163a3f869576f9504233e152a2e76baef51c Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/163136724) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11963: [FLINK-16408] Bind user code class loader to lifetime of Job on TaskExecutor

flinkbot edited a comment on pull request #11963: URL: https://github.com/apache/flink/pull/11963#issuecomment-621969588 ## CI report: * e07ec1bd9c216cdac0ac4faa79bc5509ab4129b6 UNKNOWN * 7359ca7d6960774eb8294b49d915cbd1563644fe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11970: [FLINK-17483][legal] Update flink-sql-connector-elasticsearch7 NOTICE file to correctly reflect bundled dependencies

flinkbot edited a comment on pull request #11970: URL: https://github.com/apache/flink/pull/11970#issuecomment-622395974 ## CI report: * 151f32be272c47867647c3ef9877534c37887900 Azure:

[jira] [Commented] (FLINK-16868) Table/SQL doesn't support custom trigger

[ https://issues.apache.org/jira/browse/FLINK-16868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17097390#comment-17097390 ] Jark Wu commented on FLINK-16868: - This is a new feature, not a bug. So I removed the fix versions. >

[jira] [Updated] (FLINK-16868) Table/SQL doesn't support custom trigger

[ https://issues.apache.org/jira/browse/FLINK-16868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16868: Fix Version/s: (was: 1.9.4) (was: 1.10.2) (was: 1.11.0)

[jira] [Commented] (FLINK-17466) toRetractStream doesn't work correctly with Pojo conversion class

[ https://issues.apache.org/jira/browse/FLINK-17466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17097389#comment-17097389 ] Jark Wu commented on FLINK-17466: - Yes. I checked in master and this is still another bug. Sad... >

[jira] [Updated] (FLINK-17466) toRetractStream doesn't work correctly with Pojo conversion class

[ https://issues.apache.org/jira/browse/FLINK-17466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17466: Fix Version/s: 1.10.2 1.11.0 > toRetractStream doesn't work correctly with Pojo

[jira] [Updated] (FLINK-16868) Table/SQL doesn't support custom trigger

[ https://issues.apache.org/jira/browse/FLINK-16868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-16868: -- Fix Version/s: (was: 1.9.2) (was: 1.9.1) (was: 1.9.0)

[jira] [Updated] (FLINK-16612) Submit job through the rest api, job name will be lost

[ https://issues.apache.org/jira/browse/FLINK-16612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-16612: -- Fix Version/s: (was: 1.9.2) 1.10.2 1.11.0 It's a little bit weird

[jira] [Closed] (FLINK-16901) Flink Kinesis connector NOTICE should have contents of AWS KPL's THIRD_PARTY_NOTICES file manually merged in

[ https://issues.apache.org/jira/browse/FLINK-16901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li closed FLINK-16901. - Resolution: Fixed Closing the issue since all work done. > Flink Kinesis connector NOTICE should have contents

[jira] [Updated] (FLINK-16901) Flink Kinesis connector NOTICE should have contents of AWS KPL's THIRD_PARTY_NOTICES file manually merged in

[ https://issues.apache.org/jira/browse/FLINK-16901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-16901: -- Issue Type: Bug (was: Improvement) Labels: legal pull-request-available (was:

[jira] [Updated] (FLINK-16901) Flink Kinesis connector NOTICE should have contents of AWS KPL's THIRD_PARTY_NOTICES file manually merged in

[ https://issues.apache.org/jira/browse/FLINK-16901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-16901: -- Fix Version/s: 1.11.0 Checked and confirmed master branch also has the same issue, and merged the fix into

[jira] [Created] (FLINK-17495) Add custom labels on PrometheusReporter like PrometheusPushGatewayReporter's groupingKey

jinhai created FLINK-17495: -- Summary: Add custom labels on PrometheusReporter like PrometheusPushGatewayReporter's groupingKey Key: FLINK-17495 URL: https://issues.apache.org/jira/browse/FLINK-17495

[GitHub] [flink] flinkbot commented on pull request #11970: [FLINK-17483][legal] Update flink-sql-connector-elasticsearch7 NOTICE file to correctly reflect bundled dependencies

flinkbot commented on pull request #11970: URL: https://github.com/apache/flink/pull/11970#issuecomment-622395974 ## CI report: * 151f32be272c47867647c3ef9877534c37887900 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] curcur commented on a change in pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

curcur commented on a change in pull request #11725: URL: https://github.com/apache/flink/pull/11725#discussion_r418544339 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/SinkFunction.java ## @@ -52,6 +54,20 @@ default void

[GitHub] [flink] curcur commented on a change in pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

curcur commented on a change in pull request #11725: URL: https://github.com/apache/flink/pull/11725#discussion_r418544086 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamShuffleSink.java ## @@ -0,0 +1,104 @@ +/* + * Licensed to

[jira] [Resolved] (FLINK-14816) Add thread dump feature for taskmanager

[ https://issues.apache.org/jira/browse/FLINK-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-14816. --- Resolution: Fixed Fixed via 02944090d7d267790aa9265ddce3d8a56d324878

[GitHub] [flink] curcur commented on a change in pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

curcur commented on a change in pull request #11725: URL: https://github.com/apache/flink/pull/11725#discussion_r418543715 ## File path: flink-core/src/main/java/org/apache/flink/util/PropertiesUtil.java ## @@ -19,6 +19,7 @@ Review comment: Oh, yep, used as a

[jira] [Created] (FLINK-17494) Possible direct memory leak in cassandra sink

nobleyd created FLINK-17494: --- Summary: Possible direct memory leak in cassandra sink Key: FLINK-17494 URL: https://issues.apache.org/jira/browse/FLINK-17494 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot commented on pull request #11970: [FLINK-17483][legal] Update flink-sql-connector-elasticsearch7 NOTICE file to correctly reflect bundled dependencies

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

[GitHub] [flink] curcur commented on a change in pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

curcur commented on a change in pull request #11725: URL: https://github.com/apache/flink/pull/11725#discussion_r418541284 ## File path: flink-core/src/main/java/org/apache/flink/util/PropertiesUtil.java ## @@ -108,6 +109,27 @@ public static boolean getBoolean(Properties

[GitHub] [flink] carp84 commented on pull request #11970: [FLINK-17483][legal] Update flink-sql-connector-elasticsearch7 NOTICE file to correctly reflect bundled dependencies

carp84 commented on pull request #11970: URL: https://github.com/apache/flink/pull/11970#issuecomment-622388870 CC @zentol @rmetzger This is an automated message from the Apache Git Service. To respond to the message,

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

nobleyd created FLINK-17493: --- Summary: Possible direct memory leak in cassandra sink Key: FLINK-17493 URL: https://issues.apache.org/jira/browse/FLINK-17493 Project: Flink Issue Type: Bug

[GitHub] [flink] carp84 opened a new pull request #11970: [FLINK-17483][legal] Update flink-sql-connector-elasticsearch7 NOTICE file to correctly reflect bundled dependencies

carp84 opened a new pull request #11970: URL: https://github.com/apache/flink/pull/11970 ## What is the purpose of the change Fix the legal issue in `flink-sql-connector-elasticsearch7` as reported by FLINK-17483, for master branch ## Brief change log Update

  1   2   3   >