[jira] [Created] (FLINK-8533) Support MasterTriggerRestoreHook state reinitialization

Eron Wright created FLINK-8533: --- Summary: Support MasterTriggerRestoreHook state reinitialization Key: FLINK-8533 URL: https://issues.apache.org/jira/browse/FLINK-8533 Project: Flink Issue

[jira] [Commented] (FLINK-8533) Support MasterTriggerRestoreHook state reinitialization

[ https://issues.apache.org/jira/browse/FLINK-8533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346400#comment-16346400 ] Eron Wright commented on FLINK-8533: - This relates to [issue

[jira] [Resolved] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources

[ https://issues.apache.org/jira/browse/FLINK-8240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-8240. - Resolution: Fixed Fix Version/s: 1.5.0 Fixed in 1.5:

[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources

[ https://issues.apache.org/jira/browse/FLINK-8240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346669#comment-16346669 ] ASF GitHub Bot commented on FLINK-8240: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5374: [FLINK-8101][flink-connectors] Elasticsearch 5.3+ ...

Github user yew1eb commented on a diff in the pull request: https://github.com/apache/flink/pull/5374#discussion_r165032079 --- Diff: flink-connectors/flink-connector-elasticsearch5.3/src/main/java/org/apache/flink/streaming/connectors/elasticsearch53/BulkProcessorIndexer.java ---

[GitHub] flink pull request #5374: [FLINK-8101][flink-connectors] Elasticsearch 5.3+ ...

Github user yew1eb commented on a diff in the pull request: https://github.com/apache/flink/pull/5374#discussion_r165035180 --- Diff: flink-connectors/flink-connector-elasticsearch5.3/src/main/java/org/apache/flink/streaming/connectors/elasticsearch53/Elasticsearch53ApiCallBridge.java

[jira] [Commented] (FLINK-6004) Allow FlinkKinesisConsumer to skip corrupted messages

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

[jira] [Resolved] (FLINK-8492) Improve cost estimation for Calcs

[ https://issues.apache.org/jira/browse/FLINK-8492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-8492. - Resolution: Fixed Fix Version/s: 1.5.0 Fixed in 1.5:

[GitHub] flink issue #5327: [FLINK-8428] [table] Implement stream-stream non-window l...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5327 Thanks for the reminder @hequn8128. I will review it in the next 2 weeks. If not, feel free to ping me again. ---

[jira] [Commented] (FLINK-8428) Implement stream-stream non-window left outer join

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

[jira] [Commented] (FLINK-8230) NPE in OrcRowInputFormat on nested structs

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

[jira] [Resolved] (FLINK-8230) NPE in OrcRowInputFormat on nested structs

[ https://issues.apache.org/jira/browse/FLINK-8230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-8230. - Resolution: Fixed Fixed in 1.5.0: bcead3be32c624008730555d828fd8e9447fbeff Fixed in 1.4.1:

[GitHub] flink pull request #5269: [FLINK-6004] [kinesis] Allow FlinkKinesisConsumer ...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5269#discussion_r165038908 --- Diff: flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcherTest.java ---

[jira] [Commented] (FLINK-6004) Allow FlinkKinesisConsumer to skip corrupted messages

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

[jira] [Commented] (FLINK-6004) Allow FlinkKinesisConsumer to skip corrupted messages

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

[GitHub] flink issue #5269: [FLINK-6004] [kinesis] Allow FlinkKinesisConsumer to skip...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5269 @zentol I've rebased, and adding a warning when skipping records. Could you have another quick look? ---

[jira] [Commented] (FLINK-4812) Report Watermark metrics in all operators

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

[GitHub] flink issue #5155: [FLINK-4812][metrics] Expose currentLowWatermark for all ...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5155 @aljoscha I've implemented your suggestion, in hindsight that's a rather obvious solution isn't it. Also rebased the branch. ---

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

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

[GitHub] flink issue #5373: [FLINK-8230] [orc] Fix NPEs when reading nested columns.

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5373 Thank you @fhueske. The changes look good. I will merge this... ---

[GitHub] flink pull request #5373: [FLINK-8230] [orc] Fix NPEs when reading nested co...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5373 ---

[jira] [Commented] (FLINK-6571) InfiniteSource in SourceStreamOperatorTest should deal with InterruptedExceptions

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

[GitHub] flink issue #5163: [FLINK-8254][REST][docs] Bandaid generated documentation

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5163 at this point we may just as well wait for the next flink-shaded release ---

[GitHub] flink pull request #5163: [FLINK-8254][REST][docs] Bandaid generated documen...

Github user zentol closed the pull request at: https://github.com/apache/flink/pull/5163 ---

[jira] [Commented] (FLINK-8254) REST API documentation wonky due to shading

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

[GitHub] flink pull request #5240: [FLINK-8240] [table] Create unified interfaces to ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5240 ---

[GitHub] flink issue #5240: [FLINK-8240] [table] Create unified interfaces to configu...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5240 Thanks for the review @fhueske. I will merge this now. We definitely need follow-up issues for this. ---

[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources

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

[GitHub] flink issue #5269: [FLINK-6004] [kinesis] Allow FlinkKinesisConsumer to skip...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5269 looks good, +1 ---

[jira] [Commented] (FLINK-8419) Kafka consumer's offset metrics are not registered for dynamically discovered partitions

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

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r165048556 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@ -1041,7

[GitHub] flink issue #5316: [FLINK-8022][kafka-tests] Disable at-least-once tests for...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5316 I agree with @pnowojski here. I think we should proceed with merging this to test stability, and keep an eye on whether or not this is also failing for 0.10 / 0.11. If yes, then there could

[GitHub] flink issue #5145: [FLINK-8230] [ORC] Improved mapping of Orc records to Fli...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5145 Thank you for your PR @packet23. I hope #5373 could solve FLINK-8230. Can you close this PR? ---

[GitHub] flink pull request #5394: [FLINK-6571][tests] Catch InterruptedException in ...

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5394 [FLINK-6571][tests] Catch InterruptedException in StreamSourceOperato… ## What is the purpose of the change This PR resolves a test instability in the StreamSourceOperatorTest, where the

[jira] [Updated] (FLINK-6571) InfiniteSource in SourceStreamOperatorTest should deal with InterruptedExceptions

[ https://issues.apache.org/jira/browse/FLINK-6571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6571: Affects Version/s: 1.5.0 > InfiniteSource in SourceStreamOperatorTest should deal with >

[jira] [Assigned] (FLINK-6571) InfiniteSource in SourceStreamOperatorTest should deal with InterruptedExceptions

[ https://issues.apache.org/jira/browse/FLINK-6571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-6571: --- Assignee: Chesnay Schepler > InfiniteSource in SourceStreamOperatorTest should deal

[jira] [Updated] (FLINK-6571) InfiniteSource in SourceStreamOperatorTest should deal with InterruptedExceptions

[ https://issues.apache.org/jira/browse/FLINK-6571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6571: Fix Version/s: 1.5.0 > InfiniteSource in SourceStreamOperatorTest should deal with >

[jira] [Updated] (FLINK-8526) When use parallelism equals to half of the number of cpu, join and shuffle operators will easly cause deadlock.

[ https://issues.apache.org/jira/browse/FLINK-8526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8526: Component/s: (was: Java API) (was: Cluster Management)

[jira] [Created] (FLINK-8536) Improve CSVTableSourceFactory to support all descriptor properties

Timo Walther created FLINK-8536: --- Summary: Improve CSVTableSourceFactory to support all descriptor properties Key: FLINK-8536 URL: https://issues.apache.org/jira/browse/FLINK-8536 Project: Flink

[GitHub] flink issue #5269: [FLINK-6004] [kinesis] Allow FlinkKinesisConsumer to skip...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5269 @zentol The contract is that if `KinesisDeserializationSchema.deserialize()` returns `null`, that record will be skipped. I agree it makes sense to have a add a warning log if this happens.

[jira] [Commented] (FLINK-6004) Allow FlinkKinesisConsumer to skip corrupted messages

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

[jira] [Commented] (FLINK-8492) [FLINK-8492][table] Fix calc cost bug

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

[jira] [Commented] (FLINK-8489) Data is not emitted by second ElasticSearch connector

[ https://issues.apache.org/jira/browse/FLINK-8489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346810#comment-16346810 ] Chesnay Schepler commented on FLINK-8489: - Potential fix merged to master in

[GitHub] flink pull request #2422: FLINK-4499: [WIP] Introduce findbugs maven plugin

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2422 ---

[GitHub] flink pull request #5208: [FLINK-8265] [Mesos] Missing jackson dependency fo...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5208 ---

[GitHub] flink pull request #5378: [FLINK-8489][ES] Prevent side-effects when modifyi...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5378 ---

[GitHub] flink pull request #3478: Flink 4816 Executions failed from "DEPLOYING" shou...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3478 ---

[jira] [Closed] (FLINK-8422) Checkstyle for org.apache.flink.api.java.tuple

[ https://issues.apache.org/jira/browse/FLINK-8422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8422. --- Resolution: Fixed Fix Version/s: 1.5.0 master:

[jira] [Commented] (FLINK-8484) Kinesis consumer re-reads closed shards on job restart

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

[GitHub] flink pull request #5292: [FLINK-8422] [core] Checkstyle for org.apache.flin...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5292 ---

[GitHub] flink pull request #5343: [FLINK-8496][metrics] Create missing "Network" gro...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5343 ---

[jira] [Commented] (FLINK-8422) Checkstyle for org.apache.flink.api.java.tuple

[ https://issues.apache.org/jira/browse/FLINK-8422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346817#comment-16346817 ] ASF GitHub Bot commented on FLINK-8422: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-4499) Introduce findbugs maven plugin

[ https://issues.apache.org/jira/browse/FLINK-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346816#comment-16346816 ] ASF GitHub Bot commented on FLINK-4499: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8489) Data is not emitted by second ElasticSearch connector

[ https://issues.apache.org/jira/browse/FLINK-8489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346813#comment-16346813 ] ASF GitHub Bot commented on FLINK-8489: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-4034) Dependency convergence on com.101tec:zkclient and com.esotericsoftware.kryo:kryo

[ https://issues.apache.org/jira/browse/FLINK-4034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346815#comment-16346815 ] ASF GitHub Bot commented on FLINK-4034: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8265) Missing jackson dependency for flink-mesos

[ https://issues.apache.org/jira/browse/FLINK-8265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346814#comment-16346814 ] ASF GitHub Bot commented on FLINK-8265: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8496) WebUI does not display TM MemorySegment metrics

[ https://issues.apache.org/jira/browse/FLINK-8496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346818#comment-16346818 ] ASF GitHub Bot commented on FLINK-8496: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #2192: Flink 4034 Maven dependency convergence

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2192 ---

[GitHub] flink pull request #5305: Release 1.3

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5305 ---

[GitHub] flink pull request #4847: [hotfix][doc]CEP docs review to remove weasel word...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4847 ---

[jira] [Created] (FLINK-8535) Implement a basic set of table source factories

Timo Walther created FLINK-8535: --- Summary: Implement a basic set of table source factories Key: FLINK-8535 URL: https://issues.apache.org/jira/browse/FLINK-8535 Project: Flink Issue Type: New

[jira] [Created] (FLINK-8537) Add a Kafka table source factory with Avro format support

Timo Walther created FLINK-8537: --- Summary: Add a Kafka table source factory with Avro format support Key: FLINK-8537 URL: https://issues.apache.org/jira/browse/FLINK-8537 Project: Flink Issue

[jira] [Commented] (FLINK-8101) Elasticsearch 6.x support

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

[GitHub] flink issue #5269: [FLINK-6004] [kinesis] Allow FlinkKinesisConsumer to skip...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5269 Thanks, merging .. ---

[jira] [Updated] (FLINK-8492) Improve cost estimation for Calcs

[ https://issues.apache.org/jira/browse/FLINK-8492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8492: Summary: Improve cost estimation for Calcs (was: [FLINK-8492][table] Fix calc cost bug) > Improve

[jira] [Commented] (FLINK-8230) NPE in OrcRowInputFormat on nested structs

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

[jira] [Commented] (FLINK-8230) NPE in OrcRowInputFormat on nested structs

[ https://issues.apache.org/jira/browse/FLINK-8230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346846#comment-16346846 ] ASF GitHub Bot commented on FLINK-8230: --- Github user asfgit closed the pull request at:

[GitHub] flink issue #5155: [FLINK-4812][metrics] Expose currentLowWatermark for all ...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5155 I think this looks very good, then. Thanks! 👍 ---

[jira] [Commented] (FLINK-8398) Stabilize flaky KinesisDataFetcherTests

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

[jira] [Commented] (FLINK-7923) SQL parser exception when accessing subfields of a Composite element in an Object Array type column

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

[GitHub] flink issue #5337: [FLINK-8484][flink-kinesis-connector] Ensure a Kinesis co...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5337 @pluppens the changes look good to merge! Thanks a lot for working on this. Will merge this for `release-1.4`, `release-1.3`, and `master` .. ---

[jira] [Commented] (FLINK-8384) Session Window Assigner with Dynamic Gaps

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

[jira] [Created] (FLINK-8538) Add a Kafka table source factory with JSON format support

Timo Walther created FLINK-8538: --- Summary: Add a Kafka table source factory with JSON format support Key: FLINK-8538 URL: https://issues.apache.org/jira/browse/FLINK-8538 Project: Flink Issue

[jira] [Commented] (FLINK-8101) Elasticsearch 6.x support

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

[GitHub] flink pull request #5370: [hotfix] [table] Fix IndexOutOfBoundsException in ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5370 ---

[GitHub] flink issue #5268: [FLINK-8398] [kinesis, tests] Harden KinesisDataFetcherTe...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5268 Thanks for the review @zentol. Will rebase, address your comment, and then merge. ---

[GitHub] flink issue #5347: [FLINK-8492][table] Fix calc cost bug

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5347 Thanks @hequn8128 and @fhueske. I will merge this... ---

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

[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-8538: -- Assignee: Xingcan Cui > Add a Kafka table source factory with JSON format support >

[jira] [Commented] (FLINK-8409) Race condition in KafkaConsumerThread leads to potential NPE

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

[GitHub] flink issue #5329: [FLINK-8409] [kafka] Fix potential NPE in KafkaConsumerTh...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5329 Merging ... ---

[jira] [Commented] (FLINK-8042) Retry individual failover-strategy for some time first before reverting to full job restart

[ https://issues.apache.org/jira/browse/FLINK-8042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346773#comment-16346773 ] Till Rohrmann commented on FLINK-8042: -- I think one way to tackle this problem is to enhance the

[jira] [Commented] (FLINK-8254) REST API documentation wonky due to shading

[ https://issues.apache.org/jira/browse/FLINK-8254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346888#comment-16346888 ] ASF GitHub Bot commented on FLINK-8254: --- Github user zentol closed the pull request at:

[GitHub] flink issue #5295: [FLINK-8384] [streaming] Session Window Assigner with Dyn...

Github user dyanarose commented on the issue: https://github.com/apache/flink/pull/5295 I'm not the biggest fan of unchecked casts, but testing this in our POC environment casting the existing EventTimeTrigger to a typed Trigger is working. So if the unchecked cast is

[GitHub] flink pull request #5269: [FLINK-6004] [kinesis] Allow FlinkKinesisConsumer ...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5269#discussion_r165039352 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java --- @@

[GitHub] flink pull request #5367: [FLINK-7923][Table API & SQL] Support field access...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/5367#discussion_r165038256 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/stream/sql/CalcTest.scala --- @@ -0,0 +1,47 @@ +/* + * Licensed to

[GitHub] flink pull request #5367: [FLINK-7923][Table API & SQL] Support field access...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/5367#discussion_r165039357 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/ScalarOperators.scala --- @@ -984,6 +987,63 @@ object

[jira] [Commented] (FLINK-7923) SQL parser exception when accessing subfields of a Composite element in an Object Array type column

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

[jira] [Commented] (FLINK-8308) Update yajl-ruby dependency to 1.3.1 or higher

[ https://issues.apache.org/jira/browse/FLINK-8308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346827#comment-16346827 ] Ufuk Celebi commented on FLINK-8308: A naive question first: would we notice any breaking changes

[jira] [Commented] (FLINK-8308) Update yajl-ruby dependency to 1.3.1 or higher

[ https://issues.apache.org/jira/browse/FLINK-8308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346841#comment-16346841 ] Fabian Hueske commented on FLINK-8308: -- I don't see a problem in updating the dependencies since this

[jira] [Commented] (FLINK-8267) update Kinesis Producer example for setting Region key

[ https://issues.apache.org/jira/browse/FLINK-8267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346869#comment-16346869 ] Tzu-Li (Gordon) Tai commented on FLINK-8267: I want to reconfirm a few points here. First of

[jira] [Comment Edited] (FLINK-8267) update Kinesis Producer example for setting Region key

[ https://issues.apache.org/jira/browse/FLINK-8267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346869#comment-16346869 ] Tzu-Li (Gordon) Tai edited comment on FLINK-8267 at 1/31/18 1:59 PM: -

[jira] [Commented] (FLINK-4812) Report Watermark metrics in all operators

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

[jira] [Commented] (FLINK-6004) Allow FlinkKinesisConsumer to skip corrupted messages

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

[jira] [Commented] (FLINK-6004) Allow FlinkKinesisConsumer to skip corrupted messages

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

[GitHub] flink pull request #5335: (master) [FLINK-8419] [kafka] Register metrics for...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5335#discussion_r165045598 --- Diff: flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java --- @@ -95,21

[jira] [Commented] (FLINK-8492) Improve cost estimation for Calcs

[ https://issues.apache.org/jira/browse/FLINK-8492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346790#comment-16346790 ] ASF GitHub Bot commented on FLINK-8492: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5347: [FLINK-8492][table] Fix calc cost bug

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5347 ---

[jira] [Closed] (FLINK-8496) WebUI does not display TM MemorySegment metrics

[ https://issues.apache.org/jira/browse/FLINK-8496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8496. --- Resolution: Fixed Fix Version/s: 1.4.1 1.5.0 master:

[jira] [Commented] (FLINK-8022) Kafka at-least-once tests fail occasionally

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

[jira] [Comment Edited] (FLINK-8267) update Kinesis Producer example for setting Region key

[ https://issues.apache.org/jira/browse/FLINK-8267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346869#comment-16346869 ] Tzu-Li (Gordon) Tai edited comment on FLINK-8267 at 1/31/18 2:00 PM: -

  1   2   3   4   >