[jira] [Commented] (FLINK-6968) Store streaming, updating tables with unique key in queryable state

[ https://issues.apache.org/jira/browse/FLINK-6968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16398000#comment-16398000 ] ASF GitHub Bot commented on FLINK-6968: --- Github user xccui commented on a diff in the pull request:

[GitHub] flink pull request #5688: [FLINK-6968][Table API & SQL] Add Queryable table ...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/5688#discussion_r174338955 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sinks/QueryableTableSink.scala --- @@ -0,0 +1,175 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-6968) Store streaming, updating tables with unique key in queryable state

[ https://issues.apache.org/jira/browse/FLINK-6968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16398001#comment-16398001 ] ASF GitHub Bot commented on FLINK-6968: --- Github user xccui commented on a diff in the pull request:

[GitHub] flink pull request #5688: [FLINK-6968][Table API & SQL] Add Queryable table ...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/5688#discussion_r174338947 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sinks/QueryableTableSink.scala --- @@ -0,0 +1,175 @@ +/* + * Licensed to

[jira] [Assigned] (FLINK-8915) CheckpointingStatisticsHandler fails to return PendingCheckpointStats

[ https://issues.apache.org/jira/browse/FLINK-8915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-8915: --- Assignee: vinoyang > CheckpointingStatisticsHandler fails to return PendingCheckpointStats >

[GitHub] flink pull request #5693: [FLINK-8938] [runtime] not remove job graph during...

GitHub user shuai-xu opened a pull request: https://github.com/apache/flink/pull/5693 [FLINK-8938] [runtime] not remove job graph during job master failover ## What is the purpose of the change *This pull request fix a bug that when job master failover, it may delete

[jira] [Commented] (FLINK-8915) CheckpointingStatisticsHandler fails to return PendingCheckpointStats

[ https://issues.apache.org/jira/browse/FLINK-8915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16398055#comment-16398055 ] vinoyang commented on FLINK-8915: - Hi [~gjy] , I just analyzed this issue. The real source is

[jira] [Created] (FLINK-8938) Not remove job graph during job master failover

shuai.xu created FLINK-8938: --- Summary: Not remove job graph during job master failover Key: FLINK-8938 URL: https://issues.apache.org/jira/browse/FLINK-8938 Project: Flink Issue Type: Bug

[GitHub] flink pull request #5688: [FLINK-6968][Table API & SQL] Add Queryable table ...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/5688#discussion_r174339296 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sinks/QueryableTableSink.scala --- @@ -0,0 +1,175 @@ +/* + * Licensed to

[GitHub] flink pull request #5688: [FLINK-6968][Table API & SQL] Add Queryable table ...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/5688#discussion_r174338968 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sinks/QueryableTableSink.scala --- @@ -0,0 +1,175 @@ +/* + * Licensed to

[GitHub] flink pull request #5688: [FLINK-6968][Table API & SQL] Add Queryable table ...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/5688#discussion_r174338993 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sinks/QueryableTableSink.scala --- @@ -0,0 +1,175 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling)

[ https://issues.apache.org/jira/browse/FLINK-8910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397998#comment-16397998 ] ASF GitHub Bot commented on FLINK-8910: --- Github user sihuazhou commented on a diff in the pull

[GitHub] flink pull request #5676: [FLINK-8910][tests] Automated end-to-end test for ...

Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/5676#discussion_r174338580 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/BackendRestorerProcedure.java --- @@ -105,6 +105,8 @@ public T

[GitHub] flink pull request #5688: [FLINK-6968][Table API & SQL] Add Queryable table ...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/5688#discussion_r174338981 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sinks/QueryableTableSink.scala --- @@ -0,0 +1,175 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-6968) Store streaming, updating tables with unique key in queryable state

[ https://issues.apache.org/jira/browse/FLINK-6968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16398018#comment-16398018 ] ASF GitHub Bot commented on FLINK-6968: --- Github user xccui commented on a diff in the pull request:

[jira] [Commented] (FLINK-6968) Store streaming, updating tables with unique key in queryable state

[ https://issues.apache.org/jira/browse/FLINK-6968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16398015#comment-16398015 ] ASF GitHub Bot commented on FLINK-6968: --- Github user xccui commented on a diff in the pull request:

[jira] [Commented] (FLINK-6968) Store streaming, updating tables with unique key in queryable state

[ https://issues.apache.org/jira/browse/FLINK-6968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16398020#comment-16398020 ] ASF GitHub Bot commented on FLINK-6968: --- Github user xccui commented on a diff in the pull request:

[jira] [Commented] (FLINK-6968) Store streaming, updating tables with unique key in queryable state

[ https://issues.apache.org/jira/browse/FLINK-6968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16398017#comment-16398017 ] ASF GitHub Bot commented on FLINK-6968: --- Github user xccui commented on a diff in the pull request:

[jira] [Commented] (FLINK-6968) Store streaming, updating tables with unique key in queryable state

[ https://issues.apache.org/jira/browse/FLINK-6968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16398016#comment-16398016 ] ASF GitHub Bot commented on FLINK-6968: --- Github user xccui commented on a diff in the pull request:

[jira] [Commented] (FLINK-6968) Store streaming, updating tables with unique key in queryable state

[ https://issues.apache.org/jira/browse/FLINK-6968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16398019#comment-16398019 ] ASF GitHub Bot commented on FLINK-6968: --- Github user xccui commented on a diff in the pull request:

[GitHub] flink pull request #5688: [FLINK-6968][Table API & SQL] Add Queryable table ...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/5688#discussion_r174339810 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/QueryableTableSinkTest.scala --- @@ -0,0 +1,102 @@ +/*

[GitHub] flink pull request #5688: [FLINK-6968][Table API & SQL] Add Queryable table ...

Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/5688#discussion_r174339658 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/QueryableTableSinkTest.scala --- @@ -0,0 +1,102 @@ +/*

[jira] [Commented] (FLINK-8862) Support HBase snapshot read

[ https://issues.apache.org/jira/browse/FLINK-8862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16398094#comment-16398094 ] ASF GitHub Bot commented on FLINK-8862: --- Github user neoremind commented on the issue:

[GitHub] flink issue #5639: [FLINK-8862] [HBase] Support HBase snapshot read

Github user neoremind commented on the issue: https://github.com/apache/flink/pull/5639 @fhueske Thanks for your response. I understand this case. Please take your time, hope this PR can be reviewed in the future and help people who needed. Thanks! ---

[jira] [Commented] (FLINK-8938) Not remove job graph during job master failover

[ https://issues.apache.org/jira/browse/FLINK-8938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16398081#comment-16398081 ] ASF GitHub Bot commented on FLINK-8938: --- GitHub user shuai-xu opened a pull request:

[jira] [Commented] (FLINK-6075) ORDER BY *time ASC

[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397950#comment-16397950 ] yinhua.dai commented on FLINK-6075: --- [~fhueske] Thanks for the explanation. So "ORDER BY" always

[GitHub] flink issue #5688: [FLINK-6968][Table API & SQL] Add Queryable table sink.

Github user liurenjie1024 commented on the issue: https://github.com/apache/flink/pull/5688 @twalthr Please help to review this. ---

[GitHub] flink issue #5663: [FLINK-8888] [Kinesis Connectors] Update the AWS SDK for ...

Github user tweise commented on the issue: https://github.com/apache/flink/pull/5663 @StephanEwen we are looking to utilize this patch to override discovery using ListShards (initially in our connector extension). I have tested the SDK version change on top of our Flink 1.4

[jira] [Commented] (FLINK-8888) Upgrade AWS SDK in flink-connector-kinesis

[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397985#comment-16397985 ] ASF GitHub Bot commented on FLINK-: --- Github user tweise commented on the issue:

[jira] [Commented] (FLINK-6968) Store streaming, updating tables with unique key in queryable state

[ https://issues.apache.org/jira/browse/FLINK-6968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397984#comment-16397984 ] ASF GitHub Bot commented on FLINK-6968: --- Github user liurenjie1024 commented on the issue:

[jira] [Commented] (FLINK-8888) Upgrade AWS SDK in flink-connector-kinesis

[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397485#comment-16397485 ] ASF GitHub Bot commented on FLINK-: --- Github user kailashhd commented on the issue:

[GitHub] flink issue #5663: [FLINK-8888] [Kinesis Connectors] Update the AWS SDK for ...

Github user kailashhd commented on the issue: https://github.com/apache/flink/pull/5663 Sorry for the delay in this. Confirming that I tested this using kinesalite and kinesis for both the consumer and producer functionality. I had some trouble when connecting this to kinesalite due

[jira] [Commented] (FLINK-6810) Add Some built-in Scalar Function supported

[ https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397512#comment-16397512 ] Fernando Díaz commented on FLINK-6810: -- Hi. I would like to work on any of these. They seem OK for a

[jira] [Commented] (FLINK-8919) Add KeyedProcessFunctionWIthCleanupState

[ https://issues.apache.org/jira/browse/FLINK-8919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397869#comment-16397869 ] ASF GitHub Bot commented on FLINK-8919: --- Github user fhueske commented on the issue:

[GitHub] flink issue #5680: [FLINK-8919] Add KeyedProcessFunctionWithCleanupState.

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/5680 Taking a step back. What's the purpose of this change? It adds a class to the `flink-table` module that is not used anywhere and not part of the public API of the Table API or SQL. Why do we

[jira] [Commented] (FLINK-6810) Add Some built-in Scalar Function supported

[ https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16397874#comment-16397874 ] Fabian Hueske commented on FLINK-6810: -- Hi [~fdiazgon], sure :). I suggest to pick one that does not

<    1   2