[jira] [Commented] (FLINK-13792) source and sink support manual rate limit

[ https://issues.apache.org/jira/browse/FLINK-13792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911879#comment-16911879 ] boshu Zheng commented on FLINK-13792: - +1 for this feature :) > source and sink sup

[jira] [Commented] (FLINK-12320) Flink bucketing sink restart with save point cause data loss when using SequenceFile.CompressionType.BLOCK

[ https://issues.apache.org/jira/browse/FLINK-12320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16825677#comment-16825677 ] boshu Zheng commented on FLINK-12320: - Hi [~shinchen] could you please give more det

[jira] [Assigned] (FLINK-10713) RestartIndividualStrategy does not restore state

[ https://issues.apache.org/jira/browse/FLINK-10713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-10713: --- Assignee: (was: boshu Zheng) > RestartIndividualStrategy does not restore state > -

[jira] [Commented] (FLINK-10713) RestartIndividualStrategy does not restore state

[ https://issues.apache.org/jira/browse/FLINK-10713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16825659#comment-16825659 ] boshu Zheng commented on FLINK-10713: - [~yunta] Sure, feel free to go ahead :) > Re

[jira] [Commented] (FLINK-10897) Support POJO state schema evolution

[ https://issues.apache.org/jira/browse/FLINK-10897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16775869#comment-16775869 ] boshu Zheng commented on FLINK-10897: - Sorry for the late reply [~tzulitai], and ver

[jira] [Assigned] (FLINK-11630) TaskExecutor does not wait for Task termination when terminating itself

[ https://issues.apache.org/jira/browse/FLINK-11630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-11630: --- Assignee: boshu Zheng > TaskExecutor does not wait for Task termination when terminating it

[jira] [Assigned] (FLINK-10713) RestartIndividualStrategy does not restore state

[ https://issues.apache.org/jira/browse/FLINK-10713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-10713: --- Assignee: boshu Zheng > RestartIndividualStrategy does not restore state >

[jira] [Assigned] (FLINK-11334) Migrate enum serializers to use new serialization compatibility abstractions

[ https://issues.apache.org/jira/browse/FLINK-11334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-11334: --- Assignee: boshu Zheng > Migrate enum serializers to use new serialization compatibility abs

[jira] [Assigned] (FLINK-10026) Integrate heap based timers in RocksDB backend with incremental checkpoints

[ https://issues.apache.org/jira/browse/FLINK-10026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-10026: --- Assignee: boshu Zheng > Integrate heap based timers in RocksDB backend with incremental che

[jira] [Comment Edited] (FLINK-10897) Support POJO state schema evolution

[ https://issues.apache.org/jira/browse/FLINK-10897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16747409#comment-16747409 ] boshu Zheng edited comment on FLINK-10897 at 1/30/19 2:13 AM:

[jira] [Assigned] (FLINK-9959) Add JoinWindowFunction to allow access Window

[ https://issues.apache.org/jira/browse/FLINK-9959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-9959: -- Assignee: boshu Zheng > Add JoinWindowFunction to allow access Window > --

[jira] [Assigned] (FLINK-11362) Check and port TaskManagerComponentsStartupShutdownTest to new code base if necessary

[ https://issues.apache.org/jira/browse/FLINK-11362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-11362: --- Assignee: (was: boshu Zheng) > Check and port TaskManagerComponentsStartupShutdownTest

[jira] [Commented] (FLINK-10897) Support POJO state schema evolution

[ https://issues.apache.org/jira/browse/FLINK-10897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16747409#comment-16747409 ] boshu Zheng commented on FLINK-10897: - I will try to follow the example that you pre

[jira] [Assigned] (FLINK-11362) Check and port TaskManagerComponentsStartupShutdownTest to new code base if necessary

[ https://issues.apache.org/jira/browse/FLINK-11362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-11362: --- Assignee: boshu Zheng > Check and port TaskManagerComponentsStartupShutdownTest to new code

[jira] [Assigned] (FLINK-11365) Check and port TaskManagerFailureRecoveryITCase to new code base if necessary

[ https://issues.apache.org/jira/browse/FLINK-11365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-11365: --- Assignee: boshu Zheng > Check and port TaskManagerFailureRecoveryITCase to new code base if

[jira] [Assigned] (FLINK-11318) [Regression] StreamingFileSink can overwrite existing files

[ https://issues.apache.org/jira/browse/FLINK-11318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-11318: --- Assignee: boshu Zheng > [Regression] StreamingFileSink can overwrite existing files > -

[jira] [Commented] (FLINK-8823) Add network profiling/diagnosing metrics.

[ https://issues.apache.org/jira/browse/FLINK-8823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16732964#comment-16732964 ] boshu Zheng commented on FLINK-8823: Haven't started working on this issue, do you ha

[jira] [Created] (FLINK-11248) Support Row/CRow state schema evolution

boshu Zheng created FLINK-11248: --- Summary: Support Row/CRow state schema evolution Key: FLINK-11248 URL: https://issues.apache.org/jira/browse/FLINK-11248 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-10897) Support POJO state schema evolution

[ https://issues.apache.org/jira/browse/FLINK-10897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-10897: --- Assignee: boshu Zheng > Support POJO state schema evolution > -

[jira] [Assigned] (FLINK-7463) Release nascent workers on slot request timeout

[ https://issues.apache.org/jira/browse/FLINK-7463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-7463: -- Assignee: boshu Zheng > Release nascent workers on slot request timeout > ---

[jira] [Assigned] (FLINK-6800) PojoSerializer ignores added pojo fields

[ https://issues.apache.org/jira/browse/FLINK-6800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-6800: -- Assignee: boshu Zheng > PojoSerializer ignores added pojo fields > ---

[jira] [Assigned] (FLINK-9457) Cancel container requests when cancelling pending slot allocations

[ https://issues.apache.org/jira/browse/FLINK-9457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-9457: -- Assignee: boshu Zheng (was: vinoyang) > Cancel container requests when cancelling pending slo

[jira] [Assigned] (FLINK-10502) Wait for resource stabilization

[ https://issues.apache.org/jira/browse/FLINK-10502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-10502: --- Assignee: boshu Zheng > Wait for resource stabilization > --- >

[jira] [Assigned] (FLINK-6768) Quadratic/Inefficient field lookup in PojoSerializer#ensureCompatibility

[ https://issues.apache.org/jira/browse/FLINK-6768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-6768: -- Assignee: boshu Zheng > Quadratic/Inefficient field lookup in PojoSerializer#ensureCompatibili

[jira] [Assigned] (FLINK-11190) Log stack trace on declined/discarded checkpoint

[ https://issues.apache.org/jira/browse/FLINK-11190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-11190: --- Assignee: boshu Zheng > Log stack trace on declined/discarded checkpoint >

[jira] [Assigned] (FLINK-11102) Enable check for previous data in SpanningRecordSerializer

[ https://issues.apache.org/jira/browse/FLINK-11102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-11102: --- Assignee: boshu Zheng (was: vinoyang) > Enable check for previous data in SpanningRecordSe

[jira] [Assigned] (FLINK-10177) Use network transport type AUTO by default

[ https://issues.apache.org/jira/browse/FLINK-10177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-10177: --- Assignee: boshu Zheng > Use network transport type AUTO by default > --

[jira] [Comment Edited] (FLINK-9717) Flush state of one side of the join if other side is bounded

[ https://issues.apache.org/jira/browse/FLINK-9717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16722013#comment-16722013 ] boshu Zheng edited comment on FLINK-9717 at 12/15/18 8:54 AM: -

[jira] [Assigned] (FLINK-9717) Flush state of one side of the join if other side is bounded

[ https://issues.apache.org/jira/browse/FLINK-9717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-9717: -- Assignee: (was: boshu Zheng) > Flush state of one side of the join if other side is bounde

[jira] [Commented] (FLINK-9717) Flush state of one side of the join if other side is bounded

[ https://issues.apache.org/jira/browse/FLINK-9717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16722013#comment-16722013 ] boshu Zheng commented on FLINK-9717: Just a little thought on it to share. When consi

[jira] [Commented] (FLINK-9717) Flush state of one side of the join if other side is bounded

[ https://issues.apache.org/jira/browse/FLINK-9717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16722001#comment-16722001 ] boshu Zheng commented on FLINK-9717: Hi [~pnowojski], thanks for your comment, I have

[jira] [Assigned] (FLINK-9142) Lower the minimum number of buffers for incoming channels to 1

[ https://issues.apache.org/jira/browse/FLINK-9142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-9142: -- Assignee: boshu Zheng > Lower the minimum number of buffers for incoming channels to 1 > -

[jira] [Assigned] (FLINK-10615) Cancel with savepoint can fail the job

[ https://issues.apache.org/jira/browse/FLINK-10615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-10615: --- Assignee: (was: boshu Zheng) > Cancel with savepoint can fail the job > ---

[jira] [Assigned] (FLINK-9462) Disentangle flink-json and flink-table

[ https://issues.apache.org/jira/browse/FLINK-9462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-9462: -- Assignee: (was: boshu Zheng) > Disentangle flink-json and flink-table > --

[jira] [Assigned] (FLINK-9462) Disentangle flink-json and flink-table

[ https://issues.apache.org/jira/browse/FLINK-9462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-9462: -- Assignee: boshu Zheng > Disentangle flink-json and flink-table > -

[jira] [Assigned] (FLINK-9529) Do not expose keyed operations on ProcessFunction.Context

[ https://issues.apache.org/jira/browse/FLINK-9529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-9529: -- Assignee: boshu Zheng > Do not expose keyed operations on ProcessFunction.Context > --

[jira] [Assigned] (FLINK-9717) Flush state of one side of the join if other side is bounded

[ https://issues.apache.org/jira/browse/FLINK-9717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-9717: -- Assignee: boshu Zheng > Flush state of one side of the join if other side is bounded > ---

[jira] [Assigned] (FLINK-11099) Migrate flink-table runtime CRow Types classes

[ https://issues.apache.org/jira/browse/FLINK-11099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-11099: --- Assignee: boshu Zheng > Migrate flink-table runtime CRow Types classes >

[jira] [Assigned] (FLINK-11099) Migrate flink-table runtime CRow Types classes

[ https://issues.apache.org/jira/browse/FLINK-11099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-11099: --- Assignee: (was: boshu Zheng) > Migrate flink-table runtime CRow Types classes > -

[jira] [Assigned] (FLINK-8823) Add network profiling/diagnosing metrics.

[ https://issues.apache.org/jira/browse/FLINK-8823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-8823: -- Assignee: boshu Zheng > Add network profiling/diagnosing metrics. > --

[jira] [Commented] (FLINK-11083) CRowSerializerConfigSnapshot is not instantiable

[ https://issues.apache.org/jira/browse/FLINK-11083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16711193#comment-16711193 ] boshu Zheng commented on FLINK-11083: - Hi [~dawidwys] Thanks for your reply. I use F

[jira] [Closed] (FLINK-10548) Remove LegacyStandaloneClusterDescriptor

[ https://issues.apache.org/jira/browse/FLINK-10548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng closed FLINK-10548. --- Resolution: Duplicate > Remove LegacyStandaloneClusterDescriptor > -

[jira] [Commented] (FLINK-11083) CRowSerializerConfigSnapshot is not instantiable

[ https://issues.apache.org/jira/browse/FLINK-11083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16711016#comment-16711016 ] boshu Zheng commented on FLINK-11083: - cc [~pnowojski] Could you please have a look?

[jira] [Created] (FLINK-11083) CRowSerializerConfigSnapshot is not instantiable

boshu Zheng created FLINK-11083: --- Summary: CRowSerializerConfigSnapshot is not instantiable Key: FLINK-11083 URL: https://issues.apache.org/jira/browse/FLINK-11083 Project: Flink Issue Type: Bu

[jira] [Assigned] (FLINK-10783) Update WindowOperatorMigrationTest for 1.7

[ https://issues.apache.org/jira/browse/FLINK-10783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-10783: --- Assignee: boshu Zheng (was: vinoyang) > Update WindowOperatorMigrationTest for 1.7 > -

[jira] [Assigned] (FLINK-10615) Cancel with savepoint can fail the job

[ https://issues.apache.org/jira/browse/FLINK-10615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-10615: --- Assignee: boshu Zheng > Cancel with savepoint can fail the job > --

[jira] [Assigned] (FLINK-10147) numBytesOut metric lagging behind

[ https://issues.apache.org/jira/browse/FLINK-10147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-10147: --- Assignee: boshu Zheng > numBytesOut metric lagging behind > ---