[
https://issues.apache.org/jira/browse/HBASE-20889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated HBASE-20889:
---
Status: Patch Available (was: Open)
> PE scan is failing with NullPoin
[
https://issues.apache.org/jira/browse/HBASE-20889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16544531#comment-16544531
]
Ted Yu edited comment on HBASE-20889 at 7/15/18 11:54 AM:
--
Around line 1540
[
https://issues.apache.org/jira/browse/HBASE-20889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16544531#comment-16544531
]
Ted Yu commented on HBASE-20889:
I looked at PerformanceEvaluation.java in branch-1.3 but the line
[
https://issues.apache.org/jira/browse/HBASE-20889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16544527#comment-16544527
]
Ted Yu edited comment on HBASE-20889 at 7/15/18 11:38 AM:
--
In 2.0, I ran first
[
https://issues.apache.org/jira/browse/HBASE-20889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16544527#comment-16544527
]
Ted Yu commented on HBASE-20889:
In 2.0, the above command gave me:
{code
[
https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16544346#comment-16544346
]
Ted Yu commented on KAFKA-7149:
---
Took a look at AssignmentInfo#writeTopicPartitions where :
{code
McCabe, wrote:
>
> > Good point. We should probably have a maximum number of results like
> > 1000 or something. That can go in the request RPC as well...
> > Cheers,
> > Colin
> >
> > On Fri, Jul 13, 2018, at 18:15, Ted Yu wrote:
> > > bq. describe topic
, the notion of null value support would be conveyed to user in
a friendly manner.
Cheers
On Fri, Jul 13, 2018 at 5:51 PM Colin McCabe wrote:
> On Fri, Jul 13, 2018, at 17:45, Ted Yu wrote:
>
> Looking at modifyConfigs API, it doesn't seem that ConcurrentHashMap
> should be used as th
bq. describe topics by a regular expression on the server side
Should caution be taken if the regex doesn't filter ("*") ?
Cheers
On Fri, Jul 13, 2018 at 6:02 PM Colin McCabe wrote:
> As Jason wrote, this won't scale as the number of partitions increases.
> We already have users who have tens
in
>
> On Wed, Jul 11, 2018, at 21:28, Ted Yu wrote:
> > bq. Map changes, Set
> removals,
> >
> > Is it possible to combine the two parameters into one Map where null
> Config
> > value signifies removal of config ?
> > This way, the following
Ted Yu created PHOENIX-4813:
---
Summary: Support getActiveGeneralRpcHandlerCount in
PhoenixRpcScheduler
Key: PHOENIX-4813
URL: https://issues.apache.org/jira/browse/PHOENIX-4813
Project: Phoenix
Ted Yu created KYLIN-3450:
-
Summary: Consider using google re2j
Key: KYLIN-3450
URL: https://issues.apache.org/jira/browse/KYLIN-3450
Project: Kylin
Issue Type: Improvement
Reporter: Ted
Ted Yu created KYLIN-3450:
-
Summary: Consider using google re2j
Key: KYLIN-3450
URL: https://issues.apache.org/jira/browse/KYLIN-3450
Project: Kylin
Issue Type: Improvement
Reporter: Ted
[
https://issues.apache.org/jira/browse/HBASE-20879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated HBASE-20879:
---
Resolution: Fixed
Hadoop Flags: Reviewed
Fix Version/s: 2.2.0
Status: Resolved
[
https://issues.apache.org/jira/browse/HBASE-20672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated HBASE-20672:
---
Status: Patch Available (was: Reopened)
> Create new HBase metrics ReadRequestRate and WriteRequestR
[
https://issues.apache.org/jira/browse/HBASE-15320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16543540#comment-16543540
]
Ted Yu commented on HBASE-15320:
Attaching patch v16 from review board.
> HBase connector for Ka
[
https://issues.apache.org/jira/browse/HBASE-15320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated HBASE-15320:
---
Attachment: 15320.master.16.patch
> HBase connector for Kafka Conn
Ted Yu created FLINK-9849:
-
Summary: Upgrade hbase version to 2.0.1 for hbase connector
Key: FLINK-9849
URL: https://issues.apache.org/jira/browse/FLINK-9849
Project: Flink
Issue Type: Improvement
Ted Yu created FLINK-9849:
-
Summary: Upgrade hbase version to 2.0.1 for hbase connector
Key: FLINK-9849
URL: https://issues.apache.org/jira/browse/FLINK-9849
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/BAHIR-173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16543417#comment-16543417
]
Ted Yu commented on BAHIR-173:
--
Currently I saw:
{code}
[ERROR] warning: [options] bootstrap class path
Ted Yu created BAHIR-173:
Summary: Upgrade bahir-flink to support Flink 1.5.1
Key: BAHIR-173
URL: https://issues.apache.org/jira/browse/BAHIR-173
Project: Bahir
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/HBASE-20869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16543378#comment-16543378
]
Ted Yu commented on HBASE-20869:
lgtm
> Endpoint-based Export use incorrect user to wr
[
https://issues.apache.org/jira/browse/HBASE-20865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated HBASE-20865:
---
Resolution: Fixed
Hadoop Flags: Reviewed
Fix Version/s: (was: 2.0.2)
Status
Putting dev@ to bcc.
Which hbase-spark connector are you using ?
What's the hbase release in your deployment ?
bq. some of the columns in dataframe becomes null
Is it possible to characterize what type of columns become null ? Earlier
you said one column has xml data. Did you mean this column
Putting dev@ to bcc.
Which hbase-spark connector are you using ?
What's the hbase release in your deployment ?
bq. some of the columns in dataframe becomes null
Is it possible to characterize what type of columns become null ? Earlier
you said one column has xml data. Did you mean this column
[
https://issues.apache.org/jira/browse/HBASE-20866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16542870#comment-16542870
]
Ted Yu commented on HBASE-20866:
Thanks for the new performance numbers.
Have a nice weekend.
> HB
[
https://issues.apache.org/jira/browse/HBASE-20879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated HBASE-20879:
---
Reporter: Tushar (was: Tushar Sharma)
> Compacting memstore config should handle lower c
[
https://issues.apache.org/jira/browse/HBASE-20866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16542490#comment-16542490
]
Ted Yu commented on HBASE-20866:
If you can obtain performance result for RandomSeekScanTest
[
https://issues.apache.org/jira/browse/AMBARI-23288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated AMBARI-23288:
Description:
{code}
CloudSolrClient stateWatcherClient = createSolrClient();
{code
[
https://issues.apache.org/jira/browse/AMBARI-24032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated AMBARI-24032:
Description:
For hbase config changes that only involve hbase master, Ambari should
explicitly say so
[
https://issues.apache.org/jira/browse/AMBARI-23287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated AMBARI-23287:
Description:
HostResourceProvider#processDeleteHostRequests accesses topologyHolder without
any
[
https://issues.apache.org/jira/browse/HBASE-20865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16542388#comment-16542388
]
Ted Yu commented on HBASE-20865:
[~Apache9]:
Can you help integrate to 2.x.y branches
[
https://issues.apache.org/jira/browse/HBASE-20053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated HBASE-20053:
---
Labels: build (was: )
> Remove .cmake file extension from .gitign
Ted Yu created KYLIN-3447:
-
Summary: Upgrade zookeeper to 3.4.13
Key: KYLIN-3447
URL: https://issues.apache.org/jira/browse/KYLIN-3447
Project: Kylin
Issue Type: Improvement
Reporter
Ted Yu created KYLIN-3447:
-
Summary: Upgrade zookeeper to 3.4.13
Key: KYLIN-3447
URL: https://issues.apache.org/jira/browse/KYLIN-3447
Project: Kylin
Issue Type: Improvement
Reporter
[
https://issues.apache.org/jira/browse/HBASE-20734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16542168#comment-16542168
]
Ted Yu commented on HBASE-20734:
I ran the unit tests touched by the patch.
There were a few test
[
https://issues.apache.org/jira/browse/HBASE-20734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16542158#comment-16542158
]
Ted Yu commented on HBASE-20734:
{code}
+ private FileSystem walFS;
{code}
Maybe put the above field
[
https://issues.apache.org/jira/browse/HBASE-20880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated HBASE-20880:
---
Resolution: Fixed
Hadoop Flags: Reviewed
Fix Version/s: 3.0.0
Status: Resolved
[
https://issues.apache.org/jira/browse/HBASE-20880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16541996#comment-16541996
]
Ted Yu commented on HBASE-20880:
Compiled with patch where warning disappeared.
> Fix for warn
[
https://issues.apache.org/jira/browse/HBASE-20244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated HBASE-20244:
---
Release Note:
HDFS-12574 made an incompatible change to HdfsKMSUtil with different method
signature
[
https://issues.apache.org/jira/browse/HBASE-20879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated HBASE-20879:
---
Attachment: 20879.v2.txt
> Compacting memstore config should handle lower c
[
https://issues.apache.org/jira/browse/HBASE-20879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated HBASE-20879:
---
Status: Patch Available (was: Open)
> Compacting memstore config should handle lower c
[
https://issues.apache.org/jira/browse/HBASE-20879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16541857#comment-16541857
]
Ted Yu commented on HBASE-20879:
Without the fix, the test fails with:
{code
Ted Yu created HBASE-20879:
--
Summary: Compacting memstore config should handle lower case
Key: HBASE-20879
URL: https://issues.apache.org/jira/browse/HBASE-20879
Project: HBase
Issue Type: Bug
Ted Yu created HBASE-20879:
--
Summary: Compacting memstore config should handle lower case
Key: HBASE-20879
URL: https://issues.apache.org/jira/browse/HBASE-20879
Project: HBase
Issue Type: Bug
bq. Map changes, Set removals,
Is it possible to combine the two parameters into one Map where null Config
value signifies removal of config ?
This way, the following wouldn't occur (reducing un-intended config
removal):
bq. If a configuration key is specified in both *changes* and
Ted Yu created KYLIN-3445:
-
Summary: Upgrade checkstyle version to 8.6
Key: KYLIN-3445
URL: https://issues.apache.org/jira/browse/KYLIN-3445
Project: Kylin
Issue Type: Improvement
Ted Yu created KYLIN-3445:
-
Summary: Upgrade checkstyle version to 8.6
Key: KYLIN-3445
URL: https://issues.apache.org/jira/browse/KYLIN-3445
Project: Kylin
Issue Type: Improvement
Ted Yu created FLINK-9825:
-
Summary: Upgrade checkstyle version to 8.6
Key: FLINK-9825
URL: https://issues.apache.org/jira/browse/FLINK-9825
Project: Flink
Issue Type: Improvement
Ted Yu created FLINK-9825:
-
Summary: Upgrade checkstyle version to 8.6
Key: FLINK-9825
URL: https://issues.apache.org/jira/browse/FLINK-9825
Project: Flink
Issue Type: Improvement
t of this change is worth the effort to deprecate the
> old config. Maybe we should do it separately if more people thing it is
> necessary?
>
> On Wed, Jul 11, 2018 at 8:01 PM, Ted Yu wrote:
>
> > bq. "--config-file" in ConfigCommand.
> >
> > Please update t
e updated the KIP as suggested.
>
> Thanks,
> Dong
>
> On Wed, Jul 11, 2018 at 5:57 PM, Ted Yu wrote:
>
> > Looking at StreamsResetter.java :
> >
> >commandConfigOption = optionParser.accepts("config-file",
> "Property
> > f
[
https://issues.apache.org/jira/browse/HBASE-20865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16541067#comment-16541067
]
Ted Yu commented on HBASE-20865:
lgtm
[~Apache9]:
Can you take a look as well ?
> CreateTableProced
Ted Yu created FLINK-9824:
-
Summary: Support IPv6 literal
Key: FLINK-9824
URL: https://issues.apache.org/jira/browse/FLINK-9824
Project: Flink
Issue Type: Bug
Reporter: Ted Yu
Ted Yu created FLINK-9824:
-
Summary: Support IPv6 literal
Key: FLINK-9824
URL: https://issues.apache.org/jira/browse/FLINK-9824
Project: Flink
Issue Type: Bug
Reporter: Ted Yu
Looking at StreamsResetter.java :
commandConfigOption = optionParser.accepts("config-file", "Property
file containing configs to be passed to admin cl
Not sure you have considered naming the option in the above fashion.
Probably add the above to Alternative section.
Cheers
On Wed, Jul
[
https://issues.apache.org/jira/browse/HBASE-20859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated HBASE-20859:
---
Resolution: Fixed
Status: Resolved (was: Patch Available)
Thanks for the patch, Wei-Chiu
Thanks
[
https://issues.apache.org/jira/browse/HBASE-20870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540905#comment-16540905
]
Ted Yu commented on HBASE-20870:
lgtm, assuming you have tested on cluster.
> Wrong HBase root
Please see for subscription information:
http://hbase.apache.org/mail-lists.html
On Wed, Jul 11, 2018 at 4:19 AM bill.zhou wrote:
> I am a subscriber please add me thanks
>
>
[
https://issues.apache.org/jira/browse/ZOOKEEPER-1859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated ZOOKEEPER-1859:
--
Description:
{code}
final PrintWriter pwriter = new PrintWriter(
new
[
https://issues.apache.org/jira/browse/HBASE-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated HBASE-20578:
---
Component/s: rsgroup
> Support region server group in target clus
[
https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-9675:
--
Description:
They rely on finalizers (before Java 11), which create unnecessary GC load.
The alternatives
[
https://issues.apache.org/jira/browse/FLINK-9735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540754#comment-16540754
]
Ted Yu commented on FLINK-9735:
---
Short term, we should fix the leaked DBOptions instance.
> Potent
[
https://issues.apache.org/jira/browse/HBASE-20866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540742#comment-16540742
]
Ted Yu commented on HBASE-20866:
Vikas:
Can you include trivial change to hbase-server module so
[
https://issues.apache.org/jira/browse/HBASE-20734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16540733#comment-16540733
]
Ted Yu commented on HBASE-20734:
If it is not too much trouble, can you base patch on master branch
[
https://issues.apache.org/jira/browse/HBASE-20868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539659#comment-16539659
]
Ted Yu commented on HBASE-20868:
lgtm
> Fix TestCheckTestClasses on HBASE-18
+1
Ran thru test suite.
Checked signatures.
On Tue, Jul 10, 2018 at 10:17 AM Rajini Sivaram
wrote:
> Hello Kafka users, developers and client-developers,
>
>
> This is the third candidate for release of Apache Kafka 2.0.0.
>
>
> This is a major version release of Apache Kafka. It includes 40
[
https://issues.apache.org/jira/browse/HBASE-20855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538493#comment-16538493
]
Ted Yu commented on HBASE-20855:
>From
>https://builds.apache.org/job/PreCommit-HBASE-Build
[
https://issues.apache.org/jira/browse/KAFKA-5846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16191405#comment-16191405
]
Ted Yu edited comment on KAFKA-5846 at 7/10/18 12:16 PM:
-
+1 from me
[
https://issues.apache.org/jira/browse/KAFKA-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-5943:
--
Description:
Currently connector tests make heavy use of mock (easymock, power mock).
This may hide the real
[
https://issues.apache.org/jira/browse/FLINK-6105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16307281#comment-16307281
]
Ted Yu edited comment on FLINK-6105 at 7/10/18 11:55 AM:
-
In
flink-connectors
[
https://issues.apache.org/jira/browse/FLINK-9340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-9340:
--
Labels: runtime (was: )
> ScheduleOrUpdateConsumersTest may fail with Address already in
[
https://issues.apache.org/jira/browse/HBASE-20866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538417#comment-16538417
]
Ted Yu commented on HBASE-20866:
Nice findings, Vikas.
Looking forward to the patch.
> HBase 1.x s
[
https://issues.apache.org/jira/browse/HBASE-20836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16537652#comment-16537652
]
Ted Yu commented on HBASE-20836:
Zack:
Please integrate the patch yourself, with signoff from me
[
https://issues.apache.org/jira/browse/HBASE-20860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16536935#comment-16536935
]
Ted Yu commented on HBASE-20860:
{code}
+ private void cleanRITRegion(final MasterProcedureEnv env
+1
Ran test suite.
Checked signatures.
On Sun, Jul 8, 2018 at 3:36 PM Dong Lin wrote:
> Hello Kafka users, developers and client-developers,
>
> This is the fourth candidate for release of Apache Kafka 1.1.1.
>
> Apache Kafka 1.1.1 is a bug-fix release for the 1.1 branch that was first
>
+1
Ran test suite.
Checked signatures.
On Sun, Jul 8, 2018 at 3:36 PM Dong Lin wrote:
> Hello Kafka users, developers and client-developers,
>
> This is the fourth candidate for release of Apache Kafka 1.1.1.
>
> Apache Kafka 1.1.1 is a bug-fix release for the 1.1 branch that was first
>
[
https://issues.apache.org/jira/browse/HBASE-20836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16536427#comment-16536427
]
Ted Yu commented on HBASE-20836:
lgtm
> Add Yetus annotation for ReadReplicaClustersTableNameU
[
https://issues.apache.org/jira/browse/HBASE-20257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16536385#comment-16536385
]
Ted Yu commented on HBASE-20257:
[~busbey]:
Can you take another look ?
> hbase-spark should not dep
[
https://issues.apache.org/jira/browse/HBASE-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16536384#comment-16536384
]
Ted Yu commented on HBASE-20578:
Albert:
Is there any issue that blocks you ?
Thanks
> Support reg
[
https://issues.apache.org/jira/browse/KAFKA-5946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16392411#comment-16392411
]
Ted Yu edited comment on KAFKA-5946 at 7/8/18 1:03 PM:
---
Thanks for taking
[
https://issues.apache.org/jira/browse/KAFKA-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved KAFKA-6335.
---
Resolution: Cannot Reproduce
> SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fa
[
https://issues.apache.org/jira/browse/HBASE-20859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated HBASE-20859:
---
Affects Version/s: (was: 2.0.0)
Hadoop Flags: Reviewed
Fix Version/s: 3.0.0
> Bac
[
https://issues.apache.org/jira/browse/HBASE-20859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16535977#comment-16535977
]
Ted Yu commented on HBASE-20859:
lgtm
> Backup and incremental load could fail in secure clust
[
https://issues.apache.org/jira/browse/HBASE-20859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16535766#comment-16535766
]
Ted Yu commented on HBASE-20859:
Without fix, the following fails:
{code}
Assert.assertTrue
[
https://issues.apache.org/jira/browse/HBASE-20859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16535758#comment-16535758
]
Ted Yu commented on HBASE-20859:
Nice discovery.
Please add license header to TestBackupUtils.
Thanks
+1
Checked signatures of artifacts
Ran test suite
On Fri, Jul 6, 2018 at 11:42 AM Yaz Sh wrote:
> +1
>
> Tests have been done on OS X
>
> - Ran in cluster mode ./bin/start-cluster.sh
> - Checked that *.out files are empty
> - Stopped cluster ./bin/stop-cluster.sh
> - Checked for No Exceptions
[
https://issues.apache.org/jira/browse/HBASE-20854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated HBASE-20854:
---
Summary: Wrong retries number in RpcRetryingCaller's log message (was:
Wrong retires
[
https://issues.apache.org/jira/browse/HBASE-20854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16534585#comment-16534585
]
Ted Yu commented on HBASE-20854:
lgtm
> Wrong retries number in RpcRetryingCaller's log mess
Have you tried increasing the request.timeout.ms parameter (Kafka) ?
Which Flink / Kafka release are you using ?
Cheers
On Thu, Jul 5, 2018 at 5:39 AM Amol S - iProgrammer
wrote:
> Hello,
>
> I am using flink with kafka and getting below exception.
>
>
Have you tried increasing the request.timeout.ms parameter (Kafka) ?
Which Flink / Kafka release are you using ?
Cheers
On Thu, Jul 5, 2018 at 5:39 AM Amol S - iProgrammer
wrote:
> Hello,
>
> I am using flink with kafka and getting below exception.
>
>
[
https://issues.apache.org/jira/browse/HBASE-20845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533257#comment-16533257
]
Ted Yu edited comment on HBASE-20845 at 7/5/18 4:58 AM:
Edit:
javac warning
[
https://issues.apache.org/jira/browse/HBASE-20845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533257#comment-16533257
]
Ted Yu commented on HBASE-20845:
Can you address javac warning ?
Other than that, should be good to go
[
https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-9675:
--
Labels: filesystem (was: )
> Avoid FileInputStream/FileOutputStr
[
https://issues.apache.org/jira/browse/KAFKA-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533150#comment-16533150
]
Ted Yu commented on KAFKA-6904:
---
Haven't seen this failure lately.
> DynamicBrokerReconfigurationT
[
https://issues.apache.org/jira/browse/FLINK-9736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533106#comment-16533106
]
Ted Yu commented on FLINK-9736:
---
bq. we never call `poll()` on it.
What happens to the {{peek}} call when
[
https://issues.apache.org/jira/browse/FLINK-9735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533101#comment-16533101
]
Ted Yu edited comment on FLINK-9735 at 7/4/18 11:15 PM:
One improvement
[
https://issues.apache.org/jira/browse/FLINK-9735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533101#comment-16533101
]
Ted Yu commented on FLINK-9735:
---
One improvement is to differentiate the return type from the parameter
[
https://issues.apache.org/jira/browse/FLINK-9735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16532961#comment-16532961
]
Ted Yu commented on FLINK-9735:
---
I currently don't see what is wrong with the code in {{RocksDBResource
[
https://issues.apache.org/jira/browse/FLINK-9735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16532941#comment-16532941
]
Ted Yu commented on FLINK-9735:
---
Please take a look at RocksDBResource.java :
{code}
this(new
1701 - 1800 of 42210 matches
Mail list logo
