[jira] [Resolved] (FLINK-11987) Kafka producer occasionally throws NullpointerException

2019-06-01 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-11987. - Resolution: Fixed Assignee: Yu Li This is now fixed along with the resolut

[jira] [Closed] (FLINK-12688) Make serializer lazy initialization thread safe in StateDescriptor

2019-06-01 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-12688. --- Resolution: Fixed Release Note: Access to the state serializer field in {{State

[jira] [Updated] (FLINK-12688) Make serializer lazy initialization thread safe in StateDescriptor

2019-06-01 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12688: Fix Version/s: 1.7.3 > Make serializer lazy initialization thread safe in StateDes

[jira] [Commented] (FLINK-12688) Make serializer lazy initialization thread safe in StateDescriptor

2019-06-01 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16853886#comment-16853886 ] Tzu-Li (Gordon) Tai commented on FLINK-12688: - Thanks for the fix [~carp84]!

[jira] [Updated] (FLINK-12688) Make serializer lazy initialization thread safe in StateDescriptor

2019-06-01 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12688: Issue Type: Bug (was: Improvement) > Make serializer lazy initialization thread s

[GitHub] [flink] flinkbot commented on issue #8591: [FLINK-12268][Tests] Port SharedSlotsTest to new code base

2019-06-01 Thread GitBox
flinkbot commented on issue #8591: [FLINK-12268][Tests] Port SharedSlotsTest to new code base URL: https://github.com/apache/flink/pull/8591#issuecomment-497992438 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Updated] (FLINK-12268) Port SharedSlotsTest to new code base

2019-06-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12268: --- Labels: pull-request-available (was: ) > Port SharedSlotsTest to new code base > --

[GitHub] [flink] leesf opened a new pull request #8591: [FLINK-12268][Tests] Port SharedSlotsTest to new code base

2019-06-01 Thread GitBox
leesf opened a new pull request #8591: [FLINK-12268][Tests] Port SharedSlotsTest to new code base URL: https://github.com/apache/flink/pull/8591 ## What is the purpose of the change *Port SharedSlotsTest to new code base* ## Brief change log *(for example:)*

[GitHub] [flink] flinkbot commented on issue #8590: [FLINK-12689][dist] Add flink-azure-fs-hadoop dependency to flink-dist

2019-06-01 Thread GitBox
flinkbot commented on issue #8590: [FLINK-12689][dist] Add flink-azure-fs-hadoop dependency to flink-dist URL: https://github.com/apache/flink/pull/8590#issuecomment-497973977 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revi

[GitHub] [flink] GJL opened a new pull request #8590: [FLINK-12689][dist] Add flink-azure-fs-hadoop dependency to flink-dist

2019-06-01 Thread GitBox
GJL opened a new pull request #8590: [FLINK-12689][dist] Add flink-azure-fs-hadoop dependency to flink-dist URL: https://github.com/apache/flink/pull/8590 ## What is the purpose of the change *Add flink-azure-fs-hadoop dependency to flink-dist* ## Brief change log

[jira] [Updated] (FLINK-12689) Building flink-dist fails because flink-azure-fs-hadoop jar cannot be added to /opt

2019-06-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12689: --- Labels: pull-request-available (was: ) > Building flink-dist fails because flink-azure-fs-h

[jira] [Commented] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

2019-06-01 Thread Ben La Monica (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16853806#comment-16853806 ] Ben La Monica commented on FLINK-12122: --- I am able to get even distribution as lon

[jira] [Assigned] (FLINK-12689) Building flink-dist fails because flink-azure-fs-hadoop jar cannot be added to /opt

2019-06-01 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-12689: Assignee: Gary Yao > Building flink-dist fails because flink-azure-fs-hadoop jar cannot be added

[GitHub] [flink] flinkbot commented on issue #8589: [FLINK-12677][hive][sql-client] Add descriptor, validator, and factory for HiveCatalog

2019-06-01 Thread GitBox
flinkbot commented on issue #8589: [FLINK-12677][hive][sql-client] Add descriptor, validator, and factory for HiveCatalog URL: https://github.com/apache/flink/pull/8589#issuecomment-497969607 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the comm

[jira] [Updated] (FLINK-12677) Add descriptor, validator, and factory for HiveCatalog

2019-06-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12677: --- Labels: pull-request-available (was: ) > Add descriptor, validator, and factory for HiveCat

[GitHub] [flink] bowenli86 opened a new pull request #8589: [FLINK-12677][hive][sql-client] Add descriptor, validator, and factory for HiveCatalog

2019-06-01 Thread GitBox
bowenli86 opened a new pull request #8589: [FLINK-12677][hive][sql-client] Add descriptor, validator, and factory for HiveCatalog URL: https://github.com/apache/flink/pull/8589 ## What is the purpose of the change This PR adds descriptor, validator, and factory for HiveCatalog, and t

[jira] [Commented] (FLINK-12669) Implement FixedDelayRestartBackoffTimeStrategy

2019-06-01 Thread aitozi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16853750#comment-16853750 ] aitozi commented on FLINK-12669: ok, thanks for remind, i will check that issue [~till.r

[GitHub] [flink] carp84 commented on issue #8570: [FLINK-12688] [state] Make serializer lazy initialization thread safe in StateDescriptor

2019-06-01 Thread GitBox
carp84 commented on issue #8570: [FLINK-12688] [state] Make serializer lazy initialization thread safe in StateDescriptor URL: https://github.com/apache/flink/pull/8570#issuecomment-497939392 Thanks all for the careful reviews and thanks @tzulitai for helping merge the PR! ---

[GitHub] [flink] flinkbot commented on issue #8588: [FLINK-12703] [table-planner-blink] Introduce metadata handlers on SEMI/ANTI join and lookup join

2019-06-01 Thread GitBox
flinkbot commented on issue #8588: [FLINK-12703] [table-planner-blink] Introduce metadata handlers on SEMI/ANTI join and lookup join URL: https://github.com/apache/flink/pull/8588#issuecomment-497931157 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I he

[GitHub] [flink] godfreyhe opened a new pull request #8588: [FLINK-12703] [table-planner-blink] Introduce metadata handlers on SEMI/ANTI join and lookup join

2019-06-01 Thread GitBox
godfreyhe opened a new pull request #8588: [FLINK-12703] [table-planner-blink] Introduce metadata handlers on SEMI/ANTI join and lookup join URL: https://github.com/apache/flink/pull/8588 ## What is the purpose of the change *Introduce metadata handlers on SEMI/ANTI join and look

[GitHub] [flink] godfreyhe closed pull request #8587: [FLINK-12703] [table-planner-blink] Introduce metadata handlers on SEMI/ANTI join and lookup join

2019-06-01 Thread GitBox
godfreyhe closed pull request #8587: [FLINK-12703] [table-planner-blink] Introduce metadata handlers on SEMI/ANTI join and lookup join URL: https://github.com/apache/flink/pull/8587 This is an automated message from the Apac

[GitHub] [flink] flinkbot commented on issue #8587: [FLINK-12703] [table-planner-blink] Introduce metadata handlers on SEMI/ANTI join and lookup join

2019-06-01 Thread GitBox
flinkbot commented on issue #8587: [FLINK-12703] [table-planner-blink] Introduce metadata handlers on SEMI/ANTI join and lookup join URL: https://github.com/apache/flink/pull/8587#issuecomment-497930323 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I he

[jira] [Updated] (FLINK-12703) Introduce metadata handlers on SEMI/ANTI join and lookup join

2019-06-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12703: --- Labels: pull-request-available (was: ) > Introduce metadata handlers on SEMI/ANTI join and

[GitHub] [flink] godfreyhe opened a new pull request #8587: [FLINK-12703] [table-planner-blink] Introduce metadata handlers on SEMI/ANTI join and lookup join

2019-06-01 Thread GitBox
godfreyhe opened a new pull request #8587: [FLINK-12703] [table-planner-blink] Introduce metadata handlers on SEMI/ANTI join and lookup join URL: https://github.com/apache/flink/pull/8587 ## What is the purpose of the change *Introduce metadata handlers on SEMI/ANTI join and

[jira] [Updated] (FLINK-12703) Introduce metadata handlers on SEMI/ANTI join and lookup join

2019-06-01 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12703: --- Description: In [FLINK-11822|https://issues.apache.org/jira/browse/FLINK-11822], we have introduced

[jira] [Updated] (FLINK-12703) Introduce metadata handlers on SEMI/ANTI join and lookup join

2019-06-01 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12703: --- Summary: Introduce metadata handlers on SEMI/ANTI join and lookup join (was: Introduce metadata han

[jira] [Updated] (FLINK-12703) Introduce metadata handlers on SEMI/ATNI join and lookup join

2019-06-01 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12703: --- Summary: Introduce metadata handlers on SEMI/ATNI join and lookup join (was: Introduce metadata han

[jira] [Updated] (FLINK-12703) Introduce metadata handlers on SEMI/ATNI join and lookup join

2019-06-01 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12703: --- Description: In [FLINK-11822|https://issues.apache.org/jira/browse/FLINK-11822], we have introduced

[jira] [Created] (FLINK-12703) Introduce metadata handlers on SEMI/ATNI join and look up join

2019-06-01 Thread godfrey he (JIRA)
godfrey he created FLINK-12703: -- Summary: Introduce metadata handlers on SEMI/ATNI join and look up join Key: FLINK-12703 URL: https://issues.apache.org/jira/browse/FLINK-12703 Project: Flink I

[jira] [Assigned] (FLINK-12693) Store state per key-group in CopyOnWriteStateTable

2019-06-01 Thread Yu Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li reassigned FLINK-12693: - Assignee: PengFei Li (was: Yu Li) > Store state per key-group in CopyOnWriteStateTable > -

[jira] [Assigned] (FLINK-12699) Reduce CPU consumption when snapshot/restore the spilled key-group

2019-06-01 Thread Yu Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li reassigned FLINK-12699: - Assignee: PengFei Li (was: Yu Li) > Reduce CPU consumption when snapshot/restore the spilled key-group

[jira] [Updated] (FLINK-12688) Make serializer lazy initialization thread safe in StateDescriptor

2019-06-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12688: --- Labels: pull-request-available (was: ) > Make serializer lazy initialization thread safe in

[GitHub] [flink] asfgit closed pull request #8570: [FLINK-12688] [state] Make serializer lazy initialization thread safe in StateDescriptor

2019-06-01 Thread GitBox
asfgit closed pull request #8570: [FLINK-12688] [state] Make serializer lazy initialization thread safe in StateDescriptor URL: https://github.com/apache/flink/pull/8570 This is an automated message from the Apache Git Servi

[GitHub] [flink] tzulitai commented on issue #8570: [FLINK-12688] [state] Make serializer lazy initialization thread safe in StateDescriptor

2019-06-01 Thread GitBox
tzulitai commented on issue #8570: [FLINK-12688] [state] Make serializer lazy initialization thread safe in StateDescriptor URL: https://github.com/apache/flink/pull/8570#issuecomment-497921814 Merging ... This is an automate

[GitHub] [flink] leesf commented on issue #8544: [FLINK-12264] Remove unused methods in ExecutionGraphTestUtils

2019-06-01 Thread GitBox
leesf commented on issue #8544: [FLINK-12264] Remove unused methods in ExecutionGraphTestUtils URL: https://github.com/apache/flink/pull/8544#issuecomment-497920016 Please take a look. Thanks @zentol This is an automated mes