[jira] [Commented] (FLINK-13632) Port serializer upgrade tests to TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17020320#comment-17020320 ] Aljoscha Krettek commented on FLINK-13632: -- I&

[jira] [Updated] (FLINK-13632) Port serializer upgrade tests to TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-13632: - Priority: Critical (was: Blocker) > Port serializer upgrade tests

[jira] [Assigned] (FLINK-15276) Update CLI documentation to reflect the addition of the ExecutorCLI

[ https://issues.apache.org/jira/browse/FLINK-15276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-15276: Assignee: Kostas Kloudas > Update CLI documentation to reflect the addition

[jira] [Assigned] (FLINK-14742) Unstable tests TaskExecutorTest#testSubmitTaskBeforeAcceptSlot

[ https://issues.apache.org/jira/browse/FLINK-14742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-14742: Assignee: Aljoscha Krettek (was: Kostas Kloudas) > Unstable te

[jira] [Assigned] (FLINK-14742) Unstable tests TaskExecutorTest#testSubmitTaskBeforeAcceptSlot

[ https://issues.apache.org/jira/browse/FLINK-14742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-14742: Assignee: Kostas Kloudas (was: Aljoscha Krettek) > Unstable te

[jira] [Commented] (FLINK-7050) RFC Compliant CSV Parser for Table Source

[ https://issues.apache.org/jira/browse/FLINK-7050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17020090#comment-17020090 ] Aljoscha Krettek commented on FLINK-7050: - I'm posting this to all t

[jira] [Commented] (FLINK-11746) Add thrift format support in Flink

[ https://issues.apache.org/jira/browse/FLINK-11746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17020087#comment-17020087 ] Aljoscha Krettek commented on FLINK-11746: -- Before working on Table

[jira] [Commented] (FLINK-9651) Add a Kafka table source factory with Protobuf format support

[ https://issues.apache.org/jira/browse/FLINK-9651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17020088#comment-17020088 ] Aljoscha Krettek commented on FLINK-9651: - Before working on Table API for

[jira] [Commented] (FLINK-15674) Let Java and Scala Type Extraction go through the same stack

[ https://issues.apache.org/jira/browse/FLINK-15674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17020084#comment-17020084 ] Aljoscha Krettek commented on FLINK-15674: -- This issue is trickier tha

[jira] [Commented] (FLINK-15674) Let Java and Scala Type Extraction go through the same stack

[ https://issues.apache.org/jira/browse/FLINK-15674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17020085#comment-17020085 ] Aljoscha Krettek commented on FLINK-15674: -- Before anyone starts please r

[jira] [Assigned] (FLINK-9651) Add a Kafka table source factory with Protobuf format support

[ https://issues.apache.org/jira/browse/FLINK-9651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-9651: --- Assignee: (was: Aljoscha Krettek) > Add a Kafka table source factory w

[jira] [Assigned] (FLINK-7050) RFC Compliant CSV Parser for Table Source

[ https://issues.apache.org/jira/browse/FLINK-7050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-7050: --- Assignee: Aljoscha Krettek > RFC Compliant CSV Parser for Table Sou

[jira] [Assigned] (FLINK-9651) Add a Kafka table source factory with Protobuf format support

[ https://issues.apache.org/jira/browse/FLINK-9651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-9651: --- Assignee: Aljoscha Krettek (was: vinoyang) > Add a Kafka table source factory w

[jira] [Assigned] (FLINK-7050) RFC Compliant CSV Parser for Table Source

[ https://issues.apache.org/jira/browse/FLINK-7050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-7050: --- Assignee: (was: Aljoscha Krettek) > RFC Compliant CSV Parser for Table Sou

[jira] [Assigned] (FLINK-7050) RFC Compliant CSV Parser for Table Source

[ https://issues.apache.org/jira/browse/FLINK-7050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-7050: --- Assignee: (was: Usman Younas) > RFC Compliant CSV Parser for Table Sou

[jira] [Commented] (FLINK-15669) SQL client can't cancel flink job

[ https://issues.apache.org/jira/browse/FLINK-15669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019480#comment-17019480 ] Aljoscha Krettek commented on FLINK-15669: -- I think that should work,

[jira] [Commented] (FLINK-15634) disableAutoGeneratedUIDs fails with coGroup and join

[ https://issues.apache.org/jira/browse/FLINK-15634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019478#comment-17019478 ] Aljoscha Krettek commented on FLINK-15634: -- Ah, I think the root of

[jira] [Commented] (FLINK-13613) Update state migration tests for Flink 1.9

[ https://issues.apache.org/jira/browse/FLINK-13613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019473#comment-17019473 ] Aljoscha Krettek commented on FLINK-13613: -- For the tests that were in

[jira] [Commented] (FLINK-13632) Port serializer upgrade tests to TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018104#comment-17018104 ] Aljoscha Krettek commented on FLINK-13632: -- I'

[jira] [Updated] (FLINK-13632) Port serializer upgrade tests to TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-13632: - Component/s: API / Type Serialization System > Port serializer upgrade tests

[jira] [Assigned] (FLINK-13632) Port serializer upgrade tests to TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-13632: Assignee: Aljoscha Krettek > Port serializer upgrade tests

[jira] [Closed] (FLINK-13613) Update state migration tests for Flink 1.9

[ https://issues.apache.org/jira/browse/FLINK-13613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-13613. Resolution: Fixed I'm closing this for now, though FLINK-13632 still remains an

[jira] [Updated] (FLINK-13632) Port serializer upgrade tests to TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-13632: - Parent: (was: FLINK-13613) Issue Type: Test (was: Sub-task) > P

[jira] [Updated] (FLINK-13632) Port serializer upgrade tests to TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-13632: - Summary: Port serializer upgrade tests to TypeSerializerUpgradeTestBase (was: Update

[jira] [Commented] (FLINK-15514) Bump Elasticsearch version from 6.3.1 to 6.8.6 for es6 connector

[ https://issues.apache.org/jira/browse/FLINK-15514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017821#comment-17017821 ] Aljoscha Krettek commented on FLINK-15514: -- Yes, I don't even kno

[jira] [Assigned] (FLINK-15514) Bump Elasticsearch version from 6.3.1 to 6.8.6 for es6 connector

[ https://issues.apache.org/jira/browse/FLINK-15514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-15514: Assignee: vinoyang (was: Aljoscha Krettek) > Bump Elasticsearch version f

[jira] [Commented] (FLINK-15474) In TypeSerializerUpgradeTestBase, create serializer snapshots "on demand"

[ https://issues.apache.org/jira/browse/FLINK-15474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017074#comment-17017074 ] Aljoscha Krettek commented on FLINK-15474: -- Also, the Pojo serializer ha

[jira] [Commented] (FLINK-15474) In TypeSerializerUpgradeTestBase, create serializer snapshots "on demand"

[ https://issues.apache.org/jira/browse/FLINK-15474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017064#comment-17017064 ] Aljoscha Krettek commented on FLINK-15474: -- I agree that test runtime

[jira] [Closed] (FLINK-15558) Bump Elasticsearch version from 7.3.2 to 7.5.1 for es7 connector

[ https://issues.apache.org/jira/browse/FLINK-15558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-15558. Fix Version/s: 1.11.0 Resolution: Fixed Changed in

[jira] [Commented] (FLINK-14122) Extend State Processor API to read ListCheckpointed operator state

[ https://issues.apache.org/jira/browse/FLINK-14122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016780#comment-17016780 ] Aljoscha Krettek commented on FLINK-14122: -- Yes, after I wrote my comme

[jira] [Commented] (FLINK-14122) Extend State Processor API to read ListCheckpointed operator state

[ https://issues.apache.org/jira/browse/FLINK-14122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016730#comment-17016730 ] Aljoscha Krettek commented on FLINK-14122: -- I'm wondering of we shoul

[jira] [Updated] (FLINK-14807) Add Table#collect api for fetching data to client

[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-14807: - Fix Version/s: 1.11.0 > Add Table#collect api for fetching data to cli

[jira] [Updated] (FLINK-14807) Add Table#collect api for fetching data to client

[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-14807: - Labels: usability (was: ) > Add Table#collect api for fetching data to cli

[jira] [Reopened] (FLINK-14807) Add Table#collect api for fetching data to client

[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-14807: -- > Add Table#collect api for fetching data to cli

[jira] [Commented] (FLINK-14807) Add Table#collect api for fetching data to client

[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016102#comment-17016102 ] Aljoscha Krettek commented on FLINK-14807: -- [~dwysakowicz] Should this

[jira] [Updated] (FLINK-2646) User functions should be able to differentiate between successful close and erroneous close

[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-2646: Labels: usability (was: ) > User functions should be able to differentiate betw

[jira] [Updated] (FLINK-11427) Protobuf parquet writer implementation

[ https://issues.apache.org/jira/browse/FLINK-11427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-11427: - Labels: usability (was: ) > Protobuf parquet writer implementat

[jira] [Updated] (FLINK-10036) Flink's CSV output format is not consistent with the standard.

[ https://issues.apache.org/jira/browse/FLINK-10036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-10036: - Labels: usability (was: ) > Flink's CSV output format is not consistent

[jira] [Updated] (FLINK-11746) Add thrift format support in Flink

[ https://issues.apache.org/jira/browse/FLINK-11746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-11746: - Labels: pull-request-available usability (was: pull-request-available) > Add thr

[jira] [Updated] (FLINK-7050) RFC Compliant CSV Parser for Table Source

[ https://issues.apache.org/jira/browse/FLINK-7050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7050: Labels: csv parsing usability (was: csv parsing) > RFC Compliant CSV Parser for Ta

[jira] [Commented] (FLINK-13632) Update serializer upgrade tests to restore from 1.8 and beyond

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016050#comment-17016050 ] Aljoscha Krettek commented on FLINK-13632: -- I'm currentl

[jira] [Commented] (FLINK-15549) integer overflow in SpillingResettableMutableObjectIterator

[ https://issues.apache.org/jira/browse/FLINK-15549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015838#comment-17015838 ] Aljoscha Krettek commented on FLINK-15549: -- Yes, this is a pro

[jira] [Updated] (FLINK-15561) Improve Kerberos delegation token login

[ https://issues.apache.org/jira/browse/FLINK-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-15561: - Fix Version/s: 1.11.0 > Improve Kerberos delegation token lo

[jira] [Updated] (FLINK-15561) Improve Kerberos delegation token login

[ https://issues.apache.org/jira/browse/FLINK-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-15561: - Labels: usability (was: ) > Improve Kerberos delegation token lo

[jira] [Commented] (FLINK-15557) Cannot connect to Azure Event Hub/Kafka since Jan 5th 2020. Kafka version issue

[ https://issues.apache.org/jira/browse/FLINK-15557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014417#comment-17014417 ] Aljoscha Krettek commented on FLINK-15557: -- So you can resolve it on your

[jira] [Updated] (FLINK-15474) In TypeSerializerUpgradeTestBase, create serializer snapshots "on demand"

[ https://issues.apache.org/jira/browse/FLINK-15474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-15474: - Issue Type: Improvement (was: Bug) > In TypeSerializerUpgradeTestBase, cre

[jira] [Closed] (FLINK-15541) FlinkKinesisConsumerTest.testSourceSynchronization is unstable on travis.

[ https://issues.apache.org/jira/browse/FLINK-15541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-15541. Resolution: Fixed Fixed on release-1.10 in 5bea705408ba455bd462d72d6943a59ee46e2a90 Fixed

[jira] [Commented] (FLINK-15557) Cannot connect to Azure Event Hub/Kafka since Jan 5th 2020. Kafka version issue

[ https://issues.apache.org/jira/browse/FLINK-15557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014266#comment-17014266 ] Aljoscha Krettek commented on FLINK-15557: -- For reference, there is also

[jira] [Updated] (FLINK-15566) Flink implicitly order the fields in PojoTypeInfo

[ https://issues.apache.org/jira/browse/FLINK-15566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-15566: - Component/s: (was: API / Core) Table SQL / API > Flink implici

[jira] [Commented] (FLINK-15566) Flink implicitly order the fields in PojoTypeInfo

[ https://issues.apache.org/jira/browse/FLINK-15566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014264#comment-17014264 ] Aljoscha Krettek commented on FLINK-15566: -- The problem here is that the o

[jira] [Commented] (FLINK-13613) Update state migration tests for Flink 1.9

[ https://issues.apache.org/jira/browse/FLINK-13613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012581#comment-17012581 ] Aljoscha Krettek commented on FLINK-13613: -- Yes, moving them to a cen

[jira] [Commented] (FLINK-15514) Bump Elasticsearch version from 6.3.1 to 6.8.6 for es6 connector

[ https://issues.apache.org/jira/browse/FLINK-15514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012578#comment-17012578 ] Aljoscha Krettek commented on FLINK-15514: -- Yes, that also makes s

[jira] [Commented] (FLINK-13613) Update state migration tests for Flink 1.9

[ https://issues.apache.org/jira/browse/FLINK-13613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011865#comment-17011865 ] Aljoscha Krettek commented on FLINK-13613: -- With the exception of FLINK-1

[jira] [Commented] (FLINK-15535) Add usage of ProcessFunctionTestHarnesses for testing documentation

[ https://issues.apache.org/jira/browse/FLINK-15535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011812#comment-17011812 ] Aljoscha Krettek commented on FLINK-15535: -- sounds good. > Add u

[jira] [Commented] (FLINK-15514) Bump Elasticsearch version from 6.3.1 to 6.8.6 for es6 connector

[ https://issues.apache.org/jira/browse/FLINK-15514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011810#comment-17011810 ] Aljoscha Krettek commented on FLINK-15514: -- You mean the latest ES 7.x or

[jira] [Commented] (FLINK-15514) Bump Elasticsearch version from 6.3.1 to 6.8.6 for es6 connector

[ https://issues.apache.org/jira/browse/FLINK-15514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17010796#comment-17010796 ] Aljoscha Krettek commented on FLINK-15514: -- Probably makes sense, yes. &g

[jira] [Assigned] (FLINK-15514) Bump Elasticsearch version from 6.3.1 to 6.8.6 for es6 connector

[ https://issues.apache.org/jira/browse/FLINK-15514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-15514: Assignee: Aljoscha Krettek > Bump Elasticsearch version from 6.3.1 to 6.8.6

[jira] [Closed] (FLINK-8255) Key expressions on named row types do not work

[ https://issues.apache.org/jira/browse/FLINK-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8255. --- Fix Version/s: 1.11.0 Resolution: Fixed Fixed on master in

[jira] [Created] (FLINK-15518) Don't hide web frontend side pane automatically

Aljoscha Krettek created FLINK-15518: Summary: Don't hide web frontend side pane automatically Key: FLINK-15518 URL: https://issues.apache.org/jira/browse/FLINK-15518 Project:

[jira] [Commented] (FLINK-15518) Don't hide web frontend side pane automatically

[ https://issues.apache.org/jira/browse/FLINK-15518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17010683#comment-17010683 ] Aljoscha Krettek commented on FLINK-15518: -- cc [~vthinkxie] > Don

[jira] [Closed] (FLINK-15510) Pretty Print StreamGraph JSON Plan

[ https://issues.apache.org/jira/browse/FLINK-15510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-15510. Resolution: Fixed Implemented in 07ce59e4302507c8875ec2d25cb50d1e9547f5cc > Pretty Pr

[jira] [Commented] (FLINK-13926) `ProcessingTimeSessionWindows` and `EventTimeSessionWindows` should be generic

[ https://issues.apache.org/jira/browse/FLINK-13926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17010639#comment-17010639 ] Aljoscha Krettek commented on FLINK-13926: -- It's unfortunate that we

[jira] [Closed] (FLINK-13658) Combine two triggers into one (for streaming windows)

[ https://issues.apache.org/jira/browse/FLINK-13658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-13658. Resolution: Duplicate This is a duplicate of the (very old) issue FLINK-4407. I'

[jira] [Closed] (FLINK-10126) There should be a Scala DataSource

[ https://issues.apache.org/jira/browse/FLINK-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-10126. Resolution: Won't Do I'm closing this for now because we don't really

[jira] [Closed] (FLINK-9641) Pulsar Source Connector

[ https://issues.apache.org/jira/browse/FLINK-9641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-9641. --- Resolution: Abandoned I'm sorry but I'm closing this because of the newer effort

[jira] [Closed] (FLINK-9168) Pulsar Sink Connector

[ https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-9168. --- Resolution: Abandoned I'm sorry but I'm closing this because of the newer effort

[jira] [Updated] (FLINK-15424) Make all AppendingState#add respect the java doc

[ https://issues.apache.org/jira/browse/FLINK-15424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-15424: - Component/s: API / DataStream > Make all AppendingState#add respect the java

[jira] [Closed] (FLINK-10939) Add documents for natively running Flink session cluster on k8s

[ https://issues.apache.org/jira/browse/FLINK-10939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-10939. Resolution: Fixed Added on master in 0a1ac45d8b2d425c0c538b1e97729ab77024e7ad Added on

[jira] [Commented] (FLINK-15470) Remove YARN magic properties file

[ https://issues.apache.org/jira/browse/FLINK-15470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17009872#comment-17009872 ] Aljoscha Krettek commented on FLINK-15470: -- Although I would like to re

[jira] [Closed] (FLINK-15406) RocksDB savepoints with heap timers cannot be restored by non-process functions

[ https://issues.apache.org/jira/browse/FLINK-15406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-15406. Fix Version/s: 1.10.0 Resolution: Fixed Fixed on master in

[jira] [Commented] (FLINK-15424) Make all AppendingState#add respect the java doc

[ https://issues.apache.org/jira/browse/FLINK-15424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17009808#comment-17009808 ] Aljoscha Krettek commented on FLINK-15424: -- That sounds reasonable,

[jira] [Commented] (FLINK-15362) Bump Kafka client version to 2.4.0 for universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-15362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17009809#comment-17009809 ] Aljoscha Krettek commented on FLINK-15362: -- Yes, I'd say we can

[jira] [Assigned] (FLINK-15424) Make all AppendingState#add respect the java doc

[ https://issues.apache.org/jira/browse/FLINK-15424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-15424: Assignee: Congxian Qiu(klion26) > Make all AppendingState#add respect the j

[jira] [Commented] (FLINK-15290) Need a way to turn off vectorized orc reader for SQL CLI

[ https://issues.apache.org/jira/browse/FLINK-15290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008722#comment-17008722 ] Aljoscha Krettek commented on FLINK-15290: -- I don

[jira] [Assigned] (FLINK-15406) The savepoint is writted by "State Processor API" can't be restore by map or flatmap

[ https://issues.apache.org/jira/browse/FLINK-15406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-15406: Assignee: Seth Wiesman > The savepoint is writted by "State Processor AP

[jira] [Commented] (FLINK-15424) Make all AppendingState#add respect the java doc

[ https://issues.apache.org/jira/browse/FLINK-15424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008700#comment-17008700 ] Aljoscha Krettek commented on FLINK-15424: -- This is a good catch! We hav

[jira] [Commented] (FLINK-15384) Allow to pass ExecutionEnvironment/StreamExecutionEnvironment to TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-15384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008694#comment-17008694 ] Aljoscha Krettek commented on FLINK-15384: -- {{JobListener}} is n

[jira] [Assigned] (FLINK-15362) Bump Kafka client version to 2.4.0 for universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-15362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-15362: Assignee: vinoyang (was: Aljoscha Krettek) > Bump Kafka client version to 2.

[jira] [Assigned] (FLINK-15362) Bump Kafka client version to 2.4.0 for universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-15362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-15362: Assignee: Aljoscha Krettek > Bump Kafka client version to 2.4.0 for univer

[jira] [Commented] (FLINK-15362) Bump Kafka client version to 2.4.0 for universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-15362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008688#comment-17008688 ] Aljoscha Krettek commented on FLINK-15362: -- Will this have similar issue

[jira] [Commented] (FLINK-15343) Add Watermarks options for TwoInputStreamOperator

[ https://issues.apache.org/jira/browse/FLINK-15343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008685#comment-17008685 ] Aljoscha Krettek commented on FLINK-15343: -- One alternative to this is

[jira] [Commented] (FLINK-15335) add-dependencies-for-IDEA not working anymore and dangerous in general

[ https://issues.apache.org/jira/browse/FLINK-15335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008680#comment-17008680 ] Aljoscha Krettek commented on FLINK-15335: -- I agree! [~NicoK] do you m

[jira] [Updated] (FLINK-15327) 'Walkthrough DataStream Scala nightly' sometimes fails with InterruptedException

[ https://issues.apache.org/jira/browse/FLINK-15327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-15327: - Component/s: Runtime / Task > 'Walkthrough DataStream Scala nightly' so

[jira] [Commented] (FLINK-13632) Update serializer upgrade tests to restore from 1.8 and beyond

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008637#comment-17008637 ] Aljoscha Krettek commented on FLINK-13632: -- By the way, I think this is

[jira] [Commented] (FLINK-13632) Update serializer upgrade tests to restore from 1.8 and beyond

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007521#comment-17007521 ] Aljoscha Krettek commented on FLINK-13632: -- We can start porting independe

[jira] [Comment Edited] (FLINK-13632) Update serializer upgrade tests to restore from 1.8 and beyond

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007520#comment-17007520 ] Aljoscha Krettek edited comment on FLINK-13632 at 1/3/20 2:3

[jira] [Commented] (FLINK-13632) Update serializer upgrade tests to restore from 1.8 and beyond

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007520#comment-17007520 ] Aljoscha Krettek commented on FLINK-13632: -- I'm adding this as

[jira] [Created] (FLINK-15474) In TypeSerializerUpgradeTestBase, create serializer snapshots "on demand"

Aljoscha Krettek created FLINK-15474: Summary: In TypeSerializerUpgradeTestBase, create serializer snapshots "on demand" Key: FLINK-15474 URL: https://issues.apache.org/jira/browse/F

[jira] [Updated] (FLINK-13632) Update serializer upgrade tests to restore from 1.8 and beyond

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-13632: - Description: FLINK-11767 introduced a new test base ({{TypeSerializerUpgradeTestBase

[jira] [Assigned] (FLINK-13632) Update serializer upgrade tests to restore from 1.8 and beyond

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-13632: Assignee: (was: Aljoscha Krettek) > Update serializer upgrade tests

[jira] [Closed] (FLINK-11767) Introduce new TypeSerializerUpgradeTestBase, new PojoSerializerUpgradeTest

[ https://issues.apache.org/jira/browse/FLINK-11767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-11767. Resolution: Fixed This was merged in https://github.com/apache/flink/pull/10324

[jira] [Updated] (FLINK-13632) Update serializer upgrade tests to restore from 1.8 and beyond

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-13632: - Summary: Update serializer upgrade tests to restore from 1.8 and beyond (was: Update

[jira] [Updated] (FLINK-11767) Introduce new TypeSerializerUpgradeTestBase, new PojoSerializerUpgradeTest

[ https://issues.apache.org/jira/browse/FLINK-11767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-11767: - Description: Add a new test base that is more flexible and will allow us to

[jira] [Commented] (FLINK-11767) Introduce new TypeSerializerUpgradeTestBase, new PojoSerializerUpgradeTest

[ https://issues.apache.org/jira/browse/FLINK-11767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007511#comment-17007511 ] Aljoscha Krettek commented on FLINK-11767: -- I changed the title of the i

[jira] [Updated] (FLINK-11767) Introduce new TypeSerializerUpgradeTestBase, new PojoSerializerUpgradeTest

[ https://issues.apache.org/jira/browse/FLINK-11767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-11767: - Summary: Introduce new TypeSerializerUpgradeTestBase, new PojoSerializerUpgradeTest

[jira] [Updated] (FLINK-11767) Use TypeSerializerUpgradeTestBase for serializer upgrade tests, update to 1.8 and 1.9

[ https://issues.apache.org/jira/browse/FLINK-11767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-11767: - Summary: Use TypeSerializerUpgradeTestBase for serializer upgrade tests, update to 1.8

[jira] [Updated] (FLINK-11767) Update TypeSerializerSnapshotMigrationTestBase and subclasses for 1.8

[ https://issues.apache.org/jira/browse/FLINK-11767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-11767: - Affects Version/s: 1.10.0 1.9.0 > Upd

[jira] [Updated] (FLINK-11767) Update TypeSerializerSnapshotMigrationTestBase and subclasses for 1.8

[ https://issues.apache.org/jira/browse/FLINK-11767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-11767: - Parent: (was: FLINK-11756) Issue Type: Task (was: Sub-task) > Upd

[jira] [Closed] (FLINK-15297) Do not throw exception if YARN Application switched to FINISHED immediately after deployed in YarnClusterDescriptor#startAppMaster

[ https://issues.apache.org/jira/browse/FLINK-15297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-15297. Fix Version/s: (was: 1.11.0) 1.10.0 Resolution: Fixed Fixed

[jira] [Updated] (FLINK-15273) Complete and Update Documentation for 1.10

[ https://issues.apache.org/jira/browse/FLINK-15273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-15273: - Fix Version/s: 1.10.0 > Complete and Update Documentation for 1

<    9   10   11   12   13   14   15   16   17   18   >